sql

package

Go to main page

Versions in this module

v1

v1.9.5

Sep 16, 2024

v1.9.4

Jul 25, 2024

v1.9.3

May 22, 2024

v1.9.0-RC2

Oct 16, 2023

v1.9.0-RC1

Oct 11, 2023

v1.5.0

Jun 20, 2023

Changes in this version

+ const DOT

+ const FLOAT

+ const INTEGER

+ const SCAST

+ var ErrNumericTypeExpected = errors.New("numeric type expected")

+ var ErrUnspecifiedMultiDBHandler = fmt.Errorf("%w: unspecified multidbHanlder", store.ErrIllegalState)

+ var MaxKeyLen = 512

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

+ func EncodeValueAsKey(val TypedValue, colType SQLValueType, maxLen int) ([]byte, int, error)

+ func EncodedPK(table *Table, valuesByColID map[uint32]TypedValue) ([]byte, error)

+ func IsNumericType(t SQLValueType) bool

+ func NewColUpdate(col string, val ValueExp) *colUpdate

type AVGValue

+ func (v *AVGValue) RawValue() interface{}

type AddColumnStmt

+ func NewAddColumnStmt(table string, colSpec *ColSpec) *AddColumnStmt

type AggColSelector

+ func NewAggColSelector(aggFn AggregateFn, table, col string) *AggColSelector

type BinBoolExp

+ func NewBinBoolExp(op LogicOperator, lrexp, rrexp ValueExp) *BinBoolExp

type Blob

+ func NewBlob(val []byte) *Blob

+ func (v *Blob) RawValue() interface{}

type Bool

+ func NewBool(val bool) *Bool

+ func (v *Bool) RawValue() interface{}

type Catalog

+ func (catlg *Catalog) ExistTable(table string) bool

+ func (catlg *Catalog) GetTableByID(id uint32) (*Table, error)

+ func (catlg *Catalog) GetTables() []*Table

type CmpBoolExp

+ func NewCmpBoolExp(op CmpOperator, left, right ValueExp) *CmpBoolExp

+ func (bexp *CmpBoolExp) Left() ValueExp

+ func (bexp *CmpBoolExp) OP() CmpOperator

+ func (bexp *CmpBoolExp) Right() ValueExp

type ColSelector

+ func NewColSelector(table, col string) *ColSelector

type ColSpec

+ func NewColSpec(name string, colType SQLValueType, maxLen int, autoIncrement bool, ...) *ColSpec

type CountValue

+ func (v *CountValue) RawValue() interface{}

type CreateIndexStmt

+ func NewCreateIndexStmt(table string, cols []string, isUnique bool) *CreateIndexStmt

type CreateTableStmt

+ func NewCreateTableStmt(table string, ifNotExists bool, colsSpec []*ColSpec, pkColNames []string) *CreateTableStmt

type DeleteFromStmt

+ func NewDeleteFromStmt(table string, where ValueExp, orderBy []*OrdCol, limit ValueExp) *DeleteFromStmt

+ type DropIndexStmt struct

+ func NewDropIndexStmt(table string, columns []string) *DropIndexStmt

+ type DropTableStmt struct

+ func NewDropTableStmt(table string) *DropTableStmt

type Engine

+ func (e *Engine) CopyCatalogToTx(ctx context.Context, tx *store.OngoingTx) error

+ func (e *Engine) GetPrefix() []byte

+ func (e *Engine) GetStore() *store.ImmuStore

+ type Float64 struct

+ func NewFloat64(val float64) *Float64

+ func (v *Float64) Compare(val TypedValue) (int, error)

+ func (v *Float64) IsNull() bool

+ func (v *Float64) RawValue() interface{}

+ func (v *Float64) Type() SQLValueType

type Index

+ func (i *Index) ID() uint32

+ type Integer struct

+ func NewInteger(val int64) *Integer

+ func (v *Integer) Compare(val TypedValue) (int, error)

+ func (v *Integer) IsNull() bool

+ func (v *Integer) RawValue() interface{}

+ func (v *Integer) Type() SQLValueType

