From 0141a4527f0dfd5cdf94bba8dd2e0a61a6a26959 Mon Sep 17 00:00:00 2001 From: godLei6 <603785348@qq.com> Date: Tue, 3 Sep 2024 14:14:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=9B=B4=E6=8D=A2=E6=A8=A1=E5=9D=97?= =?UTF-8?q?=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README-CN.md | 20 ++++++++++---------- README.md | 20 ++++++++++---------- af/async/handler.go | 2 +- af/conn.go | 18 +++++++++--------- af/conn_test.go | 6 +++--- af/insertstmt/stmt.go | 8 ++++---- af/insertstmt/stmt_test.go | 8 ++++---- af/locker/locker.go | 2 +- af/rows.go | 12 ++++++------ af/stmt.go | 10 +++++----- af/stmt_test.go | 4 ++-- af/tmq/config.go | 4 ++-- af/tmq/config_test.go | 2 +- af/tmq/consumer.go | 10 +++++----- af/tmq/consumer_test.go | 6 +++--- bench/driver/compare.go | 4 ++-- bench/query/main.go | 2 +- bench/sql_test.go | 2 +- bench/standard/executor/test.go | 4 ++-- bench/standard/native/exec/write.go | 2 +- bench/standard/native/query/read.go | 2 +- bench/standard/restful/exec/write.go | 2 +- bench/standard/restful/query/read.go | 2 +- bench/stmt/insert/main.go | 8 ++++---- bench/stmt/query/main.go | 8 ++++---- bench/test/tmq/multiinsert.go | 8 ++++---- bench/tmq/main.go | 8 ++++---- bench/valgrind/main.go | 2 +- benchmark/benchmark.go | 2 +- common/column.go | 2 +- common/param/column.go | 2 +- common/param/column_test.go | 2 +- common/param/param.go | 2 +- common/param/param_test.go | 2 +- common/parser/block.go | 4 ++-- common/parser/block_test.go | 8 ++++---- common/parser/raw.go | 2 +- common/reqid.go | 2 +- common/serializer/block.go | 6 +++--- common/serializer/block_test.go | 2 +- common/stmt/field.go | 4 ++-- common/stmt/field_test.go | 4 ++-- common/tmq/event.go | 2 +- common/tmq/event_test.go | 2 +- examples/platform/main.go | 4 ++-- examples/restful/main.go | 2 +- examples/schemaless/influx/main.go | 2 +- examples/schemaless/json/main.go | 2 +- examples/schemaless/telnet/main.go | 2 +- examples/sqlstmt/main.go | 2 +- examples/stmtinsert/main.go | 6 +++--- examples/stmtoverws/main.go | 8 ++++---- examples/taosSql/main.go | 2 +- examples/taosWS/main.go | 2 +- examples/tmq/main.go | 6 +++--- examples/tmqoverws/main.go | 8 ++++---- go.mod | 2 +- taosRestful/connection.go | 4 ++-- taosRestful/connector.go | 2 +- taosRestful/connector_test.go | 2 +- taosRestful/dsn.go | 2 +- taosRestful/rows.go | 2 +- taosSql/connection.go | 8 ++++---- taosSql/connection_test.go | 2 +- taosSql/connector.go | 6 +++--- taosSql/driver.go | 4 ++-- taosSql/dsn.go | 2 +- taosSql/rows.go | 8 ++++---- taosSql/statement.go | 10 +++++----- taosWS/connection.go | 22 +++++++++++++++++----- taosWS/connector.go | 2 +- taosWS/connector_test.go | 2 +- taosWS/dsn.go | 2 +- taosWS/proto.go | 2 +- taosWS/rows.go | 6 +++--- taosWS/statement.go | 10 +++++----- types/types.go | 2 +- wrapper/asynccb.go | 2 +- wrapper/block_test.go | 4 ++-- wrapper/field.go | 4 ++-- wrapper/field_test.go | 4 ++-- wrapper/handler/handlerpool.go | 2 +- wrapper/notify.go | 2 +- wrapper/notify_test.go | 4 ++-- wrapper/notifycb.go | 4 ++-- wrapper/row.go | 4 ++-- wrapper/row_test.go | 2 +- wrapper/schemaless_test.go | 4 ++-- wrapper/setconfig.go | 2 +- wrapper/stmt.go | 8 ++++---- wrapper/stmt_test.go | 12 ++++++------ wrapper/taosc.go | 6 +++--- wrapper/taosc_test.go | 8 ++++---- wrapper/tmq.go | 8 ++++---- wrapper/tmq_test.go | 10 +++++----- wrapper/tmqcb.go | 2 +- wrapper/whitelist.go | 2 +- wrapper/whitelist_test.go | 2 +- wrapper/whitelistcb.go | 2 +- ws/client/conn.go | 2 +- ws/schemaless/schemaless.go | 6 +++--- ws/schemaless/schemaless_test.go | 4 ++-- ws/stmt/connector.go | 6 +++--- ws/stmt/rows.go | 10 +++++----- ws/stmt/stmt.go | 8 ++++---- ws/stmt/stmt_test.go | 8 ++++---- ws/tmq/consumer.go | 10 +++++----- ws/tmq/consumer_test.go | 8 ++++---- ws/tmq/proto.go | 2 +- 109 files changed, 278 insertions(+), 266 deletions(-) diff --git a/README-CN.md b/README-CN.md index 9ebdaf6..02addd6 100644 --- a/README-CN.md +++ b/README-CN.md @@ -39,7 +39,7 @@ go mod init taos-demo ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) ``` @@ -52,7 +52,7 @@ go mod tidy 或通过 `go get` 直接下载安装： ```sh -go get github.com/taosdata/driver-go/v3/taosSql +go get github.com/i-Things/driver-go/v3/taosSql ``` ## 用法 @@ -69,7 +69,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) func main() { @@ -287,7 +287,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) func main() { @@ -334,7 +334,7 @@ func main() { ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) ``` @@ -370,7 +370,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) func main() { @@ -422,7 +422,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosWS" + _ "github.com/i-Things/driver-go/v3/taosWS" ) func main() { @@ -469,7 +469,7 @@ func main() { ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosWS" + _ "github.com/i-Things/driver-go/v3/taosWS" ) ``` @@ -672,6 +672,6 @@ driver-go ## 导航 -driver-go: [https://github.com/taosdata/driver-go](https://github.com/taosdata/driver-go) +driver-go: [https://github.com/i-Things/driver-go](https://github.com/i-Things/driver-go) -TDengine: [https://github.com/taosdata/TDengine](https://github.com/taosdata/TDengine) +TDengine: [https://github.com/i-Things/TDengine](https://github.com/i-Things/TDengine) diff --git a/README.md b/README.md index d0e1ba7..05f1b61 100644 --- a/README.md +++ b/README.md @@ -40,7 +40,7 @@ import taosSql： ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) ``` @@ -53,7 +53,7 @@ go mod tidy Or `go get` to directly install it: ```sh -go get github.com/taosdata/driver-go/v3/taosSql +go get github.com/i-Things/driver-go/v3/taosSql ``` ## Usage @@ -70,7 +70,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) func main() { @@ -285,7 +285,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) func main() { @@ -332,7 +332,7 @@ import ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) ``` @@ -371,7 +371,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) func main() { @@ -423,7 +423,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosWS" + _ "github.com/i-Things/driver-go/v3/taosWS" ) func main() { @@ -470,7 +470,7 @@ import ```go import ( "database/sql" - _ "github.com/taosdata/driver-go/v3/taosWS" + _ "github.com/i-Things/driver-go/v3/taosWS" ) ``` @@ -675,6 +675,6 @@ driver-go ## Link -driver-go: [https://github.com/taosdata/driver-go](https://github.com/taosdata/driver-go) +driver-go: [https://github.com/i-Things/driver-go](https://github.com/i-Things/driver-go) -TDengine: [https://github.com/taosdata/TDengine](https://github.com/taosdata/TDengine) +TDengine: [https://github.com/i-Things/TDengine](https://github.com/i-Things/TDengine) diff --git a/af/async/handler.go b/af/async/handler.go index 75979da..0941b07 100644 --- a/af/async/handler.go +++ b/af/async/handler.go @@ -3,7 +3,7 @@ package async import ( "sync" - "github.com/taosdata/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/wrapper/handler" ) const defaultPoolSize = 10000 diff --git a/af/conn.go b/af/conn.go index 77a253f..4214a7d 100644 --- a/af/conn.go +++ b/af/conn.go @@ -5,15 +5,15 @@ import ( "database/sql/driver" "unsafe" - "github.com/taosdata/driver-go/v3/af/async" - "github.com/taosdata/driver-go/v3/af/insertstmt" - "github.com/taosdata/driver-go/v3/af/locker" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/errors" - taosError "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/af/async" + "github.com/i-Things/driver-go/v3/af/insertstmt" + "github.com/i-Things/driver-go/v3/af/locker" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/errors" + taosError "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/handler" ) type Connector struct { diff --git a/af/conn_test.go b/af/conn_test.go index 354771a..4d850f1 100644 --- a/af/conn_test.go +++ b/af/conn_test.go @@ -7,10 +7,10 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common" + param2 "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/wrapper" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - param2 "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/wrapper" ) func TestMain(m *testing.M) { diff --git a/af/insertstmt/stmt.go b/af/insertstmt/stmt.go index d764560..14be906 100644 --- a/af/insertstmt/stmt.go +++ b/af/insertstmt/stmt.go @@ -5,10 +5,10 @@ import ( "errors" "unsafe" - "github.com/taosdata/driver-go/v3/af/locker" - "github.com/taosdata/driver-go/v3/common/param" - taosError "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/af/locker" + "github.com/i-Things/driver-go/v3/common/param" + taosError "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) type InsertStmt struct { diff --git a/af/insertstmt/stmt_test.go b/af/insertstmt/stmt_test.go index 0b50f39..523cf5e 100644 --- a/af/insertstmt/stmt_test.go +++ b/af/insertstmt/stmt_test.go @@ -5,11 +5,11 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + taosError "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - taosError "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" ) func prepareEnv(conn unsafe.Pointer) error { diff --git a/af/locker/locker.go b/af/locker/locker.go index 938c24d..fd8d52c 100644 --- a/af/locker/locker.go +++ b/af/locker/locker.go @@ -4,7 +4,7 @@ import ( "runtime" "sync" - "github.com/taosdata/driver-go/v3/wrapper/thread" + "github.com/i-Things/driver-go/v3/wrapper/thread" ) var locker *thread.Locker diff --git a/af/rows.go b/af/rows.go index 75aaa82..5779f94 100644 --- a/af/rows.go +++ b/af/rows.go @@ -6,12 +6,12 @@ import ( "reflect" "unsafe" - "github.com/taosdata/driver-go/v3/af/async" - "github.com/taosdata/driver-go/v3/af/locker" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/af/async" + "github.com/i-Things/driver-go/v3/af/locker" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/handler" ) type rows struct { diff --git a/af/stmt.go b/af/stmt.go index dbe849b..e981b6e 100644 --- a/af/stmt.go +++ b/af/stmt.go @@ -6,11 +6,11 @@ import ( "fmt" "unsafe" - "github.com/taosdata/driver-go/v3/af/async" - "github.com/taosdata/driver-go/v3/af/locker" - "github.com/taosdata/driver-go/v3/common/param" - taosError "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/af/async" + "github.com/i-Things/driver-go/v3/af/locker" + "github.com/i-Things/driver-go/v3/common/param" + taosError "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) type Stmt struct { diff --git a/af/stmt_test.go b/af/stmt_test.go index 6a23e9f..e1bdf82 100644 --- a/af/stmt_test.go +++ b/af/stmt_test.go @@ -6,9 +6,9 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" ) func TestNewStmt(t *testing.T) { diff --git a/af/tmq/config.go b/af/tmq/config.go index f037c46..e667b29 100644 --- a/af/tmq/config.go +++ b/af/tmq/config.go @@ -3,8 +3,8 @@ package tmq import ( "unsafe" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) type config struct { diff --git a/af/tmq/config_test.go b/af/tmq/config_test.go index f6c383e..363e7d8 100644 --- a/af/tmq/config_test.go +++ b/af/tmq/config_test.go @@ -3,7 +3,7 @@ package tmq import ( "testing" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper" ) // @author: xftan diff --git a/af/tmq/consumer.go b/af/tmq/consumer.go index aab447c..34d3a1a 100644 --- a/af/tmq/consumer.go +++ b/af/tmq/consumer.go @@ -4,12 +4,12 @@ import ( "errors" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/common/tmq" + taosError "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/common/tmq" - taosError "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" ) type Consumer struct { diff --git a/af/tmq/consumer_test.go b/af/tmq/consumer_test.go index 47252b7..03b73f5 100644 --- a/af/tmq/consumer_test.go +++ b/af/tmq/consumer_test.go @@ -7,10 +7,10 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common/tmq" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common/tmq" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" ) // @author: xftan diff --git a/bench/driver/compare.go b/bench/driver/compare.go index 39d4874..8d617c7 100644 --- a/bench/driver/compare.go +++ b/bench/driver/compare.go @@ -5,8 +5,8 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosSql" ) var cdb *sql.DB diff --git a/bench/query/main.go b/bench/query/main.go index d316359..387b294 100644 --- a/bench/query/main.go +++ b/bench/query/main.go @@ -5,7 +5,7 @@ import ( "encoding/json" "fmt" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) var ( diff --git a/bench/sql_test.go b/bench/sql_test.go index 50c7287..084eb69 100644 --- a/bench/sql_test.go +++ b/bench/sql_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) var ( diff --git a/bench/standard/executor/test.go b/bench/standard/executor/test.go index 68c80f5..a8e0a44 100644 --- a/bench/standard/executor/test.go +++ b/bench/standard/executor/test.go @@ -9,8 +9,8 @@ import ( "strconv" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosSql" ) type TDTest struct { diff --git a/bench/standard/native/exec/write.go b/bench/standard/native/exec/write.go index d85b0b7..6e9227e 100644 --- a/bench/standard/native/exec/write.go +++ b/bench/standard/native/exec/write.go @@ -4,7 +4,7 @@ import ( "fmt" "time" - "github.com/taosdata/driver-go/v3/bench/standard/executor" + "github.com/i-Things/driver-go/v3/bench/standard/executor" ) func main() { diff --git a/bench/standard/native/query/read.go b/bench/standard/native/query/read.go index 3c4b3e2..cb55b44 100644 --- a/bench/standard/native/query/read.go +++ b/bench/standard/native/query/read.go @@ -1,6 +1,6 @@ package main -import "github.com/taosdata/driver-go/v3/bench/standard/executor" +import "github.com/i-Things/driver-go/v3/bench/standard/executor" func main() { test := executor.NewTDTest(executor.DefaultNativeDriverName, executor.DefaultNativeDSN) diff --git a/bench/standard/restful/exec/write.go b/bench/standard/restful/exec/write.go index 7d9486d..528f41a 100644 --- a/bench/standard/restful/exec/write.go +++ b/bench/standard/restful/exec/write.go @@ -4,7 +4,7 @@ import ( "fmt" "time" - "github.com/taosdata/driver-go/v3/bench/standard/executor" + "github.com/i-Things/driver-go/v3/bench/standard/executor" ) func main() { diff --git a/bench/standard/restful/query/read.go b/bench/standard/restful/query/read.go index bd41c4c..24839b7 100644 --- a/bench/standard/restful/query/read.go +++ b/bench/standard/restful/query/read.go @@ -1,6 +1,6 @@ package main -import "github.com/taosdata/driver-go/v3/bench/standard/executor" +import "github.com/i-Things/driver-go/v3/bench/standard/executor" func main() { test := executor.NewTDTest(executor.DefaultRestfulDriverName, executor.DefaultRestfulDSN) diff --git a/bench/stmt/insert/main.go b/bench/stmt/insert/main.go index 72cf0fc..2afd9d6 100644 --- a/bench/stmt/insert/main.go +++ b/bench/stmt/insert/main.go @@ -8,10 +8,10 @@ import ( _ "net/http/pprof" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) func main() { diff --git a/bench/stmt/query/main.go b/bench/stmt/query/main.go index 78c7ea5..255f36c 100644 --- a/bench/stmt/query/main.go +++ b/bench/stmt/query/main.go @@ -8,10 +8,10 @@ import ( _ "net/http/pprof" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) func main() { diff --git a/bench/test/tmq/multiinsert.go b/bench/test/tmq/multiinsert.go index 547dd4b..351bc65 100644 --- a/bench/test/tmq/multiinsert.go +++ b/bench/test/tmq/multiinsert.go @@ -7,10 +7,10 @@ import ( _ "net/http/pprof" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) func main() { diff --git a/bench/tmq/main.go b/bench/tmq/main.go index 79faed0..6a6fce1 100644 --- a/bench/tmq/main.go +++ b/bench/tmq/main.go @@ -5,10 +5,10 @@ import ( "log" "time" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) func main() { diff --git a/bench/valgrind/main.go b/bench/valgrind/main.go index e1ef8b6..779a9b6 100644 --- a/bench/valgrind/main.go +++ b/bench/valgrind/main.go @@ -6,7 +6,7 @@ import ( "log" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) var ( diff --git a/benchmark/benchmark.go b/benchmark/benchmark.go index 5d69e79..8c85a43 100644 --- a/benchmark/benchmark.go +++ b/benchmark/benchmark.go @@ -10,7 +10,7 @@ import ( "math/rand" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) const ( diff --git a/common/column.go b/common/column.go index aad229c..9aaa61b 100644 --- a/common/column.go +++ b/common/column.go @@ -3,7 +3,7 @@ package common import ( "reflect" - "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/types" ) var ( diff --git a/common/param/column.go b/common/param/column.go index 1542f70..d901bea 100644 --- a/common/param/column.go +++ b/common/param/column.go @@ -3,7 +3,7 @@ package param import ( "fmt" - "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/types" ) type ColumnType struct { diff --git a/common/param/column_test.go b/common/param/column_test.go index a684a8c..57da3b5 100644 --- a/common/param/column_test.go +++ b/common/param/column_test.go @@ -3,8 +3,8 @@ package param import ( "testing" + "github.com/i-Things/driver-go/v3/types" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/types" ) func TestColumnType_AddBool(t *testing.T) { diff --git a/common/param/param.go b/common/param/param.go index cce09d0..6fed858 100644 --- a/common/param/param.go +++ b/common/param/param.go @@ -4,7 +4,7 @@ import ( "database/sql/driver" "time" - taosTypes "github.com/taosdata/driver-go/v3/types" + taosTypes "github.com/i-Things/driver-go/v3/types" ) type Param struct { diff --git a/common/param/param_test.go b/common/param/param_test.go index 8bf3a18..d779d37 100644 --- a/common/param/param_test.go +++ b/common/param/param_test.go @@ -5,8 +5,8 @@ import ( "testing" "time" + taosTypes "github.com/i-Things/driver-go/v3/types" "github.com/stretchr/testify/assert" - taosTypes "github.com/taosdata/driver-go/v3/types" ) func TestParam_SetBool(t *testing.T) { diff --git a/common/parser/block.go b/common/parser/block.go index dd7dfa1..d4eca4f 100644 --- a/common/parser/block.go +++ b/common/parser/block.go @@ -6,8 +6,8 @@ import ( "unicode/utf8" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/pointer" ) const ( diff --git a/common/parser/block_test.go b/common/parser/block_test.go index 42b2d26..2fb0e87 100644 --- a/common/parser/block_test.go +++ b/common/parser/block_test.go @@ -7,11 +7,11 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/pointer" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" ) // @author: xftan diff --git a/common/parser/raw.go b/common/parser/raw.go index 61ad125..5131b6b 100644 --- a/common/parser/raw.go +++ b/common/parser/raw.go @@ -4,7 +4,7 @@ import ( "fmt" "unsafe" - "github.com/taosdata/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/common/pointer" ) type TMQRawDataParser struct { diff --git a/common/reqid.go b/common/reqid.go index 02f1c72..b135456 100644 --- a/common/reqid.go +++ b/common/reqid.go @@ -8,7 +8,7 @@ import ( "unsafe" "github.com/google/uuid" - "github.com/taosdata/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/common/pointer" ) var tUUIDHashId int64 diff --git a/common/serializer/block.go b/common/serializer/block.go index 50d7a6e..5b3c806 100644 --- a/common/serializer/block.go +++ b/common/serializer/block.go @@ -5,9 +5,9 @@ import ( "errors" "math" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - taosTypes "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + taosTypes "github.com/i-Things/driver-go/v3/types" ) const ( diff --git a/common/serializer/block_test.go b/common/serializer/block_test.go index c59d988..58f5dcd 100644 --- a/common/serializer/block_test.go +++ b/common/serializer/block_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - "github.com/taosdata/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/common/param" ) // @author: xftan diff --git a/common/stmt/field.go b/common/stmt/field.go index 20c51b9..b27409d 100644 --- a/common/stmt/field.go +++ b/common/stmt/field.go @@ -3,8 +3,8 @@ package stmt import ( "fmt" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/types" ) type StmtField struct { diff --git a/common/stmt/field_test.go b/common/stmt/field_test.go index d50678b..c5b4c7c 100644 --- a/common/stmt/field_test.go +++ b/common/stmt/field_test.go @@ -3,8 +3,8 @@ package stmt import ( "testing" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/types" ) func TestGetType(t *testing.T) { diff --git a/common/tmq/event.go b/common/tmq/event.go index c62cc93..027b891 100644 --- a/common/tmq/event.go +++ b/common/tmq/event.go @@ -5,7 +5,7 @@ import ( "encoding/json" "fmt" - taosError "github.com/taosdata/driver-go/v3/errors" + taosError "github.com/i-Things/driver-go/v3/errors" ) type Data struct { diff --git a/common/tmq/event_test.go b/common/tmq/event_test.go index 5043a28..c4044f1 100644 --- a/common/tmq/event_test.go +++ b/common/tmq/event_test.go @@ -5,8 +5,8 @@ import ( "fmt" "testing" + taosError "github.com/i-Things/driver-go/v3/errors" "github.com/stretchr/testify/assert" - taosError "github.com/taosdata/driver-go/v3/errors" ) func TestDataMessage_String(t *testing.T) { diff --git a/examples/platform/main.go b/examples/platform/main.go index e7a7034..25e4d4f 100644 --- a/examples/platform/main.go +++ b/examples/platform/main.go @@ -7,8 +7,8 @@ import ( "strings" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" - "github.com/taosdata/driver-go/v3/types" + _ "github.com/i-Things/driver-go/v3/taosRestful" + "github.com/i-Things/driver-go/v3/types" ) func main() { diff --git a/examples/restful/main.go b/examples/restful/main.go index 67134d7..0dc05f9 100644 --- a/examples/restful/main.go +++ b/examples/restful/main.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosRestful" + _ "github.com/i-Things/driver-go/v3/taosRestful" ) func main() { diff --git a/examples/schemaless/influx/main.go b/examples/schemaless/influx/main.go index 172714d..9f63c67 100644 --- a/examples/schemaless/influx/main.go +++ b/examples/schemaless/influx/main.go @@ -3,7 +3,7 @@ package main import ( "strings" - "github.com/taosdata/driver-go/v3/af" + "github.com/i-Things/driver-go/v3/af" ) const raw = `http_response,host=host161,method=GET,result=success,server=http://localhost,status_code=404 response_time=0.003226372,http_response_code=404i,content_length=19i,result_type="success",result_code=0i 1648090640000000000 diff --git a/examples/schemaless/json/main.go b/examples/schemaless/json/main.go index 07c0cd1..033cd96 100644 --- a/examples/schemaless/json/main.go +++ b/examples/schemaless/json/main.go @@ -1,6 +1,6 @@ package main -import "github.com/taosdata/driver-go/v3/af" +import "github.com/i-Things/driver-go/v3/af" func main() { conn, err := af.Open("", "root", "taosdata", "", 0) diff --git a/examples/schemaless/telnet/main.go b/examples/schemaless/telnet/main.go index 0a57121..7a9ed9e 100644 --- a/examples/schemaless/telnet/main.go +++ b/examples/schemaless/telnet/main.go @@ -1,7 +1,7 @@ package main import ( - "github.com/taosdata/driver-go/v3/af" + "github.com/i-Things/driver-go/v3/af" ) func main() { diff --git a/examples/sqlstmt/main.go b/examples/sqlstmt/main.go index 1215d42..84c681a 100644 --- a/examples/sqlstmt/main.go +++ b/examples/sqlstmt/main.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) var ( diff --git a/examples/stmtinsert/main.go b/examples/stmtinsert/main.go index efe628d..4c3db81 100644 --- a/examples/stmtinsert/main.go +++ b/examples/stmtinsert/main.go @@ -3,9 +3,9 @@ package main import ( "time" - "github.com/taosdata/driver-go/v3/af" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/af" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" ) func main() { diff --git a/examples/stmtoverws/main.go b/examples/stmtoverws/main.go index 6e083df..6c18b56 100644 --- a/examples/stmtoverws/main.go +++ b/examples/stmtoverws/main.go @@ -5,10 +5,10 @@ import ( "fmt" "time" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - _ "github.com/taosdata/driver-go/v3/taosRestful" - "github.com/taosdata/driver-go/v3/ws/stmt" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + _ "github.com/i-Things/driver-go/v3/taosRestful" + "github.com/i-Things/driver-go/v3/ws/stmt" ) func main() { diff --git a/examples/taosSql/main.go b/examples/taosSql/main.go index 2a4b816..284206d 100644 --- a/examples/taosSql/main.go +++ b/examples/taosSql/main.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosSql" + _ "github.com/i-Things/driver-go/v3/taosSql" ) func main() { diff --git a/examples/taosWS/main.go b/examples/taosWS/main.go index cc6a598..68780ca 100644 --- a/examples/taosWS/main.go +++ b/examples/taosWS/main.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - _ "github.com/taosdata/driver-go/v3/taosWS" + _ "github.com/i-Things/driver-go/v3/taosWS" ) func main() { diff --git a/examples/tmq/main.go b/examples/tmq/main.go index 01e2010..5879ae5 100644 --- a/examples/tmq/main.go +++ b/examples/tmq/main.go @@ -4,9 +4,9 @@ import ( "fmt" "os" - "github.com/taosdata/driver-go/v3/af" - "github.com/taosdata/driver-go/v3/af/tmq" - tmqcommon "github.com/taosdata/driver-go/v3/common/tmq" + "github.com/i-Things/driver-go/v3/af" + "github.com/i-Things/driver-go/v3/af/tmq" + tmqcommon "github.com/i-Things/driver-go/v3/common/tmq" ) func main() { diff --git a/examples/tmqoverws/main.go b/examples/tmqoverws/main.go index cac691a..f9b2c42 100644 --- a/examples/tmqoverws/main.go +++ b/examples/tmqoverws/main.go @@ -4,10 +4,10 @@ import ( "database/sql" "fmt" - "github.com/taosdata/driver-go/v3/common" - tmqcommon "github.com/taosdata/driver-go/v3/common/tmq" - _ "github.com/taosdata/driver-go/v3/taosRestful" - "github.com/taosdata/driver-go/v3/ws/tmq" + "github.com/i-Things/driver-go/v3/common" + tmqcommon "github.com/i-Things/driver-go/v3/common/tmq" + _ "github.com/i-Things/driver-go/v3/taosRestful" + "github.com/i-Things/driver-go/v3/ws/tmq" ) func main() { diff --git a/go.mod b/go.mod index a82d72c..cc6a33e 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/taosdata/driver-go/v3 +module github.com/i-Things/driver-go/v3 go 1.18 diff --git a/taosRestful/connection.go b/taosRestful/connection.go index 4c27e04..3291db8 100644 --- a/taosRestful/connection.go +++ b/taosRestful/connection.go @@ -8,8 +8,8 @@ import ( "encoding/base64" "errors" "fmt" - "github.com/taosdata/driver-go/v3/common" - taosErrors "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/common" + taosErrors "github.com/i-Things/driver-go/v3/errors" "github.com/zeromicro/go-zero/core/logx" "github.com/zeromicro/go-zero/core/syncx" "github.com/zeromicro/go-zero/core/timex" diff --git a/taosRestful/connector.go b/taosRestful/connector.go index 3ae7396..35aa510 100644 --- a/taosRestful/connector.go +++ b/taosRestful/connector.go @@ -4,7 +4,7 @@ import ( "context" "database/sql/driver" - "github.com/taosdata/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common" ) type connector struct { diff --git a/taosRestful/connector_test.go b/taosRestful/connector_test.go index eac38db..e790bcb 100644 --- a/taosRestful/connector_test.go +++ b/taosRestful/connector_test.go @@ -22,8 +22,8 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/types" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/types" ) func generateCreateTableSql(db string, withJson bool) string { diff --git a/taosRestful/dsn.go b/taosRestful/dsn.go index 612962a..f0b2feb 100644 --- a/taosRestful/dsn.go +++ b/taosRestful/dsn.go @@ -5,7 +5,7 @@ import ( "strconv" "strings" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/errors" ) var ( diff --git a/taosRestful/rows.go b/taosRestful/rows.go index c9fd897..83d9945 100644 --- a/taosRestful/rows.go +++ b/taosRestful/rows.go @@ -5,7 +5,7 @@ import ( "io" "reflect" - "github.com/taosdata/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common" ) type rows struct { diff --git a/taosSql/connection.go b/taosSql/connection.go index 288a74f..698b0c1 100644 --- a/taosSql/connection.go +++ b/taosSql/connection.go @@ -5,10 +5,10 @@ import ( "database/sql/driver" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/handler" ) type taosConn struct { diff --git a/taosSql/connection_test.go b/taosSql/connection_test.go index f473ec5..812fcc4 100644 --- a/taosSql/connection_test.go +++ b/taosSql/connection_test.go @@ -5,7 +5,7 @@ import ( "database/sql" "testing" - "github.com/taosdata/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common" ) // @author: xftan diff --git a/taosSql/connector.go b/taosSql/connector.go index 215b21e..dbbddcb 100644 --- a/taosSql/connector.go +++ b/taosSql/connector.go @@ -5,9 +5,9 @@ import ( "database/sql/driver" "sync" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) type connector struct { diff --git a/taosSql/driver.go b/taosSql/driver.go index f50a907..6c8b0f2 100644 --- a/taosSql/driver.go +++ b/taosSql/driver.go @@ -7,8 +7,8 @@ import ( "runtime" "sync" - "github.com/taosdata/driver-go/v3/wrapper/handler" - "github.com/taosdata/driver-go/v3/wrapper/thread" + "github.com/i-Things/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/wrapper/thread" ) var locker *thread.Locker diff --git a/taosSql/dsn.go b/taosSql/dsn.go index 90cdb6d..719b549 100644 --- a/taosSql/dsn.go +++ b/taosSql/dsn.go @@ -22,7 +22,7 @@ import ( "strings" "time" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/errors" ) var ( diff --git a/taosSql/rows.go b/taosSql/rows.go index 54b61a8..e7ae6ca 100644 --- a/taosSql/rows.go +++ b/taosSql/rows.go @@ -6,10 +6,10 @@ import ( "reflect" "unsafe" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" - "github.com/taosdata/driver-go/v3/wrapper/handler" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/wrapper/handler" ) type rows struct { diff --git a/taosSql/statement.go b/taosSql/statement.go index 9513e37..1b29171 100644 --- a/taosSql/statement.go +++ b/taosSql/statement.go @@ -8,11 +8,11 @@ import ( "time" "unsafe" - "github.com/taosdata/driver-go/v3/common" - stmtCommon "github.com/taosdata/driver-go/v3/common/stmt" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/types" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/common" + stmtCommon "github.com/i-Things/driver-go/v3/common/stmt" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/wrapper" ) //Client can't get stmt structure even by reflection. diff --git a/taosWS/connection.go b/taosWS/connection.go index c465815..c19fc70 100644 --- a/taosWS/connection.go +++ b/taosWS/connection.go @@ -7,6 +7,8 @@ import ( "encoding/json" "errors" "fmt" + "github.com/zeromicro/go-zero/core/logx" + "github.com/zeromicro/go-zero/core/timex" "net/url" "strings" "sync" @@ -14,10 +16,10 @@ import ( "time" "github.com/gorilla/websocket" + "github.com/i-Things/driver-go/v3/common" + stmtCommon "github.com/i-Things/driver-go/v3/common/stmt" + taosErrors "github.com/i-Things/driver-go/v3/errors" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" - stmtCommon "github.com/taosdata/driver-go/v3/common/stmt" - taosErrors "github.com/taosdata/driver-go/v3/errors" ) var jsonI = jsoniter.ConfigCompatibleWithStandardLibrary @@ -73,7 +75,7 @@ func (tc *taosConn) generateReqID() uint64 { return atomic.AddUint64(&tc.requestID, 1) } -func newTaosConn(cfg *config) (*taosConn, error) { +func newTaosConn(ctx context.Context, cfg *config) (*taosConn, error) { endpointUrl := &url.URL{ Scheme: cfg.net, Host: fmt.Sprintf("%s:%d", cfg.addr, cfg.port), @@ -111,6 +113,7 @@ func newTaosConn(cfg *config) (*taosConn, error) { go tc.read() err = tc.connect() if err != nil { + logx.WithContext(ctx).Errorf("websocket 连接失败,err:%v", err) tc.Close() } return tc, nil @@ -527,7 +530,7 @@ func (tc *taosConn) queryCtx(ctx context.Context, query string, args []driver.Na return rs, err } -func (tc *taosConn) doQuery(_ context.Context, query string, args []driver.NamedValue) (*WSQueryResp, error) { +func (tc *taosConn) doQuery(ctx context.Context, query string, args []driver.NamedValue) (*WSQueryResp, error) { if tc.isClosed() { return nil, driver.ErrBadConn } @@ -543,6 +546,15 @@ func (tc *taosConn) doQuery(_ context.Context, query string, args []driver.Named query = prepared } reqID := tc.generateReqID() + startTime := timex.Now() + duration := timex.Since(startTime) + defer func() { + if duration > time.Second { + logx.WithContext(ctx).WithDuration(duration).Slowf("[SQL] taosWsQuery reqID:%v slowcall query: %s", reqID, query) + } else { + logx.WithContext(ctx).WithDuration(duration).Infof("[SQL] taosWsQuery reqID:%v query: %s", reqID, query) + } + }() tc.buf.Reset() WriteUint64(tc.buf, reqID) // req id diff --git a/taosWS/connector.go b/taosWS/connector.go index 9310ee9..85e6c09 100644 --- a/taosWS/connector.go +++ b/taosWS/connector.go @@ -4,7 +4,7 @@ import ( "context" "database/sql/driver" - "github.com/taosdata/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common" ) type connector struct { diff --git a/taosWS/connector_test.go b/taosWS/connector_test.go index d971a1d..9837965 100644 --- a/taosWS/connector_test.go +++ b/taosWS/connector_test.go @@ -9,8 +9,8 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/types" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/types" ) func generateCreateTableSql(db string, withJson bool) string { diff --git a/taosWS/dsn.go b/taosWS/dsn.go index aa8e4dd..55b03ae 100644 --- a/taosWS/dsn.go +++ b/taosWS/dsn.go @@ -6,7 +6,7 @@ import ( "strings" "time" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/errors" ) var ( diff --git a/taosWS/proto.go b/taosWS/proto.go index 2731eec..8d68f47 100644 --- a/taosWS/proto.go +++ b/taosWS/proto.go @@ -3,7 +3,7 @@ package taosWS import ( "encoding/json" - stmtCommon "github.com/taosdata/driver-go/v3/common/stmt" + stmtCommon "github.com/i-Things/driver-go/v3/common/stmt" ) type WSConnectReq struct { diff --git a/taosWS/rows.go b/taosWS/rows.go index 636f54c..805f166 100644 --- a/taosWS/rows.go +++ b/taosWS/rows.go @@ -10,9 +10,9 @@ import ( "reflect" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - taosErrors "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + taosErrors "github.com/i-Things/driver-go/v3/errors" ) type rows struct { diff --git a/taosWS/statement.go b/taosWS/statement.go index 11f1f7e..c2916bd 100644 --- a/taosWS/statement.go +++ b/taosWS/statement.go @@ -9,11 +9,11 @@ import ( "strconv" "time" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/common/serializer" - stmtCommon "github.com/taosdata/driver-go/v3/common/stmt" - "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/common/serializer" + stmtCommon "github.com/i-Things/driver-go/v3/common/stmt" + "github.com/i-Things/driver-go/v3/types" ) type Stmt struct { diff --git a/types/types.go b/types/types.go index 04ee7bb..c6b51d3 100644 --- a/types/types.go +++ b/types/types.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/errors" ) type NullInt64 struct { diff --git a/wrapper/asynccb.go b/wrapper/asynccb.go index 14446c5..1ce0a44 100644 --- a/wrapper/asynccb.go +++ b/wrapper/asynccb.go @@ -11,7 +11,7 @@ import "C" import ( "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) type Caller interface { diff --git a/wrapper/block_test.go b/wrapper/block_test.go index 22f6239..8c1528e 100644 --- a/wrapper/block_test.go +++ b/wrapper/block_test.go @@ -7,9 +7,9 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" ) // @author: xftan diff --git a/wrapper/field.go b/wrapper/field.go index 5b6a023..140578f 100644 --- a/wrapper/field.go +++ b/wrapper/field.go @@ -9,8 +9,8 @@ import ( "reflect" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/errors" ) type RowsHeader struct { diff --git a/wrapper/field_test.go b/wrapper/field_test.go index 20fda70..fa6c64d 100644 --- a/wrapper/field_test.go +++ b/wrapper/field_test.go @@ -4,9 +4,9 @@ import ( "reflect" "testing" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/errors" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/errors" ) // @author: xftan diff --git a/wrapper/handler/handlerpool.go b/wrapper/handler/handlerpool.go index be79c02..2987416 100644 --- a/wrapper/handler/handlerpool.go +++ b/wrapper/handler/handlerpool.go @@ -5,7 +5,7 @@ import ( "sync" "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) type AsyncResult struct { diff --git a/wrapper/notify.go b/wrapper/notify.go index 48480d9..bf0aebd 100644 --- a/wrapper/notify.go +++ b/wrapper/notify.go @@ -16,7 +16,7 @@ import "C" import ( "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) func TaosSetNotifyCB(taosConnect unsafe.Pointer, caller cgo.Handle, notifyType int) int32 { diff --git a/wrapper/notify_test.go b/wrapper/notify_test.go index 468dea1..4adc4c8 100644 --- a/wrapper/notify_test.go +++ b/wrapper/notify_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/wrapper/cgo" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/wrapper/cgo" ) // @author: xftan diff --git a/wrapper/notifycb.go b/wrapper/notifycb.go index d933345..929b7ff 100644 --- a/wrapper/notifycb.go +++ b/wrapper/notifycb.go @@ -10,8 +10,8 @@ import "C" import ( "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) //export NotifyCallback diff --git a/wrapper/row.go b/wrapper/row.go index 38422f8..3ca36fa 100644 --- a/wrapper/row.go +++ b/wrapper/row.go @@ -8,8 +8,8 @@ import ( "database/sql/driver" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/pointer" ) const ( diff --git a/wrapper/row_test.go b/wrapper/row_test.go index 92f9425..6b4eddd 100644 --- a/wrapper/row_test.go +++ b/wrapper/row_test.go @@ -6,8 +6,8 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/errors" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/errors" ) // @author: xftan diff --git a/wrapper/schemaless_test.go b/wrapper/schemaless_test.go index db07466..87382f3 100644 --- a/wrapper/schemaless_test.go +++ b/wrapper/schemaless_test.go @@ -6,8 +6,8 @@ import ( "time" "unsafe" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper" ) func prepareEnv() unsafe.Pointer { diff --git a/wrapper/setconfig.go b/wrapper/setconfig.go index 4d9d179..0322a94 100644 --- a/wrapper/setconfig.go +++ b/wrapper/setconfig.go @@ -11,7 +11,7 @@ import ( "strings" "unsafe" - "github.com/taosdata/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/errors" ) // TaosSetConfig int taos_set_config(const char *config); diff --git a/wrapper/stmt.go b/wrapper/stmt.go index e2bb2c0..d512306 100644 --- a/wrapper/stmt.go +++ b/wrapper/stmt.go @@ -13,10 +13,10 @@ import ( "errors" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/stmt" - taosError "github.com/taosdata/driver-go/v3/errors" - taosTypes "github.com/taosdata/driver-go/v3/types" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/stmt" + taosError "github.com/i-Things/driver-go/v3/errors" + taosTypes "github.com/i-Things/driver-go/v3/types" ) // TaosStmtInit TAOS_STMT *taos_stmt_init(TAOS *taos); diff --git a/wrapper/stmt_test.go b/wrapper/stmt_test.go index 339a6ec..23c518c 100644 --- a/wrapper/stmt_test.go +++ b/wrapper/stmt_test.go @@ -7,13 +7,13 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/common/parser" + stmtCommon "github.com/i-Things/driver-go/v3/common/stmt" + taosError "github.com/i-Things/driver-go/v3/errors" + taosTypes "github.com/i-Things/driver-go/v3/types" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/common/parser" - stmtCommon "github.com/taosdata/driver-go/v3/common/stmt" - taosError "github.com/taosdata/driver-go/v3/errors" - taosTypes "github.com/taosdata/driver-go/v3/types" ) // @author: xftan diff --git a/wrapper/taosc.go b/wrapper/taosc.go index 5fea8eb..81f77d7 100644 --- a/wrapper/taosc.go +++ b/wrapper/taosc.go @@ -33,9 +33,9 @@ import ( "strings" "unsafe" - "github.com/taosdata/driver-go/v3/common/pointer" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) // TaosFreeResult void taos_free_result(TAOS_RES *res); diff --git a/wrapper/taosc_test.go b/wrapper/taosc_test.go index 18ff226..7f44640 100644 --- a/wrapper/taosc_test.go +++ b/wrapper/taosc_test.go @@ -8,11 +8,11 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper/cgo" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper/cgo" ) // @author: xftan diff --git a/wrapper/tmq.go b/wrapper/tmq.go index 949bf10..562d10c 100644 --- a/wrapper/tmq.go +++ b/wrapper/tmq.go @@ -14,10 +14,10 @@ import ( "sync" "unsafe" - "github.com/taosdata/driver-go/v3/common/pointer" - "github.com/taosdata/driver-go/v3/common/tmq" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/common/pointer" + "github.com/i-Things/driver-go/v3/common/tmq" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) var tmqCommitCallbackResultPool = sync.Pool{} diff --git a/wrapper/tmq_test.go b/wrapper/tmq_test.go index 4e201fa..19bc67e 100644 --- a/wrapper/tmq_test.go +++ b/wrapper/tmq_test.go @@ -6,13 +6,13 @@ import ( "time" "unsafe" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + tmqcommon "github.com/i-Things/driver-go/v3/common/tmq" + "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/wrapper/cgo" jsoniter "github.com/json-iterator/go" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - tmqcommon "github.com/taosdata/driver-go/v3/common/tmq" - "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/wrapper/cgo" ) // @author: xftan diff --git a/wrapper/tmqcb.go b/wrapper/tmqcb.go index 3893944..57cac7d 100644 --- a/wrapper/tmqcb.go +++ b/wrapper/tmqcb.go @@ -10,7 +10,7 @@ import "C" import ( "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) //typedef void(tmq_commit_cb(tmq_t *, int32_t code, void *param)); diff --git a/wrapper/whitelist.go b/wrapper/whitelist.go index 32da258..63feb3f 100644 --- a/wrapper/whitelist.go +++ b/wrapper/whitelist.go @@ -18,7 +18,7 @@ import "C" import ( "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) // typedef void (*__taos_async_whitelist_fn_t)(void *param, int code, TAOS *taos, int numOfWhiteLists, uint64_t* pWhiteLists); diff --git a/wrapper/whitelist_test.go b/wrapper/whitelist_test.go index 26a3a6e..fc64847 100644 --- a/wrapper/whitelist_test.go +++ b/wrapper/whitelist_test.go @@ -3,8 +3,8 @@ package wrapper import ( "testing" + "github.com/i-Things/driver-go/v3/wrapper/cgo" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/wrapper/cgo" ) func TestGetWhiteList(t *testing.T) { diff --git a/wrapper/whitelistcb.go b/wrapper/whitelistcb.go index 34710c8..10201fc 100644 --- a/wrapper/whitelistcb.go +++ b/wrapper/whitelistcb.go @@ -5,7 +5,7 @@ import ( "net" "unsafe" - "github.com/taosdata/driver-go/v3/wrapper/cgo" + "github.com/i-Things/driver-go/v3/wrapper/cgo" ) type WhitelistResult struct { diff --git a/ws/client/conn.go b/ws/client/conn.go index 76506fc..87397b3 100644 --- a/ws/client/conn.go +++ b/ws/client/conn.go @@ -9,8 +9,8 @@ import ( "time" "github.com/gorilla/websocket" + "github.com/i-Things/driver-go/v3/common" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" ) const ( diff --git a/ws/schemaless/schemaless.go b/ws/schemaless/schemaless.go index f22c7a6..bff4a03 100644 --- a/ws/schemaless/schemaless.go +++ b/ws/schemaless/schemaless.go @@ -11,10 +11,10 @@ import ( "time" "github.com/gorilla/websocket" + "github.com/i-Things/driver-go/v3/common" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) const ( diff --git a/ws/schemaless/schemaless_test.go b/ws/schemaless/schemaless_test.go index dc9caa6..7e0c0fb 100644 --- a/ws/schemaless/schemaless_test.go +++ b/ws/schemaless/schemaless_test.go @@ -13,10 +13,10 @@ import ( "testing" "time" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" "github.com/stretchr/testify/assert" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) // @author: xftan diff --git a/ws/stmt/connector.go b/ws/stmt/connector.go index a08cd2e..755d865 100644 --- a/ws/stmt/connector.go +++ b/ws/stmt/connector.go @@ -13,10 +13,10 @@ import ( "time" "github.com/gorilla/websocket" + "github.com/i-Things/driver-go/v3/common" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) type Connector struct { diff --git a/ws/stmt/rows.go b/ws/stmt/rows.go index 5247b55..7250aff 100644 --- a/ws/stmt/rows.go +++ b/ws/stmt/rows.go @@ -8,11 +8,11 @@ import ( "reflect" "unsafe" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/common/pointer" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/common/pointer" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" ) type Rows struct { diff --git a/ws/stmt/stmt.go b/ws/stmt/stmt.go index 373b763..a614255 100644 --- a/ws/stmt/stmt.go +++ b/ws/stmt/stmt.go @@ -4,10 +4,10 @@ import ( "bytes" "encoding/binary" - "github.com/taosdata/driver-go/v3/common/param" - "github.com/taosdata/driver-go/v3/common/serializer" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" + "github.com/i-Things/driver-go/v3/common/param" + "github.com/i-Things/driver-go/v3/common/serializer" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" ) type Stmt struct { diff --git a/ws/stmt/stmt_test.go b/ws/stmt/stmt_test.go index 652766e..2d5ef27 100644 --- a/ws/stmt/stmt_test.go +++ b/ws/stmt/stmt_test.go @@ -15,12 +15,12 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/param" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/param" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) func prepareEnv(db string) error { diff --git a/ws/tmq/consumer.go b/ws/tmq/consumer.go index 64bb1ed..bf9d649 100644 --- a/ws/tmq/consumer.go +++ b/ws/tmq/consumer.go @@ -15,12 +15,12 @@ import ( "unsafe" "github.com/gorilla/websocket" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/parser" + "github.com/i-Things/driver-go/v3/common/tmq" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/parser" - "github.com/taosdata/driver-go/v3/common/tmq" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) type Consumer struct { diff --git a/ws/tmq/consumer_test.go b/ws/tmq/consumer_test.go index 37dd34b..e155547 100644 --- a/ws/tmq/consumer_test.go +++ b/ws/tmq/consumer_test.go @@ -13,12 +13,12 @@ import ( "testing" "time" + "github.com/i-Things/driver-go/v3/common" + "github.com/i-Things/driver-go/v3/common/tmq" + taosErrors "github.com/i-Things/driver-go/v3/errors" + "github.com/i-Things/driver-go/v3/ws/client" jsoniter "github.com/json-iterator/go" "github.com/stretchr/testify/assert" - "github.com/taosdata/driver-go/v3/common" - "github.com/taosdata/driver-go/v3/common/tmq" - taosErrors "github.com/taosdata/driver-go/v3/errors" - "github.com/taosdata/driver-go/v3/ws/client" ) func prepareEnv() error { diff --git a/ws/tmq/proto.go b/ws/tmq/proto.go index 3a17c8b..1b419bf 100644 --- a/ws/tmq/proto.go +++ b/ws/tmq/proto.go @@ -3,7 +3,7 @@ package tmq import ( "encoding/json" - "github.com/taosdata/driver-go/v3/common/tmq" + "github.com/i-Things/driver-go/v3/common/tmq" ) type SubscribeReq struct {