Слияние кода завершено, страница обновится автоматически
package gourm
import (
"fmt"
"log"
"reflect"
"strings"
)
func (m *Model) Insert(insertRow interface{}) error {
// 检验一下参数是不是struct pointer
t := reflect.TypeOf(insertRow)
if t.Kind() != reflect.Ptr {
return fmt.Errorf("insert value not a pointer")
}
if t.Elem().Kind() != reflect.Struct {
return fmt.Errorf("insert value not a struct")
}
v := reflect.ValueOf(insertRow).Elem()
tablename := getTableName(v)
// 检查一下 table 名称, 这个是一个必须的参数
if tablename == "" {
return fmt.Errorf("no table name")
}
var (
primary string
cols []string
vals []string
)
primary = getPrimaryKey(v)
colVals := getColumnVals(v)
for i, k := range colVals {
if i == primary {
continue
}
cols = append(cols, i)
vals = append(vals, fmt.Sprintf("'%v'", k))
}
sentence := fmt.Sprintf("insert into %s (%s) values (%s) ", tablename, strings.Join(cols, ", "), strings.Join(vals, ", "))
if primary != "" {
sentence += fmt.Sprintf("returning %s", primary)
row := dbConn.QueryRow(sentence)
primaryAddr := getPrimaryAddr(v)
err = row.Scan(primaryAddr)
if err != nil {
log.Printf("<urm><insert>sentence: (%s) scan err: %v\n", sentence, err)
return err
}
return nil
} else {
_, err := dbConn.Exec(sentence)
if err != nil {
log.Printf("<urm><insert>sentence: (%s) scan err: %v\n", sentence, err)
}
return err
}
}
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )