fix insert err bug

This commit is contained in:
Lunny Xiao 2013-07-07 16:31:58 +08:00
parent c91eeed3ed
commit a9eb28a00e
1 changed files with 15 additions and 3 deletions

View File

@ -582,7 +582,11 @@ func (session *Session) Insert(beans ...interface{}) (int64, error) {
lastId, err = session.InsertMulti(bean) lastId, err = session.InsertMulti(bean)
if err != nil { if err != nil {
if !isInTransaction { if !isInTransaction {
err = session.Rollback() err1 := session.Rollback()
if err1 == nil {
return lastId, err
}
err = err1
} }
return lastId, err return lastId, err
} }
@ -592,7 +596,11 @@ func (session *Session) Insert(beans ...interface{}) (int64, error) {
lastId, err = session.InsertOne(sliceValue.Index(i).Interface()) lastId, err = session.InsertOne(sliceValue.Index(i).Interface())
if err != nil { if err != nil {
if !isInTransaction { if !isInTransaction {
err = session.Rollback() err1 := session.Rollback()
if err1 == nil {
return lastId, err
}
err = err1
} }
return lastId, err return lastId, err
} }
@ -602,7 +610,11 @@ func (session *Session) Insert(beans ...interface{}) (int64, error) {
lastId, err = session.InsertOne(bean) lastId, err = session.InsertOne(bean)
if err != nil { if err != nil {
if !isInTransaction { if !isInTransaction {
err = session.Rollback() err1 := session.Rollback()
if err1 == nil {
return lastId, err
}
err = err1
} }
return lastId, err return lastId, err
} }