memory

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const CommentPreventingIndexBuilding = "__FOR TESTING: I cannot be built__"
View Source 
const DualTableName = ""
View Source 
const IndexDriverId = "MemoryIndexDriver"

Variables

View Source 
var DualTableSchema = sql.NewPrimaryKeySchema(sql.Schema{
	{Name: "", Source: DualTableName, Type: types.LongText, Nullable: false},
})
View Source 
var (
	ExternalStoredProcedures = []sql.ExternalStoredProcedureDetails{
		{
			Name:     "memory_inout_add",
			Schema:   nil,
			Function: inout_add,
		},
		{
			Name:     "memory_inout_set_unitialized",
			Schema:   nil,
			Function: inout_set_unitialized,
		},
		{
			Name:     "memory_overloaded_mult",
			Schema:   externalSPSchemaInt,
			Function: overloaded_mult1,
		},
		{
			Name:     "memory_overloaded_mult",
			Schema:   externalSPSchemaInt,
			Function: overloaded_mult2,
		},
		{
			Name:     "memory_overloaded_mult",
			Schema:   externalSPSchemaInt,
			Function: overloaded_mult3,
		},
		{
			Name:     "memory_overloaded_type_test",
			Schema:   externalSPSchemaInt,
			Function: overloaded_type_test1,
		},
		{
			Name:     "memory_overloaded_type_test",
			Schema:   externalSPSchemaText,
			Function: overloaded_type_test2,
		},
		{
			Name:     "memory_type_test3",
			Schema:   externalSPSchemaUint,
			Function: type_test3,
		},
		{
			Name:     "memory_inout_bool_byte",
			Schema:   nil,
			Function: inout_bool_byte,
		},
		{
			Name:     "memory_error_table_not_found",
			Schema:   nil,
			Function: error_table_not_found,
		},
		{
			Name:     "memory_variadic_add",
			Schema:   externalSPSchemaInt,
			Function: variadic_add,
		},
		{
			Name:     "memory_variadic_byte_slice",
			Schema:   externalSPSchemaText,
			Function: variadic_byte_slice,
		},
		{
			Name:     "memory_variadic_overload",
			Schema:   externalSPSchemaText,
			Function: variadic_overload1,
		},
		{
			Name:     "memory_variadic_overload",
			Schema:   externalSPSchemaText,
			Function: variadic_overload2,
		},
		{
			Name:     "memory_inout_add_readonly",
			Schema:   externalSPSchemaInt,
			Function: variadic_add,
			ReadOnly: true,
		},
		{
			Name:     "memory_inout_add_readwrite",
			Schema:   externalSPSchemaInt,
			Function: variadic_add,
			ReadOnly: false,
		},
		{
			Name:      "memory_admin_only",
			Schema:    externalSPSchemaInt,
			Function:  variadic_add,
			ReadOnly:  false,
			AdminOnly: true,
		},
	}
)

Functions

func EncodeIndexValue 

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

func NewDBProviderWithOpts 

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

NewDBProviderWithOpts creates a new DbProvider with the given options and no databases

func NewSessionBuilder 

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

NewSessionBuilder returns a session for the given in-memory database provider suitable to use in a test server This can't be defined as server.SessionBuilder because importing it would create a circular dependency, but it's the same signature.

Types

type BaseDatabase 

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

BaseDatabase is an in-memory database that can't store views, only for testing the engine

func NewViewlessDatabase 

func NewViewlessDatabase(name string) *BaseDatabase

NewViewlessDatabase creates a new database that doesn't persist views. Used only for testing. Use NewDatabase.

func (*BaseDatabase) AddTable 

func (d *BaseDatabase) AddTable(name string, t MemTable)

AddTable adds a new table to the database.

func (*BaseDatabase) CreateFulltextTableNames 

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

func (*BaseDatabase) CreateIndexedTable 

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

CreateIndexedTable creates a table with the given name and schema

func (*BaseDatabase) CreateTable 

func (d *BaseDatabase) CreateTable(ctx *sql.Context, name string, schema sql.PrimaryKeySchema, collation sql.CollationID, comment string) error

CreateTable creates a table with the given name and schema

func (*BaseDatabase) CreateTrigger 

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

func (*BaseDatabase) Database 

func (d *BaseDatabase) Database() *BaseDatabase

func (*BaseDatabase) DeleteTable 

func (d *BaseDatabase) DeleteTable(name string)

DeleteTable deletes a table from the database.

func (*BaseDatabase) DropEvent 

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

DropEvent implements sql.EventDatabase

