Merge remote-tracking branch 'origin/master' into feature/cacher-tag
This commit is contained in:
commit
40f3ddd819
|
@ -985,6 +985,9 @@ func (session *Session) Get(bean interface{}) (bool, error) {
|
||||||
}
|
}
|
||||||
// defer stmt.Close() // !nashtsai! don't close due to stmt is cached and bounded to this session
|
// defer stmt.Close() // !nashtsai! don't close due to stmt is cached and bounded to this session
|
||||||
rawRows, err = stmt.Query(args...)
|
rawRows, err = stmt.Query(args...)
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
rawRows, err = session.Tx.Query(sqlStr, args...)
|
rawRows, err = session.Tx.Query(sqlStr, args...)
|
||||||
}
|
}
|
||||||
|
@ -1108,6 +1111,11 @@ func (session *Session) Find(rowsSlicePtr interface{}, condiBean ...interface{})
|
||||||
|
|
||||||
sqlStr = session.Statement.genSelectSql(columnStr)
|
sqlStr = session.Statement.genSelectSql(columnStr)
|
||||||
args = append(session.Statement.Params, session.Statement.BeanArgs...)
|
args = append(session.Statement.Params, session.Statement.BeanArgs...)
|
||||||
|
// for mssql and use limit
|
||||||
|
qs := strings.Count(sqlStr, "?")
|
||||||
|
if len(args)*2 == qs {
|
||||||
|
args = append(args, args...)
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
sqlStr = session.Statement.RawSQL
|
sqlStr = session.Statement.RawSQL
|
||||||
args = session.Statement.RawParams
|
args = session.Statement.RawParams
|
||||||
|
|
Loading…
Reference in New Issue