|
|
@@ -167,7 +167,7 @@ func (m *Mysql) ExecBySqlByTx(tx *sql.Tx, q string, args ...interface{}) (sql.Re
|
|
|
defer stmtIns.Close()
|
|
|
result, err := stmtIns.Exec(args...)
|
|
|
if err != nil {
|
|
|
- log.Println(err)
|
|
|
+ log.Println(args, err)
|
|
|
return nil, err
|
|
|
}
|
|
|
return result, nil
|
|
|
@@ -305,7 +305,7 @@ func (m *Mysql) Select(bath int, f func(l *[]map[string]interface{}), tx *sql.Tx
|
|
|
}
|
|
|
}
|
|
|
list = append(list, ret)
|
|
|
- if bath > 0 {
|
|
|
+ if bath > 0 && len(list) == bath {
|
|
|
f(&list)
|
|
|
list = []map[string]interface{}{}
|
|
|
}
|
