sql

Documentation

Overview

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

Index

• Constants
• Variables
• func EncodeAsKey(val interface{}, colType SQLValueType, maxLen int) ([]byte, error)
• func EncodeID(id uint32) []byte
• func EncodeSelector(aggFn, db, table, col string) string
• func EncodeValue(val interface{}, colType SQLValueType, maxLen int) ([]byte, error)
• func MapKey(prefix []byte, mappingPrefix string, encValues ...[]byte) []byte
• func TimeFromInt64(t int64) time.Time
• func TimeToInt64(t time.Time) int64
• func ValidOpts(opts *Options) bool
• type AVGValue
  • func (v *AVGValue) ColBounded() bool
  • func (v *AVGValue) Compare(val TypedValue) (int, error)
  • func (v *AVGValue) IsNull() bool
  • func (v *AVGValue) Selector() string
  • func (v *AVGValue) Type() SQLValueType
  • func (v *AVGValue) Value() interface{}
• type AddColumnStmt
• type AggColSelector
• type AggregateFn
• type AggregatedValue
• type BeginTransactionStmt
• type BinBoolExp
• type Blob
  • func (v *Blob) Compare(val TypedValue) (int, error)
  • func (v *Blob) IsNull() bool
  • func (v *Blob) Type() SQLValueType
  • func (v *Blob) Value() interface{}
• type Bool
  • func (v *Bool) Compare(val TypedValue) (int, error)
  • func (v *Bool) IsNull() bool
  • func (v *Bool) Type() SQLValueType
  • func (v *Bool) Value() interface{}
• type Cast
• type Catalog
  • func (c *Catalog) Databases() []*Database
  • func (c *Catalog) ExistDatabase(db string) bool
  • func (c *Catalog) GetDatabaseByID(id uint32) (*Database, error)
  • func (c *Catalog) GetDatabaseByName(name string) (*Database, error)
  • func (c *Catalog) GetTableByName(dbName, tableName string) (*Table, error)
• type CmpBoolExp
• type CmpOperator
• type ColDescriptor
  • func (d *ColDescriptor) Selector() string
• type ColSelector
• type ColSpec
• type Column
  • func (c *Column) ID() uint32
  • func (c *Column) IsAutoIncremental() bool
  • func (c *Column) IsNullable() bool
  • func (c *Column) MaxLen() int
  • func (c *Column) Name() string
  • func (c *Column) Type() SQLValueType
• type CommitStmt
• type Comparison
• type CountValue
  • func (v *CountValue) ColBounded() bool
  • func (v *CountValue) Compare(val TypedValue) (int, error)
  • func (v *CountValue) IsNull() bool
  • func (v *CountValue) Selector() string
  • func (v *CountValue) Type() SQLValueType
  • func (v *CountValue) Value() interface{}
• type CreateDatabaseStmt
• type CreateIndexStmt
• type CreateTableStmt
• type DataSource
• type Database
  • func (db *Database) ExistTable(table string) bool
  • func (db *Database) GetTableByID(id uint32) (*Table, error)
  • func (db *Database) GetTableByName(name string) (*Table, error)
  • func (db *Database) GetTables() []*Table
  • func (db *Database) ID() uint32
  • func (db *Database) Name() string
• type DeleteFromStmt
• type Engine
  • func NewEngine(store *store.ImmuStore, opts *Options) (*Engine, error)
  • func (e *Engine) Catalog(tx *SQLTx) (catalog *Catalog, err error)
  • func (e *Engine) CurrentDatabase() string
  • func (e *Engine) Exec(sql string, params map[string]interface{}, tx *SQLTx) (ntx *SQLTx, committedTxs []*SQLTx, err error)
  • func (e *Engine) ExecPreparedStmts(stmts []SQLStmt, params map[string]interface{}, tx *SQLTx) (ntx *SQLTx, committedTxs []*SQLTx, err error)
  • func (e *Engine) InferParameters(sql string, tx *SQLTx) (params map[string]SQLValueType, err error)
  • func (e *Engine) InferParametersPreparedStmts(stmts []SQLStmt, tx *SQLTx) (params map[string]SQLValueType, err error)
  • func (e *Engine) NewTx(ctx context.Context) (*SQLTx, error)
  • func (e *Engine) Query(sql string, params map[string]interface{}, tx *SQLTx) (RowReader, error)
  • func (e *Engine) QueryPreparedStmt(stmt DataSource, params map[string]interface{}, tx *SQLTx) (rowReader RowReader, err error)
  • func (e *Engine) SetCurrentDatabase(dbName string) error
  • func (e *Engine) SetMultiDBHandler(handler MultiDBHandler)
