gdb

type Config map[string]ConfigGroup

type ConfigGroup []ConfigNode

type ConfigNode struct {
	Host             string // 地址
	Port             string // 端口
	User             string // 账号
	Pass             string // 密码
	Name             string // 数据库名称
	Type             string // 数据库类型：mysql, sqlite, mssql, pgsql, oracle(目前仅支持mysql)
	Role             string // (可选，默认为master)数据库的角色，用于主从操作分离，至少需要有一个master，参数值：master, slave
	Charset          string // (可选，默认为 utf8)编码，默认为 utf8
	Priority         int    // (可选)用于负载均衡的权重计算，当集群中只有一个节点时，权重没有任何意义
	Linkinfo         string // (可选)自定义链接信息，当该字段被设置值时，以上链接字段(Host,Port,User,Pass,Name)将失效(该字段是一个扩展功能)
	MaxIdleConnCount int    // (可选)连接池最大限制的连接数
	MaxOpenConnCount int    // (可选)连接池最大打开的连接数
	MaxConnLifetime  int    // (可选，单位秒)连接对象可重复使用的时间长度
}

type DB interface {
	// 建立数据库连接方法(开发者一般不需要直接调用)
	Open(config *ConfigNode) (*sql.DB, error)

	// SQL操作方法 API
	Query(query string, args ...interface{}) (*sql.Rows, error)
	Exec(sql string, args ...interface{}) (sql.Result, error)
	Prepare(sql string, execOnMaster ...bool) (*sql.Stmt, error)

	// 数据库查询
	GetAll(query string, args ...interface{}) (Result, error)
	GetOne(query string, args ...interface{}) (Record, error)
	GetValue(query string, args ...interface{}) (Value, error)
	GetCount(query string, args ...interface{}) (int, error)
	GetStruct(obj interface{}, query string, args ...interface{}) error

	// 创建底层数据库master/slave链接对象
	Master() (*sql.DB, error)
	Slave() (*sql.DB, error)

	// Ping
	PingMaster() error
	PingSlave() error

	// 开启事务操作
	Begin() (*TX, error)

	// 数据表插入/更新/保存操作
	Insert(table string, data Map) (sql.Result, error)
	Replace(table string, data Map) (sql.Result, error)
	Save(table string, data Map) (sql.Result, error)

	// 数据表插入/更新/保存操作(批量)
	BatchInsert(table string, list List, batch int) (sql.Result, error)
	BatchReplace(table string, list List, batch int) (sql.Result, error)
	BatchSave(table string, list List, batch int) (sql.Result, error)

	// 数据修改/删除
	Update(table string, data interface{}, condition interface{}, args ...interface{}) (sql.Result, error)
	Delete(table string, condition interface{}, args ...interface{}) (sql.Result, error)

	// 创建链式操作对象(Table为From的别名)
	Table(tables string) *Model
	From(tables string) *Model

	// 设置管理
	SetDebug(debug bool)
	SetSchema(schema string)
	GetQueriedSqls() []*Sql
	PrintQueriedSqls()
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
	SetConnMaxLifetime(n int)
	// contains filtered or unexported methods
}

type List = []Map

type Map = map[string]interface{}

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

type Record map[string]Value

type Result []Record

type Sql struct {
	Sql   string        // SQL语句(可能带有预处理占位符)
	Args  []interface{} // 预处理参数值列表
	Error error         // 执行结果(nil为成功)
	Start int64         // 执行开始时间(毫秒)
	End   int64         // 执行结束时间(毫秒)
	Func  string        // 执行方法
}

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

type Value = *gvar.Var