Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

record

package

Go to main page

Versions in this module

v0

v0.1.2

Oct 11, 2020

v0.1.1

Jul 18, 2020

v0.1.0

Jun 30, 2020

Changes in this version

+ var ErrModelEmptyQueryBuilder = errors.New("model's query builder is empty")

+ var ErrModelMissingMasterDB = errors.New("model is missing master database")

+ var ErrModelMissingReplicaDB = errors.New("model is missing replica database")

+ type Config struct

+ Adapter string

+ ConnMaxLifetime time.Duration

+ Database string

+ Host string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Port string

+ Replica bool

+ SchemaMigrationsTable string

+ SchemaSearchPath string

+ URI string

+ Username string

+ type DB struct

+ func (db *DB) Begin() (Txer, error)

+ func (db *DB) BeginContext(ctx context.Context, opts *sql.TxOptions) (Txer, error)

+ func (db *DB) Config() *Config

+ func (db *DB) Connect() error

+ func (db *DB) ConnectDefaultDB() error

+ func (db *DB) CreateDB(database string) error

+ func (db *DB) DropDB(database string) error

+ func (db *DB) DumpSchema(dbname string) error

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

+ func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) GenerateMigration(name, target string, tx bool) error

+ func (db *DB) Get(dest interface{}, query string, args ...interface{}) error

+ func (db *DB) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) Migrate() error

+ func (db *DB) MigrateStatus() ([][]string, error)

+ func (db *DB) NamedExec(query string, arg interface{}) (sql.Result, error)

+ func (db *DB) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ func (db *DB) NamedQuery(query string, arg interface{}) (*Rows, error)

+ func (db *DB) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*Rows, error)

+ func (db *DB) Prepare(query string) (*Stmt, error)

+ func (db *DB) PrepareContext(ctx context.Context, query string) (*Stmt, error)

+ func (db *DB) PrepareNamed(query string) (*NamedStmt, error)

+ func (db *DB) PrepareNamedContext(ctx context.Context, query string) (*NamedStmt, error)

+ func (db *DB) Query(query string, args ...interface{}) (*Rows, error)

+ func (db *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func (db *DB) QueryRow(query string, args ...interface{}) *Row

+ func (db *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) *Row

+ func (db *DB) RegisterMigration(up func(DBer) error, down func(DBer) error, args ...string) error

+ func (db *DB) RegisterMigrationTx(upTx func(Txer) error, downTx func(Txer) error, args ...string) error

+ func (db *DB) RegisterSeedTx(seed func(Txer) error)

+ func (db *DB) Rollback() error

+ func (db *DB) Schema() string

+ func (db *DB) Seed() error

+ func (db *DB) Select(dest interface{}, query string, args ...interface{}) error

+ func (db *DB) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) SetSchema(schema string)

+ type DBer interface

+ Begin func() (Txer, error)

+ BeginContext func(ctx context.Context, opts *sql.TxOptions) (Txer, error)

+ Close func() error

+ Config func() *Config

+ Conn func(ctx context.Context) (*sql.Conn, error)

+ Connect func() error

+ ConnectDefaultDB func() error

+ CreateDB func(database string) error

+ Driver func() driver.Driver

+ DriverName func() string

+ DropDB func(database string) error

+ DumpSchema func(database string) error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ GenerateMigration func(name, target string, tx bool) error

+ Get func(dest interface{}, query string, args ...interface{}) error

+ GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ Migrate func() error

+ MigrateStatus func() ([][]string, error)

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ NamedQuery func(query string, arg interface{}) (*Rows, error)

+ NamedQueryContext func(ctx context.Context, query string, arg interface{}) (*Rows, error)

+ Ping func() error

+ PingContext func(ctx context.Context) error

+ Prepare func(query string) (*Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*Stmt, error)

+ PrepareNamed func(query string) (*NamedStmt, error)

+ PrepareNamedContext func(ctx context.Context, query string) (*NamedStmt, error)

