This commit is contained in:
Lunny Xiao 2019-01-21 22:34:36 +08:00
parent 491559f34b
commit b7e5729c25
No known key found for this signature in database
GPG Key ID: C3B7C91B632F738A
1 changed files with 10 additions and 2 deletions

View File

@ -660,6 +660,10 @@ func (session *Session) genInsertColumns(bean interface{}) ([]string, []interfac
}
func (session *Session) insertMapInterface(m map[string]interface{}) (int64, error) {
if len(m) == 0 {
return 0, ErrParamsType
}
var columns = make([]string, 0, len(m))
for k := range m {
columns = append(columns, k)
@ -674,7 +678,7 @@ func (session *Session) insertMapInterface(m map[string]interface{}) (int64, err
return 0, ErrTableNotFound
}
var sql = "INSERT INTO `" + tableName + "` (`" + strings.Join(columns, "`,`") + "`) VALUES " + qm
var sql = fmt.Sprintf("INSERT INTO %s (`%s`) VALUES %s", tableName, strings.Join(columns, "`,`"), qm)
var args = make([]interface{}, 0, len(m))
for _, colName := range columns {
args = append(args, m[colName])
@ -696,6 +700,10 @@ func (session *Session) insertMapInterface(m map[string]interface{}) (int64, err
}
func (session *Session) insertMapString(m map[string]string) (int64, error) {
if len(m) == 0 {
return 0, ErrParamsType
}
var columns = make([]string, 0, len(m))
for k := range m {
columns = append(columns, k)
@ -710,7 +718,7 @@ func (session *Session) insertMapString(m map[string]string) (int64, error) {
return 0, ErrTableNotFound
}
var sql = "INSERT INTO `" + tableName + "` (`" + strings.Join(columns, "`,`") + "`) VALUES " + qm
var sql = fmt.Sprintf("INSERT INTO %s (`%s`) VALUES %s", tableName, strings.Join(columns, "`,`"), qm)
var args = make([]interface{}, 0, len(m))
for _, colName := range columns {
args = append(args, m[colName])