repository

Documentation

Index

• func CloseRows(rows *sql.Rows)
• func InsertSrc(db *sql.DB, q map[string]string)
• func MakeTables() []string
• func Query(ctx context.Context, db *sql.DB, query string, keys []interface{}) (*sql.Rows, object.Status)
• func QueryRow(ctx context.Context, db *sql.DB, query string, keys []interface{}) (*sql.Row, object.Status)
• func QueryRowTx(ctx context.Context, tx *sql.Tx, query string, keys []interface{}) (*sql.Row, object.Status)
• func QueryTx(ctx context.Context, tx *sql.Tx, query string, keys []interface{}) (*sql.Rows, object.Status)
• func Row(row *sql.Row, m model.Model) object.Status
• func Rows(rows *sql.Rows, m model.Models) object.Status
• func TxBegin(ctx context.Context, db *sql.DB) (*sql.Tx, object.Status)
• func TxCommit(tx *sql.Tx)
• func TxRollBack(tx *sql.Tx)
• type Configuration
• type LoremIpsum
  • func NewLoremIpsum() *LoremIpsum
  • func (li *LoremIpsum) Run(db *sql.DB, q *object.Query)
• type New
• type Repo
  • func NewRepo(ctx context.Context, new New) Repo
  • func NewRepoTx(ctx context.Context, new New) Repo

Functions

func CloseRows

func CloseRows(rows *sql.Rows)

func InsertSrc

func InsertSrc(db *sql.DB, q map[string]string)

func MakeTables

func MakeTables() []string

MakeTables returns a list of tables that need to create

func Query

func Query(ctx context.Context, db *sql.DB, query string, keys []interface{}) (*sql.Rows, object.Status)

func QueryRow

func QueryRow(ctx context.Context, db *sql.DB, query string, keys []interface{}) (*sql.Row, object.Status)

func QueryRowTx

func QueryRowTx(ctx context.Context, tx *sql.Tx, query string, keys []interface{}) (*sql.Row, object.Status)

func QueryTx

func QueryTx(ctx context.Context, tx *sql.Tx, query string, keys []interface{}) (*sql.Rows, object.Status)

func Row

func Row(row *sql.Row, m model.Model) object.Status

func Rows

func Rows(rows *sql.Rows, m model.Models) object.Status

func TxBegin

func TxBegin(ctx context.Context, db *sql.DB) (*sql.Tx, object.Status)

func TxCommit

func TxCommit(tx *sql.Tx)

func TxRollBack

func TxRollBack(tx *sql.Tx)

Types

type Configuration

type Configuration struct {
	Name, Path, PathB,
	Driver, Port, Connection string
}

Configuration for save parameters

type LoremIpsum

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

func NewLoremIpsum

func NewLoremIpsum() *LoremIpsum

func (*LoremIpsum) Run

func (li *LoremIpsum) Run(db *sql.DB, q *object.Query)

type New

type New interface {
	Connect() *Configuration
	DataBase(ctx context.Context) *sql.DB
	Query() *object.Query
}

type Repo

type Repo interface {
	Create(ctx context.Context, d dto.DTO) (int, object.Status)
	Delete(ctx context.Context, d dto.DTO) object.Status
	GetList(ctx context.Context, m model.Models) object.Status
	GetOne(ctx context.Context, m model.Model) object.Status
	ExportSettings() (*sql.DB, string, *object.Query)
}

func NewRepo

func NewRepo(ctx context.Context, new New) Repo

func NewRepoTx

func NewRepoTx(ctx context.Context, new New) Repo