add plug for aggregate function

when doing bulk insert into table with materialised column that has aggregatefunction type it errors since it's unknown type, add plug for that type so we can ignore it when inserting into specific columns
perfectscale · Feb 28, 2024 · e4e293f · e4e293f
1 parent 34af932
commit e4e293f
Show file tree

Hide file tree

Showing 250 changed files with 758 additions and 568 deletions.
diff --git a/README.md b/README.md
@@ -1,4 +1,4 @@
-# ClickHouse [![run-tests](https://github.com/ClickHouse/clickhouse-go/actions/workflows/run-tests.yml/badge.svg?branch=v2)](https://github.com/ClickHouse/clickhouse-go/actions/workflows/run-tests.yml) [![Go Reference](https://pkg.go.dev/badge/github.com/ClickHouse/clickhouse-go/v2.svg)](https://pkg.go.dev/github.com/ClickHouse/clickhouse-go/v2)
+# ClickHouse [![run-tests](https://github.com/ClickHouse/clickhouse-go/actions/workflows/run-tests.yml/badge.svg?branch=v2)](https://github.com/ClickHouse/clickhouse-go/actions/workflows/run-tests.yml) [![Go Reference](https://pkg.go.dev/badge/github.com/perfectscale/clickhouse-go/v2.svg)](https://pkg.go.dev/github.com/perfectscale/clickhouse-go/v2)
 
 Golang SQL database client for [ClickHouse](https://clickhouse.com/).
 
@@ -306,7 +306,7 @@ Available options:
 ## Install
 
 ```sh
-go get -u github.com/ClickHouse/clickhouse-go/v2
+go get -u github.com/perfectscale/clickhouse-go/v2
 ```
 
 ## Examples

diff --git a/benchmark/v2/read-native/basic_test.go b/benchmark/v2/read-native/basic_test.go
@@ -20,10 +20,11 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2"
 	"log"
 	"testing"
 	"time"
+
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 func getConnection() clickhouse.Conn {

diff --git a/benchmark/v2/read-native/main.go b/benchmark/v2/read-native/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 func benchmarkRead(conn clickhouse.Conn) error {

diff --git a/benchmark/v2/read/main.go b/benchmark/v2/read/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	_ "github.com/ClickHouse/clickhouse-go/v2"
+	_ "github.com/perfectscale/clickhouse-go/v2"
 )
 
 func benchmarkRead(conn *sql.DB) error {

diff --git a/benchmark/v2/write-async-std/main.go b/benchmark/v2/write-async-std/main.go
@@ -24,7 +24,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/benchmark/v2/write-async/main.go b/benchmark/v2/write-async/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/benchmark/v2/write-compress-buffer-limit/write_test.go b/benchmark/v2/write-compress-buffer-limit/write_test.go
@@ -20,11 +20,12 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2"
 	"log"
 	"runtime"
 	"testing"
 	"time"
+
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 func bToMb(b uint64) uint64 {

diff --git a/benchmark/v2/write-native-columnar/main.go b/benchmark/v2/write-native-columnar/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/benchmark/v2/write-native-struct/main.go b/benchmark/v2/write-native-struct/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/benchmark/v2/write-native/main.go b/benchmark/v2/write-native/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2"
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/benchmark/v2/write-native/write_test.go b/benchmark/v2/write-native/write_test.go
@@ -19,10 +19,11 @@ package main
 
 import (
 	"context"
-	"github.com/ClickHouse/clickhouse-go/v2"
 	"log"
 	"testing"
 	"time"
+
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 func getConnection() clickhouse.Conn {

diff --git a/benchmark/v2/write/main.go b/benchmark/v2/write/main.go
@@ -23,7 +23,7 @@ import (
 	"log"
 	"time"
 
-	_ "github.com/ClickHouse/clickhouse-go/v2"
+	_ "github.com/perfectscale/clickhouse-go/v2"
 )
 
 const ddl = `

diff --git a/bind.go b/bind.go
@@ -25,8 +25,8 @@ import (
 	"strings"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	"github.com/perfectscale/clickhouse-go/v2/lib/driver"
 )
 
 func Named(name string, value any) driver.NamedValue {

diff --git a/clickhouse.go b/clickhouse.go
@@ -27,10 +27,10 @@ import (
 	_ "time/tzdata"
 
 	chproto "github.com/ClickHouse/ch-go/proto"
-	"github.com/ClickHouse/clickhouse-go/v2/contributors"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/contributors"
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	"github.com/perfectscale/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 type Conn = driver.Conn

diff --git a/clickhouse_rows.go b/clickhouse_rows.go
@@ -21,7 +21,7 @@ import (
 	"database/sql"
 	"io"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 type rows struct {

diff --git a/clickhouse_rows_column_type.go b/clickhouse_rows_column_type.go
@@ -20,8 +20,8 @@ package clickhouse
 import (
 	"reflect"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	"github.com/perfectscale/clickhouse-go/v2/lib/driver"
 )
 
 type columnType struct {

diff --git a/clickhouse_rows_test.go b/clickhouse_rows_test.go
@@ -1,10 +1,11 @@
 package clickhouse
 
 import (
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
-	"github.com/stretchr/testify/assert"
 	"strconv"
 	"testing"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestReadWithEmptyBlock(t *testing.T) {

diff --git a/clickhouse_std.go b/clickhouse_std.go
@@ -31,8 +31,8 @@ import (
 	"sync/atomic"
 	"syscall"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	ldriver "github.com/ClickHouse/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	ldriver "github.com/perfectscale/clickhouse-go/v2/lib/driver"
 )
 
 var globalConnID int64

diff --git a/client_info.go b/client_info.go
@@ -19,10 +19,11 @@ package clickhouse
 
 import (
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"runtime"
 	"sort"
 	"strings"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 const ClientName = "clickhouse-go"

diff --git a/conn.go b/conn.go
@@ -28,12 +28,12 @@ import (
 	"syscall"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/resources"
+	"github.com/perfectscale/clickhouse-go/v2/resources"
 	"github.com/pkg/errors"
 
 	"github.com/ClickHouse/ch-go/compress"
 	chproto "github.com/ClickHouse/ch-go/proto"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 func dial(ctx context.Context, addr string, num int, opt *Options) (*connect, error) {

diff --git a/conn_async_insert.go b/conn_async_insert.go
@@ -19,7 +19,8 @@ package clickhouse
 
 import (
 	"context"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 func (c *connect) asyncInsert(ctx context.Context, query string, wait bool, args ...any) error {

diff --git a/conn_batch.go b/conn_batch.go
@@ -27,9 +27,9 @@ import (
 
 	"github.com/pkg/errors"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	"github.com/perfectscale/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 var splitInsertRe = regexp.MustCompile(`(?i)\sVALUES\s*\(`)

diff --git a/conn_exec.go b/conn_exec.go
@@ -19,8 +19,9 @@ package clickhouse
 
 import (
 	"context"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"time"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 func (c *connect) exec(ctx context.Context, query string, args ...any) error {

diff --git a/conn_handshake.go b/conn_handshake.go
@@ -22,7 +22,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 func (c *connect) handshake(database, username, password string) error {

diff --git a/conn_http.go b/conn_http.go
@@ -37,12 +37,12 @@ import (
 	"sync"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/resources"
+	"github.com/perfectscale/clickhouse-go/v2/resources"
 
 	"github.com/ClickHouse/ch-go/compress"
 	chproto "github.com/ClickHouse/ch-go/proto"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"github.com/andybalholm/brotli"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 	"github.com/pkg/errors"
 )
 

diff --git a/conn_http_batch.go b/conn_http_batch.go
@@ -21,13 +21,14 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"io"
 	"io/ioutil"
 	"regexp"
 	"strings"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/column"
+	"github.com/perfectscale/clickhouse-go/v2/lib/driver"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 // \x60 represents a backtick

diff --git a/conn_http_query.go b/conn_http_query.go
@@ -21,9 +21,10 @@ import (
 	"bytes"
 	"context"
 	"errors"
-	chproto "github.com/ClickHouse/ch-go/proto"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"io"
+
+	chproto "github.com/ClickHouse/ch-go/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 // release is ignored, because http used by std with empty release function

diff --git a/conn_logs.go b/conn_logs.go
@@ -21,7 +21,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 type Log struct {

diff --git a/conn_ping.go b/conn_ping.go
@@ -22,7 +22,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 // Connection::ping

diff --git a/conn_process.go b/conn_process.go
@@ -20,8 +20,9 @@ package clickhouse
 import (
 	"context"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
 	"io"
+
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 type onProcess struct {

diff --git a/conn_profile_events.go b/conn_profile_events.go
@@ -22,7 +22,7 @@ import (
 	"reflect"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 type ProfileEvent struct {

diff --git a/conn_query.go b/conn_query.go
@@ -21,7 +21,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 func (c *connect) query(ctx context.Context, release func(*connect, error), query string, args ...any) (*rows, error) {

diff --git a/conn_send_query.go b/conn_send_query.go
@@ -18,7 +18,7 @@
 package clickhouse
 
 import (
-	"github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/perfectscale/clickhouse-go/v2/lib/proto"
 )
 
 // Connection::sendQuery

diff --git a/context.go b/context.go
@@ -21,7 +21,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/ClickHouse/clickhouse-go/v2/ext"
+	"github.com/perfectscale/clickhouse-go/v2/ext"
 	"go.opentelemetry.io/otel/trace"
 )
 

diff --git a/examples/clickhouse_api/async.go b/examples/clickhouse_api/async.go
@@ -19,7 +19,8 @@ package clickhouse_api
 
 import (
 	"context"
-	clickhouse_tests "github.com/ClickHouse/clickhouse-go/v2/tests"
+
+	clickhouse_tests "github.com/perfectscale/clickhouse-go/v2/tests"
 )
 
 func AsyncInsert() error {

diff --git a/examples/clickhouse_api/auth.go b/examples/clickhouse_api/auth.go
@@ -19,7 +19,8 @@ package clickhouse_api
 
 import (
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2"
+
+	"github.com/perfectscale/clickhouse-go/v2"
 )
 
 func Auth() error {
-Original file line number
+Diff line change
@@ Expand Up / @@ -23,7 +23,7 @@ import ( @@
     	"log"
     	"time"
-    	"github.com/ClickHouse/clickhouse-go/v2"
+    	"github.com/perfectscale/clickhouse-go/v2"
     )
     func benchmarkRead(conn clickhouse.Conn) error {
@@ Expand Down @@