db

Documentation

Index

• type DB
  • func NewDB(debug bool, dsn string) (*DB, error)
  • func NewDBWithMockForTest(debug bool, conn *sql.DB) (*DB, error)
  • func (db *DB) BlockLogger()
  • func (db *DB) Exec(sql string, args ...interface{}) error
  • func (db *DB) GetDriver() *gorm.DB
  • func (db *DB) QueryMore(sql string, args ...interface{}) (*sql.Rows, error)
  • func (db *DB) QueryOne(dest interface{}, sql string, args ...interface{}) error
  • func (db *DB) ScanRows(rows *sql.Rows, dest interface{}) error

Types

type DB

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

DB simple wrapper of Gorm

func NewDB

func NewDB(debug bool, dsn string) (*DB, error)

NewDB return a new DB instance

func NewDBWithMockForTest

func NewDBWithMockForTest(debug bool, conn *sql.DB) (*DB, error)

NewDBWithMockForTest return a new DB instance JUST FOR TESTS JUST FOR TESTS JUST FOR TESTS

func (*DB) BlockLogger

func (db *DB) BlockLogger()

func (*DB) Exec

func (db *DB) Exec(sql string, args ...interface{}) error

Exec 执行 insert、update、delete 等操作

func (*DB) GetDriver

func (db *DB) GetDriver() *gorm.DB

func (*DB) QueryMore

func (db *DB) QueryMore(sql string, args ...interface{}) (*sql.Rows, error)

QueryMore 查询多个结果，返回的结果需要配合 ScanRows 使用 example: rows, _ := db.QueryMore("SELECT * FROM table LIMIT 10")

for rows.Next(){
   _ =  db.ScanRows(rows, &dest)
}

func (*DB) QueryOne

func (db *DB) QueryOne(dest interface{}, sql string, args ...interface{}) error

QueryOne

func (*DB) ScanRows

func (db *DB) ScanRows(rows *sql.Rows, dest interface{}) error

ScanRows 扫描 rows 到 dest