type LikeBoolExp

+ func NewLikeBoolExp(val ValueExp, notLike bool, pattern ValueExp) *LikeBoolExp

type MaxValue

+ func (v *MaxValue) RawValue() interface{}

type MinValue

+ func (v *MinValue) RawValue() interface{}

type NullValue

+ func (n *NullValue) RawValue() interface{}

type Options

+ func (opts *Options) Validate() error

+ func (opts *Options) WithLazyIndexConstraintValidation(lazyIndexConstraintValidation bool) *Options

+ func (opts *Options) WithMultiDBHandler(multidbHandler MultiDBHandler) *Options

type OrdCol

+ func NewOrdCol(table string, col string, descOrder bool) *OrdCol

type RenameColumnStmt

+ func NewRenameColumnStmt(table, oldName, newName string) *RenameColumnStmt

type RowSpec

+ func NewRowSpec(values []ValueExp) *RowSpec

type SQLTx

+ func (sqlTx *SQLTx) Catalog() *Catalog

+ func (sqlTx *SQLTx) Commit(ctx context.Context) error

+ func (sqlTx *SQLTx) Committed() bool

+ func (sqlTx *SQLTx) IsExplicitCloseRequired() bool

+ func (sqlTx *SQLTx) RequireExplicitClose() error

type SQLValueType

+ const Float64Type

type SelectStmt

+ func NewSelectStmt(selectors []Selector, table string, where ValueExp, orderBy []*OrdCol, ...) *SelectStmt

type SumValue

+ func (v *SumValue) RawValue() interface{}

type Table

+ func (t *Table) ColumnsByID() map[uint32]*Column

+ func (t *Table) GetIndexByName(name string) (*Index, error)

+ func (t *Table) GetIndexes() []*Index

type Timestamp

+ func (v *Timestamp) RawValue() interface{}

+ type TxOptions struct

+ ExplicitClose bool

+ ReadOnly bool

+ SnapshotMustIncludeTxID func(lastPrecommittedTxID uint64) uint64

+ SnapshotRenewalPeriod time.Duration

+ UnsafeMVCC bool

+ func DefaultTxOptions() *TxOptions

+ func (opts *TxOptions) Validate() error

+ func (opts *TxOptions) WithExplicitClose(explicitClose bool) *TxOptions

+ func (opts *TxOptions) WithReadOnly(readOnly bool) *TxOptions

+ func (opts *TxOptions) WithSnapshotMustIncludeTxID(snapshotMustIncludeTxID func(lastPrecommittedTxID uint64) uint64) *TxOptions

+ func (opts *TxOptions) WithSnapshotRenewalPeriod(snapshotRenewalPeriod time.Duration) *TxOptions

+ func (opts *TxOptions) WithUnsafeMVCC(unsafeMVCC bool) *TxOptions

type TypedValue

+ RawValue func() interface{}

type UpdateStmt

+ func NewUpdateStmt(table string, where ValueExp, update *colUpdate) *UpdateStmt

type UpsertIntoStmt

+ func NewUpserIntoStmt(table string, cols []string, rows []*RowSpec, isInsert bool, ...) *UpsertIntoStmt

type Varchar

+ func NewVarchar(val string) *Varchar

+ func (v *Varchar) RawValue() interface{}

v1.5.0-RC1

Jun 16, 2023

v1.4.1

Nov 21, 2022

v1.4.1-RC1

Nov 16, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.4.0

Oct 12, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.4.0-RC2

Oct 10, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.4.0-RC1

Oct 4, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.3.2

Aug 25, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.3.2-RC1

Aug 24, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.3.1

Jun 30, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const OFFSET

type SQLTx

+ func (sqlTx *SQLTx) Timestamp() time.Time

type SelectStmt

+ func (stmt *SelectStmt) Offset() int

v1.3.1-RC1

Jun 30, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.3.0

May 23, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const AFTER

+ const ALL

+ const ColumnsFnCall

+ const DatabasesFnCall

+ const IndexesFnCall

+ const NowFnCall

+ const OF

+ const RENAME

+ const TIMESTAMP

