Documentation
¶
Overview ¶
package gosql mysql工具包..引用"github.com/go-sql-driver/mysql"
Index ¶
- Constants
- Variables
- func Connect(host, username, password, db string, other ...string) (db.SQL, error)
- func ExecResultHasError(execresult db.ExecResult, reportZeroChange bool, param ...map[string]string) err1.Error
- func GetDuplicateField(errmsg string) string
- func InitializeDB(host, username, password, name string, log ...logs.Logger)
- func SelectSQL(obj interface{}, tablename ...string) *bytes.Buffer
- func SetSQL(obj interface{}) (string, []interface{})
- func Update(table string, obj interface{}) (string, []interface{}, err1.Error)
- func WhereIN(field string, values string, args []interface{}, bs *bytes.Buffer, ...) (*bytes.Buffer, []interface{})
- type Conn
- func (d *Conn) Close()
- func (d *Conn) Count(sql string, args ...interface{}) (int64, err1.Error)
- func (d *Conn) DataBaseName() string
- func (d *Conn) Exec(sql string, args ...interface{}) db.ExecResult
- func (d *Conn) FormatError(e error) err1.Error
- func (d *Conn) GetConn() db.SQL
- func (d *Conn) GetDb() (*sql.DB, err1.Error)
- func (d *Conn) ParseSQL(sql string, args map[string]interface{}) (string, []interface{}, err1.Error)
- func (d *Conn) Prepare(query string) (*sql.Stmt, err1.Error)
- func (d *Conn) QueryRow(sql string, args ...interface{}) db.QueryResult
- func (d *Conn) QueryRows(sql string, args ...interface{}) db.QueryResult
- func (d *Conn) QueryWithPage(sql string, page *db.PageObj, args ...interface{}) db.QueryResult
- func (d *Conn) ReConnect()
- func (d *Conn) Table(tbname string) string
- func (d *Conn) Transaction(t db.TransactionFunc, new ...bool) err1.Error
Constants ¶
View Source
const ( DuplicateErrorCode = 1062 //字段重复 PRIMARY = "primary" )
Variables ¶
View Source
var SQLEmptyChange = err1.NewError(101, "数据无变化")
Functions ¶
func ExecResultHasError ¶
func ExecResultHasError(execresult db.ExecResult, reportZeroChange bool, param ...map[string]string) err1.Error
执行结果是否有错误
func InitializeDB ¶
设置数据库基础连接
Types ¶
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
数据库连接
func InitializeConnect ¶
初始化数据库
func (*Conn) DataBaseName ¶
func (*Conn) Exec ¶
func (d *Conn) Exec(sql string, args ...interface{}) db.ExecResult
Exec 执行一条SQL param sql string SQL param args... interface{} SQL参数
func (*Conn) ParseSQL ¶
func (d *Conn) ParseSQL(sql string, args map[string]interface{}) (string, []interface{}, err1.Error)
ParseSQL 解析SQL param sql string SQL param args map[string]interface{} 参数映射
func (*Conn) QueryRow ¶
func (d *Conn) QueryRow(sql string, args ...interface{}) db.QueryResult
Rows 查询多条数据,结果以[]map[string]interface{}方式返回 返回结果,使用本package中的类型函数进行数据解析 eg:
result := QueryRow(...)
result.Error(func(error.Error){
这里处理错误
}).Rows(func(map[string]interface{}) bool {
return true //返回true，继续循环读取下一条
})
param sql string SQL param args... interface{} SQL参数
func (*Conn) QueryRows ¶
func (d *Conn) QueryRows(sql string, args ...interface{}) db.QueryResult
Rows 查询多条数据,结果以[]map[string]interface{}方式返回 返回结果,使用本package中的类型函数进行数据解析 eg:
result := QueryRow(...)
result.Error(func(error.Error){
这里处理错误
}).Rows(func(map[string]interface{}) bool {
return true //返回true，继续循环读取下一条
})
param sql string SQL param args... interface{} SQL参数
func (*Conn) QueryWithPage ¶
RowsPage 分页查询SQL 返回结果,使用本package中的类型函数进行数据解析 eg:
result := QueryRow(...)
result.Error(func(error.Error){
这里处理错误
}).Rows(func(map[string]interface{}) bool {
return true //返回true，继续循环读取下一条
})
param sql string SQL param page *PageObj 分页数据 param args... interface{} SQL参数
func (*Conn) Transaction ¶
Transaction 事务处理 param t TransactionFunc 事务处理函数
Source Files
Click to show internal directories.
Click to hide internal directories.