query

Nov 5, 2022

Changes in this version

+ const ErrorFatal

+ func NewFatalError(panicReport interface{}) error

+ type FatalError struct

Aug 14, 2022

Changes in this version

type FileInfo

+ ArchivePath string

+ func (f *FileInfo) IdentifiedPath() string

+ func (f *FileInfo) IsInlineTable() bool

+ func (f *FileInfo) IsRemoteObject() bool

+ func (f *FileInfo) IsStringObject() bool

type ObjectStatus

+ const ReadOnly

type ViewType

+ const ViewTypeRemoteObject

+ const ViewTypeStringObject

Jul 24, 2022

Changes in this version

+ const DefaultScreenWidth

+ const ErrMsgAliasMustBeSpecifiedForUpdate

+ const ErrMsgInlineTableCannotBeUpdated

+ const ErrMsgInvalidUrl

+ const ErrMsgUnsupportedUrlScheme

+ const ErrorAliasMustBeSpecifiedForUpdate

+ const ErrorInlineTableCannotBeUpdated

+ const ErrorInvalidUrl

+ const ErrorUnsupportedUrlScheme

+ func ConvertTableFunction(ctx context.Context, scope *ReferenceScope, tableFunction parser.TableFunction) (parser.QueryExpression, error)

+ func ConvertUrlExpr(urlExpr parser.Url) (parser.QueryExpression, error)

+ func FormatFieldIdentifier(e parser.QueryExpression) string

+ func FormatFieldLabel(e parser.QueryExpression) string

+ func FormatTableName(s string) string

+ func NewAliasMustBeSpecifiedForUpdateError(expr parser.QueryExpression) error

+ func NewInlineTableCannotBeUpdatedError(expr parser.QueryExpression) error

+ func NewInvalidUrlError(expr parser.Url) error

+ func NewUnsupportedUrlSchemeError(expr parser.Url, scheme string) error

+ func NormalizeTableObject(ctx context.Context, scope *ReferenceScope, tableObject parser.QueryExpression) (parser.QueryExpression, error)

+ func ParseTableName(ctx context.Context, scope *ReferenceScope, table parser.Table) (parser.Identifier, error)

+ type AliasMustBeSpecifiedForUpdateError struct

+ type DataObject struct

+ Raw string

+ func (o DataObject) String() string

type FileInfo

+ func NewInlineFileInfo(filePath string, importOptions option.ImportOptions, ...) *FileInfo

+ func NewStdinFileInfo(filePath string, importOptions option.ImportOptions, ...) *FileInfo

+ func NewTemporaryTableFileInfo(name string) *FileInfo

+ func (f *FileInfo) IsInMemoryTable() bool

+ func (f *FileInfo) IsUpdatable() bool

+ func (f *FileInfo) SetAllDefaultFileInfoAttributes(importOptions option.ImportOptions, exportOptions option.ExportOptions)

+ func (f *FileInfo) SetDefaultFileInfoAttributes(importOptions option.ImportOptions, exportOptions option.ExportOptions)

+ type HttpObject struct

+ URL string

+ func (o HttpObject) String() string

+ type InlineTableCannotBeUpdatedError struct

+ type InvalidUrlError struct

type ReferenceScope

+ func (rs *ReferenceScope) FilePathExists(identifier string) bool

type Session

+ func (sess *Session) ScreenWidth() int

type Transaction

+ UrlCache map[string]*UrlResource

+ func (tx *Transaction) ClearUrlCache()

+ func (tx *Transaction) CreateDocumentWriter() *doc.Writer

+ type UnsupportedUrlSchemeError struct

+ type UrlResource struct

+ Data []byte

+ MimeType string

+ func NewUrlResource(res *http.Response) (*UrlResource, error)

type View

+ func (view *View) IsUpdatable() bool

type ViewType

+ const ViewTypeInlineTable

Jul 3, 2022

Changes in this version

+ const ErrMsgIntegerDevidedByZero

+ const ErrMsgUndefinedConstant

+ const ErrorIntegerDevidedByZero

+ const ErrorUndefinedConstant