func (*BaseDatabase) DropStoredProcedure 

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

DropStoredProcedure implements sql.StoredProcedureDatabase

func (*BaseDatabase) DropTable 

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

DropTable drops the table with the given name

func (*BaseDatabase) DropTrigger 

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

func (*BaseDatabase) EnablePrimaryKeyIndexes 

func (d *BaseDatabase) EnablePrimaryKeyIndexes()

EnablePrimaryKeyIndexes causes every table created in this database to use an index on its primary partitionKeys

func (*BaseDatabase) GetCollation 

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

GetCollation implements sql.CollatedDatabase.

func (*BaseDatabase) GetEvent 

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

GetEvent implements sql.EventDatabase

func (*BaseDatabase) GetEvents 

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

GetEvents implements sql.EventDatabase

func (*BaseDatabase) GetForeignKeyCollection 

func (d *BaseDatabase) GetForeignKeyCollection() *ForeignKeyCollection

func (*BaseDatabase) GetStoredProcedure 

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

GetStoredProcedure implements sql.StoredProcedureDatabase

func (*BaseDatabase) GetStoredProcedures 

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

GetStoredProcedures implements sql.StoredProcedureDatabase

func (*BaseDatabase) GetTableInsensitive 

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

func (*BaseDatabase) GetTableNames 

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

func (*BaseDatabase) GetTriggers 

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

func (*BaseDatabase) Name 

func (d *BaseDatabase) Name() string

Name returns the database name.

func (*BaseDatabase) RenameTable 

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

func (*BaseDatabase) SaveEvent 

func (d *BaseDatabase) SaveEvent(_ *sql.Context, event sql.EventDefinition) (bool, error)

SaveEvent implements sql.EventDatabase

func (*BaseDatabase) SaveStoredProcedure 

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

SaveStoredProcedure implements sql.StoredProcedureDatabase

func (*BaseDatabase) SetCollation 

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

SetCollation implements sql.CollatedDatabase.

func (*BaseDatabase) Tables 

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

Tables returns all tables in the database.

func (*BaseDatabase) UpdateEvent 

func (d *BaseDatabase) UpdateEvent(_ *sql.Context, originalName string, event sql.EventDefinition) (bool, error)

UpdateEvent implements sql.EventDatabase

func (*BaseDatabase) UpdateLastExecuted 

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

UpdateLastExecuted implements sql.EventDatabase

func (*BaseDatabase) ValidateSchema 

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

ValidateSchema implements sql.SchemaValidator

type Database 

type Database struct {
	*BaseDatabase
	// contains filtered or unexported fields
}

Database is an in-memory database.

func NewDatabase 

func NewDatabase(name string) *Database

NewDatabase creates a new database with the given name.

func (*Database) AllViews 

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

AllViews implements the interface sql.ViewDatabase.

func (*Database) CreateView 

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

CreateView implements the interface sql.ViewDatabase.

func (*Database) Database 

func (d *Database) Database() *BaseDatabase

func (*Database) DropView 

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

DropView implements the interface sql.ViewDatabase.

func (*Database) GetViewDefinition 

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

GetViewDefinition implements the interface sql.ViewDatabase.

func (*Database) NeedsToReloadEvents 

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

NeedsToReloadEvents implements sql.EventDatabase

type DbProvider 

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

DbProvider is a provider for in-memory databases

func NewDBProvider 

func NewDBProvider(dbs ...sql.Database) *DbProvider

NewDBProvider creates a new DbProvider with the default options and the databases specified

func (*DbProvider) AllDatabases 

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

AllDatabases returns the Database with the given name if it exists.

func (*DbProvider) CreateDatabase 

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

CreateDatabase implements MutableDatabaseProvider.

func (*DbProvider) Database 

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

Database returns the Database with the given name if it exists.

func (*DbProvider) DropDatabase 

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

DropDatabase implements MutableDatabaseProvider.

func (*DbProvider) ExternalStoredProcedure 

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

ExternalStoredProcedure implements sql.ExternalStoredProcedureProvider

func (*DbProvider) ExternalStoredProcedures 

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

ExternalStoredProcedures implements sql.ExternalStoredProcedureProvider

func (*DbProvider) HasDatabase 

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

HasDatabase returns the Database with the given name if it exists.

func (*DbProvider) TableFunction 

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

TableFunction implements sql.TableFunctionProvider

func (*DbProvider) WithOption 

func (pro *DbProvider) WithOption(opt ProviderOption)

WithOption modifies the provider with the given option

func (*DbProvider) WithTableFunctions 

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

