sql

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2021 License: Apache-2.0 Imports: 15 Imported by: 4

Documentation

Overview

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Code generated by goyacc -l -o sql_parser.go sql_grammar.y. DO NOT EDIT.

Index

Constants

View Source 
const (
	NamedNonPositionalParamType positionalParamType = iota + 1
	NamedPositionalParamType
	UnnamedParamType
)
View Source 
const (
	PIndexPrefix = "P." // (key=P.{dbID}{tableID}{0}({pkVal}{padding}{pkValLen})+, value={count (colID valLen val)+})
	SIndexPrefix = "S." // (key=S.{dbID}{tableID}{indexID}({val}{padding}{valLen})+({pkVal}{padding}{pkValLen})+, value={})
	UIndexPrefix = "U." // (key=U.{dbID}{tableID}{indexID}({val}{padding}{valLen})+, value={({pkVal}{padding}{pkValLen})+})
)
View Source 
const ADD = 57358
View Source 
const AGGREGATE_FUNC = 57401
View Source 
const ALTER = 57357
View Source 
const AS = 57383
View Source 
const ASC = 57381
View Source 
const AUTO_INCREMENT = 57388
View Source 
const BEFORE = 57372
View Source 
const BEGIN = 57362
View Source 
const BLOB = 57400
View Source 
const BOOLEAN = 57399
View Source 
const BY = 57378
View Source 
const CMPOP = 57394
View Source 
const COLUMN = 57359
View Source 
const COMMIT = 57364
View Source 
const CREATE = 57346
View Source 
const DATABASE = 57348
View Source 
const DESC = 57382
View Source 
const DISTINCT = 57370
View Source 
const ERROR = 57402
View Source 
const EXISTS = 57387
View Source 
const EncIDLen = 4
View Source 
const EncLenLen = 4
View Source 
const FROM = 57371
View Source 
const GROUP = 57377
View Source 
const HAVING = 57375
View Source 
const IDENTIFIER = 57395
View Source 
const IF = 57386
View Source 
const INDEX = 57355
View Source 
const INSERT = 57365
View Source 
const INTO = 57367
View Source 
const JOIN = 57374
View Source 
const JOINTYPE = 57392
View Source 
const KEY = 57361
View Source 
const LIKE = 57385
View Source 
const LIMIT = 57379
View Source 
const LOP = 57393
View Source 
const MaxNumberOfColumnsInIndex = 8
View Source 
const NOT = 57384
View Source 
const NPARAM = 57390
View Source 
const NULL = 57389
View Source 
const NUMBER = 57397
View Source 
const ON = 57356
View Source 
const ORDER = 57380
View Source 
const PKIndexID = uint32(0)
View Source 
const PPARAM = 57391
View Source 
const PRIMARY = 57360
View Source 
const SELECT = 57369
View Source 
const SINCE = 57350
View Source 
const SNAPSHOT = 57349
View Source 
const STMT_SEPARATOR = 57403
View Source 
const TABLE = 57353
View Source 
const TO = 57352
View Source 
const TRANSACTION = 57363
View Source 
const TX = 57373
View Source 
const TYPE = 57396
View Source 
const UNIQUE = 57354
View Source 
const UP = 57351
View Source 
const UPSERT = 57366
View Source 
const USE = 57347
View Source 
const VALUES = 57368
View Source 
const VARCHAR = 57398
View Source 
const WHERE = 57376

Variables

