dbquery

package

v0.8.0 Latest Latest Go to latest Published: Feb 5, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

git.tetele.net/ttlpkg/tgo

Documentation ¶

Overview ¶

*

DB transaction

Index ¶

Variables
func CloseConn() error
func CloseStmt(stmt *sql.Stmt) error
func Connect(DBHOST, DBUSER, DBPWD, DBNAME, DBPORT string, conns ...int) error
func Delete(dbName, table string, data map[string]string, del_count ...string) (int64, error)
func DoQuery(args ...interface{}) ([]map[string]string, error)
func GetCount(dbName, table string, where map[string]string, args ...string) (total int)
func GetData(dbName, table string, title string, where map[string]string, ...) (int, map[string]string, error)
func GetDataByStmt(dbName string, table string, title string, where []string, ...) (map[string]string, error)
func GetDbTableName(dbName, table string) string
func GetInfo(dbName, table string, title string, where map[string]string) (map[string]string, error)
func GetJoinListByStmt(dbName string, tableA, tableA_alias string, tableB, tableB_alias string, ...) ([]map[string]string, error)
func GetList(dbName, table string, title string, where map[string]string, ...) ([]map[string]string, error)
func GetListByStmt(dbName string, table string, title string, where []string, ...) ([]map[string]string, error)
func GetTotal(dbName, table string, args ...string) (total int)
func Insert(dbName, table string, data map[string]string) (int64, error)
func InsertByStmt(dbName string, table string, data []string, valuelist []interface{}) (int64, error)
func LeftJoinListByStmt(dbName string, tableA, tableB string, join_on string, title string, ...) ([]map[string]string, error)
func QueryByStmt(sql string, valuelist []interface{}) ([]map[string]string, error)
func StmtForInsert(dbName, table string, data []string) (*sql.Stmt, error)
func StmtForInsertExec(stmt *sql.Stmt, valuelist []interface{}) (int64, error)
func StmtForQuery(querysql string) (*sql.Stmt, error)
func StmtForQueryList(stmt *sql.Stmt, valuelist []interface{}) ([]map[string]string, error)
func StmtForQueryRow(stmt *sql.Stmt, valuelist []interface{}) (map[string]string, error)
func StmtForRead(dbName, table string, title string, where []string, limit map[string]string) (*sql.Stmt, error)
func StmtForUpdate(dbName, table string, data []string, where []string) (*sql.Stmt, error)
func StmtForUpdateExec(stmt *sql.Stmt, valuelist []interface{}) (int64, error)
func TxDelete(tx *sql.Tx, dbname, table string, where map[string]string, del_count ...string) (int64, error)
func TxForRead(tx *sql.Tx, dbName, table string, title string, where []string) (*sql.Stmt, error)
func TxGetData(tx *sql.Tx, dbName string, table string, title string, where []string, ...) (map[string]string, error)
func TxInsert(tx *sql.Tx, dbname, table string, data map[string]string) (int64, error)
func TxPreInsert(tx *sql.Tx, dbname, table string, data map[string]interface{}) (int64, error)
func TxPreUpdate(tx *sql.Tx, dbname, table string, data []string, where []string, ...) (int64, error)
func TxUpdate(tx *sql.Tx, dbname, table string, data map[string]string, ...) (int64, error)
func Update(dbName, table string, data map[string]string, where map[string]string) (int64, error)
func UpdateByStmt(dbName string, table string, data []string, where []string, ...) (int64, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var DB *sql.DB

Functions ¶

func CloseConn ¶

func CloseConn() error

func CloseStmt ¶

func CloseStmt(stmt *sql.Stmt) error

func Connect ¶

func Connect(DBHOST, DBUSER, DBPWD, DBNAME, DBPORT string, conns ...int) error

func Delete ¶

func Delete(dbName, table string, data map[string]string, del_count ...string) (int64, error)

*

删除数据
@param count 删除数量

func DoQuery ¶

func DoQuery(args ...interface{}) ([]map[string]string, error)

func GetCount ¶

func GetCount(dbName, table string, where map[string]string, args ...string) (total int)

*

查询总数
2020/06/04

func GetData ¶

func GetData(dbName, table string, title string, where map[string]string, limit map[string]string) (int, map[string]string, error)

*

查找一条记录
@param dbName 数据表名
@param title 查询字段名

func GetDataByStmt ¶

func GetDataByStmt(dbName string, table string, title string, where []string, valuelist []interface{}, limit map[string]string) (map[string]string, error)

*

使用db prepare方式查询单条数据
@param dbName
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
GZ
2020/05/19

func GetDbTableName ¶

func GetDbTableName(dbName, table string) string

func GetInfo ¶

func GetInfo(dbName, table string, title string, where map[string]string) (map[string]string, error)

func GetJoinListByStmt ¶

func GetJoinListByStmt(dbName string, tableA, tableA_alias string, tableB, tableB_alias string, join_type, join_on string, title string, where []string, valuelist []interface{}, limit map[string]string, page ...int) ([]map[string]string, error)

*

联表查询
@param dbName
@param tableA 表一
@param tableA_alias 表一别名
@param tableB 表二
@param tableB_alias 表二别名
@param join 联表方式
@param join_on 联表字段
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
@param page 查询范围，可传两个值 pageNum,pageSize
GZ
2020/11/23

func GetList ¶

func GetList(dbName, table string, title string, where map[string]string, limit map[string]string) ([]map[string]string, error)

*

查询列表
2018/04/19

func GetListByStmt ¶

func GetListByStmt(dbName string, table string, title string, where []string, valuelist []interface{}, limit map[string]string, page ...int) ([]map[string]string, error)

*

使用db prepare方式查询列表
@param dbName
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
@param page 查询范围，可传两个值 pageNum,pageSize
GZ
2020/05/19

func GetTotal ¶

func GetTotal(dbName, table string, args ...string) (total int)

*

查询总数
2018/04/19

func Insert ¶

func Insert(dbName, table string, data map[string]string) (int64, error)

*

创建数据

func InsertByStmt ¶

func InsertByStmt(dbName string, table string, data []string, valuelist []interface{}) (int64, error)

*

使用db prepare写入数据
@param dbName
@param table 表名
@param data 写入的字段
@param valuelist 写入的值
GZ
2020/08/06

func LeftJoinListByStmt ¶ added in v0.6.7

func LeftJoinListByStmt(dbName string, tableA, tableB string, join_on string, title string, where []string, valuelist []interface{}, limit map[string]string, page ...int) ([]map[string]string, error)

*

左联表查询
@param dbName
@param tableA 表一
@param tableB 表二
@param join_on 联表字段
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
@param page 查询范围，可传两个值 pageNum,pageSize
GZ
2021/1/27

func QueryByStmt ¶

func QueryByStmt(sql string, valuelist []interface{}) ([]map[string]string, error)

*

执行自定义查询
@return lastId error

func StmtForInsert ¶

func StmtForInsert(dbName, table string, data []string) (*sql.Stmt, error)

*

准备写入
return Stmt error

func StmtForInsertExec ¶

func StmtForInsertExec(stmt *sql.Stmt, valuelist []interface{}) (int64, error)

*

执行写入
@return lastId error

func StmtForQuery ¶

func StmtForQuery(querysql string) (*sql.Stmt, error)

*

自定义查询
return Stmt error

func StmtForQueryList ¶

func StmtForQueryList(stmt *sql.Stmt, valuelist []interface{}) ([]map[string]string, error)

*

执行查询列表
return list error

func StmtForQueryRow ¶

func StmtForQueryRow(stmt *sql.Stmt, valuelist []interface{}) (map[string]string, error)

*

执行查询一条数据
return row error

func StmtForRead ¶

func StmtForRead(dbName, table string, title string, where []string, limit map[string]string) (*sql.Stmt, error)

*

准备查询
return Stmt error

func StmtForUpdate ¶

func StmtForUpdate(dbName, table string, data []string, where []string) (*sql.Stmt, error)

*

准备更新
return Stmt error

func StmtForUpdateExec ¶

func StmtForUpdateExec(stmt *sql.Stmt, valuelist []interface{}) (int64, error)

*

执行更新
return is_updated error

func TxDelete ¶

func TxDelete(tx *sql.Tx, dbname, table string, where map[string]string, del_count ...string) (int64, error)

*

删除数据
@param count 删除数量

func TxForRead ¶

func TxForRead(tx *sql.Tx, dbName, table string, title string, where []string) (*sql.Stmt, error)

*

准备查询
return Stmt error

func TxGetData ¶

func TxGetData(tx *sql.Tx, dbName string, table string, title string, where []string, valuelist []interface{}) (map[string]string, error)

*

使用db prepare方式查询单条数据
@param dbName
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
GZ
2020/05/19

func TxInsert ¶

func TxInsert(tx *sql.Tx, dbname, table string, data map[string]string) (int64, error)

*

创建数据

func TxPreInsert ¶

func TxPreInsert(tx *sql.Tx, dbname, table string, data map[string]interface{}) (int64, error)

*

准备写入
return Stmt error

func TxPreUpdate ¶

func TxPreUpdate(tx *sql.Tx, dbname, table string, data []string, where []string, valuelist []interface{}) (int64, error)

*

准备更新
return Stmt error

func TxUpdate ¶

func TxUpdate(tx *sql.Tx, dbname, table string, data map[string]string, where map[string]string) (int64, error)

*

修改数据

func Update ¶

func Update(dbName, table string, data map[string]string, where map[string]string) (int64, error)

*

修改数据

func UpdateByStmt ¶

func UpdateByStmt(dbName string, table string, data []string, where []string, valuelist []interface{}) (int64, error)

*

使用db prepare修改数据
@param dbName
@param title 查询的字段名
@param where 查询条件
@param valuelist 查询的条件值
@param limit 查询排序
GZ
2020/05/19

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL