database

Documentation

Index

• type Database
  • func NewDatabase(cfg *conf.Database) (*Database, error)
  • func NewDatabaseWithConnection(db *sql.DB) Database
  • func (db *Database) Close() error
  • func (db *Database) Exec(sql string, data ...interface{}) error
  • func (db *Database) GetDatabase() *sql.DB
  • func (db *Database) GetLastInsertId() uint64
  • func (db *Database) GetName() string
  • func (db *Database) GetOne(sql string, data ...interface{}) ([]byte, error)
  • func (db *Database) GetRecord(sqlString string, data ...interface{}) (map[string]interface{}, error)
  • func (db *Database) GetRecords(sqlString string, data ...interface{}) ([]map[string]interface{}, error)
  • func (db *Database) GetResult() (sql.Result, error)
  • func (db *Database) GetStmt(sql string) (*sql.Stmt, error)
  • func (db *Database) Insert(tableName string, data map[string]interface{}) error
  • func (db *Database) IsConnected() bool
  • func (db *Database) IsMySQL() bool
  • func (db *Database) IsPostgres() bool
  • func (db *Database) IsSQLite() bool
  • func (db *Database) Update(tableName string, data map[string]interface{}) error
• type IDatabase
• type Pool
  • func NewPool() *Pool
  • func (p *Pool) AddConnection(name string, conn *Database) error
  • func (p *Pool) GetConnection(name string) *Database
  • func (p *Pool) IsConnected(name string) bool
  • func (p *Pool) RemoveConnection(name string) error

Types

type Database

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

func NewDatabase

func NewDatabase(cfg *conf.Database) (*Database, error)

func NewDatabaseWithConnection

func NewDatabaseWithConnection(db *sql.DB) Database

func (*Database) Close

func (db *Database) Close() error

func (*Database) Exec

func (db *Database) Exec(sql string, data ...interface{}) error

func (*Database) GetDatabase

func (db *Database) GetDatabase() *sql.DB

func (*Database) GetLastInsertId

func (db *Database) GetLastInsertId() uint64

func (*Database) GetName

func (db *Database) GetName() string

func (*Database) GetOne

func (db *Database) GetOne(sql string, data ...interface{}) ([]byte, error)

func (*Database) GetRecord

func (db *Database) GetRecord(sqlString string, data ...interface{}) (map[string]interface{}, error)

func (*Database) GetRecords

func (db *Database) GetRecords(sqlString string, data ...interface{}) ([]map[string]interface{}, error)

func (*Database) GetResult

func (db *Database) GetResult() (sql.Result, error)

func (*Database) GetStmt

func (db *Database) GetStmt(sql string) (*sql.Stmt, error)

func (*Database) Insert

func (db *Database) Insert(tableName string, data map[string]interface{}) error

func (*Database) IsConnected

func (db *Database) IsConnected() bool

func (*Database) IsMySQL

func (db *Database) IsMySQL() bool

func (*Database) IsPostgres

func (db *Database) IsPostgres() bool

func (*Database) IsSQLite

func (db *Database) IsSQLite() bool

func (*Database) Update

func (db *Database) Update(tableName string, data map[string]interface{}) error

type IDatabase

type IDatabase interface {
	Exec(sql string, data ...interface{}) error
	GetOne(sql string, data ...interface{}) ([]byte, error)
	GetRecord(sql string, data ...interface{}) (map[string]interface{}, error)
	GetRecords(sql string, data ...interface{}) ([]map[string]interface{}, error)
	Insert(tableName string, data map[string]interface{}) error
	Update(tableName string, data map[string]interface{}) error
	IsConnected() bool
	IsSQLite() bool
	IsMySQL() bool
	IsPostgres() bool
	GetLastInsertId() uint64
	GetResult() (sql.Result, error)
	GetDatabase() *sql.DB
	GetName() string
	// contains filtered or unexported methods
}

type Pool

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

func NewPool

func NewPool() *Pool

func (*Pool) AddConnection

func (p *Pool) AddConnection(name string, conn *Database) error

func (*Pool) GetConnection

func (p *Pool) GetConnection(name string) *Database

func (*Pool) IsConnected

func (p *Pool) IsConnected(name string) bool

func (*Pool) RemoveConnection

func (p *Pool) RemoveConnection(name string) error