dsc

Mar 8, 2024

Changes in this version

type Config

+ DSN string

+ Driver string

May 25, 2023

Changes in this version

type QueryBuilder

+ func (qb *QueryBuilder) BuildBatchedInQuery(columns []string, pkRowValues [][]interface{}, inColumns []string, ...) []*ParametrizedSQL

+ func (qb *QueryBuilder) BuildQueryWithInColumns(columns []string, inCriteriaColumns []string, pkRowValues [][]interface{}) *ParametrizedSQL

Feb 13, 2020

Changes in this version

+ type ColumnType interface

+ DatabaseTypeName func() string

+ DecimalSize func() (precision, scale int64, ok bool)

+ Length func() (length int64, ok bool)

+ Nullable func() (nullable, ok bool)

+ ScanType func() reflect.Type

type FileScanner

+ func (s *FileScanner) ColumnTypes() ([]ColumnType, error)

type SQLScanner

+ func NewSQLScannerWithTypes(query *QueryStatement, config *Config, columns []string, types []ColumnType) *SQLScanner

+ func (s *SQLScanner) ColumnTypes() ([]ColumnType, error)

type Scanner

+ ColumnTypes func() ([]ColumnType, error)

Feb 3, 2020

Changes in this version

type Config

+ CredConfig *cred.Config

+ func (c *Config) ApplyCredentials(config *cred.Config) error

Sep 17, 2019

Changes in this version

type DatastoreDialect

+ IsKeyCheckSwitchSessionLevel func() bool

type DefaultDialect

+ func (d DefaultDialect) IsKeyCheckSwitchSessionLevel() bool

Aug 5, 2019

Changes in this version

+ var CopyLocalInsert = "copyLocalInsert"

Aug 3, 2019

Changes in this version

+ var UnionSelectInsert = "unionSelectInsert"

Jul 9, 2019

Changes in this version

type TableDescriptor

+ ColumnTypes map[string]string

+ Nullables map[string]bool

Jun 6, 2019

Changes in this version

type TableDescriptor

+ func (t *TableDescriptor) From() string

May 9, 2019

Changes in this version

type Config

+ func (c *Config) Clone() *Config

May 8, 2019

Changes in this version

type BaseStatement

+ Alias string

May 7, 2019

Changes in this version

+ var BulkInsertAllType = "insertAll"

type DatastoreDialect

+ BulkInsertType func() string

type DefaultDialect

+ func (d DefaultDialect) BulkInsertType() string

Apr 19, 2019

Changes in this version

type Config

+ func (c *Config) DsnDescriptor() (string, error)

Apr 16, 2019

Changes in this version

type AbstractManager

+ func (m *AbstractManager) Acquire()

type Config

+ MaxRequestPerSecond int

+ type Limiter struct

+ func NewLimiter(duration time.Duration, max int) *Limiter

+ func (l *Limiter) Acquire()

Mar 12, 2019

Changes in this version

type DatastoreDialect

+ Ping func(manager Manager) error

type DefaultDialect

+ func (d DefaultDialect) Ping(manager Manager) error

Jan 20, 2019

Changes in this version

type SQLCriteria

+ func (s *SQLCriteria) Expression() string

type SQLCriterion

+ func (c *SQLCriterion) Expression() string

Dec 27, 2018

Changes in this version

type DatastoreDialect

+ CanHandleTransaction func() bool

+ NormalizeSQL func(SQL string) string

type DefaultDialect

+ func (d DefaultDialect) CanHandleTransaction() bool

+ func (d DefaultDialect) NormalizeSQL(SQL string) string

type TableColumn

+ Position int

Nov 6, 2018

Changes in this version

+ const BatchSizeKey

+ const SQLTypeDelete

+ const SQLTypeInsert

+ const SQLTypeUpdate

+ func NewBooleanPredicate(leftOperand bool, operator string) toolbox.Predicate

+ func NewSQLCriteriaPredicate(parameters toolbox.Iterator, sqlCriteria *SQLCriteria) (toolbox.Predicate, error)

