修改starrocks 查询驱动

@@ -33,6 +33,7 @@ require (
 	github.com/ajg/form v1.5.1 // indirect
 	github.com/ajg/form v1.5.1 // indirect
 	github.com/fasthttp-contrib/websocket v0.0.0-20160511215533-1f3b11f56072 // indirect
 	github.com/fasthttp-contrib/websocket v0.0.0-20160511215533-1f3b11f56072 // indirect
 	github.com/fatih/structs v1.1.0 // indirect
 	github.com/fatih/structs v1.1.0 // indirect
+	github.com/go-sql-driver/mysql v1.7.1 // indirect
 	github.com/google/go-querystring v1.1.0 // indirect
 	github.com/google/go-querystring v1.1.0 // indirect
 	github.com/imkira/go-interpol v1.1.0 // indirect
 	github.com/imkira/go-interpol v1.1.0 // indirect
 	github.com/moul/http2curl v1.0.0 // indirect
 	github.com/moul/http2curl v1.0.0 // indirect

@@ -475,10 +475,16 @@ func (tableService *TableService) ValidExprSql(ctx *domain.Context, cmd *command
 			sql += " from " + strings.Join(set.KeysStr(), ",")
 			sql += " from " + strings.Join(set.KeysStr(), ",")
 			sql += " limit 1"
 			sql += " limit 1"
 		}
 		}
-		tx := starrocks.DB.Exec(sql)
-		if tx.Error != nil {
+		//tx := starrocks.DB.Exec(sql)
+		//if tx.Error != nil {
+		//	return map[string]string{
+		//		"result": tx.Error.Error(),
+		//	}, nil
+		//}
+		err := starrocks.ExecOfficial(sql)
+		if err != nil {
 			return map[string]string{
 			return map[string]string{
-				"result": tx.Error.Error(),
+				"result": err.Error(),
 			}, nil
 			}, nil
 		}
 		}
 	case domain.ExprModeExcelFunction:
 	case domain.ExprModeExcelFunction:

@@ -29,6 +29,9 @@ func Init() error {
 	)
 	)
 	DB, err = gorm.Open(mysql.Open(constant.STARROCKS_MYSQL_DATA_SOURCE), &gorm.Config{Logger: newLogger, PrepareStmt: false})
 	DB, err = gorm.Open(mysql.Open(constant.STARROCKS_MYSQL_DATA_SOURCE), &gorm.Config{Logger: newLogger, PrepareStmt: false})
 
 
+	if err = InitDBOfficial(); err != nil {
+		return err
+	}
 	//Test1()
 	//Test1()
 	return err
 	return err
 }
 }

+package starrocks
+
+import (
+	"database/sql"
+	_ "github.com/go-sql-driver/mysql"
+	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/constant"
+	"time"
+)
+
+var DBOfficial *sql.DB
+
+func InitDBOfficial() error {
+	var err error
+	DBOfficial, err = sql.Open("mysql", constant.STARROCKS_MYSQL_DATA_SOURCE)
+	if err != nil {
+		return err
+	}
+	// See "Important settings" section.
+	DBOfficial.SetConnMaxLifetime(time.Minute * 3)
+	DBOfficial.SetMaxOpenConns(2)
+	DBOfficial.SetMaxIdleConns(2)
+	return nil
+}
+
+func ExecOfficial(sql string) error {
+	result, err := DBOfficial.Exec(sql)
+	if err != nil {
+		return err
+	}
+	_, err = result.RowsAffected()
+	if err != nil {
+		return err
+	}
+	return nil
+}