+ Query func(query string, args ...interface{}) (*Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ QueryRow func(query string, args ...interface{}) *Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *Row

+ Rebind func(query string) string

+ RegisterMigration func(up func(DBer) error, down func(DBer) error, args ...string) error

+ RegisterMigrationTx func(upTx func(Txer) error, downTx func(Txer) error, args ...string) error

+ RegisterSeedTx func(seed func(Txer) error)

+ Rollback func() error

+ Schema func() string

+ Seed func() error

+ Select func(dest interface{}, query string, args ...interface{}) error

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ SetConnMaxLifetime func(d time.Duration)

+ SetMaxIdleConns func(n int)

+ SetMaxOpenConns func(n int)

+ SetSchema func(schema string)

+ Stats func() sql.DBStats

+ func NewDB(config *Config, logger *support.Logger) DBer

+ type Engine struct

+ func NewEngine(logger *support.Logger, i18n *support.I18n) *Engine

+ func (m *Engine) DB(name string) DBer

+ func (m *Engine) Databases() map[string]DBer

+ func (m *Engine) Errors() []error

+ func (m *Engine) Info() string

+ type ExecOption struct

+ Context context.Context

+ Locale string

+ SkipCallbacks bool

+ SkipValidate bool

+ UseReplica bool

+ type Migration struct

+ Down func(DBer) error

+ DownTx func(Txer) error

+ File string

+ Up func(DBer) error

+ UpTx func(Txer) error

+ Version string

+ type Model struct

+ func (m *Model) All() Modeler

+ func (m *Model) AttrByDBColumn(dbColumn string) *ModelAttr

+ func (m *Model) Begin() error

+ func (m *Model) BeginContext(ctx context.Context, opts *sql.TxOptions) error

+ func (m *Model) Commit() []error

+ func (m *Model) Count() Modeler

+ func (m *Model) Create() Modeler

+ func (m *Model) Delete() Modeler

+ func (m *Model) DeleteAll() Modeler

+ func (m *Model) Exec(opts ...ExecOption) (int64, []error)

+ func (m *Model) Find() Modeler

+ func (m *Model) Group(group string) Modeler

+ func (m *Model) Having(having string, args ...interface{}) Modeler

+ func (m *Model) Join(join string, args ...interface{}) Modeler

+ func (m *Model) Limit(limit int) Modeler

+ func (m *Model) Offset(offset int) Modeler

+ func (m *Model) Order(order string) Modeler

+ func (m *Model) PrimaryKeys() []string

+ func (m *Model) Rollback() []error

+ func (m *Model) SQL() string

+ func (m *Model) Scan(dest interface{}) Modeler

+ func (m *Model) Select(columns string) Modeler

+ func (m *Model) Tx() Txer

+ func (m *Model) Update() Modeler

+ func (m *Model) UpdateAll(set string, args ...interface{}) Modeler

+ func (m *Model) Where(condition string, args ...interface{}) Modeler

+ type ModelAttr struct

+ type ModelOption struct

+ Tx Txer

+ type Modeler interface

+ All func() Modeler

+ AttrByDBColumn func(dbColumn string) *ModelAttr

+ Begin func() error

+ BeginContext func(ctx context.Context, opts *sql.TxOptions) error

+ Commit func() []error

+ Count func() Modeler

+ Create func() Modeler

+ Delete func() Modeler

+ DeleteAll func() Modeler

+ Exec func(opts ...ExecOption) (int64, []error)

+ Find func() Modeler

+ Group func(group string) Modeler

+ Having func(having string, args ...interface{}) Modeler

+ Join func(join string, args ...interface{}) Modeler

+ Limit func(limit int) Modeler

+ Offset func(offset int) Modeler

+ Order func(order string) Modeler

+ PrimaryKeys func() []string

+ Rollback func() []error

+ SQL func() string

+ Scan func(dest interface{}) Modeler

+ Select func(columns string) Modeler

+ Tx func() Txer

+ Update func() Modeler

+ UpdateAll func(set string, args ...interface{}) Modeler

+ Where func(condition string, args ...interface{}) Modeler

+ func NewModel(dbManager *Engine, dest interface{}, opts ...ModelOption) Modeler

+ type NamedStmt struct

+ type Row struct

+ type Rows struct

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args ...interface{}) (sql.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func (s *Stmt) Query(args ...interface{}) (*Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args ...interface{}) (*Rows, error)

+ func (s *Stmt) QueryRow(args ...interface{}) *Row

+ func (s *Stmt) QueryRowContext(ctx context.Context, args ...interface{}) *Row

+ type Stmter interface

+ Exec func(args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, args ...interface{}) (sql.Result, error)

+ Query func(args ...interface{}) (*Rows, error)

+ QueryContext func(ctx context.Context, args ...interface{}) (*Rows, error)

+ QueryRow func(args ...interface{}) *Row

+ QueryRowContext func(ctx context.Context, args ...interface{}) *Row

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (tx *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (tx *Tx) Get(dest interface{}, query string, args ...interface{}) error

+ func (tx *Tx) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (tx *Tx) NamedExec(query string, arg interface{}) (sql.Result, error)

+ func (tx *Tx) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ func (tx *Tx) NamedQuery(query string, arg interface{}) (*Rows, error)

+ func (tx *Tx) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*Rows, error)

+ func (tx *Tx) Prepare(query string) (*Stmt, error)

+ func (tx *Tx) PrepareContext(ctx context.Context, query string) (*Stmt, error)

+ func (tx *Tx) PrepareNamed(query string) (*NamedStmt, error)

+ func (tx *Tx) PrepareNamedContext(ctx context.Context, query string) (*NamedStmt, error)

+ func (tx *Tx) Query(query string, args ...interface{}) (*Rows, error)

+ func (tx *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func (tx *Tx) QueryRow(query string, args ...interface{}) *Row

+ func (tx *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *Row

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) Select(dest interface{}, query string, args ...interface{}) error

+ func (tx *Tx) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (tx *Tx) Stmt(stmt *Stmt) *Stmt

+ func (tx *Tx) StmtContext(ctx context.Context, stmt *Stmt) *Stmt

+ type Txer interface

+ Commit func() error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Get func(dest interface{}, query string, args ...interface{}) error

+ GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ NamedQuery func(query string, arg interface{}) (*Rows, error)

+ NamedQueryContext func(ctx context.Context, query string, arg interface{}) (*Rows, error)

+ Prepare func(query string) (*Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*Stmt, error)

+ PrepareNamed func(query string) (*NamedStmt, error)

+ PrepareNamedContext func(ctx context.Context, query string) (*NamedStmt, error)

+ Query func(query string, args ...interface{}) (*Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ QueryRow func(query string, args ...interface{}) *Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *Row

+ Rollback func() error

+ Select func(dest interface{}, query string, args ...interface{}) error

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ Stmt func(stmt *Stmt) *Stmt

+ StmtContext func(ctx context.Context, stmt *Stmt) *Stmt