+ func NewSQLCriterionPredicate(criterion *SQLCriterion, parameters toolbox.Iterator) (toolbox.Predicate, error)

+ func NewSQLResult(rowsAffected, lastInsertID int64) sql.Result

+ func RegisterDatastoreDialect(driver string, dialectable DatastoreDialect)

+ func RegisterManagerFactory(driver string, factory ManagerFactory)

+ func ScanRow(scanner Scanner) ([]interface{}, []string, error)

+ func StdoutLogger(format string, args ...interface{})

+ func VoidLogger(format string, args ...interface{})

+ type AbstractConnection struct

+ func NewAbstractConnection(config *Config, connectionPool chan Connection, connection Connection) *AbstractConnection

+ func (ac *AbstractConnection) Begin() error

+ func (ac *AbstractConnection) Close() error

+ func (ac *AbstractConnection) Commit() error

+ func (ac *AbstractConnection) Config() *Config

+ func (ac *AbstractConnection) ConnectionPool() chan Connection

+ func (ac *AbstractConnection) LastUsed() *time.Time

+ func (ac *AbstractConnection) Rollback() error

+ func (ac *AbstractConnection) SetLastUsed(ts *time.Time)

+ type AbstractConnectionProvider struct

+ func NewAbstractConnectionProvider(config *Config, connectionPool chan Connection, ...) *AbstractConnectionProvider

+ func (cp *AbstractConnectionProvider) Close() error

+ func (cp *AbstractConnectionProvider) Config() *Config

+ func (cp *AbstractConnectionProvider) ConnectionPool() chan Connection

+ func (cp *AbstractConnectionProvider) Get() (Connection, error)

+ func (cp *AbstractConnectionProvider) SpawnConnectionIfNeeded()

+ type AbstractManager struct

+ func NewAbstractManager(config *Config, connectionProvider ConnectionProvider, self Manager) *AbstractManager

+ func (m *AbstractManager) ClassifyDataAsInsertableOrUpdatable(connection Connection, dataPointer interface{}, table string, ...) ([]interface{}, []interface{}, error)

+ func (m *AbstractManager) Config() *Config

+ func (m *AbstractManager) ConnectionProvider() ConnectionProvider

+ func (m *AbstractManager) DeleteAll(dataPointer interface{}, table string, keyProvider KeyGetter) (deleted int, err error)

+ func (m *AbstractManager) DeleteAllOnConnection(connection Connection, dataPointer interface{}, table string, ...) (deleted int, err error)

+ func (m *AbstractManager) DeleteSingle(dataPointer interface{}, table string, keyProvider KeyGetter) (bool, error)

+ func (m *AbstractManager) DeleteSingleOnConnection(connection Connection, dataPointer interface{}, table string, ...) (bool, error)

+ func (m *AbstractManager) Execute(sql string, sqlParameters ...interface{}) (result sql.Result, err error)

+ func (m *AbstractManager) ExecuteAll(sqls []string) ([]sql.Result, error)

+ func (m *AbstractManager) ExecuteAllOnConnection(connection Connection, sqls []string) ([]sql.Result, error)

+ func (m *AbstractManager) ExpandSQL(sql string, arguments []interface{}) string

+ func (m *AbstractManager) PersistAll(dataPointer interface{}, table string, provider DmlProvider) (int, int, error)

+ func (m *AbstractManager) PersistAllOnConnection(connection Connection, dataPointer interface{}, table string, ...) (inserted int, updated int, err error)

+ func (m *AbstractManager) PersistData(connection Connection, data interface{}, table string, keySetter KeySetter, ...) (int, error)

+ func (m *AbstractManager) PersistSingle(dataPointer interface{}, table string, provider DmlProvider) (inserted int, updated int, err error)

+ func (m *AbstractManager) PersistSingleOnConnection(connection Connection, dataPointer interface{}, table string, ...) (inserted int, updated int, err error)

