memory

package

Go to main page

Versions in this module

v0

v0.20.0

May 13, 2025

Changes in this version

type StatsProv

+ func (s *StatsProv) AnalyzeTable(ctx *sql.Context, table sql.Table, db string) error

v0.19.0

Dec 19, 2024

Changes in this version

type BaseDatabase

+ func (d *BaseDatabase) DeleteTable(name string)

type Index

+ SupportedVectorFunction vector.DistanceType

+ func (idx *Index) CanSupportOrderBy(expr sql.Expression) bool

+ func (idx *Index) IsVector() bool

type MemoryDatabase

+ DeleteTable func(name string)

type Table

+ func (t *Table) CreateVectorIndex(ctx *sql.Context, idx sql.IndexDef, distanceType vector.DistanceType) error

v0.18.1

Apr 9, 2024

Changes in this version

+ func NewSessionBuilder(pro *DbProvider) func(ctx context.Context, conn *mysql.Conn, addr string) (sql.Session, error)

v0.18.0

Feb 28, 2024

Changes in this version

+ const DualTableName

+ var DualTableSchema = sql.NewPrimaryKeySchema(sql.Schema{ ... })

type BaseDatabase

+ func (d *BaseDatabase) Database() *BaseDatabase

+ func (d *BaseDatabase) UpdateLastExecuted(ctx *sql.Context, eventName string, lastExecuted time.Time) error

+ func (d *BaseDatabase) ValidateSchema(schema sql.Schema) error

type Database

+ func (d *Database) Database() *BaseDatabase

+ func (d *Database) NeedsToReloadEvents(_ *sql.Context, token interface{}) (bool, error)

type DbProvider

+ func (pro *DbProvider) WithTableFunctions(fns ...sql.TableFunction) (sql.TableFunctionProvider, error)

+ type ExponentialDistTable struct

+ func (ExponentialDistTable) Collation() sql.CollationID

+ func (ExponentialDistTable) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (s ExponentialDistTable) CheckPrivileges(_ *sql.Context, _ sql.PrivilegedOperationChecker) bool

+ func (s ExponentialDistTable) Children() []sql.Node

+ func (s ExponentialDistTable) Database() sql.Database

+ func (s ExponentialDistTable) DebugString() string

+ func (s ExponentialDistTable) Description() string

+ func (s ExponentialDistTable) Expressions() []sql.Expression

+ func (s ExponentialDistTable) IsReadOnly() bool

+ func (s ExponentialDistTable) Name() string

+ func (s ExponentialDistTable) NewInstance(_ *sql.Context, db sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s ExponentialDistTable) PartitionRows(ctx *sql.Context, _ sql.Partition) (sql.RowIter, error)

