38 lines
605 B
Go
38 lines
605 B
Go
package internal
|
||
|
||
import (
|
||
"common/connection"
|
||
"goutil/logUtilPlus"
|
||
)
|
||
|
||
// ExecSql 执行sql
|
||
func ExecSql(sql string) error {
|
||
|
||
defer func() error {
|
||
if err := recover(); err != nil {
|
||
logUtilPlus.ErrorLog("mq远程执行sql异常，对应sql：%s", sql)
|
||
|
||
//写入失败的文件，便于后续排查
|
||
AddSqlErr(sql)
|
||
}
|
||
return nil
|
||
}()
|
||
|
||
//获取数据库连接
|
||
db := connection.GetAdminDB()
|
||
|
||
logUtilPlus.InfoLog("执行sql:%s", sql)
|
||
|
||
//执行sql
|
||
err := db.Exec(sql).Error
|
||
|
||
//判断错误
|
||
if err != nil {
|
||
|
||
//记录错误
|
||
logUtilPlus.ErrorLog("ExecSql error:", err)
|
||
}
|
||
|
||
return nil
|
||
}
|