|
|
@@ -516,8 +516,7 @@ func Query(executor Executor, executeParams *sql.QueryExecuteParams) ([]sql.Resu
|
|
|
results[i] = row
|
|
|
}
|
|
|
|
|
|
- var totalCount int64
|
|
|
- err = reflectutils.AssignInt64Value(countTableRow[0]["count"], reflect.ValueOf(&totalCount))
|
|
|
+ totalCount, err := reflectutils.ToInt64(countTableRow[0]["count"])
|
|
|
if err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
@@ -592,8 +591,7 @@ func Count(executor Executor, executeParams *sql.CountExecuteParams) (int64, err
|
|
|
return 0, err
|
|
|
}
|
|
|
|
|
|
- var count int64
|
|
|
- err = reflectutils.AssignInt64Value(tableRows[0]["count"], reflect.ValueOf(&count))
|
|
|
+ count, err := reflectutils.ToInt64(tableRows[0]["count"])
|
|
|
if err != nil {
|
|
|
return 0, err
|
|
|
}
|
|
|
@@ -631,8 +629,7 @@ func CheckExist(executor Executor, executeParams *sql.CheckExistExecuteParams) (
|
|
|
return false, err
|
|
|
}
|
|
|
|
|
|
- var count int64
|
|
|
- err = reflectutils.AssignInt64Value(tableRows[0]["count"], reflect.ValueOf(&count))
|
|
|
+ count, err := reflectutils.ToInt64(tableRows[0]["count"])
|
|
|
if err != nil {
|
|
|
return false, err
|
|
|
}
|
|
|
@@ -670,8 +667,7 @@ func CheckHasOnlyOne(executor Executor, executeParams *sql.CheckHasOnlyOneExecut
|
|
|
return false, err
|
|
|
}
|
|
|
|
|
|
- var count int64
|
|
|
- err = reflectutils.AssignInt64Value(tableRows[0]["count"], reflect.ValueOf(&count))
|
|
|
+ count, err := reflectutils.ToInt64(tableRows[0]["count"])
|
|
|
if err != nil {
|
|
|
return false, err
|
|
|
}
|