Versions in this module Expand all Collapse all v0 v0.4.4 Dec 20, 2013 v0.4.3 Dec 18, 2013 Changes in this version + type Type struct + Max uint + Min uint + Name string + Precision uint + Scale uint + func BlobType() *Type + func BoolType() *Type + func DoubleType() *Type + func FloatType() *Type + func IntType() *Type + func NumericType(precision, scale uint) *Type + func PaddedTextType() *Type + func SimpleType(name string) *Type + func TextType() *Type + func (t *Type) HasMax() bool + func (t *Type) HasMin() bool v0.4.2 Dec 17, 2013 v0.4.1 Dec 16, 2013 Changes in this version + const CapBulkTransfer + var ErrCapNotSupported = errors.New("capbility not supported") + var ErrNoTxInProgress = errors.New("no transaction is in progress") + var ErrTxInProgress = errors.New("another transaction is already in progress") type DbExecutor + func (e *DbExecutor) Begin(name string) error + func (e *DbExecutor) BulkAddRecord(args ...interface{}) error + func (e *DbExecutor) BulkFinish() error + func (e *DbExecutor) BulkInit(table string, columns ...string) error + func (e *DbExecutor) Commit() error + func (e *DbExecutor) GetTx() *sql.Tx + func (e *DbExecutor) Rollback() error + func (e *DbExecutor) Submit(stmt string) error type Executor + Begin func(name string) error + BulkAddRecord func(args ...interface{}) error + BulkFinish func() error + BulkInit func(table string, columns ...string) error + Commit func() error + GetTx func() *sql.Tx + Submit func(stmt string) error type FileExecutor + func (e *FileExecutor) Begin(name string) error + func (e *FileExecutor) BulkAddRecord(args ...interface{}) error + func (e *FileExecutor) BulkFinish() error + func (e *FileExecutor) BulkInit(table string, columns ...string) error + func (e *FileExecutor) Commit() error + func (e *FileExecutor) GetTx() *sql.Tx + func (e *FileExecutor) Submit(stmt string) error v0.3.1 Dec 15, 2013 Changes in this version + const CapCopy + const SBegin + const SCommit + const SRollback + var DBEXEC_VERBOSE = true + func FilterInclExcl(list []string, incl map[string]bool, excl map[string]bool) []string + type Column struct + AutoIncr bool + Default interface{} + Length int + Name string + NeedsQuoting bool + Null bool + PrimaryKey bool + RawType string + Select string + TableName string + Type string + type Config struct + Compress bool + Database string + Hostname string + Password string + Port int + Socket string + Username string + type DbExecutor struct + func NewDbExecutor(db *sql.DB) (*DbExecutor, error) + func (e *DbExecutor) Close() error + func (e *DbExecutor) GetDb() *sql.DB + func (e *DbExecutor) HasCapability(capability int) bool + func (e *DbExecutor) Multiple(name string, statements []string) []error + func (e *DbExecutor) Single(name string, statement string) error + func (e *DbExecutor) Transaction(name string, statements []string) error + type Executor interface + GetDb func() *sql.DB + HasCapability func(capability int) bool + Multiple func(name string, statements []string) []error + Single func(name string, statement string) error + Transaction func(name string, statements []string) error + type FileExecutor struct + func NewFileExecutor(filename string) (*FileExecutor, error) + func (e *FileExecutor) Close() error + func (e *FileExecutor) GetDb() *sql.DB + func (e *FileExecutor) HasCapability(capability int) bool + func (e *FileExecutor) Multiple(name string, statements []string) []error + func (e *FileExecutor) Single(name string, statement string) error + func (e *FileExecutor) Transaction(name string, statements []string) error + type Queryer interface + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + type ReadCloser interface + type Reader interface + CreateProjection func(name string, body string, engine string, pk []string, uks [][]string) error + CreateView func(name string, body string) error + DropProjection func(name string) error + DropView func(name string) error + FilteredTables func(incl, excl map[string]bool) []*Table + Read func(table *Table) (*sql.Rows, error) + TableNames func() []string + Tables func() []*Table + type Table struct + Columns []*Column + DbType string + Name string + type WriteCloser interface + type Writer interface + MergeTable func(src *Table, dstName string, r Reader) error
Go to main page