+ func Acosh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Asinh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Atanh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Cbrt(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Cosh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func IsInf(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func IsNaN(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Logb(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func MilliToDatetime(fn parser.Function, args []value.Primary, flags *option.Flags) (value.Primary, error)

+ func NewIntegerDevidedByZeroError(expr parser.Arithmetic) error

+ func NewUndefinedConstantError(expr parser.Constant) error

+ func Sinh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

+ func Tanh(fn parser.Function, args []value.Primary, _ *option.Flags) (value.Primary, error)

type BlockScope

+ Cursors CursorMap

+ Functions UserDefinedFunctionMap

+ TemporaryTables ViewMap

+ Variables VariableMap

type Cursor

+ Name string

+ type IntegerDevidedByZeroError struct

type ReferenceScope

+ Blocks []BlockScope

+ type UndefinedConstantError struct

Jun 19, 2022

Changes in this version

type Session

+ CanOutputToPipe bool

Jun 17, 2022

Changes in this version

+ const ErrMsgNotAllowedAnalyticFunction

+ const ErrorNotAllowedAnalyticFunction

+ func GetValuesInOrderByClause(e parser.OrderByClause) []parser.QueryExpression

+ func HasAggregateFunction(expr parser.QueryExpression, scope *ReferenceScope) (bool, error)

+ func HasAggregateFunctionInList(list []parser.QueryExpression, scope *ReferenceScope) (bool, error)

+ func NewNotAllowedAnalyticFunctionError(expr parser.AnalyticFunction) error

+ func SearchAnalyticFunctions(expr parser.QueryExpression) ([]parser.AnalyticFunction, error)

+ func SearchAnalyticFunctionsInList(list []parser.QueryExpression) ([]parser.AnalyticFunction, error)

type HeaderField

+ Identifier string

+ type NotAllowedAnalyticFunctionError struct

May 3, 2022

Changes in this version

+ func TitleCase(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

Feb 26, 2022

Changes in this version

+ const ErrMsgJsonLinesStructure

+ const ErrorJsonLinesStructure

+ func NewJsonLinesStructureError(expr parser.QueryExpression) error

+ func SearchJsonlFilePath(filename parser.Identifier, repository string) (string, error)

+ type JsonLinesStructureError struct

Mar 28, 2021

Changes in this version

+ const ErrMsgEmptyInlineTable

+ const ErrMsgHttpRequest

+ const ErrorEmptyInlineTable

+ const ErrorHttpRequestError

+ var RegExps = NewRegExpMap()

+ func NewEmptyInlineTableError(expr parser.TableObject) error

+ func NewHttpRequestError(expr parser.Expression, url string, message string) error

+ func RegExpFind(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ func RegExpFindAll(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ func RegExpFindSubMatches(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ func RegExpMatch(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ func RegExpReplace(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ type EmptyInlineTableError struct

+ type HttpRequestError struct

+ type RegExpMap struct

+ func NewRegExpMap() RegExpMap

+ func (rem RegExpMap) Get(expr string) (*regexp.Regexp, error)

+ func (rem RegExpMap) Load(key string) (*regexp.Regexp, bool)

+ func (rem RegExpMap) Store(key string, value *regexp.Regexp)

Nov 23, 2020

Changes in this version

+ func SerializeIdenticalKey(buf *bytes.Buffer, val value.Primary)

type SortValue

+ SerializedKey *bytes.Buffer

May 20, 2020

Changes in this version

+ const ApplyViewContextKey

+ const ApplyViewName

+ const ErrMsgIncorrectLateralUsage

+ const ErrorIncorrectLateralUsage

+ func NewIncorrectLateralUsageError(expr parser.Table) error

+ type ApplyView struct

+ JoinExpr parser.Join

+ View *View

type CursorMap

+ func (m CursorMap) LoadDirect(name string) (interface{}, bool)

type FileInfo

+ func (f *FileInfo) ExportOptions(tx *Transaction) cmd.ExportOptions

+ type IncorrectLateralUsageError struct

type InlineTableMap

+ func (it InlineTableMap) Store(name parser.Identifier, view *View) error

type ObjectWriter

+ Column int

+ func (w *ObjectWriter) LeadingSpacesWidth() int

+ func (w *ObjectWriter) WriteWithAutoLineBreakWithContinueMark(s string)

type PreparedStatementMap

+ func (m PreparedStatementMap) LoadDirect(name string) (interface{}, bool)

type ReferenceScope

+ func (rs *ReferenceScope) StoreInlineTable(name parser.Identifier, view *View) error

type UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) LoadDirect(name string) (interface{}, bool)

type VariableMap

+ func (m VariableMap) LoadDirect(name string) (interface{}, bool)

type ViewMap

+ func (m ViewMap) LoadDirect(name string) (interface{}, bool)

Apr 11, 2020

Changes in this version

+ func GetStdinForREPL() io.ReadCloser

Dec 12, 2019

Changes in this version

+ var DataEmpty = errors.New("data empty")

Oct 31, 2019

Changes in this version

+ func Substring(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

Jun 1, 2019

Changes in this version

+ func NotInRowValueList(rowValue value.RowValue, list []value.RowValue, datetimeFormats []string) (ternary.Value, error)

May 26, 2019

Changes in this version

+ func StdEV(list []value.Primary, _ *cmd.Flags) value.Primary

+ func StdEVP(list []value.Primary, _ *cmd.Flags) value.Primary

+ func Var(list []value.Primary, _ *cmd.Flags) value.Primary

+ func VarP(list []value.Primary, _ *cmd.Flags) value.Primary

May 19, 2019

Changes in this version

+ const ErrMsgNestedRecursion

+ const ErrorNestedRecursion

+ func NewNestedRecursionError(expr parser.QueryExpression) error

+ type NestedRecursionError struct

May 3, 2019

Changes in this version

+ const LimitToUseFieldIndexSliceChache

+ const LimitToUseUintSlicePool

+ func NanoToDatetime(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

+ type FieldIndexCache struct

+ func NewFieldIndexCache(initCap int, limitToUseSlice int) *FieldIndexCache

+ func (c *FieldIndexCache) Add(expr parser.QueryExpression, idx int)

+ func (c *FieldIndexCache) Get(expr parser.QueryExpression) (int, bool)

type ReferenceRecord

+ func NewReferenceRecord(view *View, recordIdx int, cacheLen int) ReferenceRecord

+ type UintPool struct

+ func NewUintPool(initCap int, limitToUseSlice int) *UintPool

+ func (c *UintPool) Add(val uint)

+ func (c *UintPool) Exists(val uint) bool

+ func (c *UintPool) Len() int

+ func (c *UintPool) Range(fn func(idx int, value uint) error) error

type View

+ func LoadView(ctx context.Context, scope *ReferenceScope, tables []parser.QueryExpression, ...) (*View, error)

+ func LoadViewFromTableIdentifier(ctx context.Context, scope *ReferenceScope, table parser.QueryExpression, ...) (*View, error)

Apr 28, 2019

Changes in this version

+ const ErrMsgDataEncoding

+ const ErrorDataEncoding

+ func NewDataEncodingError(message string) error

type Cell

+ func (cell Cell) ConvertToNewCell() Cell

+ type DataEncodingError struct

type Header

+ func (h Header) FieldIndex(fieldRef parser.FieldReference) (int, error)

+ func (h Header) FieldNumberIndex(number parser.ColumnNumber) (int, error)

+ func (h Header) SearchIndex(fieldRef parser.QueryExpression) (int, error)

type InlineTableMap

+ func (it InlineTableMap) Exists(name parser.Identifier) bool

type ReferenceScope

+ func (rs *ReferenceScope) InlineTableExists(name parser.Identifier) bool

Apr 25, 2019

Changes in this version

+ const ErrMsgCannotDetectFileEncoding

+ const ErrorCannotDetectFileEncoding

+ func NewCannotDetectFileEncodingError(file parser.QueryExpression) error

+ type CannotDetectFileEncodingError struct

Apr 22, 2019

Changes in this version

type CursorMap

+ func NewCursorMap() CursorMap

+ func (m CursorMap) Delete(name string)

+ func (m CursorMap) Exists(name string) bool

+ func (m CursorMap) IsEmpty() bool

+ func (m CursorMap) Load(name string) (*Cursor, bool)

+ func (m CursorMap) Store(name string, val *Cursor)

type UserDefinedFunctionMap

+ func NewUserDefinedFunctionMap() UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) Delete(name string)

+ func (m UserDefinedFunctionMap) Exists(name string) bool

+ func (m UserDefinedFunctionMap) IsEmpty() bool

+ func (m UserDefinedFunctionMap) Load(name string) (*UserDefinedFunction, bool)

+ func (m UserDefinedFunctionMap) Store(name string, val *UserDefinedFunction)

Apr 20, 2019

Changes in this version

type Transaction

+ func (tx *Transaction) SetFormatFlag(value interface{}, outFile string) error

Apr 20, 2019

Changes in this version

+ const ErrMsgRecursionExceededLimit

+ const ErrorRecursionExceededLimit

+ func EvalRowValue(ctx context.Context, scope *ReferenceScope, expr parser.QueryExpression) (value.RowValue, error)

+ func Evaluate(ctx context.Context, scope *ReferenceScope, expr parser.QueryExpression) (value.Primary, error)

+ func EvaluateEmbeddedString(ctx context.Context, scope *ReferenceScope, embedded string) (string, error)

+ func EvaluateSequentially(ctx context.Context, scope *ReferenceScope, view *View, ...) error

+ func GetComparisonKeysBuf() *bytes.Buffer

+ func NewRecursionExceededLimitError(selectEntity parser.QueryExpression, limit int64) error

+ func PutBlockScope(scope BlockScope)

+ func PutComparisonkeysBuf(buf *bytes.Buffer)

+ func PutNodeScope(scope NodeScope)

+ type BlockScope struct

+ func GetBlockScope() BlockScope

+ func NewBlockScope() BlockScope

+ func (scope BlockScope) Clear()

+ type BuiltInFunction func(parser.Function, []value.Primary, *cmd.Flags) (value.Primary, error)

+ type NodeScope struct

+ func GetNodeScope() NodeScope

+ func NewNodeScope() NodeScope

+ func (scope NodeScope) Clear()

type Processor

+ ReferenceScope *ReferenceScope

+ func NewProcessorWithScope(tx *Transaction, scope *ReferenceScope) *Processor

type RecordSet

+ func (r RecordSet) Merge(r2 RecordSet) RecordSet

+ type RecursionExceededLimitError struct

+ type ReferenceRecord struct

+ func (r *ReferenceRecord) IsInRange() bool

+ type ReferenceScope struct

+ Records []ReferenceRecord

+ RecursiveCount *int64

+ RecursiveTable *parser.InlineTable

+ RecursiveTmpView *View

+ Tx *Transaction

+ func NewReferenceScope(tx *Transaction) *ReferenceScope

+ func NewReferenceScopeWithBlock(tx *Transaction, scope BlockScope) *ReferenceScope

+ func (rs *ReferenceScope) AddAlias(alias parser.Identifier, path string) error

+ func (rs *ReferenceScope) AddPseudoCursor(name parser.Identifier, values []value.Primary) error

+ func (rs *ReferenceScope) AllCursors() CursorMap

+ func (rs *ReferenceScope) AllFunctions() (UserDefinedFunctionMap, UserDefinedFunctionMap)

+ func (rs *ReferenceScope) AllTemporaryTables() ViewMap

+ func (rs *ReferenceScope) AllVariables() VariableMap

+ func (rs *ReferenceScope) ClearCurrentBlock()

+ func (rs *ReferenceScope) CloseCurrentBlock()

+ func (rs *ReferenceScope) CloseCurrentNode()

+ func (rs *ReferenceScope) CloseCursor(name parser.Identifier) error

+ func (rs *ReferenceScope) CreateChild() *ReferenceScope

+ func (rs *ReferenceScope) CreateNode() *ReferenceScope

+ func (rs *ReferenceScope) CreateScopeForAnalytics() *ReferenceScope

+ func (rs *ReferenceScope) CreateScopeForRecordEvaluation(view *View, recordIndex int) *ReferenceScope

+ func (rs *ReferenceScope) CreateScopeForSequentialEvaluation(view *View) *ReferenceScope

+ func (rs *ReferenceScope) CurrentBlock() BlockScope

+ func (rs *ReferenceScope) CursorCount(name parser.Identifier) (int, error)

+ func (rs *ReferenceScope) CursorIsInRange(name parser.Identifier) (ternary.Value, error)

+ func (rs *ReferenceScope) CursorIsOpen(name parser.Identifier) (ternary.Value, error)

+ func (rs *ReferenceScope) DeclareAggregateFunction(expr parser.AggregateDeclaration) error

+ func (rs *ReferenceScope) DeclareCursor(expr parser.CursorDeclaration) error

+ func (rs *ReferenceScope) DeclareFunction(expr parser.FunctionDeclaration) error

+ func (rs *ReferenceScope) DeclareVariable(ctx context.Context, expr parser.VariableDeclaration) error

+ func (rs *ReferenceScope) DeclareVariableDirectly(variable parser.Variable, val value.Primary) error

+ func (rs *ReferenceScope) DisposeCursor(name parser.Identifier) error

+ func (rs *ReferenceScope) DisposeFunction(name parser.Identifier) error

+ func (rs *ReferenceScope) DisposeTemporaryTable(name parser.QueryExpression) error

+ func (rs *ReferenceScope) DisposeVariable(expr parser.Variable) error

+ func (rs *ReferenceScope) FetchCursor(name parser.Identifier, position int, number int) ([]value.Primary, error)

+ func (rs *ReferenceScope) GetAlias(alias parser.Identifier) (path string, err error)

+ func (rs *ReferenceScope) GetFunction(expr parser.QueryExpression, name string) (*UserDefinedFunction, error)

+ func (rs *ReferenceScope) GetInlineTable(name parser.Identifier) (*View, error)

+ func (rs *ReferenceScope) GetTemporaryTable(name parser.Identifier) (*View, error)

+ func (rs *ReferenceScope) GetTemporaryTableWithInternalId(ctx context.Context, name parser.Identifier, flags *cmd.Flags) (*View, error)

+ func (rs *ReferenceScope) GetVariable(expr parser.Variable) (value value.Primary, err error)

+ func (rs *ReferenceScope) Global() BlockScope

+ func (rs *ReferenceScope) LoadFilePath(identifier string) (string, bool)

+ func (rs *ReferenceScope) LoadInlineTable(ctx context.Context, clause parser.WithClause) error

+ func (rs *ReferenceScope) NextRecord() bool

+ func (rs *ReferenceScope) Now() time.Time

+ func (rs *ReferenceScope) OpenCursor(ctx context.Context, name parser.Identifier, values []parser.ReplaceValue) error

+ func (rs *ReferenceScope) ReplaceTemporaryTable(view *View)

+ func (rs *ReferenceScope) RestoreTemporaryTable(uncomittedViews map[string]*FileInfo) []string

+ func (rs *ReferenceScope) SetInlineTable(ctx context.Context, inlineTable parser.InlineTable) error

+ func (rs *ReferenceScope) SetTemporaryTable(view *View)

+ func (rs *ReferenceScope) StoreFilePath(identifier string, fpath string)

+ func (rs *ReferenceScope) StoreTemporaryTable(session *Session, uncomittedViews map[string]*FileInfo) []string

+ func (rs *ReferenceScope) SubstituteVariable(ctx context.Context, expr parser.VariableSubstitution) (val value.Primary, err error)

+ func (rs *ReferenceScope) SubstituteVariableDirectly(variable parser.Variable, val value.Primary) (value.Primary, error)

+ func (rs *ReferenceScope) TemporaryTableExists(name string) bool

type VariableMap

+ func (m VariableMap) IsEmpty() bool

type ViewMap

+ func (m ViewMap) IsEmpty() bool

Apr 16, 2019

Changes in this version

+ const ErrMsgFilterNotSet

+ const ErrorFilterNotSet

+ const ExecusionFilterContextKey

+ func ContextForExecusion(ctx context.Context, filter *Filter) context.Context

+ func ConvertContextError(err error) error

+ func NewFilterNotSetError() error

+ func PutAliasMap(t AliasMap)

+ func PutCursorMap(t CursorMap)

+ func PutInlineTableMap(t InlineTableMap)

+ func PutTemporaryViewMap(t ViewMap)

+ func PutUserDefinedFunctionMap(t UserDefinedFunctionMap)

+ func PutVariableMap(t VariableMap)

type AliasMap

+ func GetAliasMap() AliasMap

+ func (m AliasMap) Clear()

type CursorMap

+ func GetCursorMap() CursorMap

+ func (m CursorMap) Clear()

type Filter

+ func GetFilter(ctx context.Context) (*Filter, error)

+ func (f *Filter) CloseNode()

+ func (f *Filter) CloseScope()

+ type FilterNotSetError struct

type Header

+ func (h Header) Merge(h2 Header) Header

type InlineTableMap

+ func GetInlineTableMap() InlineTableMap

+ func (it InlineTableMap) Clear()

type Processor

+ func (proc *Processor) Close()

type Record

+ func (r Record) Merge(r2 Record, pool *sync.Pool) Record

type SyncMap

+ func (m SyncMap) Clear()

type UserDefinedFunctionMap

+ func GetUserDefinedFunctionMap() UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) Clear()

type VariableMap

+ func GetVariableMap() VariableMap

type ViewMap

+ func GetTemporaryViewMap() ViewMap

Apr 14, 2019

Changes in this version

+ const ErrMsgSelectIntoQueryFieldLengthNotMatch

+ const ErrMsgSelectIntoQueryTooManyRecords

+ const ErrorSelectIntoQueryFieldLengthNotMatch

+ const ErrorSelectIntoQueryTooManyRecords

+ func NewSelectIntoQueryFieldLengthNotMatchError(query parser.SelectQuery, fieldLen int) error

+ func NewSelectIntoQueryTooManyRecordsError(query parser.SelectQuery) error

+ type SelectIntoQueryFieldLengthNotMatchError struct

+ type SelectIntoQueryTooManyRecordsError struct

Apr 13, 2019

Changes in this version

+ const ErrMsgReplaceKeyNotSet

+ const ErrorReplaceKeyNotSet

+ func NewReplaceKeyNotSetError(key parser.QueryExpression) error

+ func ReplaceFn(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)

type Completer — darwin/amd64, linux/amd64, windows/amd64

+ func (c *Completer) ReplaceArgs(line string, origLine string, index int) readline.CandidateList

+ type ReplaceKeyNotSetError struct

type View

+ func (view *View) ReplaceFromQuery(ctx context.Context, fields []parser.QueryExpression, query parser.SelectQuery, ...) (int, error)

+ func (view *View) ReplaceValues(ctx context.Context, fields []parser.QueryExpression, ...) (int, error)

Apr 11, 2019

Changes in this version

type Transaction

+ func (tx *Transaction) GetFlag(key string) (value.Primary, bool)

+ func (tx *Transaction) SetFlag(key string, value interface{}, outFile string) error

Apr 10, 2019

Changes in this version

+ const ErrorContextCanceled

+ const ErrorContextDone

+ const ReturnCodeContextDone

+ func NewContextCanceled(message string) error

+ func NewContextDone(message string) error

+ type ContextCanceled struct

+ type ContextDone struct

type FileInfo

+ ViewType ViewType

+ func (f *FileInfo) IsFile() bool

+ func (f *FileInfo) IsStdin() bool

+ func (f *FileInfo) IsTemporaryTable() bool

type Session

+ func (sess *Session) GetStdinView(ctx context.Context, filter *Filter, fileInfo *FileInfo, expr parser.Stdin) (*View, error)

+ func (sess *Session) SetOutFile(w io.Writer)

+ func (sess *Session) SetStderr(w io.WriteCloser)

+ func (sess *Session) SetStdin(r io.ReadCloser) error

+ func (sess *Session) SetStdinContext(ctx context.Context, r io.ReadCloser) error

+ func (sess *Session) SetStdout(w io.WriteCloser)

+ func (sess *Session) SetTerminal(t VirtualTerminal)

+ type StdinLocker struct

+ func NewStdinLocker() *StdinLocker

+ func (cl *StdinLocker) Lock() error

+ func (cl *StdinLocker) LockContext(ctx context.Context) error

+ func (cl *StdinLocker) RLock() error

+ func (cl *StdinLocker) RLockContext(ctx context.Context) error

+ func (cl *StdinLocker) RUnlock() (err error)

+ func (cl *StdinLocker) Unlock() (err error)

type Transaction

+ Palette *color.Palette

+ func (tx *Transaction) Error(s string) string

+ func (tx *Transaction) LockStdinContext(ctx context.Context) error

+ func (tx *Transaction) Log(log string, quiet bool)

+ func (tx *Transaction) LogError(log string)

+ func (tx *Transaction) LogNotice(log string, quiet bool)

+ func (tx *Transaction) LogWarn(log string, quiet bool)

+ func (tx *Transaction) Notice(s string) string

+ func (tx *Transaction) RLockStdinContext(ctx context.Context) error

+ func (tx *Transaction) RUnlockStdin()

+ func (tx *Transaction) UnlockStdin()

+ func (tx *Transaction) UseColor(useColor bool)

+ func (tx *Transaction) Warn(s string) string

type View

+ func (view *View) CreateRestorePoint()

+ func (view *View) Restore()

+ type ViewType int

+ const ViewTypeFile

+ const ViewTypeStdin

+ const ViewTypeTemporaryTable

Apr 3, 2019

Changes in this version

+ const ErrMsgSignalReceived

+ const ReturnCodeIncorrectUsage

+ func NewSignalReceived(sig os.Signal) error

+ type SignalReceived struct

Apr 2, 2019

Changes in this version

+ const ErrMsgIO

+ const ErrMsgIncorrectCommandUsage

+ const ErrorIO

+ const ErrorIncorrectCommandUsage

+ func ConvertLoadConfigurationError(err error) error

+ func LoadContentsFromFile(ctx context.Context, tx *Transaction, fpath parser.Identifier) (content string, err error)

+ func NewIOError(expr parser.Expression, message string) error

+ func NewIncorrectCommandUsageError(message string) error

type BaseError

+ func (e *BaseError) Source() string

type Error

+ Char func() int

+ Code func() int

+ Line func() int

+ Message func() string

+ Source func() string

+ type IOError struct

+ type IncorrectCommandUsageError struct

+ type Input struct

+ func NewInput(r io.Reader) *Input

+ func (r *Input) Close() error

+ func (r *Input) Read(p []byte) (int, error)

+ type Output struct

+ func NewOutput() *Output

+ func (w *Output) Close() error

type Session

+ func (sess *Session) CanReadStdin() bool

Mar 31, 2019

Changes in this version

type PreparedStatementMap

+ func NewPreparedStatementMap() PreparedStatementMap

+ func (m PreparedStatementMap) Delete(name string)

+ func (m PreparedStatementMap) Exists(name string) bool

+ func (m PreparedStatementMap) Load(name string) (*PreparedStatement, bool)

+ func (m PreparedStatementMap) Store(name string, statement *PreparedStatement)

+ type SyncMap struct

+ func NewSyncMap() *SyncMap

+ func (m SyncMap) Keys() []string

+ func (m SyncMap) Len() int

+ func (m SyncMap) Range(fn func(key, value interface{}) bool)

+ func (m SyncMap) SortedKeys() []string

type VariableMap

+ func (m VariableMap) Delete(name string)

+ func (m VariableMap) Exists(name string) bool

+ func (m VariableMap) Load(name string) (value.Primary, bool)

+ func (m VariableMap) Store(name string, value value.Primary)

type ViewMap

+ func (m ViewMap) Delete(fpath string)

+ func (m ViewMap) Load(fpath string) (*View, bool)

+ func (m ViewMap) Store(fpath string, view *View)

Mar 29, 2019

Changes in this version

+ const ErrMsgInvalidCursorStatement

+ const ErrorInvalidCursorStatement

+ func NewInvalidCursorStatementError(statement parser.Identifier) error

type FileInfo

+ ForUpdate bool

+ type InvalidCursorStatementError struct

Mar 22, 2019

Changes in this version

+ const DefaultUserTriggeredErrorMessage

+ const ErrMsgAddFlagNotSupportedName

+ const ErrMsgBuiltInFunctionDeclared

+ const ErrMsgCombinedSetFieldLength

+ const ErrMsgCommit

+ const ErrMsgCursorClosed

+ const ErrMsgCursorFetchLength

+ const ErrMsgCursorOpen

+ const ErrMsgCursorRedeclared

+ const ErrMsgDataParsing

+ const ErrMsgDeleteTableNotSpecified

+ const ErrMsgDuplicateFieldName

+ const ErrMsgDuplicateParameter

+ const ErrMsgDuplicateStatementName

+ const ErrMsgDuplicateTableName

+ const ErrMsgEmptyJsonQuery

+ const ErrMsgEmptyJsonTable

+ const ErrMsgExternalCommand

+ const ErrMsgFieldAmbiguous

+ const ErrMsgFieldLengthInComparison

+ const ErrMsgFieldLengthNotMatch

+ const ErrMsgFieldNotExist

+ const ErrMsgFieldNotGroupKey

+ const ErrMsgFileAlreadyExist

+ const ErrMsgFileLockTimeout

+ const ErrMsgFileNameAmbiguous

+ const ErrMsgFileNotExist

+ const ErrMsgFileUnableToRead

+ const ErrMsgFlagValueNowAllowedFormat

+ const ErrMsgFormatStringLengthNotMatch

+ const ErrMsgFormatUnexpectedTermination

+ const ErrMsgFunctionArgumentsLength

+ const ErrMsgFunctionInvalidArgument

+ const ErrMsgFunctionNotExist

+ const ErrMsgFunctionRedeclared

+ const ErrMsgInlineTableFieldLength

+ const ErrMsgInlineTableRedefined

+ const ErrMsgInsertRowValueLength

+ const ErrMsgInsertSelectFieldLength

+ const ErrMsgInternalRecordIdEmpty

+ const ErrMsgInternalRecordIdNotExist

+ const ErrMsgInvalidEventName

+ const ErrMsgInvalidFetchPosition

+ const ErrMsgInvalidFlagName

+ const ErrMsgInvalidFlagValue

+ const ErrMsgInvalidFlagValueToBeRemoved

+ const ErrMsgInvalidLimitNumber

+ const ErrMsgInvalidLimitPercentage

+ const ErrMsgInvalidOffsetNumber

+ const ErrMsgInvalidPath

+ const ErrMsgInvalidReloadType

+ const ErrMsgInvalidRuntimeInformation

+ const ErrMsgInvalidTableAttributeName

+ const ErrMsgInvalidTableAttributeValue

+ const ErrMsgInvalidTableObject

+ const ErrMsgInvalidValueExpression

+ const ErrMsgJsonQueryTooManyRecords

+ const ErrMsgLoadConfiguration

+ const ErrMsgLoadJson

+ const ErrMsgNestedAggregateFunctions

+ const ErrMsgNotGroupingRecords

+ const ErrMsgNotTable

+ const ErrMsgPseudoCursor

+ const ErrMsgReadFile

+ const ErrMsgRemoveFlagNotSupportedName

+ const ErrMsgReplaceValueLength

+ const ErrMsgRollback

+ const ErrMsgRowValueLengthInComparison

+ const ErrMsgRowValueLengthInList

+ const ErrMsgShowInvalidObjectType

+ const ErrMsgSourceInvalidFilePath

+ const ErrMsgStatementNotExist

+ const ErrMsgStatementReplaceValueNotSpecified

+ const ErrMsgStdinEmpty

+ const ErrMsgSubqueryTooManyFields

+ const ErrMsgSubqueryTooManyRecords

+ const ErrMsgTableAttributeValueNotAllowedFormat

+ const ErrMsgTableFieldLength

+ const ErrMsgTableNotLoaded

+ const ErrMsgTableObjectArgumentsLength

+ const ErrMsgTableObjectInvalidArgument

+ const ErrMsgTableObjectInvalidDelimiter

+ const ErrMsgTableObjectInvalidDelimiterPositions

+ const ErrMsgTableObjectInvalidJsonQuery

+ const ErrMsgTableObjectJsonArgumentsLength

+ const ErrMsgTemporaryTableFieldLength

+ const ErrMsgTemporaryTableRedeclared

+ const ErrMsgUndeclaredCursor

+ const ErrMsgUndeclaredTemporaryTable

+ const ErrMsgUndeclaredVariable

+ const ErrMsgUndefinedInlineTable

+ const ErrMsgUnknownFormatPlaceholder

+ const ErrMsgUnpermittedFunctionStatement

+ const ErrMsgUpdateFieldNotExist

+ const ErrMsgUpdateValueAmbiguous

+ const ErrMsgVariableRedeclared

+ const ErrMsgWriteFile

+ const ErrorContextIsDone

+ const ErrorCursorOpen

+ const ErrorDuplicateStatementName

+ const ErrorEmptyJsonQuery

+ const ErrorEmptyJsonTable

+ const ErrorExit

+ const ErrorIOError

+ const ErrorInvalidPath

+ const ErrorInvalidTableObject

+ const ErrorInvalidValueExpression

+ const ErrorLoadJson

+ const ErrorPreparedStatementSyntaxError

+ const ErrorStatementNotExist

+ const ErrorStatementReplaceValueNotSpecified

+ const ErrorSyntaxError

+ const ErrorSystemError

+ const ErrorUnpermittedFunctionStatement

+ const ErrorUserTriggered

+ const ExitMessage

+ const ReturnCodeApplicationError

+ const ReturnCodeContextIsDone

+ const ReturnCodeDefaultUserTriggeredError

+ const ReturnCodeIOError

+ const ReturnCodeSyntaxError

+ const ReturnCodeSystemError

+ const ShowStatements

+ const StatementReplaceValuesContextKey

+ func ContextForPreparedStatement(ctx context.Context, values *ReplaceValues) context.Context

+ func NewDuplicateStatementNameError(name parser.Identifier) error

+ func NewEmptyJsonQueryError(expr parser.JsonQuery) error

+ func NewEmptyJsonTableError(expr parser.JsonQuery) error

+ func NewInvalidPathError(expr parser.Expression, path string, message string) error

+ func NewInvalidTableObjectError(expr parser.TableObject, objectName string) error

+ func NewInvalidValueExpressionError(expr parser.QueryExpression) error

+ func NewLoadJsonError(expr parser.JsonQuery, message string) error

+ func NewPreparedStatementSyntaxError(err *parser.SyntaxError) error

+ func NewStatementNotExistError(name parser.Identifier) error

+ func NewStatementReplaceValueNotSpecifiedError(placeholder parser.Placeholder) error

+ func NewTransactionOpenError(message string) error

+ func NewUnpermittedFunctionStatementError(expr parser.QueryExpression, funcname string) error

type BaseError

+ func (e *BaseError) Number() int

+ func (e *BaseError) ReturnCode() int

type Completer — darwin/amd64, linux/amd64, windows/amd64

+ func (c *Completer) PrepareArgs(line string, origLine string, index int) readline.CandidateList

+ type DuplicateStatementNameError struct

+ type EmptyJsonQueryError struct

+ type EmptyJsonTableError struct

type Error

+ AppendCompositeError func(Error)

+ Error func() string

+ ErrorMessage func() string

+ Number func() int

+ ReturnCode func() int

type Filter

+ func NewFilterWithScopes(tx *Transaction, variableScopes VariableScopes, ...) *Filter

+ type InvalidPathError struct

+ type InvalidTableObjectError struct

+ type InvalidValueExpressionError struct

+ type LoadJsonError struct

+ type PreparedStatement struct

+ HolderNumber int

+ Name string

+ StatementString string

+ Statements []parser.Statement

+ func NewPreparedStatement(filter *Filter, expr parser.StatementPreparation) (*PreparedStatement, error)

+ type PreparedStatementMap map[string]*PreparedStatement

+ func (m PreparedStatementMap) Dispose(expr parser.DisposeStatement) error

+ func (m PreparedStatementMap) Get(name parser.Identifier) (*PreparedStatement, error)

+ func (m PreparedStatementMap) Prepare(filter *Filter, expr parser.StatementPreparation) error

+ type PreparedStatementSyntaxError struct

+ type ReplaceValues struct

+ Names map[string]int

+ Values []parser.QueryExpression

+ func NewReplaceValues(replace []parser.ReplaceValue) *ReplaceValues

type StatementFlow

+ const TerminateWithError

+ type StatementNotExistError struct

+ type StatementReplaceValueNotSpecifiedError struct

type Transaction

+ PreparedStatements PreparedStatementMap

+ type TransactionOpenError struct

type UncommittedViews

+ Created map[string]*FileInfo

+ Updated map[string]*FileInfo

+ func NewUncommittedViews() *UncommittedViews

+ func (m *UncommittedViews) Clean()

+ func (m *UncommittedViews) CountCreatedTables() int

+ func (m *UncommittedViews) CountUpdatedTables() int

+ func (m *UncommittedViews) CountUpdatedViews() int

+ func (m *UncommittedViews) IsEmpty() bool

+ func (m *UncommittedViews) SetForCreatedView(fileInfo *FileInfo)

+ func (m *UncommittedViews) SetForUpdatedView(fileInfo *FileInfo)

+ func (m *UncommittedViews) UncommittedFiles() (map[string]*FileInfo, map[string]*FileInfo)

+ func (m *UncommittedViews) UncommittedTempViews() map[string]*FileInfo

+ func (m *UncommittedViews) Unset(fileInfo *FileInfo)

+ type UnpermittedFunctionStatementError struct

Mar 20, 2019

Changes in this version

+ const StoringResultsContextKey

+ func AppendCompositeError(e1 error, e2 error) error

+ func ContextForStoringResults(ctx context.Context) context.Context

+ func ConvertFileHandlerError(err error, ident parser.Identifier, fpath string) error

+ func NewContextIsDone(message string) error

+ func NewSystemError(message string) error

+ func NewTransactionError(message string) error

type AppError

+ AppendCompositeError func(AppError)

type BaseError

+ CompositeErrs []AppError

+ func (e *BaseError) AppendCompositeError(err AppError)

+ type ContextIsDone struct

+ type Discard struct

+ func NewDiscard() *Discard

+ func (d Discard) Close() error

+ func (d Discard) Write(p []byte) (int, error)

type Filter

+ Tx *Transaction

type ObjectWriter

+ Flags *cmd.Flags

+ type Processor struct

+ Filter *Filter

+ MeasurementStart time.Time

+ ReturnVal value.Primary

+ StoreResults bool

+ Tx *Transaction

+ func NewProcessor(tx *Transaction) *Processor

+ func NewProcessorWithFilter(tx *Transaction, filter *Filter) *Processor

+ func (proc *Processor) AutoCommit() error

+ func (proc *Processor) AutoRollback() error

+ func (proc *Processor) Case(ctx context.Context, stmt parser.Case) (StatementFlow, error)

+ func (proc *Processor) Commit(expr parser.Expression) error

+ func (proc *Processor) ExecExternalCommand(ctx context.Context, stmt parser.ExternalCommand) error

+ func (proc *Processor) Execute(ctx context.Context, statements []parser.Statement) (StatementFlow, error)

+ func (proc *Processor) ExecuteChild(ctx context.Context, statements []parser.Statement) (StatementFlow, error)

+ func (proc *Processor) ExecuteStatement(ctx context.Context, stmt parser.Statement) (StatementFlow, error)

+ func (proc *Processor) IfStmt(ctx context.Context, stmt parser.If) (StatementFlow, error)

+ func (proc *Processor) Log(log string, quiet bool)

+ func (proc *Processor) LogError(log string)

+ func (proc *Processor) LogNotice(log string, quiet bool)

+ func (proc *Processor) LogWarn(log string, quiet bool)

+ func (proc *Processor) NewChildProcessor() *Processor

+ func (proc *Processor) ReleaseResources() error

+ func (proc *Processor) ReleaseResourcesWithErrors() error

+ func (proc *Processor) Rollback(expr parser.Expression) error

+ func (proc *Processor) While(ctx context.Context, stmt parser.While) (StatementFlow, error)

+ func (proc *Processor) WhileInCursor(ctx context.Context, stmt parser.WhileInCursor) (StatementFlow, error)

+ type Session struct

+ OutFile io.Writer

+ ScreenFd uintptr

+ Stderr io.WriteCloser

+ Stdin io.ReadCloser

+ Stdout io.WriteCloser

+ Terminal VirtualTerminal

+ func NewSession() *Session

+ func (sess *Session) Log(log string, quiet bool)

+ func (sess *Session) LogError(log string)

+ func (sess *Session) LogNotice(log string, quiet bool)

+ func (sess *Session) LogWarn(log string, quiet bool)

+ func (sess *Session) WriteToStderr(s string) error

+ func (sess *Session) WriteToStderrWithLineBreak(s string) error

+ func (sess *Session) WriteToStdout(s string) error

+ func (sess *Session) WriteToStdoutWithLineBreak(s string) error

+ type SystemError struct

+ type Transaction struct

+ AffectedRows int

+ AutoCommit bool

+ CachedViews ViewMap

+ Environment *cmd.Environment

+ FileContainer *file.Container

+ Flags *cmd.Flags

+ RetryDelay time.Duration

+ SelectedViews []*View

+ Session *Session

+ UncommittedViews *UncommittedViewMap

+ WaitTimeout time.Duration

+ func NewTransaction(ctx context.Context, defaultWaitTimeout time.Duration, ...) (*Transaction, error)

+ func (tx *Transaction) Commit(filter *Filter, expr parser.Expression) error

+ func (tx *Transaction) ReleaseResources() error

+ func (tx *Transaction) ReleaseResourcesWithErrors() error

+ func (tx *Transaction) Rollback(filter *Filter, expr parser.Expression) error

+ func (tx *Transaction) UpdateWaitTimeout(waitTimeout float64, retryDelay time.Duration)

+ type TransactionError struct

type View

+ Tx *Transaction

Mar 3, 2019

Changes in this version

+ const TableDelimiterPositions

type FileInfo

+ func (f *FileInfo) SetDelimiterPositions(s string) error

Feb 25, 2019

Changes in this version

type FileInfo

+ SingleLine bool

Jan 5, 2019

Changes in this version

type Completer — darwin/amd64, linux/amd64, windows/amd64

+ func (c *Completer) FunctionArgs(line string, origLine string, index int) readline.CandidateList

Dec 31, 2018

Changes in this version

+ func SearchLTSVFilePath(filename parser.Identifier, repository string) (string, error)

Dec 26, 2018

Changes in this version

+ const MinimumRequiredPerCPUCore

+ func CalcMinimumRequired(i1 int, i2 int, defaultMinimumRequired int) int

type GoroutineManager

+ MinimumRequiredPerCore int

Dec 24, 2018

Changes in this version

+ func Syntax(expr parser.Syntax, filter *Filter) string

type ObjectWriter

+ func (w *ObjectWriter) WriteWithAutoLineBreak(s string)

Dec 13, 2018

Changes in this version

+ const ShowCursors

+ const ShowEnv

+ const ShowFlags

+ const ShowFunctions

+ const ShowRuninfo

+ const ShowTables

+ const ShowViews

+ const TablePrettyPrint

+ var FileAttributeList = []string

+ var ShowObjectList = []string

+ type Completer struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewCompleter(filter *Filter) *Completer

+ func (c *Completer) AddFlagArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) AllColumnList() []string

+ func (c *Completer) AlterArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) BracketIsEnclosed() bool

+ func (c *Completer) CaseExpression(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) ColumnList(tableName string, repository string) []string

+ func (c *Completer) CreateArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) CursorStatus(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) DeclareArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) DeleteArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) DisposeArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) Do(line []rune, pos int, index int) (readline.CandidateList, int)

+ func (c *Completer) EncloseQuotation(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) FetchArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) GetStatementPrefix(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) InsertArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) ListFiles(path string, includeExt []string, repository string) []string

+ func (c *Completer) RemoveFlagArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchAllTables(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchAllTablesWithSpace(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchDirs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchExecutableFiles(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchValues(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SearchValuesWithSpace(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SelectArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SetArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) SetLastIndex(line string)

+ func (c *Completer) ShowArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) Statements(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) TableObjectArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) Update()

+ func (c *Completer) UpdateArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) UpdateTokens(line string, origLine string)

+ func (c *Completer) UsingArgs(line string, origLine string, index int) readline.CandidateList

+ func (c *Completer) WithArgs(line string, origLine string, index int) readline.CandidateList

type ReadLineTerminal — darwin/amd64, linux/amd64, windows/amd64

+ func (t ReadLineTerminal) ReloadConfig() error

+ func (t ReadLineTerminal) UpdateCompleter()

+ type ReadlineListener struct — darwin/amd64, linux/amd64, windows/amd64

+ func (l ReadlineListener) OnChange(line []rune, pos int, key rune) (newLine []rune, newPos int, ok bool)

type SSHTerminal — js/wasm

+ func (t SSHTerminal) ReloadConfig() error

+ func (t SSHTerminal) UpdateCompleter()

type VariableMap

+ func (m *VariableMap) SortedKeys() []string

type VariableScopes

+ func (list VariableScopes) All() VariableMap

type VirtualTerminal

+ ReloadConfig func() error

+ UpdateCompleter func()

Dec 2, 2018

Changes in this version

+ func LogError(log string)

+ func LogNotice(log string, quiet bool)

+ func LogWarn(log string, quiet bool)

+ type EmptyResultSetError struct

+ func NewEmptyResultSetError() *EmptyResultSetError

+ func (e EmptyResultSetError) Error() string

type GoroutineTaskManager

+ func (m *GoroutineTaskManager) Run(fn func(int))

Nov 27, 2018

Changes in this version

+ type ContainsSubstitusion struct

+ func (c *ContainsSubstitusion) Error() string

type Filter

+ func (f *Filter) CanUseMultithreading(expr interface{}) bool

+ func (f *Filter) EvaluateSequentially(expr interface{}, fn func(*Filter, int) error) error

type GoroutineManager

+ Count int

+ CountMutex *sync.Mutex

+ MinimumRequired int

+ func GetGoroutineManager() *GoroutineManager

+ func (m *GoroutineManager) AssignRoutineNumber(recordLen int, minimumRequired int) int

+ func (m *GoroutineManager) Release()

+ type GoroutineTaskManager struct

+ Number int

+ func NewGoroutineTaskManager(recordLen int, minimumRequired int) *GoroutineTaskManager

+ func (m *GoroutineTaskManager) Add()

+ func (m *GoroutineTaskManager) Done()

+ func (m *GoroutineTaskManager) Err() error

+ func (m *GoroutineTaskManager) HasError() bool

+ func (m *GoroutineTaskManager) RecordRange(routineIndex int) (int, int)

+ func (m *GoroutineTaskManager) SetError(e error)

+ func (m *GoroutineTaskManager) Wait()

type VariableMap

+ func NewVariableMap() VariableMap

+ func (m *VariableMap) Equal(m2 *VariableMap) bool

type VariableScopes

+ func (list VariableScopes) Equal(list2 VariableScopes) bool

Nov 25, 2018

Changes in this version

+ const ErrorAddFlagNotSupportedName

+ const ErrorInvalidFlagValueToBeRemoved

+ const ErrorRemoveFlagNotSupportedName

+ func AddFlagElement(expr parser.AddFlagElement, filter *Filter) error

+ func NewAddFlagNotSupportedNameError(expr parser.AddFlagElement) error

+ func NewInvalidFlagValueToBeRemovedError(unsetFlag parser.RemoveFlagElement) error

+ func NewRemoveFlagNotSupportedNameError(expr parser.RemoveFlagElement) error

+ func RemoveFlagElement(expr parser.RemoveFlagElement, filter *Filter) error

+ type AddFlagNotSupportedNameError struct

+ type InvalidFlagValueToBeRemoveError struct

+ type RemoveFlagNotSupportedNameError struct

Nov 24, 2018

Changes in this version

+ const CreatedInformation

+ const DefaultLineWidth

+ const DefaultPadding

+ const ErrorExternalCommand

+ const ErrorInvalidReloadType

+ const ErrorInvalidRuntimeInformation

+ const ErrorInvalidValue

+ const ErrorLoadConfiguration

+ const ErrorPath

+ const LoadedTablesInformation

+ const ReloadConfig

+ const TerminalContinuousPrompt

+ const TerminalPrompt

+ const UncommittedInformation

+ const UpdatedInformation

+ const UpdatedViewsInformation

+ const VersionInformation

+ const WorkingDirectory

+ var Formatter = NewStringFormatter()

+ var RuntimeInformatinList = []string

+ var ScreenFd = os.Stdin.Fd()

+ var Stderr io.WriteCloser = os.Stderr

+ var Stdin io.ReadCloser = os.Stdin

+ var Stdout io.WriteCloser = os.Stdout

+ var Terminal VirtualTerminal

+ var UncommittedViews = NewUncommittedViewMap()

+ var Version string

+ func Chdir(expr parser.Chdir, filter *Filter) error

+ func Echo(expr parser.Echo, filter *Filter) (string, error)

+ func GetRuntimeInformation(expr parser.RuntimeInformation) (value.Primary, error)

+ func HistoryFilePath(filename string) (string, error) — darwin/amd64, linux/amd64, windows/amd64

+ func NewExternalCommandError(expr parser.Expression, message string) error

+ func NewInvalidReloadTypeError(expr parser.Reload, name string) error

+ func NewInvalidRuntimeInformationError(expr parser.RuntimeInformation) error

+ func NewInvalidValueError(expr parser.QueryExpression) error

+ func NewLoadConfigurationError(expr parser.Reload, message string) error

+ func NewPathError(expr parser.Expression, path string, message string) error

+ func NewPromptEvaluationError(message string) error

+ func NewTableAttributeUnchangedError(fpath string) error

+ func Pwd(expr parser.Pwd) (string, error)

+ func Reload(expr parser.Reload) error

+ func WriteToStderr(s string) error

+ func WriteToStderrWithLineBreak(s string) error

+ func WriteToStdout(s string) error

+ func WriteToStdoutWithLineBreak(s string) error

+ type ExternalCommandError struct

type Filter

+ func (f *Filter) EvaluateEmbeddedString(embedded string) (string, error)

+ type InvalidReloadTypeError struct

+ type InvalidRuntimeInformationError struct

+ type InvalidValueError struct

+ type LoadConfigurationError struct

+ type ObjectWriter struct

+ Indent int

+ IndentWidth int

+ MaxWidth int

+ Padding int

+ Palette *color.Palette

+ Title1 string

+ Title1Effect string

+ Title2 string

+ Title2Effect string

+ func NewObjectWriter() *ObjectWriter

+ func (w *ObjectWriter) BeginBlock()

+ func (w *ObjectWriter) BeginSubBlock()

+ func (w *ObjectWriter) Clear()

+ func (w *ObjectWriter) ClearBlock()

+ func (w *ObjectWriter) EndBlock()

+ func (w *ObjectWriter) EndSubBlock()

+ func (w *ObjectWriter) FitInLine(s string) bool

+ func (w *ObjectWriter) NewLine()

+ func (w *ObjectWriter) String() string

+ func (w *ObjectWriter) Write(s string)

+ func (w *ObjectWriter) WriteColor(s string, effect string)

+ func (w *ObjectWriter) WriteColorWithoutLineBreak(s string, effect string)

+ func (w *ObjectWriter) WriteSpaces(l int)

+ func (w *ObjectWriter) WriteWithoutLineBreak(s string)

+ type PathError struct

type Procedure

+ func (proc *Procedure) ExecExternalCommand(stmt parser.ExternalCommand) error

+ type Prompt struct

+ func NewPrompt(filter *Filter, palette *color.Palette) *Prompt

+ func (p *Prompt) LoadConfig() error

+ func (p *Prompt) Render(sequence []PromptElement) (string, error)

+ func (p *Prompt) RenderContinuousPrompt() (string, error)

+ func (p *Prompt) RenderPrompt() (string, error)

+ func (p *Prompt) StripEscapeSequence(s string) string

+ type PromptElement struct

+ Text string

+ Type excmd.ElementType

+ type PromptEvaluationError struct

+ Message string

+ func (e PromptEvaluationError) Error() string

+ type ReadLineTerminal struct — darwin/amd64, linux/amd64, windows/amd64

+ func (t ReadLineTerminal) GetSize() (int, int, error)

+ func (t ReadLineTerminal) ReadLine() (string, error)

+ func (t ReadLineTerminal) ReloadPromptConfig() error

+ func (t ReadLineTerminal) RestoreOriginalMode() error

+ func (t ReadLineTerminal) RestoreRawMode() error

+ func (t ReadLineTerminal) SaveHistory(s string)

+ func (t ReadLineTerminal) SetContinuousPrompt()

+ func (t ReadLineTerminal) SetPrompt()

+ func (t ReadLineTerminal) Teardown()

+ func (t ReadLineTerminal) Write(s string) error

+ func (t ReadLineTerminal) WriteError(s string) error

+ type SSHTerminal struct — js/wasm

+ func (t SSHTerminal) GetSize() (int, int, error)

+ func (t SSHTerminal) ReadLine() (string, error)

+ func (t SSHTerminal) ReloadPromptConfig() error

+ func (t SSHTerminal) RestoreOriginalMode() error

+ func (t SSHTerminal) RestoreRawMode() error

+ func (t SSHTerminal) SaveHistory(s string)

+ func (t SSHTerminal) SetContinuousPrompt()

+ func (t SSHTerminal) SetPrompt()

+ func (t SSHTerminal) Teardown()

+ func (t SSHTerminal) Write(s string) error

+ func (t SSHTerminal) WriteError(s string) error

+ type StdIO struct — js/wasm

+ func NewStdIO() *StdIO

+ func (sh *StdIO) Read(p []byte) (n int, err error)

+ func (sh *StdIO) Write(p []byte) (n int, err error)

+ type TableAttributeUnchangedError struct

+ Message string

+ Path string

+ func (e TableAttributeUnchangedError) Error() string

+ type UncommittedViewMap struct

+ Created map[string]*FileInfo

+ Updated map[string]*FileInfo

+ func NewUncommittedViewMap() *UncommittedViewMap

+ func (m *UncommittedViewMap) Clean()

+ func (m *UncommittedViewMap) CountCreatedTables() int

+ func (m *UncommittedViewMap) CountUpdatedTables() int

+ func (m *UncommittedViewMap) CountUpdatedViews() int

+ func (m *UncommittedViewMap) IsEmpty() bool

+ func (m *UncommittedViewMap) SetForCreatedView(fileInfo *FileInfo)

+ func (m *UncommittedViewMap) SetForUpdatedView(fileInfo *FileInfo)

+ func (m *UncommittedViewMap) UncommittedFiles() (map[string]*FileInfo, map[string]*FileInfo)

+ func (m *UncommittedViewMap) UncommittedTempViews() map[string]*FileInfo

+ func (m *UncommittedViewMap) Unset(fileInfo *FileInfo)

+ type VirtualTerminal interface

+ GetSize func() (int, int, error)

+ ReadLine func() (string, error)

+ ReloadPromptConfig func() error

+ RestoreOriginalMode func() error

+ RestoreRawMode func() error

+ SaveHistory func(string)

+ SetContinuousPrompt func()

+ SetPrompt func()

+ Teardown func()

+ Write func(string) error

+ WriteError func(string) error

+ func NewTerminal(filter *Filter) (VirtualTerminal, error)

Nov 18, 2018

Changes in this version

+ const TableJsonEscape

type FileInfo

+ JsonEscape json.EscapeType

+ func (f *FileInfo) SetJsonEscape(s string) error

Nov 18, 2018

Changes in this version

+ const ErrorCommit

+ const ErrorMessageWithCustomPrefixTemplate

+ const ErrorRollback

+ const TableEncloseAll

+ var OutFile *os.File

+ var SelectResult = new(bytes.Buffer)

+ func ConvertFieldContents(val value.Primary, forTextTable bool) (string, string, text.FieldAlignment)

+ func LoadStatementsFromFile(expr parser.Source, fpath string) ([]parser.Statement, error)

+ func NewCommitError(expr parser.Expression, message string) error

+ func NewRollbackError(expr parser.Expression, message string) error

+ func ReleaseResourcesWithErrors() error

+ func SetEnvVar(expr parser.SetEnvVar, filter *Filter) error

+ func UnsetEnvVar(expr parser.UnsetEnvVar) error

type BaseError

+ Prefix string

+ func NewBaseErrorWithPrefix(prefix string, message string, code int) *BaseError

+ type CommitError struct

type FileInfo

+ EncloseAll bool

+ Handler *file.Handler

+ func (f *FileInfo) Close() error

+ func (f *FileInfo) CloseWithErrors() error

+ func (f *FileInfo) Commit() error

+ func (f *FileInfo) SetEncloseAll(b bool)

+ type RollbackError struct

type ViewMap

+ func (m ViewMap) CleanWithErrors() error

Nov 8, 2018

Changes in this version

+ const EOF

+ const ErrorFormatUnexpectedTermination

+ const ErrorReplaceValueLength

+ const ErrorSourceInvalidFilePath

+ const ErrorUnknownFormatPlaceholder

+ func NewFormatUnexpectedTerminationError() error

+ func NewReplaceValueLengthError(expr parser.Expression, message string) error

+ func NewSourceInvalidFilePathError(source parser.Source, arg parser.QueryExpression) error

+ func NewUnknownFormatPlaceholderError(placeholder rune) error

+ func NumberFormat(fn parser.Function, args []value.Primary) (value.Primary, error)

+ func ParseExecuteStatements(expr parser.Execute, filter *Filter) ([]parser.Statement, error)

+ type FormatUnexpectedTerminationError struct

+ type ReplaceValueLengthError struct

+ type SourceInvalidFilePathError struct

+ type StringFormatter struct

+ func NewStringFormatter() *StringFormatter

+ func (f *StringFormatter) Format(format string, values []value.Primary) (string, error)

+ type UnknownFormatPlaceholderError struct

Nov 4, 2018

Changes in this version

+ const ErrorDataParsing

+ const ErrorFileNameAmbiguous

+ const ErrorFlagValueNowAllowedFormat

+ const ErrorInvalidEventName

+ const ErrorInvalidTableAttributeName

+ const ErrorInvalidTableAttributeValue

+ const ErrorJsonQueryEmpty

+ const ErrorNotTable

+ const ErrorShowInvalidObjectType

+ const ErrorTableAttributeValueNotAllowedFormat

+ const ErrorTableObjectArgumentsLength

+ const ErrorTableObjectInvalidArgument

+ const ErrorTableObjectInvalidDelimiter

+ const ErrorTableObjectInvalidDelimiterPositions

+ const ErrorTableObjectInvalidJsonQuery

+ const ErrorTableObjectInvalidObject

+ const ErrorTableObjectJsonArgumentsLength

+ const ErrorTableObjectMultipleRead

+ const IgnoredFlagPrefix

+ const TableDelimiter

+ const TableEncoding

+ const TableFormat

+ const TableHeader

+ const TableLineBreak

+ const TablePrettyPring

+ var ExecResults = make([]ExecResult, 0, 10)

+ func CreateFilePath(filename parser.Identifier, repository string) (string, error)

+ func NewDataParsingError(file parser.QueryExpression, filepath string, message string) error

+ func NewFileNameAmbiguousError(file parser.Identifier) error

+ func NewFlagValueNotAllowedFormatError(setFlag parser.SetFlag) error

+ func NewInvalidEventNameError(expr parser.Identifier) error

+ func NewInvalidTableAttributeNameError(expr parser.Identifier) error

+ func NewInvalidTableAttributeValueError(expr parser.SetTableAttribute, message string) error

+ func NewJsonQueryEmptyError(expr parser.JsonQuery) error

+ func NewNotTableError(expr parser.QueryExpression) error

+ func NewShowInvalidObjectTypeError(expr parser.Expression, objectType string) error

+ func NewTableAttributeValueNotAllowedFormatError(expr parser.SetTableAttribute) error

+ func NewTableObjectArgumentsLengthError(expr parser.TableObject, argLen int) error

+ func NewTableObjectInvalidArgumentError(expr parser.TableObject, message string) error

+ func NewTableObjectInvalidDelimiterError(expr parser.TableObject, delimiter string) error

+ func NewTableObjectInvalidDelimiterPositionsError(expr parser.TableObject, positions string) error

+ func NewTableObjectInvalidJsonQueryError(expr parser.TableObject, jsonQuery string) error

+ func NewTableObjectInvalidObjectError(expr parser.TableObject, objectName string) error

+ func NewTableObjectJsonArgumentsLengthError(expr parser.TableObject, argLen int) error

+ func NewTableObjectMultipleReadError(tableIdentifier parser.Identifier) error

+ func SearchCSVFilePath(filename parser.Identifier, repository string) (string, error)

+ func SearchFilePath(filename parser.Identifier, repository string, format cmd.Format) (string, cmd.Format, error)

+ func SearchFilePathFromAllTypes(filename parser.Identifier, repository string) (string, error)

+ func SearchFilePathWithExtType(filename parser.Identifier, repository string, extTypes []string) (string, error)

+ func SearchFixedLengthFilePath(filename parser.Identifier, repository string) (string, error)

+ func SearchJsonFilePath(filename parser.Identifier, repository string) (string, error)

+ func SetTableAttribute(query parser.SetTableAttribute, parentFilter *Filter) (string, error)

+ func UncommittedFiles() (map[string]*FileInfo, map[string]*FileInfo)

+ func UncommittedTempViews() map[string]*FileInfo

+ func Width(fn parser.Function, args []value.Primary) (value.Primary, error)

type Cursor

+ func (c *Cursor) Count() (int, error)

+ func (c *Cursor) IsInRange() (ternary.Value, error)

+ func (c *Cursor) IsOpen() ternary.Value

+ func (c *Cursor) Pointer() (int, error)

type CursorMap

+ func (m CursorMap) Keys() []string

+ func (m CursorMap) SortedKeys() []string

type CursorScopes

+ func (list CursorScopes) All() CursorMap

+ type DataParsingError struct

+ type Direction string

+ const LeftDirection

+ const RightDirection

+ type ExecResult struct

+ FileInfo *FileInfo

+ OperatedCount int

+ Type OperationType

type FileInfo

+ DelimiterPositions text.DelimiterPositions

+ Format cmd.Format

+ JsonQuery string

+ PrettyPrint bool

+ func (f *FileInfo) Equivalent(f2 *FileInfo) bool

+ func (f *FileInfo) SetDelimiter(s string) error

+ func (f *FileInfo) SetEncoding(s string) error

+ func (f *FileInfo) SetFormat(s string) error

+ func (f *FileInfo) SetLineBreak(s string) error

+ func (f *FileInfo) SetNoHeader(b bool)

+ func (f *FileInfo) SetPrettyPrint(b bool)

+ type FileNameAmbiguousError struct

+ type FlagValueNotAllowedFormatError struct

type Header

+ func NewHeaderWithAutofill(view string, words []string) Header

+ type InvalidEventNameError struct

+ type InvalidTableAttributeNameError struct

+ type InvalidTableAttributeValueError struct

+ type JsonQueryEmptyError struct

+ type NotTableError struct

+ type ObjectStatus int

+ const ObjectCreated

+ const ObjectFixed

+ const ObjectUpdated

+ type PaddingType string

+ const PaddingByteCount

+ const PaddingRuneCount

+ const PaddingWidth

+ type RecordReader interface

+ Read func() ([]value.Field, error)

+ type ShowInvalidObjectTypeError struct

+ type TableAttributeValueNotAllowedFormatError struct

+ type TableObjectArgumentsLengthError struct

+ type TableObjectInvalidArgumentError struct

+ type TableObjectInvalidDelimiterError struct

+ type TableObjectInvalidDelimiterPositionsError struct

+ type TableObjectInvalidJsonQueryError struct

+ type TableObjectInvalidObjectError struct

+ type TableObjectJsonArgumentsLengthError struct

+ type TableObjectMultipleReadError struct

type TemporaryViewScopes

+ func (list TemporaryViewScopes) All() ViewMap

type UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) Keys() []string

+ func (m UserDefinedFunctionMap) SortedKeys() []string

type UserDefinedFunctionScopes

+ func (list UserDefinedFunctionScopes) All() (UserDefinedFunctionMap, UserDefinedFunctionMap)

type ViewMap

+ func (m ViewMap) Keys() []string

+ func (m ViewMap) SortedKeys() []string

Oct 19, 2018

Changes in this version

+ const CPUFlag

+ const ColorFlag

+ const DatetimeFormatFlag

+ const DelimiterFlag

+ const EncodingFlag

+ const FormatFlag

+ const LineBreakFlag

+ const MinimumRequiredForParallelRoutine

+ const NoHeaderFlag

+ const PrettyPrintFlag

+ const QuietFlag

+ const RepositoryFlag

+ const StatsFlag

+ const TimezoneFlag

+ const WaitTimeoutFlag

+ const WithoutHeaderFlag

+ const WithoutNullFlag

+ const WriteDelimiterFlag

+ const WriteEncodingFlag

Oct 13, 2018

Changes in this version

+ const ErrorJsonQuery

+ const ErrorJsonQueryTooManyRecords

+ const ErrorJsonTableEmpty

+ func JsonAgg(list []value.Primary) value.Primary

+ func JsonObject(fn parser.Function, filter *Filter) (value.Primary, error)

+ func JsonValue(fn parser.Function, args []value.Primary) (value.Primary, error)

+ func NewJsonQueryError(expr parser.JsonQuery, message string) error

+ func NewJsonQueryTooManyRecordsError(expr parser.JsonQuery) error

+ func NewJsonTableEmptyError(expr parser.JsonQuery) error

+ type AnalyticJsonAgg struct

+ func (fn AnalyticJsonAgg) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn AnalyticJsonAgg) Execute(partition Partition, expr parser.AnalyticFunction, filter *Filter) (map[int]value.Primary, error)