View Source 
var ErrAlreadyClosed = errors.New("sql engine already closed")
View Source 
var ErrCatalogNotReady = errors.New("catalog not ready")
View Source 
var ErrColumnDoesNotExist = errors.New("column does not exist")
View Source 
var ErrColumnIsNotAnAggregation = errors.New("column is not an aggregation")
View Source 
var ErrColumnNotIndexed = errors.New("column is not indexed")
View Source 
var ErrCorruptedData = store.ErrCorruptedData
View Source 
var ErrDDLorDMLTxOnly = errors.New("transactions can NOT combine DDL and DML statements")
View Source 
var ErrDatabaseAlreadyExists = errors.New("database already exists")
View Source 
var ErrDatabaseDoesNotExist = errors.New("database does not exist")
View Source 
var ErrDivisionByZero = errors.New("division by zero")
View Source 
var ErrDuplicatedColumn = errors.New("duplicated column")
View Source 
var ErrEitherNamedOrUnnamedParams = errors.New("either named or unnamed params")
View Source 
var ErrEitherPosOrNonPosParams = errors.New("either positional or non-positional named params")
View Source 
var ErrExpectingDQLStmt = errors.New("illegal statement. DQL statement expected")
View Source 
var ErrHavingClauseRequiresGroupClause = errors.New("having clause requires group clause")
View Source 
var ErrIllegalArguments = store.ErrIllegalArguments
View Source 
var ErrIllegalMappedKey = errors.New("error illegal mapped key")
View Source 
var ErrIndexAlreadyExists = errors.New("index already exists")
View Source 
var ErrIndexedColumnCanNotBeNull = errors.New("indexed column can not be null")
View Source 
var ErrInferredMultipleTypes = errors.New("inferred multiple types")
View Source 
var ErrInvalidColumn = errors.New("invalid column")
View Source 
var ErrInvalidCondition = errors.New("invalid condition")
View Source 
var ErrInvalidNumberOfValues = errors.New("invalid number of values provided")
View Source 
var ErrInvalidPositionalParameter = errors.New("invalid positional parameter")
View Source 
var ErrInvalidTypes = errors.New("invalid types")
View Source 
var ErrInvalidValue = errors.New("invalid value provided")
View Source 
var ErrLimitedAutoIncrement = errors.New("only INTEGER single-column primary keys can be set as auto incremental")
View Source 
var ErrLimitedCount = errors.New("only unbounded counting is supported i.e. COUNT()")
View Source 
var ErrLimitedGroupBy = errors.New("group by requires ordering by the grouping column")
View Source 
var ErrLimitedIndexCreation = errors.New("index creation is only supported on empty tables")
View Source 
var ErrLimitedKeyType = errors.New("indexed key of invalid type. Supported types are: INTEGER, VARCHAR[256] OR BLOB[256]")
View Source 
var ErrLimitedMaxLen = errors.New("only VARCHAR and BLOB types support max length")
View Source 
var ErrLimitedOrderBy = errors.New("order is limit to one indexed column")
View Source 
var ErrLimitedUpsert = errors.New("upsert is only supported in tables without secondary indexes")
View Source 
var ErrMaxKeyLengthExceeded = errors.New("max key length exceeded")
View Source 
var ErrMaxLengthExceeded = errors.New("max length exceeded")
View Source 
var ErrMaxNumberOfColumnsInIndexExceeded = errors.New("number of columns in multi-column index exceeded")
View Source 
var ErrMissingParameter = errors.New("missing parameter")
View Source 
var ErrNoAvailableIndex = errors.New("no available index")
View Source 
var ErrNoDatabaseSelected = errors.New("no database selected")
View Source 
var ErrNoMoreRows = store.ErrNoMoreEntries
View Source 
var ErrNoSupported = errors.New("not yet supported")
View Source 
var ErrNoValueForAutoIncrementalColumn = errors.New("no value should be specified for auto incremental columns")
View Source 
var ErrNotComparableValues = errors.New("values are not comparable")
View Source 
var ErrNotNullableColumnCannotBeNull = errors.New("not nullable column can not be null")
View Source 
var ErrPKCanNotBeNull = errors.New("primary key can not be null")
View Source 
var ErrTableAlreadyExists = errors.New("table already exists")
View Source 
var ErrTableDoesNotExist = errors.New("table does not exist")
View Source 
var ErrTxDoesNotExist = errors.New("tx does not exist")
View Source 
var ErrUnexpected = errors.New("unexpected error")
View Source 
var ErrUnsupportedJoinType = errors.New("unsupported join type")
View Source 
var ErrUnsupportedParameter = errors.New("unsupported parameter")