type ExponentialDistTable 

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

ExponentialDistTable a simple table function that returns samples from a parameterized exponential distribution.

func (ExponentialDistTable) CheckPrivileges 

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

func (ExponentialDistTable) Children 

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

func (ExponentialDistTable) Collation 

func (ExponentialDistTable) Collation() sql.CollationID

Collation implements the sql.Table interface.

func (ExponentialDistTable) CollationCoercibility 

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

CollationCoercibility implements the interface sql.CollationCoercible.

func (ExponentialDistTable) Database 

func (s ExponentialDistTable) Database() sql.Database

func (ExponentialDistTable) DebugString 

func (s ExponentialDistTable) DebugString() string

func (ExponentialDistTable) Description 

func (s ExponentialDistTable) Description() string

func (ExponentialDistTable) Expressions 

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

func (ExponentialDistTable) IsReadOnly 

func (s ExponentialDistTable) IsReadOnly() bool

func (ExponentialDistTable) Name 

func (s ExponentialDistTable) Name() string

func (ExponentialDistTable) NewInstance 

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

func (ExponentialDistTable) PartitionRows 

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

PartitionRows is a sql.Table interface function that takes a partition and returns all rows in that partition. This table has a partition for just schema changes, one for just data changes, and one for both.

func (ExponentialDistTable) Partitions 

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

Partitions is a sql.Table interface function that returns a partition of the data. This data has a single partition.

func (ExponentialDistTable) Resolved 

func (s ExponentialDistTable) Resolved() bool

func (ExponentialDistTable) RowIter 

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

func (ExponentialDistTable) Schema 

func (s ExponentialDistTable) Schema() sql.Schema

func (ExponentialDistTable) String 

func (s ExponentialDistTable) String() string

func (ExponentialDistTable) UnderlyingTable 

func (s ExponentialDistTable) UnderlyingTable() sql.Table

func (ExponentialDistTable) WithChildren 

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

func (ExponentialDistTable) WithDatabase 

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

func (ExponentialDistTable) WithExpressions 

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

type ExpressionsIndex 

type ExpressionsIndex interface {
	sql.Index
	MemTable() *Table
	ColumnExpressions() []sql.Expression
}

ExpressionsIndex is an index made out of one or more expressions (usually field expressions), linked to a Table.

type FilteredTable 

type FilteredTable struct {
	*Table
}

FilteredTable functionality in the Table type was disabled for a long period of time, and has developed major issues with the current analyzer logic. It's only used in the pushdown unit tests, and sql.FilteredTable should be considered unstable until this situation is fixed.

func NewFilteredTable 

func NewFilteredTable(db MemoryDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection) *FilteredTable

func (*FilteredTable) Projections 

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

Projections implements sql.ProjectedTable

func (*FilteredTable) WithFilters 

func (t *FilteredTable) WithFilters(ctx *sql.Context, filters []sql.Expression) sql.Table

WithFilters implements the sql.FilteredTable interface.

func (*FilteredTable) WithProjections 

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

WithProjections implements sql.ProjectedTable

type ForeignKeyCollection 

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

ForeignKeyCollection is a shareable container for a collection of foreign keys.

func (*ForeignKeyCollection) AddFK 

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

AddFK adds the given foreign key to the internal slice.

func (*ForeignKeyCollection) DropFK 

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

DropFK removes the given foreign key from the internal slice. Returns true if the foreign key was found.

func (*ForeignKeyCollection) Keys 

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

Keys returns all of the foreign keys.

func (*ForeignKeyCollection) SetResolved 

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

SetResolved sets the given foreign key as being resolved.

type GlobalsMap 

type GlobalsMap = map[string]interface{}

type HistoryDatabase 

type HistoryDatabase struct {
	*Database
	Revisions map[string]map[interface{}]sql.Table
	// contains filtered or unexported fields
}

HistoryDatabase is a test-only VersionedDatabase implementation. It only supports exact lookups, not AS OF queries between two revisions. It's constructed just like its non-versioned sibling, but it can receive updates to particular tables via the AddTableAsOf method. Consecutive calls to AddTableAsOf with the same table must install new versions of the named table each time, with ascending version identifiers, for this to work.

func NewHistoryDatabase 

func NewHistoryDatabase(name string) *HistoryDatabase

func (*HistoryDatabase) AddTableAsOf 

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

Adds a table with an asOf revision key. The table given becomes the current version for the name given.

func (*HistoryDatabase) GetTableInsensitiveAsOf 

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

