add plug for aggregate function

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

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 {

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 {

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 {

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 = `

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 = `

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 {

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 = `

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 = `

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 = `

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 {

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 = `

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 {

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

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 {

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 {

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) {

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

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"

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) {

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 {

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*\(`)

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 {

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 {

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"
 )
 

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

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

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 {

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

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 {

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 {

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) {

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

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"
 )
 

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 {

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 {