+ func (m *AbstractManager) ReadAllOnConnection(connection Connection, resultSlicePointer interface{}, query string, ...) error

+ func (m *AbstractManager) ReadAllWithHandler(query string, queryParameters []interface{}, ...) error

+ func (m *AbstractManager) ReadSingle(resultPointer interface{}, query string, queryParameters []interface{}, ...) (success bool, err error)

+ func (m *AbstractManager) ReadSingleOnConnection(connection Connection, resultPointer interface{}, query string, ...) (success bool, err error)

+ func (m *AbstractManager) RegisterDescriptorIfNeeded(table string, instance interface{}) (*TableDescriptor, error)

+ func (m *AbstractManager) TableDescriptorRegistry() TableDescriptorRegistry

+ func (m AbstractManager) ReadAll(resultSlicePointer interface{}, query string, queryParameters []interface{}, ...) error

+ type BaseStatement struct

+ Columns []*SQLColumn

+ SQL string

+ Table string

+ func (bs BaseStatement) ColumnNames() []string

+ type Column interface

+ DatabaseTypeName func() string

+ DecimalSize func() (precision, scale int64, ok bool)

+ Length func() (length int64, ok bool)

+ Name func() string

+ Nullable func() (nullable, ok bool)

+ ScanType func() reflect.Type

+ func NewColumn(name, typeName string, length, precision, scale *int64, scanType reflect.Type, ...) Column

+ func NewSimpleColumn(name, typeName string) Column

+ type ColumnValueProvider interface

+ ColumnValues func() ([]interface{}, error)

+ type Config struct

+ Credentials string

+ Descriptor string

+ DriverName string

+ MaxPoolSize int

+ Parameters map[string]interface{}

+ PoolSize int

+ SecureDescriptor string

+ URL string

+ func NewConfig(driverName string, descriptor string, encodedParameters string) *Config

+ func NewConfigFromURL(URL string) (*Config, error)

+ func NewConfigWithParameters(driverName string, descriptor string, credential string, ...) (*Config, error)

+ func (c *Config) Get(name string) string

+ func (c *Config) GetBoolean(name string, defaultValue bool) bool

+ func (c *Config) GetDateLayout() string

+ func (c *Config) GetDuration(name string, multiplier time.Duration, defaultValue time.Duration) time.Duration

+ func (c *Config) GetFloat(name string, defaultValue float64) float64

+ func (c *Config) GetInt(name string, defaultValue int) int

+ func (c *Config) GetMap(name string) map[string]interface{}

+ func (c *Config) GetString(name string, defaultValue string) string

+ func (c *Config) Has(name string) bool

+ func (c *Config) HasDateLayout() bool

+ func (c *Config) Init() error

+ type Connection interface

+ Close func() error

+ CloseNow func() error

+ Config func() *Config

+ ConnectionPool func() chan Connection

+ LastUsed func() *time.Time

+ SetLastUsed func(ts *time.Time)

+ Unwrap func(target interface{}) interface{}

+ type ConnectionProvider interface

+ Close func() error

+ Config func() *Config

+ ConnectionPool func() chan Connection

+ Get func() (Connection, error)

+ NewConnection func() (Connection, error)

+ SpawnConnectionIfNeeded func()

+ type DatastoreDialect interface

+ CanCreateDatastore func(manager Manager) bool

+ CanDropDatastore func(manager Manager) bool

+ CanPersistBatch func() bool

+ CreateDatastore func(manager Manager, datastore string) error

+ CreateTable func(manager Manager, datastore string, table string, specification string) error

+ DisableForeignKeyCheck func(manager Manager, connection Connection) error

+ DropDatastore func(manager Manager, datastore string) error

+ DropTable func(manager Manager, datastore string, table string) error

+ EachTable func(manager Manager, handler func(table string) error) error

+ EnableForeignKeyCheck func(manager Manager, connection Connection) error

+ GetColumns func(manager Manager, datastore, table string) ([]Column, error)