func (*HistoryDatabase) GetTableNamesAsOf 

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

type Index 

type Index struct {
	DB         string // required for engine tests with driver
	DriverName string // required for engine tests with driver
	Tbl        *Table // required for engine tests with driver
	TableName  string
	Exprs      []sql.Expression
	Name       string
	Unique     bool
	Spatial    bool
	Fulltext   bool
	CommentStr string
	PrefixLens []uint16
	// contains filtered or unexported fields
}

func (*Index) CanSupport 

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

func (*Index) ColumnExpressionTypes 

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

ColumnExpressionTypes implements the interface sql.Index.

func (*Index) ColumnExpressions 

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

func (*Index) Comment 

func (idx *Index) Comment() string

func (*Index) Database 

func (idx *Index) Database() string

func (*Index) Driver 

func (idx *Index) Driver() string

func (*Index) Expressions 

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

func (*Index) ExtendedColumnExpressionTypes 

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

func (*Index) ExtendedExpressions 

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

func (*Index) ExtendedExprs 

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

ExtendedExprs returns the same information as ExtendedExpressions, but in sql.Expression form.

func (*Index) FullTextKeyColumns 

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

func (*Index) FullTextTableNames 

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

func (*Index) HandledFilters 

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

func (*Index) ID 

func (idx *Index) ID() string

func (*Index) IndexType 

func (idx *Index) IndexType() string

func (*Index) IsFullText 

func (idx *Index) IsFullText() bool

func (*Index) IsGenerated 

func (idx *Index) IsGenerated() bool

func (*Index) IsSpatial 

func (idx *Index) IsSpatial() bool

func (*Index) IsUnique 

func (idx *Index) IsUnique() bool

func (*Index) MemTable 

func (idx *Index) MemTable() *Table

func (*Index) Order 

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

func (*Index) PrefixLengths 

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

func (*Index) Reversible 

func (idx *Index) Reversible() bool

func (*Index) Table 

func (idx *Index) Table() string

type IndexValue 

type IndexValue struct {
	Key string
	Pos int
}

func DecodeIndexValue 

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

type IndexedTable 

type IndexedTable struct {
	*Table
	Lookup sql.IndexLookup
}

IndexedTable is a table that expects to return one or more partitions for range lookups.

func (*IndexedTable) LookupPartitions 

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

func (*IndexedTable) PartitionRows 

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

PartitionRows implements the sql.PartitionRows interface.

type IntSequenceTable 

type IntSequenceTable struct {
	Len int64
	// contains filtered or unexported fields
}

IntSequenceTable a simple table function that returns a sequence of integers.

func (IntSequenceTable) CheckPrivileges 

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

func (IntSequenceTable) Children 

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

func (IntSequenceTable) Collation 

func (IntSequenceTable) Collation() sql.CollationID

Collation implements the sql.Table interface.

func (IntSequenceTable) CollationCoercibility 

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

CollationCoercibility implements the interface sql.CollationCoercible.

func (IntSequenceTable) Database 

func (s IntSequenceTable) Database() sql.Database

func (IntSequenceTable) DebugString 

func (s IntSequenceTable) DebugString() string

func (IntSequenceTable) Description 

func (s IntSequenceTable) Description() string

func (IntSequenceTable) Expressions 

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

func (IntSequenceTable) GetIndexes 

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

func (IntSequenceTable) IndexedAccess 

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

func (IntSequenceTable) IsReadOnly 

func (s IntSequenceTable) IsReadOnly() bool

func (IntSequenceTable) LookupPartitions 

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

LookupPartitions is a sql.IndexedTable interface function that takes an index lookup and returns the set of corresponding partitions.

func (IntSequenceTable) Name 

func (s IntSequenceTable) Name() string

func (IntSequenceTable) NewInstance 

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

func (IntSequenceTable) PartitionRows 

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

PartitionRows is a sql.Table interface function that takes a partition and returns all rows in that partition. This table has a partition for just schema changes, one for just data changes, and one for both.

func (IntSequenceTable) Partitions 

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

Partitions is a sql.Table interface function that returns a partition of the data. This data has a single partition.

func (IntSequenceTable) PreciseMatch 

func (s IntSequenceTable) PreciseMatch() bool

func (IntSequenceTable) Resolved 

func (s IntSequenceTable) Resolved() bool

func (IntSequenceTable) RowIter 

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

func (IntSequenceTable) Schema 

func (s IntSequenceTable) Schema() sql.Schema

func (IntSequenceTable) String 

func (s IntSequenceTable) String() string

func (IntSequenceTable) UnderlyingTable 

