db

Documentation

Index

• Constants
• func InitDbGormConnection(connStr string, poolSize int, dns utils.DNSClient) (*gorm.DB, error)
• type Config
• type DB
  • func NewDB() *DB
  • func NewDBMock(impl *sql.DB) *DB
  • func (d *DB) Close()
  • func (d *DB) Exec(sql string, value ...interface{}) error
  • func (d *DB) ExecWithTX(iLevel sql.IsolationLevel, sqlStr string, args ...interface{}) error
  • func (d *DB) Mock(db *sql.DB)
  • func (d *DB) Open(config *Config) error
  • func (d *DB) OpenWithDSN(dsn string) error
  • func (d *DB) Query(mapper func(row Row) (interface{}, error), sql string, args ...interface{}) ([]interface{}, error)
  • func (d *DB) QueryMap(conv func(i interface{}) interface{}, sql string, args ...interface{}) ([]map[string]interface{}, error)
  • func (d *DB) QueryRow(mapper func(row Row) (interface{}, error), sql string, args ...interface{}) (interface{}, error)
  • func (d *DB) SetImpl(db *sql.DB)
• type Row

Constants

const ExternalProto = "ext"

ExternalProto ...

Functions

func InitDbGormConnection

func InitDbGormConnection(connStr string, poolSize int, dns utils.DNSClient) (*gorm.DB, error)

InitDbGormConnection ...

Types

type Config

type Config struct {
	User    string
	Passwd  string
	Net     string
	Addr    string
	DBName  string
	Timeout time.Duration
	Params  map[string]string
}

Config ...

type DB

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

DB ...

func NewDB

func NewDB() *DB

NewDB ...

func NewDBMock

func NewDBMock(impl *sql.DB) *DB

NewDBMock ...

func (*DB) Close

func (d *DB) Close()

Close ...

func (*DB) Exec

func (d *DB) Exec(sql string, value ...interface{}) error

Exec ...

func (*DB) ExecWithTX

func (d *DB) ExecWithTX(iLevel sql.IsolationLevel, sqlStr string, args ...interface{}) error

ExecWithTX exec sql in transaction

func (*DB) Mock

func (d *DB) Mock(db *sql.DB)

Mock ...

func (*DB) Open

func (d *DB) Open(config *Config) error

Open ...

func (*DB) OpenWithDSN

func (d *DB) OpenWithDSN(dsn string) error

OpenWithDSN open db connection with dsn string

func (*DB) Query

func (d *DB) Query(mapper func(row Row) (interface{}, error), sql string, args ...interface{}) ([]interface{}, error)

Query ...

func (*DB) QueryMap

func (d *DB) QueryMap(conv func(i interface{}) interface{}, sql string, args ...interface{}) ([]map[string]interface{}, error)

QueryMap ...

func (*DB) QueryRow

func (d *DB) QueryRow(mapper func(row Row) (interface{}, error), sql string, args ...interface{}) (interface{}, error)

QueryRow ...

func (*DB) SetImpl

func (d *DB) SetImpl(db *sql.DB)

SetImpl if necessary, such as tddlx

type Row

type Row interface {
	Scan(args ...interface{}) error
}

Row ...