feat:support db Ping

connection.go

@@ -130,7 +130,7 @@ func (dc *DatabendConn) PrepareContext(ctx context.Context, query string) (drive
 	return dc.prepare(query)
 }
 
-func buildDatabendConn(ctx context.Context, config Config) (*DatabendConn, error) {
+func BuildDatabendConn(ctx context.Context, config Config) (*DatabendConn, error) {
 	dc := &DatabendConn{
 		ctx:  ctx,
 		cfg:  &config,
@@ -206,3 +206,11 @@ func (dc *DatabendConn) Rollback() error {
 	dc.Close()
 	return nil
 }
+
+func (dc *DatabendConn) Ping() error {
+	_, err := dc.Query("SELECT VERSION()", []driver.Value{})
+	if err != nil {
+		return err
+	}
+	return nil
+}

driver.go

@@ -28,7 +28,7 @@ func (d DatabendDriver) OpenWithConfig(
 	config Config) (
 	driver.Conn, error) {
 	logger.Info("OpenWithConfig")
-	dc, err := buildDatabendConn(ctx, config)
+	dc, err := BuildDatabendConn(ctx, config)
 	if err != nil {
 		return nil, err
 	}

stmt.go

@@ -3,14 +3,10 @@ package godatabend
 import (
 	"context"
 	"database/sql/driver"
-	"regexp"
 
-	ldriver "github.com/databendcloud/databend-go/lib/driver"
 	"github.com/pkg/errors"
-)
 
-var (
-	splitInsertRe = regexp.MustCompile(`(?si)(.+\s*VALUES)\s*(\(.+\))`)
+	ldriver "github.com/databendcloud/databend-go/lib/driver"
 )
 
 type databendStmt struct {

tests/main_test.go

@@ -1,9 +1,9 @@
 package tests
 
 import (
+	"context"
 	"database/sql"
 	"fmt"
-	"os"
 	"reflect"
 	"testing"
 	"time"
@@ -33,19 +33,25 @@ func TestDatabendSuite(t *testing.T) {
 
 type DatabendTestSuite struct {
 	suite.Suite
-	db    *sql.DB
-	table string
-	r     *require.Assertions
+	db           *sql.DB
+	databendConn *dc.DatabendConn
+	table        string
+	r            *require.Assertions
 }
 
 func (s *DatabendTestSuite) SetupSuite() {
 	var err error
 
-	dsn := os.Getenv("TEST_DATABEND_DSN")
+	//dsn := os.Getenv("TEST_DATABEND_DSN")
+	dsn := "http://databend:databend@localhost:8000/default?sslmode=disable"
 	s.NotEmpty(dsn)
 
 	s.db, err = sql.Open("databend", dsn)
 	s.Nil(err)
+	cfg, err := dc.ParseDSN(dsn)
+	s.Nil(err)
+	s.databendConn, err = dc.BuildDatabendConn(context.TODO(), *cfg)
+	s.Nil(err)
 
 	err = s.db.Ping()
 	s.Nil(err)
@@ -80,13 +86,18 @@ func (s *DatabendTestSuite) TearDownTest() {
 	s.r.Nil(err)
 }
 
+func (s *DatabendTestSuite) TestPing() {
+	err := s.databendConn.Ping()
+	s.r.Nil(err)
+}
+
 func (s *DatabendTestSuite) TestDesc() {
 	rows, err := s.db.Query("DESC " + s.table)
 	s.r.Nil(err)
 
 	result, err := scanValues(rows)
 	s.r.Nil(err)
-	s.r.Equal([][]interface{}{[]interface{}{"i64", "BIGINT", "NO", "0", ""}, []interface{}{"u64", "BIGINT UNSIGNED", "NO", "0", ""}, []interface{}{"f64", "DOUBLE", "NO", "0", ""}, []interface{}{"s", "VARCHAR", "NO", "", ""}, []interface{}{"s2", "VARCHAR", "NO", "", ""}, []interface{}{"a16", "ARRAY(INT16)", "NO", "[]", ""}, []interface{}{"a8", "ARRAY(UINT8)", "NO", "[]", ""}, []interface{}{"d", "DATE", "NO", "", ""}, []interface{}{"t", "TIMESTAMP", "NO", "", ""}}, result)
+	s.r.Equal([][]interface{}{[]interface{}{"i64", "BIGINT", "YES", "NULL", ""}, []interface{}{"u64", "BIGINT UNSIGNED", "YES", "NULL", ""}, []interface{}{"f64", "DOUBLE", "YES", "NULL", ""}, []interface{}{"s", "VARCHAR", "YES", "NULL", ""}, []interface{}{"s2", "VARCHAR", "YES", "NULL", ""}, []interface{}{"a16", "ARRAY(INT16)", "YES", "NULL", ""}, []interface{}{"a8", "ARRAY(UINT8)", "YES", "NULL", ""}, []interface{}{"d", "DATE", "YES", "NULL", ""}, []interface{}{"t", "TIMESTAMP", "YES", "NULL", ""}}, result)
 	rows.Close()
 }
 
@@ -163,12 +174,12 @@ func (s *DatabendTestSuite) TestExec() {
 	}{
 		{
 			fmt.Sprintf("INSERT INTO %s (i64) VALUES (?)", s.table),
-			fmt.Sprintf("SELECT i64 FROM %s WHERE i64=?", s.table),
+			"",
 			[]interface{}{int64(1)},
 		},
 		{
 			fmt.Sprintf("INSERT INTO %s (i64, u64) VALUES (?, ?)", s.table),
-			fmt.Sprintf("SELECT i64, u64 FROM %s WHERE i64=? AND u64=?", s.table),
+			"",
 			[]interface{}{int64(2), uint64(12)},
 		},
 		{