xdatabase

package
v1.0.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 31, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DB 

func DB(dbName ...string) xqi.Database

获取数据库

func DefaultLogger 

func DefaultLogger() func(e DbConn)

func NewDbLoggerPlugin 

func NewDbLoggerPlugin(o *LogOption, log xlogger.ILogger) func(e DbConn)

日志插件

Types

type LogLevel 

type LogLevel uint
const (
	LOG_SQL LogLevel = iota
	LOG_SLOW
	LOG_ERROR
)

func (LogLevel) String 

func (l LogLevel) String() string

type LogOption 

type LogOption struct {
	EnableSqlLog bool
	// 是否记录慢查询, 默认0s, 不记录, 设置记录的时间阀值, 比如 1, 则表示超过1s的都记录
	EnableSlowLog  float64
	EnableErrorLog bool
}

func NewDbLogOptions 

func NewDbLogOptions() *LogOption

type TBaseDb 

type TBaseDb struct {
	// contains filtered or unexported fields
}

func (*TBaseDb) BeginTran 

func (db *TBaseDb) BeginTran() exception.IException

func (*TBaseDb) Close 

func (db *TBaseDb) Close()

func (*TBaseDb) Commit 

func (db *TBaseDb) Commit() exception.IException

func (*TBaseDb) Connection 

func (db *TBaseDb) Connection(conf ...interface{}) exception.IException

func (*TBaseDb) Execute 

func (db *TBaseDb) Execute(szSql string, args ...interface{}) (int64, exception.IException)

func (*TBaseDb) GetConn 

func (db *TBaseDb) GetConn() DbConn

func (*TBaseDb) GetErr 

func (db *TBaseDb) GetErr() exception.IException

func (*TBaseDb) LastInsertId 

func (db *TBaseDb) LastInsertId() int64

func (*TBaseDb) LastSql 

func (db *TBaseDb) LastSql() string

func (*TBaseDb) LastSqlDuration 

func (db *TBaseDb) LastSqlDuration() time.Duration

func (*TBaseDb) Query 

func (db *TBaseDb) Query(binder TBinderName, szSql string, args ...interface{}) (result interface{}, err exception.IException)

func (*TBaseDb) QueryBind 

func (db *TBaseDb) QueryBind(binder DbQueryBinder, szSql string, args ...interface{}) (result interface{}, err exception.IException)

func (*TBaseDb) Rollback 

func (db *TBaseDb) Rollback() exception.IException

func (*TBaseDb) This 

func (db *TBaseDb) This() interface{}

func (*TBaseDb) Transaction 

func (db *TBaseDb) Transaction(closers ...func(session BasicDB) error) exception.IException

func (*TBaseDb) Use 

func (db *TBaseDb) Use(closers ...func(e xqi.DbConn))

type TDatabase 

type TDatabase struct {
	*TBaseDb
}

func (*TDatabase) Conn 

func (db *TDatabase) Conn() xqi.DbConn

func (*TDatabase) Create 

func (db *TDatabase) Create() exception.IException

创建数据库表方法

func (*TDatabase) Driver 

func (db *TDatabase) Driver() string

数据库驱动名称

func (*TDatabase) Logger 

func (db *TDatabase) Logger() xqi.DbLogger

func (*TDatabase) Prefix 

func (db *TDatabase) Prefix() string

表前掇

func (*TDatabase) Upgrade 

func (db *TDatabase) Upgrade() exception.IException

升级数据库表方法

type TDbBaseConfig 

type TDbBaseConfig struct {
	// contains filtered or unexported fields
}

func NewBaseConfig 

func NewBaseConfig(driver, dsn string, maxOpenCons, maxIdleCons int, prefix string, inherited ...interface{}) *TDbBaseConfig

func (*TDbBaseConfig) Driver 

func (cfg *TDbBaseConfig) Driver() string

func (*TDbBaseConfig) Dsn 

func (cfg *TDbBaseConfig) Dsn() string

func (*TDbBaseConfig) LoadFromMap 

func (cfg *TDbBaseConfig) LoadFromMap(c map[string]interface{})

func (*TDbBaseConfig) MaxIdleCons 

func (cfg *TDbBaseConfig) MaxIdleCons() int

func (*TDbBaseConfig) MaxOpenCons 

func (cfg *TDbBaseConfig) MaxOpenCons() int

func (*TDbBaseConfig) Prefix 

