bug fixed for engine.ShowExecTime
This commit is contained in:
parent
4bcbb95688
commit
8c05434162
|
@ -219,7 +219,6 @@ func (engine *Engine) Ping() error {
|
||||||
// logging sql
|
// logging sql
|
||||||
func (engine *Engine) logSQL(sqlStr string, sqlArgs ...interface{}) {
|
func (engine *Engine) logSQL(sqlStr string, sqlArgs ...interface{}) {
|
||||||
if engine.showSQL && !engine.showExecTime {
|
if engine.showSQL && !engine.showExecTime {
|
||||||
//engine.overrideLogLevel(core.LOG_INFO)
|
|
||||||
if len(sqlArgs) > 0 {
|
if len(sqlArgs) > 0 {
|
||||||
engine.logger.Infof("[sql] %v [args] %v", sqlStr, sqlArgs)
|
engine.logger.Infof("[sql] %v [args] %v", sqlStr, sqlArgs)
|
||||||
} else {
|
} else {
|
||||||
|
|
37
session.go
37
session.go
|
@ -1057,16 +1057,7 @@ func (session *Session) Get(bean interface{}) (bool, error) {
|
||||||
var err error
|
var err error
|
||||||
session.queryPreprocess(&sqlStr, args...)
|
session.queryPreprocess(&sqlStr, args...)
|
||||||
if session.IsAutoCommit {
|
if session.IsAutoCommit {
|
||||||
if session.prepareStmt {
|
_, rawRows, err = session.innerQuery(sqlStr, args...)
|
||||||
stmt, errPrepare := session.doPrepare(sqlStr)
|
|
||||||
if errPrepare != nil {
|
|
||||||
return false, errPrepare
|
|
||||||
}
|
|
||||||
// defer stmt.Close() // !nashtsai! don't close due to stmt is cached and bounded to this session
|
|
||||||
rawRows, err = stmt.Query(args...)
|
|
||||||
} else {
|
|
||||||
rawRows, err = session.DB().Query(sqlStr, args...)
|
|
||||||
}
|
|
||||||
} else {
|
} else {
|
||||||
rawRows, err = session.Tx.Query(sqlStr, args...)
|
rawRows, err = session.Tx.Query(sqlStr, args...)
|
||||||
}
|
}
|
||||||
|
@ -1302,20 +1293,10 @@ func (session *Session) Find(rowsSlicePtr interface{}, condiBean ...interface{})
|
||||||
|
|
||||||
if sliceValue.Kind() != reflect.Map {
|
if sliceValue.Kind() != reflect.Map {
|
||||||
var rawRows *core.Rows
|
var rawRows *core.Rows
|
||||||
var stmt *core.Stmt
|
|
||||||
|
|
||||||
session.queryPreprocess(&sqlStr, args...)
|
session.queryPreprocess(&sqlStr, args...)
|
||||||
|
|
||||||
if session.IsAutoCommit {
|
if session.IsAutoCommit {
|
||||||
if session.prepareStmt {
|
_, rawRows, err = session.innerQuery(sqlStr, args...)
|
||||||
stmt, err = session.doPrepare(sqlStr)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
rawRows, err = stmt.Query(args...)
|
|
||||||
} else {
|
|
||||||
rawRows, err = session.DB().Query(sqlStr, args...)
|
|
||||||
}
|
|
||||||
} else {
|
} else {
|
||||||
rawRows, err = session.Tx.Query(sqlStr, args...)
|
rawRows, err = session.Tx.Query(sqlStr, args...)
|
||||||
}
|
}
|
||||||
|
@ -2049,7 +2030,7 @@ func (session *Session) query(sqlStr string, paramStr ...interface{}) (resultsSl
|
||||||
session.queryPreprocess(&sqlStr, paramStr...)
|
session.queryPreprocess(&sqlStr, paramStr...)
|
||||||
|
|
||||||
if session.IsAutoCommit {
|
if session.IsAutoCommit {
|
||||||
return session.innerQuery(sqlStr, paramStr...)
|
return session.innerQuery2(sqlStr, paramStr...)
|
||||||
}
|
}
|
||||||
return session.txQuery(session.Tx, sqlStr, paramStr...)
|
return session.txQuery(session.Tx, sqlStr, paramStr...)
|
||||||
}
|
}
|
||||||
|
@ -2064,7 +2045,7 @@ func (session *Session) txQuery(tx *core.Tx, sqlStr string, params ...interface{
|
||||||
return rows2maps(rows)
|
return rows2maps(rows)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (session *Session) innerQuery(sqlStr string, params ...interface{}) ([]map[string][]byte, error) {
|
func (session *Session) innerQuery(sqlStr string, params ...interface{}) (*core.Stmt, *core.Rows, error) {
|
||||||
var callback func() (*core.Stmt, *core.Rows, error)
|
var callback func() (*core.Stmt, *core.Rows, error)
|
||||||
if session.prepareStmt {
|
if session.prepareStmt {
|
||||||
callback = func() (*core.Stmt, *core.Rows, error) {
|
callback = func() (*core.Stmt, *core.Rows, error) {
|
||||||
|
@ -2087,7 +2068,15 @@ func (session *Session) innerQuery(sqlStr string, params ...interface{}) ([]map[
|
||||||
return nil, rows, err
|
return nil, rows, err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
_, rows, err := session.Engine.logSQLQueryTime(sqlStr, params, callback)
|
stmt, rows, err := session.Engine.logSQLQueryTime(sqlStr, params, callback)
|
||||||
|
if err != nil {
|
||||||
|
return nil, nil, err
|
||||||
|
}
|
||||||
|
return stmt, rows, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (session *Session) innerQuery2(sqlStr string, params ...interface{}) ([]map[string][]byte, error) {
|
||||||
|
_, rows, err := session.innerQuery(sqlStr, params...)
|
||||||
if rows != nil {
|
if rows != nil {
|
||||||
defer rows.Close()
|
defer rows.Close()
|
||||||
}
|
}
|
||||||
|
|
|
@ -15,6 +15,7 @@ import (
|
||||||
|
|
||||||
var _ core.ILogger = &SyslogLogger{}
|
var _ core.ILogger = &SyslogLogger{}
|
||||||
|
|
||||||
|
// SyslogLogger will be depricated
|
||||||
type SyslogLogger struct {
|
type SyslogLogger struct {
|
||||||
w *syslog.Writer
|
w *syslog.Writer
|
||||||
showSQL bool
|
showSQL bool
|
||||||
|
|
Loading…
Reference in New Issue