+ type JsonQueryError struct

+ type JsonQueryTooManyRecordsError struct

+ type JsonTableEmptyError struct

Sep 25, 2018

Changes in this version

+ const ErrorBuiltInFunctionDeclared

+ const ErrorCSVParsing

+ const ErrorCombinedSetFieldLength

+ const ErrorCreateFile

+ const ErrorCursorClosed

+ const ErrorCursorFetchLength

+ const ErrorCursorRedeclared

+ const ErrorDeleteTableNotSpecified

+ const ErrorDuplicateFieldName

+ const ErrorDuplicateParameter

+ const ErrorDuplicateTableName

+ const ErrorFieldAmbiguous

+ const ErrorFieldLengthInComparison

+ const ErrorFieldLengthNotMatch

+ const ErrorFieldNotExist

+ const ErrorFieldNotGroupKey

+ const ErrorFileAlreadyExist

+ const ErrorFileLockTimeout

+ const ErrorFileNotExist

+ const ErrorFileUnableToRead

+ const ErrorFormatStringLengthNotMatch

+ const ErrorFunctionArgumentsLength

+ const ErrorFunctionInvalidArgument

+ const ErrorFunctionNotExist

+ const ErrorFunctionRedeclared

+ const ErrorInlineTableFieldLength

+ const ErrorInlineTableRedefined