func (cfg *TDbBaseConfig) Prefix() string

func (*TDbBaseConfig) SetDSN added in v1.0.1 

func (cfg *TDbBaseConfig) SetDSN(dsn string)

func (*TDbBaseConfig) SetDriver added in v1.0.1 

func (cfg *TDbBaseConfig) SetDriver(driver string)

func (*TDbBaseConfig) SetMaxIdleCons added in v1.0.1 

func (cfg *TDbBaseConfig) SetMaxIdleCons(v int)

func (*TDbBaseConfig) SetMaxOpenCons added in v1.0.1 

func (cfg *TDbBaseConfig) SetMaxOpenCons(v int)

func (*TDbBaseConfig) SetPrefix added in v1.0.1 

func (cfg *TDbBaseConfig) SetPrefix(prefix string)

func (*TDbBaseConfig) String 

func (cfg *TDbBaseConfig) String() string

func (*TDbBaseConfig) This 

func (cfg *TDbBaseConfig) This() interface{}

type TDbConfigCluster 

type TDbConfigCluster struct {
	// contains filtered or unexported fields
}

func NewDbConfigCluster 

func NewDbConfigCluster() *TDbConfigCluster

func (*TDbConfigCluster) AddMaster 

func (dcc *TDbConfigCluster) AddMaster(config DbConfig) DbConfigCluster

func (*TDbConfigCluster) AddSlave 

func (dcc *TDbConfigCluster) AddSlave(config DbConfig) DbConfigCluster

func (*TDbConfigCluster) Driver 

func (dcc *TDbConfigCluster) Driver() string

func (*TDbConfigCluster) Master 

func (dcc *TDbConfigCluster) Master() []DbConfig

func (*TDbConfigCluster) Prefix 

func (dcc *TDbConfigCluster) Prefix() string

func (*TDbConfigCluster) SetDriver added in v1.0.1 

func (dcc *TDbConfigCluster) SetDriver(driver string)

func (*TDbConfigCluster) SetPrefix added in v1.0.1 

func (dcc *TDbConfigCluster) SetPrefix(prefix string)

func (*TDbConfigCluster) Slave 

func (dcc *TDbConfigCluster) Slave() []DbConfig

func (*TDbConfigCluster) String 

func (dcc *TDbConfigCluster) String() string

func (*TDbConfigCluster) This 

func (dcc *TDbConfigCluster) This() interface{}

type TDbConn 

type TDbConn struct {
	// contains filtered or unexported fields
}

func NewDbConn 

func NewDbConn(conf ...interface{}) (conn *TDbConn, err exception.IException)

NewDbConn : 初始化 TDbConn 结构体对象指针

func (*TDbConn) GetDriver 

func (c *TDbConn) GetDriver() string

func (*TDbConn) GetExecuteDB 

func (c *TDbConn) GetExecuteDB() *sql.DB

GetExecuteDB : 获取一个主库用来做查询之外的操作

func (*TDbConn) GetLogger 

func (c *TDbConn) GetLogger() DbLogger

func (*TDbConn) GetPrefix 

func (c *TDbConn) GetPrefix() string

GetPrefix 获取前缀

func (*TDbConn) GetQueryDB 

func (c *TDbConn) GetQueryDB() *sql.DB

GetQueryDB : get a slave db for using query operation GetQueryDB : 获取一个从库用来做查询操作

func (*TDbConn) Ping 

func (c *TDbConn) Ping() exception.IException

Ping

func (*TDbConn) SetLogger 

func (c *TDbConn) SetLogger(logger DbLogger)

func (*TDbConn) SetPrefix 

func (c *TDbConn) SetPrefix(pre string)

SetPrefix 设置表前缀

func (*TDbConn) This 

func (c *TDbConn) This() interface{}

func (*TDbConn) Use 

func (c *TDbConn) Use(closers ...func(e DbConn))

使用插件

type TDbLogger 

type TDbLogger struct {
	// contains filtered or unexported fields
}

func NewDbLogger 

func NewDbLogger(o *LogOption, log xlogger.ILogger) *TDbLogger

func (*TDbLogger) EnableErrorLog 

func (l *TDbLogger) EnableErrorLog() bool

func (*TDbLogger) EnableSlowLog 

func (l *TDbLogger) EnableSlowLog() float64

func (*TDbLogger) EnableSqlLog 

func (l *TDbLogger) EnableSqlLog() bool

func (*TDbLogger) Error 

