sql

Documentation

Index

• func ToSnakeCase(str string) string
• type DB
  • func NewMYSQL(config *DBConfig, logger datasource.Logger) (*DB, error)
  • func (d *DB) Begin() (*Tx, error)
  • func (d *DB) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (d *DB) HealthCheck() datasource.Health
  • func (d *DB) Prepare(query string) (*sql.Stmt, error)
  • func (d *DB) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DB) QueryRow(query string, args ...interface{}) *sql.Row
  • func (d *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
  • func (d *DB) Select(ctx context.Context, data interface{}, query string, args ...interface{})
• type DBConfig
• type Log
• type Tx
  • func (t *Tx) Commit() error
  • func (t *Tx) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (t *Tx) Prepare(query string) (*sql.Stmt, error)
  • func (t *Tx) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (t *Tx) QueryRow(query string, args ...interface{}) *sql.Row
  • func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
  • func (t *Tx) Rollback() error

Functions

func ToSnakeCase

func ToSnakeCase(str string) string

Types

type DB

type DB struct {
	*sql.DB
	// contains filtered or unexported fields
}

DB is a wrapper around sql.DB which provides some more features.

func NewMYSQL

func NewMYSQL(config *DBConfig, logger datasource.Logger) (*DB, error)

func (*DB) Begin

func (d *DB) Begin() (*Tx, error)

func (*DB) Exec

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

func (*DB) HealthCheck

func (d *DB) HealthCheck() datasource.Health

func (*DB) Prepare

func (d *DB) Prepare(query string) (*sql.Stmt, error)

func (*DB) Query

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

func (*DB) QueryRow

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

func (*DB) QueryRowContext

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

func (*DB) Select

func (d *DB) Select(ctx context.Context, data interface{}, query string, args ...interface{})

Select runs a query with args and binds the result of the query to the data. data should ba a point to a slice, struct or any type. Slice will return multiple objects whereas struct will return a single object.

Example Usages:

1. Get multiple rows with only one column ids := make([]int, 0) db.Select(ctx, &ids, "select id from users")

2. Get a single object from database type user struct { Name string ID int Image string } u := user{} db.Select(ctx, &u, "select * from users where id=?", 1)

3. Get array of objects from multiple rows type user struct { Name string ID int Image string `db:"image_url"` } users := []user{} db.Select(ctx, &users, "select * from users")

type DBConfig

type DBConfig struct {
	HostName string
	User     string
	Password string
	Port     string
	Database string
}

DBConfig has those members which are necessary variables while connecting to database.

type Log

type Log struct {
	Type     string        `json:"type"`
	Query    string        `json:"query"`
	Duration int64         `json:"duration"`
	Args     []interface{} `json:"args,omitempty"`
}

type Tx

type Tx struct {
	*sql.Tx
	// contains filtered or unexported fields
}

func (*Tx) Commit

func (t *Tx) Commit() error

func (*Tx) Exec

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

func (*Tx) Prepare

func (t *Tx) Prepare(query string) (*sql.Stmt, error)

func (*Tx) Query

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

func (*Tx) QueryRow

func (t *Tx) QueryRow(query string, args ...interface{}) *sql.Row

func (*Tx) QueryRowContext

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

func (*Tx) Rollback

func (t *Tx) Rollback() error