+ const TablesFnCall

+ const UNION

+ const UNTIL

+ var ErrColumnAlreadyExists = errors.New("column already exists")

+ var ErrColumnMismatchInUnionStmt = errors.New("column mismatch in union statement")

+ var ErrFunctionDoesNotExist = errors.New("function does not exist")

+ var ErrNewColumnMustBeNullable = errors.New("new column must be nullable")

+ var ErrNonTransactionalStmt = errors.New("non transactional statement")

+ var ErrParsingError = errors.New("parsing error")

+ var ErrSameOldAndNewColumnName = errors.New("same old and new column names")

type Engine

+ func (e *Engine) CurrentDatabase() string

+ func (e *Engine) NewTx(ctx context.Context) (*SQLTx, error)

+ func (e *Engine) SetCurrentDatabase(dbName string) error

+ func (e *Engine) SetMultiDBHandler(handler MultiDBHandler)

+ type FnCall struct

+ type FnDataSourceStmt struct

+ func (stmt *FnDataSourceStmt) Alias() string

+ func (stmt *FnDataSourceStmt) Resolve(tx *SQLTx, params map[string]interface{}, scanSpecs *ScanSpecs) (rowReader RowReader, err error)

type Index

+ func (i *Index) Name() string

+ type MultiDBHandler interface

+ CreateDatabase func(ctx context.Context, db string, ifNotExists bool) error

+ ExecPreparedStmts func(ctx context.Context, stmts []SQLStmt, params map[string]interface{}) (ntx *SQLTx, committedTxs []*SQLTx, err error)

+ ListDatabases func(ctx context.Context) ([]string, error)

+ UseDatabase func(ctx context.Context, db string) error

+ type RenameColumnStmt struct

type Row

+ ValuesByPosition []TypedValue

+ ValuesBySelector map[string]TypedValue

type RowReader

+ Parameters func() map[string]interface{}

type ScanSpecs

+ DescOrder bool

+ Index *Index

+ type UnionStmt struct

+ func (stmt *UnionStmt) Alias() string

+ func (stmt *UnionStmt) Resolve(tx *SQLTx, params map[string]interface{}, _ *ScanSpecs) (rowReader RowReader, err error)

v1.3.0-RC1

May 20, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.4

Apr 28, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.4-RC1

Apr 27, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.3

Apr 14, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.3-RC1

Apr 13, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.2

Jan 18, 2022 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const CONFLICT

+ const DO

+ const NOTHING

+ func TimeFromInt64(t int64) time.Time

+ func TimeToInt64(t time.Time) int64

+ type OnConflictDo struct

type SQLTx

+ func (sqlTx *SQLTx) FirstInsertedPKs() map[string]int64

v1.2.1

Dec 14, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.2.0

Dec 10, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const CAST

+ const DELETE

+ const IN

+ const IS

+ const KeyValPrefixNotNull

+ const KeyValPrefixNull

+ const KeyValPrefixUpperBound

+ const ROLLBACK

+ const SET

+ const UPDATE

+ var ErrAmbiguousSelector = errors.New("ambiguous selector")

+ var ErrDuplicatedParameters = errors.New("duplicated parameters")

+ var ErrNestedTxNotSupported = errors.New("nested tx are not supported")

+ var ErrNoOngoingTx = errors.New("no ongoing transaction")

+ var ErrPKCanNotBeUpdated = errors.New("primary key can not be updated")

+ var ErrTooManyRows = errors.New("too many rows")

+ var ErrUnsupportedCast = errors.New("unsupported cast")

+ func ValidOpts(opts *Options) bool

type AVGValue

+ func (v *AVGValue) IsNull() bool

+ type BeginTransactionStmt struct

type Blob

+ func (v *Blob) IsNull() bool

type Bool

+ func (v *Bool) IsNull() bool

+ type Cast struct

+ type CommitStmt struct

type CountValue

+ func (v *CountValue) IsNull() bool

+ type DeleteFromStmt struct

type Engine

+ func (e *Engine) DefaultDatabase() string