+ const ErrorInsertRowValueLength

+ const ErrorInsertSelectFieldLength

+ const ErrorInternalRecordIdEmpty

+ const ErrorInternalRecordIdNotExist

+ const ErrorInvalidFetchPosition

+ const ErrorInvalidFlagName

+ const ErrorInvalidFlagValue

+ const ErrorInvalidLimitNumber

+ const ErrorInvalidLimitPercentage

+ const ErrorInvalidOffsetNumber

+ const ErrorInvalidSyntax

+ const ErrorMessageTemplate

+ const ErrorMessageWithEmptyPositionTemplate

+ const ErrorMessageWithFilepathTemplate

+ const ErrorNestedAggregateFunctions

+ const ErrorNotGroupingRecords

+ const ErrorPrintfReplaceValueLength

+ const ErrorPseudoCursor

+ const ErrorReadFile

+ const ErrorRowValueLengthInComparison

+ const ErrorRowValueLengthInList

+ const ErrorSourceFileNotExist

+ const ErrorSourceFileUnableToRead

+ const ErrorSourceInvalidArgument

+ const ErrorStdinEmpty

+ const ErrorSubqueryTooManyFields

+ const ErrorSubqueryTooManyRecords

+ const ErrorTableFieldLength

+ const ErrorTableNotLoaded

