sql

Documentation

Index

• Variables
• func NewRepository(db DB, mapper Mapper) repository
• type DB
  • func NewDB(sqlDB *sql.DB) (DB, error)
• type Mapper
• type MapperBuilder
  • func NewMapperBuilder() *MapperBuilder
  • func (builder *MapperBuilder) NewMapper() Mapper
  • func (builder *MapperBuilder) Set(entityName string, structBuilder *sqlbuilder.Struct) *MapperBuilder
• type Result
• type Row
• type Rows

Variables

var (
	ErrBlankDB = errors.New("err_blankdb")
)

Functions

func NewRepository

func NewRepository(db DB, mapper Mapper) repository

Types

type DB

type DB interface {
	Query(string, ...interface{}) (Rows, error)
	QueryRow(string, ...interface{}) Row
	Exec(string, ...interface{}) (Result, error)
	Ping() error
	Close() error
}

func NewDB

func NewDB(sqlDB *sql.DB) (DB, error)

type Mapper

type Mapper interface {
	Get(string) *sqlbuilder.Struct
}

type MapperBuilder

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

func NewMapperBuilder

func NewMapperBuilder() *MapperBuilder

func (*MapperBuilder) NewMapper

func (builder *MapperBuilder) NewMapper() Mapper

func (*MapperBuilder) Set

func (builder *MapperBuilder) Set(entityName string, structBuilder *sqlbuilder.Struct) *MapperBuilder

type Result

type Result interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}

type Row

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

type Rows

type Rows interface {
	Row
	Next() bool
	Err() error
}