+ func (e *Engine) InferParametersPreparedStmts(stmts []SQLStmt, tx *SQLTx) (params map[string]SQLValueType, err error)

+ func (e *Engine) SetDefaultDatabase(dbName string) error

+ type InListExp struct

+ type InSubQueryExp struct

type MaxValue

+ func (v *MaxValue) IsNull() bool

type MinValue

+ func (v *MinValue) IsNull() bool

type NullValue

+ func (n *NullValue) IsNull() bool

type Number

+ func (v *Number) IsNull() bool

+ type Options struct

+ func DefaultOptions() *Options

+ func (opts *Options) WithAutocommit(autocommit bool) *Options

+ func (opts *Options) WithDistinctLimit(distinctLimit int) *Options

+ func (opts *Options) WithPrefix(prefix []byte) *Options

+ type RollbackStmt struct

type RowReader

+ Database func() *Database

+ TableAlias func() string

+ Tx func() *SQLTx

+ type SQLTx struct

+ func (sqlTx *SQLTx) Cancel() error

+ func (sqlTx *SQLTx) Closed() bool

+ func (sqlTx *SQLTx) Database() *Database

+ func (sqlTx *SQLTx) LastInsertedPKs() map[string]int64

+ func (sqlTx *SQLTx) TxHeader() *store.TxHeader

+ func (sqlTx *SQLTx) UpdatedRows() int

type SumValue

+ func (v *SumValue) IsNull() bool

+ type Timestamp struct

+ func (v *Timestamp) Compare(val TypedValue) (int, error)

+ func (v *Timestamp) IsNull() bool

+ func (v *Timestamp) Type() SQLValueType

+ func (v *Timestamp) Value() interface{}

type TypedValue

+ IsNull func() bool

+ type UpdateStmt struct

type Varchar

+ func (v *Varchar) IsNull() bool

v1.2.0-RC1

Dec 7, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.1.0

Sep 21, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const AUTO_INCREMENT

+ const MaxNumberOfColumnsInIndex

+ const PIndexPrefix

+ const PKIndexID

+ const SIndexPrefix

+ const UIndexPrefix

+ const UNIQUE

+ var ErrLimitedAutoIncrement = errors.New("only INTEGER single-column primary keys can be set as auto incremental")

+ var ErrLimitedGroupBy = errors.New("group by requires ordering by the grouping column")

+ var ErrLimitedIndexCreation = errors.New("index creation is only supported on empty tables")

+ var ErrLimitedKeyType = errors.New(...)

+ var ErrLimitedMaxLen = errors.New("only VARCHAR and BLOB types support max length")

+ var ErrLimitedUpsert = errors.New("upsert is only supported in tables without secondary indexes")

+ var ErrMaxLengthExceeded = errors.New("max length exceeded")

+ var ErrMaxNumberOfColumnsInIndexExceeded = errors.New("number of columns in multi-column index exceeded")

+ var ErrNoAvailableIndex = errors.New("no available index")

+ var ErrNoValueForAutoIncrementalColumn = errors.New("no value should be specified for auto incremental columns")

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

type Column

+ func (c *Column) IsAutoIncremental() bool

+ func (c *Column) MaxLen() int

+ type ExecSummary struct

+ DDTxs []*store.TxMetadata

+ DMTxs []*store.TxMetadata

+ LastInsertedPKs map[string]int64

+ UpdatedRows int

+ type Index struct

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

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

+ func (i *Index) IsPrimary() bool

+ func (i *Index) IsUnique() bool

+ type Order int

+ const AscOrder

+ const DescOrder

type RowReader

+ OrderBy func() []*ColDescriptor

+ ScanSpecs func() *ScanSpecs

+ type ScanSpecs struct

type Table

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

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

+ func (t *Table) PrimaryIndex() *Index

+ type TxSummary struct

v1.0.5

Aug 2, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const NPARAM

+ const NamedNonPositionalParamType

+ const NamedPositionalParamType

+ const PPARAM

+ const UnnamedParamType

+ var ErrCatalogNotReady = errors.New("catalog not ready")

+ var ErrEitherNamedOrUnnamedParams = errors.New("either named or unnamed params")