+ func (s ExponentialDistTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (s ExponentialDistTable) Resolved() bool

+ func (s ExponentialDistTable) RowIter(_ *sql.Context, _ sql.Row) (sql.RowIter, error)

+ func (s ExponentialDistTable) Schema() sql.Schema

+ func (s ExponentialDistTable) String() string

+ func (s ExponentialDistTable) UnderlyingTable() sql.Table

+ func (s ExponentialDistTable) WithChildren(_ ...sql.Node) (sql.Node, error)

+ func (s ExponentialDistTable) WithDatabase(_ sql.Database) (sql.Node, error)

+ func (s ExponentialDistTable) WithExpressions(e ...sql.Expression) (sql.Node, error)

type Index

+ func (idx *Index) ExtendedExprs() []sql.Expression

type IntSequenceTable

+ func (s IntSequenceTable) IsReadOnly() bool

+ func (s IntSequenceTable) PreciseMatch() bool

+ type MemTable interface

+ IgnoreSessionData func() bool

+ UnderlyingTable func() *Table

type MemoryDatabase

+ Database func() *BaseDatabase

+ type NormalDistTable struct

+ func (NormalDistTable) Collation() sql.CollationID

+ func (NormalDistTable) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (s NormalDistTable) CheckPrivileges(_ *sql.Context, _ sql.PrivilegedOperationChecker) bool

+ func (s NormalDistTable) Children() []sql.Node

+ func (s NormalDistTable) Database() sql.Database

+ func (s NormalDistTable) DebugString() string

+ func (s NormalDistTable) Description() string

+ func (s NormalDistTable) Expressions() []sql.Expression

+ func (s NormalDistTable) IsReadOnly() bool

+ func (s NormalDistTable) Name() string

+ func (s NormalDistTable) NewInstance(_ *sql.Context, db sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s NormalDistTable) PartitionRows(ctx *sql.Context, _ sql.Partition) (sql.RowIter, error)

+ func (s NormalDistTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (s NormalDistTable) Resolved() bool

+ func (s NormalDistTable) RowIter(_ *sql.Context, _ sql.Row) (sql.RowIter, error)

+ func (s NormalDistTable) Schema() sql.Schema

+ func (s NormalDistTable) String() string

+ func (s NormalDistTable) UnderlyingTable() sql.Table

+ func (s NormalDistTable) WithChildren(_ ...sql.Node) (sql.Node, error)

+ func (s NormalDistTable) WithDatabase(_ sql.Database) (sql.Node, error)

+ func (s NormalDistTable) WithExpressions(e ...sql.Expression) (sql.Node, error)

+ type PointLookupTable struct

+ func (s PointLookupTable) DebugString() string

+ func (s PointLookupTable) Description() string

+ func (s PointLookupTable) GetIndexes(ctx *sql.Context) (indexes []sql.Index, err error)

+ func (s PointLookupTable) Name() string

+ func (s PointLookupTable) NewInstance(ctx *sql.Context, db sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s PointLookupTable) PreciseMatch() bool

+ func (s PointLookupTable) String() string

+ func (s PointLookupTable) UnderlyingTable() sql.Table

+ type RequiredLookupTable struct

+ func (s RequiredLookupTable) Database() sql.Database

+ func (s RequiredLookupTable) DebugString() string

+ func (s RequiredLookupTable) Description() string

+ func (s RequiredLookupTable) Expressions() []sql.Expression

+ func (s RequiredLookupTable) GetIndexes(ctx *sql.Context) (indexes []sql.Index, err error)

+ func (s RequiredLookupTable) IndexedAccess(lookup sql.IndexLookup) sql.IndexedTable

+ func (s RequiredLookupTable) Name() string

+ func (s RequiredLookupTable) NewInstance(ctx *sql.Context, db sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s RequiredLookupTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (s RequiredLookupTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (s RequiredLookupTable) PreciseMatch() bool

+ func (s RequiredLookupTable) RequiredPredicates() []string

+ func (s RequiredLookupTable) RowIter(_ *sql.Context, _ sql.Row) (sql.RowIter, error)

+ func (s RequiredLookupTable) String() string

+ func (s RequiredLookupTable) UnderlyingTable() sql.Table

+ func (s RequiredLookupTable) WithChildren(_ ...sql.Node) (sql.Node, error)

+ func (s RequiredLookupTable) WithDatabase(_ sql.Database) (sql.Node, error)

+ func (s RequiredLookupTable) WithExpressions(e ...sql.Expression) (sql.Node, error)

+ type Session struct

+ func NewSession(baseSession *sql.BaseSession, provider sql.DatabaseProvider) *Session

+ func SessionFromContext(ctx *sql.Context) *Session

+ func (s *Session) CommitTransaction(ctx *sql.Context, tx sql.Transaction) error

+ func (s *Session) CreateSavepoint(ctx *sql.Context, transaction sql.Transaction, name string) error

+ func (s *Session) GetPersistedValue(k string) (interface{}, error)

+ func (s *Session) PersistGlobal(sysVarName string, value interface{}) error

+ func (s *Session) ReleaseSavepoint(ctx *sql.Context, transaction sql.Transaction, name string) error

+ func (s *Session) RemoveAllPersistedGlobals() error

+ func (s *Session) RemovePersistedGlobal(sysVarName string) error

+ func (s *Session) Rollback(ctx *sql.Context, transaction sql.Transaction) error

+ func (s *Session) RollbackToSavepoint(ctx *sql.Context, transaction sql.Transaction, name string) error

+ func (s *Session) SetGlobals(globals map[string]interface{}) *Session

+ func (s *Session) SetValidationCallback(validationCallback func()) *Session

+ func (s *Session) StartTransaction(ctx *sql.Context, tCharacteristic sql.TransactionCharacteristic) (sql.Transaction, error)

+ func (s *Session) ValidateSession(ctx *sql.Context) error

+ type StatsProv struct

+ func NewStatsProv() *StatsProv

+ func (s *StatsProv) DataLength(ctx *sql.Context, db, table string) (uint64, error)

+ func (s *StatsProv) DropDbStats(ctx *sql.Context, db string, flush bool) error

+ func (s *StatsProv) DropStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) error

+ func (s *StatsProv) GetStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) (sql.Statistic, bool)

+ func (s *StatsProv) GetTableStats(ctx *sql.Context, db, table string) ([]sql.Statistic, error)

+ func (s *StatsProv) RefreshTableStats(ctx *sql.Context, table sql.Table, db string) error

+ func (s *StatsProv) RowCount(ctx *sql.Context, db, table string) (uint64, error)

+ func (s *StatsProv) SetStats(ctx *sql.Context, stats sql.Statistic) error

type Table

+ func NewDualTable() *Table

+ func NewLocalTable(db MemoryDatabase, name string, schema sql.PrimaryKeySchema, ...) *Table

+ func (t *Table) BuildIndex(ctx *sql.Context, indexDef sql.IndexDef) (sql.RowInserter, error)

+ func (t *Table) Comment() string

+ func (t *Table) Database() string

+ func (t *Table) IgnoreSessionData() bool

+ func (t *Table) PreciseMatch() bool

+ func (t *Table) RewriteInserter(ctx *sql.Context, oldSchema, newSchema sql.PrimaryKeySchema, _, _ *sql.Column, ...) (sql.RowInserter, error)

+ func (t *Table) ShouldBuildIndex(ctx *sql.Context, indexDef sql.IndexDef) (bool, error)

+ func (t *Table) ShouldRewriteTable(ctx *sql.Context, oldSchema, newSchema sql.PrimaryKeySchema, ...) bool

+ func (t *Table) UnderlyingTable() *Table

+ type TableData struct

+ func (td TableData) Table(database *BaseDatabase) *Table

+ type TableFunc struct

+ func (TableFunc) Collation() sql.CollationID

+ func (TableFunc) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (s TableFunc) CheckPrivileges(_ *sql.Context, _ sql.PrivilegedOperationChecker) bool

+ func (s TableFunc) Children() []sql.Node

+ func (s TableFunc) Database() sql.Database

+ func (s TableFunc) DebugString() string

+ func (s TableFunc) Description() string

+ func (s TableFunc) Expressions() []sql.Expression

+ func (s TableFunc) IsReadOnly() bool

+ func (s TableFunc) Name() string

+ func (s TableFunc) NewInstance(_ *sql.Context, db sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s TableFunc) Resolved() bool

+ func (s TableFunc) RowIter(_ *sql.Context, _ sql.Row) (sql.RowIter, error)

+ func (s TableFunc) Schema() sql.Schema

+ func (s TableFunc) String() string

+ func (s TableFunc) WithChildren(_ ...sql.Node) (sql.Node, error)

+ func (s TableFunc) WithDatabase(_ sql.Database) (sql.Node, error)

+ func (s TableFunc) WithExpressions(e ...sql.Expression) (sql.Node, error)

+ type TableFunctionRowIter struct

+ func (i *TableFunctionRowIter) Close(_ *sql.Context) error

+ func (i *TableFunctionRowIter) Next(_ *sql.Context) (sql.Row, error)

+ type TableRevision struct

+ func NewPartitionedTableRevision(db *BaseDatabase, name string, schema sql.PrimaryKeySchema, ...) *TableRevision

+ func (t *TableRevision) AddColumn(ctx *sql.Context, column *sql.Column, order *sql.ColumnOrder) error

+ func (t *TableRevision) IgnoreSessionData() bool

+ func (t *TableRevision) Inserter(ctx *sql.Context) sql.RowInserter

+ type Transaction struct

+ func (s *Transaction) IsReadOnly() bool

+ func (s *Transaction) String() string

v0.17.0

Aug 23, 2023

Changes in this version

type BaseDatabase

+ func (d *BaseDatabase) CreateFulltextTableNames(ctx *sql.Context, parentTableName string, parentIndexName string) (fulltext.IndexTableNames, error)

type Index

+ Fulltext bool

+ func (idx *Index) FullTextKeyColumns(ctx *sql.Context) (fulltext.KeyColumns, error)

+ func (idx *Index) FullTextTableNames(ctx *sql.Context) (fulltext.IndexTableNames, error)

+ func (idx *Index) IsFullText() bool

type IntSequenceTable

+ func (IntSequenceTable) Collation() sql.CollationID

+ func (s IntSequenceTable) GetIndexes(ctx *sql.Context) ([]sql.Index, error)

+ func (s IntSequenceTable) IndexedAccess(lookup sql.IndexLookup) sql.IndexedTable

+ func (s IntSequenceTable) LookupPartitions(context *sql.Context, lookup sql.IndexLookup) (sql.PartitionIter, error)

+ func (s IntSequenceTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (s IntSequenceTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (s IntSequenceTable) UnderlyingTable() sql.Table

type Table

+ func (t *Table) CreateFulltextIndex(ctx *sql.Context, indexDef sql.IndexDef, keyCols fulltext.KeyColumns, ...) error

v0.16.0

Jun 29, 2023

Changes in this version

type Index

+ func (idx *Index) ExtendedColumnExpressionTypes() []sql.ColumnExpressionType

+ func (idx *Index) ExtendedExpressions() []string

+ func (idx *Index) Reversible() bool

type IndexedTable

+ Lookup sql.IndexLookup

v0.15.0

Apr 18, 2023

Changes in this version

+ func NewDBProvider(dbs ...sql.Database) sql.MutableDatabaseProvider

+ func NewDBProviderWithOpts(opts ...ProviderOption) sql.MutableDatabaseProvider

+ func NewHistogramMapFromTable(ctx *sql.Context, t sql.Table) (sql.HistogramMap, error)

type BaseDatabase

+ func (d *BaseDatabase) CreateIndexedTable(ctx *sql.Context, name string, sch sql.PrimaryKeySchema, idxDef sql.IndexDef, ...) error

+ func (d *BaseDatabase) DropEvent(ctx *sql.Context, name string) error

+ func (d *BaseDatabase) GetEvent(ctx *sql.Context, name string) (sql.EventDefinition, bool, error)

+ func (d *BaseDatabase) GetEvents(ctx *sql.Context) ([]sql.EventDefinition, error)

+ func (d *BaseDatabase) GetStoredProcedure(ctx *sql.Context, name string) (sql.StoredProcedureDetails, bool, error)

+ func (d *BaseDatabase) SaveEvent(ctx *sql.Context, ed sql.EventDefinition) error

+ func (d *BaseDatabase) UpdateEvent(ctx *sql.Context, ed sql.EventDefinition) error

type Database

+ func (d *Database) GetViewDefinition(ctx *sql.Context, viewName string) (sql.ViewDefinition, bool, error)

+ type DbProvider struct

+ func (pro *DbProvider) AllDatabases(*sql.Context) []sql.Database

+ func (pro *DbProvider) CreateDatabase(_ *sql.Context, name string) (err error)

+ func (pro *DbProvider) Database(_ *sql.Context, name string) (sql.Database, error)

+ func (pro *DbProvider) DropDatabase(_ *sql.Context, name string) (err error)

+ func (pro *DbProvider) ExternalStoredProcedure(_ *sql.Context, name string, numOfParams int) (*sql.ExternalStoredProcedureDetails, error)

+ func (pro *DbProvider) ExternalStoredProcedures(_ *sql.Context, name string) ([]sql.ExternalStoredProcedureDetails, error)

+ func (pro *DbProvider) HasDatabase(_ *sql.Context, name string) bool

+ func (pro *DbProvider) TableFunction(_ *sql.Context, name string) (sql.TableFunction, error)

+ func (pro *DbProvider) WithOption(opt ProviderOption)

type Index

+ PrefixLens []uint16

+ Spatial bool

+ func (idx *Index) IsSpatial() bool

+ func (idx *Index) PrefixLengths() []uint16

type IndexedTable

+ Idx *Index

+ func (t *IndexedTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ type IntSequenceTable struct

+ Len int

+ func (IntSequenceTable) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (s IntSequenceTable) CheckPrivileges(_ *sql.Context, _ sql.PrivilegedOperationChecker) bool

+ func (s IntSequenceTable) Children() []sql.Node

+ func (s IntSequenceTable) Database() sql.Database

+ func (s IntSequenceTable) DebugString() string

+ func (s IntSequenceTable) Description() string

+ func (s IntSequenceTable) Expressions() []sql.Expression

+ func (s IntSequenceTable) Name() string

+ func (s IntSequenceTable) NewInstance(_ *sql.Context, _ sql.Database, args []sql.Expression) (sql.Node, error)

+ func (s IntSequenceTable) Resolved() bool

+ func (s IntSequenceTable) RowIter(_ *sql.Context, _ sql.Row) (sql.RowIter, error)

+ func (s IntSequenceTable) Schema() sql.Schema

+ func (s IntSequenceTable) String() string

+ func (s IntSequenceTable) WithChildren(_ ...sql.Node) (sql.Node, error)

+ func (s IntSequenceTable) WithDatabase(_ sql.Database) (sql.Node, error)

+ func (s IntSequenceTable) WithExpressions(e ...sql.Expression) (sql.Node, error)

+ type ProviderOption func(*DbProvider)

+ func HistoryProvider(enableHistory bool) ProviderOption

+ func NativeIndexProvider(useNativeIndexes bool) ProviderOption

+ func ReadOnlyProvider(enableReadOnly bool) ProviderOption

+ func WithDbsOption(dbs []sql.Database) ProviderOption

+ type SequenceTableFnRowIter struct

+ func NewSequenceTableFnRowIter(n int) *SequenceTableFnRowIter

+ func (i *SequenceTableFnRowIter) Close(_ *sql.Context) error

+ func (i *SequenceTableFnRowIter) Next(_ *sql.Context) (sql.Row, error)

type Table

+ func (t *Table) GetForeignKeyEditor(ctx *sql.Context) sql.ForeignKeyEditor

+ func (t *Table) ModifyDefaultCollation(ctx *sql.Context, collation sql.CollationID) error

+ func (t *Table) ModifyStoredCollation(ctx *sql.Context, collation sql.CollationID) error

+ func (t *Table) RowCount(ctx *sql.Context) (uint64, error)

v0.14.0

Nov 1, 2022

Changes in this version

+ var ExternalStoredProcedures = []sql.ExternalStoredProcedureDetails

type BaseDatabase

+ func (d *BaseDatabase) GetCollation(ctx *sql.Context) sql.CollationID

+ func (d *BaseDatabase) SetCollation(ctx *sql.Context, collation sql.CollationID) error

type InMemoryPersistedSession

+ func NewInMemoryPersistedSessionWithValidationCallback(sess sql.Session, validateCb func()) *InMemoryPersistedSession

+ func (s *InMemoryPersistedSession) ValidateSession(ctx *sql.Context, dbName string) error

type Index

+ func (idx *Index) CanSupport(...sql.Range) bool

+ type IndexedTable struct

+ func (t *IndexedTable) LookupPartitions(ctx *sql.Context, lookup sql.IndexLookup) (sql.PartitionIter, error)

type Table

+ func NewPartitionedTableWithCollation(name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, ...) *Table

+ func NewTableWithCollation(name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, ...) *Table

+ func (t *Table) AnalyzeTable(ctx *sql.Context) error

+ func (t *Table) Collation() sql.CollationID

+ func (t *Table) IndexedAccess(sql.Index) sql.IndexedTable

+ func (t *Table) Statistics(ctx *sql.Context) (sql.TableStatistics, error)

+ func (t *Table) WithDriverIndexLookup(lookup sql.DriverIndexLookup) sql.Table

+ type TableStatistics struct

+ func (ts *TableStatistics) CreatedAt() time.Time

+ func (ts *TableStatistics) Histogram(colName string) (*sql.Histogram, error)

+ func (ts *TableStatistics) HistogramMap() sql.HistogramMap

+ func (ts *TableStatistics) NullCount() uint64

+ func (ts *TableStatistics) RowCount() uint64

v0.12.0

Jun 12, 2022

Changes in this version

+ const CommentPreventingIndexBuilding

+ func NewTableEditAccumulator(t *Table) tableEditAccumulator

type BaseDatabase

+ func (d *BaseDatabase) GetForeignKeyCollection() *ForeignKeyCollection

+ type ExternalStoredProcedureDatabase struct

+ func NewExternalStoredProcedureDatabase(name string) ExternalStoredProcedureDatabase

+ func (e ExternalStoredProcedureDatabase) GetExternalStoredProcedures(ctx *sql.Context) ([]sql.ExternalStoredProcedureDetails, error)

type FilteredTable

+ func (t *FilteredTable) Projections() []string

+ func (t *FilteredTable) WithProjections(colNames []string) sql.Table

+ type ForeignKeyCollection struct

+ func (fkc *ForeignKeyCollection) AddFK(fk sql.ForeignKeyConstraint)

+ func (fkc *ForeignKeyCollection) DropFK(fkName string) bool

+ func (fkc *ForeignKeyCollection) Keys() []sql.ForeignKeyConstraint

+ func (fkc *ForeignKeyCollection) SetResolved(fkName string) bool

+ type GlobalsMap = map[string]interface

+ type InMemoryPersistedSession struct

+ func NewInMemoryPersistedSession(sess sql.Session, persistedGlobals GlobalsMap) *InMemoryPersistedSession

+ func (s *InMemoryPersistedSession) GetPersistedValue(k string) (interface{}, error)

+ func (s *InMemoryPersistedSession) PersistGlobal(sysVarName string, value interface{}) error

+ func (s *InMemoryPersistedSession) RemoveAllPersistedGlobals() error

+ func (s *InMemoryPersistedSession) RemovePersistedGlobal(sysVarName string) error

+ type Index struct

+ CommentStr string

+ DB string

+ DriverName string

+ Exprs []sql.Expression

+ Name string

+ TableName string

+ Tbl *Table

+ Unique bool

+ func (idx *Index) ColumnExpressionTypes(*sql.Context) []sql.ColumnExpressionType

+ func (idx *Index) ColumnExpressions() []sql.Expression

+ func (idx *Index) Comment() string

+ func (idx *Index) Database() string

+ func (idx *Index) Driver() string

+ func (idx *Index) Expressions() []string

+ func (idx *Index) HandledFilters(filters []sql.Expression) []sql.Expression

+ func (idx *Index) ID() string

+ func (idx *Index) IndexType() string

+ func (idx *Index) IsGenerated() bool

+ func (idx *Index) IsUnique() bool

+ func (idx *Index) MemTable() *Table

+ func (idx *Index) NewLookup(ctx *sql.Context, ranges ...sql.Range) (sql.IndexLookup, error)

+ func (idx *Index) Order() sql.IndexOrder

+ func (idx *Index) Table() string

+ type IndexLookup struct

+ Expr sql.Expression

+ func NewIndexLookup(ctx *sql.Context, idx ExpressionsIndex, expr sql.Expression, ...) *IndexLookup

+ func (eil *IndexLookup) EvalExpression() sql.Expression

+ func (eil *IndexLookup) Index() sql.Index

+ func (eil *IndexLookup) Indexes() []string

+ func (eil *IndexLookup) Ranges() sql.RangeCollection

+ func (eil *IndexLookup) String() string

+ func (eil *IndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

type Table

+ func (t *Table) AddForeignKey(ctx *sql.Context, fk sql.ForeignKeyConstraint) error

+ func (t *Table) CreateIndexForForeignKey(ctx *sql.Context, indexName string, using sql.IndexUsing, ...) error

+ func (t *Table) GetDeclaredForeignKeys(ctx *sql.Context) ([]sql.ForeignKeyConstraint, error)

+ func (t *Table) GetForeignKeyUpdater(ctx *sql.Context) sql.ForeignKeyUpdater

+ func (t *Table) GetReferencedForeignKeys(ctx *sql.Context) ([]sql.ForeignKeyConstraint, error)

+ func (t *Table) PartitionRows2(ctx *sql.Context, partition sql.Partition) (sql.RowIter2, error)

+ func (t *Table) PrimaryKeySchema() sql.PrimaryKeySchema

+ func (t *Table) Projections() []string

+ func (t *Table) SetForeignKeyResolved(ctx *sql.Context, fkName string) error

+ func (t *Table) UpdateForeignKey(ctx *sql.Context, fkName string, fk sql.ForeignKeyConstraint) error

+ func (t *Table) WithProjections(colNames []string) sql.Table

v0.11.0

Oct 20, 2021

Changes in this version

+ func NewMemoryDBProvider(dbs ...sql.Database) sql.MutableDatabaseProvider

+ type BaseDatabase struct

+ func NewViewlessDatabase(name string) *BaseDatabase

+ func (d *BaseDatabase) AddTable(name string, t sql.Table)

+ func (d *BaseDatabase) CreateTable(ctx *sql.Context, name string, schema sql.Schema) error

+ func (d *BaseDatabase) CreateTrigger(ctx *sql.Context, definition sql.TriggerDefinition) error

+ func (d *BaseDatabase) DropStoredProcedure(ctx *sql.Context, name string) error

+ func (d *BaseDatabase) DropTable(ctx *sql.Context, name string) error

+ func (d *BaseDatabase) DropTrigger(ctx *sql.Context, name string) error

+ func (d *BaseDatabase) EnablePrimaryKeyIndexes()

+ func (d *BaseDatabase) GetStoredProcedures(ctx *sql.Context) ([]sql.StoredProcedureDetails, error)

+ func (d *BaseDatabase) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error)

+ func (d *BaseDatabase) GetTableNames(ctx *sql.Context) ([]string, error)

+ func (d *BaseDatabase) GetTriggers(ctx *sql.Context) ([]sql.TriggerDefinition, error)

+ func (d *BaseDatabase) Name() string

+ func (d *BaseDatabase) RenameTable(ctx *sql.Context, oldName, newName string) error

+ func (d *BaseDatabase) SaveStoredProcedure(ctx *sql.Context, spd sql.StoredProcedureDetails) error

+ func (d *BaseDatabase) Tables() map[string]sql.Table

type Database

+ func (d *Database) AllViews(ctx *sql.Context) ([]sql.ViewDefinition, error)

+ func (d *Database) CreateView(ctx *sql.Context, name string, selectStatement string) error

+ func (d *Database) DropView(ctx *sql.Context, name string) error

+ func (d *Database) GetView(ctx *sql.Context, viewName string) (string, bool, error)

+ type MemoryDatabase interface

+ AddTable func(name string, t sql.Table)

+ type ReadOnlyDatabase struct

+ func NewReadOnlyDatabase(name string) ReadOnlyDatabase

+ func (d ReadOnlyDatabase) IsReadOnly() bool

type Table

+ func (t *Table) CreatePrimaryKey(ctx *sql.Context, columns []sql.IndexColumn) error

+ func (t *Table) DropPrimaryKey(ctx *sql.Context) error

+ func (t *Table) GetNextAutoIncrementValue(ctx *sql.Context, insertVal interface{}) (interface{}, error)

+ func (t *Table) PeekNextAutoIncrementValue(*sql.Context) (interface{}, error)

v0.10.0

Jun 2, 2021

Changes in this version

+ type FilteredTable struct

+ func NewFilteredTable(name string, schema sql.Schema) *FilteredTable

+ func (t *FilteredTable) WithFilters(filters []sql.Expression) sql.Table

+ func (t *FilteredTable) WithProjection(colNames []string) sql.Table

type MergeableIndex

+ func (i *MergeableIndex) IsGenerated() bool

type Table

+ func (t *Table) Filters() []sql.Expression

+ func (t *Table) WithProjection(colNames []string) sql.Table

v0.9.0

Apr 2, 2021

Changes in this version

+ func EncodeIndexValue(value *IndexValue) ([]byte, error)

type Database

+ func (d *Database) DropStoredProcedure(ctx *sql.Context, name string) error

+ func (d *Database) GetStoredProcedures(ctx *sql.Context) ([]sql.StoredProcedureDetails, error)

+ func (d *Database) SaveStoredProcedure(ctx *sql.Context, spd sql.StoredProcedureDetails) error

+ type IndexValue struct

+ Key string

+ Pos int

+ func DecodeIndexValue(data []byte) (*IndexValue, error)

+ type Partition struct

+ func NewPartition(key []byte) *Partition

+ func (p *Partition) Key() []byte

type Table

+ func (t *Table) CreateCheck(_ *sql.Context, check *sql.CheckDefinition) error

+ func (t *Table) DataLength(ctx *sql.Context) (uint64, error)

+ func (t *Table) DropCheck(ctx *sql.Context, chName string) error

+ func (t *Table) GetChecks(_ *sql.Context) ([]sql.CheckDefinition, error)

+ func (t *Table) GetPartition(key string) []sql.Row

+ func (t *Table) NumRows(ctx *sql.Context) (uint64, error)

v0.8.0

Feb 1, 2021

Changes in this version

+ const IndexDriverId

+ type AscendIndexLookup struct

+ Gte []interface{}

+ Index ExpressionsIndex

+ Lt []interface{}

+ func (l *AscendIndexLookup) EvalExpression() sql.Expression

+ func (l *AscendIndexLookup) ID() string

+ func (l *AscendIndexLookup) Indexes() []string

+ func (l *AscendIndexLookup) Intersection(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *AscendIndexLookup) IsMergeable(lookup sql.IndexLookup) bool

+ func (l *AscendIndexLookup) String() string

+ func (l *AscendIndexLookup) Union(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *AscendIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

+ type Database struct

+ func NewDatabase(name string) *Database

+ func (d *Database) AddTable(name string, t sql.Table)

+ func (d *Database) CreateTable(ctx *sql.Context, name string, schema sql.Schema) error

+ func (d *Database) CreateTrigger(ctx *sql.Context, definition sql.TriggerDefinition) error

+ func (d *Database) DropTable(ctx *sql.Context, name string) error

+ func (d *Database) DropTrigger(ctx *sql.Context, name string) error

+ func (d *Database) EnablePrimaryKeyIndexes()

+ func (d *Database) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error)

+ func (d *Database) GetTableNames(ctx *sql.Context) ([]string, error)

+ func (d *Database) GetTriggers(ctx *sql.Context) ([]sql.TriggerDefinition, error)

+ func (d *Database) Name() string

+ func (d *Database) RenameTable(ctx *sql.Context, oldName, newName string) error

+ func (d *Database) Tables() map[string]sql.Table

+ type DescendIndexLookup struct

+ Gt []interface{}

+ Index ExpressionsIndex

+ Lte []interface{}

+ func (l *DescendIndexLookup) EvalExpression() sql.Expression

+ func (l *DescendIndexLookup) ID() string

+ func (l *DescendIndexLookup) Indexes() []string

+ func (l *DescendIndexLookup) Intersection(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *DescendIndexLookup) IsMergeable(lookup sql.IndexLookup) bool

+ func (l *DescendIndexLookup) String() string

+ func (l *DescendIndexLookup) Union(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *DescendIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

+ type ExpressionsIndex interface

+ ColumnExpressions func() []sql.Expression

+ MemTable func() *Table

+ type HistoryDatabase struct

+ Revisions map[string]map[interface{}]sql.Table

+ func NewHistoryDatabase(name string) *HistoryDatabase

+ func (db *HistoryDatabase) AddTableAsOf(name string, t sql.Table, asOf interface{})

+ func (db *HistoryDatabase) GetTableInsensitiveAsOf(ctx *sql.Context, tblName string, time interface{}) (sql.Table, bool, error)

+ func (db *HistoryDatabase) GetTableNamesAsOf(ctx *sql.Context, time interface{}) ([]string, error)

+ type MergeableIndex struct

+ CommentStr string

+ DB string

+ DriverName string

+ Exprs []sql.Expression

+ Name string

+ TableName string

+ Tbl *Table

+ Unique bool

+ func (i *MergeableIndex) AscendGreaterOrEqual(keys ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) AscendLessThan(keys ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) AscendRange(greaterOrEqual, lessThan []interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) ColumnExpressions() []sql.Expression

+ func (i *MergeableIndex) Comment() string

+ func (i *MergeableIndex) Database() string

+ func (i *MergeableIndex) DescendGreater(keys ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) DescendLessOrEqual(keys ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) DescendRange(lessOrEqual, greaterThan []interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) Driver() string

+ func (i *MergeableIndex) Expressions() []string

+ func (i *MergeableIndex) Get(key ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) Has(sql.Partition, ...interface{}) (bool, error)

+ func (i *MergeableIndex) ID() string

+ func (i *MergeableIndex) IndexType() string

+ func (i *MergeableIndex) IsUnique() bool

+ func (i *MergeableIndex) MemTable() *Table

+ func (i *MergeableIndex) Not(keys ...interface{}) (sql.IndexLookup, error)

+ func (i *MergeableIndex) Table() string

+ type MergeableIndexLookup struct

+ Index ExpressionsIndex

+ Key []interface{}

+ func (i *MergeableIndexLookup) EvalExpression() sql.Expression

+ func (i *MergeableIndexLookup) ID() string

+ func (i *MergeableIndexLookup) Indexes() []string

+ func (i *MergeableIndexLookup) Intersection(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (i *MergeableIndexLookup) IsMergeable(lookup sql.IndexLookup) bool

+ func (i *MergeableIndexLookup) String() string

+ func (i *MergeableIndexLookup) Union(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (i *MergeableIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

+ type MergeableLookup interface

+ ID func() string

+ type MergedIndexLookup struct

+ Index ExpressionsIndex

+ Intersections []sql.IndexLookup

+ Unions []sql.IndexLookup

+ func (m *MergedIndexLookup) EvalExpression() sql.Expression

+ func (m *MergedIndexLookup) ID() string

+ func (m *MergedIndexLookup) Indexes() []string

+ func (m *MergedIndexLookup) Intersection(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (m *MergedIndexLookup) IsMergeable(lookup sql.IndexLookup) bool

+ func (m *MergedIndexLookup) String() string

+ func (m *MergedIndexLookup) Union(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (m *MergedIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

+ type NegateIndexLookup struct

+ Index ExpressionsIndex

+ Lookup MergeableLookup

+ func (*NegateIndexLookup) IsMergeable(lookup sql.IndexLookup) bool

+ func (l *NegateIndexLookup) EvalExpression() sql.Expression

+ func (l *NegateIndexLookup) ID() string

+ func (l *NegateIndexLookup) Indexes() []string

+ func (l *NegateIndexLookup) Intersection(indexes ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *NegateIndexLookup) String() string

+ func (l *NegateIndexLookup) Union(lookups ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (l *NegateIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

+ type PushdownTable struct

+ func NewPartitionedPushdownTable(name string, schema sql.Schema, numPartitions int) *PushdownTable

+ func NewPushdownTable(name string, schema sql.Schema) *PushdownTable

+ func (t *PushdownTable) DebugString() string

+ func (t *PushdownTable) Filters() []sql.Expression

+ func (t *PushdownTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (t *PushdownTable) Projection() []string

+ func (t *PushdownTable) String() string

+ func (t *PushdownTable) WithFilters(filters []sql.Expression) sql.Table

+ func (t *PushdownTable) WithIndexLookup(lookup sql.IndexLookup) sql.Table

+ func (t *PushdownTable) WithProjection(colNames []string) sql.Table

+ type Table struct

+ func NewPartitionedTable(name string, schema sql.Schema, numPartitions int) *Table

+ func NewTable(name string, schema sql.Schema) *Table

+ func (t *Table) AddColumn(ctx *sql.Context, column *sql.Column, order *sql.ColumnOrder) error

+ func (t *Table) AutoIncrementSetter(*sql.Context) sql.AutoIncrementSetter

+ func (t *Table) CreateForeignKey(_ *sql.Context, fkName string, columns []string, referencedTable string, ...) error

+ func (t *Table) CreateIndex(ctx *sql.Context, indexName string, using sql.IndexUsing, ...) error

+ func (t *Table) DebugString() string

+ func (t *Table) Deleter(*sql.Context) sql.RowDeleter

+ func (t *Table) DropColumn(ctx *sql.Context, columnName string) error

+ func (t *Table) DropForeignKey(ctx *sql.Context, fkName string) error

+ func (t *Table) DropIndex(ctx *sql.Context, indexName string) error

+ func (t *Table) EnablePrimaryKeyIndexes()

+ func (t *Table) GetAutoIncrementValue(*sql.Context) (interface{}, error)

+ func (t *Table) GetForeignKeys(_ *sql.Context) ([]sql.ForeignKeyConstraint, error)

+ func (t *Table) GetIndexes(ctx *sql.Context) ([]sql.Index, error)

+ func (t *Table) HandledFilters(filters []sql.Expression) []sql.Expression

+ func (t *Table) IndexKeyValues(ctx *sql.Context, colNames []string) (sql.PartitionIndexKeyValueIter, error)

+ func (t *Table) Insert(ctx *sql.Context, row sql.Row) error

+ func (t *Table) Inserter(*sql.Context) sql.RowInserter

+ func (t *Table) ModifyColumn(ctx *sql.Context, columnName string, column *sql.Column, ...) error

+ func (t *Table) Name() string

+ func (t *Table) PartitionCount(ctx *sql.Context) (int64, error)

+ func (t *Table) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (t *Table) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (t *Table) RenameIndex(ctx *sql.Context, fromIndexName string, toIndexName string) error

+ func (t *Table) Replacer(*sql.Context) sql.RowReplacer

+ func (t *Table) Schema() sql.Schema

+ func (t *Table) String() string

+ func (t *Table) Truncate(ctx *sql.Context) (int, error)

+ func (t *Table) Updater(*sql.Context) sql.RowUpdater

+ func (t *Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table

+ type TestIndexDriver struct

+ func NewIndexDriver(db string, indexes map[string][]sql.DriverIndex) *TestIndexDriver

+ func (d *TestIndexDriver) Create(db, table, id string, expressions []sql.Expression, config map[string]string) (sql.DriverIndex, error)

+ func (d *TestIndexDriver) Delete(sql.DriverIndex, sql.PartitionIter) error

+ func (d *TestIndexDriver) ID() string

+ func (d *TestIndexDriver) LoadAll(ctx *sql.Context, db, table string) ([]sql.DriverIndex, error)

+ func (d *TestIndexDriver) Save(*sql.Context, sql.DriverIndex, sql.PartitionIndexKeyValueIter) error

+ type UnmergeableIndex struct

+ func (u *UnmergeableIndex) Get(key ...interface{}) (sql.IndexLookup, error)

+ func (u *UnmergeableIndex) Has(partition sql.Partition, key ...interface{}) (bool, error)

+ func (u *UnmergeableIndex) Table() string

+ type UnmergeableIndexLookup struct

+ func (u *UnmergeableIndexLookup) Indexes() []string

+ func (u *UnmergeableIndexLookup) Intersection(_ ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (u *UnmergeableIndexLookup) IsMergeable(_ sql.IndexLookup) bool

+ func (u *UnmergeableIndexLookup) String() string

+ func (u *UnmergeableIndexLookup) Union(_ ...sql.IndexLookup) (sql.IndexLookup, error)

+ func (u *UnmergeableIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL