Feature/support json column type (#20)

* refactor to proton go driver
* support json type column

bind.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	std_driver "database/sql/driver"

bind_test.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"testing"

clickhouse.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"
@@ -40,10 +40,10 @@ type (
 )
 
 var (
-	ErrBatchAlreadySent               = errors.New("clickhouse: batch has already been sent")
-	ErrAcquireConnTimeout             = errors.New("clickhouse: acquire conn timeout. you can increase the number of max open conn or the dial timeout")
-	ErrUnsupportedServerRevision      = errors.New("clickhouse: unsupported server revision")
-	ErrBindMixedNamedAndNumericParams = errors.New("clickhouse [bind]: mixed named and numeric parameters")
+	ErrBatchAlreadySent               = errors.New("proton: batch has already been sent")
+	ErrAcquireConnTimeout             = errors.New("proton: acquire conn timeout. you can increase the number of max open conn or the dial timeout")
+	ErrUnsupportedServerRevision      = errors.New("proton: unsupported server revision")
+	ErrBindMixedNamedAndNumericParams = errors.New("proton [bind]: mixed named and numeric parameters")
 )
 
 type OpError struct {
@@ -55,46 +55,46 @@ type OpError struct {
 func (e *OpError) Error() string {
 	switch err := e.Err.(type) {
 	case *column.Error:
-		return fmt.Sprintf("clickhouse [%s]: (%s %s) %s", e.Op, e.ColumnName, err.ColumnType, err.Err)
+		return fmt.Sprintf("proton [%s]: (%s %s) %s", e.Op, e.ColumnName, err.ColumnType, err.Err)
 	case *column.ColumnConverterError:
 		var hint string
 		if len(err.Hint) != 0 {
 			hint += ". " + err.Hint
 		}
-		return fmt.Sprintf("clickhouse [%s]: (%s) converting %s to %s is unsupported%s",
+		return fmt.Sprintf("proton [%s]: (%s) converting %s to %s is unsupported%s",
 			err.Op, e.ColumnName,
 			err.From, err.To,
 			hint,
 		)
 	}
-	return fmt.Sprintf("clickhouse [%s]: %s", e.Op, e.Err)
+	return fmt.Sprintf("proton [%s]: %s", e.Op, e.Err)
 }
 
 func Open(opt *Options) (driver.Conn, error) {
 	opt.setDefaults()
-	return &clickhouse{
+	return &proton{
 		opt:  opt,
 		idle: make(chan *connect, opt.MaxIdleConns),
 		open: make(chan struct{}, opt.MaxOpenConns),
 	}, nil
 }
 
-type clickhouse struct {
+type proton struct {
 	opt    *Options
 	idle   chan *connect
 	open   chan struct{}
 	connID int64
 }
 
-func (clickhouse) Contributors() []string {
+func (proton) Contributors() []string {
 	list := contributors.List
 	if len(list[len(list)-1]) == 0 {
 		return list[:len(list)-1]
 	}
 	return list
 }
 
-func (ch *clickhouse) ServerVersion() (*driver.ServerVersion, error) {
+func (ch *proton) ServerVersion() (*driver.ServerVersion, error) {
 	var (
 		ctx, cancel = context.WithTimeout(context.Background(), ch.opt.DialTimeout)
 		conn, err   = ch.acquire(ctx)
@@ -107,15 +107,15 @@ func (ch *clickhouse) ServerVersion() (*driver.ServerVersion, error) {
 	return &conn.server, nil
 }
 
-func (ch *clickhouse) Query(ctx context.Context, query string, args ...interface{}) (rows driver.Rows, err error) {
+func (ch *proton) Query(ctx context.Context, query string, args ...interface{}) (rows driver.Rows, err error) {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return nil, err
 	}
 	return conn.query(ctx, ch.release, query, args...)
 }
 
-func (ch *clickhouse) QueryRow(ctx context.Context, query string, args ...interface{}) (rows driver.Row) {
+func (ch *proton) QueryRow(ctx context.Context, query string, args ...interface{}) (rows driver.Row) {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return &row{
@@ -125,7 +125,7 @@ func (ch *clickhouse) QueryRow(ctx context.Context, query string, args ...interf
 	return conn.queryRow(ctx, ch.release, query, args...)
 }
 
-func (ch *clickhouse) Exec(ctx context.Context, query string, args ...interface{}) error {
+func (ch *proton) Exec(ctx context.Context, query string, args ...interface{}) error {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return err
@@ -138,15 +138,15 @@ func (ch *clickhouse) Exec(ctx context.Context, query string, args ...interface{
 	return nil
 }
 
-func (ch *clickhouse) PrepareBatch(ctx context.Context, query string) (driver.Batch, error) {
+func (ch *proton) PrepareBatch(ctx context.Context, query string) (driver.Batch, error) {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return nil, err
 	}
 	return conn.prepareBatch(ctx, query, ch.release)
 }
 
-func (ch *clickhouse) AsyncInsert(ctx context.Context, query string, wait bool) error {
+func (ch *proton) AsyncInsert(ctx context.Context, query string, wait bool) error {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return err
@@ -159,7 +159,7 @@ func (ch *clickhouse) AsyncInsert(ctx context.Context, query string, wait bool)
 	return nil
 }
 
-func (ch *clickhouse) Ping(ctx context.Context) (err error) {
+func (ch *proton) Ping(ctx context.Context) (err error) {
 	conn, err := ch.acquire(ctx)
 	if err != nil {
 		return err
@@ -172,7 +172,7 @@ func (ch *clickhouse) Ping(ctx context.Context) (err error) {
 	return nil
 }
 
-func (ch *clickhouse) Stats() driver.Stats {
+func (ch *proton) Stats() driver.Stats {
 	return driver.Stats{
 		Open:         len(ch.open),
 		Idle:         len(ch.idle),
@@ -181,7 +181,7 @@ func (ch *clickhouse) Stats() driver.Stats {
 	}
 }
 
-func (ch *clickhouse) dial(ctx context.Context) (conn *connect, err error) {
+func (ch *proton) dial(ctx context.Context) (conn *connect, err error) {
 	connID := int(atomic.AddInt64(&ch.connID, 1))
 	for num := range ch.opt.Addr {
 		if ch.opt.ConnOpenStrategy == ConnOpenRoundRobin {
@@ -194,7 +194,7 @@ func (ch *clickhouse) dial(ctx context.Context) (conn *connect, err error) {
 	return nil, err
 }
 
-func (ch *clickhouse) acquire(ctx context.Context) (conn *connect, err error) {
+func (ch *proton) acquire(ctx context.Context) (conn *connect, err error) {
 	timer := time.NewTimer(ch.opt.DialTimeout)
 	defer timer.Stop()
 	select {
@@ -235,7 +235,7 @@ func (ch *clickhouse) acquire(ctx context.Context) (conn *connect, err error) {
 	return conn, nil
 }
 
-func (ch *clickhouse) release(conn *connect, err error) {
+func (ch *proton) release(conn *connect, err error) {
 	if conn.released {
 		return
 	}
@@ -255,7 +255,7 @@ func (ch *clickhouse) release(conn *connect, err error) {
 	}
 }
 
-func (ch *clickhouse) Close() error {
+func (ch *proton) Close() error {
 	for {
 		select {
 		case c := <-ch.idle:

clickhouse_options.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"
@@ -104,7 +104,7 @@ func (o *Options) fromDSN(in string) error {
 		case "dial_timeout":
 			duration, err := time.ParseDuration(params.Get(v))
 			if err != nil {
-				return fmt.Errorf("clickhouse [dsn parse]: dial timeout: %s", err)
+				return fmt.Errorf("proton [dsn parse]: dial timeout: %s", err)
 			}
 			o.DialTimeout = duration
 		case "secure":

clickhouse_rows.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"database/sql"

clickhouse_rows_column_type.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"reflect"

clickhouse_std.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"
@@ -64,7 +64,7 @@ func (o *stdConnOpener) Connect(ctx context.Context) (_ driver.Conn, err error)
 }
 
 func init() {
-	sql.Register("clickhouse", &stdDriver{})
+	sql.Register("proton", &stdDriver{})
 }
 
 func OpenDB(opt *Options) *sql.DB {
@@ -134,7 +134,7 @@ func (std *stdDriver) CheckNamedValue(nv *driver.NamedValue) error { return nil
 func (std *stdDriver) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error) {
 	if options := queryOptions(ctx); options.async.ok {
 		if len(args) != 0 {
-			return nil, errors.New("clickhouse: you can't use parameters in an asynchronous insert")
+			return nil, errors.New("proton: you can't use parameters in an asynchronous insert")
 		}
 		return driver.RowsAffected(0), std.conn.asyncInsert(ctx, query, options.async.wait)
 	}

conn.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"
@@ -53,7 +53,7 @@ func dial(ctx context.Context, addr string, num int, opt *Options) (*connect, er
 		return nil, err
 	}
 	if opt.Debug {
-		debugf = log.New(os.Stdout, fmt.Sprintf("[clickhouse][conn=%d][%s]", num, conn.RemoteAddr()), 0).Printf
+		debugf = log.New(os.Stdout, fmt.Sprintf("[proton][conn=%d][%s]", num, conn.RemoteAddr()), 0).Printf
 	}
 	var compression bool
 	if opt.Compression != nil {

conn_async_insert.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_batch.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_check.go

@@ -18,7 +18,7 @@
 //go:build linux || darwin || dragonfly || freebsd || netbsd || openbsd || solaris || illumos
 // +build linux darwin dragonfly freebsd netbsd openbsd solaris illumos
 
-package clickhouse
+package proton
 
 import (
 	"errors"

conn_check_ping.go

@@ -18,7 +18,7 @@
 //go:build !linux && !darwin && !dragonfly && !freebsd && !netbsd && !openbsd && !solaris && !illumos
 // +build !linux,!darwin,!dragonfly,!freebsd,!netbsd,!openbsd,!solaris,!illumos
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_exec.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_handshake.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"fmt"

conn_logs.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"time"

conn_ping.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_process.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_profile_events.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"reflect"

conn_query.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"

conn_send_query.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"github.com/timeplus-io/proton-go-driver/v2/lib/proto"

context.go

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package clickhouse
+package proton
 
 import (
 	"context"