sqlx

Documentation

Overview

Extension to the package sqle/sql.

Deprecated.

Index

• func BuildDatabase(cat *sql.Catalog, dbn string, dbs DynamicSchemaDatabase, ...) error
• type DTDatabase
  • func (d DTDatabase) GetDynamicTxTable(name string) DynamicTransactionalTable
  • func (d *DTDatabase) SetDynamicTable(name string, tab DynamicTransactionalTable)
• type DatabaseTx
  • func (d *DatabaseTx) Commit() (err2 error)
  • func (d *DatabaseTx) CommitWith(f func(e error))
  • func (d *DatabaseTx) Discard()
  • func (d *DatabaseTx) GetDynamicTable(name string) DynamicSchemaTable
• type DynamicSchemaDatabase
• type DynamicSchemaDatabaseTx
• type DynamicSchemaTable
• type DynamicSchemaTableTx
• type DynamicTransactionalDatabase
• type DynamicTransactionalTable
• type Tx

Functions

func BuildDatabase

func BuildDatabase(cat *sql.Catalog, dbn string, dbs DynamicSchemaDatabase, tables []*schema.TableMetadata, NOTFOUND error) error

Types

type DTDatabase

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

func (DTDatabase) GetDynamicTxTable

func (d DTDatabase) GetDynamicTxTable(name string) DynamicTransactionalTable

func (*DTDatabase) SetDynamicTable

func (d *DTDatabase) SetDynamicTable(name string, tab DynamicTransactionalTable)

type DatabaseTx

type DatabaseTx struct {
	DynamicTransactionalDatabase
	// contains filtered or unexported fields
}

func (*DatabaseTx) Commit

func (d *DatabaseTx) Commit() (err2 error)

func (*DatabaseTx) CommitWith

func (d *DatabaseTx) CommitWith(f func(e error))

func (*DatabaseTx) Discard

func (d *DatabaseTx) Discard()

func (*DatabaseTx) GetDynamicTable

func (d *DatabaseTx) GetDynamicTable(name string) DynamicSchemaTable

type DynamicSchemaDatabase

type DynamicSchemaDatabase interface {
	// Returns the table, or null, if not exist.
	GetDynamicTable(name string) DynamicSchemaTable
}

type DynamicSchemaDatabaseTx

type DynamicSchemaDatabaseTx interface {
	DynamicSchemaDatabase
	Tx
}

type DynamicSchemaTable

type DynamicSchemaTable interface {
	GetTableOf(db string, tmd *schema.TableMetadata) (sql.Table, []sql.Index, error)
}

type DynamicSchemaTableTx

type DynamicSchemaTableTx interface {
	DynamicSchemaTable
	Tx
}

type DynamicTransactionalDatabase

type DynamicTransactionalDatabase interface {
	GetDynamicTxTable(name string) DynamicTransactionalTable
}

type DynamicTransactionalTable

type DynamicTransactionalTable interface {
	StartTransaction() DynamicSchemaTableTx
}

type Tx

type Tx interface {
	Commit() error
	CommitWith(func(e error))
	Discard()
}