Exec support builder (#1064)
This commit is contained in:
parent
4b224e8823
commit
4ce90f9a62
|
@ -1333,10 +1333,10 @@ func (engine *Engine) DropIndexes(bean interface{}) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Exec raw sql
|
// Exec raw sql
|
||||||
func (engine *Engine) Exec(sql string, args ...interface{}) (sql.Result, error) {
|
func (engine *Engine) Exec(sqlorArgs ...interface{}) (sql.Result, error) {
|
||||||
session := engine.NewSession()
|
session := engine.NewSession()
|
||||||
defer session.Close()
|
defer session.Close()
|
||||||
return session.Exec(sql, args...)
|
return session.Exec(sqlorArgs...)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Query a raw sql and return records as []map[string][]byte
|
// Query a raw sql and return records as []map[string][]byte
|
||||||
|
|
|
@ -27,7 +27,7 @@ type Interface interface {
|
||||||
Delete(interface{}) (int64, error)
|
Delete(interface{}) (int64, error)
|
||||||
Distinct(columns ...string) *Session
|
Distinct(columns ...string) *Session
|
||||||
DropIndexes(bean interface{}) error
|
DropIndexes(bean interface{}) error
|
||||||
Exec(string, ...interface{}) (sql.Result, error)
|
Exec(sqlOrAgrs ...interface{}) (sql.Result, error)
|
||||||
Exist(bean ...interface{}) (bool, error)
|
Exist(bean ...interface{}) (bool, error)
|
||||||
Find(interface{}, ...interface{}) error
|
Find(interface{}, ...interface{}) error
|
||||||
FindAndCount(interface{}, ...interface{}) (int64, error)
|
FindAndCount(interface{}, ...interface{}) (int64, error)
|
||||||
|
|
|
@ -17,17 +17,7 @@ import (
|
||||||
|
|
||||||
func (session *Session) genQuerySQL(sqlorArgs ...interface{}) (string, []interface{}, error) {
|
func (session *Session) genQuerySQL(sqlorArgs ...interface{}) (string, []interface{}, error) {
|
||||||
if len(sqlorArgs) > 0 {
|
if len(sqlorArgs) > 0 {
|
||||||
switch sqlorArgs[0].(type) {
|
return convertSQLOrArgs(sqlorArgs...)
|
||||||
case string:
|
|
||||||
return sqlorArgs[0].(string), sqlorArgs[1:], nil
|
|
||||||
case *builder.Builder:
|
|
||||||
return sqlorArgs[0].(*builder.Builder).ToSQL()
|
|
||||||
case builder.Builder:
|
|
||||||
bd := sqlorArgs[0].(builder.Builder)
|
|
||||||
return bd.ToSQL()
|
|
||||||
default:
|
|
||||||
return "", nil, ErrUnSupportedType
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if session.statement.RawSQL != "" {
|
if session.statement.RawSQL != "" {
|
||||||
|
|
|
@ -9,6 +9,7 @@ import (
|
||||||
"reflect"
|
"reflect"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/go-xorm/builder"
|
||||||
"github.com/go-xorm/core"
|
"github.com/go-xorm/core"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -193,11 +194,34 @@ func (session *Session) exec(sqlStr string, args ...interface{}) (sql.Result, er
|
||||||
return session.DB().Exec(sqlStr, args...)
|
return session.DB().Exec(sqlStr, args...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func convertSQLOrArgs(sqlorArgs ...interface{}) (string, []interface{}, error) {
|
||||||
|
switch sqlorArgs[0].(type) {
|
||||||
|
case string:
|
||||||
|
return sqlorArgs[0].(string), sqlorArgs[1:], nil
|
||||||
|
case *builder.Builder:
|
||||||
|
return sqlorArgs[0].(*builder.Builder).ToSQL()
|
||||||
|
case builder.Builder:
|
||||||
|
bd := sqlorArgs[0].(builder.Builder)
|
||||||
|
return bd.ToSQL()
|
||||||
|
}
|
||||||
|
|
||||||
|
return "", nil, ErrUnSupportedType
|
||||||
|
}
|
||||||
|
|
||||||
// Exec raw sql
|
// Exec raw sql
|
||||||
func (session *Session) Exec(sqlStr string, args ...interface{}) (sql.Result, error) {
|
func (session *Session) Exec(sqlorArgs ...interface{}) (sql.Result, error) {
|
||||||
if session.isAutoClose {
|
if session.isAutoClose {
|
||||||
defer session.Close()
|
defer session.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if len(sqlorArgs) == 0 {
|
||||||
|
return nil, ErrUnSupportedType
|
||||||
|
}
|
||||||
|
|
||||||
|
sqlStr, args, err := convertSQLOrArgs(sqlorArgs...)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
return session.exec(sqlStr, args...)
|
return session.exec(sqlStr, args...)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue