feat: support ComInitDB

Author: dk-lockdown

.github/workflows/main.yml

@@ -55,7 +55,7 @@ jobs:
       - name: Unit Tests
         run: |
           mkdir -p build
-          go test -gcflags=all=-l ./pkg/... -coverprofile=coverage.txt -covermode=atomic
+          go test -gcflags=all=-l $(go list ./... | grep -v /test/ | grep -v /parser | grep -v /types) -coverprofile=coverage.txt -covermode=atomic
 
       - name: Post Coverage
         run: bash <(curl -s https://codecov.io/bash)

docker/conf/config_rws.yaml

@@ -39,7 +39,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql1:3306)/employees?timeout=1s&readTimeout=1s&writeTimeout=1s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql1:3306)/?timeout=1s&readTimeout=1s&writeTimeout=1s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:
@@ -50,7 +50,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql2:3306)/employees?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql2:3306)/?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
 

docker/conf/config_sdb.yaml

@@ -34,7 +34,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql:3306)/employees?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql:3306)/?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:

docker/conf/config_shd_mod.yaml

@@ -53,7 +53,6 @@ app_config:
                 type: snowflake
                 config:
                   worker_id: 123
-                  # dsn: root:123456@tcp(dbpack-mysql1:3306)/world?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
               topology:
                 "0": 0-4
                 "1": 5-9
@@ -68,7 +67,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql1:3306)/world?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql1:3306)/?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:
@@ -78,7 +77,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql2:3306)/world?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql2:3306)/?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:

docker/conf/config_shd_range.yaml

@@ -64,7 +64,6 @@ app_config:
                 type: snowflake
                 config:
                   worker_id: 123
-                  # dsn: root:123456@tcp(dbpack-mysql1:3306)/world?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
               topology:
                 "0": 0-4
                 "1": 5-9
@@ -79,7 +78,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql1:3306)/world?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql1:3306)/?timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:
@@ -89,7 +88,7 @@ app_config:
         capacity: 10
         max_capacity: 20
         idle_timeout: 60s
-        dsn: root:123456@tcp(dbpack-mysql2:3306)/world?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
+        dsn: root:123456@tcp(dbpack-mysql2:3306)/?timeout=60s&readTimeout=60s&writeTimeout=60s&parseTime=true&loc=Local&charset=utf8mb4,utf8
         ping_interval: 20s
         ping_times_for_change_status: 3
         filters:

docker/docker-compose-rws.yaml

@@ -64,4 +64,4 @@ services:
 
 networks:
   local:
-    name: dbpack
+    name: dbpack-network

docker/docker-compose-sdb.yaml

@@ -48,4 +48,4 @@ services:
     command: ["./wait-for-mysql.sh","--","/dbpack", "start", "-c", "config.yaml"]
 networks:
   local:
-    name: dbpack
+    name: dbpack-network

docker/docker-compose-shd-mod.yaml

@@ -60,4 +60,4 @@ services:
     command: ["./wait-for-mysql.sh","--","/dbpack", "start", "-c", "mod_config.yaml"]
 networks:
   local:
-    name: dbpack
+    name: dbpack-network

docker/docker-compose-shd-range.yaml

@@ -60,4 +60,4 @@ services:
     command: ["./wait-for-mysql.sh","--","/dbpack", "start", "-c", "range_config.yaml"]
 networks:
   local:
-    name: dbpack
+    name: dbpack-network

go.mod

@@ -1,6 +1,8 @@
 module github.com/cectc/dbpack
 
-go 1.23
+go 1.23.0
+
+toolchain go1.23.2
 
 require (
 	github.com/agiledragon/gomonkey/v2 v2.7.0
@@ -42,6 +44,7 @@ require (
 	go.uber.org/goleak v1.1.12
 	go.uber.org/ratelimit v0.2.1-0.20220713224938-b62b799bc9a5
 	go.uber.org/zap v1.21.0
+	golang.org/x/exp v0.0.0-20250506013437-ce4c2cf36ca6
 	golang.org/x/net v0.25.0
 	golang.org/x/text v0.21.0
 	google.golang.org/grpc v1.56.3
@@ -144,7 +147,7 @@ require (
 	go.opentelemetry.io/otel/sdk v1.9.0
 	go.opentelemetry.io/otel/trace v1.9.0
 	go.uber.org/multierr v1.7.0 // indirect
-	golang.org/x/sync v0.10.0
+	golang.org/x/sync v0.14.0
 	golang.org/x/sys v0.28.0 // indirect
 	golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac // indirect
 	google.golang.org/genproto v0.0.0-20230410155749-daa745c078e1 // indirect