HiPoweredDev
/
xorm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed session.queryPreprocess usage

This commit is contained in:
Nash Tsai 2013-12-30 02:32:26 +08:00
parent 8f0aba838f
commit 5fa8a7271d
1 changed files with 6 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
session.go
View File

@ -886,16 +886,7 @@ func (session *Session) Get(bean interface{}) (bool, error) {
} }
var rawRows *sql.Rows var rawRows *sql.Rows
// !nashtsai! TODO calling session.queryPreprocess with cause error session.queryPreprocess(&sqlStr, args...)
// session.queryPreprocess(sqlStr, args...)
for _, filter := range session.Engine.Filters {
sqlStr = filter.Do(sqlStr, session)
}
session.Engine.LogSQL(sqlStr)
session.Engine.LogSQL(args)
if session.IsAutoCommit { if session.IsAutoCommit {
stmt, err := session.Db.Prepare(sqlStr) stmt, err := session.Db.Prepare(sqlStr)
if err != nil { if err != nil {
@ -1052,15 +1043,7 @@ func (session *Session) Find(rowsSlicePtr interface{}, condiBean ...interface{})
if sliceValue.Kind() != reflect.Map { if sliceValue.Kind() != reflect.Map {
var rawRows *sql.Rows var rawRows *sql.Rows
// !nashtsai! TODO calling session.queryPreprocess with cause error session.queryPreprocess(&sqlStr, args...)
// session.queryPreprocess(sqlStr, args...)
for _, filter := range session.Engine.Filters {
sqlStr = filter.Do(sqlStr, session)
}
session.Engine.LogSQL(sqlStr)
session.Engine.LogSQL(args)
// err = session.queryRows(&stmt, &rawRows, sqlStr, args...) // err = session.queryRows(&stmt, &rawRows, sqlStr, args...)
// if err != nil { // if err != nil {
// return err // return err
@ -1641,24 +1624,17 @@ func (session *Session) row2Bean(rows *sql.Rows, fields []string, fieldsCount in
} }
func (session *Session) queryPreprocess(sqlStr string, paramStr ...interface{}) { func (session *Session) queryPreprocess(sqlStr *string, paramStr ...interface{}) {
for _, filter := range session.Engine.Filters { for _, filter := range session.Engine.Filters {
sqlStr = filter.Do(sqlStr, session) *sqlStr = filter.Do(*sqlStr, session)
} }
session.Engine.LogSQL(sqlStr) session.Engine.LogSQL(*sqlStr)
session.Engine.LogSQL(paramStr) session.Engine.LogSQL(paramStr)
} }
func (session *Session) query(sqlStr string, paramStr ...interface{}) (resultsSlice []map[string][]byte, err error) { func (session *Session) query(sqlStr string, paramStr ...interface{}) (resultsSlice []map[string][]byte, err error) {
// !nashtsai! TODO calling session.queryPreprocess with cause error session.queryPreprocess(&sqlStr, paramStr...)
// session.queryPreprocess(sqlStr, paramStr...)
for _, filter := range session.Engine.Filters {
sqlStr = filter.Do(sqlStr, session)
}
session.Engine.LogSQL(sqlStr)
session.Engine.LogSQL(paramStr)
if session.IsAutoCommit { if session.IsAutoCommit {
return query(session.Db, sqlStr, paramStr...) return query(session.Db, sqlStr, paramStr...)