gsql

Documentation

Index

• Variables
• func GetMssqlDB(conInfo string) *sql.DB
• func GetMysqlDB(conInfo string) *sql.DB
• func InitConnection(driverName string)
• func InitMsSqlConnection() map[string]*sql.DB
• func InitMySqlConnection() map[string]*sql.DB
• func InitPgConnection() map[string]*sql.DB
• func Run(driverName string, tgtDb string, stmt string) (int, []string, []map[string]interface{}, string)
• type SqlExec
  • func (sqlExec *SqlExec) Delete() error
  • func (sqlExec *SqlExec) Insert() error
  • func (sqlExec *SqlExec) QueryWithParams()
  • func (sqlExec *SqlExec) QueryWithoutParams() error
  • func (sqlExec *SqlExec) ScanRows(rows *sql.Rows) (int, []string, []map[string]interface{})
  • func (sqlExec *SqlExec) Update() error

Variables

var SqlCons map[string]map[string]*sql.DB

Functions

func GetMssqlDB

func GetMssqlDB(conInfo string) *sql.DB

func GetMysqlDB

func GetMysqlDB(conInfo string) *sql.DB

func InitConnection

func InitConnection(driverName string)

func InitMsSqlConnection

func InitMsSqlConnection() map[string]*sql.DB

func InitMySqlConnection

func InitMySqlConnection() map[string]*sql.DB

func InitPgConnection

func InitPgConnection() map[string]*sql.DB

var db = &sql.DB{}

func Run

func Run(driverName string, tgtDb string, stmt string) (int, []string, []map[string]interface{}, string)

Types

type SqlExec

type SqlExec struct {
	DriverName       string
	TargetDb         string
	Stmt             string
	CmdAffectedCount int
	RowsHeaders      []string
	CmdResults       []map[string]interface{}
}

func (*SqlExec) Delete

func (sqlExec *SqlExec) Delete() error

func (*SqlExec) Insert

func (sqlExec *SqlExec) Insert() error

func (*SqlExec) QueryWithParams

func (sqlExec *SqlExec) QueryWithParams()

func (*SqlExec) QueryWithoutParams

func (sqlExec *SqlExec) QueryWithoutParams() error

func (*SqlExec) ScanRows

func (sqlExec *SqlExec) ScanRows(rows *sql.Rows) (int, []string, []map[string]interface{})

func (*SqlExec) Update

func (sqlExec *SqlExec) Update() error