func (l *TDbLogger) Error(msg string)

func (*TDbLogger) GetLogger 

func (l *TDbLogger) GetLogger() xlogger.ILogger

func (*TDbLogger) SetLogger 

func (l *TDbLogger) SetLogger(logger xlogger.ILogger)

func (*TDbLogger) Slow 

func (l *TDbLogger) Slow(sqlStr string, runtime time.Duration)

func (*TDbLogger) Sql 

func (l *TDbLogger) Sql(sqlStr string, runtime time.Duration)

func (*TDbLogger) This 

func (l *TDbLogger) This() interface{}

type TDbMysqlConfig 

type TDbMysqlConfig struct {
	*TDbBaseConfig
	// contains filtered or unexported fields
}

func NewMysqlConfig 

func NewMysqlConfig() *TDbMysqlConfig

func NewMysqlConfig6 

func NewMysqlConfig6(host string, port int, user string, password string, db string, protocol ...string) *TDbMysqlConfig

创建数据库配置

func NewMysqlConfigFromMap 

func NewMysqlConfigFromMap(c map[string]interface{}) *TDbMysqlConfig

从配置文件创建数据库配置

func (*TDbMysqlConfig) AddParam 

func (cfg *TDbMysqlConfig) AddParam(name string, value string) DbMysqlConfig

func (*TDbMysqlConfig) Charset 

func (cfg *TDbMysqlConfig) Charset() string

字符编码，默认utf-8

func (*TDbMysqlConfig) DbConfig 

func (cfg *TDbMysqlConfig) DbConfig() DbConfig

func (*TDbMysqlConfig) DbName 

func (cfg *TDbMysqlConfig) DbName() string

数据库名称

func (*TDbMysqlConfig) Dsn 

func (cfg *TDbMysqlConfig) Dsn() string

mysql 示例: root:root@tcp(localhost:3306)/test?charset=utf8&parseTime=true

func (*TDbMysqlConfig) Host 

func (cfg *TDbMysqlConfig) Host() string

数据库服务器地址

func (*TDbMysqlConfig) LoadFromMap 

func (cfg *TDbMysqlConfig) LoadFromMap(c map[string]interface{})

func (*TDbMysqlConfig) Params 

func (cfg *TDbMysqlConfig) Params() map[string]string

其他连接参数

func (*TDbMysqlConfig) ParseTime 

func (cfg *TDbMysqlConfig) ParseTime() bool

是否解析日期, 默认true

func (*TDbMysqlConfig) Password 

func (cfg *TDbMysqlConfig) Password() string

密码

func (*TDbMysqlConfig) Port 

func (cfg *TDbMysqlConfig) Port() int

数据库服务器端口号

func (*TDbMysqlConfig) Protocol 

func (cfg *TDbMysqlConfig) Protocol() string

func (*TDbMysqlConfig) SetCharset 

func (cfg *TDbMysqlConfig) SetCharset(charset string) DbMysqlConfig

func (*TDbMysqlConfig) SetDatabase 

func (cfg *TDbMysqlConfig) SetDatabase(db string) DbMysqlConfig

func (*TDbMysqlConfig) SetDbName added in v1.0.1 

func (cfg *TDbMysqlConfig) SetDbName(dbName string)

func (*TDbMysqlConfig) SetHost added in v1.0.1 

func (cfg *TDbMysqlConfig) SetHost(host string)

func (*TDbMysqlConfig) SetOption 

func (cfg *TDbMysqlConfig) SetOption(host string, port int, user string, password string, db string, protocol ...string) DbMysqlConfig

func (*TDbMysqlConfig) SetParseTime 

func (cfg *TDbMysqlConfig) SetParseTime(b bool) DbMysqlConfig

func (*TDbMysqlConfig) SetPassword added in v1.0.1 

func (cfg *TDbMysqlConfig) SetPassword(pwd string)

func (*TDbMysqlConfig) SetPort added in v1.0.1 

func (cfg *TDbMysqlConfig) SetPort(port int)

func (*TDbMysqlConfig) SetProtocol added in v1.0.1 

func (cfg *TDbMysqlConfig) SetProtocol(protocol string)

func (*TDbMysqlConfig) SetUser added in v1.0.1 

func (cfg *TDbMysqlConfig) SetUser(user string)

func (*TDbMysqlConfig) User 

func (cfg *TDbMysqlConfig) User() string

账户名

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.