+ var ErrEitherPosOrNonPosParams = errors.New("either positional or non-positional named params")

+ var ErrInferredMultipleTypes = errors.New("inferred multiple types")

+ var ErrInvalidPositionalParameter = errors.New("invalid positional parameter")

+ var ErrInvalidTypes = errors.New("invalid types")

type ColDescriptor

+ AggFn string

+ Column string

+ Database string

+ Table string

type Engine

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

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

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

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

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

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

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

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

type RowReader

+ InferParameters func(params map[string]SQLValueType) error

+ SetParameters func(params map[string]interface{})

type SQLValueType

+ const AnyType

v1.0.1

Jun 7, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

v1.0.0

May 20, 2021 GO-2022-1117 +1 more

GO-2022-1117: Insufficient verification of proofs in github.com/codenotary/immudb

GO-2022-1118: Improper validation of UUIDs in github.com/codenotary/immudb

Changes in this version

+ const ADD

+ const AGGREGATE_FUNC

+ const ALTER

+ const AS

+ const ASC

+ const AVG

+ const BEFORE

+ const BEGIN

+ const BLOB

+ const BLOBType

+ const BOOLEAN

+ const BY

+ const BooleanType

+ const CMPOP

+ const COLUMN

+ const COMMIT

+ const COUNT

+ const CREATE

+ const DATABASE

+ const DESC

+ const DISTINCT

+ const ERROR

+ const EXISTS

+ const EncIDLen

+ const EncLenLen

+ const FROM

+ const GROUP

+ const HAVING

+ const IDENTIFIER

+ const IF

+ const INDEX

+ const INSERT

+ const INTO

+ const IntegerType

+ const JOIN

+ const JOINTYPE

+ const KEY

+ const LIKE

+ const LIMIT

+ const LOP

+ const MAX

+ const MIN

+ const NOT

+ const NULL

+ const NUMBER

+ const ON

+ const ORDER

+ const PRIMARY

+ const RowPrefix

+ const SELECT

+ const SINCE

+ const SNAPSHOT

+ const STMT_SEPARATOR

+ const SUM

+ const TABLE

+ const TO

+ const TRANSACTION

+ const TX

+ const TYPE

+ const TimestampType

+ const UP

+ const UPSERT

+ const USE

+ const VALUES

+ const VARCHAR

+ const VarcharType

+ const WHERE

+ var ErrAlreadyClosed = errors.New("sql engine already closed")

+ var ErrColumnDoesNotExist = errors.New("column does not exist")

+ var ErrColumnIsNotAnAggregation = errors.New("column is not an aggregation")

+ var ErrColumnNotIndexed = errors.New("column is not indexed")

+ var ErrCorruptedData = store.ErrCorruptedData

+ var ErrDDLorDMLTxOnly = errors.New("transactions can NOT combine DDL and DML statements")

+ var ErrDatabaseAlreadyExists = errors.New("database already exists")

+ var ErrDatabaseDoesNotExist = errors.New("database does not exist")

+ var ErrDivisionByZero = errors.New("division by zero")

+ var ErrDuplicatedColumn = errors.New("duplicated column")

+ var ErrExpectingDQLStmt = errors.New("illegal statement. DQL statement expected")

+ var ErrHavingClauseRequiresGroupClause = errors.New("having clause requires group clause")

+ var ErrIllegalArguments = store.ErrIllegalArguments

+ var ErrIllegalMappedKey = errors.New("error illegal mapped key")

+ var ErrIndexAlreadyExists = errors.New("index already exists")

+ var ErrIndexedColumnCanNotBeNull = errors.New("indexed column can not be null")

+ var ErrInvalidColumn = errors.New("invalid column")

+ var ErrInvalidCondition = errors.New("invalid condition")

+ var ErrInvalidJointColumn = errors.New("invalid joint column")

+ var ErrInvalidNumberOfValues = errors.New("invalid number of values provided")

+ var ErrInvalidPK = errors.New(...)

+ var ErrInvalidValue = errors.New("invalid value provided")

