sql

Documentation

Index

• func MakeColumns(s *schema.Schema, join bool) []string
• type DB
  • func NewDB() *DB
  • func (db *DB) Begin() (transaction.Transaction, error)
  • func (db *DB) Connect(sqlType, conn string) (err error)
  • func (db *DB) DropTable(s *schema.Schema) error
  • func (db *DB) GenTableDef(s *schema.Schema, cascade bool) string
  • func (db *DB) RegisterTable(s *schema.Schema, cascade bool) error
• type Transaction
  • func (tx *Transaction) Close() error
  • func (tx *Transaction) Closed() bool
  • func (tx *Transaction) Commit() error
  • func (tx *Transaction) Create(resource *schema.Resource) error
  • func (tx *Transaction) Delete(s *schema.Schema, resourceID interface{}) error
  • func (tx *Transaction) Exec(sql string, args ...interface{}) error
  • func (tx *Transaction) Fetch(s *schema.Schema, ID interface{}, tenantFilter []string) (*schema.Resource, error)
  • func (tx *Transaction) List(s *schema.Schema, filter map[string]interface{}, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)
  • func (tx *Transaction) Query(s *schema.Schema, query string, arguments []interface{}) (list []*schema.Resource, err error)
  • func (tx *Transaction) RawTransaction() *sqlx.Tx
  • func (tx *Transaction) StateFetch(s *schema.Schema, ID interface{}, tenantFilter []string) (state transaction.ResourceState, err error)
  • func (tx *Transaction) StateUpdate(resource *schema.Resource, state *transaction.ResourceState) error
  • func (tx *Transaction) Update(resource *schema.Resource) error

Functions

func MakeColumns

func MakeColumns(s *schema.Schema, join bool) []string

MakeColumns generates an array that has Gohan style colmun names

Types

type DB

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

DB is sql implementation of DB

func NewDB

func NewDB() *DB

NewDB constructor

func (*DB) Begin

func (db *DB) Begin() (transaction.Transaction, error)

Begin starts new transaction

func (*DB) Connect

func (db *DB) Connect(sqlType, conn string) (err error)

Connect connec to the db

func (*DB) DropTable

func (db *DB) DropTable(s *schema.Schema) error

DropTable drop table definition

func (*DB) GenTableDef

func (db *DB) GenTableDef(s *schema.Schema, cascade bool) string

GenTableDef generates table create sql

func (*DB) RegisterTable

func (db *DB) RegisterTable(s *schema.Schema, cascade bool) error

RegisterTable creates table in the db

type Transaction

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

Transaction is sql implementation of Transaction

func (*Transaction) Close

func (tx *Transaction) Close() error

Close closes connection

func (*Transaction) Closed

func (tx *Transaction) Closed() bool

Closed returns whether the transaction is closed

func (*Transaction) Commit

func (tx *Transaction) Commit() error

Commit commits transaction

func (*Transaction) Create

func (tx *Transaction) Create(resource *schema.Resource) error

Create create resource in the db

func (*Transaction) Delete

func (tx *Transaction) Delete(s *schema.Schema, resourceID interface{}) error

Delete delete resource from db

func (*Transaction) Exec

func (tx *Transaction) Exec(sql string, args ...interface{}) error

Exec executes sql in transaction

func (*Transaction) Fetch

func (tx *Transaction) Fetch(s *schema.Schema, ID interface{}, tenantFilter []string) (*schema.Resource, error)

Fetch resources by ID in the db

func (*Transaction) List

func (tx *Transaction) List(s *schema.Schema, filter map[string]interface{}, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)

List resources in the db

func (*Transaction) Query

func (tx *Transaction) Query(s *schema.Schema, query string, arguments []interface{}) (list []*schema.Resource, err error)

Query with raw sql string

func (*Transaction) RawTransaction

func (tx *Transaction) RawTransaction() *sqlx.Tx

RawTransaction returns raw transaction

func (*Transaction) StateFetch

func (tx *Transaction) StateFetch(s *schema.Schema, ID interface{}, tenantFilter []string) (state transaction.ResourceState, err error)

StateFetch fetches the state of the specified resource

func (*Transaction) StateUpdate

func (tx *Transaction) StateUpdate(resource *schema.Resource, state *transaction.ResourceState) error

StateUpdate update resource state

func (*Transaction) Update

func (tx *Transaction) Update(resource *schema.Resource) error

Update update resource in the db