+ const ErrorTemporaryTableFieldLength

+ const ErrorTemporaryTableRedeclared

+ const ErrorUndeclaredCursor

+ const ErrorUndeclaredTemporaryTable

+ const ErrorUndeclaredVariable

+ const ErrorUndefinedInlineTable

+ const ErrorUnpermittedStatementFunction

+ const ErrorUpdateFieldNotExist

+ const ErrorUpdateValueAmbiguous

+ const ErrorVariableRedeclared

+ const ErrorWriteFile

+ const ErrorWriteFileInAutoCommit

+ const InternalIdColumn

+ func NewForcedExit(code int) error

+ type ForcedExit struct

+ Code int

+ func (e ForcedExit) Error() string

+ func (e ForcedExit) GetCode() int

type OperationType

+ const AddColumnsQuery

+ const CreateTableQuery

+ const DeleteQuery

+ const DropColumnsQuery

+ const InsertQuery

+ const RenameColumnQuery

+ const UpdateQuery

type SortValueType

+ const BooleanType

+ const DatetimeType

+ const FloatType

+ const IntegerType

+ const NullType

+ const StringType

type StatementFlow

+ const Break

+ const Continue

+ const Error

+ const Return

+ const Terminate

Apr 5, 2018

Changes in this version

+ func Instr(fn parser.Function, args []value.Primary) (value.Primary, error)

+ func ListElem(fn parser.Function, args []value.Primary) (value.Primary, error)

Sep 25, 2017

Changes in this version

type UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) Dispose(name parser.Identifier) error

type UserDefinedFunctionScopes

+ func (list UserDefinedFunctionScopes) Dispose(name parser.Identifier) error

+ type WindowFrame struct

+ High int

+ Low int

+ Records []int

+ func WindowFrameSet(partition Partition, expr parser.AnalyticClause) []WindowFrame

Sep 19, 2017

Changes in this version

type Filter

+ func (f *Filter) ResetCurrentScope()

type GoroutineManager

+ func (m *GoroutineManager) Error() error

+ func (m *GoroutineManager) HasError() bool

+ func (m *GoroutineManager) SetError(e error)

type View

+ ForUpdate bool

Sep 16, 2017

Changes in this version

+ const ERROR_INLINE_TABLE_REDEFINED

+ const ERROR_UNDECLARED_CURSOR

+ const ERROR_UNDECLARED_TEMPORARY_TABLE

+ const ERROR_UNDECLARED_VARIABLE

+ func NewInLineTableRedefinedError(table parser.Identifier) error

+ func NewUndeclaredCursorError(cursor parser.Identifier) error

+ func NewUndeclaredTemporaryTableError(table parser.Identifier) error

+ func NewUndeclaredVariableError(expr parser.Variable) error

+ type GoroutineManager struct

+ func NewGoroutineManager(recordLen int, minimumRequired int) *GoroutineManager

+ func (m *GoroutineManager) Add()

+ func (m *GoroutineManager) CPU() int

+ func (m *GoroutineManager) Done()

+ func (m *GoroutineManager) RecordRange(routineIndex int) (int, int)

+ func (m *GoroutineManager) Wait()

+ type InLineTableRedefinedError struct

type TemporaryViewScopes

+ func (list TemporaryViewScopes) GetHeader(name parser.Identifier) (Header, error)

+ type UndeclaredCursorError struct

+ type UndeclaredTemporaryTableError struct

+ type UndeclaredVariableError struct

type ViewMap

+ func (m ViewMap) GetHeader(name parser.Identifier) (Header, error)

Sep 15, 2017

Changes in this version

+ func DeclareView(expr parser.ViewDeclaration, filter *Filter) error

+ func ShowFields(expr parser.ShowFields, filter *Filter) (string, error)

+ func ShowObjects(expr parser.ShowObjects, filter *Filter) (string, error)

type CursorScopes

+ func (list CursorScopes) List() []string

type TemporaryViewScopes

+ func (list TemporaryViewScopes) List() []string

type UserDefinedFunctionScopes

+ func (list UserDefinedFunctionScopes) List() ([]string, []string)

Sep 12, 2017

Changes in this version

type Procedure

+ MeasurementStart time.Time

Sep 11, 2017

Changes in this version

+ func ReleaseResources()

+ func ShowFlag(expr parser.ShowFlag) (string, error)

+ func UpdateWaitTimeout()

type FileLockContainer

+ func (c FileLockContainer) IsLockedByOtherProcess(path string) bool

Sep 8, 2017

Changes in this version

+ const ERROR_FILE_LOCK_TIMEOUT

+ var FileLocks = NewFileLockContainer()

+ func FileLockPath(path string) string

+ func NewFileLockTimeoutError(file parser.Identifier, path string) error

type FileInfo

+ File *os.File

+ type FileLockContainer struct

+ FileMap map[string]string

+ RetryInterval time.Duration

+ WaitTimeout float64

+ func NewFileLockContainer() *FileLockContainer

+ func (c FileLockContainer) CanRead(path string) bool

+ func (c FileLockContainer) HasLock(path string) bool

+ func (c FileLockContainer) LockWithTimeout(ident parser.Identifier, path string) error

+ func (c FileLockContainer) LockedByOtherProcess(path string) bool

+ func (c FileLockContainer) TryLock(path string) error

+ func (c FileLockContainer) Unlock(path string) error

+ func (c FileLockContainer) UnlockAll() error

+ type FileLockTimeoutError struct

type TemporaryViewScopes

+ func (list TemporaryViewScopes) Restore()

+ func (list TemporaryViewScopes) Store()

type View

+ UseLock bool

type ViewMap

+ func (m ViewMap) Clean()

+ func (m ViewMap) Dispose(name string)

Sep 2, 2017

Changes in this version

+ type AliasNodes []AliasMap

+ func (list AliasNodes) Add(alias parser.Identifier, path string) error

+ func (list AliasNodes) Get(alias parser.Identifier) (path string, err error)

type Cell

+ func (cell Cell) GroupedValue(index int) value.Primary

+ func (cell Cell) Value() value.Primary

+ type CursorScopes []CursorMap

+ func (list CursorScopes) AddPseudoCursor(name parser.Identifier, values []value.Primary) error

+ func (list CursorScopes) Close(name parser.Identifier) error

+ func (list CursorScopes) Count(name parser.Identifier) (int, error)

+ func (list CursorScopes) Declare(expr parser.CursorDeclaration) error

+ func (list CursorScopes) Dispose(name parser.Identifier) error

+ func (list CursorScopes) Fetch(name parser.Identifier, position int, number int) ([]value.Primary, error)

+ func (list CursorScopes) IsInRange(name parser.Identifier) (ternary.Value, error)

+ func (list CursorScopes) IsOpen(name parser.Identifier) (ternary.Value, error)

+ func (list CursorScopes) Open(name parser.Identifier, filter *Filter) error

type FileInfo

+ InitialRecordSet RecordSet

type Filter

+ Aliases AliasNodes

+ Cursors CursorScopes

+ Functions UserDefinedFunctionScopes

+ TempViews TemporaryViewScopes

+ Variables VariableScopes

+ type InlineTableMap map[string]*View

+ func (it InlineTableMap) Get(name parser.Identifier) (*View, error)

+ func (it InlineTableMap) Set(inlineTable parser.InlineTable, parentFilter *Filter) error

+ type InlineTableNodes []InlineTableMap

+ func (list InlineTableNodes) Get(name parser.Identifier) (view *View, err error)

+ func (list InlineTableNodes) Load(clause parser.WithClause, parentFilter *Filter) error

+ func (list InlineTableNodes) Set(inlineTable parser.InlineTable, parentFilter *Filter) error

+ type RecordSet []Record

+ func MergeRecordSetList(list []RecordSet) RecordSet

+ func (r RecordSet) Copy() RecordSet

+ type TemporaryViewScopes []ViewMap

+ func (list TemporaryViewScopes) Dispose(name parser.Identifier) error

+ func (list TemporaryViewScopes) Exists(name string) bool

+ func (list TemporaryViewScopes) Get(name parser.Identifier) (*View, error)

+ func (list TemporaryViewScopes) GetWithInternalId(name parser.Identifier) (*View, error)

+ func (list TemporaryViewScopes) Replace(view *View)

+ func (list TemporaryViewScopes) Rollback()

+ func (list TemporaryViewScopes) Set(view *View)

+ type UserDefinedFunctionScopes []UserDefinedFunctionMap

+ func (list UserDefinedFunctionScopes) Declare(expr parser.FunctionDeclaration) error

+ func (list UserDefinedFunctionScopes) DeclareAggregate(expr parser.AggregateDeclaration) error

+ func (list UserDefinedFunctionScopes) Get(expr parser.QueryExpression, name string) (*UserDefinedFunction, error)

+ type VariableMap map[string]value.Primary

+ func (v VariableMap) Add(variable parser.Variable, value value.Primary) error

+ func (v VariableMap) Declare(declaration parser.VariableDeclaration, filter *Filter) error

+ func (v VariableMap) Dispose(variable parser.Variable) error

+ func (v VariableMap) Get(variable parser.Variable) (value.Primary, error)

+ func (v VariableMap) Set(variable parser.Variable, value value.Primary) error

+ func (v VariableMap) Substitute(substitution parser.VariableSubstitution, filter *Filter) (value.Primary, error)

+ func (v VariableMap) SubstituteDirectly(variable parser.Variable, value value.Primary) (value.Primary, error)

+ type VariableScopes []VariableMap

+ func (list VariableScopes) Declare(expr parser.VariableDeclaration, filter *Filter) error

+ func (list VariableScopes) Dispose(expr parser.Variable) error

+ func (list VariableScopes) Get(expr parser.Variable) (value value.Primary, err error)

+ func (list VariableScopes) Substitute(expr parser.VariableSubstitution, filter *Filter) (value value.Primary, err error)

+ func (list VariableScopes) SubstituteDirectly(variable parser.Variable, value value.Primary) (value.Primary, error)

type View

+ RecordSet RecordSet

Aug 31, 2017

Changes in this version

+ func NewExit(code int) error

+ type Exit struct

+ Code int

+ func (e Exit) Error() string

+ func (e Exit) GetCode() int

Aug 31, 2017

Changes in this version

+ const ERROR_CREATE_FILE

+ func NewCreateFileError(expr parser.Expression, message string) error

+ type CreateFileError struct

type FileInfo

+ IsTemporary bool

Aug 30, 2017

Changes in this version

type FileInfo

+ InitialHeader Header

type Procedure

+ func (proc *Procedure) Case(stmt parser.Case) (StatementFlow, error)

Aug 29, 2017

Changes in this version

type Header

+ func (h Header) ContainsInternalId(viewName string) (int, error)

type HeaderField

+ IsFromTable bool

+ IsJoinColumn bool

Aug 27, 2017

Changes in this version

+ func MathLog(fn parser.Function, args []parser.Primary) (parser.Primary, error)

type Filter

+ Now time.Time

Aug 26, 2017

Changes in this version

