作者 yangfu

修改starrocks 查询驱动

... ... @@ -28,10 +28,12 @@ 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("exec error", map[string]interface{}{"result": err.Error()})
return err
}
return nil
... ...