From 373438a2833cf1caa5c38138d59a52f32ff95e2e Mon Sep 17 00:00:00 2001 From: zhenghaorong Date: Mon, 19 Jun 2023 17:11:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B9=E5=A4=9A=E8=A1=A8=E5=90=8D?= =?UTF-8?q?=E7=9A=84=E6=83=85=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- conn.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/conn.go b/conn.go index 06b0a18..718ce8f 100755 --- a/conn.go +++ b/conn.go @@ -17,7 +17,7 @@ var DB *sql.DB var SLAVER_DB *sql.DB -//db类型,默认空，如TencentDB（腾讯）, +// db类型,默认空，如TencentDB（腾讯）, var DB_PROVIDER string func Connect(DBHOST, DBUSER, DBPWD, DBNAME, DBPORT string, conns ...int) error { @@ -123,7 +123,16 @@ func getTableName(dbName, table string, dbtype ...string) string { ret = table } if dbName != "" { - ret = helper.StringJoin(dbName, ".", table) + if strings.Contains(table, ",") { + arr := strings.Split(table, ",") + arrStrs := make([]string, 0, len(arr)) + for _, v := range arr { + arrStrs = append(arrStrs, helper.StringJoin(dbName, ".", v)) + } + ret = strings.Join(arrStrs, ",") + } else { + ret = helper.StringJoin(dbName, ".", table) + } } else { ret = table }