+ var ErrJointColumnNotFound = errors.New("joint column not found")

+ var ErrLimitedCount = errors.New("only unbounded counting is supported i.e. COUNT()")

+ var ErrLimitedIndex = errors.New("index creation is only supported on empty tables")

+ var ErrLimitedJoins = errors.New("joins limited to tables")

+ var ErrLimitedOrderBy = errors.New("order is limit to one indexed column")

+ var ErrMaxKeyLengthExceeded = errors.New("max key length exceeded")

+ var ErrMissingParameter = errors.New("missing paramter")

+ var ErrNoDatabaseSelected = errors.New("no database selected")

+ var ErrNoMoreRows = store.ErrNoMoreEntries

+ var ErrNoSupported = errors.New("not yet supported")

+ var ErrNotComparableValues = errors.New("values are not comparable")

+ var ErrNotNullableColumnCannotBeNull = errors.New("not nullable column can not be null")

+ var ErrPKCanNotBeNull = errors.New("primary key can not be null")

+ var ErrTableAlreadyExists = errors.New("table already exists")

+ var ErrTableDoesNotExist = errors.New("table does not exist")

+ var ErrTxDoesNotExist = errors.New("tx does not exist")

+ var ErrUnexpected = errors.New("unexpected error")

+ var ErrUnsupportedJoinType = errors.New("unsupported join type")

+ var ErrUnsupportedParameter = errors.New("unsupported parameter")

+ func EncodeID(id uint64) []byte

+ func EncodeRawValue(val interface{}, colType SQLValueType, asKey bool) ([]byte, error)

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

+ func EncodeValue(val TypedValue, colType SQLValueType, asKey bool) ([]byte, error)

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

+ type AVGValue struct

+ func (v *AVGValue) ColBounded() bool

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

+ func (v *AVGValue) Selector() string

+ func (v *AVGValue) Type() SQLValueType

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

+ type AddColumnStmt struct

