作者 yangfu

修改starrocks 查询驱动

... ... @@ -475,12 +475,18 @@ func (tableService *TableService) ValidExprSql(ctx *domain.Context, cmd *command
sql += " from " + strings.Join(set.KeysStr(), ",")
sql += " limit 1"
}
err := starrocks.ExecOfficial(sql)
if err != nil {
tx := starrocks.DB.Exec(sql)
if tx.Error != nil {
return map[string]string{
"result": err.Error(),
"result": tx.Error.Error(),
}, nil
}
//err := starrocks.ExecOfficial(sql)
//if err != nil {
// return map[string]string{
// "result": err.Error(),
// }, nil
//}
case domain.ExprModeExcelFunction:
_, err := astexpr.NewExprAST(cmd.ExprSql)
if err != nil {
... ...
... ... @@ -29,9 +29,9 @@ func Init() error {
)
DB, err = gorm.Open(mysql.Open(constant.STARROCKS_MYSQL_DATA_SOURCE), &gorm.Config{Logger: newLogger, PrepareStmt: false})
if err = InitDBOfficial(); err != nil {
return err
}
//if err = InitDBOfficial(); err != nil {
// return err
//}
//Test1()
return err
}
... ...
package starrocks
import (
"database/sql"
"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/constant"
"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/log"
"time"
)
var DBOfficial *sql.DB
func InitDBOfficial() error {
var err error
//sql.Register("mysql-star", &mysql.MySQLDriver{})
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 {
log.Logger.Debug(sql)
result, err := DBOfficial.Exec(sql)
if err != nil {
log.Logger.Error("exec error", map[string]interface{}{"err": err.Error()})
return err
}
_, err = result.RowsAffected()
if err != nil {
log.Logger.Error("result error", map[string]interface{}{"result": err.Error()})
return err
}
return nil
}
//import (
// "database/sql"
// "gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/constant"
// "gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/log"
// "time"
//)
//
//var DBOfficial *sql.DB
//
//func InitDBOfficial() error {
// var err error
// //sql.Register("mysql-star", &mysql.MySQLDriver{})
// 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 {
// log.Logger.Debug(sql)
// result, err := DBOfficial.Exec(sql)
// if err != nil {
// log.Logger.Error("exec error", map[string]interface{}{"err": err.Error()})
// return err
// }
// _, err = result.RowsAffected()
// if err != nil {
// log.Logger.Error("result error", map[string]interface{}{"result": err.Error()})
// return err
// }
// return nil
//}
... ...