func (s IntSequenceTable) UnderlyingTable() sql.Table

func (IntSequenceTable) WithChildren 

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

func (IntSequenceTable) WithDatabase 

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

func (IntSequenceTable) WithExpressions 

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

type MemTable 

type MemTable interface {
	sql.Table
	IgnoreSessionData() bool
	UnderlyingTable() *Table
}

type MemoryDatabase 

type MemoryDatabase interface {
	sql.Database
	AddTable(name string, t MemTable)
	DeleteTable(name string)
	Database() *BaseDatabase
}

type NormalDistTable 

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

NormalDistTable a simple table function that returns samples from a parameterized normal distribution.

func (NormalDistTable) CheckPrivileges 

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

func (NormalDistTable) Children 

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

func (NormalDistTable) Collation 

func (NormalDistTable) Collation() sql.CollationID

Collation implements the sql.Table interface.

func (NormalDistTable) CollationCoercibility 

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

CollationCoercibility implements the interface sql.CollationCoercible.

func (NormalDistTable) Database 

func (s NormalDistTable) Database() sql.Database

func (NormalDistTable) DebugString 

func (s NormalDistTable) DebugString() string

func (NormalDistTable) Description 

func (s NormalDistTable) Description() string

func (NormalDistTable) Expressions 

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

func (NormalDistTable) IsReadOnly 

func (s NormalDistTable) IsReadOnly() bool

func (NormalDistTable) Name 

func (s NormalDistTable) Name() string

func (NormalDistTable) NewInstance 

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

func (NormalDistTable) PartitionRows 

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

PartitionRows is a sql.Table interface function that takes a partition and returns all rows in that partition. This table has a partition for just schema changes, one for just data changes, and one for both.

func (NormalDistTable) Partitions 

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

Partitions is a sql.Table interface function that returns a partition of the data. This data has a single partition.

func (NormalDistTable) Resolved 

func (s NormalDistTable) Resolved() bool

func (NormalDistTable) RowIter 

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

func (NormalDistTable) Schema 

func (s NormalDistTable) Schema() sql.Schema

func (NormalDistTable) String 

func (s NormalDistTable) String() string

func (NormalDistTable) UnderlyingTable 

func (s NormalDistTable) UnderlyingTable() sql.Table

func (NormalDistTable) WithChildren 

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

func (NormalDistTable) WithDatabase 

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

func (NormalDistTable) WithExpressions 

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

type Partition 

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

func NewPartition 

func NewPartition(key []byte) *Partition

func (*Partition) Key 

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

type PointLookupTable 

type PointLookupTable struct {
	IntSequenceTable
}

PointLookupTable is a table whose indexes only support point lookups but not range scans. It's used for testing optimizations on indexes.

func (PointLookupTable) DebugString 

func (s PointLookupTable) DebugString() string

func (PointLookupTable) Description 

func (s PointLookupTable) Description() string

func (PointLookupTable) GetIndexes 

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

func (PointLookupTable) Name 

func (s PointLookupTable) Name() string

func (PointLookupTable) NewInstance 

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

func (PointLookupTable) PreciseMatch 

func (s PointLookupTable) PreciseMatch() bool

func (PointLookupTable) String 

func (s PointLookupTable) String() string

func (PointLookupTable) UnderlyingTable 

func (s PointLookupTable) UnderlyingTable() sql.Table

type ProviderOption 

type ProviderOption func(*DbProvider)

func HistoryProvider 

func HistoryProvider(enableHistory bool) ProviderOption

HistoryProvider returns a ProviderOption to construct a memoryDBProvider that uses history databases

func NativeIndexProvider 

func NativeIndexProvider(useNativeIndexes bool) ProviderOption

func ReadOnlyProvider 

func ReadOnlyProvider(enableReadOnly bool) ProviderOption

ReadOnlyProvider returns a ProviderOption to construct a memoryDBProvider that is read-only

func WithDbsOption 

func WithDbsOption(dbs []sql.Database) ProviderOption

WithDbsOption returns a ProviderOption to construct a DbProvider with the given databases

type ReadOnlyDatabase 

type ReadOnlyDatabase struct {
	*HistoryDatabase
}

func NewReadOnlyDatabase 

func NewReadOnlyDatabase(name string) ReadOnlyDatabase

func (ReadOnlyDatabase) IsReadOnly 

func (d ReadOnlyDatabase) IsReadOnly() bool

type RequiredLookupTable 

type RequiredLookupTable struct {
	IntSequenceTable
	// contains filtered or unexported fields
}

RequiredLookupTable is a table that will error if not executed as an index lookup

func (RequiredLookupTable) Database 

func (s RequiredLookupTable) Database() sql.Database

func (RequiredLookupTable) DebugString 

func (s RequiredLookupTable) DebugString() string

func (RequiredLookupTable) Description 

func (s RequiredLookupTable) Description() string

func (RequiredLookupTable) Expressions 

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

func (RequiredLookupTable) GetIndexes 

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

func (RequiredLookupTable) IndexedAccess 

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

func (RequiredLookupTable) Name 

func (s RequiredLookupTable) Name() string

func (RequiredLookupTable) NewInstance 

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

func (RequiredLookupTable) PartitionRows 

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

func (RequiredLookupTable) Partitions 

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

Partitions is a sql.Table interface function that returns a partition of the data. This data has a single partition.

func (RequiredLookupTable) PreciseMatch 

func (s RequiredLookupTable) PreciseMatch() bool

func (RequiredLookupTable) RequiredPredicates 

func (s RequiredLookupTable) RequiredPredicates() []string

func (RequiredLookupTable) RowIter 

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

func (RequiredLookupTable) String 

func (s RequiredLookupTable) String() string

func (RequiredLookupTable) UnderlyingTable 

func (s RequiredLookupTable) UnderlyingTable() sql.Table

func (RequiredLookupTable) WithChildren 

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

func (RequiredLookupTable) WithDatabase 

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

func (RequiredLookupTable) WithExpressions 

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

type SequenceTableFnRowIter 

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

func (*SequenceTableFnRowIter) Close 

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

func (*SequenceTableFnRowIter) Next 

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

type Session 

type Session struct {
	*sql.BaseSession
	// contains filtered or unexported fields
}

func NewSession 

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

NewSession returns the new session for this object

func SessionFromContext 

func SessionFromContext(ctx *sql.Context) *Session

func (*Session) CommitTransaction 

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

func (*Session) CreateSavepoint 

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

func (*Session) GetPersistedValue 

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

GetPersistedValue implements sql.PersistableSession

func (*Session) PersistGlobal 

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

PersistGlobal implements sql.PersistableSession

func (*Session) ReleaseSavepoint 

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

func (*Session) RemoveAllPersistedGlobals 

func (s *Session) RemoveAllPersistedGlobals() error

RemoveAllPersistedGlobals implements sql.PersistableSession

func (*Session) RemovePersistedGlobal 

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

RemovePersistedGlobal implements sql.PersistableSession

func (*Session) Rollback 

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

func (*Session) RollbackToSavepoint 

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

func (*Session) SetGlobals 

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

func (*Session) SetValidationCallback 

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

func (*Session) StartTransaction 

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

StartTransaction clears session state and returns a new transaction object. Because we don't support concurrency, we store table data changes in the session, rather than the transaction itself.

func (*Session) ValidateSession 

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

ValidateSession counts the number of times this method is called.

type StatsProv 

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

func NewStatsProv 

func NewStatsProv() *StatsProv

func (*StatsProv) DataLength 

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

func (*StatsProv) DropDbStats 

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

func (*StatsProv) DropStats 

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

func (*StatsProv) GetStats 

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

func (*StatsProv) GetTableStats 

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

func (*StatsProv) RefreshTableStats 

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

func (*StatsProv) RowCount 

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

func (*StatsProv) SetStats 

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

type Table 

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

Table represents an in-memory database table.

func NewDualTable 

func NewDualTable() *Table

NewDualTable creates the dual table, which is used by the engine for queries with no tables specified, or the `dual` table specified. This table is never supplied by integrators, but always by this stand-in implementation.

func NewLocalTable 

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

NewLocalTable returns a table suitable to use for transient non-memory applications

func NewPartitionedTable 

func NewPartitionedTable(db *BaseDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, numPartitions int) *Table

NewPartitionedTable creates a new Table with the given name, schema and number of partitions. Assigns the default collation, therefore if a different collation is desired, please use NewPartitionedTableWithCollation.

func NewPartitionedTableWithCollation 

func NewPartitionedTableWithCollation(db *BaseDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, numPartitions int, collation sql.CollationID, comment string) *Table

NewPartitionedTableWithCollation creates a new Table with the given name, schema, number of partitions, collation, and comment.

func NewTable 

func NewTable(db MemoryDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection) *Table

NewTable creates a new Table with the given name and schema. Assigns the default collation, therefore if a different collation is desired, please use NewTableWithCollation.

func NewTableWithCollation 

