README
¶
sqltk
Functions for simple SQL queries and commands.
Try to make SQL actions more easily.
Install:
go get -v github.com/topxeq/sqltk
Usage:
See the test file(sqltk_test.go) for details.
or in short:
dbT, errT := sqltk.ConnectDB("goracle", dbConnectString)
tk.CheckErrf("failed to connect: %v", errT)
defer dbT.Close()
insertIDT, rowsAffectedT, errT := sqltk.ExecV(dbT, `DROP TABLE TXTEST`)
tk.Plvsr(insertIDT, rowsAffectedT, errT)
createStatementT := `
CREATE TABLE TXTEST (
ID NUMBER(10),
USER_NAME VARCHAR(256),
CODE NUMBER,
UPDATE_TIME DATE
)
`
insertIDT, rowsAffectedT, errT = sqltk.ExecV(dbT, createStatementT)
tk.CheckErrf("failed to create DB: %v", errT)
tk.Plvsr(insertIDT, rowsAffectedT)
insertIDT, rowsAffectedT, errT = sqltk.ExecV(dbT, `insert into TXTEST (ID, USER_NAME, CODE, UPDATE_TIME) values(:a1, :a2, :a3, TO_DATE(:a4 ,'yyyy-mm-dd hh24:mi:ss'))`, 1, "abc", 1.2, "2019-04-22 15:30:00")
tk.CheckErrf("failed to insert record: %v", errT)
tk.Plvsr(insertIDT, rowsAffectedT)
tk.Plvsr(sqltk.ExecV(dbT, `insert into TXTEST (ID, USER_NAME, CODE, UPDATE_TIME) values(:a1, :a2, :a3, TO_DATE(:a4 ,'yyyy-mm-dd hh24:mi:ss'))`, 1, "abc", 1.2, "2019-04-22 15:30:00"))
resultSetT, errT := sqltk.QueryDBNS(dbT, "select * from TXTEST")
tk.CheckErrf("failed to query: %v", errT)
tk.Plvsr(resultSetT)
tk.Plvsr(sqltk.QueryDBNS(dbT, "select count(*) from TXTEST"))
tk.Plvsr(sqltk.QueryDBI(dbT, "select * from TXTEST"))
tk.Plvsr(sqltk.QueryDBNS(dbT, "select * from TXTEST where ID=?", 3))
Documentation
¶
Index ¶
- Variables
- type SqlTK
- func (pA *SqlTK) BeginTransX(dbA *sql.DB) interface{}
- func (pA *SqlTK) CloseDBX(dbA *sql.DB) error
- func (pA *SqlTK) CommitX(transA *sql.Tx, sqlA string) interface{}
- func (pA *SqlTK) ConnectDB(driverStrA string, connectStrA string) (*sql.DB, error)
- func (pA *SqlTK) ConnectDBNoPing(driverStrA string, connectStrA string) (*sql.DB, error)
- func (pA *SqlTK) ConnectDBX(driverStrA string, connectStrA string) interface{}
- func (pA *SqlTK) ExecDBX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) ExecV(dbA *sql.DB, sqlStrA string, argsA ...interface{}) (int64, int64, error)
- func (pA *SqlTK) FormatSQLValue(strA string) string
- func (pA *SqlTK) GetVersion() string
- func (pA *SqlTK) ListToSQLList(vA interface{}) string
- func (pA *SqlTK) NewSqlTK() *SqlTK
- func (pA *SqlTK) OneColumnRecordsToArray(recsA [][]string) []string
- func (pA *SqlTK) OneLineRecordToMap(recA [][]string) map[string]string
- func (pA *SqlTK) PrepareX(transA *sql.Tx, sqlA string) interface{}
- func (pA *SqlTK) QueryCountX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryDBCount(dbA *sql.DB, sqlStrA string, argsA ...interface{}) (int, error)
- func (pA *SqlTK) QueryDBFloat(dbA *sql.DB, sqlStrA string, argsA ...interface{}) (float64, error)
- func (pA *SqlTK) QueryDBI(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]interface{}, error)
- func (pA *SqlTK) QueryDBMapArrayX(dbA *sql.DB, sqlStrA string, idA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryDBMapX(dbA *sql.DB, sqlStrA string, idA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryDBNS(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]string, error)
- func (pA *SqlTK) QueryDBNSS(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]string, error)
- func (pA *SqlTK) QueryDBNSSF(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]string, error)
- func (pA *SqlTK) QueryDBNSV(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]string, error)
- func (pA *SqlTK) QueryDBOrderedX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryDBRecsX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryDBS(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]string, error)
- func (pA *SqlTK) QueryDBString(dbA *sql.DB, sqlStrA string, argsA ...interface{}) (string, error)
- func (pA *SqlTK) QueryDBX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryFloatX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) QueryStringX(dbA *sql.DB, sqlStrA string, argsA ...interface{}) interface{}
- func (pA *SqlTK) RecordsToMapArray(recA [][]string) []map[string]string
- func (pA *SqlTK) RecordsToMapArrayMap(recA [][]string, keyA string) map[string][]map[string]string
Constants ¶
This section is empty.
Variables ¶
var BeginTransX = SqlTKX.BeginTransX
var CloseDBX = SqlTKX.CloseDBX
var CommitX = SqlTKX.CommitX
var ConnectDB = SqlTKX.ConnectDB
var ConnectDBNoPing = SqlTKX.ConnectDBNoPing
var ConnectDBX = SqlTKX.ConnectDBX
var ExecDBX = SqlTKX.ExecDBX
var ExecV = SqlTKX.ExecV
var FormatSQLValue = SqlTKX.FormatSQLValue
var GetVersion = SqlTKX.GetVersion
var ListToSQLList = SqlTKX.ListToSQLList
var NewSqlTK = SqlTKX.NewSqlTK
var OneColumnRecordsToArray = SqlTKX.OneColumnRecordsToArray
var OneLineRecordToMap = SqlTKX.OneLineRecordToMap
var PrepareX = SqlTKX.PrepareX
var QueryCountX = SqlTKX.QueryCountX
var QueryDBCount = SqlTKX.QueryDBCount
var QueryDBFloat = SqlTKX.QueryDBFloat
var QueryDBI = SqlTKX.QueryDBI
var QueryDBMapArrayX = SqlTKX.QueryDBMapArrayX
var QueryDBMapX = SqlTKX.QueryDBMapX
var QueryDBNS = SqlTKX.QueryDBNS
var QueryDBNSS = SqlTKX.QueryDBNSS
var QueryDBNSSF = SqlTKX.QueryDBNSSF
var QueryDBNSV = SqlTKX.QueryDBNSV
var QueryDBOrderedX = SqlTKX.QueryDBOrderedX
var QueryDBRecsX = SqlTKX.QueryDBRecsX
var QueryDBS = SqlTKX.QueryDBS
var QueryDBString = SqlTKX.QueryDBString
var QueryDBX = SqlTKX.QueryDBX
var QueryFloatX = SqlTKX.QueryFloatX
var QueryStringX = SqlTKX.QueryStringX
var RecordsToMapArray = SqlTKX.RecordsToMapArray
var RecordsToMapArrayMap = SqlTKX.RecordsToMapArrayMap
var SqlTKX = &SqlTK{Version: versionG}
Functions ¶
This section is empty.
Types ¶
type SqlTK ¶
type SqlTK struct {
Version string
}
func (*SqlTK) BeginTransX ¶
func (*SqlTK) ConnectDB ¶
ConnectDB connected the database, don't forget to close it(probably by defer function)
func (*SqlTK) ConnectDBNoPing ¶
ConnectDBNoPing connected the database(with no ping action), don't forget to close it(probably by defer function)
func (*SqlTK) ConnectDBX ¶
func (*SqlTK) ExecV ¶
ExecV execute SQL statement, get the results(insert id and rows afftected), passing parameters is supported as well.
func (*SqlTK) FormatSQLValue ¶
FormatSQLValue equivalent to strings.Replace(strA, "'", "”")
func (*SqlTK) GetVersion ¶
func (*SqlTK) ListToSQLList ¶
func (*SqlTK) OneColumnRecordsToArray ¶
OneColumnRecordsToArray convert SQL result in [][]string (several lines, first is the header, only one column per line) to []string
func (*SqlTK) OneLineRecordToMap ¶
OneLineRecordToMap convert SQL result in [][]string (2 lines, first is the header) to map[string]string
func (*SqlTK) QueryCountX ¶
func (*SqlTK) QueryDBCount ¶
QueryDBCount execute a SQL query for count(select count(*)), -1 indicates error, can handle null values, passing parameters is supported as well. Also used to get a single int result from SQL query.
func (*SqlTK) QueryDBFloat ¶
QueryDBFloat execute a SQL query for get a single float value, can handle null values, passing parameters is supported as well.
func (*SqlTK) QueryDBI ¶
func (pA *SqlTK) QueryDBI(dbA *sql.DB, sqlStrA string, argsA ...interface{}) ([][]interface{}, error)
QueryDBI execute a SQL query and return result set(first row will be the column names), all values will be interface{} type, passing parameters is supported as well.
func (*SqlTK) QueryDBMapArrayX ¶
func (*SqlTK) QueryDBMapX ¶
func (*SqlTK) QueryDBNS ¶
QueryDBNS execute a SQL query and return result set(first row will be the column names), all values will be string type, can handle null values, passing parameters is supported as well.
func (*SqlTK) QueryDBNSS ¶
QueryDBNSS execute a SQL query and return result set(first row will be the column names), all values will be string type(ensure for some DBs, such as MYSQL with uf8_general_ci encoding), can handle null values, passing parameters is supported as well.
func (*SqlTK) QueryDBNSSF ¶
QueryDBNSSF the same as QueryDBNSS, but use special format on float values, format with argument floatFormatA(i.e. %1.2f etc).
func (*SqlTK) QueryDBNSV ¶
QueryDBNSV execute a SQL query and return result set(first row will be the column names), all values will be string type(ensure for some DBs, such as MYSQL with uf8_general_ci encoding), can handle null values, passing parameters is supported as well.
func (*SqlTK) QueryDBOrderedX ¶
func (*SqlTK) QueryDBRecsX ¶
func (*SqlTK) QueryDBS ¶
QueryDBS execute a SQL query and return result set(first row will be the column names), all values will be string type, cannot handle null values, passing parameters is supported as well.
func (*SqlTK) QueryDBString ¶
QueryDBString execute a SQL query for a one string result, can handle null values, passing parameters is supported as well.
func (*SqlTK) QueryFloatX ¶
func (*SqlTK) QueryStringX ¶
func (*SqlTK) RecordsToMapArray ¶
RecordsToMapArray convert SQL result in [][]string (multi lines, first is the header) to []map[string]string
Source Files