Functions

func EncodeAsKey added in v1.1.0 

func EncodeAsKey(val interface{}, colType SQLValueType, maxLen int) ([]byte, error)

func EncodeID 

func EncodeID(id uint32) []byte

func EncodeSelector 

func EncodeSelector(aggFn, db, table, col string) string

func EncodeValue 

func EncodeValue(val interface{}, colType SQLValueType, maxLen int) ([]byte, error)

func MapKey 

func MapKey(prefix []byte, mappingPrefix string, encValues ...[]byte) []byte

Types

type AVGValue 

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

func (*AVGValue) ColBounded 

func (v *AVGValue) ColBounded() bool

func (*AVGValue) Compare 

func (v *AVGValue) Compare(val TypedValue) (int, error)

func (*AVGValue) Selector 

func (v *AVGValue) Selector() string

func (*AVGValue) Type 

func (v *AVGValue) Type() SQLValueType

func (*AVGValue) Value 

func (v *AVGValue) Value() interface{}

type AddColumnStmt 

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

type AggColSelector 

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

type AggregateFn 

type AggregateFn = string
const (
	COUNT AggregateFn = "COUNT"
	SUM   AggregateFn = "SUM"
	MAX   AggregateFn = "MAX"
	MIN   AggregateFn = "MIN"
	AVG   AggregateFn = "AVG"
)

type AggregatedValue 

type AggregatedValue interface {
	TypedValue

	Selector() string
	ColBounded() bool
	// contains filtered or unexported methods
}

type BinBoolExp 

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

type Blob 

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

func (*Blob) Compare 

func (v *Blob) Compare(val TypedValue) (int, error)

func (*Blob) Type 

func (v *Blob) Type() SQLValueType

func (*Blob) Value 

func (v *Blob) Value() interface{}

type Bool 

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

func (*Bool) Compare 

func (v *Bool) Compare(val TypedValue) (int, error)

func (*Bool) Type 

func (v *Bool) Type() SQLValueType

func (*Bool) Value 

func (v *Bool) Value() interface{}

type Catalog 

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

func (*Catalog) Databases 

func (c *Catalog) Databases() []*Database

func (*Catalog) ExistDatabase 

func (c *Catalog) ExistDatabase(db string) bool

func (*Catalog) GetDatabaseByID 

func (c *Catalog) GetDatabaseByID(id uint32) (*Database, error)

func (*Catalog) GetDatabaseByName 

func (c *Catalog) GetDatabaseByName(name string) (*Database, error)

func (*Catalog) GetTableByName 

func (c *Catalog) GetTableByName(dbName, tableName string) (*Table, error)

type CmpBoolExp 

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

type CmpOperator 

type CmpOperator = int
const (
	EQ CmpOperator = iota
	NE
	LT
	LE
	GT
	GE
)

type ColDescriptor 

type ColDescriptor struct {
	AggFn    string
	Database string
	Table    string
	Column   string
	Type     SQLValueType
}

func (*ColDescriptor) Selector 

func (d *ColDescriptor) Selector() string

type ColSelector 

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

type ColSpec 

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

type Column 

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

func (*Column) ID 

func (c *Column) ID() uint32

func (*Column) IsAutoIncremental added in v1.1.0 

func (c *Column) IsAutoIncremental() bool

func (*Column) IsNullable 

func (c *Column) IsNullable() bool

func (*Column) MaxLen added in v1.1.0 

func (c *Column) MaxLen() int

func (*Column) Name 

func (c *Column) Name() string

func (*Column) Type 

func (c *Column) Type() SQLValueType

type Comparison 

type Comparison int
const (
	EqualTo Comparison = iota
	LowerThan
	LowerOrEqualTo
	GreaterThan
	GreaterOrEqualTo
)

type CountValue 

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

func (*CountValue) ColBounded 

func (v *CountValue) ColBounded() bool

func (*CountValue) Compare 

func (v *CountValue) Compare(val TypedValue) (int, error)

func (*CountValue) Selector 

func (v *CountValue) Selector() string

func (*CountValue) Type 

func (v *CountValue) Type() SQLValueType

func (*CountValue) Value 

func (v *CountValue) Value() interface{}

type CreateDatabaseStmt 

type CreateDatabaseStmt struct {
	DB string
}

type CreateIndexStmt 

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

type CreateTableStmt 

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

type DataSource 

type DataSource interface {
	Resolve(e *Engine, snap *store.Snapshot, implicitDB *Database, params map[string]interface{}, ScanSpecs *ScanSpecs) (RowReader, error)
	Alias() string
	// contains filtered or unexported methods
}

type Database 

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

func (*Database) ExistTable 

func (db *Database) ExistTable(table string) bool

func (*Database) GetTableByID 

func (db *Database) GetTableByID(id uint32) (*Table, error)

func (*Database) GetTableByName 

func (db *Database) GetTableByName(name string) (*Table, error)

func (*Database) GetTables 

func (db *Database) GetTables() []*Table

func (*Database) ID 

func (db *Database) ID() uint32

func (*Database) Name 

func (db *Database) Name() string

type Engine 

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

func NewEngine 

func NewEngine(catalogStore, dataStore *store.ImmuStore, prefix []byte) (*Engine, error)

func (*Engine) Close 

func (e *Engine) Close() error

func (*Engine) CloseSnapshot 

func (e *Engine) CloseSnapshot() error

func (*Engine) DatabaseInUse 

func (e *Engine) DatabaseInUse() (*Database, error)

func (*Engine) DumpCatalogTo added in v1.0.5 

func (e *Engine) DumpCatalogTo(srcName, dstName string, targetStore *store.ImmuStore) error

func (*Engine) EnsureCatalogReady added in v1.0.5 

func (e *Engine) EnsureCatalogReady(cancellation <-chan struct{}) error

TODO (jeroiraz); this operation won't be needed with a transactional in-memory catalog

func (*Engine) Exec 

func (e *Engine) Exec(sql io.ByteReader, params map[string]interface{}, waitForIndexing bool) (summary *ExecSummary, err error)

func (*Engine) ExecPreparedStmts 

func (e *Engine) ExecPreparedStmts(stmts []SQLStmt, params map[string]interface{}, waitForIndexing bool) (summary *ExecSummary, err error)

func (*Engine) ExecStmt 

func (e *Engine) ExecStmt(sql string, params map[string]interface{}, waitForIndexing bool) (summary *ExecSummary, err error)

func (*Engine) ExistDatabase added in v1.0.5 

func (e *Engine) ExistDatabase(db string) (bool, error)

func (*Engine) GetDatabaseByName added in v1.0.5 

func (e *Engine) GetDatabaseByName(db string) (*Database, error)

func (*Engine) GetTableByName added in v1.0.5 

func (e *Engine) GetTableByName(dbName, tableName string) (*Table, error)

func (*Engine) InferParameters added in v1.0.5 

func (e *Engine) InferParameters(sql string) (map[string]SQLValueType, error)

func (*Engine) InferParametersPreparedStmt added in v1.0.5 

func (e *Engine) InferParametersPreparedStmt(stmt SQLStmt) (map[string]SQLValueType, error)

func (*Engine) Query 

func (e *Engine) Query(sql io.ByteReader, params map[string]interface{}, renewSnapshot bool) (RowReader, error)

func (*Engine) QueryPreparedStmt 

func (e *Engine) QueryPreparedStmt(stmt *SelectStmt, params map[string]interface{}, renewSnapshot bool) (RowReader, error)

