xdb

Documentation

Index

• Constants
• Variables
• func Deregister(name string)
• func NewBuilder() container.StandardBuilder
• func NewError(err error, sql string, args []interface{}) error
• func Register(resolver Resover)
• func RegistryLogger(logger Logger)
• type DbError
• type Executer
• type IDB
• type ITrans
• type Logger
  • func GetLogger(loggerName string) (Logger, bool)
• type Resover
• type Result
• type Row
  • func NewRow() Row
• type Rows
  • func NewRows() Rows
• type StandardDB
  • func NewStandardDB(container container.Container) StandardDB

Constants

const DbTypeNode = "dbs"

Variables

var (
	DateFormat = "2006-01-02 15:04:05"
)

Functions

func Deregister

func Deregister(name string)

Deregister 清理配置适配器

func NewBuilder

func NewBuilder() container.StandardBuilder

func NewError

func NewError(err error, sql string, args []interface{}) error

func Register

func Register(resolver Resover)

Register 注册配置文件适配器

func RegistryLogger

func RegistryLogger(logger Logger)

Types

type DbError

type DbError interface {
	Error() string
	Inner() error
	SQL() string
	Args() []interface{}
}

type Executer

type Executer interface {
	Query(ctx context.Context, sql string, input map[string]interface{}) (data Rows, err error)
	Multi(ctx context.Context, sql string, input map[string]interface{}) (data []Rows, err error)
	First(ctx context.Context, sql string, input map[string]interface{}) (data Row, err error)
	Scalar(ctx context.Context, sql string, input map[string]interface{}) (data interface{}, err error)
	Exec(ctx context.Context, sql string, input map[string]interface{}) (r Result, err error)
}

Executer 数据库操作对象集合

type IDB

type IDB interface {
	Executer
	Begin() (ITrans, error)
	Close() error
	GetImpl() interface{}
}

IDB 数据库操作接口

type ITrans

type ITrans interface {
	Executer
	Rollback() error
	Commit() error
}

ITrans 数据库事务接口

type Logger

type Logger interface {
	Name() string
	Log(args ...interface{})
}

func GetLogger

func GetLogger(loggerName string) (Logger, bool)

type Resover

type Resover interface {
	Name() string
	Resolve(setting config.Config) (interface{}, error)
}

dbResover 定义配置文件转换方法

type Result

type Result = sql.Result

type Row

type Row = xtypes.XMap

Row 单行数据

func NewRow

func NewRow() Row

NewRow 构建Row对象

type Rows

type Rows = xtypes.XMaps

Rows 多行数据

func NewRows

func NewRows() Rows

NewRows 构建Rows

type StandardDB

type StandardDB interface {
	GetDB(name ...string) (q IDB)
	GetImpl(name ...string) interface{}
}

StandardDB

func NewStandardDB

func NewStandardDB(container container.Container) StandardDB

NewStandardDBs 创建DB