• type ExistsBoolExp
• type FnCall
• type FnDataSourceStmt
  • func (stmt *FnDataSourceStmt) Alias() string
  • func (stmt *FnDataSourceStmt) Resolve(tx *SQLTx, params map[string]interface{}, scanSpecs *ScanSpecs) (rowReader RowReader, err error)
• type InListExp
• type InSubQueryExp
• type Index
  • func (i *Index) Cols() []*Column
  • func (i *Index) IncludesCol(colID uint32) bool
  • func (i *Index) IsPrimary() bool
  • func (i *Index) IsUnique() bool
  • func (i *Index) Name() string
• type JoinSpec
• type JoinType
• type LikeBoolExp
• type LogicOperator
• type MaxValue
  • func (v *MaxValue) ColBounded() bool
  • func (v *MaxValue) Compare(val TypedValue) (int, error)
  • func (v *MaxValue) IsNull() bool
  • func (v *MaxValue) Selector() string
  • func (v *MaxValue) Type() SQLValueType
  • func (v *MaxValue) Value() interface{}
• type MinValue
  • func (v *MinValue) ColBounded() bool
  • func (v *MinValue) Compare(val TypedValue) (int, error)
  • func (v *MinValue) IsNull() bool
  • func (v *MinValue) Selector() string
  • func (v *MinValue) Type() SQLValueType
  • func (v *MinValue) Value() interface{}
• type MultiDBHandler
• type NotBoolExp
• type NullValue
  • func (n *NullValue) Compare(val TypedValue) (int, error)
  • func (n *NullValue) IsNull() bool
  • func (n *NullValue) Type() SQLValueType
  • func (n *NullValue) Value() interface{}
• type NumExp
• type NumOperator
• type Number
  • func (v *Number) Compare(val TypedValue) (int, error)
  • func (v *Number) IsNull() bool
  • func (v *Number) Type() SQLValueType
  • func (v *Number) Value() interface{}
• type OnConflictDo
• type Options
  • 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 OrdCol
• type Param
• type RenameColumnStmt
• type RollbackStmt
• type Row
• type RowReader
• type RowSpec
• type SQLStmt
  • func Parse(r io.ByteReader) ([]SQLStmt, error)
  • func ParseString(sql string) ([]SQLStmt, error)
• type SQLTx
  • func (sqlTx *SQLTx) Cancel() error
  • func (sqlTx *SQLTx) Closed() bool
  • func (sqlTx *SQLTx) Database() *Database
  • func (sqlTx *SQLTx) FirstInsertedPKs() map[string]int64
  • func (sqlTx *SQLTx) LastInsertedPKs() map[string]int64
  • func (sqlTx *SQLTx) Timestamp() time.Time
  • func (sqlTx *SQLTx) TxHeader() *store.TxHeader
  • func (sqlTx *SQLTx) UpdatedRows() int
• type SQLValueType
• type ScanSpecs
• type SelectStmt
  • func (stmt *SelectStmt) Alias() string
  • func (stmt *SelectStmt) Limit() int
  • func (stmt *SelectStmt) Offset() int
  • func (stmt *SelectStmt) Resolve(tx *SQLTx, params map[string]interface{}, _ *ScanSpecs) (ret RowReader, err error)
• type Selector
• type SumValue
  • func (v *SumValue) ColBounded() bool
  • func (v *SumValue) Compare(val TypedValue) (int, error)
  • func (v *SumValue) IsNull() bool
  • func (v *SumValue) Selector() string
  • func (v *SumValue) Type() SQLValueType
  • func (v *SumValue) Value() interface{}