func (*Engine) QueryStmt 

func (e *Engine) QueryStmt(sql string, params map[string]interface{}, renewSnapshot bool) (RowReader, error)

exist database directly on catalogStore: // existKey(e.mapKey(catalogDatabase, db), e.catalogStore)

func (*Engine) ReloadCatalog added in v1.0.5 

func (e *Engine) ReloadCatalog(cancellation <-chan struct{}) error

func (*Engine) RenewSnapshot 

func (e *Engine) RenewSnapshot() error

func (*Engine) UseDatabase 

func (e *Engine) UseDatabase(dbName string) error

func (*Engine) UseSnapshot 

func (e *Engine) UseSnapshot(sinceTx uint64, asBeforeTx uint64) error

type ExecSummary added in v1.1.0 

type ExecSummary struct {
	DDTxs []*store.TxMetadata
	DMTxs []*store.TxMetadata

	UpdatedRows     int
	LastInsertedPKs map[string]int64
}

type ExistsBoolExp 

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

type Index added in v1.1.0 

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

func (*Index) Cols added in v1.1.0 

func (i *Index) Cols() []*Column

func (*Index) IncludesCol added in v1.1.0 

func (i *Index) IncludesCol(colID uint32) bool

func (*Index) IsPrimary added in v1.1.0 

func (i *Index) IsPrimary() bool

func (*Index) IsUnique added in v1.1.0 

func (i *Index) IsUnique() bool

type JoinSpec 

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

type JoinType 

type JoinType = int
const (
	InnerJoin JoinType = iota
	LeftJoin
	RightJoin
)

type LikeBoolExp 

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

type LogicOperator 

type LogicOperator = int
const (
	AND LogicOperator = iota
	OR
)

type MaxValue 

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

func (*MaxValue) ColBounded 

func (v *MaxValue) ColBounded() bool

func (*MaxValue) Compare 

func (v *MaxValue) Compare(val TypedValue) (int, error)

func (*MaxValue) Selector 

func (v *MaxValue) Selector() string

func (*MaxValue) Type 

func (v *MaxValue) Type() SQLValueType

func (*MaxValue) Value 

func (v *MaxValue) Value() interface{}

type MinValue 

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

func (*MinValue) ColBounded 

func (v *MinValue) ColBounded() bool

func (*MinValue) Compare 

func (v *MinValue) Compare(val TypedValue) (int, error)

func (*MinValue) Selector 

func (v *MinValue) Selector() string

func (*MinValue) Type 

func (v *MinValue) Type() SQLValueType

func (*MinValue) Value 

func (v *MinValue) Value() interface{}

type NotBoolExp 

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

type NullValue 

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

func (*NullValue) Compare 

func (n *NullValue) Compare(val TypedValue) (int, error)

func (*NullValue) Type 

func (n *NullValue) Type() SQLValueType

func (*NullValue) Value 

func (n *NullValue) Value() interface{}

type NumExp 

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

type NumOperator 

type NumOperator = int
const (
	ADDOP NumOperator = iota
	SUBSOP
	DIVOP
	MULTOP
)

type Number 

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

func (*Number) Compare 

func (v *Number) Compare(val TypedValue) (int, error)

func (*Number) Type 

func (v *Number) Type() SQLValueType

func (*Number) Value 

func (v *Number) Value() interface{}

type OrdCol 

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

type Order added in v1.1.0 

type Order int
const (
	AscOrder Order = iota
	DescOrder
)

type Param 

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

type Row 

type Row struct {
	Values map[string]TypedValue
}

func (*Row) Compatible 

func (row *Row) Compatible(aRow *Row, selectors []*ColSelector, db, table string) (bool, error)

rows are selector-compatible if both rows have the same assigned value for all specified selectors

type RowReader 

