Help us shape the future of Go! Take the 2026 Go Developer Survey

sql

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 17, 2018 License: Apache-2.0 Imports: 24 Imported by: 25

Documentation

Index

Constants

View Source 
const (
	OrCondition  = "__or__"
	AndCondition = "__and__"
)

Variables

This section is empty.

Functions

func AddFilterToQuery 

func AddFilterToQuery(s *schema.Schema, q sq.SelectBuilder, filter map[string]interface{}, join bool) (sq.SelectBuilder, error)

func MakeColumns 

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

MakeColumns generates an array that has Gohan style column names

Types

type CachedState 

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

type CachedTransaction 

type CachedTransaction struct {
	TxInterface
	QueryCache map[string]CachedState
}

func (*CachedTransaction) ClearCache 

func (tx *CachedTransaction) ClearCache()

func (*CachedTransaction) Create 

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

func (*CachedTransaction) CreateContext 

func (tx *CachedTransaction) CreateContext(ctx context.Context, resource *schema.Resource) error

func (*CachedTransaction) Delete 

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

func (*CachedTransaction) DeleteContext 

func (tx *CachedTransaction) DeleteContext(ctx context.Context, s *schema.Schema, resourceID interface{}) error

func (*CachedTransaction) Fetch 

func (tx *CachedTransaction) Fetch(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions) (*schema.Resource, error)

func (*CachedTransaction) FetchContext 

func (tx *CachedTransaction) FetchContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions) (*schema.Resource, error)

func (*CachedTransaction) List 

func (tx *CachedTransaction) List(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)

func (*CachedTransaction) ListContext 

func (tx *CachedTransaction) ListContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)

List resources in the db

func (*CachedTransaction) LockFetch 

func (tx *CachedTransaction) LockFetch(s *schema.Schema, filter transaction.Filter, lockPolicy schema.LockPolicy, options *transaction.ViewOptions) (*schema.Resource, error)

func (*CachedTransaction) LockFetchContext 

func (tx *CachedTransaction) LockFetchContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, lockPolicy schema.LockPolicy, options *transaction.ViewOptions) (*schema.Resource, error)

func (*CachedTransaction) LockList 

func (tx *CachedTransaction) LockList(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator, lockPolicy schema.LockPolicy) (list []*schema.Resource, total uint64, err error)

func (*CachedTransaction) LockListContext 

func (tx *CachedTransaction) LockListContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator, lockPolicy schema.LockPolicy) (list []*schema.Resource, total uint64, err error)

func (*CachedTransaction) Query 

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

func (*CachedTransaction) QueryContext 

func (tx *CachedTransaction) QueryContext(ctx context.Context, s *schema.Schema, query string, arguments []interface{}) (list []*schema.Resource, err error)

func (*CachedTransaction) StateUpdate 

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

func (*CachedTransaction) StateUpdateContext 

func (tx *CachedTransaction) StateUpdateContext(ctx context.Context, resource *schema.Resource, state *transaction.ResourceState) error

func (*CachedTransaction) Update 

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

func (*CachedTransaction) UpdateContext 

func (tx *CachedTransaction) UpdateContext(ctx context.Context, resource *schema.Resource) error

type DB 

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

DB is sql implementation of DB

func NewDB 

func NewDB(options options.Options) *DB

NewDB constructor

func (*DB) AlterTableDef 

func (db *DB) AlterTableDef(s *schema.Schema, cascade bool) (string, []string, error)

AlterTableDef generates alter table sql

func (*DB) Begin 

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

Begin starts new transaction

func (*DB) BeginTx 

func (db *DB) BeginTx(ctx context.Context, options *transaction.TxOptions) (tx transaction.Transaction, err error)

BeginTx starts new transaction with given transaction options

func (*DB) Close 

func (db *DB) Close()

Close closes db connection

func (*DB) Connect 

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

Connect connects 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, []string)

GenTableDef generates create table sql

func (*DB) Options 

func (db *DB) Options() options.Options

Options returns DB options

func (*DB) RegisterTable 

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

RegisterTable creates table in the db

func (*DB) SetMaxOpenConns 

func (db *DB) SetMaxOpenConns(maxIdleConns int)

SetMaxOpenConns limit maximum connections

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) CountContext 

func (tx *Transaction) CountContext(ctx context.Context, s *schema.Schema, filter transaction.Filter) (res uint64, err error)

CountContext count all matching resources in the db

func (*Transaction) Create 

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

func (*Transaction) CreateContext 

func (tx *Transaction) CreateContext(ctx context.Context, resource *schema.Resource) error

Create create resource in the db

func (*Transaction) Delete 

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

func (*Transaction) DeleteContext 

func (tx *Transaction) DeleteContext(ctx context.Context, s *schema.Schema, resourceID interface{}) error

Delete delete resource from db

func (*Transaction) Exec 

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

func (*Transaction) ExecContext 

func (tx *Transaction) ExecContext(ctx context.Context, sql string, args ...interface{}) error

Exec executes sql in transaction

func (*Transaction) Fetch 

func (tx *Transaction) Fetch(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions) (*schema.Resource, error)

func (*Transaction) FetchContext 

func (tx *Transaction) FetchContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions) (*schema.Resource, error)

Fetch resources by ID in the db

func (*Transaction) GetIsolationLevel 

func (tx *Transaction) GetIsolationLevel() transaction.Type

GetIsolationLevel returns tx isolation level

func (*Transaction) List 

func (tx *Transaction) List(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)

func (*Transaction) ListContext 

func (tx *Transaction) ListContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator) (list []*schema.Resource, total uint64, err error)

List resources in the db

func (*Transaction) LockFetch 

func (tx *Transaction) LockFetch(s *schema.Schema, filter transaction.Filter, lockPolicy schema.LockPolicy, options *transaction.ViewOptions) (*schema.Resource, error)

func (*Transaction) LockFetchContext 

func (tx *Transaction) LockFetchContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, lockPolicy schema.LockPolicy, options *transaction.ViewOptions) (*schema.Resource, error)

LockFetch fetches & locks a resource

func (*Transaction) LockList 

func (tx *Transaction) LockList(s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator, lockPolicy schema.LockPolicy) (list []*schema.Resource, total uint64, err error)

func (*Transaction) LockListContext 

func (tx *Transaction) LockListContext(ctx context.Context, s *schema.Schema, filter transaction.Filter, options *transaction.ViewOptions, pg *pagination.Paginator, lockPolicy schema.LockPolicy) (list []*schema.Resource, total uint64, err error)

LockList locks resources in the db

func (*Transaction) Query 

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

func (*Transaction) QueryContext 

func (tx *Transaction) QueryContext(ctx context.Context, 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, filter transaction.Filter) (state transaction.ResourceState, err error)

func (*Transaction) StateFetchContext 

func (tx *Transaction) StateFetchContext(ctx context.Context, s *schema.Schema, filter transaction.Filter) (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

func (*Transaction) StateUpdateContext 

func (tx *Transaction) StateUpdateContext(ctx context.Context, resource *schema.Resource, state *transaction.ResourceState) error

StateUpdate update resource state

func (*Transaction) Update 

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

func (*Transaction) UpdateContext 

func (tx *Transaction) UpdateContext(ctx context.Context, resource *schema.Resource) error

Update update resource in the db

type TxInterface 

type TxInterface transaction.Transaction

func MakeCachedTransaction 

func MakeCachedTransaction(transx TxInterface) TxInterface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.