jdb

Documentation

Index

• func ReflectMapToStructure(m map[string]string, v reflect.Value, tagName string) error
• func ReflectSelectSqlMapResultToStructure(data []map[string]string, v interface{}, tagName string) error
• type DBConnector
  • func NewDbConnector() *DBConnector
  • func (connector *DBConnector) Close() error
  • func (connector *DBConnector) ExecuteQuery(sqlStatement string, v interface{}, args ...interface{}) error
  • func (connector *DBConnector) ExecuteQueryForKeyValueMap(sqlStatement string, args ...interface{}) ([]map[string]string, error)
  • func (connector *DBConnector) ExecuteQueryForRows(sqlStatement string, args ...interface{}) (*sql.Rows, error)
  • func (connector *DBConnector) ExecuteUpdate(sqlStatement string, args ...interface{}) (sql.Result, error)
  • func (connector *DBConnector) IsConnected() (bool, error)
  • func (connector *DBConnector) Open(driverName string, dataSourceName string) error
• type DbConnectInfo
  • func (connectInfo *DbConnectInfo) ToDataSourceName() (string, error)
• type SqlExecutor
  • func (sqlExecutor *SqlExecutor) ExecuteNonSelectSql(sqlStatement string, args ...interface{}) (sql.Result, error)
  • func (sqlExecutor *SqlExecutor) ExecuteSelectSql(sqlStatement string, v interface{}, args ...interface{}) error
  • func (sqlExecutor *SqlExecutor) ExecuteSelectSqlForMapResult(sqlStatement string, args ...interface{}) ([]map[string]string, error)
  • func (sqlExecutor *SqlExecutor) ExecuteSelectSqlForRows(sqlStatement string, args ...interface{}) (*sql.Rows, error)

Functions

func ReflectMapToStructure

func ReflectMapToStructure(m map[string]string, v reflect.Value, tagName string) error

将map值映射到结构体

func ReflectSelectSqlMapResultToStructure

func ReflectSelectSqlMapResultToStructure(data []map[string]string, v interface{}, tagName string) error

将查询语句得到的[]Map结果反射到结构体中

Types

type DBConnector

type DBConnector struct {
	DB *sql.DB
}

###################################################################################################################### 数据库连接器

func NewDbConnector

func NewDbConnector() *DBConnector

新建数据库连接器

func (*DBConnector) Close

func (connector *DBConnector) Close() error

关闭数据库连接

func (*DBConnector) ExecuteQuery

func (connector *DBConnector) ExecuteQuery(sqlStatement string, v interface{}, args ...interface{}) error

执行查询语句

func (*DBConnector) ExecuteQueryForKeyValueMap

func (connector *DBConnector) ExecuteQueryForKeyValueMap(sqlStatement string, args ...interface{}) ([]map[string]string, error)

执行查询语句并返回[]map[string]string

func (*DBConnector) ExecuteQueryForRows

func (connector *DBConnector) ExecuteQueryForRows(sqlStatement string, args ...interface{}) (*sql.Rows, error)

执行查询语句并返回Rows

func (*DBConnector) ExecuteUpdate

func (connector *DBConnector) ExecuteUpdate(sqlStatement string, args ...interface{}) (sql.Result, error)

执行更新语句，包括：插入、删除、修改

func (*DBConnector) IsConnected

func (connector *DBConnector) IsConnected() (bool, error)

判断数据库是否已连接

func (*DBConnector) Open

func (connector *DBConnector) Open(driverName string, dataSourceName string) error

打开数据库连接

type DbConnectInfo

type DbConnectInfo struct {
	DriverName  string //数据库驱动名称
	User        string //用户名
	Password    string //密码
	Ip          string //IP地址
	Port        int    //端口
	DBName      string //数据库名称
	Description string //描述
}

数据库连接信息

func (*DbConnectInfo) ToDataSourceName

func (connectInfo *DbConnectInfo) ToDataSourceName() (string, error)

根据结构体参数组装dataSourceName

type SqlExecutor

type SqlExecutor struct {
	DB *sql.DB
}

func (*SqlExecutor) ExecuteNonSelectSql

func (sqlExecutor *SqlExecutor) ExecuteNonSelectSql(sqlStatement string, args ...interface{}) (sql.Result, error)

执行非查询SQL语句(增、删、改)

func (*SqlExecutor) ExecuteSelectSql

func (sqlExecutor *SqlExecutor) ExecuteSelectSql(sqlStatement string, v interface{}, args ...interface{}) error

执行查询SQL语句

func (*SqlExecutor) ExecuteSelectSqlForMapResult

func (sqlExecutor *SqlExecutor) ExecuteSelectSqlForMapResult(sqlStatement string, args ...interface{}) ([]map[string]string, error)

执行查询语句并将结果转换为Map切片

func (*SqlExecutor) ExecuteSelectSqlForRows

func (sqlExecutor *SqlExecutor) ExecuteSelectSqlForRows(sqlStatement string, args ...interface{}) (*sql.Rows, error)

执行查询语句并返回查询结果