• type Table
  • func (t *Table) Cols() []*Column
  • func (t *Table) ColsByName() map[string]*Column
  • func (t *Table) Database() *Database
  • func (t *Table) GetColumnByID(id uint32) (*Column, error)
  • func (t *Table) GetColumnByName(name string) (*Column, error)
  • func (t *Table) ID() uint32
  • func (t *Table) IndexesByColID(colID uint32) []*Index
  • func (t *Table) IsIndexed(colName string) (indexed bool, err error)
  • func (t *Table) Name() string
  • func (t *Table) PrimaryIndex() *Index
• type Timestamp
  • 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
  • func DecodeValue(b []byte, colType SQLValueType) (TypedValue, int, error)
• type UnionStmt
  • func (stmt *UnionStmt) Alias() string
  • func (stmt *UnionStmt) Resolve(tx *SQLTx, params map[string]interface{}, _ *ScanSpecs) (ret RowReader, err error)
• type UpdateStmt
• type UpsertIntoStmt
• type UseDatabaseStmt
• type UseSnapshotStmt
• type ValueExp
• type Varchar
  • func (v *Varchar) Compare(val TypedValue) (int, error)
  • func (v *Varchar) IsNull() bool
  • func (v *Varchar) Type() SQLValueType
  • func (v *Varchar) Value() interface{}

Constants

const (
	KeyValPrefixNull       byte = 0x20
	KeyValPrefixNotNull    byte = 0x80
	KeyValPrefixUpperBound byte = 0xFF
)

const (
	NamedNonPositionalParamType positionalParamType = iota + 1
	NamedPositionalParamType
	UnnamedParamType
)

const (
	PIndexPrefix = "R." // (key=R.{dbID}{tableID}{0}({null}({pkVal}{padding}{pkValLen})?)+, value={count (colID valLen val)+})
	SIndexPrefix = "E." // (key=E.{dbID}{tableID}{indexID}({null}({val}{padding}{valLen})?)+({pkVal}{padding}{pkValLen})+, value={})
	UIndexPrefix = "N." // (key=N.{dbID}{tableID}{indexID}({null}({val}{padding}{valLen})?)+, value={({pkVal}{padding}{pkValLen})+})

)

const (
	NowFnCall       string = "NOW"
	DatabasesFnCall string = "DATABASES"
	TablesFnCall    string = "TABLES"
	ColumnsFnCall   string = "COLUMNS"
	IndexesFnCall   string = "INDEXES"
)

const ADD = 57362

const AFTER = 57351

const AGGREGATE_FUNC = 57418

const ALL = 57397

const ALTER = 57361

const AS = 57395

const ASC = 57393

const AUTO_INCREMENT = 57404

const BEFORE = 57352

const BEGIN = 57368

const BLOB = 57417

const BOOLEAN = 57416

const BY = 57389

const CAST = 57406

const CMPOP = 57411

const COLUMN = 57365

const COMMIT = 57370

const CONFLICT = 57379

const CREATE = 57346

const DATABASE = 57348

const DELETE = 57376

const DESC = 57394

const DISTINCT = 57383

const DO = 57380

const ERROR = 57419

const EXISTS = 57401

const EncIDLen = 4

const EncLenLen = 4

const FROM = 57384

const GROUP = 57388

const HAVING = 57386

const IDENTIFIER = 57412

const IF = 57400

const IN = 57402

const INDEX = 57359

const INSERT = 57372

const INTO = 57374

const IS = 57403

const JOIN = 57385

const JOINTYPE = 57409

const KEY = 57367

const LIKE = 57399

const LIMIT = 57390

const LOP = 57410

const MaxNumberOfColumnsInIndex = 8

const NOT = 57398

const NOTHING = 57381

const NPARAM = 57407

const NULL = 57405

const NUMBER = 57414

const OF = 57355

const OFFSET = 57391

const ON = 57360

const ORDER = 57392

const PKIndexID = uint32(0)

const PPARAM = 57408