type RowReader interface {
	ImplicitDB() string
	ImplicitTable() string
	SetParameters(params map[string]interface{})
	Read() (*Row, error)
	Close() error
	Columns() ([]*ColDescriptor, error)
	OrderBy() []*ColDescriptor
	ScanSpecs() *ScanSpecs
	InferParameters(params map[string]SQLValueType) error
	// contains filtered or unexported methods
}

type RowSpec 

type RowSpec struct {
	Values []ValueExp
}

type SQLStmt 

type SQLStmt interface {
	// contains filtered or unexported methods
}

func Parse 

func Parse(r io.ByteReader) ([]SQLStmt, error)

func ParseString 

func ParseString(sql string) ([]SQLStmt, error)

type SQLValueType 

type SQLValueType = string
const (
	IntegerType   SQLValueType = "INTEGER"
	BooleanType   SQLValueType = "BOOLEAN"
	VarcharType   SQLValueType = "VARCHAR"
	BLOBType      SQLValueType = "BLOB"
	TimestampType SQLValueType = "TIMESTAMP"
	AnyType       SQLValueType = "ANY"
)

type ScanSpecs added in v1.1.0 

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

type SelectStmt 

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

func (*SelectStmt) Alias 

func (stmt *SelectStmt) Alias() string

func (*SelectStmt) Limit 

func (stmt *SelectStmt) Limit() uint64

func (*SelectStmt) Resolve 

func (stmt *SelectStmt) Resolve(e *Engine, snap *store.Snapshot, implicitDB *Database, params map[string]interface{}, _ *ScanSpecs) (rowReader RowReader, err error)

type Selector 

type Selector interface {
	ValueExp
	// contains filtered or unexported methods
}

type SumValue 

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

func (*SumValue) ColBounded 

func (v *SumValue) ColBounded() bool

func (*SumValue) Compare 

func (v *SumValue) Compare(val TypedValue) (int, error)

func (*SumValue) Selector 

func (v *SumValue) Selector() string

func (*SumValue) Type 

func (v *SumValue) Type() SQLValueType

func (*SumValue) Value 

func (v *SumValue) Value() interface{}

type SysFn 

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

type Table 

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

func (*Table) Cols added in v1.1.0 

func (t *Table) Cols() []*Column

func (*Table) ColsByName 

func (t *Table) ColsByName() map[string]*Column

func (*Table) Database 

func (t *Table) Database() *Database

func (*Table) GetColumnByID 

func (t *Table) GetColumnByID(id uint32) (*Column, error)

func (*Table) GetColumnByName 

func (t *Table) GetColumnByName(name string) (*Column, error)

func (*Table) ID 

func (t *Table) ID() uint32

func (*Table) IndexesByColID added in v1.1.0 

func (t *Table) IndexesByColID(colID uint32) []*Index

func (*Table) IsIndexed 

func (t *Table) IsIndexed(colName string) (indexed bool, err error)

func (*Table) Name 

func (t *Table) Name() string

func (*Table) PrimaryIndex added in v1.1.0 

func (t *Table) PrimaryIndex() *Index

type TxStmt 

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

type TxSummary added in v1.1.0 

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

type TypedValue 

type TypedValue interface {
	ValueExp
	Type() SQLValueType
	Value() interface{}
	Compare(val TypedValue) (int, error)
}

func DecodeValue 

func DecodeValue(b []byte, colType SQLValueType) (TypedValue, int, error)

type UpsertIntoStmt 

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

type UseDatabaseStmt 

type UseDatabaseStmt struct {
	DB string
}

type UseSnapshotStmt 

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

type ValueExp 

type ValueExp interface {
	// contains filtered or unexported methods
}

type Varchar 

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

func (*Varchar) Compare 

func (v *Varchar) Compare(val TypedValue) (int, error)

func (*Varchar) Type 

func (v *Varchar) Type() SQLValueType

func (*Varchar) Value 

func (v *Varchar) Value() interface{}

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.