+ GetCurrentDatastore func(manager Manager) (string, error)

+ GetDatastores func(manager Manager) ([]string, error)

+ GetKeyName func(manager Manager, datastore, table string) string

+ GetSequence func(manager Manager, name string) (int64, error)

+ GetTables func(manager Manager, datastore string) ([]string, error)

+ Init func(manager Manager, connection Connection) error

+ IsAutoincrement func(manager Manager, datastore, table string) bool

+ NormalizePlaceholders func(SQL string) string

+ ShowCreateTable func(manager Manager, table string) (string, error)

+ func GetDatastoreDialect(driver string) DatastoreDialect

+ func NewDefaultDialect() DatastoreDialect

+ func NewSQLDatastoreDialect(tablesSQL, sequenceSQL, schemaSQL, allSchemaSQL, keySQL, ... string, ...) DatastoreDialect

+ type DefaultDialect struct

+ func (d DefaultDialect) CanCreateDatastore(manager Manager) bool

+ func (d DefaultDialect) CanDropDatastore(manager Manager) bool

+ func (d DefaultDialect) CanPersistBatch() bool

+ func (d DefaultDialect) CreateDatastore(manager Manager, datastore string) error

+ func (d DefaultDialect) CreateTable(manager Manager, datastore string, table string, options string) error

+ func (d DefaultDialect) DisableForeignKeyCheck(manager Manager, connection Connection) error

+ func (d DefaultDialect) DropDatastore(manager Manager, datastore string) error

+ func (d DefaultDialect) DropTable(manager Manager, datastore string, table string) error

+ func (d DefaultDialect) EachTable(manager Manager, handler func(table string) error) error

+ func (d DefaultDialect) EnableForeignKeyCheck(manager Manager, connection Connection) error

+ func (d DefaultDialect) GetColumns(manager Manager, datastore, table string) ([]Column, error)

+ func (d DefaultDialect) GetCurrentDatastore(manager Manager) (string, error)

+ func (d DefaultDialect) GetDatastores(manager Manager) ([]string, error)

+ func (d DefaultDialect) GetKeyName(manager Manager, datastore, table string) string

+ func (d DefaultDialect) GetSequence(manager Manager, name string) (int64, error)

+ func (d DefaultDialect) GetTables(manager Manager, datastore string) ([]string, error)

+ func (d DefaultDialect) Init(manager Manager, connection Connection) error

+ func (d DefaultDialect) IsAutoincrement(manager Manager, datastore, table string) bool

+ func (d DefaultDialect) NormalizePlaceholders(SQL string) string

+ func (d DefaultDialect) ShowCreateTable(manager Manager, table string) (string, error)

+ type DelimiteredRecord struct

+ Columns []string

+ Delimiter string

+ Record map[string]interface{}

+ type DmlBuilder struct

+ Columns *[]string

+ DeleteSQL string

+ InsertSQL string

+ NonPkColumns *[]string

+ TableDescriptor *TableDescriptor

+ UpdateSQL string

+ func NewDmlBuilder(descriptor *TableDescriptor) *DmlBuilder

+ func (b *DmlBuilder) GetParametrizedSQL(sqlType int, valueProvider func(column string) interface{}) *ParametrizedSQL

+ type DmlParser struct

+ func NewDmlParser() *DmlParser

+ func (dp *DmlParser) Parse(input string) (*DmlStatement, error)

+ type DmlProvider interface

+ Get func(operationType int, instance interface{}) *ParametrizedSQL

+ func NewDmlProviderIfNeeded(provider DmlProvider, table string, targetType reflect.Type) (DmlProvider, error)

+ func NewMapDmlProvider(descriptor *TableDescriptor) DmlProvider

+ type DmlStatement struct

+ Type string

+ Values []interface{}

+ func (ds DmlStatement) ColumnValueMap(parameters toolbox.Iterator) (map[string]interface{}, error)

+ func (ds DmlStatement) ColumnValues(parameters toolbox.Iterator) ([]interface{}, error)

