aa
This commit is contained in:
@@ -26,7 +26,7 @@ func Insert(db *sqlx.DB, obj interface{}) (err error) {
|
||||
}
|
||||
sname := stype.Name()
|
||||
sql.WriteString("INSERT INTO ")
|
||||
for i := 0; i < stype.NumField()-1; i++ {
|
||||
for i := 0; i < stype.NumField(); i++ {
|
||||
if stype.Field(i).Type.String() == "*time.Time" {
|
||||
if direct.Field(i).Interface().(*time.Time) != nil {
|
||||
values.WriteString(stype.Field(i).Tag.Get("json") + ",")
|
||||
@@ -49,8 +49,6 @@ func Insert(db *sqlx.DB, obj interface{}) (err error) {
|
||||
sql.WriteString("?")
|
||||
}
|
||||
sql.WriteString(")")
|
||||
fmt.Println(sql.String())
|
||||
fmt.Println(sqlParams)
|
||||
_, err = db.DB.Exec(sql.String(), sqlParams...)
|
||||
return err
|
||||
}
|
||||
@@ -129,12 +127,12 @@ func UpdateDiff(db *sqlx.DB, obj interface{}, obj2 interface{}) (err error) {
|
||||
if sname != sname2 {
|
||||
return fmt.Errorf("请传入两个类型相同的结构体!")
|
||||
}
|
||||
for i := 5; i < stype.NumField()-1; i++ {
|
||||
for i := 5; i < stype.NumField(); i++ {
|
||||
if !value.Field(i).IsZero() {
|
||||
fieldMap1[stype.Field(i).Tag.Get("json")] = value.Field(i).Interface()
|
||||
}
|
||||
}
|
||||
for i := 5; i < stype2.NumField()-1; i++ {
|
||||
for i := 5; i < stype2.NumField(); i++ {
|
||||
if !value2.Field(i).IsZero() {
|
||||
fieldMap2[stype2.Field(i).Tag.Get("json")] = value2.Field(i).Interface()
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user