func NewTableWithCollation(db *BaseDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, collation sql.CollationID) *Table

NewTableWithCollation creates a new Table with the given name, schema, and collation.

func (*Table) AddColumn 

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

func (*Table) AddForeignKey 

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

AddForeignKey implements sql.ForeignKeyTable. Foreign partitionKeys are not enforced on update / delete.

func (*Table) AutoIncrementSetter 

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

func (*Table) BuildIndex 

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

func (*Table) Collation 

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

Collation implements the sql.Table interface.

func (*Table) Comment 

func (t *Table) Comment() string

Comment implements the sql.CommentedTable interface.

func (*Table) CreateCheck 

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

CreateCheck implements sql.CheckAlterableTable

func (*Table) CreateFulltextIndex 

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

CreateFulltextIndex implements fulltext.IndexAlterableTable

func (*Table) CreateIndex 

func (t *Table) CreateIndex(ctx *sql.Context, idx sql.IndexDef) error

CreateIndex implements sql.IndexAlterableTable

func (*Table) CreateIndexForForeignKey 

func (t *Table) CreateIndexForForeignKey(ctx *sql.Context, idx sql.IndexDef) error

CreateIndexForForeignKey implements sql.ForeignKeyTable.

func (*Table) CreatePrimaryKey 

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

CreatePrimaryKey implements the PrimaryKeyAlterableTable

func (*Table) DataLength 

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

func (*Table) Database 

func (t *Table) Database() string

func (*Table) DebugString 

func (t *Table) DebugString() string

func (*Table) Deleter 

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

func (*Table) DropCheck 

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

DropCheck implements sql.CheckAlterableTable.

func (*Table) DropColumn 

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

func (*Table) DropForeignKey 

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

DropForeignKey implements sql.ForeignKeyTable.

func (*Table) DropIndex 

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

DropIndex implements sql.IndexAlterableTable

func (*Table) DropPrimaryKey 

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

DropPrimaryKey implements the PrimaryKeyAlterableTable TODO: get rid of this / make it error?

func (*Table) EnablePrimaryKeyIndexes 

func (t *Table) EnablePrimaryKeyIndexes()

EnablePrimaryKeyIndexes enables the use of primary key indexes on this table.

func (*Table) Filters 

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

Filters implements the sql.FilteredTable interface.

func (*Table) GetChecks 

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

GetChecks implements sql.CheckTable

func (*Table) GetDeclaredForeignKeys 

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

GetDeclaredForeignKeys implements the interface sql.ForeignKeyTable.

func (*Table) GetForeignKeyEditor 

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

GetForeignKeyEditor implements sql.ForeignKeyTable.

func (*Table) GetIndexes 

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

GetIndexes implements sql.IndexedTable

func (*Table) GetNextAutoIncrementValue 

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

GetNextAutoIncrementValue gets the next auto increment value for the memory table the increment.

func (*Table) GetPartition 

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

func (*Table) GetReferencedForeignKeys 

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

GetReferencedForeignKeys implements the interface sql.ForeignKeyTable.

func (*Table) HandledFilters 

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

HandledFilters implements the sql.FilteredTable interface.

func (*Table) IgnoreSessionData 

func (t *Table) IgnoreSessionData() bool

func (*Table) IndexedAccess 

func (t *Table) IndexedAccess(lookup sql.IndexLookup) sql.IndexedTable

func (*Table) Insert 

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

Insert is a convenience method to avoid having to create an inserter in test setup

func (*Table) Inserter 

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

func (*Table) ModifyColumn 

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

func (*Table) ModifyDefaultCollation 

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

ModifyDefaultCollation implements sql.CollationAlterableTable

func (*Table) ModifyStoredCollation 

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

ModifyStoredCollation implements sql.CollationAlterableTable

func (*Table) Name 

func (t *Table) Name() string

Name implements the sql.Table interface.

func (*Table) PartitionCount 

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

PartitionCount implements the sql.PartitionCounter interface.

func (*Table) PartitionRows 

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

PartitionRows implements the sql.PartitionRows interface.

func (*Table) Partitions 

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

Partitions implements the sql.Table interface.

func (*Table) PeekNextAutoIncrementValue 

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

PeekNextAutoIncrementValue peeks at the next AUTO_INCREMENT value

func (*Table) PreciseMatch 

func (t *Table) PreciseMatch() bool

func (*Table) PrimaryKeySchema 

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

PrimaryKeySchema implements sql.PrimaryKeyAlterableTable

func (*Table) Projections 

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

Projections implements sql.ProjectedTable