+ type FileManager struct

+ func NewFileManager(encoderFactory toolbox.EncoderFactory, decoderFactory toolbox.DecoderFactory, ...) *FileManager

+ func (m *FileManager) ExecuteOnConnection(connection Connection, sql string, sqlParameters []interface{}) (sql.Result, error)

+ func (m *FileManager) Init() error

+ func (m *FileManager) PersistTableData(tableURL string, data []byte) error

+ func (m *FileManager) ReadAllOnWithHandlerOnConnection(connection Connection, query string, sqlParameters []interface{}, ...) error

+ type FileScanner struct

+ Values map[string]interface{}

+ func NewFileScanner(config *Config, columns []string) *FileScanner

+ func (s *FileScanner) Columns() ([]string, error)

+ func (s *FileScanner) Scan(destinations ...interface{}) (err error)

+ type KeyGetter interface

+ Key func(instance interface{}) []interface{}

+ func NewKeyGetterIfNeeded(keyGetter KeyGetter, table string, targetType reflect.Type) (KeyGetter, error)

+ type KeySetter interface

+ SetKey func(instance interface{}, seq int64)

+ type Log func(format string, args ...interface{})

+ var Logf Log = VoidLogger

+ type Manager interface

+ ClassifyDataAsInsertableOrUpdatable func(connection Connection, slicePointer interface{}, table string, ...) (insertables, updatables []interface{}, err error)

+ Config func() *Config

+ ConnectionProvider func() ConnectionProvider

+ DeleteAll func(slicePointer interface{}, table string, keyProvider KeyGetter) (deleted int, err error)

+ DeleteAllOnConnection func(connection Connection, resultPointer interface{}, table string, ...) (deleted int, err error)

+ DeleteSingle func(resultPointer interface{}, table string, keyProvider KeyGetter) (success bool, err error)

+ DeleteSingleOnConnection func(connection Connection, resultPointer interface{}, table string, ...) (success bool, err error)

+ Execute func(sql string, parameters ...interface{}) (sql.Result, error)

+ ExecuteAll func(sqls []string) ([]sql.Result, error)

+ ExecuteAllOnConnection func(connection Connection, sqls []string) ([]sql.Result, error)

+ ExecuteOnConnection func(connection Connection, sql string, parameters []interface{}) (sql.Result, error)

+ PersistAll func(slicePointer interface{}, table string, provider DmlProvider) (inserted int, updated int, err error)

+ PersistAllOnConnection func(connection Connection, dataPointer interface{}, table string, ...) (inserted int, updated int, err error)

+ PersistData func(connection Connection, data interface{}, table string, keySetter KeySetter, ...) (int, error)

+ PersistSingle func(dataPointer interface{}, table string, provider DmlProvider) (inserted int, updated int, err error)

+ PersistSingleOnConnection func(connection Connection, dataPointer interface{}, table string, ...) (inserted int, updated int, err error)

+ ReadAll func(resultSlicePointer interface{}, query string, parameters []interface{}, ...) error

+ ReadAllOnConnection func(connection Connection, resultSlicePointer interface{}, query string, ...) error

+ ReadAllOnWithHandlerOnConnection func(connection Connection, query string, parameters []interface{}, ...) error

+ ReadAllWithHandler func(query string, parameters []interface{}, ...) error

+ ReadSingle func(resultPointer interface{}, query string, parameters []interface{}, ...) (success bool, err error)

+ ReadSingleOnConnection func(connection Connection, resultPointer interface{}, query string, ...) (success bool, err error)

+ TableDescriptorRegistry func() TableDescriptorRegistry

+ type ManagerFactory interface

+ Create func(config *Config) (Manager, error)

+ CreateFromURL func(url string) (Manager, error)

+ func GetManagerFactory(driver string) (ManagerFactory, error)

+ func NewManagerFactory() ManagerFactory

+ type ManagerRegistry interface

+ Get func(name string) Manager

+ Register func(name string, manager Manager)

+ func NewManagerRegistry() ManagerRegistry

+ type ParametrizedSQL struct

+ SQL string

+ Type int

+ Values []interface{}

+ type QueryBuilder struct

+ QueryHint string

+ TableDescriptor *TableDescriptor

+ func NewQueryBuilder(descriptor *TableDescriptor, queryHint string) QueryBuilder

+ func (qb *QueryBuilder) BuildBatchedQueryOnPk(columns []string, pkRowValues [][]interface{}, batchSize int) []*ParametrizedSQL

+ func (qb *QueryBuilder) BuildQueryAll(columns []string) *ParametrizedSQL

+ func (qb *QueryBuilder) BuildQueryOnPk(columns []string, pkRowValues [][]interface{}) *ParametrizedSQL

+ type QueryParser struct

+ func NewQueryParser() *QueryParser

+ func (qp *QueryParser) Parse(query string) (*QueryStatement, error)

+ type QueryStatement struct

+ AllField bool

+ GroupBy []*SQLColumn

+ UnionTables []string

+ type RecordMapper interface

+ Map func(scanner Scanner) (interface{}, error)

+ func NewColumnarRecordMapper(usePointer bool, targetSlice reflect.Type) RecordMapper

+ func NewMapRecordMapper(usePointer bool, targetSlice reflect.Type) RecordMapper

+ func NewMetaRecordMapped(targetType interface{}, usePointer bool) RecordMapper

+ func NewRecordMapper(targetType reflect.Type) RecordMapper

+ func NewRecordMapperIfNeeded(mapper RecordMapper, targetType reflect.Type) RecordMapper

+ type SQLColumn struct

+ Alias string

+ Expression string

+ Function string

+ FunctionArguments string

+ Name string

+ type SQLCriteria struct

+ Criteria []*SQLCriterion

+ LogicalOperator string

+ func (s *SQLCriteria) CriteriaValues(parameters toolbox.Iterator) ([]interface{}, error)

+ type SQLCriterion struct

+ Criteria *SQLCriteria

+ Inverse bool

+ LeftOperand interface{}

+ Operator string

+ RightOperand interface{}

+ RightOperands []interface{}

+ type SQLScanner struct

+ Values map[string]interface{}

+ func NewSQLScanner(query *QueryStatement, config *Config, columns []string) *SQLScanner

+ func (s *SQLScanner) Columns() ([]string, error)

+ func (s *SQLScanner) Scan(destinations ...interface{}) error

+ type Scanner interface

+ Columns func() ([]string, error)

+ Scan func(dest ...interface{}) error

+ func NewScanner(s Scanner) Scanner

+ type TableColumn struct

+ ColumnName string

+ DataType string

+ DataTypeLength *int64

+ IsNullable *bool

+ NumericPrecision *int64

+ NumericScale *int64

+ func (c *TableColumn) DatabaseTypeName() string

+ func (c *TableColumn) DecimalSize() (precision, scale int64, ok bool)

+ func (c *TableColumn) Length() (length int64, ok bool)

+ func (c *TableColumn) Name() string

+ func (c *TableColumn) Nullable() (nullable, ok bool)

+ func (c *TableColumn) ScanType() reflect.Type

+ type TableDescriptor struct

+ Autoincrement bool

+ Columns []string

+ FromQuery string

+ FromQueryAlias string

+ OrderColumns []string

+ PkColumns []string

+ Schema []map[string]interface{}

+ SchemaURL string

+ Table string

+ func NewTableDescriptor(table string, instance interface{}) (*TableDescriptor, error)

+ func (d *TableDescriptor) HasSchema() bool

+ type TableDescriptorRegistry interface

+ Get func(table string) *TableDescriptor

+ Has func(table string) bool

+ Register func(descriptor *TableDescriptor) error

+ Tables func() []string

+ func NewTableDescriptorRegistry() TableDescriptorRegistry

+ type TransactionManager interface

+ Begin func() error

+ Commit func() error

+ Rollback func() error