const PRIMARY = 57366

const RENAME = 57363

const ROLLBACK = 57371

const SELECT = 57382

const SET = 57378

const SINCE = 57350

const SNAPSHOT = 57349

const STMT_SEPARATOR = 57420

const TABLE = 57357

const TIMESTAMP = 57356

const TO = 57364

const TRANSACTION = 57369

const TX = 57354

const TYPE = 57413

const UNION = 57396

const UNIQUE = 57358

const UNTIL = 57353

const UPDATE = 57377

const UPSERT = 57373

const USE = 57347

const VALUES = 57375

const VARCHAR = 57415

const WHERE = 57387

Variables

var ErrAlreadyClosed = store.ErrAlreadyClosed

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

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

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

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

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

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 ErrDuplicatedParameters = errors.New("duplicated parameters")

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

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

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

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

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 ErrInferredMultipleTypes = errors.New("inferred multiple types")

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

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

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

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

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

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

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

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

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("indexed key of invalid type. Supported types are: INTEGER, VARCHAR[256] OR BLOB[256]")

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

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

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

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

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

var ErrMissingParameter = errors.New("missing parameter")

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

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

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

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

var ErrNoMoreRows = store.ErrNoMoreEntries

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

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

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

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 ErrPKCanNotBeUpdated = errors.New("primary key can not be updated")

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

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

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

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

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

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

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

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

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

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

Functions

func EncodeAsKey

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

func TimeFromInt64

func TimeFromInt64(t int64) time.Time

func TimeToInt64

func TimeToInt64(t time.Time) int64

func ValidOpts

func ValidOpts(opts *Options) bool

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) IsNull

func (v *AVGValue) IsNull() bool

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 BeginTransactionStmt

type BeginTransactionStmt struct {
}

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) IsNull

func (v *Blob) IsNull() bool

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) IsNull

func (v *Bool) IsNull() bool

func (*Bool) Type

func (v *Bool) Type() SQLValueType

func (*Bool) Value

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

type Cast

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

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

func (c *Column) IsAutoIncremental() bool

func (*Column) IsNullable

func (c *Column) IsNullable() bool

func (*Column) MaxLen

func (c *Column) MaxLen() int

func (*Column) Name

func (c *Column) Name() string

func (*Column) Type

func (c *Column) Type() SQLValueType

type CommitStmt

type CommitStmt struct {
}

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) IsNull

func (v *CountValue) IsNull() bool

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
	// contains filtered or unexported fields
}

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 {
	SQLStmt
	Resolve(tx *SQLTx, params map[string]interface{}, ScanSpecs *ScanSpecs) (RowReader, error)
	Alias() string
}

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 DeleteFromStmt

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

type Engine

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

func NewEngine

func NewEngine(store *store.ImmuStore, opts *Options) (*Engine, error)

func (*Engine) Catalog

func (e *Engine) Catalog(tx *SQLTx) (catalog *Catalog, err error)

func (*Engine) CurrentDatabase

func (e *Engine) CurrentDatabase() string

func (*Engine) Exec

func (e *Engine) Exec(sql string, params map[string]interface{}, tx *SQLTx) (ntx *SQLTx, committedTxs []*SQLTx, err error)

func (*Engine) ExecPreparedStmts

func (e *Engine) ExecPreparedStmts(stmts []SQLStmt, params map[string]interface{}, tx *SQLTx) (ntx *SQLTx, committedTxs []*SQLTx, err error)

func (*Engine) InferParameters

func (e *Engine) InferParameters(sql string, tx *SQLTx) (params map[string]SQLValueType, err error)

func (*Engine) InferParametersPreparedStmts

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

func (*Engine) NewTx

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

func (*Engine) Query

func (e *Engine) Query(sql string, params map[string]interface{}, tx *SQLTx) (RowReader, error)

func (*Engine) QueryPreparedStmt

func (e *Engine) QueryPreparedStmt(stmt DataSource, params map[string]interface{}, tx *SQLTx) (rowReader RowReader, err error)

func (*Engine) SetCurrentDatabase

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