+ func (stmt *AddColumnStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type AggColSelector struct

+ type AggregateFn = string

+ type AggregatedValue interface

+ ColBounded func() bool

+ Selector func() string

+ type BinBoolExp struct

+ type Blob struct

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

+ func (v *Blob) Type() SQLValueType

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

+ type Bool struct

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

+ func (v *Bool) Type() SQLValueType

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

+ type Catalog struct

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

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

+ func (c *Catalog) GetDatabaseByID(id uint64) (*Database, error)

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

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

+ type CmpBoolExp struct

+ type CmpOperator = int

+ const EQ

+ const GE

+ const GT

+ const LE

+ const LT

+ const NE

+ type ColDescriptor struct

+ Selector string

+ Type SQLValueType

+ type ColSelector struct

+ type ColSpec struct

+ type Column struct

+ func (c *Column) ID() uint64

+ func (c *Column) IsNullable() bool

+ func (c *Column) Name() string

+ func (c *Column) Type() SQLValueType

+ type Comparison int

+ const EqualTo

+ const GreaterOrEqualTo

+ const GreaterThan

+ const LowerOrEqualTo

+ const LowerThan

+ type CountValue struct

+ func (v *CountValue) ColBounded() bool

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

+ func (v *CountValue) Selector() string

+ func (v *CountValue) Type() SQLValueType

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

+ type CreateDatabaseStmt struct

+ DB string

+ func (stmt *CreateDatabaseStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type CreateIndexStmt struct

+ func (stmt *CreateIndexStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type CreateTableStmt struct

+ func (stmt *CreateTableStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type DataSource interface

+ Alias func() string

+ Resolve func(e *Engine, implicitDB *Database, snap *store.Snapshot, ...) (RowReader, error)

+ type Database struct

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

+ func (db *Database) GetTableByID(id uint64) (*Table, error)

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

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

+ func (db *Database) ID() uint64

+ func (db *Database) Name() string

+ type Engine struct

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

+ func (e *Engine) Catalog() *Catalog

+ func (e *Engine) Close() error

+ func (e *Engine) CloseSnapshot() error

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

+ func (e *Engine) Exec(sql io.ByteReader, params map[string]interface{}, waitForIndexing bool) (ddTxs, dmTxs []*store.TxMetadata, err error)

+ func (e *Engine) ExecPreparedStmts(stmts []SQLStmt, params map[string]interface{}, waitForIndexing bool) (ddTxs, dmTxs []*store.TxMetadata, err error)

+ func (e *Engine) ExecStmt(sql string, params map[string]interface{}, waitForIndexing bool) (ddTxs, dmTxs []*store.TxMetadata, err error)

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

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

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

+ func (e *Engine) RenewSnapshot() error

+ func (e *Engine) Snapshot() (*store.Snapshot, error)

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

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

+ type ExistsBoolExp struct

+ type GroupBySpec struct

+ type JoinSpec struct

+ type JoinType = int

+ const InnerJoin

+ const LeftJoin

+ const RightJoin

+ type LikeBoolExp struct

+ type LogicOperator = int

+ const AND

+ const OR

+ type MaxValue struct

+ func (v *MaxValue) ColBounded() bool

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

+ func (v *MaxValue) Selector() string

+ func (v *MaxValue) Type() SQLValueType

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

+ type MinValue struct

+ func (v *MinValue) ColBounded() bool

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

+ func (v *MinValue) Selector() string

+ func (v *MinValue) Type() SQLValueType

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

+ type NotBoolExp struct

+ type NullValue struct

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

+ func (n *NullValue) Type() SQLValueType

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

+ type NumExp struct

+ type NumOperator = int

+ const ADDOP

+ const DIVOP

+ const MULTOP

+ const SUBSOP

+ type Number struct

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

+ func (v *Number) Type() SQLValueType

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

+ type OrdCol struct

+ type Param struct

+ type Row struct

+ Values map[string]TypedValue

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

+ type RowReader interface

+ Close func() error

+ Columns func() ([]*ColDescriptor, error)

+ ImplicitDB func() string

+ ImplicitTable func() string

+ Read func() (*Row, error)

+ type RowSpec struct

+ Values []ValueExp

+ type SQLStmt interface

+ CompileUsing func(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

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

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

+ type SQLValueType = string

+ type SelectStmt struct

+ func (stmt *SelectStmt) Alias() string

+ func (stmt *SelectStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ func (stmt *SelectStmt) Limit() uint64

+ func (stmt *SelectStmt) Resolve(e *Engine, implicitDB *Database, snap *store.Snapshot, ...) (RowReader, error)

+ type Selector interface

+ type SumValue struct

+ func (v *SumValue) ColBounded() bool

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

+ func (v *SumValue) Selector() string

+ func (v *SumValue) Type() SQLValueType

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

+ type SysFn struct

+ type Table struct

+ func (t *Table) ColsByID() map[uint64]*Column

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

+ func (t *Table) Database() *Database

+ func (t *Table) GetColumnByID(id uint64) (*Column, error)

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

+ func (t *Table) ID() uint64

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

+ func (t *Table) Name() string

+ func (t *Table) PrimaryKey() *Column

+ type TableRef struct

+ func (stmt *TableRef) Alias() string

+ func (stmt *TableRef) Resolve(e *Engine, implicitDB *Database, snap *store.Snapshot, ...) (RowReader, error)

+ type TxStmt struct

+ func (stmt *TxStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type TypedValue interface

+ Compare func(val TypedValue) (int, error)

+ Type func() SQLValueType

+ Value func() interface{}

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

+ type UpsertIntoStmt struct

+ func (stmt *UpsertIntoStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ func (stmt *UpsertIntoStmt) Validate(table *Table) (map[uint64]int, error)

+ type UseDatabaseStmt struct

+ DB string

+ func (stmt *UseDatabaseStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type UseSnapshotStmt struct

+ func (stmt *UseSnapshotStmt) CompileUsing(e *Engine, implicitDB *Database, params map[string]interface{}) (ces, des []*store.KV, db *Database, err error)

+ type ValueExp interface

+ type Varchar struct

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

+ func (v *Varchar) Type() SQLValueType

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

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