func (*Table) RenameIndex 

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

RenameIndex implements sql.IndexAlterableTable

func (*Table) Replacer 

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

func (*Table) RewriteInserter 

func (t *Table) RewriteInserter(ctx *sql.Context, oldSchema, newSchema sql.PrimaryKeySchema, _, _ *sql.Column, idxCols []sql.IndexColumn) (sql.RowInserter, error)

func (*Table) RowCount 

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

func (*Table) Schema 

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

Schema implements the sql.Table interface.

func (*Table) SetForeignKeyResolved 

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

SetForeignKeyResolved implements sql.ForeignKeyTable.

func (*Table) ShouldBuildIndex 

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

func (*Table) ShouldRewriteTable 

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

func (*Table) String 

func (t *Table) String() string

String implements the sql.Table interface.

func (*Table) Truncate 

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

func (*Table) UnderlyingTable 

func (t *Table) UnderlyingTable() *Table

func (*Table) UpdateForeignKey 

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

UpdateForeignKey implements sql.ForeignKeyTable.

func (*Table) Updater 

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

func (*Table) WithProjections 

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

WithProjections implements sql.ProjectedTable

type TableData 

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

TableData encapsulates all schema and data for a table's schema and rows. Other aspects of a table can change freely as needed for different views on a table (column projections, index lookups, filters, etc.) but the storage of underlying data lives here.

func (TableData) Table 

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

Table returns a table with this data

type TableFunc 

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

TableFunc a simple table function that returns the instantiated value.

func (TableFunc) CheckPrivileges 

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

func (TableFunc) Children 

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

func (TableFunc) Collation 

func (TableFunc) Collation() sql.CollationID

Collation implements the sql.Table interface.

func (TableFunc) CollationCoercibility 

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

CollationCoercibility implements the interface sql.CollationCoercible.

func (TableFunc) Database 

func (s TableFunc) Database() sql.Database

func (TableFunc) DebugString 

func (s TableFunc) DebugString() string

func (TableFunc) Description 

func (s TableFunc) Description() string

func (TableFunc) Expressions 

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

func (TableFunc) IsReadOnly 

func (s TableFunc) IsReadOnly() bool

func (TableFunc) Name 

func (s TableFunc) Name() string

func (TableFunc) NewInstance 

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

func (TableFunc) Resolved 

func (s TableFunc) Resolved() bool

func (TableFunc) RowIter 

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

func (TableFunc) Schema 

func (s TableFunc) Schema() sql.Schema

func (TableFunc) String 

func (s TableFunc) String() string

func (TableFunc) WithChildren 

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

func (TableFunc) WithDatabase 

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

func (TableFunc) WithExpressions 

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

type TableFunctionRowIter 

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

func (*TableFunctionRowIter) Close 

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

func (*TableFunctionRowIter) Next 

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

type TableRevision 

type TableRevision struct {
	*Table
}

TableRevision is a container for memory tables to run basic smoke tests for versioned queries. It overrides only enough of the Table interface required to pass those tests. Memory tables have a flag to force them to ignore session data and use embedded data, which is required for the versioned table tests to pass.

func NewPartitionedTableRevision 

func NewPartitionedTableRevision(db *BaseDatabase, name string, schema sql.PrimaryKeySchema, fkColl *ForeignKeyCollection, numPartitions int) *TableRevision

NewPartitionedTable creates a new Table with the given name, schema and number of partitions. Assigns the default collation, therefore if a different collation is desired, please use NewPartitionedTableWithCollation.

func (*TableRevision) AddColumn 

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

func (*TableRevision) IgnoreSessionData 

func (t *TableRevision) IgnoreSessionData() bool

func (*TableRevision) Inserter 

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

type TestIndexDriver 

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

TestIndexDriver is a non-performant index driver meant to aid in verification of engine correctness. It can not create or delete indexes, but will use the index types defined in this package to alter how queries are executed, retrieving values from the indexes rather than from the tables directly.

func NewIndexDriver 

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

NewIndexDriver returns a new index driver for database and the indexes given, keyed by the table name.

func (*TestIndexDriver) Create 

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

func (*TestIndexDriver) Delete 

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

func (*TestIndexDriver) ID 

func (d *TestIndexDriver) ID() string

func (*TestIndexDriver) LoadAll 

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

func (*TestIndexDriver) Save 

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

type Transaction 

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

func (*Transaction) IsReadOnly 

func (s *Transaction) IsReadOnly() bool

func (*Transaction) String 

func (s *Transaction) String() string

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.