new version v2.6.3 (#3308)

rename gitee ISSUE_TEMPLATE.MD to ISSUE_TEMPLATE

.github/ISSUE_TEMPLATE.MD

@@ -1,38 +0,0 @@
-<!-- Please answer these questions before submitting your issue. Thanks! -->
-
-<!-- 为高效处理您的疑问，如果觉得是BUG类问题，请您务必提供可复现该问题的最小可运行代码！否则issue可能会被延期处理！ -->
-<!-- 为高效处理您的疑问，如果觉得是BUG类问题，请您务必提供可复现该问题的最小可运行代码！否则issue可能会被延期处理！ -->
-<!-- 为高效处理您的疑问，如果觉得是BUG类问题，请您务必提供可复现该问题的最小可运行代码！否则issue可能会被延期处理！ -->
-<!-- 重要的事情说三遍！ -->
-
-### 1. What version of `Go` and system type/arch are you using?
-<!-- 
-Please paste the output of command `go version` from your terminal.
-What expect to see is like: `go 1.12, linux/amd64`
--->
-
-
-### 2. What version of `GoFrame` are you using?
-<!-- You can find the GF version from your `go.mod`, or from the `version.go` in `GF` -->
-
-
-### 3. Can this issue be re-produced with the latest release?
-
-
-
-### 4. What did you do?
-<!--
-If possible, provide a copy of shortest codes for reproducing the error.
-A complete runnable program is best.
--->
-
-
-
-### 5. What did you expect to see?
-
-
-
-### 6. What did you see instead?
-
-
-

.github/ISSUE_TEMPLATE/bug-report.md

@@ -0,0 +1,41 @@
+---
+name: Bug report
+about: Create a report to help us improve
+title: ''
+labels: bug
+assignees: ''
+
+---
+
+<!-- Please answer these questions before submitting your issue. Thanks! -->
+
+<!-- 为高效处理 Bug，请您务必提供可复现该问题的最小可运行代码！否则 issue 可能会被延期处理！ -->
+<!-- 为高效处理 Bug，请您务必提供可复现该问题的最小可运行代码！否则 issue 可能会被延期处理！ -->
+<!-- 为高效处理 Bug，如请您务必提供可复现该问题的最小可运行代码！否则 issue 可能会被延期处理！ -->
+<!-- 重要的事情说三遍！ -->
+
+**What version of `Go` and system type/arch are you using?**
+<!-- 
+Please paste the output of command `go version` from your terminal.
+What expects to see is like: `go 1.12, linux/amd64`
+-->
+
+
+**What version of `GoFrame` are you using?**
+<!-- You can find the GF version from your `go.mod`, or from the `version.go` in `GF` -->
+
+
+**Can this bug be re-produced with the latest release?**
+
+
+**What did you do?**
+<!--
+If possible, provide a copy of shortest codes for reproducing the error.
+A complete runnable program is best.
+-->
+
+
+**What did you expect to see?**
+
+
+**What did you see instead?**

.github/ISSUE_TEMPLATE/enhancement-request.md

@@ -0,0 +1,16 @@
+---
+name: Enhancement request
+about: Enhance an idea for this project
+title: ''
+labels: enhancement
+assignees: ''
+
+---
+
+**Package that You wish to enhance**
+
+
+**Enhancement description**
+
+
+**Additional**

.github/ISSUE_TEMPLATE/feature-request.md

@@ -0,0 +1,19 @@
+---
+name: Feature request
+about: Suggest an idea for this project
+title: ''
+labels: feature
+assignees: ''
+
+---
+
+**Is your feature request related to a problem? Please describe.**
+
+
+**Describe the solution you'd like**
+
+
+**Describe alternatives you've considered**
+
+
+**Additional**

.github/ISSUE_TEMPLATE/question.md

@@ -0,0 +1,11 @@
+---
+name: Question
+about: I want to ask a question
+title: ''
+labels: question
+assignees: ''
+
+---
+
+<!-- 请优先仔细阅读文档 -->
+**What do you want to ask**

.github/workflows/ci-main.yml

@@ -67,9 +67,13 @@ jobs:
           - 3306:3306
 
       # PostgreSQL backend server.
-      # docker run -d --name postgres -p 5432:5432 \
-      # -e POSTGRES_PASSWORD=12345678 -e POSTGRES_USER=postgres -e POSTGRES_DB=test \
-      # -v postgres:/Users/john/Temp/postgresql/data loads/postgres:13
+      # docker run -d --name postgres \
+      # -p 5432:5432 \
+      # -e POSTGRES_PASSWORD=12345678 \
+      # -e POSTGRES_USER=postgres \
+      # -e POSTGRES_DB=test \
+      # -v postgres:/Users/john/Temp/postgresql/data \
+      # loads/postgres:13
       postgres:
         image: loads/postgres:13
         env:
@@ -87,7 +91,8 @@ jobs:
           --health-retries 5
 
       # MSSQL backend server.
-      # docker run -d --name mssql -p 1433:1433 \
+      # docker run \
+      # -p 1433:1433 \
       # -e ACCEPT_EULA=Y \
       # -e SA_PASSWORD=LoremIpsum86 \
       # -e MSSQL_DB=test \
@@ -123,8 +128,13 @@ jobs:
           - 9001:9001
 
       # Polaris backend server.
-      # docker run -d --name polaris -p 8090:8090 -p 8091:8091 -p 8093:8093  -p 9090:9090 -p 9091:9091 loads/polaris-server-standalone:1.11.2
-      # docker run -d --name polaris -p 8090:8090 -p 8091:8091 -p 8093:8093  -p 9090:9090 -p 9091:9091 loads/polaris-standalone:v1.16.3
+      # docker run -d --name polaris \
+      # -p 8090:8090 -p 8091:8091 -p 8093:8093 -p 9090:9090 -p 9091:9091 \
+      # loads/polaris-server-standalone:1.11.2
+      #
+      # docker run -d --name polaris \
+      # -p 8090:8090 -p 8091:8091 -p 8093:8093 -p 9090:9090 -p 9091:9091 \
+      # loads/polaris-standalone:v1.16.3
       polaris:
         image: loads/polaris-standalone:v1.17.2
         ports:
@@ -134,7 +144,14 @@ jobs:
           - 9090:9090
           - 9091:9091
 
-      # Oracle 11g server
+      # Oracle 11g server.
+      # docker run \
+      # -e ORACLE_ALLOW_REMOTE=true \
+      # -e ORACLE_SID=XE \
+      # -e ORACLE_DB_USER_NAME=system \
+      # -e ORACLE_DB_PASSWORD=oracle \
+      # -p 1521:1521 \
+      # loads/oracle-xe-11g-r2:11.2.0
       oracle-server:
         image: loads/oracle-xe-11g-r2:11.2.0
         env:
@@ -146,7 +163,7 @@ jobs:
           - 1521:1521
 
       # dm8 server
-      # docker run -d --name dm -p 5236:5236 loads/dm:v8.1.2.128_ent_x86_64_ctm_pack4
+      # docker run -p 5236:5236 loads/dm:v8.1.2.128_ent_x86_64_ctm_pack4
       dm-server:
         image: loads/dm:v8.1.2.128_ent_x86_64_ctm_pack4
         ports:

.github/workflows/gitee-sync.yml

@@ -1,7 +1,7 @@
 on:
   push:
     branches:
-      - main
+      - master
     tags:
       - "*"
 
@@ -13,8 +13,8 @@ jobs:
     steps:
       - name: Checkout source code
         uses: actions/checkout@v4
-      - name: Mirror Github to Gitee
-        uses: Yikun/hub-mirror-action@v1.2
+      - name: Mirror GitHub to Gitee
+        uses: Yikun/hub-mirror-action@v1.3
         with:
           src: github/gogf
           dst: gitee/johng

.github/workflows/release.yml

@@ -34,7 +34,7 @@ jobs:
       - name: Build CLI Binary For All Platform
         run: |
           cd cmd/gf
-          gf build main.go -n gf -a all -s all
+          gf build main.go -n gf -a all -s all -p temp
 
       - name: Move Files Before Release
         run: |

README.MD

@@ -7,16 +7,16 @@
 [![GoFrame CI](https://github.com/gogf/gf/actions/workflows/ci-main.yml/badge.svg)](https://github.com/gogf/gf/actions/workflows/ci-main.yml)
 [![Go Report Card](https://goreportcard.com/badge/github.com/gogf/gf/v2)](https://goreportcard.com/report/github.com/gogf/gf/v2)
 [![Code Coverage](https://codecov.io/gh/gogf/gf/branch/master/graph/badge.svg)](https://codecov.io/gh/gogf/gf)
-[![Production Ready](https://img.shields.io/badge/production-ready-blue.svg)](https://github.com/gogf/gf)
+[![Production Ready](https://img.shields.io/badge/production-ready-blue.svg?style=flat)](https://github.com/gogf/gf)
 [![License](https://img.shields.io/github/license/gogf/gf.svg?style=flat)](https://github.com/gogf/gf)
 
-[![Release](https://img.shields.io/github/v/release/gogf/gf)](https://github.com/gogf/gf/releases)
-[![GitHub pull requests](https://img.shields.io/github/issues-pr/gogf/gf)](https://github.com/gogf/gf/pulls)
-[![GitHub closed pull requests](https://img.shields.io/github/issues-pr-closed/gogf/gf)](https://github.com/gogf/gf/pulls?q=is%3Apr+is%3Aclosed)
-[![GitHub issues](https://img.shields.io/github/issues/gogf/gf)](https://github.com/gogf/gf/issues)
-[![GitHub closed issues](https://img.shields.io/github/issues-closed/gogf/gf)](https://github.com/gogf/gf/issues?q=is%3Aissue+is%3Aclosed)
-![Stars](https://img.shields.io/github/stars/gogf/gf)
-![Forks](https://img.shields.io/github/forks/gogf/gf)
+[![Release](https://img.shields.io/github/v/release/gogf/gf?style=flat)](https://github.com/gogf/gf/releases)
+[![GitHub pull requests](https://img.shields.io/github/issues-pr/gogf/gf?style=flat)](https://github.com/gogf/gf/pulls)
+[![GitHub closed pull requests](https://img.shields.io/github/issues-pr-closed/gogf/gf?style=flat)](https://github.com/gogf/gf/pulls?q=is%3Apr+is%3Aclosed)
+[![GitHub issues](https://img.shields.io/github/issues/gogf/gf?style=flat)](https://github.com/gogf/gf/issues)
+[![GitHub closed issues](https://img.shields.io/github/issues-closed/gogf/gf?style=flat)](https://github.com/gogf/gf/issues?q=is%3Aissue+is%3Aclosed)
+![Stars](https://img.shields.io/github/stars/gogf/gf?style=flat)
+![Forks](https://img.shields.io/github/forks/gogf/gf?style=flat)
 
 </div>
 
@@ -62,6 +62,7 @@ golang version >= 1.18
 # Documentation
 
 - Chinese Official Site(中文官网): [https://goframe.org](https://goframe.org/display/gf)
+- Offline Document(中文离线文档): [https://github.com/gogf/goframe.org-pdf](https://github.com/gogf/goframe.org-pdf)
 - GoDoc API: [https://pkg.go.dev/github.com/gogf/gf/v2](https://pkg.go.dev/github.com/gogf/gf/v2)
 
 # License

cmd/gf/go.mod

@@ -3,13 +3,13 @@ module github.com/gogf/gf/cmd/gf/v2
 go 1.18
 
 require (
-	github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.6.1
-	github.com/gogf/gf/contrib/drivers/mssql/v2 v2.6.1
-	github.com/gogf/gf/contrib/drivers/mysql/v2 v2.6.1
-	github.com/gogf/gf/contrib/drivers/oracle/v2 v2.6.1
-	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.6.1
-	github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.6.1
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.6.3
+	github.com/gogf/gf/contrib/drivers/mssql/v2 v2.6.3
+	github.com/gogf/gf/contrib/drivers/mysql/v2 v2.6.3
+	github.com/gogf/gf/contrib/drivers/oracle/v2 v2.6.3
+	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.6.3
+	github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.6.3
+	github.com/gogf/gf/v2 v2.6.3
 	github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f
 	github.com/olekukonko/tablewriter v0.0.5
 	golang.org/x/mod v0.9.0

cmd/gf/internal/cmd/cmd_build.go

@@ -44,8 +44,9 @@ type cBuild struct {
 }
 
 const (
-	cBuildBrief = `cross-building go project for lots of platforms`
-	cBuildEg    = `
+	cBuildDefaultFile = "main.go"
+	cBuildBrief       = `cross-building go project for lots of platforms`
+	cBuildEg          = `
 gf build main.go
 gf build main.go --ps public,template
 gf build main.go --cgo
@@ -123,7 +124,7 @@ type cBuildInput struct {
 	Arch          string `short:"a"  name:"arch"    brief:"output binary architecture, multiple arch separated with ','"`
 	System        string `short:"s"  name:"system"  brief:"output binary system, multiple os separated with ','"`
 	Output        string `short:"o"  name:"output"  brief:"output binary path, used when building single binary file"`
-	Path          string `short:"p"  name:"path"    brief:"output binary directory path, default is './temp'" d:"./temp"`
+	Path          string `short:"p"  name:"path"    brief:"output binary directory path, default is '.'" d:"."`
 	Extra         string `short:"e"  name:"extra"   brief:"extra custom \"go build\" options"`
 	Mod           string `short:"m"  name:"mod"     brief:"like \"-mod\" option of \"go build\", use \"-m none\" to disable go module"`
 	Cgo           bool   `short:"c"  name:"cgo"     brief:"enable or disable cgo feature, it's disabled in default" orphan:"true"`
@@ -152,12 +153,13 @@ func (c cBuild) Index(ctx context.Context, in cBuildInput) (out *cBuildOutput, e
 
 	var (
 		parser = gcmd.ParserFromCtx(ctx)
-		file   = parser.GetArg(2).String()
+		file   = in.File
 	)
-	if len(file) < 1 {
+	if file == "" {
+		file = parser.GetArg(2).String()
 		// Check and use the main.go file.
-		if gfile.Exists("main.go") {
-			file = "main.go"
+		if gfile.Exists(cBuildDefaultFile) {
+			file = cBuildDefaultFile
 		} else {
 			mlog.Fatal("build file path is empty or main.go not found in current working directory")
 		}
@@ -239,13 +241,7 @@ func (c cBuild) Index(ctx context.Context, in cBuildInput) (out *cBuildOutput, e
 	} else {
 		genv.MustSet("CGO_ENABLED", "0")
 	}
-	var (
-		cmd = ""
-		ext = ""
-	)
 	for system, item := range platformMap {
-		cmd = ""
-		ext = ""
 		if len(customSystems) > 0 && customSystems[0] != "all" && !gstr.InArray(customSystems, system) {
 			continue
 		}
@@ -258,58 +254,22 @@ func (c cBuild) Index(ctx context.Context, in cBuildInput) (out *cBuildOutput, e
 				// For example:
 				// `gf build`
 				// `gf build -o main.exe`
-				if runtime.GOOS == "windows" {
-					ext = ".exe"
-				}
-				var outputPath string
-				if len(in.Output) > 0 {
-					outputPath = "-o " + in.Output
-				} else {
-					outputPath = "-o " + in.Name + ext
-				}
-				cmd = fmt.Sprintf(
-					`go build %s -ldflags "%s" %s %s`,
-					outputPath, ldFlags, in.Extra, file,
+				c.doBinaryBuild(
+					ctx, file,
+					in.Output, in.Path,
+					runtime.GOOS, runtime.GOARCH, in.Name, ldFlags, in.Extra,
+					in.ExitWhenError,
+					true,
 				)
 			} else {
-				// Cross-building, output the compiled binary to specified path.
-				if system == "windows" {
-					ext = ".exe"
-				}
-				genv.MustSet("GOOS", system)
-				genv.MustSet("GOARCH", arch)
-
-				var outputPath string
-				if len(in.Output) > 0 {
-					outputPath = "-o " + in.Output
-				} else {
-					outputPath = fmt.Sprintf(
-						"-o %s/%s/%s%s",
-						in.Path, system+"_"+arch, in.Name, ext,
-					)
-				}
-				cmd = fmt.Sprintf(
-					`go build %s -ldflags "%s" %s%s`,
-					outputPath, ldFlags, in.Extra, file,
+				c.doBinaryBuild(
+					ctx, file,
+					in.Output, in.Path,
+					system, arch, in.Name, ldFlags, in.Extra,
+					in.ExitWhenError,
+					false,
 				)
 			}
-			mlog.Debug(fmt.Sprintf("build for GOOS=%s GOARCH=%s", system, arch))
-			mlog.Debug(cmd)
-			// It's not necessary printing the complete command string.
-			cmdShow, _ := gregex.ReplaceString(`\s+(-ldflags ".+?")\s+`, " ", cmd)
-			mlog.Print(cmdShow)
-			if result, err := gproc.ShellExec(ctx, cmd); err != nil {
-				mlog.Printf(
-					"failed to build, os:%s, arch:%s, error:\n%s\n\n%s\n",
-					system, arch, gstr.Trim(result),
-					`you may use command option "--debug" to enable debug info and check the details`,
-				)
-				if in.ExitWhenError {
-					os.Exit(1)
-				}
-			} else {
-				mlog.Debug(gstr.Trim(result))
-			}
 			// single binary building.
 			if len(customSystems) == 0 && len(customArches) == 0 {
 				goto buildDone
@@ -322,6 +282,68 @@ buildDone:
 	return
 }
 
+func (c cBuild) doBinaryBuild(
+	ctx context.Context,
+	filePath string,
+	outputPath, dirPath string,
+	system, arch, name, ldFlags, extra string,
+	exitWhenError bool,
+	singleBuild bool,
+) {
+	var (
+		cmd string
+		ext string
+	)
+	// Cross-building, output the compiled binary to specified path.
+	if system == "windows" {
+		ext = ".exe"
+	}
+	genv.MustSet("GOOS", system)
+	genv.MustSet("GOARCH", arch)
+
+	if outputPath != "" {
+		outputPath = "-o " + outputPath
+	} else {
+		if dirPath == "" {
+			dirPath = "."
+		} else {
+			dirPath = gstr.TrimRight(dirPath, "/")
+		}
+		if singleBuild {
+			outputPath = fmt.Sprintf(
+				"-o %s/%s%s",
+				dirPath, name, ext,
+			)
+		} else {
+			outputPath = fmt.Sprintf(
+				"-o %s/%s/%s%s",
+				dirPath, system+"_"+arch, name, ext,
+			)
+		}
+	}
+	cmd = fmt.Sprintf(
+		`go build %s -ldflags "%s" %s%s`,
+		outputPath, ldFlags, extra, filePath,
+	)
+	mlog.Debug(fmt.Sprintf("build for GOOS=%s GOARCH=%s", system, arch))
+	mlog.Debug(cmd)
+	// It's not necessary printing the complete command string, filtering ldFlags.
+	cmdShow, _ := gregex.ReplaceString(`\s+(-ldflags ".+?")\s+`, " ", cmd)
+	mlog.Print(cmdShow)
+	if result, err := gproc.ShellExec(ctx, cmd); err != nil {
+		mlog.Printf(
+			"failed to build, os:%s, arch:%s, error:\n%s\n\n%s\n",
+			system, arch, gstr.Trim(result),
+			`you may use command option "--debug" to enable debug info and check the details`,
+		)
+		if exitWhenError {
+			os.Exit(1)
+		}
+	} else {
+		mlog.Debug(gstr.Trim(result))
+	}
+}
+
 // getBuildInVarStr retrieves and returns the custom build-in variables in configuration
 // file as json.
 func (c cBuild) getBuildInVarStr(ctx context.Context, in cBuildInput) string {

cmd/gf/internal/cmd/cmd_z_unit_build_test.go

@@ -0,0 +1,151 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package cmd
+
+import (
+	"testing"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/os/gproc"
+	"github.com/gogf/gf/v2/test/gtest"
+	"github.com/gogf/gf/v2/text/gstr"
+)
+
+func Test_Build_Single(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			buildPath  = gtest.DataPath(`build`, `single`)
+			pwd        = gfile.Pwd()
+			binaryName = `t.test`
+			binaryPath = gtest.DataPath(`build`, `single`, binaryName)
+			f          = cBuild{}
+		)
+		defer gfile.Chdir(pwd)
+		defer gfile.Remove(binaryPath)
+		err := gfile.Chdir(buildPath)
+		t.AssertNil(err)
+
+		t.Assert(gfile.Exists(binaryPath), false)
+		_, err = f.Index(ctx, cBuildInput{
+			File: cBuildDefaultFile,
+			Name: binaryName,
+		})
+		t.AssertNil(err)
+		t.Assert(gfile.Exists(binaryPath), true)
+	})
+}
+
+func Test_Build_Single_Output(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			buildPath     = gtest.DataPath(`build`, `single`)
+			pwd           = gfile.Pwd()
+			binaryName    = `tt`
+			binaryDirPath = gtest.DataPath(`build`, `single`, `tt`)
+			binaryPath    = gtest.DataPath(`build`, `single`, `tt`, binaryName)
+			f             = cBuild{}
+		)
+		defer gfile.Chdir(pwd)
+		defer gfile.Remove(binaryDirPath)
+		err := gfile.Chdir(buildPath)
+		t.AssertNil(err)
+
+		t.Assert(gfile.Exists(binaryPath), false)
+		_, err = f.Index(ctx, cBuildInput{
+			Output: "./tt/tt",
+		})
+		t.AssertNil(err)
+		t.Assert(gfile.Exists(binaryPath), true)
+	})
+}
+
+func Test_Build_Single_Path(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			buildPath     = gtest.DataPath(`build`, `single`)
+			pwd           = gfile.Pwd()
+			dirName       = "ttt"
+			binaryName    = `main`
+			binaryDirPath = gtest.DataPath(`build`, `single`, dirName)
+			binaryPath    = gtest.DataPath(`build`, `single`, dirName, binaryName)
+			f             = cBuild{}
+		)
+		defer gfile.Chdir(pwd)
+		defer gfile.Remove(binaryDirPath)
+		err := gfile.Chdir(buildPath)
+		t.AssertNil(err)
+
+		t.Assert(gfile.Exists(binaryPath), false)
+		_, err = f.Index(ctx, cBuildInput{
+			Path: "ttt",
+		})
+		t.AssertNil(err)
+		t.Assert(gfile.Exists(binaryPath), true)
+	})
+}
+
+func Test_Build_Single_VarMap(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			buildPath  = gtest.DataPath(`build`, `varmap`)
+			pwd        = gfile.Pwd()
+			binaryName = `main`
+			binaryPath = gtest.DataPath(`build`, `varmap`, binaryName)
+			f          = cBuild{}
+		)
+		defer gfile.Chdir(pwd)
+		defer gfile.Remove(binaryPath)
+		err := gfile.Chdir(buildPath)
+		t.AssertNil(err)
+
+		t.Assert(gfile.Exists(binaryPath), false)
+		_, err = f.Index(ctx, cBuildInput{
+			VarMap: map[string]interface{}{
+				"a": "1",
+				"b": "2",
+			},
+		})
+		t.AssertNil(err)
+		t.Assert(gfile.Exists(binaryPath), true)
+
+		result, err := gproc.ShellExec(ctx, binaryPath)
+		t.AssertNil(err)
+		t.Assert(gstr.Contains(result, `a: 1`), true)
+		t.Assert(gstr.Contains(result, `b: 2`), true)
+	})
+}
+
+func Test_Build_Multiple(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			buildPath         = gtest.DataPath(`build`, `multiple`)
+			pwd               = gfile.Pwd()
+			binaryDirPath     = gtest.DataPath(`build`, `multiple`, `temp`)
+			binaryPathLinux   = gtest.DataPath(`build`, `multiple`, `temp`, `v1.1`, `linux_amd64`, `ttt`)
+			binaryPathWindows = gtest.DataPath(`build`, `multiple`, `temp`, `v1.1`, `windows_amd64`, `ttt.exe`)
+			f                 = cBuild{}
+		)
+		defer gfile.Chdir(pwd)
+		defer gfile.Remove(binaryDirPath)
+		err := gfile.Chdir(buildPath)
+		t.AssertNil(err)
+
+		t.Assert(gfile.Exists(binaryPathLinux), false)
+		t.Assert(gfile.Exists(binaryPathWindows), false)
+		_, err = f.Index(ctx, cBuildInput{
+			File:    "multiple.go",
+			Name:    "ttt",
+			Version: "v1.1",
+			Arch:    "amd64",
+			System:  "linux, windows",
+			Path:    "temp",
+		})
+		t.AssertNil(err)
+		t.Assert(gfile.Exists(binaryPathLinux), true)
+		t.Assert(gfile.Exists(binaryPathWindows), true)
+	})
+}

cmd/gf/internal/cmd/cmd_z_unit_gen_ctrl_test.go

@@ -7,13 +7,14 @@
 package cmd
 
 import (
+	"path/filepath"
+	"testing"
+
 	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/genctrl"
 	"github.com/gogf/gf/v2/os/gfile"
 	"github.com/gogf/gf/v2/test/gtest"
 	"github.com/gogf/gf/v2/util/guid"
 	"github.com/gogf/gf/v2/util/gutil"
-	"path/filepath"
-	"testing"
 )
 
 func Test_Gen_Ctrl_Default(t *testing.T) {

cmd/gf/internal/cmd/cmd_z_unit_gen_dao_test.go

@@ -12,6 +12,7 @@ import (
 	"testing"
 
 	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/gendao"
+	"github.com/gogf/gf/v2/database/gdb"
 	"github.com/gogf/gf/v2/os/gfile"
 	"github.com/gogf/gf/v2/test/gtest"
 	"github.com/gogf/gf/v2/text/gstr"
@@ -209,3 +210,186 @@ func Test_Gen_Dao_TypeMapping(t *testing.T) {
 		}
 	})
 }
+
+func execSqlFile(db gdb.DB, filePath string, args ...any) error {
+	sqlContent := fmt.Sprintf(
+		gfile.GetContents(filePath),
+		args...,
+	)
+	array := gstr.SplitAndTrim(sqlContent, ";")
+	for _, v := range array {
+		if _, err := db.Exec(ctx, v); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func Test_Gen_Dao_Issue2572(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			err          error
+			db           = testDB
+			table1       = "user1"
+			table2       = "user2"
+			issueDirPath = gtest.DataPath(`issue`, `2572`)
+		)
+		t.AssertNil(execSqlFile(db, gtest.DataPath(`issue`, `2572`, `sql1.sql`)))
+		t.AssertNil(execSqlFile(db, gtest.DataPath(`issue`, `2572`, `sql2.sql`)))
+		defer dropTableWithDb(db, table1)
+		defer dropTableWithDb(db, table2)
+
+		var (
+			path  = gfile.Temp(guid.S())
+			group = "test"
+			in    = gendao.CGenDaoInput{
+				Path:               path,
+				Link:               link,
+				Tables:             "",
+				TablesEx:           "",
+				Group:              group,
+				Prefix:             "",
+				RemovePrefix:       "",
+				JsonCase:           "SnakeScreaming",
+				ImportPrefix:       "",
+				DaoPath:            "",
+				DoPath:             "",
+				EntityPath:         "",
+				TplDaoIndexPath:    "",
+				TplDaoInternalPath: "",
+				TplDaoDoPath:       "",
+				TplDaoEntityPath:   "",
+				StdTime:            false,
+				WithTime:           false,
+				GJsonSupport:       false,
+				OverwriteDao:       false,
+				DescriptionTag:     false,
+				NoJsonTag:          false,
+				NoModelComment:     false,
+				Clear:              false,
+				TypeMapping:        nil,
+			}
+		)
+		err = gutil.FillStructWithDefault(&in)
+		t.AssertNil(err)
+
+		err = gfile.Copy(issueDirPath, path)
+		t.AssertNil(err)
+
+		defer gfile.Remove(path)
+
+		pwd := gfile.Pwd()
+		err = gfile.Chdir(path)
+		t.AssertNil(err)
+
+		defer gfile.Chdir(pwd)
+
+		_, err = gendao.CGenDao{}.Dao(ctx, in)
+		t.AssertNil(err)
+
+		generatedFiles, err := gfile.ScanDir(path, "*.go", true)
+		t.AssertNil(err)
+		t.Assert(len(generatedFiles), 8)
+		for i, generatedFile := range generatedFiles {
+			generatedFiles[i] = gstr.TrimLeftStr(generatedFile, path)
+		}
+		t.Assert(gstr.InArray(generatedFiles, "/dao/internal/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/internal/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/do/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/do/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/entity/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/entity/user_2.go"), true)
+	})
+}
+
+func Test_Gen_Dao_Issue2616(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			err          error
+			db           = testDB
+			table1       = "user1"
+			table2       = "user2"
+			issueDirPath = gtest.DataPath(`issue`, `2616`)
+		)
+		t.AssertNil(execSqlFile(db, gtest.DataPath(`issue`, `2616`, `sql1.sql`)))
+		t.AssertNil(execSqlFile(db, gtest.DataPath(`issue`, `2616`, `sql2.sql`)))
+		defer dropTableWithDb(db, table1)
+		defer dropTableWithDb(db, table2)
+
+		var (
+			path  = gfile.Temp(guid.S())
+			group = "test"
+			in    = gendao.CGenDaoInput{
+				Path:               path,
+				Link:               link,
+				Tables:             "",
+				TablesEx:           "",
+				Group:              group,
+				Prefix:             "",
+				RemovePrefix:       "",
+				JsonCase:           "SnakeScreaming",
+				ImportPrefix:       "",
+				DaoPath:            "",
+				DoPath:             "",
+				EntityPath:         "",
+				TplDaoIndexPath:    "",
+				TplDaoInternalPath: "",
+				TplDaoDoPath:       "",
+				TplDaoEntityPath:   "",
+				StdTime:            false,
+				WithTime:           false,
+				GJsonSupport:       false,
+				OverwriteDao:       false,
+				DescriptionTag:     false,
+				NoJsonTag:          false,
+				NoModelComment:     false,
+				Clear:              false,
+				TypeMapping:        nil,
+			}
+		)
+		err = gutil.FillStructWithDefault(&in)
+		t.AssertNil(err)
+
+		err = gfile.Copy(issueDirPath, path)
+		t.AssertNil(err)
+
+		defer gfile.Remove(path)
+
+		pwd := gfile.Pwd()
+		err = gfile.Chdir(path)
+		t.AssertNil(err)
+
+		defer gfile.Chdir(pwd)
+
+		_, err = gendao.CGenDao{}.Dao(ctx, in)
+		t.AssertNil(err)
+
+		generatedFiles, err := gfile.ScanDir(path, "*.go", true)
+		t.AssertNil(err)
+		t.Assert(len(generatedFiles), 8)
+		for i, generatedFile := range generatedFiles {
+			generatedFiles[i] = gstr.TrimLeftStr(generatedFile, path)
+		}
+		t.Assert(gstr.InArray(generatedFiles, "/dao/internal/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/internal/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/dao/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/do/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/do/user_2.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/entity/user_1.go"), true)
+		t.Assert(gstr.InArray(generatedFiles, "/model/entity/user_2.go"), true)
+
+		// Key string to check if overwrite the dao files.
+		// dao user1 is not be overwritten as configured in config.yaml.
+		// dao user2 is to  be overwritten as configured in config.yaml.
+		var (
+			keyStr          = `// I am not overwritten.`
+			daoUser1Content = gfile.GetContents(path + "/dao/user_1.go")
+			daoUser2Content = gfile.GetContents(path + "/dao/user_2.go")
+		)
+		t.Assert(gstr.Contains(daoUser1Content, keyStr), true)
+		t.Assert(gstr.Contains(daoUser2Content, keyStr), false)
+	})
+}

cmd/gf/internal/cmd/cmd_z_unit_gen_service_test.go

@@ -7,13 +7,14 @@
 package cmd
 
 import (
+	"path/filepath"
+	"testing"
+
 	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/genservice"
 	"github.com/gogf/gf/v2/os/gfile"
 	"github.com/gogf/gf/v2/test/gtest"
 	"github.com/gogf/gf/v2/util/guid"
 	"github.com/gogf/gf/v2/util/gutil"
-	"path/filepath"
-	"testing"
 )
 
 func Test_Gen_Service_Default(t *testing.T) {

cmd/gf/internal/cmd/gendao/gendao.go

@@ -201,7 +201,8 @@ type (
 		NoModelComment     bool   `name:"noModelComment"      short:"m"  brief:"{CGenDaoBriefNoModelComment}" orphan:"true"`
 		Clear              bool   `name:"clear"               short:"a"  brief:"{CGenDaoBriefClear}" orphan:"true"`
 
-		TypeMapping map[DBFieldTypeName]CustomAttributeType `name:"typeMapping" short:"y" brief:"{CGenDaoBriefTypeMapping}" orphan:"true"`
+		TypeMapping        map[DBFieldTypeName]CustomAttributeType `name:"typeMapping" short:"y" brief:"{CGenDaoBriefTypeMapping}" orphan:"true"`
+		generatedFilePaths *CGenDaoInternalGeneratedFilePaths
 	}
 	CGenDaoOutput struct{}
 
@@ -212,6 +213,13 @@ type (
 		NewTableNames []string
 	}
 
+	CGenDaoInternalGeneratedFilePaths struct {
+		DaoFilePaths         []string
+		DaoInternalFilePaths []string
+		DoFilePaths          []string
+		EntityFilePaths      []string
+	}
+
 	DBFieldTypeName     = string
 	CustomAttributeType struct {
 		Type   string `brief:"custom attribute type name"`
@@ -220,6 +228,12 @@ type (
 )
 
 func (c CGenDao) Dao(ctx context.Context, in CGenDaoInput) (out *CGenDaoOutput, err error) {
+	in.generatedFilePaths = &CGenDaoInternalGeneratedFilePaths{
+		DaoFilePaths:         make([]string, 0),
+		DaoInternalFilePaths: make([]string, 0),
+		DoFilePaths:          make([]string, 0),
+		EntityFilePaths:      make([]string, 0),
+	}
 	if g.Cfg().Available(ctx) {
 		v := g.Cfg().MustGet(ctx, CGenDaoConfig)
 		if v.IsSlice() {
@@ -333,6 +347,10 @@ func doGenDaoForArray(ctx context.Context, index int, in CGenDaoInput) {
 		TableNames:    tableNames,
 		NewTableNames: newTableNames,
 	})
+
+	if in.Clear {
+		doClear(ctx, in)
+	}
 }
 
 func getImportPartContent(ctx context.Context, source string, isDo bool, appendImports []string) string {

cmd/gf/internal/cmd/gendao/gendao_clear.go

@@ -10,19 +10,24 @@ import (
 	"context"
 
 	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/text/gstr"
 
 	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
-	"github.com/gogf/gf/cmd/gf/v2/internal/utility/utils"
 )
 
-func doClear(ctx context.Context, dirPath string, force bool) {
-	files, err := gfile.ScanDirFile(dirPath, "*.go", true)
+func doClear(ctx context.Context, in CGenDaoInput) {
+	filePaths, err := gfile.ScanDirFile(in.Path, "*.go", true)
 	if err != nil {
 		mlog.Fatal(err)
 	}
-	for _, file := range files {
-		if force || utils.IsFileDoNotEdit(file) {
-			if err = gfile.Remove(file); err != nil {
+	var allGeneratedFilePaths = make([]string, 0)
+	allGeneratedFilePaths = append(allGeneratedFilePaths, in.generatedFilePaths.DaoFilePaths...)
+	allGeneratedFilePaths = append(allGeneratedFilePaths, in.generatedFilePaths.DaoInternalFilePaths...)
+	allGeneratedFilePaths = append(allGeneratedFilePaths, in.generatedFilePaths.EntityFilePaths...)
+	allGeneratedFilePaths = append(allGeneratedFilePaths, in.generatedFilePaths.DoFilePaths...)
+	for _, filePath := range filePaths {
+		if !gstr.InArray(allGeneratedFilePaths, filePath) {
+			if err = gfile.Remove(filePath); err != nil {
 				mlog.Print(err)
 			}
 		}

cmd/gf/internal/cmd/gendao/gendao_dao.go

@@ -30,9 +30,6 @@ func generateDao(ctx context.Context, in CGenDaoInternalInput) {
 		dirPathDao         = gfile.Join(in.Path, in.DaoPath)
 		dirPathDaoInternal = gfile.Join(dirPathDao, "internal")
 	)
-	if in.Clear {
-		doClear(ctx, dirPathDao, true)
-	}
 	for i := 0; i < len(in.TableNames); i++ {
 		generateDaoSingle(ctx, generateDaoSingleInput{
 			CGenDaoInternalInput: in,
@@ -108,6 +105,11 @@ type generateDaoIndexInput struct {
 
 func generateDaoIndex(in generateDaoIndexInput) {
 	path := filepath.FromSlash(gfile.Join(in.DirPathDao, in.FileName+".go"))
+	// It should add path to result slice whenever it would generate the path file or not.
+	in.generatedFilePaths.DaoFilePaths = append(
+		in.generatedFilePaths.DaoFilePaths,
+		path,
+	)
 	if in.OverwriteDao || !gfile.Exists(path) {
 		indexContent := gstr.ReplaceByMap(
 			getTemplateFromPathOrDefault(in.TplDaoIndexPath, consts.TemplateGenDaoIndexContent),
@@ -151,6 +153,10 @@ func generateDaoInternal(in generateDaoInternalInput) {
 			tplVarColumnNames:             gstr.Trim(generateColumnNamesForDao(in.FieldMap, removeFieldPrefixArray)),
 		})
 	modelContent = replaceDefaultVar(in.CGenDaoInternalInput, modelContent)
+	in.generatedFilePaths.DaoInternalFilePaths = append(
+		in.generatedFilePaths.DaoInternalFilePaths,
+		path,
+	)
 	if err := gfile.PutContents(path, strings.TrimSpace(modelContent)); err != nil {
 		mlog.Fatalf("writing content to '%s' failed: %v", path, err)
 	} else {

cmd/gf/internal/cmd/gendao/gendao_do.go

@@ -24,9 +24,6 @@ import (
 
 func generateDo(ctx context.Context, in CGenDaoInternalInput) {
 	var dirPathDo = filepath.FromSlash(gfile.Join(in.Path, in.DoPath))
-	if in.Clear {
-		doClear(ctx, dirPathDo, false)
-	}
 	in.NoJsonTag = true
 	in.DescriptionTag = false
 	in.NoModelComment = false
@@ -66,6 +63,10 @@ func generateDo(ctx context.Context, in CGenDaoInternalInput) {
 			gstr.CaseCamel(newTableName),
 			structDefinition,
 		)
+		in.generatedFilePaths.DoFilePaths = append(
+			in.generatedFilePaths.DoFilePaths,
+			doFilePath,
+		)
 		err = gfile.PutContents(doFilePath, strings.TrimSpace(modelContent))
 		if err != nil {
 			mlog.Fatalf(`writing content to "%s" failed: %v`, doFilePath, err)

cmd/gf/internal/cmd/gendao/gendao_entity.go

@@ -22,9 +22,6 @@ import (
 
 func generateEntity(ctx context.Context, in CGenDaoInternalInput) {
 	var dirPathEntity = gfile.Join(in.Path, in.EntityPath)
-	if in.Clear {
-		doClear(ctx, dirPathEntity, false)
-	}
 	// Model content.
 	for i, tableName := range in.TableNames {
 		fieldMap, err := in.DB.TableFields(ctx, tableName)
@@ -51,7 +48,10 @@ func generateEntity(ctx context.Context, in CGenDaoInternalInput) {
 				appendImports,
 			)
 		)
-
+		in.generatedFilePaths.EntityFilePaths = append(
+			in.generatedFilePaths.EntityFilePaths,
+			entityFilePath,
+		)
 		err = gfile.PutContents(entityFilePath, strings.TrimSpace(entityContent))
 		if err != nil {
 			mlog.Fatalf("writing content to '%s' failed: %v", entityFilePath, err)

cmd/gf/internal/cmd/genservice/genservice.go

@@ -174,7 +174,7 @@ func (c CGenService) Service(ctx context.Context, in CGenServiceInput) (out *CGe
 		// Parse single logic package folder.
 		var (
 			// StructName => FunctionDefinitions
-			srcPkgInterfaceMap   = make(map[string]*garray.StrArray)
+			srcPkgInterfaceMap   = gmap.NewListMap()
 			srcImportedPackages  = garray.NewSortedStrArray().SetUnique(true)
 			importAliasToPathMap = gmap.NewStrStrMap() // for conflict imports check. alias => import path(with `"`)
 			importPathToAliasMap = gmap.NewStrStrMap() // for conflict imports check. import path(with `"`) => alias

cmd/gf/internal/cmd/genservice/genservice_calculate.go

@@ -12,6 +12,7 @@ import (
 	"go/token"
 
 	"github.com/gogf/gf/v2/container/garray"
+	"github.com/gogf/gf/v2/container/gmap"
 	"github.com/gogf/gf/v2/text/gregex"
 	"github.com/gogf/gf/v2/text/gstr"
 )
@@ -99,10 +100,9 @@ func (c CGenService) calculateCodeCommented(in CGenServiceInput, fileContent str
 }
 
 func (c CGenService) calculateInterfaceFunctions(
-	in CGenServiceInput, fileContent string, srcPkgInterfaceMap map[string]*garray.StrArray,
+	in CGenServiceInput, fileContent string, srcPkgInterfaceMap *gmap.ListMap,
 ) (err error) {
 	var (
-		ok                       bool
 		matches                  [][]string
 		srcPkgInterfaceFuncArray *garray.StrArray
 	)
@@ -142,9 +142,11 @@ func (c CGenService) calculateInterfaceFunctions(
 			continue
 		}
 		structName = gstr.CaseCamel(structMatch[1])
-		if srcPkgInterfaceFuncArray, ok = srcPkgInterfaceMap[structName]; !ok {
-			srcPkgInterfaceMap[structName] = garray.NewStrArray()
-			srcPkgInterfaceFuncArray = srcPkgInterfaceMap[structName]
+		if !srcPkgInterfaceMap.Contains(structName) {
+			srcPkgInterfaceFuncArray = garray.NewStrArray()
+			srcPkgInterfaceMap.Set(structName, srcPkgInterfaceFuncArray)
+		} else {
+			srcPkgInterfaceFuncArray = srcPkgInterfaceMap.Get(structName).(*garray.StrArray)
 		}
 		srcPkgInterfaceFuncArray.Append(functionHead)
 	}
@@ -165,8 +167,8 @@ func (c CGenService) calculateInterfaceFunctions(
 			continue
 		}
 		structName = gstr.CaseCamel(structMatch[1])
-		if srcPkgInterfaceFuncArray, ok = srcPkgInterfaceMap[structName]; !ok {
-			srcPkgInterfaceMap[structName] = garray.NewStrArray()
+		if !srcPkgInterfaceMap.Contains(structName) {
+			srcPkgInterfaceMap.Set(structName, garray.NewStrArray())
 		}
 	}
 	return nil

cmd/gf/internal/cmd/genservice/genservice_generate.go

@@ -10,6 +10,7 @@ import (
 	"fmt"
 
 	"github.com/gogf/gf/v2/container/garray"
+	"github.com/gogf/gf/v2/container/gmap"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gfile"
 	"github.com/gogf/gf/v2/text/gregex"
@@ -23,7 +24,7 @@ import (
 type generateServiceFilesInput struct {
 	CGenServiceInput
 	DstFilePath         string // Absolute file path for generated service go file.
-	SrcStructFunctions  map[string]*garray.StrArray
+	SrcStructFunctions  *gmap.ListMap
 	SrcImportedPackages []string
 	SrcPackageName      string
 	DstPackageName      string
@@ -46,7 +47,8 @@ func (c CGenService) generateServiceFile(in generateServiceFilesInput) (ok bool,
 	// Type definitions.
 	generatedContent += "type("
 	generatedContent += "\n"
-	for structName, funcArray := range in.SrcStructFunctions {
+	in.SrcStructFunctions.Iterator(func(key, value interface{}) bool {
+		structName, funcArray := key.(string), value.(*garray.StrArray)
 		allFuncArray.Append(funcArray.Slice()...)
 		// Add comments to a method.
 		for index, funcName := range funcArray.Slice() {
@@ -60,7 +62,8 @@ func (c CGenService) generateServiceFile(in generateServiceFilesInput) (ok bool,
 			"{FuncDefinition}": funcArray.Join("\n\t"),
 		}))
 		generatedContent += "\n"
-	}
+		return true
+	})
 	generatedContent += ")"
 	generatedContent += "\n"
 
@@ -70,17 +73,19 @@ func (c CGenService) generateServiceFile(in generateServiceFilesInput) (ok bool,
 		generatingInterfaceCheck string
 	)
 	// Variable definitions.
-	for structName := range in.SrcStructFunctions {
+	in.SrcStructFunctions.Iterator(func(key, value interface{}) bool {
+		structName := key.(string)
 		generatingInterfaceCheck = fmt.Sprintf(`[^\w\d]+%s.I%s[^\w\d]`, in.DstPackageName, structName)
 		if gregex.IsMatchString(generatingInterfaceCheck, generatedContent) {
-			continue
+			return true
 		}
 		variableContent += gstr.Trim(gstr.ReplaceByMap(consts.TemplateGenServiceContentVariable, g.MapStrStr{
 			"{StructName}":    structName,
 			"{InterfaceName}": "I" + structName,
 		}))
 		variableContent += "\n"
-	}
+		return true
+	})
 	if variableContent != "" {
 		generatedContent += "var("
 		generatedContent += "\n"
@@ -89,17 +94,19 @@ func (c CGenService) generateServiceFile(in generateServiceFilesInput) (ok bool,
 		generatedContent += "\n"
 	}
 	// Variable register function definitions.
-	for structName := range in.SrcStructFunctions {
+	in.SrcStructFunctions.Iterator(func(key, value interface{}) bool {
+		structName := key.(string)
 		generatingInterfaceCheck = fmt.Sprintf(`[^\w\d]+%s.I%s[^\w\d]`, in.DstPackageName, structName)
 		if gregex.IsMatchString(generatingInterfaceCheck, generatedContent) {
-			continue
+			return true
 		}
 		generatedContent += gstr.Trim(gstr.ReplaceByMap(consts.TemplateGenServiceContentRegister, g.MapStrStr{
 			"{StructName}":    structName,
 			"{InterfaceName}": "I" + structName,
 		}))
 		generatedContent += "\n\n"
-	}
+		return true
+	})
 
 	// Replace empty braces that have new line.
 	generatedContent, _ = gregex.ReplaceString(`{[\s\t]+}`, `{}`, generatedContent)

cmd/gf/internal/cmd/testdata/build/multiple/multiple.go

@@ -0,0 +1,5 @@
+package main
+
+func main() {
+
+}

cmd/gf/internal/cmd/testdata/build/single/main.go

@@ -0,0 +1,5 @@
+package main
+
+func main() {
+
+}

cmd/gf/internal/cmd/testdata/build/varmap/go.mod

@@ -0,0 +1,12 @@
+module github.com/gogf/gf/cmd/gf/cmd/gf/testdata/vardump/v2
+
+go 1.18
+
+require github.com/gogf/gf/v2 v2.6.1
+
+require (
+	go.opentelemetry.io/otel v1.14.0 // indirect
+	go.opentelemetry.io/otel/trace v1.14.0 // indirect
+)
+
+replace github.com/gogf/gf/v2 => ../../../../../../../

cmd/gf/internal/cmd/testdata/build/varmap/go.sum

@@ -0,0 +1,27 @@
+github.com/BurntSushi/toml v1.2.0 h1:Rt8g24XnyGTyglgET/PRUNlrUeu9F5L+7FilkXfZgs0=
+github.com/clbanning/mxj/v2 v2.7.0 h1:WA/La7UGCanFe5NpHF0Q3DNtnCsVoxbPKuyBNHWRyME=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/fatih/color v1.15.0 h1:kOqh6YHBtK8aywxGerMG2Eq3H6Qgoqeo13Bk2Mv/nBs=
+github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA=
+github.com/go-logr/logr v1.2.4 h1:g01GSCwiDw2xSZfjJ2/T9M+S6pFdcNtFYsp+Y43HYDQ=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
+github.com/grokify/html-strip-tags-go v0.0.1 h1:0fThFwLbW7P/kOiTBs03FsJSV9RM2M/Q/MOnCQxKMo0=
+github.com/magiconair/properties v1.8.6 h1:5ibWZ6iY0NctNGWo87LalDlEZ6R41TqbbDamhfG/Qzo=
+github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
+github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
+github.com/mattn/go-runewidth v0.0.15 h1:UNAjwbU9l54TA3KzvqLGxwWjHmMgBUVhBiTjelZgg3U=
+github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N7AbDhec=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/rivo/uniseg v0.4.4 h1:8TfxU8dW6PdqD27gjM8MVNuicgxIjxpm4K7x4jp8sis=
+github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
+go.opentelemetry.io/otel v1.14.0 h1:/79Huy8wbf5DnIPhemGB+zEPVwnN6fuQybr/SRXa6hM=
+go.opentelemetry.io/otel v1.14.0/go.mod h1:o4buv+dJzx8rohcUeRmWUZhqupFvzWis188WlggnNeU=
+go.opentelemetry.io/otel/sdk v1.14.0 h1:PDCppFRDq8A1jL9v6KMI6dYesaq+DFcDZvjsoGvxGzY=
+go.opentelemetry.io/otel/trace v1.14.0 h1:wp2Mmvj41tDsyAJXiWDWpfNsOiIyd38fy85pyKcFq/M=
+go.opentelemetry.io/otel/trace v1.14.0/go.mod h1:8avnQLK+CG77yNLUae4ea2JDQ6iT+gozhnZjy/rw9G8=
+golang.org/x/net v0.17.0 h1:pVaXccu2ozPjCXewfr1S7xza/zcXTity9cCdXQYSjIM=
+golang.org/x/sys v0.13.0 h1:Af8nKPmuFypiUBjVoU9V20FiaFXOcuZI21p0ycVYYGE=
+golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

cmd/gf/internal/cmd/testdata/build/varmap/main.go

@@ -0,0 +1,13 @@
+package main
+
+import (
+	"fmt"
+
+	"github.com/gogf/gf/v2/os/gbuild"
+)
+
+func main() {
+	for k, v := range gbuild.Data() {
+		fmt.Printf("%s: %v\n", k, v)
+	}
+}

cmd/gf/internal/cmd/testdata/genservice/logic/article/article.go

@@ -8,6 +8,7 @@ package article
 
 import (
 	"context"
+
 	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genservice/service"
 )
 

cmd/gf/internal/cmd/testdata/issue/2572/config.yaml

@@ -0,0 +1,20 @@
+gfcli:
+  gen:
+    dao:
+      - link: "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
+        tables: "user1"
+        descriptionTag: true
+        noModelComment: true
+        group: "sys"
+        clear: true
+        overwriteDao: true
+      - link: "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
+        tables: "user2"
+        descriptionTag: true
+        noModelComment: true
+        group: "book"
+        clear: true
+        overwriteDao: true
+
+
+

cmd/gf/internal/cmd/testdata/issue/2572/dao/internal/user_3.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User3Dao is the data access object for table user3.
+type User3Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User3Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User3Columns defines and stores column names for table user3.
+type User3Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user3Columns holds the columns for table user3.
+var user3Columns = User3Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser3Dao creates and returns a new DAO object for table data access.
+func NewUser3Dao() *User3Dao {
+	return &User3Dao{
+		group:   "sys",
+		table:   "user3",
+		columns: user3Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User3Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User3Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User3Dao) Columns() User3Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User3Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User3Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User3Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2572/dao/internal/user_4.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User4Dao is the data access object for table user4.
+type User4Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User4Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User4Columns defines and stores column names for table user4.
+type User4Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user4Columns holds the columns for table user4.
+var user4Columns = User4Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser4Dao creates and returns a new DAO object for table data access.
+func NewUser4Dao() *User4Dao {
+	return &User4Dao{
+		group:   "book",
+		table:   "user4",
+		columns: user4Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User4Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User4Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User4Dao) Columns() User4Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User4Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User4Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User4Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2572/dao/user_3.go

@@ -0,0 +1,27 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser3Dao is internal type for wrapping internal DAO implements.
+type internalUser3Dao = *internal.User3Dao
+
+// user3Dao is the data access object for table user3.
+// You can define custom methods on it to extend its functionality as you wish.
+type user3Dao struct {
+	internalUser3Dao
+}
+
+var (
+	// User3 is globally public accessible object for table user3 operations.
+	User3 = user3Dao{
+		internal.NewUser3Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2572/dao/user_4.go

@@ -0,0 +1,27 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser4Dao is internal type for wrapping internal DAO implements.
+type internalUser4Dao = *internal.User4Dao
+
+// user4Dao is the data access object for table user4.
+// You can define custom methods on it to extend its functionality as you wish.
+type user4Dao struct {
+	internalUser4Dao
+}
+
+var (
+	// User4 is globally public accessible object for table user4 operations.
+	User4 = user4Dao{
+		internal.NewUser4Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2572/model/do/user_3.go

@@ -0,0 +1,22 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package do
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User1 is the golang structure of table user1 for DAO operations like Where/Data.
+type User1 struct {
+	g.Meta   `orm:"table:user1, do:true"`
+	Id       interface{} // User ID
+	Passport interface{} // User Passport
+	Password interface{} // User Password
+	Nickname interface{} // User Nickname
+	Score    interface{} // Total score amount.
+	CreateAt *gtime.Time // Created Time
+	UpdateAt *gtime.Time // Updated Time
+}

cmd/gf/internal/cmd/testdata/issue/2572/model/do/user_4.go

@@ -0,0 +1,22 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package do
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User2 is the golang structure of table user2 for DAO operations like Where/Data.
+type User2 struct {
+	g.Meta   `orm:"table:user2, do:true"`
+	Id       interface{} // User ID
+	Passport interface{} // User Passport
+	Password interface{} // User Password
+	Nickname interface{} // User Nickname
+	Score    interface{} // Total score amount.
+	CreateAt *gtime.Time // Created Time
+	UpdateAt *gtime.Time // Updated Time
+}

cmd/gf/internal/cmd/testdata/issue/2572/model/entity/user_3.go

@@ -0,0 +1,20 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package entity
+
+import (
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User1 is the golang structure for table user1.
+type User1 struct {
+	Id       uint        `json:"ID"        description:"User ID"`
+	Passport string      `json:"PASSPORT"  description:"User Passport"`
+	Password string      `json:"PASSWORD"  description:"User Password"`
+	Nickname string      `json:"NICKNAME"  description:"User Nickname"`
+	Score    float64     `json:"SCORE"     description:"Total score amount."`
+	CreateAt *gtime.Time `json:"CREATE_AT" description:"Created Time"`
+	UpdateAt *gtime.Time `json:"UPDATE_AT" description:"Updated Time"`
+}

cmd/gf/internal/cmd/testdata/issue/2572/model/entity/user_4.go

@@ -0,0 +1,20 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package entity
+
+import (
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User2 is the golang structure for table user2.
+type User2 struct {
+	Id       uint        `json:"ID"        description:"User ID"`
+	Passport string      `json:"PASSPORT"  description:"User Passport"`
+	Password string      `json:"PASSWORD"  description:"User Password"`
+	Nickname string      `json:"NICKNAME"  description:"User Nickname"`
+	Score    float64     `json:"SCORE"     description:"Total score amount."`
+	CreateAt *gtime.Time `json:"CREATE_AT" description:"Created Time"`
+	UpdateAt *gtime.Time `json:"UPDATE_AT" description:"Updated Time"`
+}

cmd/gf/internal/cmd/testdata/issue/2572/sql1.sql

@@ -0,0 +1,10 @@
+CREATE TABLE `user1` (
+    `id` int unsigned NOT NULL AUTO_INCREMENT COMMENT 'User ID',
+    `passport` varchar(45) NOT NULL COMMENT 'User Passport',
+    `password` varchar(45) NOT NULL COMMENT 'User Password',
+    `nickname` varchar(45) NOT NULL COMMENT 'User Nickname',
+    `score` decimal(10,2) unsigned DEFAULT NULL COMMENT 'Total score amount.',
+    `create_at` datetime DEFAULT NULL COMMENT 'Created Time',
+    `update_at` datetime DEFAULT NULL COMMENT 'Updated Time',
+    PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;

cmd/gf/internal/cmd/testdata/issue/2572/sql2.sql

@@ -0,0 +1,10 @@
+CREATE TABLE `user2` (
+    `id` int unsigned NOT NULL AUTO_INCREMENT COMMENT 'User ID',
+    `passport` varchar(45) NOT NULL COMMENT 'User Passport',
+    `password` varchar(45) NOT NULL COMMENT 'User Password',
+    `nickname` varchar(45) NOT NULL COMMENT 'User Nickname',
+    `score` decimal(10,2) unsigned DEFAULT NULL COMMENT 'Total score amount.',
+    `create_at` datetime DEFAULT NULL COMMENT 'Created Time',
+    `update_at` datetime DEFAULT NULL COMMENT 'Updated Time',
+    PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;

cmd/gf/internal/cmd/testdata/issue/2616/config.yaml

@@ -0,0 +1,20 @@
+gfcli:
+  gen:
+    dao:
+      - link: "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
+        tables: "user1"
+        descriptionTag: true
+        noModelComment: true
+        group: "sys"
+        clear: true
+        overwriteDao: false
+      - link: "mysql:root:12345678@tcp(127.0.0.1:3306)/test"
+        tables: "user2"
+        descriptionTag: true
+        noModelComment: true
+        group: "book"
+        clear: true
+        overwriteDao: true
+
+
+

cmd/gf/internal/cmd/testdata/issue/2616/dao/internal/user_1.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User1Dao is the data access object for table user1.
+type User1Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User1Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User1Columns defines and stores column names for table user1.
+type User1Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user1Columns holds the columns for table user1.
+var user1Columns = User1Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser1Dao creates and returns a new DAO object for table data access.
+func NewUser1Dao() *User1Dao {
+	return &User1Dao{
+		group:   "sys",
+		table:   "user1",
+		columns: user1Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User1Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User1Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User1Dao) Columns() User1Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User1Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User1Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User1Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2616/dao/internal/user_2.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User2Dao is the data access object for table user2.
+type User2Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User2Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User2Columns defines and stores column names for table user2.
+type User2Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user2Columns holds the columns for table user2.
+var user2Columns = User2Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser2Dao creates and returns a new DAO object for table data access.
+func NewUser2Dao() *User2Dao {
+	return &User2Dao{
+		group:   "sys",
+		table:   "user2",
+		columns: user2Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User2Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User2Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User2Dao) Columns() User2Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User2Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User2Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User2Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2616/dao/internal/user_3.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User3Dao is the data access object for table user3.
+type User3Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User3Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User3Columns defines and stores column names for table user3.
+type User3Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user3Columns holds the columns for table user3.
+var user3Columns = User3Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser3Dao creates and returns a new DAO object for table data access.
+func NewUser3Dao() *User3Dao {
+	return &User3Dao{
+		group:   "sys",
+		table:   "user3",
+		columns: user3Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User3Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User3Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User3Dao) Columns() User3Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User3Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User3Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User3Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2616/dao/internal/user_4.go

@@ -0,0 +1,85 @@
+// ==========================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// ==========================================================================
+
+package internal
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/frame/g"
+)
+
+// User4Dao is the data access object for table user4.
+type User4Dao struct {
+	table   string       // table is the underlying table name of the DAO.
+	group   string       // group is the database configuration group name of current DAO.
+	columns User4Columns // columns contains all the column names of Table for convenient usage.
+}
+
+// User4Columns defines and stores column names for table user4.
+type User4Columns struct {
+	Id       string // User ID
+	Passport string // User Passport
+	Password string // User Password
+	Nickname string // User Nickname
+	Score    string // Total score amount.
+	CreateAt string // Created Time
+	UpdateAt string // Updated Time
+}
+
+// user4Columns holds the columns for table user4.
+var user4Columns = User4Columns{
+	Id:       "id",
+	Passport: "passport",
+	Password: "password",
+	Nickname: "nickname",
+	Score:    "score",
+	CreateAt: "create_at",
+	UpdateAt: "update_at",
+}
+
+// NewUser4Dao creates and returns a new DAO object for table data access.
+func NewUser4Dao() *User4Dao {
+	return &User4Dao{
+		group:   "book",
+		table:   "user4",
+		columns: user4Columns,
+	}
+}
+
+// DB retrieves and returns the underlying raw database management object of current DAO.
+func (dao *User4Dao) DB() gdb.DB {
+	return g.DB(dao.group)
+}
+
+// Table returns the table name of current dao.
+func (dao *User4Dao) Table() string {
+	return dao.table
+}
+
+// Columns returns all column names of current dao.
+func (dao *User4Dao) Columns() User4Columns {
+	return dao.columns
+}
+
+// Group returns the configuration group name of database of current dao.
+func (dao *User4Dao) Group() string {
+	return dao.group
+}
+
+// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
+func (dao *User4Dao) Ctx(ctx context.Context) *gdb.Model {
+	return dao.DB().Model(dao.table).Safe().Ctx(ctx)
+}
+
+// Transaction wraps the transaction logic using function f.
+// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
+// It commits the transaction and returns nil if function f returns nil.
+//
+// Note that, you should not Commit or Rollback the transaction in function f
+// as it is automatically handled by this function.
+func (dao *User4Dao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) {
+	return dao.Ctx(ctx).Transaction(ctx, f)
+}

cmd/gf/internal/cmd/testdata/issue/2616/dao/user_1.go

@@ -0,0 +1,29 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+// I am not overwritten.
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser1Dao is internal type for wrapping internal DAO implements.
+type internalUser1Dao = *internal.User1Dao
+
+// user1Dao is the data access object for table user1.
+// You can define custom methods on it to extend its functionality as you wish.
+type user1Dao struct {
+	internalUser1Dao
+}
+
+var (
+	// User1 is globally public accessible object for table user1 operations.
+	User1 = user1Dao{
+		internal.NewUser1Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2616/dao/user_2.go

@@ -0,0 +1,29 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+// I am not overwritten.
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser2Dao is internal type for wrapping internal DAO implements.
+type internalUser2Dao = *internal.User2Dao
+
+// user2Dao is the data access object for table user2.
+// You can define custom methods on it to extend its functionality as you wish.
+type user2Dao struct {
+	internalUser2Dao
+}
+
+var (
+	// User2 is globally public accessible object for table user2 operations.
+	User2 = user2Dao{
+		internal.NewUser2Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2616/dao/user_3.go

@@ -0,0 +1,27 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser3Dao is internal type for wrapping internal DAO implements.
+type internalUser3Dao = *internal.User3Dao
+
+// user3Dao is the data access object for table user3.
+// You can define custom methods on it to extend its functionality as you wish.
+type user3Dao struct {
+	internalUser3Dao
+}
+
+var (
+	// User3 is globally public accessible object for table user3 operations.
+	User3 = user3Dao{
+		internal.NewUser3Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2616/dao/user_4.go

@@ -0,0 +1,27 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package dao
+
+import (
+	"/internal"
+)
+
+// internalUser4Dao is internal type for wrapping internal DAO implements.
+type internalUser4Dao = *internal.User4Dao
+
+// user4Dao is the data access object for table user4.
+// You can define custom methods on it to extend its functionality as you wish.
+type user4Dao struct {
+	internalUser4Dao
+}
+
+var (
+	// User4 is globally public accessible object for table user4 operations.
+	User4 = user4Dao{
+		internal.NewUser4Dao(),
+	}
+)
+
+// Fill with you ideas below.

cmd/gf/internal/cmd/testdata/issue/2616/model/do/user_3.go

@@ -0,0 +1,22 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package do
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User1 is the golang structure of table user1 for DAO operations like Where/Data.
+type User1 struct {
+	g.Meta   `orm:"table:user1, do:true"`
+	Id       interface{} // User ID
+	Passport interface{} // User Passport
+	Password interface{} // User Password
+	Nickname interface{} // User Nickname
+	Score    interface{} // Total score amount.
+	CreateAt *gtime.Time // Created Time
+	UpdateAt *gtime.Time // Updated Time
+}

cmd/gf/internal/cmd/testdata/issue/2616/model/do/user_4.go

@@ -0,0 +1,22 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package do
+
+import (
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User2 is the golang structure of table user2 for DAO operations like Where/Data.
+type User2 struct {
+	g.Meta   `orm:"table:user2, do:true"`
+	Id       interface{} // User ID
+	Passport interface{} // User Passport
+	Password interface{} // User Password
+	Nickname interface{} // User Nickname
+	Score    interface{} // Total score amount.
+	CreateAt *gtime.Time // Created Time
+	UpdateAt *gtime.Time // Updated Time
+}

cmd/gf/internal/cmd/testdata/issue/2616/model/entity/user_3.go

@@ -0,0 +1,20 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package entity
+
+import (
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User1 is the golang structure for table user1.
+type User1 struct {
+	Id       uint        `json:"ID"        description:"User ID"`
+	Passport string      `json:"PASSPORT"  description:"User Passport"`
+	Password string      `json:"PASSWORD"  description:"User Password"`
+	Nickname string      `json:"NICKNAME"  description:"User Nickname"`
+	Score    float64     `json:"SCORE"     description:"Total score amount."`
+	CreateAt *gtime.Time `json:"CREATE_AT" description:"Created Time"`
+	UpdateAt *gtime.Time `json:"UPDATE_AT" description:"Updated Time"`
+}

cmd/gf/internal/cmd/testdata/issue/2616/model/entity/user_4.go

@@ -0,0 +1,20 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package entity
+
+import (
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// User2 is the golang structure for table user2.
+type User2 struct {
+	Id       uint        `json:"ID"        description:"User ID"`
+	Passport string      `json:"PASSPORT"  description:"User Passport"`
+	Password string      `json:"PASSWORD"  description:"User Password"`
+	Nickname string      `json:"NICKNAME"  description:"User Nickname"`
+	Score    float64     `json:"SCORE"     description:"Total score amount."`
+	CreateAt *gtime.Time `json:"CREATE_AT" description:"Created Time"`
+	UpdateAt *gtime.Time `json:"UPDATE_AT" description:"Updated Time"`
+}

cmd/gf/internal/cmd/testdata/issue/2616/sql1.sql

@@ -0,0 +1,10 @@
+CREATE TABLE `user1` (
+    `id` int unsigned NOT NULL AUTO_INCREMENT COMMENT 'User ID',
+    `passport` varchar(45) NOT NULL COMMENT 'User Passport',
+    `password` varchar(45) NOT NULL COMMENT 'User Password',
+    `nickname` varchar(45) NOT NULL COMMENT 'User Nickname',
+    `score` decimal(10,2) unsigned DEFAULT NULL COMMENT 'Total score amount.',
+    `create_at` datetime DEFAULT NULL COMMENT 'Created Time',
+    `update_at` datetime DEFAULT NULL COMMENT 'Updated Time',
+    PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;

cmd/gf/internal/cmd/testdata/issue/2616/sql2.sql

@@ -0,0 +1,10 @@
+CREATE TABLE `user2` (
+    `id` int unsigned NOT NULL AUTO_INCREMENT COMMENT 'User ID',
+    `passport` varchar(45) NOT NULL COMMENT 'User Passport',
+    `password` varchar(45) NOT NULL COMMENT 'User Password',
+    `nickname` varchar(45) NOT NULL COMMENT 'User Nickname',
+    `score` decimal(10,2) unsigned DEFAULT NULL COMMENT 'Total score amount.',
+    `create_at` datetime DEFAULT NULL COMMENT 'Created Time',
+    `update_at` datetime DEFAULT NULL COMMENT 'Updated Time',
+    PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;

cmd/gf/internal/utility/utils/utils.go

@@ -9,6 +9,7 @@ package utils
 import (
 	"context"
 	"fmt"
+
 	"golang.org/x/tools/imports"
 
 	"github.com/gogf/gf/cmd/gf/v2/internal/consts"

container/garray/garray_normal_int.go

@@ -173,7 +173,11 @@ func (a *IntArray) InsertBefore(index int, values ...int) error {
 	a.mu.Lock()
 	defer a.mu.Unlock()
 	if index < 0 || index >= len(a.array) {
-		return gerror.NewCodef(gcode.CodeInvalidParameter, "index %d out of array range %d", index, len(a.array))
+		return gerror.NewCodef(
+			gcode.CodeInvalidParameter,
+			"index %d out of array range %d",
+			index, len(a.array),
+		)
 	}
 	rear := append([]int{}, a.array[index:]...)
 	a.array = append(a.array[0:index], values...)
@@ -186,7 +190,11 @@ func (a *IntArray) InsertAfter(index int, values ...int) error {
 	a.mu.Lock()
 	defer a.mu.Unlock()
 	if index < 0 || index >= len(a.array) {
-		return gerror.NewCodef(gcode.CodeInvalidParameter, "index %d out of array range %d", index, len(a.array))
+		return gerror.NewCodef(
+			gcode.CodeInvalidParameter,
+			"index %d out of array range %d",
+			index, len(a.array),
+		)
 	}
 	rear := append([]int{}, a.array[index+1:]...)
 	a.array = append(a.array[0:index+1], values...)
@@ -583,7 +591,11 @@ func (a *IntArray) Fill(startIndex int, num int, value int) error {
 	a.mu.Lock()
 	defer a.mu.Unlock()
 	if startIndex < 0 || startIndex > len(a.array) {
-		return gerror.NewCodef(gcode.CodeInvalidParameter, "index %d out of array range %d", startIndex, len(a.array))
+		return gerror.NewCodef(
+			gcode.CodeInvalidParameter,
+			"index %d out of array range %d",
+			startIndex, len(a.array),
+		)
 	}
 	for i := startIndex; i < startIndex+num; i++ {
 		if i > len(a.array)-1 {

container/gqueue/gqueue_z_unit_test.go

@@ -75,7 +75,8 @@ func TestQueue_Close(t *testing.T) {
 		q1 := gqueue.New()
 		q1.Push(1)
 		q1.Push(2)
-		time.Sleep(time.Millisecond)
+		// wait sync to channel
+		time.Sleep(10 * time.Millisecond)
 		t.Assert(q1.Len(), 2)
 		q1.Close()
 	})
@@ -83,7 +84,8 @@ func TestQueue_Close(t *testing.T) {
 		q1 := gqueue.New(2)
 		q1.Push(1)
 		q1.Push(2)
-		time.Sleep(time.Millisecond)
+		// wait sync to channel
+		time.Sleep(10 * time.Millisecond)
 		t.Assert(q1.Len(), 2)
 		q1.Close()
 	})

container/gset/gset_z_example_int_test.go

@@ -42,7 +42,7 @@ func ExampleIntSet_Add() {
 	fmt.Println(intSet.Slice())
 	fmt.Println(intSet.AddIfNotExist(1))
 
-	// Mya Output:
+	// May Output:
 	// [1 2 3]
 	// false
 }
@@ -56,7 +56,7 @@ func ExampleIntSet_AddIfNotExist() {
 	fmt.Println(intSet.Slice())
 	fmt.Println(intSet.AddIfNotExist(1))
 
-	// Mya Output:
+	// May Output:
 	// [1 2 3]
 	// false
 }

container/gset/gset_z_example_str_test.go

@@ -42,13 +42,13 @@ func ExampleStrSet_Add() {
 	fmt.Println(strSet.Slice())
 	fmt.Println(strSet.AddIfNotExist("str"))
 
-	// Mya Output:
+	// May Output:
 	// [str str1 str2 str3]
 	// false
 }
 
 // AddIfNotExist checks whether item exists in the set,
-// it adds the item to set and returns true if it does not exists in the set,
+// it adds the item to set and returns true if it does not exist in the set,
 // or else it does nothing and returns false.
 func ExampleStrSet_AddIfNotExist() {
 	strSet := gset.NewStrSetFrom([]string{"str1", "str2", "str3"}, true)
@@ -56,13 +56,13 @@ func ExampleStrSet_AddIfNotExist() {
 	fmt.Println(strSet.Slice())
 	fmt.Println(strSet.AddIfNotExist("str"))
 
-	// Mya Output:
+	// May Output:
 	// [str str1 str2 str3]
 	// false
 }
 
 // AddIfNotExistFunc checks whether item exists in the set,
-// it adds the item to set and returns true if it does not exists in the set and function `f` returns true,
+// it adds the item to set and returns true if it does not exist in the set and function `f` returns true,
 // or else it does nothing and returns false.
 // Note that, the function `f` is executed without writing lock.
 func ExampleStrSet_AddIfNotExistFunc() {
@@ -79,7 +79,7 @@ func ExampleStrSet_AddIfNotExistFunc() {
 }
 
 // AddIfNotExistFunc checks whether item exists in the set,
-// it adds the item to set and returns true if it does not exists in the set and function `f` returns true,
+// it adds the item to set and returns true if it does not exist in the set and function `f` returns true,
 // or else it does nothing and returns false.
 // Note that, the function `f` is executed without writing lock.
 func ExampleStrSet_AddIfNotExistFuncLock() {

contrib/config/apollo/go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/apolloconfig/agollo/v4 v4.3.1
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 )
 
 require (

contrib/config/consul/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/consul/v2
 go 1.19
 
 require (
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 	github.com/hashicorp/consul/api v1.24.0
 	github.com/hashicorp/go-cleanhttp v0.5.2
 )

contrib/config/kubecm/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/kubecm/v2
 go 1.19
 
 require (
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 	k8s.io/api v0.27.4
 	k8s.io/apimachinery v0.27.4
 	k8s.io/client-go v0.27.4

contrib/config/nacos/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/nacos/v2
 go 1.18
 
 require (
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 	github.com/nacos-group/nacos-sdk-go v1.1.4
 )
 

contrib/config/polaris/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/polaris/v2
 go 1.18
 
 require (
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 	github.com/polarismesh/polaris-go v1.5.5
 )
 

contrib/drivers/clickhouse/clickhouse.go

@@ -9,25 +9,10 @@ package clickhouse
 
 import (
 	"context"
-	"database/sql"
-	"database/sql/driver"
 	"errors"
-	"fmt"
-	"net/url"
-	"strings"
-	"time"
-
-	"github.com/ClickHouse/clickhouse-go/v2"
-	"github.com/google/uuid"
-	"github.com/shopspring/decimal"
 
 	"github.com/gogf/gf/v2/database/gdb"
-	"github.com/gogf/gf/v2/errors/gcode"
-	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/os/gctx"
-	"github.com/gogf/gf/v2/os/gtime"
-	"github.com/gogf/gf/v2/text/gregex"
-	"github.com/gogf/gf/v2/util/gutil"
 )
 
 // Driver is the driver for postgresql database.
@@ -71,386 +56,9 @@ func (d *Driver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error) {
 	}, nil
 }
 
-// Open creates and returns an underlying sql.DB object for clickhouse.
-func (d *Driver) Open(config *gdb.ConfigNode) (db *sql.DB, err error) {
-	source := config.Link
-	// clickhouse://username:password@host1:9000,host2:9000/database?dial_timeout=200ms&max_execution_time=60
-	if config.Link != "" {
-		// ============================================================================
-		// Deprecated from v2.2.0.
-		// ============================================================================
-		// Custom changing the schema in runtime.
-		if config.Name != "" {
-			source, _ = gregex.ReplaceString(replaceSchemaPattern, "@$1/"+config.Name, config.Link)
-		} else {
-			// If no schema, the link is matched for replacement
-			dbName, _ := gregex.MatchString(replaceSchemaPattern, config.Link)
-			if len(dbName) > 0 {
-				config.Name = dbName[len(dbName)-1]
-			}
-		}
-	} else {
-		if config.Pass != "" {
-			source = fmt.Sprintf(
-				"clickhouse://%s:%s@%s:%s/%s?debug=%t",
-				config.User, url.PathEscape(config.Pass),
-				config.Host, config.Port, config.Name, config.Debug,
-			)
-		} else {
-			source = fmt.Sprintf(
-				"clickhouse://%s@%s:%s/%s?debug=%t",
-				config.User, config.Host, config.Port, config.Name, config.Debug,
-			)
-		}
-		if config.Extra != "" {
-			source = fmt.Sprintf("%s&%s", source, config.Extra)
-		}
-	}
-	if db, err = sql.Open(driverName, source); err != nil {
-		err = gerror.WrapCodef(
-			gcode.CodeDbOperationError, err,
-			`sql.Open failed for driver "%s" by source "%s"`, driverName, source,
-		)
-		return nil, err
-	}
-	return
-}
-
-// Tables retrieves and returns the tables of current schema.
-// It's mainly used in cli tool chain for automatically generating the models.
-func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error) {
-	var result gdb.Result
-	link, err := d.SlaveLink(schema...)
-	if err != nil {
-		return nil, err
-	}
-	query := fmt.Sprintf("select name from `system`.tables where database = '%s'", d.GetConfig().Name)
-	result, err = d.DoSelect(ctx, link, query)
-	if err != nil {
-		return
-	}
-	for _, m := range result {
-		tables = append(tables, m["name"].String())
-	}
-	return
-}
-
-// TableFields retrieves and returns the fields' information of specified table of current schema.
-// Also see DriverMysql.TableFields.
-func (d *Driver) TableFields(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error) {
-	var (
-		result     gdb.Result
-		link       gdb.Link
-		usedSchema = gutil.GetOrDefaultStr(d.GetSchema(), schema...)
-	)
-	if link, err = d.SlaveLink(usedSchema); err != nil {
-		return nil, err
-	}
-	var (
-		columns       = "name,position,default_expression,comment,type,is_in_partition_key,is_in_sorting_key,is_in_primary_key,is_in_sampling_key"
-		getColumnsSql = fmt.Sprintf(
-			"select %s from `system`.columns c where `table` = '%s'",
-			columns, table,
-		)
-	)
-	result, err = d.DoSelect(ctx, link, getColumnsSql)
-	if err != nil {
-		return nil, err
-	}
-	fields = make(map[string]*gdb.TableField)
-	for _, m := range result {
-		var (
-			isNull    = false
-			fieldType = m["type"].String()
-		)
-		// in clickhouse , field type like is Nullable(int)
-		fieldsResult, _ := gregex.MatchString(`^Nullable\((.*?)\)`, fieldType)
-		if len(fieldsResult) == 2 {
-			isNull = true
-			fieldType = fieldsResult[1]
-		}
-		position := m["position"].Int()
-		if result[0]["position"].Int() != 0 {
-			position -= 1
-		}
-		fields[m["name"].String()] = &gdb.TableField{
-			Index:   position,
-			Name:    m["name"].String(),
-			Default: m["default_expression"].Val(),
-			Comment: m["comment"].String(),
-			// Key:     m["Key"].String(),
-			Type: fieldType,
-			Null: isNull,
-		}
-	}
-	return fields, nil
-}
-
-// PingMaster pings the master node to check authentication or keeps the connection alive.
-func (d *Driver) PingMaster() error {
-	conn, err := d.Master()
-	if err != nil {
-		return err
-	}
-	return d.ping(conn)
-}
-
-// PingSlave pings the slave node to check authentication or keeps the connection alive.
-func (d *Driver) PingSlave() error {
-	conn, err := d.Slave()
-	if err != nil {
-		return err
-	}
-	return d.ping(conn)
-}
-
-// ping Returns the Clickhouse specific error.
-func (d *Driver) ping(conn *sql.DB) error {
-	err := conn.Ping()
-	if exception, ok := err.(*clickhouse.Exception); ok {
-		return fmt.Errorf("[%d]%s", exception.Code, exception.Message)
-	}
-	return err
-}
-
-// DoFilter handles the sql before posts it to database.
-func (d *Driver) DoFilter(
-	ctx context.Context, link gdb.Link, originSql string, args []interface{},
-) (newSql string, newArgs []interface{}, err error) {
-	if len(args) == 0 {
-		return originSql, args, nil
-	}
-	// Convert placeholder char '?' to string "$x".
-	var index int
-	originSql, _ = gregex.ReplaceStringFunc(`\?`, originSql, func(s string) string {
-		index++
-		return fmt.Sprintf(`$%d`, index)
-	})
-
-	// Only SQL generated through the framework is processed.
-	if !d.getNeedParsedSqlFromCtx(ctx) {
-		return originSql, args, nil
-	}
-
-	// replace STD SQL to Clickhouse SQL grammar
-	modeRes, err := gregex.MatchString(filterTypePattern, strings.TrimSpace(originSql))
-	if err != nil {
-		return "", nil, err
-	}
-	if len(modeRes) == 0 {
-		return originSql, args, nil
-	}
-
-	// Only delete/ UPDATE statements require filter
-	switch strings.ToUpper(modeRes[0]) {
-	case "UPDATE":
-		// MySQL eg: UPDATE table_name SET field1=new-value1, field2=new-value2 [WHERE Clause]
-		// Clickhouse eg: ALTER TABLE [db.]table UPDATE column1 = expr1 [, ...] WHERE filter_expr
-		newSql, err = gregex.ReplaceStringFuncMatch(
-			updateFilterPattern, originSql,
-			func(s []string) string {
-				return fmt.Sprintf("ALTER TABLE %s UPDATE", s[1])
-			},
-		)
-		if err != nil {
-			return "", nil, err
-		}
-		return newSql, args, nil
-
-	case "DELETE":
-		// MySQL eg: DELETE FROM table_name [WHERE Clause]
-		// Clickhouse eg: ALTER TABLE [db.]table [ON CLUSTER cluster] DELETE WHERE filter_expr
-		newSql, err = gregex.ReplaceStringFuncMatch(
-			deleteFilterPattern, originSql,
-			func(s []string) string {
-				return fmt.Sprintf("ALTER TABLE %s DELETE", s[1])
-			},
-		)
-		if err != nil {
-			return "", nil, err
-		}
-		return newSql, args, nil
-
-	}
-	return originSql, args, nil
-}
-
-// DoCommit commits current sql and arguments to underlying sql driver.
-func (d *Driver) DoCommit(ctx context.Context, in gdb.DoCommitInput) (out gdb.DoCommitOutput, err error) {
-	ctx = d.InjectIgnoreResult(ctx)
-	return d.Core.DoCommit(ctx, in)
-}
-
-// DoInsert inserts or updates data forF given table.
-func (d *Driver) DoInsert(
-	ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption,
-) (result sql.Result, err error) {
-	var (
-		keys        []string // Field names.
-		valueHolder = make([]string, 0)
-	)
-	// Handle the field names and placeholders.
-	for k := range list[0] {
-		keys = append(keys, k)
-		valueHolder = append(valueHolder, "?")
-	}
-	// Prepare the batch result pointer.
-	var (
-		charL, charR = d.Core.GetChars()
-		keysStr      = charL + strings.Join(keys, charR+","+charL) + charR
-		holderStr    = strings.Join(valueHolder, ",")
-		tx           gdb.TX
-		stmt         *gdb.Stmt
-	)
-	tx, err = d.Core.Begin(ctx)
-	if err != nil {
-		return
-	}
-	// It here uses defer to guarantee transaction be committed or roll-backed.
-	defer func() {
-		if err == nil {
-			_ = tx.Commit()
-		} else {
-			_ = tx.Rollback()
-		}
-	}()
-	stmt, err = tx.Prepare(fmt.Sprintf(
-		"INSERT INTO %s(%s) VALUES (%s)",
-		d.QuotePrefixTableName(table), keysStr,
-		holderStr,
-	))
-	if err != nil {
-		return
-	}
-	for i := 0; i < len(list); i++ {
-		// Values that will be committed to underlying database driver.
-		params := make([]interface{}, 0)
-		for _, k := range keys {
-			params = append(params, list[i][k])
-		}
-		// Prepare is allowed to execute only once in a transaction opened by clickhouse
-		result, err = stmt.ExecContext(ctx, params...)
-		if err != nil {
-			return
-		}
-	}
-	return
-}
-
-// ConvertValueForField converts value to the type of the record field.
-func (d *Driver) ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error) {
-	switch itemValue := fieldValue.(type) {
-	case time.Time:
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue.IsZero() {
-			return nil, nil
-		}
-
-	case uuid.UUID:
-		return itemValue, nil
-
-	case *time.Time:
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue == nil || itemValue.IsZero() {
-			return nil, nil
-		}
-		return itemValue, nil
-
-	case gtime.Time:
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue.IsZero() {
-			return nil, nil
-		}
-		// for gtime type, needs to get time.Time
-		return itemValue.Time, nil
-
-	case *gtime.Time:
-		// for gtime type, needs to get time.Time
-		if itemValue != nil {
-			return itemValue.Time, nil
-		}
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue == nil || itemValue.IsZero() {
-			return nil, nil
-		}
-
-	case decimal.Decimal:
-		return itemValue, nil
-
-	case *decimal.Decimal:
-		if itemValue != nil {
-			return *itemValue, nil
-		}
-		return nil, nil
-
-	default:
-		// if the other type implements valuer for the driver package
-		// the converted result is used
-		// otherwise the interface data is committed
-		valuer, ok := itemValue.(driver.Valuer)
-		if !ok {
-			return itemValue, nil
-		}
-		convertedValue, err := valuer.Value()
-		if err != nil {
-			return nil, err
-		}
-		return convertedValue, nil
-	}
-	return fieldValue, nil
-}
-
-// DoDelete does "DELETE FROM ... " statement for the table.
-func (d *Driver) DoDelete(ctx context.Context, link gdb.Link, table string, condition string, args ...interface{}) (result sql.Result, err error) {
-	ctx = d.injectNeedParsedSql(ctx)
-	return d.Core.DoDelete(ctx, link, table, condition, args...)
-}
-
-// DoUpdate does "UPDATE ... " statement for the table.
-func (d *Driver) DoUpdate(ctx context.Context, link gdb.Link, table string, data interface{}, condition string, args ...interface{}) (result sql.Result, err error) {
-	ctx = d.injectNeedParsedSql(ctx)
-	return d.Core.DoUpdate(ctx, link, table, data, condition, args...)
-}
-
-// InsertIgnore Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
-func (d *Driver) InsertIgnore(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error) {
-	return nil, errUnsupportedInsertIgnore
-}
-
-// InsertAndGetId Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
-func (d *Driver) InsertAndGetId(ctx context.Context, table string, data interface{}, batch ...int) (int64, error) {
-	return 0, errUnsupportedInsertGetId
-}
-
-// Replace Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
-func (d *Driver) Replace(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error) {
-	return nil, errUnsupportedReplace
-}
-
-// Begin starts and returns the transaction object.
-func (d *Driver) Begin(ctx context.Context) (tx gdb.TX, err error) {
-	return nil, errUnsupportedBegin
-}
-
-// Transaction wraps the transaction logic using function `f`.
-func (d *Driver) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) error {
-	return errUnsupportedTransaction
-}
-
 func (d *Driver) injectNeedParsedSql(ctx context.Context) context.Context {
 	if ctx.Value(needParsedSqlInCtx) != nil {
 		return ctx
 	}
 	return context.WithValue(ctx, needParsedSqlInCtx, true)
 }
-
-func (d *Driver) getNeedParsedSqlFromCtx(ctx context.Context) bool {
-	if ctx.Value(needParsedSqlInCtx) != nil {
-		return true
-	}
-	return false
-}

contrib/drivers/clickhouse/clickhouse_convert.go

@@ -0,0 +1,85 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"database/sql/driver"
+	"time"
+
+	"github.com/google/uuid"
+	"github.com/shopspring/decimal"
+
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// ConvertValueForField converts value to the type of the record field.
+func (d *Driver) ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error) {
+	switch itemValue := fieldValue.(type) {
+	case time.Time:
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue.IsZero() {
+			return nil, nil
+		}
+
+	case uuid.UUID:
+		return itemValue, nil
+
+	case *time.Time:
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue == nil || itemValue.IsZero() {
+			return nil, nil
+		}
+		return itemValue, nil
+
+	case gtime.Time:
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue.IsZero() {
+			return nil, nil
+		}
+		// for gtime type, needs to get time.Time
+		return itemValue.Time, nil
+
+	case *gtime.Time:
+		// for gtime type, needs to get time.Time
+		if itemValue != nil {
+			return itemValue.Time, nil
+		}
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue == nil || itemValue.IsZero() {
+			return nil, nil
+		}
+
+	case decimal.Decimal:
+		return itemValue, nil
+
+	case *decimal.Decimal:
+		if itemValue != nil {
+			return *itemValue, nil
+		}
+		return nil, nil
+
+	default:
+		// if the other type implements valuer for the driver package
+		// the converted result is used
+		// otherwise the interface data is committed
+		valuer, ok := itemValue.(driver.Valuer)
+		if !ok {
+			return itemValue, nil
+		}
+		convertedValue, err := valuer.Value()
+		if err != nil {
+			return nil, err
+		}
+		return convertedValue, nil
+	}
+	return fieldValue, nil
+}

contrib/drivers/clickhouse/clickhouse_do_commit.go

@@ -0,0 +1,19 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+// DoCommit commits current sql and arguments to underlying sql driver.
+func (d *Driver) DoCommit(ctx context.Context, in gdb.DoCommitInput) (out gdb.DoCommitOutput, err error) {
+	ctx = d.InjectIgnoreResult(ctx)
+	return d.Core.DoCommit(ctx, in)
+}

contrib/drivers/clickhouse/clickhouse_do_delete.go

@@ -0,0 +1,20 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"database/sql"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+// DoDelete does "DELETE FROM ... " statement for the table.
+func (d *Driver) DoDelete(ctx context.Context, link gdb.Link, table string, condition string, args ...interface{}) (result sql.Result, err error) {
+	ctx = d.injectNeedParsedSql(ctx)
+	return d.Core.DoDelete(ctx, link, table, condition, args...)
+}

contrib/drivers/clickhouse/clickhouse_do_filter.go

@@ -0,0 +1,85 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"fmt"
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/text/gregex"
+)
+
+// DoFilter handles the sql before posts it to database.
+func (d *Driver) DoFilter(
+	ctx context.Context, link gdb.Link, originSql string, args []interface{},
+) (newSql string, newArgs []interface{}, err error) {
+	if len(args) == 0 {
+		return originSql, args, nil
+	}
+	// Convert placeholder char '?' to string "$x".
+	var index int
+	originSql, _ = gregex.ReplaceStringFunc(`\?`, originSql, func(s string) string {
+		index++
+		return fmt.Sprintf(`$%d`, index)
+	})
+
+	// Only SQL generated through the framework is processed.
+	if !d.getNeedParsedSqlFromCtx(ctx) {
+		return originSql, args, nil
+	}
+
+	// replace STD SQL to Clickhouse SQL grammar
+	modeRes, err := gregex.MatchString(filterTypePattern, strings.TrimSpace(originSql))
+	if err != nil {
+		return "", nil, err
+	}
+	if len(modeRes) == 0 {
+		return originSql, args, nil
+	}
+
+	// Only delete/ UPDATE statements require filter
+	switch strings.ToUpper(modeRes[0]) {
+	case "UPDATE":
+		// MySQL eg: UPDATE table_name SET field1=new-value1, field2=new-value2 [WHERE Clause]
+		// Clickhouse eg: ALTER TABLE [db.]table UPDATE column1 = expr1 [, ...] WHERE filter_expr
+		newSql, err = gregex.ReplaceStringFuncMatch(
+			updateFilterPattern, originSql,
+			func(s []string) string {
+				return fmt.Sprintf("ALTER TABLE %s UPDATE", s[1])
+			},
+		)
+		if err != nil {
+			return "", nil, err
+		}
+		return newSql, args, nil
+
+	case "DELETE":
+		// MySQL eg: DELETE FROM table_name [WHERE Clause]
+		// Clickhouse eg: ALTER TABLE [db.]table [ON CLUSTER cluster] DELETE WHERE filter_expr
+		newSql, err = gregex.ReplaceStringFuncMatch(
+			deleteFilterPattern, originSql,
+			func(s []string) string {
+				return fmt.Sprintf("ALTER TABLE %s DELETE", s[1])
+			},
+		)
+		if err != nil {
+			return "", nil, err
+		}
+		return newSql, args, nil
+
+	}
+	return originSql, args, nil
+}
+
+func (d *Driver) getNeedParsedSqlFromCtx(ctx context.Context) bool {
+	if ctx.Value(needParsedSqlInCtx) != nil {
+		return true
+	}
+	return false
+}

contrib/drivers/clickhouse/clickhouse_do_insert.go

@@ -0,0 +1,72 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"database/sql"
+	"fmt"
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+// DoInsert inserts or updates data forF given table.
+func (d *Driver) DoInsert(
+	ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption,
+) (result sql.Result, err error) {
+	var (
+		keys        []string // Field names.
+		valueHolder = make([]string, 0)
+	)
+	// Handle the field names and placeholders.
+	for k := range list[0] {
+		keys = append(keys, k)
+		valueHolder = append(valueHolder, "?")
+	}
+	// Prepare the batch result pointer.
+	var (
+		charL, charR = d.Core.GetChars()
+		keysStr      = charL + strings.Join(keys, charR+","+charL) + charR
+		holderStr    = strings.Join(valueHolder, ",")
+		tx           gdb.TX
+		stmt         *gdb.Stmt
+	)
+	tx, err = d.Core.Begin(ctx)
+	if err != nil {
+		return
+	}
+	// It here uses defer to guarantee transaction be committed or roll-backed.
+	defer func() {
+		if err == nil {
+			_ = tx.Commit()
+		} else {
+			_ = tx.Rollback()
+		}
+	}()
+	stmt, err = tx.Prepare(fmt.Sprintf(
+		"INSERT INTO %s(%s) VALUES (%s)",
+		d.QuotePrefixTableName(table), keysStr,
+		holderStr,
+	))
+	if err != nil {
+		return
+	}
+	for i := 0; i < len(list); i++ {
+		// Values that will be committed to underlying database driver.
+		params := make([]interface{}, 0)
+		for _, k := range keys {
+			params = append(params, list[i][k])
+		}
+		// Prepare is allowed to execute only once in a transaction opened by clickhouse
+		result, err = stmt.ExecContext(ctx, params...)
+		if err != nil {
+			return
+		}
+	}
+	return
+}

contrib/drivers/clickhouse/clickhouse_do_update.go

@@ -0,0 +1,20 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"database/sql"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+// DoUpdate does "UPDATE ... " statement for the table.
+func (d *Driver) DoUpdate(ctx context.Context, link gdb.Link, table string, data interface{}, condition string, args ...interface{}) (result sql.Result, err error) {
+	ctx = d.injectNeedParsedSql(ctx)
+	return d.Core.DoUpdate(ctx, link, table, data, condition, args...)
+}

contrib/drivers/clickhouse/clickhouse_insert.go

@@ -0,0 +1,27 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"database/sql"
+)
+
+// InsertIgnore Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
+func (d *Driver) InsertIgnore(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error) {
+	return nil, errUnsupportedInsertIgnore
+}
+
+// InsertAndGetId Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
+func (d *Driver) InsertAndGetId(ctx context.Context, table string, data interface{}, batch ...int) (int64, error) {
+	return 0, errUnsupportedInsertGetId
+}
+
+// Replace Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.
+func (d *Driver) Replace(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error) {
+	return nil, errUnsupportedReplace
+}

contrib/drivers/clickhouse/clickhouse_open.go

@@ -0,0 +1,63 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"database/sql"
+	"fmt"
+	"net/url"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+	"github.com/gogf/gf/v2/text/gregex"
+)
+
+// Open creates and returns an underlying sql.DB object for clickhouse.
+func (d *Driver) Open(config *gdb.ConfigNode) (db *sql.DB, err error) {
+	source := config.Link
+	// clickhouse://username:password@host1:9000,host2:9000/database?dial_timeout=200ms&max_execution_time=60
+	if config.Link != "" {
+		// ============================================================================
+		// Deprecated from v2.2.0.
+		// ============================================================================
+		// Custom changing the schema in runtime.
+		if config.Name != "" {
+			source, _ = gregex.ReplaceString(replaceSchemaPattern, "@$1/"+config.Name, config.Link)
+		} else {
+			// If no schema, the link is matched for replacement
+			dbName, _ := gregex.MatchString(replaceSchemaPattern, config.Link)
+			if len(dbName) > 0 {
+				config.Name = dbName[len(dbName)-1]
+			}
+		}
+	} else {
+		if config.Pass != "" {
+			source = fmt.Sprintf(
+				"clickhouse://%s:%s@%s:%s/%s?debug=%t",
+				config.User, url.PathEscape(config.Pass),
+				config.Host, config.Port, config.Name, config.Debug,
+			)
+		} else {
+			source = fmt.Sprintf(
+				"clickhouse://%s@%s:%s/%s?debug=%t",
+				config.User, config.Host, config.Port, config.Name, config.Debug,
+			)
+		}
+		if config.Extra != "" {
+			source = fmt.Sprintf("%s&%s", source, config.Extra)
+		}
+	}
+	if db, err = sql.Open(driverName, source); err != nil {
+		err = gerror.WrapCodef(
+			gcode.CodeDbOperationError, err,
+			`sql.Open failed for driver "%s" by source "%s"`, driverName, source,
+		)
+		return nil, err
+	}
+	return
+}

contrib/drivers/clickhouse/clickhouse_ping.go

@@ -0,0 +1,41 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"database/sql"
+	"fmt"
+
+	"github.com/ClickHouse/clickhouse-go/v2"
+)
+
+// PingMaster pings the master node to check authentication or keeps the connection alive.
+func (d *Driver) PingMaster() error {
+	conn, err := d.Master()
+	if err != nil {
+		return err
+	}
+	return d.ping(conn)
+}
+
+// PingSlave pings the slave node to check authentication or keeps the connection alive.
+func (d *Driver) PingSlave() error {
+	conn, err := d.Slave()
+	if err != nil {
+		return err
+	}
+	return d.ping(conn)
+}
+
+// ping Returns the Clickhouse specific error.
+func (d *Driver) ping(conn *sql.DB) error {
+	err := conn.Ping()
+	if exception, ok := err.(*clickhouse.Exception); ok {
+		return fmt.Errorf("[%d]%s", exception.Code, exception.Message)
+	}
+	return err
+}

contrib/drivers/clickhouse/clickhouse_table_fields.go

@@ -0,0 +1,70 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/text/gregex"
+	"github.com/gogf/gf/v2/util/gutil"
+)
+
+const (
+	tableFieldsColumns = `name,position,default_expression,comment,type,is_in_partition_key,is_in_sorting_key,is_in_primary_key,is_in_sampling_key`
+)
+
+// TableFields retrieves and returns the fields' information of specified table of current schema.
+// Also see DriverMysql.TableFields.
+func (d *Driver) TableFields(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error) {
+	var (
+		result     gdb.Result
+		link       gdb.Link
+		usedSchema = gutil.GetOrDefaultStr(d.GetSchema(), schema...)
+	)
+	if link, err = d.SlaveLink(usedSchema); err != nil {
+		return nil, err
+	}
+	var (
+		getColumnsSql = fmt.Sprintf(
+			"select %s from `system`.columns c where `table` = '%s'",
+			tableFieldsColumns, table,
+		)
+	)
+	result, err = d.DoSelect(ctx, link, getColumnsSql)
+	if err != nil {
+		return nil, err
+	}
+	fields = make(map[string]*gdb.TableField)
+	for _, m := range result {
+		var (
+			isNull    = false
+			fieldType = m["type"].String()
+		)
+		// in clickhouse , field type like is Nullable(int)
+		fieldsResult, _ := gregex.MatchString(`^Nullable\((.*?)\)`, fieldType)
+		if len(fieldsResult) == 2 {
+			isNull = true
+			fieldType = fieldsResult[1]
+		}
+		position := m["position"].Int()
+		if result[0]["position"].Int() != 0 {
+			position -= 1
+		}
+		fields[m["name"].String()] = &gdb.TableField{
+			Index:   position,
+			Name:    m["name"].String(),
+			Default: m["default_expression"].Val(),
+			Comment: m["comment"].String(),
+			// Key:     m["Key"].String(),
+			Type: fieldType,
+			Null: isNull,
+		}
+	}
+	return fields, nil
+}

contrib/drivers/clickhouse/clickhouse_tables.go

@@ -0,0 +1,36 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+const (
+	tablesSqlTmp = "select name from `system`.tables where database = '%s'"
+)
+
+// Tables retrieves and returns the tables of current schema.
+// It's mainly used in cli tool chain for automatically generating the models.
+func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error) {
+	var result gdb.Result
+	link, err := d.SlaveLink(schema...)
+	if err != nil {
+		return nil, err
+	}
+	result, err = d.DoSelect(ctx, link, fmt.Sprintf(tablesSqlTmp, d.GetConfig().Name))
+	if err != nil {
+		return
+	}
+	for _, m := range result {
+		tables = append(tables, m["name"].String())
+	}
+	return
+}

contrib/drivers/clickhouse/clickhouse_transaction.go

@@ -0,0 +1,23 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package clickhouse
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+// Begin starts and returns the transaction object.
+func (d *Driver) Begin(ctx context.Context) (tx gdb.TX, err error) {
+	return nil, errUnsupportedBegin
+}
+
+// Transaction wraps the transaction logic using function `f`.
+func (d *Driver) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) error {
+	return errUnsupportedTransaction
+}

contrib/drivers/clickhouse/go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/ClickHouse/clickhouse-go/v2 v2.0.15
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 	github.com/google/uuid v1.3.0
 	github.com/shopspring/decimal v1.3.1
 )

contrib/drivers/dm/dm.go

@@ -8,24 +8,10 @@
 package dm
 
 import (
-	"context"
-	"database/sql"
-	"fmt"
-	"net/url"
-	"strings"
-	"time"
-
 	_ "gitee.com/chunanyong/dm"
 
 	"github.com/gogf/gf/v2/database/gdb"
-	"github.com/gogf/gf/v2/errors/gcode"
-	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/frame/g"
-	"github.com/gogf/gf/v2/os/gtime"
-	"github.com/gogf/gf/v2/text/gregex"
-	"github.com/gogf/gf/v2/text/gstr"
-	"github.com/gogf/gf/v2/util/gconv"
-	"github.com/gogf/gf/v2/util/gutil"
 )
 
 type Driver struct {
@@ -61,390 +47,7 @@ func (d *Driver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error) {
 	}, nil
 }
 
-// Open creates and returns an underlying sql.DB object for pgsql.
-func (d *Driver) Open(config *gdb.ConfigNode) (db *sql.DB, err error) {
-	var (
-		source               string
-		underlyingDriverName = "dm"
-	)
-	if config.Name == "" {
-		return nil, fmt.Errorf(
-			`dm.Open failed for driver "%s" without DB Name`, underlyingDriverName,
-		)
-	}
-	// Data Source Name of DM8:
-	// dm://userName:password@ip:port/dbname
-	// dm://userName:password@DW/dbname?DW=(192.168.1.1:5236,192.168.1.2:5236)
-	var domain string
-	if config.Port != "" {
-		domain = fmt.Sprintf("%s:%s", config.Host, config.Port)
-	} else {
-		domain = config.Host
-	}
-	source = fmt.Sprintf(
-		"dm://%s:%s@%s/%s?charset=%s&schema=%s",
-		config.User, config.Pass, domain, config.Name, config.Charset, config.Name,
-	)
-	// Demo of timezone setting:
-	// &loc=Asia/Shanghai
-	if config.Timezone != "" {
-		if strings.Contains(config.Timezone, "/") {
-			config.Timezone = url.QueryEscape(config.Timezone)
-		}
-		source = fmt.Sprintf("%s&loc%s", source, config.Timezone)
-	}
-	if config.Extra != "" {
-		source = fmt.Sprintf("%s&%s", source, config.Extra)
-	}
-
-	if db, err = sql.Open(underlyingDriverName, source); err != nil {
-		err = gerror.WrapCodef(
-			gcode.CodeDbOperationError, err,
-			`dm.Open failed for driver "%s" by source "%s"`, underlyingDriverName, source,
-		)
-		return nil, err
-	}
-	return
-}
-
 // GetChars returns the security char for this type of database.
 func (d *Driver) GetChars() (charLeft string, charRight string) {
 	return quoteChar, quoteChar
 }
-
-// Tables retrieves and returns the tables of current schema.
-// It's mainly used in cli tool chain for automatically generating the models.
-func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error) {
-	var result gdb.Result
-	// When schema is empty, return the default link
-	link, err := d.SlaveLink(schema...)
-	if err != nil {
-		return nil, err
-	}
-	// The link has been distinguished and no longer needs to judge the owner
-	result, err = d.DoSelect(
-		ctx, link, `SELECT * FROM ALL_TABLES`,
-	)
-	if err != nil {
-		return
-	}
-	for _, m := range result {
-		if v, ok := m["IOT_NAME"]; ok {
-			tables = append(tables, v.String())
-		}
-	}
-	return
-}
-
-// TableFields retrieves and returns the fields' information of specified table of current schema.
-func (d *Driver) TableFields(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error) {
-	var (
-		result gdb.Result
-		link   gdb.Link
-		// When no schema is specified, the configuration item is returned by default
-		usedSchema = gutil.GetOrDefaultStr(d.GetSchema(), schema...)
-	)
-	// When usedSchema is empty, return the default link
-	if link, err = d.SlaveLink(usedSchema); err != nil {
-		return nil, err
-	}
-	// The link has been distinguished and no longer needs to judge the owner
-	result, err = d.DoSelect(
-		ctx, link,
-		fmt.Sprintf(
-			`SELECT * FROM ALL_TAB_COLUMNS WHERE Table_Name= '%s' AND OWNER = '%s'`,
-			strings.ToUpper(table),
-			strings.ToUpper(d.GetSchema()),
-		),
-	)
-	if err != nil {
-		return nil, err
-	}
-	fields = make(map[string]*gdb.TableField)
-	for i, m := range result {
-		// m[NULLABLE] returns "N" "Y"
-		// "N" means not null
-		// "Y" means could be null
-		var nullable bool
-		if m["NULLABLE"].String() != "N" {
-			nullable = true
-		}
-		fields[m["COLUMN_NAME"].String()] = &gdb.TableField{
-			Index:   i,
-			Name:    m["COLUMN_NAME"].String(),
-			Type:    m["DATA_TYPE"].String(),
-			Null:    nullable,
-			Default: m["DATA_DEFAULT"].Val(),
-			// Key:     m["Key"].String(),
-			// Extra:   m["Extra"].String(),
-			// Comment: m["Comment"].String(),
-		}
-	}
-	return fields, nil
-}
-
-// ConvertValueForField converts value to the type of the record field.
-func (d *Driver) ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error) {
-	switch itemValue := fieldValue.(type) {
-	// dm does not support time.Time, it so here converts it to time string that it supports.
-	case time.Time:
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue.IsZero() {
-			return nil, nil
-		}
-		return gtime.New(itemValue).String(), nil
-
-	// dm does not support time.Time, it so here converts it to time string that it supports.
-	case *time.Time:
-		// If the time is zero, it then updates it to nil,
-		// which will insert/update the value to database as "null".
-		if itemValue == nil || itemValue.IsZero() {
-			return nil, nil
-		}
-		return gtime.New(itemValue).String(), nil
-	}
-
-	return fieldValue, nil
-}
-
-// DoFilter deals with the sql string before commits it to underlying sql driver.
-func (d *Driver) DoFilter(ctx context.Context, link gdb.Link, sql string, args []interface{}) (newSql string, newArgs []interface{}, err error) {
-	// There should be no need to capitalize, because it has been done from field processing before
-	newSql, _ = gregex.ReplaceString(`["\n\t]`, "", sql)
-	newSql = gstr.ReplaceI(gstr.ReplaceI(newSql, "GROUP_CONCAT", "LISTAGG"), "SEPARATOR", ",")
-
-	// TODO The current approach is too rough. We should deal with the GROUP_CONCAT function and the parsing of the index field from within the select from match.
-	// （GROUP_CONCAT DM  does not approve; index cannot be used as a query column name, and security characters need to be added, such as "index"）
-	l, r := d.GetChars()
-	if strings.Contains(newSql, "INDEX") || strings.Contains(newSql, "index") {
-		if !(strings.Contains(newSql, "_INDEX") || strings.Contains(newSql, "_index")) {
-			newSql = gstr.ReplaceI(newSql, "INDEX", l+"INDEX"+r)
-		}
-	}
-
-	// TODO i tried to do but it never work：
-	// array, err := gregex.MatchAllString(`SELECT (.*INDEX.*) FROM .*`, newSql)
-	// g.Dump("err:", err)
-	// g.Dump("array:", array)
-	// g.Dump("array:", array[0][1])
-
-	// newSql, err = gregex.ReplaceString(`SELECT (.*INDEX.*) FROM .*`, l+"INDEX"+r, newSql)
-	// g.Dump("err:", err)
-	// g.Dump("newSql:", newSql)
-
-	// re, err := regexp.Compile(`.*SELECT (.*INDEX.*) FROM .*`)
-	// newSql = re.ReplaceAllStringFunc(newSql, func(data string) string {
-	// 	fmt.Println("data:", data)
-	// 	return data
-	// })
-
-	return d.Core.DoFilter(
-		ctx,
-		link,
-		newSql,
-		args,
-	)
-}
-
-// TODO I originally wanted to only convert keywords in select
-// 但是我发现 DoQuery 中会对 sql 会对 " " 达梦的安全字符 进行 / 转义，最后还是导致达梦无法正常解析
-// However, I found that DoQuery() will perform / escape on sql with " " Dameng's safe characters, which ultimately caused Dameng to be unable to parse normally.
-// But processing in DoFilter() is OK
-// func (d *Driver) DoQuery(ctx context.Context, link gdb.Link, sql string, args ...interface{}) (gdb.Result, error) {
-// 	l, r := d.GetChars()
-// 	new := gstr.ReplaceI(sql, "INDEX", l+"INDEX"+r)
-// 	g.Dump("new:", new)
-// 	return d.Core.DoQuery(
-// 		ctx,
-// 		link,
-// 		new,
-// 		args,
-// 	)
-// }
-
-// DoInsert inserts or updates data forF given table.
-func (d *Driver) DoInsert(
-	ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption,
-) (result sql.Result, err error) {
-	switch option.InsertOption {
-	case gdb.InsertOptionReplace:
-		// TODO:: Should be Supported
-		return nil, gerror.NewCode(
-			gcode.CodeNotSupported, `Replace operation is not supported by dm driver`,
-		)
-
-	case gdb.InsertOptionSave:
-		// This syntax currently only supports design tables whose primary key is ID.
-		listLength := len(list)
-		if listLength == 0 {
-			return nil, gerror.NewCode(
-				gcode.CodeInvalidRequest, `Save operation list is empty by dm driver`,
-			)
-		}
-		var (
-			keysSort     []string
-			charL, charR = d.GetChars()
-		)
-		// Column names need to be aligned in the syntax
-		for k := range list[0] {
-			keysSort = append(keysSort, k)
-		}
-		var char = struct {
-			charL        string
-			charR        string
-			valueCharL   string
-			valueCharR   string
-			duplicateKey string
-			keys         []string
-		}{
-			charL:      charL,
-			charR:      charR,
-			valueCharL: "'",
-			valueCharR: "'",
-			// TODO:: Need to dynamically set the primary key of the table
-			duplicateKey: "ID",
-			keys:         keysSort,
-		}
-
-		// insertKeys:   Handle valid keys that need to be inserted and updated
-		// insertValues: Handle values that need to be inserted
-		// updateValues: Handle values that need to be updated
-		// queryValues:  Handle only one insert with column name
-		insertKeys, insertValues, updateValues, queryValues := parseValue(list[0], char)
-		// unionValues: Handling values that need to be inserted and updated
-		unionValues := parseUnion(list[1:], char)
-
-		batchResult := new(gdb.SqlResult)
-		// parseSql():
-		// MERGE INTO {{table}} T1
-		// USING ( SELECT {{queryValues}} FROM DUAL
-		// {{unionValues}} ) T2
-		// ON (T1.{{duplicateKey}} = T2.{{duplicateKey}})
-		// WHEN NOT MATCHED THEN
-		// INSERT {{insertKeys}} VALUES {{insertValues}}
-		// WHEN MATCHED THEN
-		// UPDATE SET {{updateValues}}
-		sqlStr := parseSql(
-			insertKeys, insertValues, updateValues, queryValues, unionValues, table, char.duplicateKey,
-		)
-		r, err := d.DoExec(ctx, link, sqlStr)
-		if err != nil {
-			return r, err
-		}
-		if n, err := r.RowsAffected(); err != nil {
-			return r, err
-		} else {
-			batchResult.Result = r
-			batchResult.Affected += n
-		}
-		return batchResult, nil
-	}
-	return d.Core.DoInsert(ctx, link, table, list, option)
-}
-
-func parseValue(listOne gdb.Map, char struct {
-	charL        string
-	charR        string
-	valueCharL   string
-	valueCharR   string
-	duplicateKey string
-	keys         []string
-}) (insertKeys []string, insertValues []string, updateValues []string, queryValues []string) {
-	for _, column := range char.keys {
-		if listOne[column] == nil {
-			// remove unassigned struct object
-			continue
-		}
-		insertKeys = append(insertKeys, char.charL+column+char.charR)
-		insertValues = append(insertValues, "T2."+char.charL+column+char.charR)
-		if column != char.duplicateKey {
-			updateValues = append(
-				updateValues,
-				fmt.Sprintf(`T1.%s = T2.%s`, char.charL+column+char.charR, char.charL+column+char.charR),
-			)
-		}
-
-		saveValue := gconv.String(listOne[column])
-		queryValues = append(
-			queryValues,
-			fmt.Sprintf(
-				char.valueCharL+"%s"+char.valueCharR+" AS "+char.charL+"%s"+char.charR,
-				saveValue, column,
-			),
-		)
-	}
-	return
-}
-
-func parseUnion(list gdb.List, char struct {
-	charL        string
-	charR        string
-	valueCharL   string
-	valueCharR   string
-	duplicateKey string
-	keys         []string
-}) (unionValues []string) {
-	for _, mapper := range list {
-		var saveValue []string
-		for _, column := range char.keys {
-			if mapper[column] == nil {
-				continue
-			}
-			// va := reflect.ValueOf(mapper[column])
-			// ty := reflect.TypeOf(mapper[column])
-			// switch ty.Kind() {
-			// case reflect.String:
-			// 	saveValue = append(saveValue, char.valueCharL+va.String()+char.valueCharR)
-
-			// case reflect.Int:
-			// 	saveValue = append(saveValue, strconv.FormatInt(va.Int(), 10))
-
-			// case reflect.Int64:
-			// 	saveValue = append(saveValue, strconv.FormatInt(va.Int(), 10))
-
-			// default:
-			// 	// The fish has no chance getting here.
-			// 	// Nothing to do.
-			// }
-			saveValue = append(saveValue,
-				fmt.Sprintf(
-					char.valueCharL+"%s"+char.valueCharR,
-					gconv.String(mapper[column]),
-				))
-		}
-		unionValues = append(
-			unionValues,
-			fmt.Sprintf(`UNION ALL SELECT %s FROM DUAL`, strings.Join(saveValue, ",")),
-		)
-	}
-	return
-}
-
-func parseSql(
-	insertKeys, insertValues, updateValues, queryValues, unionValues []string, table, duplicateKey string,
-) (sqlStr string) {
-	var (
-		queryValueStr  = strings.Join(queryValues, ",")
-		unionValueStr  = strings.Join(unionValues, " ")
-		insertKeyStr   = strings.Join(insertKeys, ",")
-		insertValueStr = strings.Join(insertValues, ",")
-		updateValueStr = strings.Join(updateValues, ",")
-		pattern        = gstr.Trim(`
-MERGE INTO %s T1 USING (SELECT %s FROM DUAL %s) T2 ON %s 
-WHEN NOT MATCHED 
-THEN 
-INSERT(%s) VALUES (%s) 
-WHEN MATCHED 
-THEN 
-UPDATE SET %s; 
-COMMIT;
-`)
-	)
-	return fmt.Sprintf(
-		pattern,
-		table, queryValueStr, unionValueStr,
-		fmt.Sprintf("(T1.%s = T2.%s)", duplicateKey, duplicateKey),
-		insertKeyStr, insertValueStr, updateValueStr,
-	)
-}

contrib/drivers/dm/dm_convert.go

@@ -0,0 +1,40 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"context"
+
+	"time"
+
+	"github.com/gogf/gf/v2/os/gtime"
+)
+
+// ConvertValueForField converts value to the type of the record field.
+func (d *Driver) ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error) {
+	switch itemValue := fieldValue.(type) {
+	// dm does not support time.Time, it so here converts it to time string that it supports.
+	case time.Time:
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue.IsZero() {
+			return nil, nil
+		}
+		return gtime.New(itemValue).String(), nil
+
+	// dm does not support time.Time, it so here converts it to time string that it supports.
+	case *time.Time:
+		// If the time is zero, it then updates it to nil,
+		// which will insert/update the value to database as "null".
+		if itemValue == nil || itemValue.IsZero() {
+			return nil, nil
+		}
+		return gtime.New(itemValue).String(), nil
+	}
+
+	return fieldValue, nil
+}

contrib/drivers/dm/dm_do_filter.go

@@ -0,0 +1,59 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"context"
+
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/text/gregex"
+	"github.com/gogf/gf/v2/text/gstr"
+)
+
+// DoFilter deals with the sql string before commits it to underlying sql driver.
+func (d *Driver) DoFilter(
+	ctx context.Context, link gdb.Link, sql string, args []interface{},
+) (newSql string, newArgs []interface{}, err error) {
+	// There should be no need to capitalize, because it has been done from field processing before
+	newSql, _ = gregex.ReplaceString(`["\n\t]`, "", sql)
+	newSql = gstr.ReplaceI(gstr.ReplaceI(newSql, "GROUP_CONCAT", "LISTAGG"), "SEPARATOR", ",")
+
+	// TODO The current approach is too rough. We should deal with the GROUP_CONCAT function and the
+	// parsing of the index field from within the select from match.
+	// （GROUP_CONCAT DM  does not approve; index cannot be used as a query column name, and security characters need to be added, such as "index"）
+	l, r := d.GetChars()
+	if strings.Contains(newSql, "INDEX") || strings.Contains(newSql, "index") {
+		if !(strings.Contains(newSql, "_INDEX") || strings.Contains(newSql, "_index")) {
+			newSql = gstr.ReplaceI(newSql, "INDEX", l+"INDEX"+r)
+		}
+	}
+
+	// TODO i tried to do but it never work：
+	// array, err := gregex.MatchAllString(`SELECT (.*INDEX.*) FROM .*`, newSql)
+	// g.Dump("err:", err)
+	// g.Dump("array:", array)
+	// g.Dump("array:", array[0][1])
+
+	// newSql, err = gregex.ReplaceString(`SELECT (.*INDEX.*) FROM .*`, l+"INDEX"+r, newSql)
+	// g.Dump("err:", err)
+	// g.Dump("newSql:", newSql)
+
+	// re, err := regexp.Compile(`.*SELECT (.*INDEX.*) FROM .*`)
+	// newSql = re.ReplaceAllStringFunc(newSql, func(data string) string {
+	// 	fmt.Println("data:", data)
+	// 	return data
+	// })
+
+	return d.Core.DoFilter(
+		ctx,
+		link,
+		newSql,
+		args,
+	)
+}

contrib/drivers/dm/dm_do_insert.go

@@ -0,0 +1,207 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"context"
+	"database/sql"
+	"fmt"
+
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+	"github.com/gogf/gf/v2/text/gstr"
+	"github.com/gogf/gf/v2/util/gconv"
+)
+
+// DoInsert inserts or updates data forF given table.
+func (d *Driver) DoInsert(
+	ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption,
+) (result sql.Result, err error) {
+	switch option.InsertOption {
+	case gdb.InsertOptionReplace:
+		// TODO:: Should be Supported
+		return nil, gerror.NewCode(
+			gcode.CodeNotSupported, `Replace operation is not supported by dm driver`,
+		)
+
+	case gdb.InsertOptionSave:
+		// This syntax currently only supports design tables whose primary key is ID.
+		listLength := len(list)
+		if listLength == 0 {
+			return nil, gerror.NewCode(
+				gcode.CodeInvalidRequest, `Save operation list is empty by dm driver`,
+			)
+		}
+		var (
+			keysSort     []string
+			charL, charR = d.GetChars()
+		)
+		// Column names need to be aligned in the syntax
+		for k := range list[0] {
+			keysSort = append(keysSort, k)
+		}
+		var char = struct {
+			charL        string
+			charR        string
+			valueCharL   string
+			valueCharR   string
+			duplicateKey string
+			keys         []string
+		}{
+			charL:      charL,
+			charR:      charR,
+			valueCharL: "'",
+			valueCharR: "'",
+			// TODO:: Need to dynamically set the primary key of the table
+			duplicateKey: "ID",
+			keys:         keysSort,
+		}
+
+		// insertKeys:   Handle valid keys that need to be inserted and updated
+		// insertValues: Handle values that need to be inserted
+		// updateValues: Handle values that need to be updated
+		// queryValues:  Handle only one insert with column name
+		insertKeys, insertValues, updateValues, queryValues := parseValue(list[0], char)
+		// unionValues: Handling values that need to be inserted and updated
+		unionValues := parseUnion(list[1:], char)
+
+		batchResult := new(gdb.SqlResult)
+		// parseSql():
+		// MERGE INTO {{table}} T1
+		// USING ( SELECT {{queryValues}} FROM DUAL
+		// {{unionValues}} ) T2
+		// ON (T1.{{duplicateKey}} = T2.{{duplicateKey}})
+		// WHEN NOT MATCHED THEN
+		// INSERT {{insertKeys}} VALUES {{insertValues}}
+		// WHEN MATCHED THEN
+		// UPDATE SET {{updateValues}}
+		sqlStr := parseSql(
+			insertKeys, insertValues, updateValues, queryValues, unionValues, table, char.duplicateKey,
+		)
+		r, err := d.DoExec(ctx, link, sqlStr)
+		if err != nil {
+			return r, err
+		}
+		if n, err := r.RowsAffected(); err != nil {
+			return r, err
+		} else {
+			batchResult.Result = r
+			batchResult.Affected += n
+		}
+		return batchResult, nil
+	}
+	return d.Core.DoInsert(ctx, link, table, list, option)
+}
+
+func parseValue(listOne gdb.Map, char struct {
+	charL        string
+	charR        string
+	valueCharL   string
+	valueCharR   string
+	duplicateKey string
+	keys         []string
+}) (insertKeys []string, insertValues []string, updateValues []string, queryValues []string) {
+	for _, column := range char.keys {
+		if listOne[column] == nil {
+			// remove unassigned struct object
+			continue
+		}
+		insertKeys = append(insertKeys, char.charL+column+char.charR)
+		insertValues = append(insertValues, "T2."+char.charL+column+char.charR)
+		if column != char.duplicateKey {
+			updateValues = append(
+				updateValues,
+				fmt.Sprintf(`T1.%s = T2.%s`, char.charL+column+char.charR, char.charL+column+char.charR),
+			)
+		}
+
+		saveValue := gconv.String(listOne[column])
+		queryValues = append(
+			queryValues,
+			fmt.Sprintf(
+				char.valueCharL+"%s"+char.valueCharR+" AS "+char.charL+"%s"+char.charR,
+				saveValue, column,
+			),
+		)
+	}
+	return
+}
+
+func parseUnion(list gdb.List, char struct {
+	charL        string
+	charR        string
+	valueCharL   string
+	valueCharR   string
+	duplicateKey string
+	keys         []string
+}) (unionValues []string) {
+	for _, mapper := range list {
+		var saveValue []string
+		for _, column := range char.keys {
+			if mapper[column] == nil {
+				continue
+			}
+			// va := reflect.ValueOf(mapper[column])
+			// ty := reflect.TypeOf(mapper[column])
+			// switch ty.Kind() {
+			// case reflect.String:
+			// 	saveValue = append(saveValue, char.valueCharL+va.String()+char.valueCharR)
+
+			// case reflect.Int:
+			// 	saveValue = append(saveValue, strconv.FormatInt(va.Int(), 10))
+
+			// case reflect.Int64:
+			// 	saveValue = append(saveValue, strconv.FormatInt(va.Int(), 10))
+
+			// default:
+			// 	// The fish has no chance getting here.
+			// 	// Nothing to do.
+			// }
+			saveValue = append(saveValue,
+				fmt.Sprintf(
+					char.valueCharL+"%s"+char.valueCharR,
+					gconv.String(mapper[column]),
+				))
+		}
+		unionValues = append(
+			unionValues,
+			fmt.Sprintf(`UNION ALL SELECT %s FROM DUAL`, strings.Join(saveValue, ",")),
+		)
+	}
+	return
+}
+
+func parseSql(
+	insertKeys, insertValues, updateValues, queryValues, unionValues []string, table, duplicateKey string,
+) (sqlStr string) {
+	var (
+		queryValueStr  = strings.Join(queryValues, ",")
+		unionValueStr  = strings.Join(unionValues, " ")
+		insertKeyStr   = strings.Join(insertKeys, ",")
+		insertValueStr = strings.Join(insertValues, ",")
+		updateValueStr = strings.Join(updateValues, ",")
+		pattern        = gstr.Trim(`
+MERGE INTO %s T1 USING (SELECT %s FROM DUAL %s) T2 ON %s 
+WHEN NOT MATCHED 
+THEN 
+INSERT(%s) VALUES (%s) 
+WHEN MATCHED 
+THEN 
+UPDATE SET %s; 
+COMMIT;
+`)
+	)
+	return fmt.Sprintf(
+		pattern,
+		table, queryValueStr, unionValueStr,
+		fmt.Sprintf("(T1.%s = T2.%s)", duplicateKey, duplicateKey),
+		insertKeyStr, insertValueStr, updateValueStr,
+	)
+}

contrib/drivers/dm/dm_do_query.go

@@ -0,0 +1,23 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+// TODO I originally wanted to only convert keywords in select
+// 但是我发现 DoQuery 中会对 sql 会对 " " 达梦的安全字符 进行 / 转义，最后还是导致达梦无法正常解析
+// However, I found that DoQuery() will perform / escape on sql with " " Dameng's safe characters, which ultimately caused Dameng to be unable to parse normally.
+// But processing in DoFilter() is OK
+// func (d *Driver) DoQuery(ctx context.Context, link gdb.Link, sql string, args ...interface{}) (gdb.Result, error) {
+// 	l, r := d.GetChars()
+// 	new := gstr.ReplaceI(sql, "INDEX", l+"INDEX"+r)
+// 	g.Dump("new:", new)
+// 	return d.Core.DoQuery(
+// 		ctx,
+// 		link,
+// 		new,
+// 		args,
+// 	)
+// }

contrib/drivers/dm/dm_open.go

@@ -0,0 +1,65 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"database/sql"
+	"fmt"
+
+	"net/url"
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+)
+
+// Open creates and returns an underlying sql.DB object for pgsql.
+func (d *Driver) Open(config *gdb.ConfigNode) (db *sql.DB, err error) {
+	var (
+		source               string
+		underlyingDriverName = "dm"
+	)
+	if config.Name == "" {
+		return nil, fmt.Errorf(
+			`dm.Open failed for driver "%s" without DB Name`, underlyingDriverName,
+		)
+	}
+	// Data Source Name of DM8:
+	// dm://userName:password@ip:port/dbname
+	// dm://userName:password@DW/dbname?DW=(192.168.1.1:5236,192.168.1.2:5236)
+	var domain string
+	if config.Port != "" {
+		domain = fmt.Sprintf("%s:%s", config.Host, config.Port)
+	} else {
+		domain = config.Host
+	}
+	source = fmt.Sprintf(
+		"dm://%s:%s@%s/%s?charset=%s&schema=%s",
+		config.User, config.Pass, domain, config.Name, config.Charset, config.Name,
+	)
+	// Demo of timezone setting:
+	// &loc=Asia/Shanghai
+	if config.Timezone != "" {
+		if strings.Contains(config.Timezone, "/") {
+			config.Timezone = url.QueryEscape(config.Timezone)
+		}
+		source = fmt.Sprintf("%s&loc%s", source, config.Timezone)
+	}
+	if config.Extra != "" {
+		source = fmt.Sprintf("%s&%s", source, config.Extra)
+	}
+
+	if db, err = sql.Open(underlyingDriverName, source); err != nil {
+		err = gerror.WrapCodef(
+			gcode.CodeDbOperationError, err,
+			`dm.Open failed for driver "%s" by source "%s"`, underlyingDriverName, source,
+		)
+		return nil, err
+	}
+	return
+}

contrib/drivers/dm/dm_table_fields.go

@@ -0,0 +1,70 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"context"
+	"fmt"
+
+	"strings"
+
+	"github.com/gogf/gf/v2/database/gdb"
+	"github.com/gogf/gf/v2/util/gutil"
+)
+
+const (
+	tableFieldsSqlTmp = `SELECT * FROM ALL_TAB_COLUMNS WHERE Table_Name= '%s' AND OWNER = '%s'`
+)
+
+// TableFields retrieves and returns the fields' information of specified table of current schema.
+func (d *Driver) TableFields(
+	ctx context.Context, table string, schema ...string,
+) (fields map[string]*gdb.TableField, err error) {
+	var (
+		result gdb.Result
+		link   gdb.Link
+		// When no schema is specified, the configuration item is returned by default
+		usedSchema = gutil.GetOrDefaultStr(d.GetSchema(), schema...)
+	)
+	// When usedSchema is empty, return the default link
+	if link, err = d.SlaveLink(usedSchema); err != nil {
+		return nil, err
+	}
+	// The link has been distinguished and no longer needs to judge the owner
+	result, err = d.DoSelect(
+		ctx, link,
+		fmt.Sprintf(
+			tableFieldsSqlTmp,
+			strings.ToUpper(table),
+			strings.ToUpper(d.GetSchema()),
+		),
+	)
+	if err != nil {
+		return nil, err
+	}
+	fields = make(map[string]*gdb.TableField)
+	for i, m := range result {
+		// m[NULLABLE] returns "N" "Y"
+		// "N" means not null
+		// "Y" means could be null
+		var nullable bool
+		if m["NULLABLE"].String() != "N" {
+			nullable = true
+		}
+		fields[m["COLUMN_NAME"].String()] = &gdb.TableField{
+			Index:   i,
+			Name:    m["COLUMN_NAME"].String(),
+			Type:    m["DATA_TYPE"].String(),
+			Null:    nullable,
+			Default: m["DATA_DEFAULT"].Val(),
+			// Key:     m["Key"].String(),
+			// Extra:   m["Extra"].String(),
+			// Comment: m["Comment"].String(),
+		}
+	}
+	return fields, nil
+}

contrib/drivers/dm/dm_tables.go

@@ -0,0 +1,39 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/database/gdb"
+)
+
+const (
+	tablesSqlTmp = `SELECT * FROM ALL_TABLES`
+)
+
+// Tables retrieves and returns the tables of current schema.
+// It's mainly used in cli tool chain for automatically generating the models.
+func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error) {
+	var result gdb.Result
+	// When schema is empty, return the default link
+	link, err := d.SlaveLink(schema...)
+	if err != nil {
+		return nil, err
+	}
+	// The link has been distinguished and no longer needs to judge the owner
+	result, err = d.DoSelect(ctx, link, tablesSqlTmp)
+	if err != nil {
+		return
+	}
+	for _, m := range result {
+		if v, ok := m["IOT_NAME"]; ok {
+			tables = append(tables, v.String())
+		}
+	}
+	return
+}

contrib/drivers/dm/dm_z_unit_init_test.go

@@ -12,7 +12,6 @@ import (
 	"strings"
 	"time"
 
-	_ "gitee.com/chunanyong/dm"
 	"github.com/gogf/gf/v2/container/garray"
 	"github.com/gogf/gf/v2/database/gdb"
 	"github.com/gogf/gf/v2/frame/g"

contrib/drivers/dm/dm_z_unit_issue_test.go

@@ -0,0 +1,73 @@
+// Copyright 2019 gf Author(https://github.com/gogf/gf). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package dm_test
+
+import (
+	"testing"
+	"time"
+
+	"github.com/gogf/gf/v2/os/gtime"
+	"github.com/gogf/gf/v2/test/gtest"
+	"github.com/gogf/gf/v2/text/gstr"
+)
+
+func Test_Issue2594(t *testing.T) {
+	table := "HANDLE_INFO"
+	array := gstr.SplitAndTrim(gtest.DataContent(`issue`, `2594`, `sql.sql`), ";")
+	for _, v := range array {
+		if _, err := db.Exec(ctx, v); err != nil {
+			gtest.Error(err)
+		}
+	}
+	defer dropTable(table)
+
+	type HandleValueMysql struct {
+		Index int64  `orm:"index"`
+		Type  string `orm:"type"`
+		Data  []byte `orm:"data"`
+	}
+	type HandleInfoMysql struct {
+		Id         int                `orm:"id,primary" json:"id"`
+		SubPrefix  string             `orm:"sub_prefix"`
+		Prefix     string             `orm:"prefix"`
+		HandleName string             `orm:"handle_name"`
+		CreateTime time.Time          `orm:"create_time"`
+		UpdateTime time.Time          `orm:"update_time"`
+		Value      []HandleValueMysql `orm:"value"`
+	}
+
+	gtest.C(t, func(t *gtest.T) {
+		var h1 = HandleInfoMysql{
+			SubPrefix:  "p_",
+			Prefix:     "m_",
+			HandleName: "name",
+			CreateTime: gtime.Now().FormatTo("Y-m-d H:i:s").Time,
+			UpdateTime: gtime.Now().FormatTo("Y-m-d H:i:s").Time,
+			Value: []HandleValueMysql{
+				{
+					Index: 10,
+					Type:  "t1",
+					Data:  []byte("abc"),
+				},
+				{
+					Index: 20,
+					Type:  "t2",
+					Data:  []byte("def"),
+				},
+			},
+		}
+		_, err := db.Model(table).OmitEmptyData().Insert(h1)
+		t.AssertNil(err)
+
+		var h2 HandleInfoMysql
+		err = db.Model(table).Scan(&h2)
+		t.AssertNil(err)
+
+		h1.Id = 1
+		t.Assert(h1, h2)
+	})
+}

contrib/drivers/dm/go.mod

@@ -6,7 +6,7 @@ replace github.com/gogf/gf/v2 => ../../../
 
 require (
 	gitee.com/chunanyong/dm v1.8.12
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 )
 
 require (

contrib/drivers/dm/testdata/issue/2594/sql.sql

@@ -0,0 +1,10 @@
+CREATE TABLE HANDLE_INFO (
+    ID INT IDENTITY (1, 1) NOT NULL,
+    SUB_PREFIX VARCHAR(128),
+    PREFIX VARCHAR(256),
+    HANDLE_NAME VARCHAR(1024) NOT NULL,
+    CREATE_TIME TIMESTAMP,
+    UPDATE_TIME TIMESTAMP,
+    VALUE BLOB   ,
+    NOT CLUSTER PRIMARY KEY (ID)
+);

contrib/drivers/mssql/go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/denisenkom/go-mssqldb v0.12.3
-	github.com/gogf/gf/v2 v2.6.1
+	github.com/gogf/gf/v2 v2.6.3
 )
 
 require (

contrib/drivers/mssql/mssql.go

@@ -12,20 +12,11 @@
 package mssql
 
 import (
-	"context"
-	"database/sql"
-	"fmt"
-	"strconv"
-	"strings"
-
 	_ "github.com/denisenkom/go-mssqldb"
 
 	"github.com/gogf/gf/v2/database/gdb"
-	"github.com/gogf/gf/v2/errors/gcode"
-	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/text/gregex"
 	"github.com/gogf/gf/v2/text/gstr"
-	"github.com/gogf/gf/v2/util/gutil"
 )
 
 // Driver is the driver for SQL server database.
@@ -43,6 +34,21 @@ func init() {
 	}
 }
 
+// formatSqlTmp formats sql template string into one line.
+func formatSqlTmp(sqlTmp string) string {
+	var err error
+	// format sql template string.
+	sqlTmp, err = gregex.ReplaceString(`[\n\r\s]+`, " ", gstr.Trim(sqlTmp))
+	if err != nil {
+		panic(err)
+	}
+	sqlTmp, err = gregex.ReplaceString(`\s{2,}`, " ", gstr.Trim(sqlTmp))
+	if err != nil {
+		panic(err)
+	}
+	return sqlTmp
+}
+
 // New create and returns a driver that implements gdb.Driver, which supports operations for Mssql.
 func New() gdb.Driver {
 	return &Driver{}
@@ -56,262 +62,7 @@ func (d *Driver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error) {
 	}, nil
 }
 
-// Open creates and returns an underlying sql.DB object for mssql.
-func (d *Driver) Open(config *gdb.ConfigNode) (db *sql.DB, err error) {
-	var (
-		source               string
-		underlyingDriverName = "sqlserver"
-	)
-	if config.Link != "" {
-		// ============================================================================
-		// Deprecated from v2.2.0.
-		// ============================================================================
-		source = config.Link
-		// Custom changing the schema in runtime.
-		if config.Name != "" {
-			source, _ = gregex.ReplaceString(`database=([\w\.\-]+)+`, "database="+config.Name, source)
-		}
-	} else {
-		source = fmt.Sprintf(
-			"user id=%s;password=%s;server=%s;port=%s;database=%s;encrypt=disable",
-			config.User, config.Pass, config.Host, config.Port, config.Name,
-		)
-		if config.Extra != "" {
-			var extraMap map[string]interface{}
-			if extraMap, err = gstr.Parse(config.Extra); err != nil {
-				return nil, err
-			}
-			for k, v := range extraMap {
-				source += fmt.Sprintf(`;%s=%s`, k, v)
-			}
-		}
-	}
-
-	if db, err = sql.Open(underlyingDriverName, source); err != nil {
-		err = gerror.WrapCodef(
-			gcode.CodeDbOperationError, err,
-			`sql.Open failed for driver "%s" by source "%s"`, underlyingDriverName, source,
-		)
-		return nil, err
-	}
-	return
-}
-
 // GetChars returns the security char for this type of database.
 func (d *Driver) GetChars() (charLeft string, charRight string) {
 	return quoteChar, quoteChar
 }
-
-// DoFilter deals with the sql string before commits it to underlying sql driver.
-func (d *Driver) DoFilter(ctx context.Context, link gdb.Link, sql string, args []interface{}) (newSql string, newArgs []interface{}, err error) {
-	var index int
-	// Convert placeholder char '?' to string "@px".
-	newSql, _ = gregex.ReplaceStringFunc("\\?", sql, func(s string) string {
-		index++
-		return fmt.Sprintf("@p%d", index)
-	})
-	newSql, _ = gregex.ReplaceString("\"", "", newSql)
-	return d.Core.DoFilter(ctx, link, d.parseSql(newSql), args)
-}
-
-// parseSql does some replacement of the sql before commits it to underlying driver,
-// for support of microsoft sql server.
-func (d *Driver) parseSql(sql string) string {
-	// SELECT * FROM USER WHERE ID=1 LIMIT 1
-	if m, _ := gregex.MatchString(`^SELECT(.+)LIMIT 1$`, sql); len(m) > 1 {
-		return fmt.Sprintf(`SELECT TOP 1 %s`, m[1])
-	}
-	// SELECT * FROM USER WHERE AGE>18 ORDER BY ID DESC LIMIT 100, 200
-	patten := `^\s*(?i)(SELECT)|(LIMIT\s*(\d+)\s*,\s*(\d+))`
-	if gregex.IsMatchString(patten, sql) == false {
-		return sql
-	}
-	res, err := gregex.MatchAllString(patten, sql)
-	if err != nil {
-		return ""
-	}
-	var (
-		index   = 0
-		keyword = strings.TrimSpace(res[index][0])
-	)
-	index++
-	switch strings.ToUpper(keyword) {
-	case "SELECT":
-		// LIMIT statement checks.
-		if len(res) < 2 ||
-			(strings.HasPrefix(res[index][0], "LIMIT") == false &&
-				strings.HasPrefix(res[index][0], "limit") == false) {
-			break
-		}
-		if gregex.IsMatchString("((?i)SELECT)(.+)((?i)LIMIT)", sql) == false {
-			break
-		}
-		// ORDER BY statement checks.
-		var (
-			selectStr = ""
-			orderStr  = ""
-			haveOrder = gregex.IsMatchString("((?i)SELECT)(.+)((?i)ORDER BY)", sql)
-		)
-		if haveOrder {
-			queryExpr, _ := gregex.MatchString("((?i)SELECT)(.+)((?i)ORDER BY)", sql)
-			if len(queryExpr) != 4 ||
-				strings.EqualFold(queryExpr[1], "SELECT") == false ||
-				strings.EqualFold(queryExpr[3], "ORDER BY") == false {
-				break
-			}
-			selectStr = queryExpr[2]
-			orderExpr, _ := gregex.MatchString("((?i)ORDER BY)(.+)((?i)LIMIT)", sql)
-			if len(orderExpr) != 4 ||
-				strings.EqualFold(orderExpr[1], "ORDER BY") == false ||
-				strings.EqualFold(orderExpr[3], "LIMIT") == false {
-				break
-			}
-			orderStr = orderExpr[2]
-		} else {
-			queryExpr, _ := gregex.MatchString("((?i)SELECT)(.+)((?i)LIMIT)", sql)
-			if len(queryExpr) != 4 ||
-				strings.EqualFold(queryExpr[1], "SELECT") == false ||
-				strings.EqualFold(queryExpr[3], "LIMIT") == false {
-				break
-			}
-			selectStr = queryExpr[2]
-		}
-		first, limit := 0, 0
-		for i := 1; i < len(res[index]); i++ {
-			if len(strings.TrimSpace(res[index][i])) == 0 {
-				continue
-			}
-
-			if strings.HasPrefix(res[index][i], "LIMIT") ||
-				strings.HasPrefix(res[index][i], "limit") {
-				first, _ = strconv.Atoi(res[index][i+1])
-				limit, _ = strconv.Atoi(res[index][i+2])
-				break
-			}
-		}
-		if haveOrder {
-			sql = fmt.Sprintf(
-				"SELECT * FROM "+
-					"(SELECT ROW_NUMBER() OVER (ORDER BY %s) as ROWNUMBER_, %s ) as TMP_ "+
-					"WHERE TMP_.ROWNUMBER_ > %d AND TMP_.ROWNUMBER_ <= %d",
-				orderStr, selectStr, first, first+limit,
-			)
-		} else {
-			if first == 0 {
-				first = limit
-			}
-			sql = fmt.Sprintf(
-				"SELECT * FROM (SELECT TOP %d * FROM (SELECT TOP %d %s) as TMP1_ ) as TMP2_ ",
-				limit, first+limit, selectStr,
-			)
-		}
-	default:
-	}
-	return sql
-}
-
-// Tables retrieves and returns the tables of current schema.
-// It's mainly used in cli tool chain for automatically generating the models.
-func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error) {
-	var result gdb.Result
-	link, err := d.SlaveLink(schema...)
-	if err != nil {
-		return nil, err
-	}
-
-	result, err = d.DoSelect(
-		ctx, link, `SELECT NAME FROM SYSOBJECTS WHERE XTYPE='U' AND STATUS >= 0 ORDER BY NAME`,
-	)
-	if err != nil {
-		return
-	}
-	for _, m := range result {
-		for _, v := range m {
-			tables = append(tables, v.String())
-		}
-	}
-	return
-}
-
-// TableFields retrieves and returns the fields' information of specified table of current schema.
-//
-// Also see DriverMysql.TableFields.
-func (d *Driver) TableFields(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error) {
-	var (
-		result     gdb.Result
-		link       gdb.Link
-		usedSchema = gutil.GetOrDefaultStr(d.GetSchema(), schema...)
-	)
-	if link, err = d.SlaveLink(usedSchema); err != nil {
-		return nil, err
-	}
-	structureSql := fmt.Sprintf(`
-SELECT 
-	a.name Field,
-	CASE b.name 
-		WHEN 'datetime' THEN 'datetime'
-		WHEN 'numeric' THEN b.name + '(' + convert(varchar(20), a.xprec) + ',' + convert(varchar(20), a.xscale) + ')' 
-		WHEN 'char' THEN b.name + '(' + convert(varchar(20), a.length)+ ')'
-		WHEN 'varchar' THEN b.name + '(' + convert(varchar(20), a.length)+ ')'
-		ELSE b.name + '(' + convert(varchar(20),a.length)+ ')' END AS Type,
-	CASE WHEN a.isnullable=1 THEN 'YES' ELSE 'NO' end AS [Null],
-	CASE WHEN exists (
-		SELECT 1 FROM sysobjects WHERE xtype='PK' AND name IN (
-			SELECT name FROM sysindexes WHERE indid IN (
-				SELECT indid FROM sysindexkeys WHERE id = a.id AND colid=a.colid
-			)
-		)
-	) THEN 'PRI' ELSE '' END AS [Key],
-	CASE WHEN COLUMNPROPERTY(a.id,a.name,'IsIdentity')=1 THEN 'auto_increment' ELSE '' END Extra,
-	isnull(e.text,'') AS [Default],
-	isnull(g.[value],'') AS [Comment]
-FROM syscolumns a
-LEFT JOIN systypes b ON a.xtype=b.xtype AND a.xusertype=b.xusertype
-INNER JOIN sysobjects d ON a.id=d.id AND d.xtype='U' AND d.name<>'dtproperties'
-LEFT JOIN syscomments e ON a.cdefault=e.id
-LEFT JOIN sys.extended_properties g ON a.id=g.major_id AND a.colid=g.minor_id
-LEFT JOIN sys.extended_properties f ON d.id=f.major_id AND f.minor_id =0
-WHERE d.name='%s'
-ORDER BY a.id,a.colorder`,
-		table,
-	)
-	structureSql, _ = gregex.ReplaceString(`[\n\r\s]+`, " ", gstr.Trim(structureSql))
-	result, err = d.DoSelect(ctx, link, structureSql)
-	if err != nil {
-		return nil, err
-	}
-	fields = make(map[string]*gdb.TableField)
-	for i, m := range result {
-		fields[m["Field"].String()] = &gdb.TableField{
-			Index:   i,
-			Name:    m["Field"].String(),
-			Type:    m["Type"].String(),
-			Null:    m["Null"].Bool(),
-			Key:     m["Key"].String(),
-			Default: m["Default"].Val(),
-			Extra:   m["Extra"].String(),
-			Comment: m["Comment"].String(),
-		}
-	}
-	return fields, nil
-}
-
-// DoInsert inserts or updates data forF given table.
-func (d *Driver) DoInsert(ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption) (result sql.Result, err error) {
-	switch option.InsertOption {
-	case gdb.InsertOptionSave:
-		return nil, gerror.NewCode(
-			gcode.CodeNotSupported,
-			`Save operation is not supported by mssql driver`,
-		)
-
-	case gdb.InsertOptionReplace:
-		return nil, gerror.NewCode(
-			gcode.CodeNotSupported,
-			`Replace operation is not supported by mssql driver`,
-		)
-
-	default:
-		return d.Core.DoInsert(ctx, link, table, list, option)
-	}
-}