+ func TimeNanoDiff(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncDay(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncMicro(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncMilli(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncMinute(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncMonth(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncNano(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncSecond(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func TruncTime(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func UTC(fn parser.Function, args []parser.Primary) (parser.Primary, error)

Aug 25, 2017

Changes in this version

type SortValues

+ func (values SortValues) Serialize() string

type View

+ func (view *View) ExtendRecordCapacity(exprs []parser.Expression) error

Aug 24, 2017

Changes in this version

+ const ERROR_TABLE_FIELD_LENGTH

+ func NewTableFieldLengthError(query parser.SelectQuery, table parser.Identifier, fieldLen int) error

+ type Partitions map[string]Partition

+ type TableFieldLengthError struct

Aug 23, 2017

Changes in this version

+ func SerializeKey(value parser.Primary) string

type ComparisonResult

+ const BOOL_EQUAL

type Partition

+ func (p Partition) Reverse() Partition

type PartitionItem

+ OrderKey string

type Record

+ func (r Record) SerializeComparisonKeys() string

type SortValueType

+ const SORT_VALUE_BOOLEAN

type Variables

+ func (v Variables) SubstitutePrimary(variable parser.Variable, value parser.Primary) (parser.Primary, error)

type VariablesList

+ func (list VariablesList) SubstitutePrimary(variable parser.Variable, value parser.Primary) (parser.Primary, error)

type View

+ func (view *View) GenerateComparisonKeys()

Aug 20, 2017

Changes in this version

+ func NumberOfCPU(recordLen int) int

+ func SerializeComparisonKeys(values []parser.Primary) string

Aug 19, 2017

Changes in this version

+ func SerializeGroupKeys(values []parser.Primary) string

+ type SortValue struct

+ Boolean bool

+ Datetime time.Time

+ Float float64

+ Integer int64

+ String string

+ Type SortValueType

+ func NewSortValue(value parser.Primary) *SortValue

+ func (v SortValue) EquivalentTo(compareValue *SortValue) bool

+ func (v SortValue) Less(compareValue *SortValue) ternary.Value

+ type SortValueType int

+ const SORT_VALUE_DATETIME

+ const SORT_VALUE_FLOAT

+ const SORT_VALUE_INTEGER

+ const SORT_VALUE_NULL

+ const SORT_VALUE_STRING

+ type SortValues []*SortValue

+ func (values SortValues) EquivalentTo(compareValues SortValues) bool

+ func (values SortValues) Less(compareValues SortValues, directions []int, nullPositions []int) bool

Aug 18, 2017

Changes in this version

+ func RecordRange(cpuIndex int, totalLen int, numberOfCPU int) (int, int)

+ func SerializeValues(values []parser.Primary) string

type Records

+ func MergeRecordsList(list []Records) Records

Aug 16, 2017

Changes in this version

type Record

+ func MergeRecord(r1 Record, r2 Record) Record

Aug 14, 2017

Changes in this version

+ func Enotation(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func EnotationToDec(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func InRuneSlice(r rune, list []rune) bool

Aug 8, 2017

Changes in this version

type HeaderField

+ Aliases []string

+ View string

Aug 6, 2017

Changes in this version

+ func Analyze(view *View, fn parser.AnalyticFunction) error

+ func CheckArgsLen(expr parser.AnalyticFunction, length []int) error

+ type AggregateFunction func([]parser.Primary) parser.Primary

+ type AnalyticFunction interface

+ CheckArgsLen func(expr parser.AnalyticFunction) error

+ Execute func(PartitionItemList, parser.AnalyticFunction, Filter) (map[int]parser.Primary, error)

+ type AnalyticListAgg struct

+ func (fn AnalyticListAgg) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn AnalyticListAgg) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type CumeDist

+ func (fn CumeDist) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn CumeDist) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type DenseRank

+ func (fn DenseRank) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn DenseRank) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type FirstValue

+ func (fn FirstValue) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn FirstValue) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type Header

+ func NewHeaderWithId(ref string, words []string) Header

+ type Lag struct

+ func (fn Lag) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn Lag) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type LastValue

+ func (fn LastValue) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn LastValue) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

+ type Lead struct

+ func (fn Lead) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn Lead) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

+ type NTile struct

+ func (fn NTile) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn NTile) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

+ type NthValue struct

+ func (fn NthValue) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn NthValue) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

+ type OperationType int

+ type Partition struct

+ Items PartitionItemList

+ PartitionValues []parser.Primary

+ func (p Partition) Match(values []parser.Primary) bool

+ type PartitionItem struct

+ OrderValues []parser.Primary

+ RecordIndex int

+ func (item PartitionItem) IsSameRank(partitionItem PartitionItem) bool

+ type PartitionItemList []PartitionItem

+ func (list PartitionItemList) Reverse() PartitionItemList

+ type PartitionList []Partition

+ func (list PartitionList) SearchIndex(partitionValues []parser.Primary) int

type PercentRank

+ func (fn PercentRank) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn PercentRank) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type Rank

+ func (fn Rank) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn Rank) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type Record

+ func NewRecordWithId(internalId int, values []parser.Primary) Record

type RowNumber

+ func (fn RowNumber) CheckArgsLen(expr parser.AnalyticFunction) error

+ func (fn RowNumber) Execute(items PartitionItemList, expr parser.AnalyticFunction, filter Filter) (map[int]parser.Primary, error)

type View

+ func (view *View) ListValuesForAnalyticFunctions(fn parser.AnalyticFunction, partitionItems PartitionItemList) ([]parser.Primary, error)

Aug 4, 2017

Changes in this version

+ func CumeDist(view *View, fn parser.AnalyticFunction) error

+ func Median(list []parser.Primary) parser.Primary

+ func PercentRank(view *View, fn parser.AnalyticFunction) error

Aug 3, 2017

Changes in this version

+ const ERROR_FILE_ALREADY_EXIST

+ func NewFileAlreadyExistError(file parser.Identifier) error

+ type FileAlreadyExistError struct

type FileInfo

+ func NewFileInfoForCreate(finename parser.Identifier, repository string, delimiter rune) (*FileInfo, error)

type View

+ Filter Filter

Aug 1, 2017

Changes in this version

+ const ERROR_DUPLICATE_PARAMETER

+ const ERROR_FORMAT_STRING_LENGTH_NOT_MATCH

+ func Format(fn parser.Function, args []parser.Primary) (parser.Primary, error)

+ func FormatString(format string, args []parser.Primary) (string, error)

+ func NewDuplicateParameterError(expr parser.Variable) error

+ func NewFormatStringLengthNotMatchError() error

+ func NewUserTriggeredError(expr parser.Trigger, message string) error

type AppError

+ GetCode func() int

type BaseError

+ Code int

+ func NewBaseErrorWithCode(expr parser.ProcExpr, message string, code int) *BaseError

+ func (e BaseError) GetCode() int

+ type DuplicateParameterError struct

+ type FormatStringLengthNotMatchError struct

type UserDefinedFunction

+ Defaults map[string]parser.Expression

+ RequiredArgs int

+ func (fn *UserDefinedFunction) CheckArgsLen(expr parser.Expression, name string, argsLen int) error

+ type UserTriggeredError struct

Jul 31, 2017

Changes in this version

type UserDefinedFunction

+ Cursor parser.Identifier

+ func (fn *UserDefinedFunction) ExecuteAggregate(values []parser.Primary, args []parser.Primary, filter Filter) (parser.Primary, error)

Jul 30, 2017

Changes in this version

+ const ERROR_PSEUDO_CURSOR

+ const ERROR_SOURCE_INVALID_ARGUMENT

+ func AnalyzeLag(view *View, fn parser.AnalyticFunction) error

+ func Distinguish(list []parser.Primary) []parser.Primary

+ func NewPseudoCursorError(cursor parser.Identifier) error

+ func NewSourceInvalidArgumentError(source parser.Source, arg parser.Expression) error

type Cursor

+ func NewPseudoCursor(values []parser.Primary) *Cursor

type CursorMap

+ func (m CursorMap) AddPseudoCursor(name parser.Identifier, values []parser.Primary) error

+ func (m CursorMap) Count(name parser.Identifier) (int, error)

type CursorMapList

+ func (list CursorMapList) AddPseudoCursor(name parser.Identifier, values []parser.Primary) error

+ func (list CursorMapList) Count(name parser.Identifier) (int, error)

+ type PseudoCursorError struct

+ type SourceInvalidArgumentError struct

type UserDefinedFunction

+ IsAggregate bool

+ Parameter parser.Identifier

type UserDefinedFunctionMap

+ func (m UserDefinedFunctionMap) CheckDuplicate(name parser.Identifier) error

+ func (m UserDefinedFunctionMap) DeclareAggregate(expr parser.AggregateDeclaration) error

type UserDefinedFunctionsList

+ func (list UserDefinedFunctionsList) DeclareAggregate(expr parser.AggregateDeclaration) error

type View

+ func (view *View) RestoreHeaderReferences()

Jul 29, 2017

Changes in this version

+ const ERROR_READ_FILE

+ const ERROR_WRITE_FILE

+ const ERROR_WRITE_FILE_IN_AUTOCOMMIT

+ func AnalyzeAggregateValue(view *View, fn parser.AnalyticFunction) error

+ func AnalyzeListAgg(view *View, fn parser.AnalyticFunction) error

+ func FirstValue(view *View, fn parser.AnalyticFunction) error

+ func LastValue(view *View, fn parser.AnalyticFunction) error

+ func ListAgg(distinct bool, list []parser.Primary, separator string) parser.Primary

+ func NewAutoCommitError(message string) error

+ func NewPartitionBase(pvalues []parser.Primary, ovalues []parser.Primary) *partitionBase

+ func NewReadFileError(expr parser.ProcExpr, message string) error

+ func NewWriteFileError(expr parser.ProcExpr, message string) error

+ type AutoCommitError struct

+ Message string

+ func (e AutoCommitError) Error() string

type Filter

+ FunctionsList UserDefinedFunctionsList

+ InlineTablesList InlineTablesList

+ func (f Filter) CreateChildScope() Filter

+ type InlineTablesList []InlineTables

+ func (list InlineTablesList) Get(name parser.Identifier) (view *View, err error)

+ func (list InlineTablesList) Load(clause parser.WithClause, parentFilter Filter) error

+ func (list InlineTablesList) Set(inlineTable parser.InlineTable, parentFilter Filter) error

+ type ReadFileError struct

+ type UserDefinedFunctionsList []UserDefinedFunctionMap

+ func (list UserDefinedFunctionsList) Declare(expr parser.FunctionDeclaration) error

+ func (list UserDefinedFunctionsList) Get(expr parser.Function) (*UserDefinedFunction, error)

type View

+ func (view *View) ListValuesForAggregateFunctions(expr parser.Expression, arg parser.Expression, filter Filter) ([]parser.Primary, error)

+ type WriteFileError struct

Jul 26, 2017

Changes in this version

type View

+ func (view *View) LoadFromTableIdentifier(table parser.Expression, parentFilter Filter) error

Jul 25, 2017

Changes in this version

+ const ERROR_FIELD_NUMBER_NOT_EXIST

+ const ERROR_FIELD_NUMBER_NOT_GROUP_KEY

+ func NewFieldNumberNotExistError(number parser.ColumnNumber) error

+ func NewFieldNumberNotGroupKeyError(number parser.ColumnNumber) error

+ type FieldNumberNotExistError struct

+ type FieldNumberNotGroupKeyError struct

type Header

+ func (h Header) ContainsNumber(number parser.ColumnNumber) (int, error)

+ func (h Header) Update(reference string, fields []parser.Expression) error

type HeaderField

+ Number int

Jul 25, 2017

Changes in this version

+ func IsReadableFromStdin() bool

type AliasMapList

+ func (list AliasMapList) Add(alias parser.Identifier, path string) error

type FileInfo

+ InitialRecords Records

type Records

+ func (r Records) Copy() Records

type TemporaryViewMapList

+ func (list TemporaryViewMapList) Exists(name string) bool

+ func (list TemporaryViewMapList) Rollback()

type View

+ func (view *View) Rollback()

Jul 24, 2017

Changes in this version

+ var SelectLogs = []string

+ func AddSelectLog(log string)

+ func ReadSelectLog() string

type AliasMapList

+ func (l AliasMapList) CreateNode() AliasMapList

+ type CursorMapList []CursorMap

+ func (list CursorMapList) Close(name parser.Identifier) error

+ func (list CursorMapList) Declare(expr parser.CursorDeclaration) error

+ func (list CursorMapList) Dispose(name parser.Identifier) error

+ func (list CursorMapList) Fetch(name parser.Identifier, position int, number int) ([]parser.Primary, error)

+ func (list CursorMapList) IsInRange(name parser.Identifier) (ternary.Value, error)

+ func (list CursorMapList) IsOpen(name parser.Identifier) (ternary.Value, error)

+ func (list CursorMapList) Open(name parser.Identifier, filter Filter) error

type Filter

+ CursorsList CursorMapList

+ TempViewsList TemporaryViewMapList

+ func NewFilterForSequentialEvaluation(view *View, parentFilter Filter) Filter

+ func (f Filter) CreateNode() Filter

type Procedure

+ Filter Filter

+ type TemporaryViewMapList []ViewMap

+ func (list TemporaryViewMapList) Clear()

+ func (list TemporaryViewMapList) Dispose(name parser.Identifier) error

+ func (list TemporaryViewMapList) Get(name parser.Identifier) (*View, error)

+ func (list TemporaryViewMapList) GetWithInternalId(name parser.Identifier) (*View, error)

+ func (list TemporaryViewMapList) HasView(name string) bool

+ func (list TemporaryViewMapList) Replace(view *View)

+ func (list TemporaryViewMapList) Set(view *View)

type Variables

+ func (v Variables) Dispose(variable parser.Variable) error

+ type VariablesList []Variables

+ func (list VariablesList) Declare(expr parser.VariableDeclaration, filter Filter) error

+ func (list VariablesList) Dispose(expr parser.Variable) error

+ func (list VariablesList) Get(expr parser.Variable) (value parser.Primary, err error)

+ func (list VariablesList) Substitute(expr parser.VariableSubstitution, filter Filter) (value parser.Primary, err error)

Jul 23, 2017

Changes in this version

+ const ERROR_BUILT_IN_FUNCTION_DECLARED

+ const ERROR_COMBINED_SET_FIELD_LENGTH

+ const ERROR_CSV_PARSING

+ const ERROR_CURSOR_CLOSED

+ const ERROR_CURSOR_FETCH_LENGTH

+ const ERROR_CURSOR_OPEN

+ const ERROR_CURSOR_REDECLARED

+ const ERROR_DELETE_TABLE_NOT_SPECIFIED

+ const ERROR_DUPLICATE_FIELD_NAME

+ const ERROR_DUPLICATE_TABLE_NAME

+ const ERROR_FIELD_AMBIGUOUS

+ const ERROR_FIELD_LENGTH_NOT_MATCH

+ const ERROR_FIELD_NOT_EXIST

+ const ERROR_FIELD_NOT_GROUP_KEY

+ const ERROR_FILE_NOT_EXIST

+ const ERROR_FILE_UNABLE_TO_READ

+ const ERROR_FUNCTION_ARGUMENT_LENGTH

+ const ERROR_FUNCTION_INVALID_ARGUMENT

+ const ERROR_FUNCTION_NOT_EXIST

+ const ERROR_FUNCTION_REDECLARED

+ const ERROR_INLINE_TABLE_FIELD_LENGTH

+ const ERROR_INLINE_TABLE_REDECLARED

+ const ERROR_INSERT_ROW_VALUE_LENGTH

+ const ERROR_INSERT_SELECT_FIELD_LENGTH

+ const ERROR_INTERNAL_RECORD_ID_EMPTY

+ const ERROR_INTERNAL_RECORD_ID_NOT_EXIST

+ const ERROR_INVALID_FETCH_POSITION

+ const ERROR_INVALID_FLAG_NAME

+ const ERROR_INVALID_FLAG_VALUE

+ const ERROR_INVALID_LIMIT_NUMBER

+ const ERROR_INVALID_LIMIT_PERCENTAGE

+ const ERROR_INVALID_OFFSET_NUMBER

+ const ERROR_INVALID_SYNTAX

+ const ERROR_MESSAGE_TEMPLATE

+ const ERROR_MESSAGE_WITH_EMPTY_POSITION_TEMPLATE

+ const ERROR_MESSAGE_WITH_FILEPATH_TEMPLATE

+ const ERROR_NESTED_AGGREGATE_FUNCTIONS

+ const ERROR_NOT_GROUPING_RECORDS

+ const ERROR_PRINTF_REPLACE_VALUE_LENGTH

+ const ERROR_ROW_VALUE_LENGTH_IN_COMPARISON

+ const ERROR_ROW_VALUE_LENGTH_IN_LIST

+ const ERROR_ROW_VALUE_LENGTH_NOT_MATCH

+ const ERROR_SELECT_FIELD_LENGTH_IN_COMPARISON

+ const ERROR_SOURCE_FILE_NOT_EXIST

+ const ERROR_SOURCE_FILE_UNABLE_TO_READ

+ const ERROR_STDIN_EMPTY

