mirror of
https://github.com/astaxie/beego.git
synced 2024-12-23 07:50:49 +00:00
Update orm_querym2m.go
This commit is contained in:
parent
a89f14d80d
commit
ca37557a26
@ -44,7 +44,15 @@ func (o *queryM2M) Add(mds ...interface{}) (int64, error) {
|
||||
dbase := orm.alias.DbBaser
|
||||
|
||||
var models []interface{}
|
||||
|
||||
last_md_col_name := mi.fields.dbcols[len(mi.fields.dbcols)-1]
|
||||
last_md := mds[len(mds)-1]
|
||||
var v3 interface{}
|
||||
var names []string
|
||||
var values []interface{}
|
||||
if reflect.Indirect(reflect.ValueOf(last_md)).Kind() != reflect.Struct {
|
||||
v3 = (last_md)
|
||||
mds = mds[:len(mds)-1]
|
||||
}
|
||||
for _, md := range mds {
|
||||
val := reflect.ValueOf(md)
|
||||
if val.Kind() == reflect.Slice || val.Kind() == reflect.Array {
|
||||
@ -63,15 +71,18 @@ func (o *queryM2M) Add(mds ...interface{}) (int64, error) {
|
||||
if exist == false {
|
||||
panic(ErrMissPK)
|
||||
}
|
||||
if v3 != nil {
|
||||
names = []string{mfi.column, rfi.column, last_md_col_name}
|
||||
|
||||
names := []string{mfi.column, rfi.column}
|
||||
|
||||
values := make([]interface{}, 0, len(models)*2)
|
||||
values = make([]interface{}, 0, len(models)*3)
|
||||
} else {
|
||||
names = []string{mfi.column, rfi.column}
|
||||
|
||||
values = make([]interface{}, 0, len(models)*2)
|
||||
}
|
||||
for _, md := range models {
|
||||
|
||||
ind := reflect.Indirect(reflect.ValueOf(md))
|
||||
|
||||
var v2 interface{}
|
||||
if ind.Kind() != reflect.Struct {
|
||||
v2 = ind.Interface()
|
||||
@ -81,14 +92,17 @@ func (o *queryM2M) Add(mds ...interface{}) (int64, error) {
|
||||
panic(ErrMissPK)
|
||||
}
|
||||
}
|
||||
|
||||
values = append(values, v1, v2)
|
||||
if v3 == nil {
|
||||
values = append(values, v1, v2)
|
||||
} else {
|
||||
values = append(values, v1, v2, v3)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return dbase.InsertValue(orm.db, mi, true, names, values)
|
||||
}
|
||||
|
||||
|
||||
// remove models following the origin model relationship
|
||||
func (o *queryM2M) Remove(mds ...interface{}) (int64, error) {
|
||||
fi := o.fi
|
||||
|
Loading…
Reference in New Issue
Block a user