func (*Engine) SetMultiDBHandler

func (e *Engine) SetMultiDBHandler(handler MultiDBHandler)

type ExistsBoolExp

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

type FnCall

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

type FnDataSourceStmt

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

func (*FnDataSourceStmt) Alias

func (stmt *FnDataSourceStmt) Alias() string

func (*FnDataSourceStmt) Resolve

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

type InListExp

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

TODO: once InSubQueryExp is supported, this struct may become obsolete by creating a ListDataSource struct

type InSubQueryExp

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

type Index

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

func (*Index) Cols

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

func (*Index) IncludesCol

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

func (*Index) IsPrimary

func (i *Index) IsPrimary() bool

func (*Index) IsUnique

func (i *Index) IsUnique() bool

func (*Index) Name

func (i *Index) Name() string

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) IsNull

func (v *MaxValue) IsNull() bool

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) IsNull

func (v *MinValue) IsNull() bool

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 MultiDBHandler

type MultiDBHandler interface {
	ListDatabases(ctx context.Context) ([]string, error)
	CreateDatabase(ctx context.Context, db string, ifNotExists bool) error
	UseDatabase(ctx context.Context, db string) error
	ExecPreparedStmts(ctx context.Context, stmts []SQLStmt, params map[string]interface{}) (ntx *SQLTx, committedTxs []*SQLTx, err error)
}

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) IsNull

func (n *NullValue) IsNull() bool

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) IsNull

func (v *Number) IsNull() bool

func (*Number) Type

func (v *Number) Type() SQLValueType

func (*Number) Value

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

type OnConflictDo

type OnConflictDo struct {
}

type Options

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

func DefaultOptions

func DefaultOptions() *Options

func (*Options) WithAutocommit

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

func (*Options) WithDistinctLimit

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

func (*Options) WithPrefix

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

type OrdCol

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

type Param

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

type RenameColumnStmt

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

type RollbackStmt

type RollbackStmt struct {
}

type Row

type Row struct {
	ValuesByPosition []TypedValue
	ValuesBySelector map[string]TypedValue
}

type RowReader

type RowReader interface {
	Tx() *SQLTx
	Database() string
	TableAlias() string
	Parameters() map[string]interface{}
	SetParameters(params map[string]interface{}) error
	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 SQLTx

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

SQLTx (no-thread safe) represents an interactive or incremental transaction with support of RYOW

func (*SQLTx) Cancel

func (sqlTx *SQLTx) Cancel() error

func (*SQLTx) Closed

func (sqlTx *SQLTx) Closed() bool

func (*SQLTx) Database

func (sqlTx *SQLTx) Database() *Database

func (*SQLTx) FirstInsertedPKs

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

func (*SQLTx) LastInsertedPKs

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

func (*SQLTx) Timestamp

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

func (*SQLTx) TxHeader

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

func (*SQLTx) UpdatedRows

func (sqlTx *SQLTx) UpdatedRows() int

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

type ScanSpecs struct {
	Index *Index

	DescOrder bool
	// 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() int

func (*SelectStmt) Offset

func (stmt *SelectStmt) Offset() int

func (*SelectStmt) Resolve

func (stmt *SelectStmt) Resolve(tx *SQLTx, params map[string]interface{}, _ *ScanSpecs) (ret 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) IsNull

func (v *SumValue) IsNull() bool

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 Table

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

func (*Table) Cols

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

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

func (t *Table) PrimaryIndex() *Index

type Timestamp

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

func (*Timestamp) Compare

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

func (*Timestamp) IsNull

func (v *Timestamp) IsNull() bool

func (*Timestamp) Type

func (v *Timestamp) Type() SQLValueType

func (*Timestamp) Value

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

type TypedValue

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

func DecodeValue

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

type UnionStmt

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

func (*UnionStmt) Alias

func (stmt *UnionStmt) Alias() string

func (*UnionStmt) Resolve

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

type UpdateStmt

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

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) IsNull

func (v *Varchar) IsNull() bool

func (*Varchar) Type

func (v *Varchar) Type() SQLValueType

func (*Varchar) Value

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