+ const ERROR_SUBQUERY_TOO_MANY_FIELDS

+ const ERROR_SUBQUERY_TOO_MANY_RECORDS

+ const ERROR_TABLE_NOT_LOADED

+ const ERROR_TEMPORARY_TABLE_FIELD_LENGTH

+ const ERROR_TEMPORARY_TABLE_REDECLARED

+ const ERROR_UNDEFINED_CURSOR

+ const ERROR_UNDEFINED_INLINE_TABLE

+ const ERROR_UNDEFINED_TEMPORARY_TABLE

+ const ERROR_UNDEFINED_VARIABLE

+ const ERROR_UNPERMITTED_STATEMENT_FUNCTION

+ const ERROR_UNPERMITTED_WILDCARD

+ const ERROR_UPDATE_FIELD_NOT_EXIST

+ const ERROR_UPDATE_VALUE_AMBIGUOUS

+ const ERROR_VARIABLE_REDECLARED

+ func FormatCount(i int, obj string) string

+ func InStrSliceWithCaseInsensitive(s string, list []string) bool

+ func NewBuiltInFunctionDeclaredError(expr parser.Identifier) error

+ func NewCombinedSetFieldLengthError(selectEntity parser.Expression, fieldLen int) error

+ func NewCsvParsingError(file parser.Identifier, filepath string, message string) error

+ func NewCursorClosedError(cursor parser.Identifier) error

+ func NewCursorFetchLengthError(cursor parser.Identifier, returnLen int) error

+ func NewCursorOpenError(cursor parser.Identifier) error

+ func NewCursorRedeclaredError(cursor parser.Identifier) error

+ func NewDeleteTableNotSpecifiedError(query parser.DeleteQuery) error

+ func NewDuplicateFieldNameError(fieldName parser.Identifier) error

+ func NewDuplicateTableNameError(table parser.Identifier) error

+ func NewFieldLengthNotMatchError() error

+ func NewFieldNotGroupKeyError(field parser.FieldReference) error

+ func NewFileNotExistError(file parser.Identifier) error

+ func NewFileUnableToReadError(file parser.Identifier) error

+ func NewFunctionArgumentLengthError(funcname string, argslen []int, expr parser.Expression) error

+ func NewFunctionArgumentLengthErrorWithCustomArgs(funcname string, argstr string, expr parser.Expression) error

+ func NewFunctionInvalidArgumentError(function parser.Function, message string) error

+ func NewFunctionNotExistError(funcname string, expr parser.Expression) error

+ func NewFunctionRedeclaredError(expr parser.Identifier) error

+ func NewInLineTableRedeclaredError(table parser.Identifier) error

+ func NewInlineTableFieldLengthError(query parser.SelectQuery, table parser.Identifier, fieldLen int) error

+ func NewInsertRowValueLengthError(rowValue parser.RowValue, valueLen int) error

+ func NewInsertSelectFieldLengthError(query parser.SelectQuery, fieldLen int) error

+ func NewInternalRecordIdEmptyError() error

+ func NewInternalRecordIdNotExistError() error

+ func NewInvalidFetchPositionError(position parser.FetchPosition) error

+ func NewInvalidFlagNameError(setFlag parser.SetFlag) error

+ func NewInvalidFlagValueError(setFlag parser.SetFlag) error

+ func NewInvalidLimitNumberError(clause parser.LimitClause) error

+ func NewInvalidLimitPercentageError(clause parser.LimitClause) error

+ func NewInvalidOffsetNumberError(clause parser.OffsetClause) error

+ func NewNestedAggregateFunctionsError(expr parser.Expression) error

+ func NewNotGroupingRecordsError(funcname string, expr parser.Expression) error

+ func NewPrintfReplaceValueLengthError(printf parser.Printf) error

+ func NewRowValueLengthInComparisonError(expr parser.Expression, valueLen int) error

+ func NewRowValueLengthInListError(i int) error

+ func NewRowValueLengthNotMatchError() error

+ func NewSelectFieldLengthInComparisonError(query parser.Subquery, valueLen int) error

+ func NewSourceFileNotExistError(source parser.Source) error

+ func NewSourceFileUnableToReadError(source parser.Source) error

+ func NewStdinEmptyError(stdin parser.Stdin) error

+ func NewSubqueryTooManyFieldsError(expr parser.Subquery) error

+ func NewSubqueryTooManyRecordsError(expr parser.Subquery) error

+ func NewSyntaxError(message string, line int, char int, sourceFile string) error

+ func NewSyntaxErrorFromExpr(expr parser.Expression) error

+ func NewTableNotLoadedError(table parser.Identifier) error

+ func NewTemporaryTableFieldLengthError(query parser.SelectQuery, table parser.Identifier, fieldLen int) error

+ func NewTemporaryTableRedeclaredError(table parser.Identifier) error

+ func NewUndefinedCursorError(cursor parser.Identifier) error

+ func NewUndefinedInLineTableError(table parser.Identifier) error

+ func NewUndefinedTemporaryTableError(table parser.Identifier) error

+ func NewUnpermittedStatementFunctionError(funcname string, expr parser.Expression) error

+ func NewUnpermittedWildCardError(funcname string, expr parser.AllColumns) error

+ func NewUpdateFieldNotExistError(field parser.FieldReference) error

+ func NewUpdateValueAmbiguousError(field parser.FieldReference, value parser.Expression) error

+ func NewVariableRedeclaredError(expr parser.Variable) error

+ type AliasMap map[string]string

+ func (m AliasMap) Add(alias parser.Identifier, path string) error

+ func (m AliasMap) Get(alias parser.Identifier) (string, error)

+ type AliasMapList []AliasMap

+ func (l AliasMapList) CreateChild() AliasMapList

+ func (l AliasMapList) Get(alias parser.Identifier) (path string, err error)

+ type AppError interface

+ Error func() string

+ ErrorMessage func() string

+ type BaseError struct

+ Char int

+ Line int

+ Message string

+ SourceFile string

+ func NewBaseError(expr parser.ProcExpr, message string) *BaseError

+ func (e BaseError) Error() string

+ func (e BaseError) ErrorMessage() string

+ type BuiltInFunctionDeclaredError struct

+ type CombinedSetFieldLengthError struct

+ type CsvParsingError struct

+ type CursorClosedError struct

+ type CursorFetchLengthError struct

type CursorMap

+ func (m CursorMap) Declare(expr parser.CursorDeclaration) error

+ type CursorOpenError struct

+ type CursorRedeclaredError struct

+ type DeleteTableNotSpecifiedError struct

+ type DuplicateFieldNameError struct

+ type DuplicateTableNameError struct

+ type FieldLengthNotMatchError struct

+ type FieldNotGroupKeyError struct

+ type FileNotExistError struct

+ type FileUnableToReadError struct

type Filter

+ AliasesList AliasMapList

+ func NewEmptyFilter() Filter

+ func (f Filter) CreateChild() Filter

+ type FunctionArgumentLengthError struct

+ type FunctionInvalidArgumentError struct

+ type FunctionNotExistError struct

+ type FunctionRedeclaredError struct

+ type InLineTableRedeclaredError struct

+ type InlineTableFieldLengthError struct

+ type InsertRowValueLengthError struct

+ type InsertSelectFieldLengthError struct

+ type InternalRecordIdEmptyError struct

+ type InternalRecordIdNotExistError struct

+ type InvalidFetchPositionError struct

+ type InvalidFlagNameError struct

+ type InvalidFlagValueError struct

+ type InvalidLimitNumberError struct

+ type InvalidLimitPercentageError struct

+ type InvalidOffsetNumberError struct

+ type NestedAggregateFunctionsError struct

+ type NotGroupingRecordsError struct

+ type PrintfReplaceValueLengthError struct

+ type RowValueLengthInComparisonError struct

+ type RowValueLengthInListError struct

+ Index int

+ type RowValueLengthNotMatchError struct

+ type SelectFieldLengthInComparisonError struct

+ type SourceFileNotExistError struct

+ type SourceFileUnableToReadError struct

+ type StdinEmptyError struct

+ type SubqueryTooManyFieldsError struct

+ type SubqueryTooManyRecordsError struct

+ type SyntaxError struct

+ type TableNotLoadedError struct

+ type TemporaryTableFieldLengthError struct

+ type TemporaryTableRedeclaredError struct

+ type UndefinedCursorError struct

+ type UndefinedInLineTableError struct

+ type UndefinedTemporaryTableError struct

+ type UnpermittedStatementFunctionError struct

+ type UnpermittedWildCardError struct

+ type UpdateFieldNotExistError struct

+ type UpdateValueAmbiguousError struct

+ type UserDefinedFunction struct

+ Name parser.Identifier

+ Parameters []parser.Variable

+ Statements []parser.Statement

+ func (fn *UserDefinedFunction) Execute(args []parser.Primary, filter Filter) (parser.Primary, error)

+ type UserDefinedFunctionMap map[string]*UserDefinedFunction

+ func (m UserDefinedFunctionMap) Declare(expr parser.FunctionDeclaration) error

+ func (m UserDefinedFunctionMap) Get(fn parser.Function) (*UserDefinedFunction, error)

+ type VariableRedeclaredError struct

Jul 19, 2017

Changes in this version

type ViewMap

+ func (m *ViewMap) DisposeTemporaryTable(name string) error

Jul 19, 2017

Changes in this version

+ var ErrRedeclaredVariable = errors.New("variable %s is redeclared")

+ var ErrUndefinedVariable = errors.New("variable %s is undefined")

+ var Logs = []string

+ var Results = []Result

+ var UserFunctions = UserFunctionMap

+ func AddLog(log string)

+ func Init()

+ func NewFieldAmbiguousError(field parser.FieldReference) error

+ func NewFieldNotExistError(field parser.FieldReference) error

+ func NewNotGroupedErr(funcName string) error

+ func NewRedeclaredVariableError(name string) error

+ func NewUndefinedVariableError(name string) error

+ func Printf(expr parser.Printf, filter Filter) (string, error)

+ func ReadLog() string

+ func Source(expr parser.Source) ([]parser.Statement, error)

+ type FieldAmbiguousError struct

+ Err error

+ Field parser.FieldReference

+ func (e FieldAmbiguousError) Error() string

+ type FieldNotExistError struct

+ Err error

+ Field parser.FieldReference

+ func (e FieldNotExistError) Error() string

type Filter

+ VariablesList []Variables

+ func NewFilter(variablesList []Variables) Filter

+ func (f Filter) LoadInlineTable(clause parser.WithClause) error

+ type Procedure struct

+ ReturnVal parser.Primary

+ VariablesList []Variables

+ func NewProcedure() *Procedure

+ func (proc *Procedure) Commit() error

+ func (proc *Procedure) Execute(statements []parser.Statement) (StatementFlow, error)

+ func (proc *Procedure) ExecuteChild(statements []parser.Statement) (StatementFlow, error)

+ func (proc *Procedure) ExecuteStatement(stmt parser.Statement) (StatementFlow, error)

+ func (proc *Procedure) IfStmt(stmt parser.If) (StatementFlow, error)

+ func (proc *Procedure) NewChildProcedure() *Procedure

+ func (proc *Procedure) Rollback()

+ func (proc *Procedure) While(stmt parser.While) (StatementFlow, error)

+ func (proc *Procedure) WhileInCursor(stmt parser.WhileInCursor) (StatementFlow, error)

+ type RedeclaredVariableError struct

+ Err error

+ Name string

+ func (e RedeclaredVariableError) Error() string

type StatementFlow

+ const RETURN

+ type UndefinedVariableError struct

+ Err error

+ Name string

+ func (e UndefinedVariableError) Error() string

+ type UserFunction struct

+ Name string

+ Parameters []parser.Variable

+ Statements []parser.Statement

+ func (fn *UserFunction) Execute(args []parser.Primary, filter Filter) (parser.Primary, error)

+ type UserFunctionMap map[string]*UserFunction

+ func (m UserFunctionMap) Declare(expr parser.FunctionDeclaration) error

+ func (m UserFunctionMap) Get(key string) (*UserFunction, error)

type Variables

+ func (v Variables) Declare(declaration parser.VariableDeclaration, filter Filter) error

Jul 14, 2017

Changes in this version

type Filter

+ InlineTables InlineTables

+ type InlineTables map[string]*View

+ func (it InlineTables) Copy() InlineTables

+ func (it InlineTables) Get(name string) (*View, error)

+ func (it InlineTables) Load(clause parser.WithClause) error

+ func (it InlineTables) Merge(tables InlineTables) InlineTables

+ func (it InlineTables) Set(inlineTable parser.InlineTable) error

type View

+ func (view *View) LoadFromIdentifierWithInlineTables(table parser.Identifier, parentFilter Filter) error

Jul 10, 2017

Changes in this version

+ func DeclareTable(expr parser.TableDeclaration) error

type FileInfo

+ Temporary bool

type ViewMap

+ func (m *ViewMap) HasTemporaryTable(name string) bool

Jul 7, 2017

Changes in this version

+ func NewTextField(s string, sign int) textField

Jul 6, 2017

Changes in this version

type CursorMap

+ func (m CursorMap) IsInRange(key string) (ternary.Value, error)

+ func (m CursorMap) IsOpen(key string) (ternary.Value, error)

Jul 5, 2017

Changes in this version

+ const STDIN_VIRTUAL_FILE_PATH

+ func DefineAnalyticFunctions()

+ type CommonTables map[string]*View

+ func (ct CommonTables) Copy() CommonTables

+ func (ct CommonTables) Get(name string) (*View, error)

+ func (ct CommonTables) Load(clause parser.CommonTableClause) error

+ func (ct CommonTables) Merge(tables CommonTables) CommonTables

+ func (ct CommonTables) Set(commonTable parser.CommonTable) error

type Filter

+ CommonTables CommonTables

+ Records []FilterRecord

+ RecursiveTable parser.CommonTable

+ RecursiveTmpView *View

+ func NewFilterForLoop(view *View, parentFilter Filter) Filter

+ func NewFilterForRecord(view *View, recordIndex int, parentFilter Filter) Filter

+ func (f Filter) Copy() Filter

+ func (f Filter) Merge(filter Filter) Filter

+ func (f Filter) RecordCount() int

type View

+ ParentFilter Filter

+ func SelectAsSubquery(query parser.SelectQuery, parentFilter Filter) (*View, error)

+ func (view *View) LoadFromIdentifierWithCommonTables(table parser.Identifier, parentFilter Filter) error

+ func (view *View) UpdateHeader(reference string, fields []parser.Expression) error

Jul 2, 2017

Changes in this version

+ var AnalyticFunctions = map[string]func(*View, []parser.Expression, []partitionValue) error

+ func DenseRank(view *View, args []parser.Expression, partitinList []partitionValue) error

+ func Rank(view *View, args []parser.Expression, partitinList []partitionValue) error

+ func RowNumber(view *View, args []parser.Expression, partitinList []partitionValue) error

type Header

+ func (h Header) ContainsObject(obj parser.Expression) (int, error)

type Record

+ func (r Record) Match(record Record, indices []int) bool

Jun 27, 2017

Changes in this version

+ func CompareRowValues(v1 []parser.Primary, v2 []parser.Primary, operator string) (ternary.Value, error)

+ func InRowValueList(value []parser.Primary, list [][]parser.Primary, matchType int, ...) (ternary.Value, error)

type View

+ func (view *View) Offset(clause parser.OffsetClause)

Jun 24, 2017

Changes in this version

type Record

+ func (r Record) IsEqualTo(record Record) bool

+ type Records []Record

+ func (r Records) Contains(record Record) bool

type View

+ func (view *View) Distinct()

+ func (view *View) Except(calcView *View, all bool)

+ func (view *View) Intersect(calcView *View, all bool)

+ func (view *View) Union(calcView *View, all bool)

Jun 23, 2017

Changes in this version

type FileInfo

+ Encoding cmd.Encoding

+ LineBreak cmd.LineBreak

+ NoHeader bool

type Result

+ FileInfo *FileInfo

+ OperatedCount int

type ViewMap

+ func (m *ViewMap) Replace(view *View) error

Jun 13, 2017

Changes in this version

+ const INTERNAL_ID_COLUMN

+ var Cursors = CursorMap

+ var GlobalVars = Variables

+ func Call(args []parser.Primary) (parser.Primary, error)

+ func FetchCursor(name string, vars []parser.Variable) (bool, error)

+ type Cursor struct

+ func NewCursor(name string, query parser.SelectQuery) *Cursor

+ func (c *Cursor) Close()

+ func (c *Cursor) Fetch() ([]parser.Primary, error)

+ func (c *Cursor) Open() error

+ type CursorMap map[string]*Cursor

+ func (m CursorMap) Add(key string, query parser.SelectQuery) error

+ func (m CursorMap) Close(key string) error

+ func (m CursorMap) Dispose(key string)

+ func (m CursorMap) Fetch(key string) ([]parser.Primary, error)

+ func (m CursorMap) Open(key string) error

type Header

+ func (h Header) ContainsAlias(alias string) (int, error)

type IdentificationError

+ Field parser.FieldReference

+ type StatementFlow int

+ const BREAK

+ const CONTINUE

+ const ERROR

+ const EXIT

+ const TERMINATE

+ func ExecuteProgram(program []parser.Statement) (StatementFlow, string, error)

+ func IfStmt(stmt parser.If) (StatementFlow, string, error)

+ func While(stmt parser.While) (StatementFlow, string, error)

+ func WhileInCursor(stmt parser.WhileInCursor) (StatementFlow, string, error)

type View

+ func (view *View) FieldViewName(fieldRef parser.FieldReference) (string, error)

Jun 10, 2017

Changes in this version

+ const INTERNAL_ID_FIELD

+ var ResultSet = []Result

+ var ViewCache = NewViewMap()

+ func Commit(expressly bool) (string, error)

+ func EncodeView(view *View, format cmd.Format, delimiter rune, withoutHeader bool, ...) (string, error)

+ func ExecuteStatement(stmt parser.Statement) (string, error)

+ func InIntSlice(i int, list []int) bool

+ func InStrSlice(s string, list []string) bool

+ func Print(query parser.Print) (string, error)

+ func Rollback() string

+ func SetFlag(query parser.SetFlag) error

type Header

+ func NewHeaderWithoutId(ref string, words []string) Header

+ func (h Header) Copy() Header

+ func (h Header) TableColumnNames() []string

type Record

+ func NewRecordWithoutId(values []parser.Primary) Record

+ func (r Record) Copy() Record

type Result

+ Log string

+ Type StatementType

+ type StatementType int

+ const ADD_COLUMNS

+ const CREATE_TABLE

+ const DELETE

+ const DROP_COLUMNS

+ const INSERT

+ const PRINT

+ const RENAME_COLUMN

+ const UPDATE

type View

+ OperatedFields int

+ OperatedRecords int

+ UseInternalId bool

+ func AddColumns(query parser.AddColumns) (*View, error)

+ func CreateTable(query parser.CreateTable) (*View, error)

+ func Delete(query parser.DeleteQuery) ([]*View, error)

+ func DropColumns(query parser.DropColumns) (*View, error)

+ func Insert(query parser.InsertQuery) (*View, error)

+ func RenameColumn(query parser.RenameColumn) (*View, error)

+ func Select(query parser.SelectQuery, parentFilter Filter) (*View, error)

+ func Update(query parser.UpdateQuery) ([]*View, error)

+ func (view *View) Copy() *View

+ func (view *View) FieldIndex(ident parser.Identifier) (int, error)

+ func (view *View) FieldIndices(fields []parser.Expression) ([]int, error)

+ func (view *View) FieldRef(ident parser.Identifier) (string, error)

+ func (view *View) InsertFromQuery(fields []parser.Expression, query parser.SelectQuery) error

+ func (view *View) InsertValues(fields []parser.Expression, list []parser.Expression) error

+ func (view *View) InternalRecordId(ref string, recordIndex int) (int, error)

+ func (view *View) Load(clause parser.FromClause, parentFilter Filter) error

+ func (view *View) LoadFromIdentifier(table parser.Identifier) error

+ func (view *View) SelectAllColumns() error

+ type ViewMap struct

+ func NewViewMap() *ViewMap

+ func (m *ViewMap) Clear()

+ func (m *ViewMap) ClearAliases()

+ func (m *ViewMap) Exists(filepath string) (string, bool)

+ func (m *ViewMap) Get(filepath string) (*View, error)

+ func (m *ViewMap) GetWithInternalId(filepath string) (*View, error)

+ func (m *ViewMap) HasAlias(alias string) (string, bool)

+ func (m *ViewMap) Set(view *View, alias string) error

+ func (m *ViewMap) SetAlias(alias string, filepath string) error

+ func (m *ViewMap) Update(view *View) error

Jun 1, 2017

Changes in this version

+ const AUTO_INCREMENT_KEY

+ var AggregateFunctions = map[string]func(bool, []parser.Primary) parser.Primary

+ var ErrFieldAmbiguous = errors.New("field is ambiguous")

+ var ErrFieldNotExist = errors.New("field does not exist")

+ var ErrNotGrouped = errors.New("records are not grouped")

+ var Functions = map[string]func([]parser.Primary) (parser.Primary, error)

+ var Variable = Variables

+ func Abs(args []parser.Primary) (parser.Primary, error)

+ func Acos(args []parser.Primary) (parser.Primary, error)

+ func AddDay(args []parser.Primary) (parser.Primary, error)

+ func AddHour(args []parser.Primary) (parser.Primary, error)

+ func AddMicro(args []parser.Primary) (parser.Primary, error)

+ func AddMilli(args []parser.Primary) (parser.Primary, error)

+ func AddMinute(args []parser.Primary) (parser.Primary, error)

+ func AddMonth(args []parser.Primary) (parser.Primary, error)

+ func AddNano(args []parser.Primary) (parser.Primary, error)

+ func AddSecond(args []parser.Primary) (parser.Primary, error)

+ func AddYear(args []parser.Primary) (parser.Primary, error)

+ func All(p parser.Primary, list []parser.Primary, operator string) ternary.Value

+ func Any(p parser.Primary, list []parser.Primary, operator string) ternary.Value

+ func Asin(args []parser.Primary) (parser.Primary, error)

+ func Atan(args []parser.Primary) (parser.Primary, error)

+ func Atan2(args []parser.Primary) (parser.Primary, error)

+ func AutoIncrement(args []parser.Primary) (parser.Primary, error)

+ func Avg(distinct bool, list []parser.Primary) parser.Primary

+ func Base64Decode(args []parser.Primary) (parser.Primary, error)

+ func Base64Encode(args []parser.Primary) (parser.Primary, error)

+ func Between(p parser.Primary, low parser.Primary, high parser.Primary) ternary.Value

+ func Bin(args []parser.Primary) (parser.Primary, error)

+ func BinToDec(args []parser.Primary) (parser.Primary, error)

+ func Boolean(args []parser.Primary) (parser.Primary, error)

+ func ByteLen(args []parser.Primary) (parser.Primary, error)

+ func Calculate(p1 parser.Primary, p2 parser.Primary, operator int) parser.Primary

+ func Ceil(args []parser.Primary) (parser.Primary, error)

+ func Coalesce(args []parser.Primary) (parser.Primary, error)

+ func Compare(p1 parser.Primary, p2 parser.Primary, operator string) ternary.Value

+ func Cos(args []parser.Primary) (parser.Primary, error)

+ func Count(distinct bool, list []parser.Primary) parser.Primary

+ func DateDiff(args []parser.Primary) (parser.Primary, error)

+ func Datetime(args []parser.Primary) (parser.Primary, error)

+ func DatetimeFormat(args []parser.Primary) (parser.Primary, error)

+ func Day(args []parser.Primary) (parser.Primary, error)

+ func DayOfYear(args []parser.Primary) (parser.Primary, error)

+ func EqualTo(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func EquivalentTo(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Exp(args []parser.Primary) (parser.Primary, error)

+ func Exp2(args []parser.Primary) (parser.Primary, error)

+ func Expm1(args []parser.Primary) (parser.Primary, error)

+ func Float(args []parser.Primary) (parser.Primary, error)

+ func Floor(args []parser.Primary) (parser.Primary, error)

+ func GreaterThan(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func GreaterThanOrEqualTo(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Hex(args []parser.Primary) (parser.Primary, error)

+ func HexDecode(args []parser.Primary) (parser.Primary, error)

+ func HexEncode(args []parser.Primary) (parser.Primary, error)

+ func HexToDec(args []parser.Primary) (parser.Primary, error)

+ func Hour(args []parser.Primary) (parser.Primary, error)

+ func If(args []parser.Primary) (parser.Primary, error)

+ func Ifnull(args []parser.Primary) (parser.Primary, error)

+ func Integer(args []parser.Primary) (parser.Primary, error)

+ func Is(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Len(args []parser.Primary) (parser.Primary, error)

+ func LessThan(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func LessThanOrEqualTo(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Like(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Log(args []parser.Primary) (parser.Primary, error)

+ func Log10(args []parser.Primary) (parser.Primary, error)

+ func Log1p(args []parser.Primary) (parser.Primary, error)

+ func Log2(args []parser.Primary) (parser.Primary, error)

+ func Lower(args []parser.Primary) (parser.Primary, error)

+ func Lpad(args []parser.Primary) (parser.Primary, error)

+ func Ltrim(args []parser.Primary) (parser.Primary, error)

+ func Max(distinct bool, list []parser.Primary) parser.Primary

+ func Md5(args []parser.Primary) (parser.Primary, error)

+ func Md5Hmac(args []parser.Primary) (parser.Primary, error)

+ func Microsecond(args []parser.Primary) (parser.Primary, error)

+ func Millisecond(args []parser.Primary) (parser.Primary, error)

+ func Min(distinct bool, list []parser.Primary) parser.Primary

+ func Minute(args []parser.Primary) (parser.Primary, error)

+ func Month(args []parser.Primary) (parser.Primary, error)

+ func Nanosecond(args []parser.Primary) (parser.Primary, error)

+ func NotEqualTo(p1 parser.Primary, p2 parser.Primary) ternary.Value

+ func Now(args []parser.Primary) (parser.Primary, error)

+ func Nullif(args []parser.Primary) (parser.Primary, error)

+ func Oct(args []parser.Primary) (parser.Primary, error)

+ func OctToDec(args []parser.Primary) (parser.Primary, error)

+ func ParseJoinCondition(join parser.Join, view *View, joinView *View) parser.Expression

+ func Pow(args []parser.Primary) (parser.Primary, error)

+ func Rand(args []parser.Primary) (parser.Primary, error)

+ func Replace(args []parser.Primary) (parser.Primary, error)

+ func Round(args []parser.Primary) (parser.Primary, error)

+ func Rpad(args []parser.Primary) (parser.Primary, error)

+ func Rtrim(args []parser.Primary) (parser.Primary, error)

+ func Second(args []parser.Primary) (parser.Primary, error)

+ func Sha1(args []parser.Primary) (parser.Primary, error)

+ func Sha1Hmac(args []parser.Primary) (parser.Primary, error)

+ func Sha256(args []parser.Primary) (parser.Primary, error)

+ func Sha256Hmac(args []parser.Primary) (parser.Primary, error)

+ func Sha512(args []parser.Primary) (parser.Primary, error)

+ func Sha512Hmac(args []parser.Primary) (parser.Primary, error)

+ func Sin(args []parser.Primary) (parser.Primary, error)

+ func Sqrt(args []parser.Primary) (parser.Primary, error)

+ func String(args []parser.Primary) (parser.Primary, error)

+ func Substr(args []parser.Primary) (parser.Primary, error)

+ func Sum(distinct bool, list []parser.Primary) parser.Primary

+ func Tan(args []parser.Primary) (parser.Primary, error)

+ func Ternary(args []parser.Primary) (parser.Primary, error)

+ func TimeDiff(args []parser.Primary) (parser.Primary, error)

+ func Trim(args []parser.Primary) (parser.Primary, error)

+ func UnixNanoTime(args []parser.Primary) (parser.Primary, error)

+ func UnixTime(args []parser.Primary) (parser.Primary, error)

+ func Upper(args []parser.Primary) (parser.Primary, error)

+ func WeekOfYear(args []parser.Primary) (parser.Primary, error)

+ func Weekday(args []parser.Primary) (parser.Primary, error)

+ func Year(args []parser.Primary) (parser.Primary, error)

+ type Cell []parser.Primary

+ func NewCell(value parser.Primary) Cell

+ func NewGroupCell(values []parser.Primary) Cell

+ func (cell Cell) GroupedPrimary(index int) parser.Primary

+ func (cell Cell) Len() int

+ func (cell Cell) Primary() parser.Primary

+ type ComparisonResult int

+ const EQUAL

+ const GREATER

+ const INCOMMENSURABLE

+ const LESS

+ const NOT_EQUAL

+ func CompareCombinedly(p1 parser.Primary, p2 parser.Primary) ComparisonResult

+ func (cr ComparisonResult) String() string

+ type FileInfo struct

+ Delimiter rune

+ Path string

+ func NewFileInfo(filename string, repository string, delimiter rune) (*FileInfo, error)

+ type Filter []FilterRecord

+ func (f Filter) Evaluate(expr parser.Expression) (parser.Primary, error)

+ type FilterRecord struct

+ RecordIndex int

+ View *View

+ type Header []HeaderField

+ func AddHeaderField(h Header, alias string) Header

+ func MergeHeader(h1 Header, h2 Header) Header

+ func NewDualHeader() Header

+ func NewEmptyHeader(len int) Header

+ func NewHeader(ref string, words []string) Header

+ func (h Header) Contains(ref string, column string) (int, error)

+ func (h Header) Len() int

+ func (h Header) TableColumns() []parser.Expression

+ type HeaderField struct

+ Alias string

+ Column string

+ FromTable bool

+ IsGroupKey bool

+ Reference string

+ func (hf HeaderField) Label() string

+ type IdentificationError struct

+ Err error

+ Identifier string

+ func (e IdentificationError) Error() string

+ type NotGroupedError struct

+ Err error

+ Function string

+ func (e NotGroupedError) Error() string

+ type Record []Cell

+ func NewEmptyRecord(len int) Record

+ func NewRecord(values []parser.Primary) Record

+ func (record Record) GroupLen() int

+ type Result struct

+ Count int

+ Statement Statement

+ View *View

+ func Execute(input string) ([]Result, error)

+ type Statement int

+ const SELECT

+ type Variables map[string]parser.Primary

+ func (v Variables) Add(key string, value parser.Primary) error

+ func (v Variables) ClearAutoIncrement()

+ func (v Variables) Decrare(declaration parser.VariableDeclaration, filter Filter) error

+ func (v Variables) Delete(key string)

+ func (v Variables) Get(key string) (parser.Primary, error)

+ func (v Variables) Increment(key string, initialVal int64) parser.Primary

+ func (v Variables) Set(key string, value parser.Primary) error

+ func (v Variables) Substitute(substitution parser.VariableSubstitution, filter Filter) (parser.Primary, error)

+ type View struct

+ FileInfo *FileInfo

+ Header Header

+ Records []Record

+ func CrossJoin(view *View, joinView *View) *View

+ func ExecuteSelect(query parser.SelectQuery, parentFilter Filter) (*View, error)

+ func InnerJoin(view *View, joinView *View, condition parser.Expression, parentFilter Filter) (*View, error)

+ func NewDualView() *View

+ func NewView(clause parser.FromClause, parentFilter Filter) (*View, error)

+ func NewViewFromGroupedRecord(fr FilterRecord) *View

+ func OuterJoin(view *View, joinView *View, condition parser.Expression, direction int, ...) (*View, error)

+ func (view *View) Extract()

+ func (view *View) FieldLen() int

+ func (view *View) Fix()

+ func (view *View) GroupBy(clause parser.GroupByClause) error

+ func (view *View) Having(clause parser.HavingClause) error

+ func (view *View) Len() int

+ func (view *View) Less(i, j int) bool

+ func (view *View) Limit(clause parser.LimitClause)

+ func (view *View) OrderBy(clause parser.OrderByClause) error

+ func (view *View) RecordLen() int

+ func (view *View) Select(clause parser.SelectClause) error

+ func (view *View) Swap(i, j int)

+ func (view *View) Where(clause parser.WhereClause) error