query

package

v1.9.6 Latest Latest Go to latest Published: Mar 29, 2019 License: MIT Imports: 46 Imported by: 9

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mithrandie/csvq

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
Variables
func Abs(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Acos(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func AddDay(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddFlagElement(ctx context.Context, filter *Filter, expr parser.AddFlagElement) error
func AddHour(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddMicro(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddMilli(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddMinute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddMonth(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddNano(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddSecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func AddYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func All(rowValue value.RowValue, list []value.RowValue, operator string, ...) (ternary.Value, error)
func Analyze(ctx context.Context, view *View, fn parser.AnalyticFunction, ...) error
func Any(rowValue value.RowValue, list []value.RowValue, operator string, ...) (ternary.Value, error)
func AppendCompositeError(e1 error, e2 error) error
func Asin(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Atan(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Atan2(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Avg(list []value.Primary, _ *cmd.Flags) value.Primary
func Base64Decode(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Base64Encode(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Bin(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func BinToDec(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Boolean(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func ByteLen(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func CalcMinimumRequired(i1 int, i2 int, defaultMinimumRequired int) int
func Calculate(p1 value.Primary, p2 value.Primary, operator int) value.Primary
func Call(ctx context.Context, fn parser.Function, args []value.Primary) (value.Primary, error)
func Ceil(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Chdir(ctx context.Context, filter *Filter, expr parser.Chdir) error
func CheckArgsLen(expr parser.AnalyticFunction, length []int) error
func Coalesce(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func ContextForPreparedStatement(ctx context.Context, values *ReplaceValues) context.Context
func ContextForStoringResults(ctx context.Context) context.Context
func ConvertFieldContents(val value.Primary, forTextTable bool) (string, string, text.FieldAlignment)
func ConvertFileHandlerError(err error, ident parser.Identifier, fpath string) error
func Cos(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Count(list []value.Primary, _ *cmd.Flags) value.Primary
func CreateFilePath(filename parser.Identifier, repository string) (string, error)
func CrossJoin(ctx context.Context, filter *Filter, view *View, joinView *View) error
func DateDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Datetime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func DatetimeFormat(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Day(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func DayOfYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func DeclareView(ctx context.Context, filter *Filter, expr parser.ViewDeclaration) error
func Distinguish(list []value.Primary, flags *cmd.Flags) []value.Primary
func Echo(ctx context.Context, filter *Filter, expr parser.Echo) (string, error)
func EncodeView(fp io.Writer, view *View, fileInfo *FileInfo, flags *cmd.Flags) (string, error)
func Enotation(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func EnotationToDec(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Exp(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Exp2(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Expm1(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func FetchCursor(ctx context.Context, filter *Filter, name parser.Identifier, ...) (bool, error)
func Float(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Floor(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Format(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func FormatCount(i int, obj string) string
func GetRuntimeInformation(tx *Transaction, expr parser.RuntimeInformation) (value.Primary, error)
func Hex(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func HexDecode(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func HexEncode(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func HexToDec(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func HistoryFilePath(filename string) (string, error)
func Hour(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func If(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Ifnull(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func InIntSlice(i int, list []int) bool
func InRowValueList(rowValue value.RowValue, list []value.RowValue, matchType int, operator string, ...) (ternary.Value, error)
func InStrSliceWithCaseInsensitive(s string, list []string) bool
func InnerJoin(ctx context.Context, parentFilter *Filter, view *View, joinView *View, ...) error
func Instr(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Integer(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Is(p1 value.Primary, p2 value.Primary) ternary.Value
func JsonAgg(list []value.Primary) value.Primary
func JsonObject(ctx context.Context, filter *Filter, fn parser.Function) (value.Primary, error)
func JsonValue(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Len(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Like(p1 value.Primary, p2 value.Primary) ternary.Value
func ListAgg(list []value.Primary, separator string) value.Primary
func ListElem(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func LoadStatementsFromFile(ctx context.Context, tx *Transaction, expr parser.Source, fpath string) (statements []parser.Statement, err error)
func Log10(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Log1p(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Log2(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Lower(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Lpad(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Ltrim(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func MathLog(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Max(list []value.Primary, flags *cmd.Flags) value.Primary
func Md5(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Md5Hmac(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Median(list []value.Primary, flags *cmd.Flags) value.Primary
func Microsecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Millisecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Min(list []value.Primary, flags *cmd.Flags) value.Primary
func Minute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Month(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Nanosecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func NewAddFlagNotSupportedNameError(expr parser.AddFlagElement) error
func NewBuiltInFunctionDeclaredError(expr parser.Identifier) error
func NewCombinedSetFieldLengthError(selectEntity parser.QueryExpression, fieldLen int) error
func NewCommitError(expr parser.Expression, message string) error
func NewContextIsDone(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 NewDataParsingError(file parser.QueryExpression, filepath string, message string) error
func NewDeleteTableNotSpecifiedError(query parser.DeleteQuery) error
func NewDuplicateFieldNameError(fieldName parser.Identifier) error
func NewDuplicateParameterError(expr parser.Variable) error
func NewDuplicateStatementNameError(name parser.Identifier) error
func NewDuplicateTableNameError(table parser.Identifier) error
func NewEmptyJsonQueryError(expr parser.JsonQuery) error
func NewEmptyJsonTableError(expr parser.JsonQuery) error
func NewExternalCommandError(expr parser.Expression, message string) error
func NewFieldAmbiguousError(field parser.QueryExpression) error
func NewFieldLengthNotMatchError() error
func NewFieldNotExistError(field parser.QueryExpression) error
func NewFieldNotGroupKeyError(field parser.QueryExpression) error
func NewFileAlreadyExistError(file parser.Identifier) error
func NewFileLockTimeoutError(file parser.Identifier, path string) error
func NewFileNameAmbiguousError(file parser.Identifier) error
func NewFileNotExistError(file parser.QueryExpression) error
func NewFileUnableToReadError(file parser.Identifier) error
func NewFlagValueNotAllowedFormatError(setFlag parser.SetFlag) error
func NewForcedExit(code int) error
func NewFormatStringLengthNotMatchError() error
func NewFormatUnexpectedTerminationError() error
func NewFunctionArgumentLengthError(expr parser.QueryExpression, funcname string, argslen []int) error
func NewFunctionArgumentLengthErrorWithCustomArgs(expr parser.QueryExpression, funcname string, argstr string) error
func NewFunctionInvalidArgumentError(function parser.QueryExpression, funcname string, message string) error
func NewFunctionNotExistError(expr parser.QueryExpression, funcname string) error
func NewFunctionRedeclaredError(expr parser.Identifier) error
func NewInLineTableRedefinedError(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 NewInvalidCursorStatementError(statement parser.Identifier) error
func NewInvalidEventNameError(expr parser.Identifier) error
func NewInvalidFetchPositionError(position parser.FetchPosition) error
func NewInvalidFlagNameError(expr parser.Expression, name string) error
func NewInvalidFlagValueError(expr parser.SetFlag, message string) error
func NewInvalidFlagValueToBeRemovedError(unsetFlag parser.RemoveFlagElement) error
func NewInvalidLimitNumberError(clause parser.LimitClause) error
func NewInvalidLimitPercentageError(clause parser.LimitClause) error
func NewInvalidOffsetNumberError(clause parser.OffsetClause) error
func NewInvalidPathError(expr parser.Expression, path string, message string) error
func NewInvalidReloadTypeError(expr parser.Reload, name string) error
func NewInvalidRuntimeInformationError(expr parser.RuntimeInformation) error
func NewInvalidTableAttributeNameError(expr parser.Identifier) error
func NewInvalidTableAttributeValueError(expr parser.SetTableAttribute, message string) error
func NewInvalidTableObjectError(expr parser.TableObject, objectName string) error
func NewInvalidValueExpressionError(expr parser.QueryExpression) error
func NewJsonQueryTooManyRecordsError(expr parser.JsonQuery) error
func NewLoadConfigurationError(expr parser.Reload, message string) error
func NewLoadJsonError(expr parser.JsonQuery, message string) error
func NewNestedAggregateFunctionsError(expr parser.QueryExpression) error
func NewNotGroupingRecordsError(expr parser.QueryExpression, funcname string) error
func NewNotTableError(expr parser.QueryExpression) error
func NewPreparedStatementSyntaxError(err *parser.SyntaxError) error
func NewPromptEvaluationError(message string) error
func NewPseudoCursorError(cursor parser.Identifier) error
func NewReadFileError(expr parser.Expression, message string) error
func NewRemoveFlagNotSupportedNameError(expr parser.RemoveFlagElement) error
func NewReplaceValueLengthError(expr parser.Expression, message string) error
func NewRollbackError(expr parser.Expression, message string) error
func NewRowValueLengthInComparisonError(expr parser.QueryExpression, valueLen int) error
func NewRowValueLengthInListError(i int) error
func NewSelectFieldLengthInComparisonError(query parser.Subquery, valueLen int) error
func NewShowInvalidObjectTypeError(expr parser.Expression, objectType string) error
func NewSourceInvalidFilePathError(source parser.Source, arg parser.QueryExpression) error
func NewStatementNotExistError(name parser.Identifier) error
func NewStatementReplaceValueNotSpecifiedError(placeholder parser.Placeholder) error
func NewStdinEmptyError(stdin parser.Stdin) error
func NewSubqueryTooManyFieldsError(expr parser.Subquery) error
func NewSubqueryTooManyRecordsError(expr parser.Subquery) error
func NewSyntaxError(err *parser.SyntaxError) error
func NewSystemError(message string) error
func NewTableAttributeUnchangedError(fpath string) error
func NewTableAttributeValueNotAllowedFormatError(expr parser.SetTableAttribute) error
func NewTableFieldLengthError(query parser.SelectQuery, table parser.Identifier, fieldLen int) error
func NewTableNotLoadedError(table parser.Identifier) 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 NewTableObjectJsonArgumentsLengthError(expr parser.TableObject, argLen int) error
func NewTemporaryTableFieldLengthError(query parser.SelectQuery, table parser.Identifier, fieldLen int) error
func NewTemporaryTableRedeclaredError(table parser.Identifier) error
func NewTransactionOpenError(message string) error
func NewUndeclaredCursorError(cursor parser.Identifier) error
func NewUndeclaredTemporaryTableError(table parser.Identifier) error
func NewUndeclaredVariableError(expr parser.Variable) error
func NewUndefinedInLineTableError(table parser.Identifier) error
func NewUnknownFormatPlaceholderError(placeholder rune) error
func NewUnpermittedFunctionStatementError(expr parser.QueryExpression, funcname string) error
func NewUpdateFieldNotExistError(field parser.QueryExpression) error
func NewUpdateValueAmbiguousError(field parser.QueryExpression, value parser.QueryExpression) error
func NewUserTriggeredError(expr parser.Trigger, message string) error
func NewVariableRedeclaredError(expr parser.Variable) error
func NewWriteFileError(expr parser.Expression, message string) error
func Now(filter *Filter, fn parser.Function, args []value.Primary) (value.Primary, error)
func Nullif(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func NumberFormat(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Oct(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func OctToDec(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func OuterJoin(ctx context.Context, parentFilter *Filter, view *View, joinView *View, ...) error
func ParseExecuteStatements(ctx context.Context, filter *Filter, expr parser.Execute) ([]parser.Statement, error)
func ParseJoinCondition(join parser.Join, view *View, joinView *View) (parser.QueryExpression, []parser.FieldReference, []parser.FieldReference, ...)
func Pow(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Print(ctx context.Context, filter *Filter, expr parser.Print) (string, error)
func Printf(ctx context.Context, filter *Filter, expr parser.Printf) (string, error)
func Pwd(expr parser.Pwd) (string, error)
func Rand(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Reload(ctx context.Context, tx *Transaction, expr parser.Reload) error
func RemoveFlagElement(ctx context.Context, filter *Filter, expr parser.RemoveFlagElement) error
func Replace(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Round(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Rpad(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Rtrim(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, 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 SearchLTSVFilePath(filename parser.Identifier, repository string) (string, error)
func Second(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func SerializeComparisonKeys(buf *bytes.Buffer, values []value.Primary, flags *cmd.Flags)
func SerializeKey(buf *bytes.Buffer, val value.Primary, flags *cmd.Flags)
func SetEnvVar(ctx context.Context, filter *Filter, expr parser.SetEnvVar) error
func SetFlag(ctx context.Context, filter *Filter, expr parser.SetFlag) error
func Sha1(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sha1Hmac(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sha256(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sha256Hmac(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sha512(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sha512Hmac(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func ShowFields(ctx context.Context, filter *Filter, expr parser.ShowFields) (string, error)
func ShowFlag(flags *cmd.Flags, expr parser.ShowFlag) (string, error)
func ShowObjects(filter *Filter, expr parser.ShowObjects) (string, error)
func Sin(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Source(ctx context.Context, filter *Filter, expr parser.Source) ([]parser.Statement, error)
func Sqrt(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func String(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Substr(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Sum(list []value.Primary, _ *cmd.Flags) value.Primary
func Syntax(ctx context.Context, filter *Filter, expr parser.Syntax) string
func Tan(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func Ternary(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func TimeDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TimeNanoDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Trim(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func TruncDay(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncMicro(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncMilli(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncMinute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncMonth(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncNano(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncSecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func TruncTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func UTC(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func UnixNanoTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func UnixTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func UnsetEnvVar(expr parser.UnsetEnvVar) error
func Upper(fn parser.Function, args []value.Primary, _ *cmd.Flags) (value.Primary, error)
func WeekOfYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Weekday(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Width(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
func Year(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)
type AddFlagNotSupportedNameError
type AggregateFunction
type AliasMap
- func (m AliasMap) Add(alias parser.Identifier, path string) error
- func (m AliasMap) Get(alias parser.Identifier) (string, error)
type AliasNodes
- func (list AliasNodes) Add(alias parser.Identifier, path string) error
- func (list AliasNodes) Get(alias parser.Identifier) (path string, err error)
type AnalyticFunction
type AnalyticJsonAgg
- func (fn AnalyticJsonAgg) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn AnalyticJsonAgg) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type AnalyticListAgg
- func (fn AnalyticListAgg) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn AnalyticListAgg) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type BaseError
- func NewBaseError(expr parser.Expression, message string, code int, number int) *BaseError
- func NewBaseErrorWithCode(expr parser.Expression, message string, code int, number int) *BaseError
- func NewBaseErrorWithPrefix(prefix string, message string, code int, number int) *BaseError
- func (e *BaseError) AppendCompositeError(err Error)
- func (e *BaseError) Error() string
- func (e *BaseError) ErrorMessage() string
- func (e *BaseError) Number() int
- func (e *BaseError) ReturnCode() int
type BuiltInFunctionDeclaredError
type Cell
- func NewCell(val value.Primary) Cell
- func NewGroupCell(values []value.Primary) Cell
- func (cell Cell) GroupedValue(index int) value.Primary
- func (cell Cell) Len() int
- func (cell Cell) Value() value.Primary
type CombinedSetFieldLengthError
type CommitError
type Completer
- 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) FunctionArgs(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) PrepareArgs(line string, origLine string, index int) readline.CandidateList
- 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 ContainsSubstitusion
- func (c *ContainsSubstitusion) Error() string
type ContextIsDone
type CumeDist
- func (fn CumeDist) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn CumeDist) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type Cursor
- func NewCursor(e parser.CursorDeclaration) *Cursor
- func NewPseudoCursor(tx *Transaction, values []value.Primary) *Cursor
- func (c *Cursor) Close(name parser.Identifier) error
- func (c *Cursor) Count() (int, error)
- func (c *Cursor) Fetch(name parser.Identifier, position int, number int) ([]value.Primary, error)
- func (c *Cursor) IsInRange() (ternary.Value, error)
- func (c *Cursor) IsOpen() ternary.Value
- func (c *Cursor) Open(ctx context.Context, filter *Filter, name parser.Identifier, ...) error
- func (c *Cursor) Pointer() (int, error)
type CursorClosedError
type CursorFetchLengthError
type CursorMap
- func (m CursorMap) AddPseudoCursor(tx *Transaction, name parser.Identifier, values []value.Primary) error
- func (m CursorMap) Close(name parser.Identifier) error
- func (m CursorMap) Count(name parser.Identifier) (int, error)
- func (m CursorMap) Declare(expr parser.CursorDeclaration) error
- func (m CursorMap) Dispose(name parser.Identifier) error
- func (m CursorMap) Fetch(name parser.Identifier, position int, number int) ([]value.Primary, error)
- func (m CursorMap) IsInRange(name parser.Identifier) (ternary.Value, error)
- func (m CursorMap) IsOpen(name parser.Identifier) (ternary.Value, error)
- func (m CursorMap) Keys() []string
- func (m CursorMap) Open(ctx context.Context, filter *Filter, name parser.Identifier, ...) error
- func (m CursorMap) SortedKeys() []string
type CursorOpenError
type CursorRedeclaredError
type CursorScopes
- func (list CursorScopes) AddPseudoCursor(tx *Transaction, name parser.Identifier, values []value.Primary) error
- func (list CursorScopes) All() CursorMap
- 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(ctx context.Context, filter *Filter, name parser.Identifier, ...) error
type DataParsingError
type DeleteTableNotSpecifiedError
type DenseRank
- func (fn DenseRank) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn DenseRank) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type Direction
type Discard
- func NewDiscard() *Discard
- func (d Discard) Close() error
- func (d Discard) Write(p []byte) (int, error)
type DuplicateFieldNameError
type DuplicateParameterError
type DuplicateStatementNameError
type DuplicateTableNameError
type EmptyJsonQueryError
type EmptyJsonTableError
type EmptyResultSetError
- func NewEmptyResultSetError() *EmptyResultSetError
- func (e EmptyResultSetError) Error() string
type Error
type ExternalCommandError
type FieldAmbiguousError
type FieldLengthNotMatchError
type FieldNotExistError
type FieldNotGroupKeyError
type FileAlreadyExistError
type FileInfo
- func AddColumns(ctx context.Context, parentFilter *Filter, query parser.AddColumns) (*FileInfo, int, error)
- func CreateTable(ctx context.Context, parentFilter *Filter, query parser.CreateTable) (*FileInfo, error)
- func Delete(ctx context.Context, parentFilter *Filter, query parser.DeleteQuery) ([]*FileInfo, []int, error)
- func DropColumns(ctx context.Context, parentFilter *Filter, query parser.DropColumns) (*FileInfo, int, error)
- func Insert(ctx context.Context, parentFilter *Filter, query parser.InsertQuery) (*FileInfo, int, error)
- func NewFileInfo(filename parser.Identifier, repository string, format cmd.Format, ...) (*FileInfo, error)
- func NewFileInfoForCreate(filename parser.Identifier, repository string, delimiter rune, ...) (*FileInfo, error)
- func RenameColumn(ctx context.Context, parentFilter *Filter, query parser.RenameColumn) (*FileInfo, error)
- func SetTableAttribute(ctx context.Context, parentFilter *Filter, query parser.SetTableAttribute) (*FileInfo, string, error)
- func Update(ctx context.Context, parentFilter *Filter, query parser.UpdateQuery) ([]*FileInfo, []int, error)
- func (f *FileInfo) SetDelimiter(s string) error
- func (f *FileInfo) SetDelimiterPositions(s string) error
- func (f *FileInfo) SetEncloseAll(b bool) error
- func (f *FileInfo) SetEncoding(s string) error
- func (f *FileInfo) SetFormat(s string) error
- func (f *FileInfo) SetJsonEscape(s string) error
- func (f *FileInfo) SetLineBreak(s string) error
- func (f *FileInfo) SetNoHeader(b bool) error
- func (f *FileInfo) SetPrettyPrint(b bool) error
type FileLockTimeoutError
type FileNameAmbiguousError
type FileNotExistError
type FileUnableToReadError
type Filter
- func NewFilter(tx *Transaction) *Filter
- func NewFilterForRecord(parentFilter *Filter, view *View, recordIndex int) *Filter
- func NewFilterForSequentialEvaluation(parentFilter *Filter, view *View) *Filter
- func NewFilterWithScopes(tx *Transaction, variableScopes VariableScopes, ...) *Filter
- func (f *Filter) CreateChildScope() *Filter
- func (f *Filter) CreateNode() *Filter
- func (f *Filter) Evaluate(ctx context.Context, expr parser.QueryExpression) (value.Primary, error)
- func (f *Filter) EvaluateEmbeddedString(ctx context.Context, embedded string) (string, error)
- func (f *Filter) EvaluateSequentially(ctx context.Context, fn func(*Filter, int) error) error
- func (f *Filter) LoadInlineTable(ctx context.Context, clause parser.WithClause) error
- func (f *Filter) Merge(filter *Filter)
- func (f *Filter) ResetCurrentScope()
type FirstValue
- func (fn FirstValue) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn FirstValue) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type FlagValueNotAllowedFormatError
type ForcedExit
type FormatStringLengthNotMatchError
type FormatUnexpectedTerminationError
type FunctionArgumentLengthError
type FunctionInvalidArgumentError
type FunctionNotExistError
type FunctionRedeclaredError
type GoroutineManager
- func GetGoroutineManager() *GoroutineManager
- func (m *GoroutineManager) AssignRoutineNumber(recordLen int, minimumRequiredPerCore int, cpuNum int) int
- func (m *GoroutineManager) Release()
type GoroutineTaskManager
- func NewGoroutineTaskManager(recordLen int, minimumRequiredPerCore int, cpuNum 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) Run(ctx context.Context, fn func(int) error) error
- func (m *GoroutineTaskManager) SetError(e error)
- func (m *GoroutineTaskManager) Wait()
type Header
- func AddHeaderField(h Header, column string, alias string) (header Header, index int)
- func MergeHeader(h1 Header, h2 Header) Header
- func NewDualHeader() Header
- func NewEmptyHeader(len int) Header
- func NewHeader(view string, words []string) Header
- func NewHeaderWithAutofill(view string, words []string) Header
- func NewHeaderWithId(view string, words []string) Header
- func (h Header) Contains(fieldRef parser.FieldReference) (int, error)
- func (h Header) ContainsInternalId(viewName string) (int, error)
- func (h Header) ContainsNumber(number parser.ColumnNumber) (int, error)
- func (h Header) ContainsObject(obj parser.QueryExpression) (int, error)
- func (h Header) Copy() Header
- func (h Header) Len() int
- func (h Header) TableColumnNames() []string
- func (h Header) TableColumns() []parser.QueryExpression
- func (h Header) Update(reference string, fields []parser.QueryExpression) error
type HeaderField
type InLineTableRedefinedError
type InlineTableFieldLengthError
type InlineTableMap
- func (it InlineTableMap) Get(name parser.Identifier) (*View, error)
- func (it InlineTableMap) Set(ctx context.Context, parentFilter *Filter, inlineTable parser.InlineTable) error
type InlineTableNodes
- func (list InlineTableNodes) Get(name parser.Identifier) (*View, error)
- func (list InlineTableNodes) Load(ctx context.Context, parentFilter *Filter, clause parser.WithClause) error
- func (list InlineTableNodes) Set(ctx context.Context, parentFilter *Filter, inlineTable parser.InlineTable) error
type InsertRowValueLengthError
type InsertSelectFieldLengthError
type InternalRecordIdEmptyError
type InternalRecordIdNotExistError
type InvalidCursorStatementError
type InvalidEventNameError
type InvalidFetchPositionError
type InvalidFlagNameError
type InvalidFlagValueError
type InvalidFlagValueToBeRemoveError
type InvalidLimitNumberError
type InvalidLimitPercentageError
type InvalidOffsetNumberError
type InvalidPathError
type InvalidReloadTypeError
type InvalidRuntimeInformationError
type InvalidTableAttributeNameError
type InvalidTableAttributeValueError
type InvalidTableObjectError
type InvalidValueExpressionError
type JsonQueryTooManyRecordsError
type Lag
- func (fn Lag) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn Lag) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type LastValue
- func (fn LastValue) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn LastValue) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type Lead
- func (fn Lead) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn Lead) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type LoadConfigurationError
type LoadJsonError
type NTile
- func (fn NTile) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn NTile) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type NestedAggregateFunctionsError
type NotGroupingRecordsError
type NotTableError
type NthValue
- func (fn NthValue) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn NthValue) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type ObjectStatus
type ObjectWriter
- func NewObjectWriter(tx *Transaction) *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) WriteWithAutoLineBreak(s string)
- func (w *ObjectWriter) WriteWithoutLineBreak(s string)
type PaddingType
type Partition
- func (p Partition) Reverse()
type Partitions
type PercentRank
- func (fn PercentRank) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn PercentRank) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type PreparedStatement
- func NewPreparedStatement(filter *Filter, expr parser.StatementPreparation) (*PreparedStatement, error)
type PreparedStatementMap
- 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
type Processor
- 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) 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 Prompt
- func NewPrompt(filter *Filter, palette *color.Palette) *Prompt
- func (p *Prompt) LoadConfig() error
- func (p *Prompt) Render(ctx context.Context, sequence []PromptElement) (string, error)
- func (p *Prompt) RenderContinuousPrompt(ctx context.Context) (string, error)
- func (p *Prompt) RenderPrompt(ctx context.Context) (string, error)
- func (p *Prompt) StripEscapeSequence(s string) string
type PromptElement
type PromptEvaluationError
- func (e PromptEvaluationError) Error() string
type PseudoCursorError
type Rank
- func (fn Rank) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn Rank) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type ReadFileError
type ReadLineTerminal
- func (t ReadLineTerminal) GetSize() (int, int, error)
- func (t ReadLineTerminal) ReadLine() (string, error)
- func (t ReadLineTerminal) ReloadConfig() error
- func (t ReadLineTerminal) SaveHistory(s string) error
- func (t ReadLineTerminal) SetContinuousPrompt(ctx context.Context)
- func (t ReadLineTerminal) SetPrompt(ctx context.Context)
- func (t ReadLineTerminal) Teardown() error
- func (t ReadLineTerminal) UpdateCompleter()
- func (t ReadLineTerminal) Write(s string) error
- func (t ReadLineTerminal) WriteError(s string) error
type ReadlineListener
- func (l ReadlineListener) OnChange(line []rune, pos int, key rune) (newLine []rune, newPos int, ok bool)
type Record
- func NewEmptyRecord(len int) Record
- func NewRecord(values []value.Primary) Record
- func NewRecordWithId(internalId int, values []value.Primary) Record
- func (r Record) Copy() Record
- func (r Record) GroupLen() int
- func (r Record) SerializeComparisonKeys(buf *bytes.Buffer, flags *cmd.Flags)
type RecordReader
type RecordSet
- func MergeRecordSetList(list []RecordSet) RecordSet
- func (r RecordSet) Copy() RecordSet
type RemoveFlagNotSupportedNameError
type ReplaceValueLengthError
type ReplaceValues
- func NewReplaceValues(replace []parser.ReplaceValue) *ReplaceValues
type RollbackError
type RowNumber
- func (fn RowNumber) CheckArgsLen(expr parser.AnalyticFunction) error
- func (fn RowNumber) Execute(ctx context.Context, filter *Filter, partition Partition, ...) (map[int]value.Primary, error)
type RowValueLengthInComparisonError
type RowValueLengthInListError
type SelectFieldLengthInComparisonError
type Session
- 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 ShowInvalidObjectTypeError
type SortValue
- func NewSortValue(val value.Primary, flags *cmd.Flags) *SortValue
- func (v *SortValue) EquivalentTo(compareValue *SortValue) bool
- func (v *SortValue) Less(compareValue *SortValue) ternary.Value
type SortValueType
type SortValues
- func (values SortValues) EquivalentTo(compareValues SortValues) bool
- func (values SortValues) Less(compareValues SortValues, directions []int, nullPositions []int) bool
- func (values SortValues) Serialize(buf *bytes.Buffer)
type SourceInvalidFilePathError
type StatementFlow
type StatementNotExistError
type StatementReplaceValueNotSpecifiedError
type StdinEmptyError
type StringFormatter
- func NewStringFormatter() *StringFormatter
- func (f *StringFormatter) Format(format string, values []value.Primary) (string, error)
type SubqueryTooManyFieldsError
type SubqueryTooManyRecordsError
type SyntaxError
type SystemError
type TableAttributeUnchangedError
- func (e TableAttributeUnchangedError) Error() string
type TableAttributeValueNotAllowedFormatError
type TableFieldLengthError
type TableNotLoadedError
type TableObjectArgumentsLengthError
type TableObjectInvalidArgumentError
type TableObjectInvalidDelimiterError
type TableObjectInvalidDelimiterPositionsError
type TableObjectInvalidJsonQueryError
type TableObjectJsonArgumentsLengthError
type TemporaryTableFieldLengthError
type TemporaryTableRedeclaredError
type TemporaryViewScopes
- func (list TemporaryViewScopes) All() 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(ctx context.Context, name parser.Identifier, flags *cmd.Flags) (*View, error)
- func (list TemporaryViewScopes) Replace(view *View)
- func (list TemporaryViewScopes) Restore(uncomittedViews map[string]*FileInfo) []string
- func (list TemporaryViewScopes) Set(view *View)
- func (list TemporaryViewScopes) Store(uncomittedViews map[string]*FileInfo) []string
type Transaction
- 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 TransactionOpenError
type UncommittedViews
- 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 UndeclaredCursorError
type UndeclaredTemporaryTableError
type UndeclaredVariableError
type UndefinedInLineTableError
type UnknownFormatPlaceholderError
type UnpermittedFunctionStatementError
type UpdateFieldNotExistError
type UpdateValueAmbiguousError
type UserDefinedFunction
- func (fn *UserDefinedFunction) CheckArgsLen(expr parser.QueryExpression, name string, argsLen int) error
- func (fn *UserDefinedFunction) Execute(ctx context.Context, filter *Filter, args []value.Primary) (value.Primary, error)
- func (fn *UserDefinedFunction) ExecuteAggregate(ctx context.Context, filter *Filter, values []value.Primary, ...) (value.Primary, error)
type UserDefinedFunctionMap
- func (m UserDefinedFunctionMap) CheckDuplicate(name parser.Identifier) error
- func (m UserDefinedFunctionMap) Declare(expr parser.FunctionDeclaration) error
- func (m UserDefinedFunctionMap) DeclareAggregate(expr parser.AggregateDeclaration) error
- func (m UserDefinedFunctionMap) Dispose(name parser.Identifier) error
- func (m UserDefinedFunctionMap) Get(fn parser.QueryExpression, name string) (*UserDefinedFunction, error)
- func (m UserDefinedFunctionMap) Keys() []string
- func (m UserDefinedFunctionMap) SortedKeys() []string
type UserDefinedFunctionScopes
- func (list UserDefinedFunctionScopes) All() (UserDefinedFunctionMap, UserDefinedFunctionMap)
- func (list UserDefinedFunctionScopes) Declare(expr parser.FunctionDeclaration) error
- func (list UserDefinedFunctionScopes) DeclareAggregate(expr parser.AggregateDeclaration) error
- func (list UserDefinedFunctionScopes) Dispose(name parser.Identifier) error
- func (list UserDefinedFunctionScopes) Get(expr parser.QueryExpression, name string) (*UserDefinedFunction, error)
type UserTriggeredError
type VariableMap
- func NewVariableMap() VariableMap
- func (m *VariableMap) Add(variable parser.Variable, value value.Primary) error
- func (m *VariableMap) Declare(ctx context.Context, filter *Filter, declaration parser.VariableDeclaration) error
- func (m *VariableMap) Dispose(variable parser.Variable) error
- func (m *VariableMap) Get(variable parser.Variable) (value.Primary, error)
- func (m *VariableMap) Set(variable parser.Variable, value value.Primary) error
- func (m *VariableMap) SortedKeys() []string
- func (m *VariableMap) Substitute(ctx context.Context, filter *Filter, substitution parser.VariableSubstitution) (value.Primary, error)
- func (m *VariableMap) SubstituteDirectly(variable parser.Variable, value value.Primary) (value.Primary, error)
type VariableRedeclaredError
type VariableScopes
- func (list VariableScopes) All() VariableMap
- func (list VariableScopes) Declare(ctx context.Context, filter *Filter, expr parser.VariableDeclaration) 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(ctx context.Context, filter *Filter, expr parser.VariableSubstitution) (value value.Primary, err error)
- func (list VariableScopes) SubstituteDirectly(variable parser.Variable, value value.Primary) (value.Primary, error)
type View
- func NewView(tx *Transaction) *View
- func NewViewFromGroupedRecord(filterRecord filterRecord) *View
- func Select(ctx context.Context, parentFilter *Filter, query parser.SelectQuery) (*View, error)
- func (view *View) Copy() *View
- func (view *View) Except(ctx context.Context, calcView *View, all bool) (err error)
- func (view *View) ExtendRecordCapacity(ctx context.Context, exprs []parser.QueryExpression) error
- func (view *View) FieldIndex(fieldRef parser.QueryExpression) (int, error)
- func (view *View) FieldIndices(fields []parser.QueryExpression) ([]int, error)
- func (view *View) FieldLen() int
- func (view *View) FieldViewName(fieldRef parser.QueryExpression) (string, error)
- func (view *View) Fix(ctx context.Context) error
- func (view *View) GenerateComparisonKeys(ctx context.Context) error
- func (view *View) GroupBy(ctx context.Context, clause parser.GroupByClause) error
- func (view *View) Having(ctx context.Context, clause parser.HavingClause) error
- func (view *View) InsertFromQuery(ctx context.Context, fields []parser.QueryExpression, query parser.SelectQuery) (int, error)
- func (view *View) InsertValues(ctx context.Context, fields []parser.QueryExpression, ...) (int, error)
- func (view *View) InternalRecordId(ref string, recordIndex int) (int, error)
- func (view *View) Intersect(ctx context.Context, calcView *View, all bool) (err error)
- func (view *View) Len() int
- func (view *View) Less(i, j int) bool
- func (view *View) Limit(ctx context.Context, clause parser.LimitClause) error
- func (view *View) ListValuesForAggregateFunctions(ctx context.Context, expr parser.QueryExpression, arg parser.QueryExpression, ...) ([]value.Primary, error)
- func (view *View) Load(ctx context.Context, filter *Filter, clause parser.FromClause, forUpdate bool, ...) error
- func (view *View) LoadFromTableIdentifier(ctx context.Context, filter *Filter, table parser.QueryExpression, ...) error
- func (view *View) Offset(ctx context.Context, clause parser.OffsetClause) error
- func (view *View) OrderBy(ctx context.Context, clause parser.OrderByClause) error
- func (view *View) RecordLen() int
- func (view *View) RestoreHeaderReferences() error
- func (view *View) Select(ctx context.Context, clause parser.SelectClause) error
- func (view *View) SelectAllColumns(ctx context.Context) error
- func (view *View) Swap(i, j int)
- func (view *View) Union(ctx context.Context, calcView *View, all bool) (err error)
- func (view *View) Where(ctx context.Context, clause parser.WhereClause) error
type ViewMap
- func NewViewMap() ViewMap
- func (m ViewMap) Clean(container *file.Container) error
- func (m ViewMap) CleanWithErrors(container *file.Container) error
- func (m ViewMap) Dispose(container *file.Container, name string) error
- func (m ViewMap) DisposeTemporaryTable(table parser.Identifier) error
- func (m ViewMap) Exists(fpath string) bool
- func (m ViewMap) Get(fpath parser.Identifier) (*View, error)
- func (m ViewMap) GetWithInternalId(ctx context.Context, fpath parser.Identifier, flags *cmd.Flags) (*View, error)
- func (m ViewMap) Keys() []string
- func (m ViewMap) Replace(view *View) error
- func (m ViewMap) Set(view *View)
- func (m ViewMap) SortedKeys() []string
type VirtualTerminal
- func NewTerminal(ctx context.Context, filter *Filter) (VirtualTerminal, error)
type WindowFrame
- func WindowFrameSet(partition Partition, expr parser.AnalyticClause) []WindowFrame
type WriteFileError

Constants ¶

View Source

const (
	ShowTables     = "TABLES"
	ShowViews      = "VIEWS"
	ShowCursors    = "CURSORS"
	ShowFunctions  = "FUNCTIONS"
	ShowStatements = "STATEMENTS"
	ShowFlags      = "FLAGS"
	ShowEnv        = "ENV"
	ShowRuninfo    = "RUNINFO"
)

View Source

const (
	ErrorMessageTemplate                 = "[L:%d C:%d] %s"
	ErrorMessageWithFilepathTemplate     = "%s [L:%d C:%d] %s"
	ErrorMessageWithCustomPrefixTemplate = "[%s] %s"

	ErrMsgInvalidValueExpression               = "%s: cannot evaluate as a value"
	ErrMsgInvalidPath                          = "%s: %s"
	ErrMsgReadFile                             = "failed to read from file: %s"
	ErrMsgWriteFile                            = "failed to write to file: %s"
	ErrMsgCommit                               = "failed to commit: %s"
	ErrMsgRollback                             = "failed to rollback: %s"
	ErrMsgFieldAmbiguous                       = "field %s is ambiguous"
	ErrMsgFieldNotExist                        = "field %s does not exist"
	ErrMsgFieldNotGroupKey                     = "field %s is not a group key"
	ErrMsgDuplicateFieldName                   = "field name %s is a duplicate"
	ErrMsgNotGroupingRecords                   = "function %s cannot aggregate not grouping records"
	ErrMsgUndeclaredVariable                   = "variable %s is undeclared"
	ErrMsgVariableRedeclared                   = "variable %s is redeclared"
	ErrMsgFunctionNotExist                     = "function %s does not exist"
	ErrMsgFunctionArgumentsLength              = "function %s takes %s"
	ErrMsgFunctionInvalidArgument              = "%s for function %s"
	ErrMsgUnpermittedFunctionStatement         = "function %s cannot be used as a statement"
	ErrMsgNestedAggregateFunctions             = "aggregate functions are nested at %s"
	ErrMsgFunctionRedeclared                   = "function %s is redeclared"
	ErrMsgBuiltInFunctionDeclared              = "function %s is a built-in function"
	ErrMsgDuplicateParameter                   = "parameter %s is a duplicate"
	ErrMsgSubqueryTooManyRecords               = "subquery returns too many records, should return only one record"
	ErrMsgSubqueryTooManyFields                = "subquery returns too many fields, should return only one field"
	ErrMsgJsonQueryTooManyRecords              = "json query returns too many records, should return only one record"
	ErrMsgLoadJson                             = "json loading error: %s"
	ErrMsgEmptyJsonQuery                       = "json query is empty"
	ErrMsgEmptyJsonTable                       = "json table is empty"
	ErrMsgInvalidTableObject                   = "invalid table object: %s"
	ErrMsgTableObjectInvalidDelimiter          = "invalid delimiter: %s"
	ErrMsgTableObjectInvalidDelimiterPositions = "invalid delimiter positions: %s"
	ErrMsgTableObjectInvalidJsonQuery          = "invalid json query: %s"
	ErrMsgTableObjectArgumentsLength           = "table object %s takes at most %d arguments"
	ErrMsgTableObjectJsonArgumentsLength       = "table object %s takes exactly %d arguments"
	ErrMsgTableObjectInvalidArgument           = "invalid argument for %s: %s"
	ErrMsgCursorRedeclared                     = "cursor %s is redeclared"
	ErrMsgUndeclaredCursor                     = "cursor %s is undeclared"
	ErrMsgCursorClosed                         = "cursor %s is closed"
	ErrMsgCursorOpen                           = "cursor %s is already open"
	ErrMsgInvalidCursorStatement               = "invalid cursor statement: %s"
	ErrMsgPseudoCursor                         = "cursor %s is a pseudo cursor"
	ErrMsgCursorFetchLength                    = "fetching from cursor %s returns %s"
	ErrMsgInvalidFetchPosition                 = "fetching position %s is not an integer value"
	ErrMsgInlineTableRedefined                 = "inline table %s is redefined"
	ErrMsgUndefinedInlineTable                 = "inline table %s is undefined"
	ErrMsgInlineTableFieldLength               = "select query should return exactly %s for inline table %s"
	ErrMsgFileNotExist                         = "file %s does not exist"
	ErrMsgFileAlreadyExist                     = "file %s already exists"
	ErrMsgFileUnableToRead                     = "file %s is unable to be read"
	ErrMsgFileLockTimeout                      = "file %s: lock wait timeout period exceeded"
	ErrMsgFileNameAmbiguous                    = "filename %s is ambiguous"
	ErrMsgDataParsing                          = "data parse error in file %s: %s"
	ErrMsgTableFieldLength                     = "select query should return exactly %s for table %s"
	ErrMsgTemporaryTableRedeclared             = "view %s is redeclared"
	ErrMsgUndeclaredTemporaryTable             = "view %s is undeclared"
	ErrMsgTemporaryTableFieldLength            = "select query should return exactly %s for view %s"
	ErrMsgDuplicateTableName                   = "table name %s is a duplicate"
	ErrMsgTableNotLoaded                       = "table %s is not loaded"
	ErrMsgStdinEmpty                           = "stdin is empty"
	ErrMsgRowValueLengthInComparison           = "row value should contain exactly %s"
	ErrMsgFieldLengthInComparison              = "select query should return exactly %s"
	ErrMsgInvalidLimitPercentage               = "limit percentage %s is not a float value"
	ErrMsgInvalidLimitNumber                   = "limit number of records %s is not an integer value"
	ErrMsgInvalidOffsetNumber                  = "offset number %s is not an integer value"
	ErrMsgCombinedSetFieldLength               = "result set to be combined should contain exactly %s"
	ErrMsgInsertRowValueLength                 = "row value should contain exactly %s"
	ErrMsgInsertSelectFieldLength              = "select query should return exactly %s"
	ErrMsgUpdateFieldNotExist                  = "field %s does not exist in the tables to update"
	ErrMsgUpdateValueAmbiguous                 = "value %s to set in the field %s is ambiguous"
	ErrMsgDeleteTableNotSpecified              = "tables to delete records are not specified"
	ErrMsgShowInvalidObjectType                = "object type %s is invalid"
	ErrMsgReplaceValueLength                   = "%s"
	ErrMsgSourceInvalidFilePath                = "%s is a invalid file path"
	ErrMsgInvalidFlagName                      = "%s is an unknown flag"
	ErrMsgFlagValueNowAllowedFormat            = "%s for %s is not allowed"
	ErrMsgInvalidFlagValue                     = "%s"
	ErrMsgAddFlagNotSupportedName              = "add flag element syntax does not support %s"
	ErrMsgRemoveFlagNotSupportedName           = "remove flag element syntax does not support %s"
	ErrMsgInvalidFlagValueToBeRemoved          = "%s is an invalid value for %s to specify the element"
	ErrMsgInvalidRuntimeInformation            = "%s is an unknown runtime information"
	ErrMsgNotTable                             = "view has no attributes"
	ErrMsgInvalidTableAttributeName            = "table attribute %s does not exist"
	ErrMsgTableAttributeValueNotAllowedFormat  = "%s for %s is not allowed"
	ErrMsgInvalidTableAttributeValue           = "%s"
	ErrMsgInvalidEventName                     = "%s is an unknown event"
	ErrMsgInternalRecordIdNotExist             = "internal record id does not exist"
	ErrMsgInternalRecordIdEmpty                = "internal record id is empty"
	ErrMsgFieldLengthNotMatch                  = "field length does not match"
	ErrMsgRowValueLengthInList                 = "row value length does not match at index %d"
	ErrMsgFormatStringLengthNotMatch           = "number of replace values does not match"
	ErrMsgUnknownFormatPlaceholder             = "%q is an unknown placeholder"
	ErrMsgFormatUnexpectedTermination          = "unexpected termination of format string"
	ErrMsgExternalCommand                      = "external command: %s"
	ErrMsgInvalidReloadType                    = "%s is an unknown reload type"
	ErrMsgLoadConfiguration                    = "configuration loading error: %s"
	ErrMsgDuplicateStatementName               = "statement %s is a duplicate"
	ErrMsgStatementNotExist                    = "statement %s does not exist"
	ErrMsgStatementReplaceValueNotSpecified    = "replace value for %s is not specified"
)

View Source

const (
	ReturnCodeSystemError               = 1
	ReturnCodeIOError                   = 2
	ReturnCodeContextIsDone             = 4
	ReturnCodeSyntaxError               = 8
	ReturnCodeApplicationError          = 16
	ReturnCodeDefaultUserTriggeredError = 32
)

View Source

const (
	//System Error
	ErrorSystemError     = 1000
	ErrorExternalCommand = 1100

	//IO Error
	ErrorIOError          = 2000
	ErrorReadFile         = 2001
	ErrorWriteFile        = 2002
	ErrorCommit           = 2100
	ErrorRollback         = 2101
	ErrorInvalidPath      = 2200
	ErrorFileNotExist     = 2201
	ErrorFileAlreadyExist = 2202
	ErrorFileUnableToRead = 2203

	//Context Error
	ErrorContextIsDone   = 4000
	ErrorFileLockTimeout = 4001

	//Syntax Error
	ErrorSyntaxError                  = 8000
	ErrorInvalidValueExpression       = 8001
	ErrorUnpermittedFunctionStatement = 8002
	ErrorNestedAggregateFunctions     = 8003
	ErrorPreparedStatementSyntaxError = 8004

	//Application Error
	ErrorFieldAmbiguous                       = 16001
	ErrorFieldNotExist                        = 16002
	ErrorFieldNotGroupKey                     = 16003
	ErrorDuplicateFieldName                   = 16004
	ErrorNotGroupingRecords                   = 16101
	ErrorUndeclaredVariable                   = 16201
	ErrorVariableRedeclared                   = 16202
	ErrorFunctionNotExist                     = 16301
	ErrorFunctionArgumentsLength              = 16302
	ErrorFunctionInvalidArgument              = 16303
	ErrorFunctionRedeclared                   = 16401
	ErrorBuiltInFunctionDeclared              = 16402
	ErrorDuplicateParameter                   = 16403
	ErrorSubqueryTooManyRecords               = 16501
	ErrorSubqueryTooManyFields                = 16502
	ErrorJsonQueryTooManyRecords              = 16601
	ErrorLoadJson                             = 16602
	ErrorEmptyJsonQuery                       = 16603
	ErrorEmptyJsonTable                       = 16701
	ErrorInvalidTableObject                   = 16801
	ErrorTableObjectInvalidDelimiter          = 16802
	ErrorTableObjectInvalidDelimiterPositions = 16803
	ErrorTableObjectInvalidJsonQuery          = 16804
	ErrorTableObjectArgumentsLength           = 16805
	ErrorTableObjectJsonArgumentsLength       = 16806
	ErrorTableObjectInvalidArgument           = 16807
	ErrorCursorRedeclared                     = 16901
	ErrorUndeclaredCursor                     = 16902
	ErrorCursorClosed                         = 16903
	ErrorCursorOpen                           = 16904
	ErrorInvalidCursorStatement               = 16905
	ErrorPseudoCursor                         = 16906
	ErrorCursorFetchLength                    = 16907
	ErrorInvalidFetchPosition                 = 16908
	ErrorInlineTableRedefined                 = 17001
	ErrorUndefinedInlineTable                 = 17002
	ErrorInlineTableFieldLength               = 17003
	ErrorFileNameAmbiguous                    = 17101
	ErrorDataParsing                          = 17201
	ErrorTableFieldLength                     = 17301
	ErrorTemporaryTableRedeclared             = 17401
	ErrorUndeclaredTemporaryTable             = 17402
	ErrorTemporaryTableFieldLength            = 17403
	ErrorDuplicateTableName                   = 17501
	ErrorTableNotLoaded                       = 17502
	ErrorStdinEmpty                           = 17503
	ErrorRowValueLengthInComparison           = 17601
	ErrorFieldLengthInComparison              = 17602
	ErrorInvalidLimitPercentage               = 17701
	ErrorInvalidLimitNumber                   = 17702
	ErrorInvalidOffsetNumber                  = 17801
	ErrorCombinedSetFieldLength               = 17901
	ErrorInsertRowValueLength                 = 18001
	ErrorInsertSelectFieldLength              = 18002
	ErrorUpdateFieldNotExist                  = 19001
	ErrorUpdateValueAmbiguous                 = 19002
	ErrorDeleteTableNotSpecified              = 19101
	ErrorShowInvalidObjectType                = 19201
	ErrorReplaceValueLength                   = 19301
	ErrorSourceInvalidFilePath                = 19401
	ErrorInvalidFlagName                      = 19501
	ErrorFlagValueNowAllowedFormat            = 19502
	ErrorInvalidFlagValue                     = 19503
	ErrorAddFlagNotSupportedName              = 19601
	ErrorRemoveFlagNotSupportedName           = 19602
	ErrorInvalidFlagValueToBeRemoved          = 19603
	ErrorInvalidRuntimeInformation            = 19701
	ErrorNotTable                             = 19801
	ErrorInvalidTableAttributeName            = 19802
	ErrorTableAttributeValueNotAllowedFormat  = 19803
	ErrorInvalidTableAttributeValue           = 19804
	ErrorInvalidEventName                     = 19901
	ErrorInternalRecordIdNotExist             = 20001
	ErrorInternalRecordIdEmpty                = 20002
	ErrorFieldLengthNotMatch                  = 20101
	ErrorRowValueLengthInList                 = 20201
	ErrorFormatStringLengthNotMatch           = 20301
	ErrorUnknownFormatPlaceholder             = 20302
	ErrorFormatUnexpectedTermination          = 20303
	ErrorInvalidReloadType                    = 20401
	ErrorLoadConfiguration                    = 20501
	ErrorDuplicateStatementName               = 20601
	ErrorStatementNotExist                    = 20602
	ErrorStatementReplaceValueNotSpecified    = 20603

	//User Triggered Error
	ErrorExit          = 32000
	ErrorUserTriggered = 32001
)

View Source

const (
	TableDelimiter          = "DELIMITER"
	TableDelimiterPositions = "DELIMITER_POSITIONS"
	TableFormat             = "FORMAT"
	TableEncoding           = "ENCODING"
	TableLineBreak          = "LINE_BREAK"
	TableHeader             = "HEADER"
	TableEncloseAll         = "ENCLOSE_ALL"
	TableJsonEscape         = "JSON_ESCAPE"
	TablePrettyPrint        = "PRETTY_PRINT"
)

View Source

const (
	DefaultLineWidth = 75
	DefaultPadding   = 1
)

View Source

const (
	UncommittedInformation  = "UNCOMMITTED"
	CreatedInformation      = "CREATED"
	UpdatedInformation      = "UPDATED"
	UpdatedViewsInformation = "UPDATED_VIEWS"
	LoadedTablesInformation = "LOADED_TABLES"
	WorkingDirectory        = "WORKING_DIRECTORY"
	VersionInformation      = "VERSION"
)

View Source

const (
	TerminalPrompt           string = "csvq > "
	TerminalContinuousPrompt string = "     > "
)

View Source

const DefaultUserTriggeredErrorMessage = "triggered error"

View Source

const EOF = -1

View Source

const ExitMessage = "exit"

View Source

const IgnoredFlagPrefix = "(ignored) "

View Source

const InternalIdColumn = "@__internal_id"

View Source

const MinimumRequiredPerCPUCore = 80

View Source

const (
	ReloadConfig = "CONFIG"
)

View Source

const StatementReplaceValuesContextKey = "statement_replace_values"

View Source

const StoringResultsContextKey = "store_query_results"

Variables ¶

View Source

var AggregateFunctions = map[string]AggregateFunction{
	"COUNT":  Count,
	"MAX":    Max,
	"MIN":    Min,
	"SUM":    Sum,
	"AVG":    Avg,
	"MEDIAN": Median,
}

View Source

var AnalyticFunctions = map[string]AnalyticFunction{
	"ROW_NUMBER":   RowNumber{},
	"RANK":         Rank{},
	"DENSE_RANK":   DenseRank{},
	"CUME_DIST":    CumeDist{},
	"PERCENT_RANK": PercentRank{},
	"NTILE":        NTile{},
	"FIRST_VALUE":  FirstValue{},
	"LAST_VALUE":   LastValue{},
	"NTH_VALUE":    NthValue{},
	"LAG":          Lag{},
	"LEAD":         Lead{},
	"LISTAGG":      AnalyticListAgg{},
	"JSON_AGG":     AnalyticJsonAgg{},
}

View Source

var FileAttributeList = []string{
	TableDelimiter,
	TableDelimiterPositions,
	TableFormat,
	TableEncoding,
	TableLineBreak,
	TableHeader,
	TableEncloseAll,
	TableJsonEscape,
	TablePrettyPrint,
}

View Source

var Functions = map[string]func(parser.Function, []value.Primary, *cmd.Flags) (value.Primary, error){}/* 105 elements not displayed */

View Source

var RuntimeInformatinList = []string{
	UncommittedInformation,
	CreatedInformation,
	UpdatedInformation,
	UpdatedViewsInformation,
	LoadedTablesInformation,
	WorkingDirectory,
	VersionInformation,
}

View Source

var ShowObjectList = []string{
	ShowTables,
	ShowViews,
	ShowCursors,
	ShowFunctions,
	ShowStatements,
	ShowFlags,
	ShowEnv,
	ShowRuninfo,
}

View Source

var Version = "v1.9.6"

Functions ¶

func Abs ¶

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

func Acos ¶

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

func AddDay ¶

func AddDay(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddFlagElement ¶ added in v1.6.5

func AddFlagElement(ctx context.Context, filter *Filter, expr parser.AddFlagElement) error

func AddHour ¶

func AddHour(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddMicro ¶

func AddMicro(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddMilli ¶

func AddMilli(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddMinute ¶

func AddMinute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddMonth ¶

func AddMonth(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddNano ¶

func AddNano(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddSecond ¶

func AddSecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func AddYear ¶

func AddYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func All ¶

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

func Analyze ¶ added in v0.5.6

func Analyze(ctx context.Context, view *View, fn parser.AnalyticFunction, partitionIndices []int) error

func Any ¶

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

func AppendCompositeError ¶ added in v1.9.3

func AppendCompositeError(e1 error, e2 error) error

func Asin ¶

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

func Atan ¶

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

func Atan2 ¶

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

func Avg ¶

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

func Base64Decode ¶

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

func Base64Encode ¶

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

func Bin ¶

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

func BinToDec ¶

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

func Boolean ¶

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

func ByteLen ¶

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

func CalcMinimumRequired ¶ added in v1.7.3

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

func Calculate ¶

func Calculate(p1 value.Primary, p2 value.Primary, operator int) value.Primary

func Call ¶ added in v0.1.8

func Call(ctx context.Context, fn parser.Function, args []value.Primary) (value.Primary, error)

func Ceil ¶

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

func Chdir ¶ added in v1.6.2

func Chdir(ctx context.Context, filter *Filter, expr parser.Chdir) error

func CheckArgsLen ¶ added in v0.5.6

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

func Coalesce ¶

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

func ContextForPreparedStatement ¶ added in v1.9.4

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

func ContextForStoringResults ¶ added in v1.9.3

func ContextForStoringResults(ctx context.Context) context.Context

func ConvertFieldContents ¶ added in v1.6.0

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

func ConvertFileHandlerError ¶ added in v1.9.3

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

func Cos ¶

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

func Count ¶

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

func CreateFilePath ¶ added in v1.5.0

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

func CrossJoin ¶

func CrossJoin(ctx context.Context, filter *Filter, view *View, joinView *View) error

func DateDiff ¶

func DateDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Datetime ¶

func Datetime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func DatetimeFormat ¶

func DatetimeFormat(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Day ¶

func Day(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func DayOfYear ¶

func DayOfYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func DeclareView ¶ added in v0.8.6

func DeclareView(ctx context.Context, filter *Filter, expr parser.ViewDeclaration) error

func Distinguish ¶ added in v0.4.10

func Distinguish(list []value.Primary, flags *cmd.Flags) []value.Primary

func Echo ¶ added in v1.6.2

func Echo(ctx context.Context, filter *Filter, expr parser.Echo) (string, error)

func EncodeView ¶ added in v0.1.6

func EncodeView(fp io.Writer, view *View, fileInfo *FileInfo, flags *cmd.Flags) (string, error)

func Enotation ¶ added in v0.5.12

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

func EnotationToDec ¶ added in v0.5.12

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

func Exp ¶

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

func Exp2 ¶

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

func Expm1 ¶

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

func FetchCursor ¶ added in v0.1.8

func FetchCursor(ctx context.Context, filter *Filter, name parser.Identifier, fetchPosition parser.FetchPosition, vars []parser.Variable) (bool, error)

func Float ¶

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

func Floor ¶

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

func Format ¶ added in v0.5.0

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

func FormatCount ¶ added in v0.4.3

func FormatCount(i int, obj string) string

func GetRuntimeInformation ¶ added in v1.6.2

func GetRuntimeInformation(tx *Transaction, expr parser.RuntimeInformation) (value.Primary, error)

func Hex ¶

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

func HexDecode ¶

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

func HexEncode ¶

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

func HexToDec ¶

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

func HistoryFilePath ¶ added in v1.6.2

func HistoryFilePath(filename string) (string, error)

func Hour ¶

func Hour(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func If ¶

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

func Ifnull ¶

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

func InIntSlice ¶ added in v0.1.6

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

func InRowValueList ¶ added in v0.2.2

func InRowValueList(rowValue value.RowValue, list []value.RowValue, matchType int, operator string, datetimeFormats []string) (ternary.Value, error)

func InStrSliceWithCaseInsensitive ¶ added in v0.4.3

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

func InnerJoin ¶

func InnerJoin(ctx context.Context, parentFilter *Filter, view *View, joinView *View, condition parser.QueryExpression) error

func Instr ¶ added in v1.1.1

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

func Integer ¶

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

func Is ¶

func Is(p1 value.Primary, p2 value.Primary) ternary.Value

func JsonAgg ¶ added in v1.3.0

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

func JsonObject ¶ added in v1.3.0

func JsonObject(ctx context.Context, filter *Filter, fn parser.Function) (value.Primary, error)

func JsonValue ¶ added in v1.3.0

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

func Len ¶

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

func Like ¶

func Like(p1 value.Primary, p2 value.Primary) ternary.Value

func ListAgg ¶ added in v0.4.9

func ListAgg(list []value.Primary, separator string) value.Primary

func ListElem ¶ added in v1.1.1

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

func LoadStatementsFromFile ¶ added in v1.6.0

func LoadStatementsFromFile(ctx context.Context, tx *Transaction, expr parser.Source, fpath string) (statements []parser.Statement, err error)

func Log10 ¶

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

func Log1p ¶

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

func Log2 ¶

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

func Lower ¶

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

func Lpad ¶

func Lpad(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Ltrim ¶

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

func MathLog ¶ added in v0.7.1

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

func Max ¶

func Max(list []value.Primary, flags *cmd.Flags) value.Primary

func Md5 ¶

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

func Md5Hmac ¶

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

func Median ¶ added in v0.5.5

func Median(list []value.Primary, flags *cmd.Flags) value.Primary

func Microsecond ¶

func Microsecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Millisecond ¶

func Millisecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Min ¶

func Min(list []value.Primary, flags *cmd.Flags) value.Primary

func Minute ¶

func Minute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Month ¶

func Month(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Nanosecond ¶

func Nanosecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func NewAddFlagNotSupportedNameError ¶ added in v1.6.5

func NewAddFlagNotSupportedNameError(expr parser.AddFlagElement) error

func NewBuiltInFunctionDeclaredError ¶ added in v0.4.3

func NewBuiltInFunctionDeclaredError(expr parser.Identifier) error

func NewCombinedSetFieldLengthError ¶ added in v0.4.3

func NewCombinedSetFieldLengthError(selectEntity parser.QueryExpression, fieldLen int) error

func NewCommitError ¶ added in v1.6.0

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

func NewContextIsDone ¶ added in v1.9.3

func NewContextIsDone(message string) error

func NewCursorClosedError ¶ added in v0.4.3

func NewCursorClosedError(cursor parser.Identifier) error

func NewCursorFetchLengthError ¶ added in v0.4.3

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

func NewCursorOpenError ¶ added in v0.4.3

func NewCursorOpenError(cursor parser.Identifier) error

func NewCursorRedeclaredError ¶ added in v0.4.3

func NewCursorRedeclaredError(cursor parser.Identifier) error

func NewDataParsingError ¶ added in v1.5.0

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

func NewDeleteTableNotSpecifiedError ¶ added in v0.4.3

func NewDeleteTableNotSpecifiedError(query parser.DeleteQuery) error

func NewDuplicateFieldNameError ¶ added in v0.4.3

func NewDuplicateFieldNameError(fieldName parser.Identifier) error

func NewDuplicateParameterError ¶ added in v0.5.0

func NewDuplicateParameterError(expr parser.Variable) error

func NewDuplicateStatementNameError ¶ added in v1.9.4

func NewDuplicateStatementNameError(name parser.Identifier) error

func NewDuplicateTableNameError ¶ added in v0.4.3

func NewDuplicateTableNameError(table parser.Identifier) error

func NewEmptyJsonQueryError ¶ added in v1.9.4

func NewEmptyJsonQueryError(expr parser.JsonQuery) error

func NewEmptyJsonTableError ¶ added in v1.9.4

func NewEmptyJsonTableError(expr parser.JsonQuery) error

func NewExternalCommandError ¶ added in v1.6.2

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

func NewFieldAmbiguousError ¶ added in v0.4.0

func NewFieldAmbiguousError(field parser.QueryExpression) error

func NewFieldLengthNotMatchError ¶ added in v0.4.3

func NewFieldLengthNotMatchError() error

func NewFieldNotExistError ¶ added in v0.4.0

func NewFieldNotExistError(field parser.QueryExpression) error

func NewFieldNotGroupKeyError ¶ added in v0.4.3

func NewFieldNotGroupKeyError(field parser.QueryExpression) error

func NewFileAlreadyExistError ¶ added in v0.5.3

func NewFileAlreadyExistError(file parser.Identifier) error

func NewFileLockTimeoutError ¶ added in v0.7.10

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

func NewFileNameAmbiguousError ¶ added in v1.5.0

func NewFileNameAmbiguousError(file parser.Identifier) error

func NewFileNotExistError ¶ added in v0.4.3

func NewFileNotExistError(file parser.QueryExpression) error

func NewFileUnableToReadError ¶ added in v0.4.3

func NewFileUnableToReadError(file parser.Identifier) error

func NewFlagValueNotAllowedFormatError ¶ added in v1.5.0

func NewFlagValueNotAllowedFormatError(setFlag parser.SetFlag) error

func NewForcedExit ¶ added in v1.2.0

func NewForcedExit(code int) error

func NewFormatStringLengthNotMatchError ¶ added in v0.5.0

func NewFormatStringLengthNotMatchError() error

func NewFormatUnexpectedTerminationError ¶ added in v1.5.3

func NewFormatUnexpectedTerminationError() error

func NewFunctionArgumentLengthError ¶ added in v0.4.3

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

func NewFunctionArgumentLengthErrorWithCustomArgs ¶ added in v0.4.3

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

func NewFunctionInvalidArgumentError ¶ added in v0.4.3

func NewFunctionInvalidArgumentError(function parser.QueryExpression, funcname string, message string) error

func NewFunctionNotExistError ¶ added in v0.4.3

func NewFunctionNotExistError(expr parser.QueryExpression, funcname string) error

func NewFunctionRedeclaredError ¶ added in v0.4.3

func NewFunctionRedeclaredError(expr parser.Identifier) error

func NewInLineTableRedefinedError ¶ added in v0.8.7

func NewInLineTableRedefinedError(table parser.Identifier) error

func NewInlineTableFieldLengthError ¶ added in v0.4.3

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

func NewInsertRowValueLengthError ¶ added in v0.4.3

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

func NewInsertSelectFieldLengthError ¶ added in v0.4.3

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

func NewInternalRecordIdEmptyError ¶ added in v0.4.3

func NewInternalRecordIdEmptyError() error

func NewInternalRecordIdNotExistError ¶ added in v0.4.3

func NewInternalRecordIdNotExistError() error

func NewInvalidCursorStatementError ¶ added in v1.9.6

func NewInvalidCursorStatementError(statement parser.Identifier) error

func NewInvalidEventNameError ¶ added in v1.5.0

func NewInvalidEventNameError(expr parser.Identifier) error

func NewInvalidFetchPositionError ¶ added in v0.4.3

func NewInvalidFetchPositionError(position parser.FetchPosition) error

func NewInvalidFlagNameError ¶ added in v0.4.3

func NewInvalidFlagNameError(expr parser.Expression, name string) error

func NewInvalidFlagValueError ¶ added in v0.4.3

func NewInvalidFlagValueError(expr parser.SetFlag, message string) error

func NewInvalidFlagValueToBeRemovedError ¶ added in v1.6.5

func NewInvalidFlagValueToBeRemovedError(unsetFlag parser.RemoveFlagElement) error

func NewInvalidLimitNumberError ¶ added in v0.4.3

func NewInvalidLimitNumberError(clause parser.LimitClause) error

func NewInvalidLimitPercentageError ¶ added in v0.4.3

func NewInvalidLimitPercentageError(clause parser.LimitClause) error

func NewInvalidOffsetNumberError ¶ added in v0.4.3

func NewInvalidOffsetNumberError(clause parser.OffsetClause) error

func NewInvalidPathError ¶ added in v1.9.4

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

func NewInvalidReloadTypeError ¶ added in v1.6.2

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

func NewInvalidRuntimeInformationError ¶ added in v1.6.2

func NewInvalidRuntimeInformationError(expr parser.RuntimeInformation) error

func NewInvalidTableAttributeNameError ¶ added in v1.5.0

func NewInvalidTableAttributeNameError(expr parser.Identifier) error

func NewInvalidTableAttributeValueError ¶ added in v1.5.0

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

func NewInvalidTableObjectError ¶ added in v1.9.4

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

func NewInvalidValueExpressionError ¶ added in v1.9.4

func NewInvalidValueExpressionError(expr parser.QueryExpression) error

func NewJsonQueryTooManyRecordsError ¶ added in v1.3.0

func NewJsonQueryTooManyRecordsError(expr parser.JsonQuery) error

func NewLoadConfigurationError ¶ added in v1.6.2

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

func NewLoadJsonError ¶ added in v1.9.4

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

func NewNestedAggregateFunctionsError ¶ added in v0.4.3

func NewNestedAggregateFunctionsError(expr parser.QueryExpression) error

func NewNotGroupingRecordsError ¶ added in v0.4.3

func NewNotGroupingRecordsError(expr parser.QueryExpression, funcname string) error

func NewNotTableError ¶ added in v1.5.0

func NewNotTableError(expr parser.QueryExpression) error

func NewPreparedStatementSyntaxError ¶ added in v1.9.4

func NewPreparedStatementSyntaxError(err *parser.SyntaxError) error

func NewPromptEvaluationError ¶ added in v1.6.2

func NewPromptEvaluationError(message string) error

func NewPseudoCursorError ¶ added in v0.4.10

func NewPseudoCursorError(cursor parser.Identifier) error

func NewReadFileError ¶ added in v0.4.9

func NewReadFileError(expr parser.Expression, message string) error

func NewRemoveFlagNotSupportedNameError ¶ added in v1.6.5

func NewRemoveFlagNotSupportedNameError(expr parser.RemoveFlagElement) error

func NewReplaceValueLengthError ¶ added in v1.5.3

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

func NewRollbackError ¶ added in v1.6.0

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

func NewRowValueLengthInComparisonError ¶ added in v0.4.3

func NewRowValueLengthInComparisonError(expr parser.QueryExpression, valueLen int) error

func NewRowValueLengthInListError ¶ added in v0.4.3

func NewRowValueLengthInListError(i int) error

func NewSelectFieldLengthInComparisonError ¶ added in v0.4.3

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

func NewShowInvalidObjectTypeError ¶ added in v1.5.0

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

func NewSourceInvalidFilePathError ¶ added in v1.5.3

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

func NewStatementNotExistError ¶ added in v1.9.4

func NewStatementNotExistError(name parser.Identifier) error

func NewStatementReplaceValueNotSpecifiedError ¶ added in v1.9.4

func NewStatementReplaceValueNotSpecifiedError(placeholder parser.Placeholder) error

func NewStdinEmptyError ¶ added in v0.4.3

func NewStdinEmptyError(stdin parser.Stdin) error

func NewSubqueryTooManyFieldsError ¶ added in v0.4.3

func NewSubqueryTooManyFieldsError(expr parser.Subquery) error

func NewSubqueryTooManyRecordsError ¶ added in v0.4.3

func NewSubqueryTooManyRecordsError(expr parser.Subquery) error

func NewSyntaxError ¶ added in v0.4.3

func NewSyntaxError(err *parser.SyntaxError) error

func NewSystemError ¶ added in v1.9.3

func NewSystemError(message string) error

func NewTableAttributeUnchangedError ¶ added in v1.6.2

func NewTableAttributeUnchangedError(fpath string) error

func NewTableAttributeValueNotAllowedFormatError ¶ added in v1.5.0

func NewTableAttributeValueNotAllowedFormatError(expr parser.SetTableAttribute) error

func NewTableFieldLengthError ¶ added in v0.6.7

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

func NewTableNotLoadedError ¶ added in v0.4.3

func NewTableNotLoadedError(table parser.Identifier) error

func NewTableObjectArgumentsLengthError ¶ added in v1.5.0

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

func NewTableObjectInvalidArgumentError ¶ added in v1.5.0

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

func NewTableObjectInvalidDelimiterError ¶ added in v1.5.0

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

func NewTableObjectInvalidDelimiterPositionsError ¶ added in v1.5.0

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

func NewTableObjectInvalidJsonQueryError ¶ added in v1.5.0

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

func NewTableObjectJsonArgumentsLengthError ¶ added in v1.5.0

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

func NewTemporaryTableFieldLengthError ¶ added in v0.4.3

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

func NewTemporaryTableRedeclaredError ¶ added in v0.4.3

func NewTemporaryTableRedeclaredError(table parser.Identifier) error

func NewTransactionOpenError ¶ added in v1.9.4

func NewTransactionOpenError(message string) error

func NewUndeclaredCursorError ¶ added in v0.8.7

func NewUndeclaredCursorError(cursor parser.Identifier) error

func NewUndeclaredTemporaryTableError ¶ added in v0.8.7

func NewUndeclaredTemporaryTableError(table parser.Identifier) error

func NewUndeclaredVariableError ¶ added in v0.8.7

func NewUndeclaredVariableError(expr parser.Variable) error

func NewUndefinedInLineTableError ¶ added in v0.4.3

func NewUndefinedInLineTableError(table parser.Identifier) error

func NewUnknownFormatPlaceholderError ¶ added in v1.5.3

func NewUnknownFormatPlaceholderError(placeholder rune) error

func NewUnpermittedFunctionStatementError ¶ added in v1.9.4

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

func NewUpdateFieldNotExistError ¶ added in v0.4.3

func NewUpdateFieldNotExistError(field parser.QueryExpression) error

func NewUpdateValueAmbiguousError ¶ added in v0.4.3

func NewUpdateValueAmbiguousError(field parser.QueryExpression, value parser.QueryExpression) error

func NewUserTriggeredError ¶ added in v0.5.0

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

func NewVariableRedeclaredError ¶ added in v0.4.3

func NewVariableRedeclaredError(expr parser.Variable) error

func NewWriteFileError ¶ added in v0.4.9

func NewWriteFileError(expr parser.Expression, message string) error

func Now ¶

func Now(filter *Filter, fn parser.Function, args []value.Primary) (value.Primary, error)

func Nullif ¶

func Nullif(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func NumberFormat ¶ added in v1.5.3

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

func Oct ¶

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

func OctToDec ¶

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

func OuterJoin ¶

func OuterJoin(ctx context.Context, parentFilter *Filter, view *View, joinView *View, condition parser.QueryExpression, direction int) error

func ParseExecuteStatements ¶ added in v1.5.3

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

func ParseJoinCondition ¶

func ParseJoinCondition(join parser.Join, view *View, joinView *View) (parser.QueryExpression, []parser.FieldReference, []parser.FieldReference, error)

func Pow ¶

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

func Print ¶ added in v0.1.6

func Print(ctx context.Context, filter *Filter, expr parser.Print) (string, error)

func Printf ¶ added in v0.4.0

func Printf(ctx context.Context, filter *Filter, expr parser.Printf) (string, error)

func Pwd ¶ added in v1.6.2

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

func Rand ¶

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

func Reload ¶ added in v1.6.2

func Reload(ctx context.Context, tx *Transaction, expr parser.Reload) error

func RemoveFlagElement ¶ added in v1.6.5

func RemoveFlagElement(ctx context.Context, filter *Filter, expr parser.RemoveFlagElement) error

func Replace ¶

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

func Round ¶

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

func Rpad ¶

func Rpad(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Rtrim ¶

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

func SearchCSVFilePath ¶ added in v1.5.0

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

func SearchFilePath ¶ added in v1.5.0

func SearchFilePath(filename parser.Identifier, repository string, format cmd.Format, flags *cmd.Flags) (string, cmd.Format, error)

func SearchFilePathFromAllTypes ¶ added in v1.5.0

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

func SearchFilePathWithExtType ¶ added in v1.5.0

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

func SearchFixedLengthFilePath ¶ added in v1.5.0

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

func SearchJsonFilePath ¶ added in v1.5.0

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

func SearchLTSVFilePath ¶ added in v1.8.0

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

func Second ¶

func Second(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func SerializeComparisonKeys ¶ added in v0.6.4

func SerializeComparisonKeys(buf *bytes.Buffer, values []value.Primary, flags *cmd.Flags)

func SerializeKey ¶ added in v0.6.6

func SerializeKey(buf *bytes.Buffer, val value.Primary, flags *cmd.Flags)

func SetEnvVar ¶ added in v1.6.0

func SetEnvVar(ctx context.Context, filter *Filter, expr parser.SetEnvVar) error

func SetFlag ¶ added in v0.1.6

func SetFlag(ctx context.Context, filter *Filter, expr parser.SetFlag) error

func Sha1 ¶

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

func Sha1Hmac ¶

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

func Sha256 ¶

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

func Sha256Hmac ¶

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

func Sha512 ¶

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

func Sha512Hmac ¶

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

func ShowFields ¶ added in v0.8.6

func ShowFields(ctx context.Context, filter *Filter, expr parser.ShowFields) (string, error)

func ShowFlag ¶ added in v0.8.0

func ShowFlag(flags *cmd.Flags, expr parser.ShowFlag) (string, error)

func ShowObjects ¶ added in v0.8.6

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

func Sin ¶

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

func Source ¶ added in v0.4.0

func Source(ctx context.Context, filter *Filter, expr parser.Source) ([]parser.Statement, error)

func Sqrt ¶

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

func String ¶

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

func Substr ¶

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

func Sum ¶

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

func Syntax ¶ added in v1.7.2

func Syntax(ctx context.Context, filter *Filter, expr parser.Syntax) string

func Tan ¶

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

func Ternary ¶

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

func TimeDiff ¶

func TimeDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TimeNanoDiff ¶ added in v0.7.0

func TimeNanoDiff(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Trim ¶

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

func TruncDay ¶ added in v0.7.0

func TruncDay(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncMicro ¶ added in v0.7.0

func TruncMicro(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncMilli ¶ added in v0.7.0

func TruncMilli(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncMinute ¶ added in v0.7.0

func TruncMinute(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncMonth ¶ added in v0.7.0

func TruncMonth(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncNano ¶ added in v0.7.0

func TruncNano(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncSecond ¶ added in v0.7.0

func TruncSecond(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func TruncTime ¶ added in v0.7.0

func TruncTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func UTC ¶ added in v0.7.0

func UTC(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func UnixNanoTime ¶

func UnixNanoTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func UnixTime ¶

func UnixTime(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func UnsetEnvVar ¶ added in v1.6.0

func UnsetEnvVar(expr parser.UnsetEnvVar) error

func Upper ¶

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

func WeekOfYear ¶

func WeekOfYear(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Weekday ¶

func Weekday(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Width ¶ added in v1.5.0

func Width(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

func Year ¶

func Year(fn parser.Function, args []value.Primary, flags *cmd.Flags) (value.Primary, error)

Types ¶

type AddFlagNotSupportedNameError ¶ added in v1.6.5

type AddFlagNotSupportedNameError struct {
	*BaseError
}

type AggregateFunction ¶ added in v0.5.6

type AggregateFunction func([]value.Primary, *cmd.Flags) value.Primary

type AliasMap ¶ added in v0.4.3

type AliasMap map[string]string

func (AliasMap) Add ¶ added in v0.4.3

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

func (AliasMap) Get ¶ added in v0.4.3

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

type AliasNodes ¶ added in v0.7.9

type AliasNodes []AliasMap

func (AliasNodes) Add ¶ added in v0.7.9

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

func (AliasNodes) Get ¶ added in v0.7.9

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

type AnalyticFunction ¶ added in v0.5.6

type AnalyticFunction interface {
	CheckArgsLen(expr parser.AnalyticFunction) error
	Execute(context.Context, *Filter, Partition, parser.AnalyticFunction) (map[int]value.Primary, error)
}

type AnalyticJsonAgg ¶ added in v1.3.0

type AnalyticJsonAgg struct{}

func (AnalyticJsonAgg) CheckArgsLen ¶ added in v1.3.0

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

func (AnalyticJsonAgg) Execute ¶ added in v1.3.0

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

type AnalyticListAgg ¶ added in v0.5.6

type AnalyticListAgg struct{}

func (AnalyticListAgg) CheckArgsLen ¶ added in v0.5.6

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

func (AnalyticListAgg) Execute ¶ added in v0.5.6

func (fn AnalyticListAgg) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type BaseError ¶ added in v0.4.3

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

func NewBaseError ¶ added in v0.4.3

func NewBaseError(expr parser.Expression, message string, code int, number int) *BaseError

func NewBaseErrorWithCode ¶ added in v0.5.0

func NewBaseErrorWithCode(expr parser.Expression, message string, code int, number int) *BaseError

func NewBaseErrorWithPrefix ¶ added in v1.6.0

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

func (*BaseError) AppendCompositeError ¶ added in v1.9.3

func (e *BaseError) AppendCompositeError(err Error)

func (*BaseError) Error ¶ added in v0.4.3

func (e *BaseError) Error() string

func (*BaseError) ErrorMessage ¶ added in v0.4.3

func (e *BaseError) ErrorMessage() string

func (*BaseError) Number ¶ added in v1.9.4

func (e *BaseError) Number() int

func (*BaseError) ReturnCode ¶ added in v1.9.4

func (e *BaseError) ReturnCode() int

type BuiltInFunctionDeclaredError ¶ added in v0.4.3

type BuiltInFunctionDeclaredError struct {
	*BaseError
}

type Cell ¶

type Cell []value.Primary

func NewCell ¶

func NewCell(val value.Primary) Cell

func NewGroupCell ¶

func NewGroupCell(values []value.Primary) Cell

func (Cell) GroupedValue ¶ added in v0.7.9

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

func (Cell) Len ¶

func (cell Cell) Len() int

func (Cell) Value ¶ added in v0.7.9

func (cell Cell) Value() value.Primary

type CombinedSetFieldLengthError ¶ added in v0.4.3

type CombinedSetFieldLengthError struct {
	*BaseError
}

type CommitError ¶ added in v1.6.0

type CommitError struct {
	*BaseError
}

type Completer ¶ added in v1.7.0

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

func NewCompleter ¶ added in v1.7.0

func NewCompleter(filter *Filter) *Completer

func (*Completer) AddFlagArgs ¶ added in v1.7.0

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

func (*Completer) AllColumnList ¶ added in v1.7.0

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

func (*Completer) AlterArgs ¶ added in v1.7.0

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

func (*Completer) BracketIsEnclosed ¶ added in v1.7.0

func (c *Completer) BracketIsEnclosed() bool

func (*Completer) CaseExpression ¶ added in v1.7.0

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

func (*Completer) ColumnList ¶ added in v1.7.0

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

func (*Completer) CreateArgs ¶ added in v1.7.0

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

func (*Completer) CursorStatus ¶ added in v1.7.0

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

func (*Completer) DeclareArgs ¶ added in v1.7.0

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

func (*Completer) DeleteArgs ¶ added in v1.7.0

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

func (*Completer) DisposeArgs ¶ added in v1.7.0

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

func (*Completer) Do ¶ added in v1.7.0

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

func (*Completer) EncloseQuotation ¶ added in v1.7.0

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

func (*Completer) FetchArgs ¶ added in v1.7.0

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

func (*Completer) FunctionArgs ¶ added in v1.8.1

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

func (*Completer) GetStatementPrefix ¶ added in v1.7.0

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

func (*Completer) InsertArgs ¶ added in v1.7.0

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

func (*Completer) ListFiles ¶ added in v1.7.0

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

func (*Completer) PrepareArgs ¶ added in v1.9.4

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

func (*Completer) RemoveFlagArgs ¶ added in v1.7.0

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

func (*Completer) SearchAllTables ¶ added in v1.7.0

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

func (*Completer) SearchAllTablesWithSpace ¶ added in v1.7.0

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

func (*Completer) SearchDirs ¶ added in v1.7.0

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

func (*Completer) SearchExecutableFiles ¶ added in v1.7.0

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

func (*Completer) SearchValues ¶ added in v1.7.0

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

func (*Completer) SearchValuesWithSpace ¶ added in v1.7.0

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

func (*Completer) SelectArgs ¶ added in v1.7.0

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

func (*Completer) SetArgs ¶ added in v1.7.0

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

func (*Completer) SetLastIndex ¶ added in v1.7.0

func (c *Completer) SetLastIndex(line string)

func (*Completer) ShowArgs ¶ added in v1.7.0

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

func (*Completer) Statements ¶ added in v1.7.0

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

func (*Completer) TableObjectArgs ¶ added in v1.7.0

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

func (*Completer) Update ¶ added in v1.7.0

func (c *Completer) Update()

func (*Completer) UpdateArgs ¶ added in v1.7.0

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

func (*Completer) UpdateTokens ¶ added in v1.7.0

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

func (*Completer) UsingArgs ¶ added in v1.7.0

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

func (*Completer) WithArgs ¶ added in v1.7.0

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

type ContainsSubstitusion ¶ added in v1.6.6

type ContainsSubstitusion struct{}

func (*ContainsSubstitusion) Error ¶ added in v1.6.6

func (c *ContainsSubstitusion) Error() string

type ContextIsDone ¶ added in v1.9.3

type ContextIsDone struct {
	*BaseError
}

type CumeDist ¶ added in v0.5.5

type CumeDist struct{}

func (CumeDist) CheckArgsLen ¶ added in v0.5.6

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

func (CumeDist) Execute ¶ added in v0.5.6

func (fn CumeDist) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type Cursor ¶ added in v0.1.8

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

func NewCursor ¶ added in v0.1.8

func NewCursor(e parser.CursorDeclaration) *Cursor

func NewPseudoCursor ¶ added in v0.4.10

func NewPseudoCursor(tx *Transaction, values []value.Primary) *Cursor

func (*Cursor) Close ¶ added in v0.1.8

func (c *Cursor) Close(name parser.Identifier) error

func (*Cursor) Count ¶ added in v1.5.0

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

func (*Cursor) Fetch ¶ added in v0.1.8

func (c *Cursor) Fetch(name parser.Identifier, position int, number int) ([]value.Primary, error)

func (*Cursor) IsInRange ¶ added in v1.5.0

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

func (*Cursor) IsOpen ¶ added in v1.5.0

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

func (*Cursor) Open ¶ added in v0.1.8

func (c *Cursor) Open(ctx context.Context, filter *Filter, name parser.Identifier, values []parser.ReplaceValue) error

func (*Cursor) Pointer ¶ added in v1.5.0

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

type CursorClosedError ¶ added in v0.4.3

type CursorClosedError struct {
	*BaseError
}

type CursorFetchLengthError ¶ added in v0.4.3

type CursorFetchLengthError struct {
	*BaseError
}

type CursorMap ¶ added in v0.1.8

type CursorMap map[string]*Cursor

func (CursorMap) AddPseudoCursor ¶ added in v0.4.10

func (m CursorMap) AddPseudoCursor(tx *Transaction, name parser.Identifier, values []value.Primary) error

func (CursorMap) Close ¶ added in v0.1.8

func (m CursorMap) Close(name parser.Identifier) error

func (CursorMap) Count ¶ added in v0.4.10

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

func (CursorMap) Declare ¶ added in v0.4.3

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

func (CursorMap) Dispose ¶ added in v0.1.8

func (m CursorMap) Dispose(name parser.Identifier) error

func (CursorMap) Fetch ¶ added in v0.1.8

func (m CursorMap) Fetch(name parser.Identifier, position int, number int) ([]value.Primary, error)

func (CursorMap) IsInRange ¶ added in v0.2.5

func (m CursorMap) IsInRange(name parser.Identifier) (ternary.Value, error)

func (CursorMap) IsOpen ¶ added in v0.2.5

func (m CursorMap) IsOpen(name parser.Identifier) (ternary.Value, error)

func (CursorMap) Keys ¶ added in v1.5.0

func (m CursorMap) Keys() []string

func (CursorMap) Open ¶ added in v0.1.8

func (m CursorMap) Open(ctx context.Context, filter *Filter, name parser.Identifier, values []parser.ReplaceValue) error

func (CursorMap) SortedKeys ¶ added in v1.5.0

func (m CursorMap) SortedKeys() []string

type CursorOpenError ¶ added in v0.4.3

type CursorOpenError struct {
	*BaseError
}

type CursorRedeclaredError ¶ added in v0.4.3

type CursorRedeclaredError struct {
	*BaseError
}

type CursorScopes ¶ added in v0.7.9

type CursorScopes []CursorMap

func (CursorScopes) AddPseudoCursor ¶ added in v0.7.9

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

func (CursorScopes) All ¶ added in v1.5.0

func (list CursorScopes) All() CursorMap

func (CursorScopes) Close ¶ added in v0.7.9

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

func (CursorScopes) Count ¶ added in v0.7.9

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

func (CursorScopes) Declare ¶ added in v0.7.9

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

func (CursorScopes) Dispose ¶ added in v0.7.9

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

func (CursorScopes) Fetch ¶ added in v0.7.9

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

func (CursorScopes) IsInRange ¶ added in v0.7.9

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

func (CursorScopes) IsOpen ¶ added in v0.7.9

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

func (CursorScopes) Open ¶ added in v0.7.9

func (list CursorScopes) Open(ctx context.Context, filter *Filter, name parser.Identifier, values []parser.ReplaceValue) error

type DataParsingError ¶ added in v1.5.0

type DataParsingError struct {
	*BaseError
}

type DeleteTableNotSpecifiedError ¶ added in v0.4.3

type DeleteTableNotSpecifiedError struct {
	*BaseError
}

type DenseRank ¶ added in v0.2.3

type DenseRank struct{}

func (DenseRank) CheckArgsLen ¶ added in v0.5.6

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

func (DenseRank) Execute ¶ added in v0.5.6

func (fn DenseRank) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type Direction ¶ added in v1.5.0

type Direction string

const (
	RightDirection Direction = "R"
	LeftDirection            = "L"
)

type Discard ¶ added in v1.9.3

type Discard struct {
}

func NewDiscard ¶ added in v1.9.3

func NewDiscard() *Discard

func (Discard) Close ¶ added in v1.9.3

func (d Discard) Close() error

func (Discard) Write ¶ added in v1.9.3

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

type DuplicateFieldNameError ¶ added in v0.4.3

type DuplicateFieldNameError struct {
	*BaseError
}

type DuplicateParameterError ¶ added in v0.5.0

type DuplicateParameterError struct {
	*BaseError
}

type DuplicateStatementNameError ¶ added in v1.9.4

type DuplicateStatementNameError struct {
	*BaseError
}

type DuplicateTableNameError ¶ added in v0.4.3

type DuplicateTableNameError struct {
	*BaseError
}

type EmptyJsonQueryError ¶ added in v1.9.4

type EmptyJsonQueryError struct {
	*BaseError
}

type EmptyJsonTableError ¶ added in v1.9.4

type EmptyJsonTableError struct {
	*BaseError
}

type EmptyResultSetError ¶ added in v1.6.7

type EmptyResultSetError struct{}

func NewEmptyResultSetError ¶ added in v1.6.7

func NewEmptyResultSetError() *EmptyResultSetError

func (EmptyResultSetError) Error ¶ added in v1.6.7

func (e EmptyResultSetError) Error() string

type Error ¶ added in v1.2.0

type Error interface {
	Error() string
	ErrorMessage() string
	ReturnCode() int
	Number() int
	AppendCompositeError(Error)
}

type ExternalCommandError ¶ added in v1.6.2

type ExternalCommandError struct {
	*BaseError
}

type FieldAmbiguousError ¶ added in v0.4.0

type FieldAmbiguousError struct {
	*BaseError
}

type FieldLengthNotMatchError ¶ added in v0.4.3

type FieldLengthNotMatchError struct {
	*BaseError
}

type FieldNotExistError ¶ added in v0.4.0

type FieldNotExistError struct {
	*BaseError
}

type FieldNotGroupKeyError ¶ added in v0.4.3

type FieldNotGroupKeyError struct {
	*BaseError
}

type FileAlreadyExistError ¶ added in v0.5.3

type FileAlreadyExistError struct {
	*BaseError
}

type FileInfo ¶

type FileInfo struct {
	Path string

	Format             cmd.Format
	Delimiter          rune
	DelimiterPositions fixedlen.DelimiterPositions
	JsonQuery          string
	Encoding           text.Encoding
	LineBreak          text.LineBreak
	NoHeader           bool
	EncloseAll         bool
	JsonEscape         json.EscapeType
	PrettyPrint        bool

	SingleLine bool

	Handler *file.Handler

	ForUpdate        bool
	IsTemporary      bool
	InitialHeader    Header
	InitialRecordSet RecordSet
}

func AddColumns ¶ added in v0.1.6

func AddColumns(ctx context.Context, parentFilter *Filter, query parser.AddColumns) (*FileInfo, int, error)

func CreateTable ¶ added in v0.1.6

func CreateTable(ctx context.Context, parentFilter *Filter, query parser.CreateTable) (*FileInfo, error)

func Delete ¶ added in v0.1.6

func Delete(ctx context.Context, parentFilter *Filter, query parser.DeleteQuery) ([]*FileInfo, []int, error)

func DropColumns ¶ added in v0.1.6

func DropColumns(ctx context.Context, parentFilter *Filter, query parser.DropColumns) (*FileInfo, int, error)

func Insert ¶ added in v0.1.6

func Insert(ctx context.Context, parentFilter *Filter, query parser.InsertQuery) (*FileInfo, int, error)

func NewFileInfo ¶

func NewFileInfo(
	filename parser.Identifier,
	repository string,
	format cmd.Format,
	delimiter rune,
	encoding text.Encoding,
	flags *cmd.Flags,
) (*FileInfo, error)

func NewFileInfoForCreate ¶ added in v0.5.3

func NewFileInfoForCreate(filename parser.Identifier, repository string, delimiter rune, encoding text.Encoding) (*FileInfo, error)

func RenameColumn ¶ added in v0.1.6

func RenameColumn(ctx context.Context, parentFilter *Filter, query parser.RenameColumn) (*FileInfo, error)

func SetTableAttribute ¶ added in v1.5.0

func SetTableAttribute(ctx context.Context, parentFilter *Filter, query parser.SetTableAttribute) (*FileInfo, string, error)

func Update ¶ added in v0.1.6

func Update(ctx context.Context, parentFilter *Filter, query parser.UpdateQuery) ([]*FileInfo, []int, error)

func (*FileInfo) SetDelimiter ¶ added in v1.5.0

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

func (*FileInfo) SetDelimiterPositions ¶ added in v1.9.0

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

func (*FileInfo) SetEncloseAll ¶ added in v1.6.0

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

func (*FileInfo) SetEncoding ¶ added in v1.5.0

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

func (*FileInfo) SetFormat ¶ added in v1.5.0

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

func (*FileInfo) SetJsonEscape ¶ added in v1.6.1

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

func (*FileInfo) SetLineBreak ¶ added in v1.5.0

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

func (*FileInfo) SetNoHeader ¶ added in v1.5.0

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

func (*FileInfo) SetPrettyPrint ¶ added in v1.5.0

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

type FileLockTimeoutError ¶ added in v0.7.10

type FileLockTimeoutError struct {
	*BaseError
}

type FileNameAmbiguousError ¶ added in v1.5.0

type FileNameAmbiguousError struct {
	*BaseError
}

type FileNotExistError ¶ added in v0.4.3

type FileNotExistError struct {
	*BaseError
}

type FileUnableToReadError ¶ added in v0.4.3

type FileUnableToReadError struct {
	*BaseError
}

type Filter ¶

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

func NewFilter ¶ added in v0.4.0

func NewFilter(tx *Transaction) *Filter

func NewFilterForRecord ¶ added in v0.2.4

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

func NewFilterForSequentialEvaluation ¶ added in v0.4.4

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

func NewFilterWithScopes ¶ added in v1.9.4

func NewFilterWithScopes(tx *Transaction, variableScopes VariableScopes, tempViewScopes TemporaryViewScopes, cursorScopes CursorScopes, functionScopes UserDefinedFunctionScopes) *Filter

func (*Filter) CreateChildScope ¶ added in v0.4.9

func (f *Filter) CreateChildScope() *Filter

func (*Filter) CreateNode ¶ added in v0.4.4

func (f *Filter) CreateNode() *Filter

func (*Filter) Evaluate ¶

func (f *Filter) Evaluate(ctx context.Context, expr parser.QueryExpression) (value.Primary, error)

func (*Filter) EvaluateEmbeddedString ¶ added in v1.6.2

func (f *Filter) EvaluateEmbeddedString(ctx context.Context, embedded string) (string, error)

func (*Filter) EvaluateSequentially ¶ added in v1.6.6

func (f *Filter) EvaluateSequentially(ctx context.Context, fn func(*Filter, int) error) error

func (*Filter) LoadInlineTable ¶ added in v0.4.0

func (f *Filter) LoadInlineTable(ctx context.Context, clause parser.WithClause) error

func (*Filter) Merge ¶ added in v0.2.4

func (f *Filter) Merge(filter *Filter)

func (*Filter) ResetCurrentScope ¶ added in v1.0.0

func (f *Filter) ResetCurrentScope()

type FirstValue ¶ added in v0.4.9

type FirstValue struct{}

func (FirstValue) CheckArgsLen ¶ added in v0.5.6

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

func (FirstValue) Execute ¶ added in v0.5.6

func (fn FirstValue) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type FlagValueNotAllowedFormatError ¶ added in v1.5.0

type FlagValueNotAllowedFormatError struct {
	*BaseError
}

type ForcedExit ¶ added in v1.2.0

type ForcedExit struct {
	*BaseError
}

type FormatStringLengthNotMatchError ¶ added in v0.5.0

type FormatStringLengthNotMatchError struct {
	*BaseError
}

type FormatUnexpectedTerminationError ¶ added in v1.5.3

type FormatUnexpectedTerminationError struct {
	*BaseError
}

type FunctionArgumentLengthError ¶ added in v0.4.3

type FunctionArgumentLengthError struct {
	*BaseError
}

type FunctionInvalidArgumentError ¶ added in v0.4.3

type FunctionInvalidArgumentError struct {
	*BaseError
}

type FunctionNotExistError ¶ added in v0.4.3

type FunctionNotExistError struct {
	*BaseError
}

type FunctionRedeclaredError ¶ added in v0.4.3

type FunctionRedeclaredError struct {
	*BaseError
}

type GoroutineManager ¶ added in v0.8.7

type GoroutineManager struct {
	Count                  int
	CountMutex             *sync.Mutex
	MinimumRequiredPerCore int
}

func GetGoroutineManager ¶ added in v1.6.6

func GetGoroutineManager() *GoroutineManager

func (*GoroutineManager) AssignRoutineNumber ¶ added in v1.6.6

func (m *GoroutineManager) AssignRoutineNumber(recordLen int, minimumRequiredPerCore int, cpuNum int) int

func (*GoroutineManager) Release ¶ added in v1.6.6

func (m *GoroutineManager) Release()

type GoroutineTaskManager ¶ added in v1.6.6

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

func NewGoroutineTaskManager ¶ added in v1.6.6

func NewGoroutineTaskManager(recordLen int, minimumRequiredPerCore int, cpuNum int) *GoroutineTaskManager

func (*GoroutineTaskManager) Add ¶ added in v1.6.6

func (m *GoroutineTaskManager) Add()

func (*GoroutineTaskManager) Done ¶ added in v1.6.6

func (m *GoroutineTaskManager) Done()

func (*GoroutineTaskManager) Err ¶ added in v1.6.6

func (m *GoroutineTaskManager) Err() error

func (*GoroutineTaskManager) HasError ¶ added in v1.6.6

func (m *GoroutineTaskManager) HasError() bool

func (*GoroutineTaskManager) RecordRange ¶ added in v1.6.6

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

func (*GoroutineTaskManager) Run ¶ added in v1.6.7

func (m *GoroutineTaskManager) Run(ctx context.Context, fn func(int) error) error

func (*GoroutineTaskManager) SetError ¶ added in v1.6.6

func (m *GoroutineTaskManager) SetError(e error)

func (*GoroutineTaskManager) Wait ¶ added in v1.6.6

func (m *GoroutineTaskManager) Wait()

type Header ¶

type Header []HeaderField

func AddHeaderField ¶

func AddHeaderField(h Header, column string, alias string) (header Header, index int)

func MergeHeader ¶

func MergeHeader(h1 Header, h2 Header) Header

func NewDualHeader ¶

func NewDualHeader() Header

func NewEmptyHeader ¶

func NewEmptyHeader(len int) Header

func NewHeader ¶

func NewHeader(view string, words []string) Header

func NewHeaderWithAutofill ¶ added in v1.5.0

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

func NewHeaderWithId ¶ added in v0.5.6

func NewHeaderWithId(view string, words []string) Header

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

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

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

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

func (h Header) Copy() Header

func (h Header) Len() int

func (h Header) TableColumnNames() []string

func (h Header) TableColumns() []parser.QueryExpression

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

type HeaderField ¶

type HeaderField struct {
	View         string
	Column       string
	Aliases      []string
	Number       int
	IsFromTable  bool
	IsJoinColumn bool
	IsGroupKey   bool
}

type InLineTableRedefinedError ¶ added in v0.8.7

type InLineTableRedefinedError struct {
	*BaseError
}

type InlineTableFieldLengthError ¶ added in v0.4.3

type InlineTableFieldLengthError struct {
	*BaseError
}

type InlineTableMap ¶ added in v0.7.9

type InlineTableMap map[string]*View

func (InlineTableMap) Get ¶ added in v0.7.9

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

func (InlineTableMap) Set ¶ added in v0.7.9

func (it InlineTableMap) Set(ctx context.Context, parentFilter *Filter, inlineTable parser.InlineTable) error

type InlineTableNodes ¶ added in v0.7.9

type InlineTableNodes []InlineTableMap

func (InlineTableNodes) Get ¶ added in v0.7.9

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

func (InlineTableNodes) Load ¶ added in v0.7.9

func (list InlineTableNodes) Load(ctx context.Context, parentFilter *Filter, clause parser.WithClause) error

func (InlineTableNodes) Set ¶ added in v0.7.9

func (list InlineTableNodes) Set(ctx context.Context, parentFilter *Filter, inlineTable parser.InlineTable) error

type InsertRowValueLengthError ¶ added in v0.4.3

type InsertRowValueLengthError struct {
	*BaseError
}

type InsertSelectFieldLengthError ¶ added in v0.4.3

type InsertSelectFieldLengthError struct {
	*BaseError
}

type InternalRecordIdEmptyError ¶ added in v0.4.3

type InternalRecordIdEmptyError struct {
	*BaseError
}

type InternalRecordIdNotExistError ¶ added in v0.4.3

type InternalRecordIdNotExistError struct {
	*BaseError
}

type InvalidCursorStatementError ¶ added in v1.9.6

type InvalidCursorStatementError struct {
	*BaseError
}

type InvalidEventNameError ¶ added in v1.5.0

type InvalidEventNameError struct {
	*BaseError
}

type InvalidFetchPositionError ¶ added in v0.4.3

type InvalidFetchPositionError struct {
	*BaseError
}

type InvalidFlagNameError ¶ added in v0.4.3

type InvalidFlagNameError struct {
	*BaseError
}

type InvalidFlagValueError ¶ added in v0.4.3

type InvalidFlagValueError struct {
	*BaseError
}

type InvalidFlagValueToBeRemoveError ¶ added in v1.6.5

type InvalidFlagValueToBeRemoveError struct {
	*BaseError
}

type InvalidLimitNumberError ¶ added in v0.4.3

type InvalidLimitNumberError struct {
	*BaseError
}

type InvalidLimitPercentageError ¶ added in v0.4.3

type InvalidLimitPercentageError struct {
	*BaseError
}

type InvalidOffsetNumberError ¶ added in v0.4.3

type InvalidOffsetNumberError struct {
	*BaseError
}

type InvalidPathError ¶ added in v1.9.4

type InvalidPathError struct {
	*BaseError
}

type InvalidReloadTypeError ¶ added in v1.6.2

type InvalidReloadTypeError struct {
	*BaseError
}

type InvalidRuntimeInformationError ¶ added in v1.6.2

type InvalidRuntimeInformationError struct {
	*BaseError
}

type InvalidTableAttributeNameError ¶ added in v1.5.0

type InvalidTableAttributeNameError struct {
	*BaseError
}

type InvalidTableAttributeValueError ¶ added in v1.5.0

type InvalidTableAttributeValueError struct {
	*BaseError
}

type InvalidTableObjectError ¶ added in v1.9.4

type InvalidTableObjectError struct {
	*BaseError
}

type InvalidValueExpressionError ¶ added in v1.9.4

type InvalidValueExpressionError struct {
	*BaseError
}

type JsonQueryTooManyRecordsError ¶ added in v1.3.0

type JsonQueryTooManyRecordsError struct {
	*BaseError
}

type Lag ¶ added in v0.5.6

type Lag struct{}

func (Lag) CheckArgsLen ¶ added in v0.5.6

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

func (Lag) Execute ¶ added in v0.5.6

func (fn Lag) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type LastValue ¶ added in v0.4.9

type LastValue struct{}

func (LastValue) CheckArgsLen ¶ added in v0.5.6

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

func (LastValue) Execute ¶ added in v0.5.6

func (fn LastValue) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type Lead ¶ added in v0.5.6

type Lead struct{}

func (Lead) CheckArgsLen ¶ added in v0.5.6

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

func (Lead) Execute ¶ added in v0.5.6

func (fn Lead) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type LoadConfigurationError ¶ added in v1.6.2

type LoadConfigurationError struct {
	*BaseError
}

type LoadJsonError ¶ added in v1.9.4

type LoadJsonError struct {
	*BaseError
}

type NTile ¶ added in v0.5.6

type NTile struct{}

func (NTile) CheckArgsLen ¶ added in v0.5.6

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

func (NTile) Execute ¶ added in v0.5.6

func (fn NTile) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type NestedAggregateFunctionsError ¶ added in v0.4.3

type NestedAggregateFunctionsError struct {
	*BaseError
}

type NotGroupingRecordsError ¶ added in v0.4.3

type NotGroupingRecordsError struct {
	*BaseError
}

type NotTableError ¶ added in v1.5.0

type NotTableError struct {
	*BaseError
}

type NthValue ¶ added in v0.5.6

type NthValue struct{}

func (NthValue) CheckArgsLen ¶ added in v0.5.6

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

func (NthValue) Execute ¶ added in v0.5.6

func (fn NthValue) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type ObjectStatus ¶ added in v1.5.0

type ObjectStatus int

const (
	ObjectFixed ObjectStatus = iota
	ObjectCreated
	ObjectUpdated
)

type ObjectWriter ¶ added in v1.6.2

type ObjectWriter struct {
	Flags   *cmd.Flags
	Palette *color.Palette

	MaxWidth    int
	Padding     int
	Indent      int
	IndentWidth int

	Title1       string
	Title1Effect string
	Title2       string
	Title2Effect string
	// contains filtered or unexported fields
}

func NewObjectWriter ¶ added in v1.6.2

func NewObjectWriter(tx *Transaction) *ObjectWriter

func (*ObjectWriter) BeginBlock ¶ added in v1.6.2

func (w *ObjectWriter) BeginBlock()

func (*ObjectWriter) BeginSubBlock ¶ added in v1.6.2

func (w *ObjectWriter) BeginSubBlock()

func (*ObjectWriter) Clear ¶ added in v1.6.2

func (w *ObjectWriter) Clear()

func (*ObjectWriter) ClearBlock ¶ added in v1.6.2

func (w *ObjectWriter) ClearBlock()

func (*ObjectWriter) EndBlock ¶ added in v1.6.2

func (w *ObjectWriter) EndBlock()

func (*ObjectWriter) EndSubBlock ¶ added in v1.6.2

func (w *ObjectWriter) EndSubBlock()

func (*ObjectWriter) FitInLine ¶ added in v1.6.2

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

func (*ObjectWriter) NewLine ¶ added in v1.6.2

func (w *ObjectWriter) NewLine()

func (*ObjectWriter) String ¶ added in v1.6.2

func (w *ObjectWriter) String() string

func (*ObjectWriter) Write ¶ added in v1.6.2

func (w *ObjectWriter) Write(s string)

func (*ObjectWriter) WriteColor ¶ added in v1.6.2

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

func (*ObjectWriter) WriteColorWithoutLineBreak ¶ added in v1.6.2

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

func (*ObjectWriter) WriteSpaces ¶ added in v1.6.2

func (w *ObjectWriter) WriteSpaces(l int)

func (*ObjectWriter) WriteWithAutoLineBreak ¶ added in v1.7.2

func (w *ObjectWriter) WriteWithAutoLineBreak(s string)

func (*ObjectWriter) WriteWithoutLineBreak ¶ added in v1.6.2

func (w *ObjectWriter) WriteWithoutLineBreak(s string)

type PaddingType ¶ added in v1.5.0

type PaddingType string

const (
	PaddingRuneCount PaddingType = "LEN"
	PaddingByteCount PaddingType = "BYTE"
	PaddingWidth     PaddingType = "WIDTH"
)

type Partition ¶ added in v0.5.6

type Partition []int

func (Partition) Reverse ¶ added in v0.6.6

func (p Partition) Reverse()

type Partitions ¶ added in v0.6.7

type Partitions map[string]Partition

type PercentRank ¶ added in v0.5.5

type PercentRank struct{}

func (PercentRank) CheckArgsLen ¶ added in v0.5.6

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

func (PercentRank) Execute ¶ added in v0.5.6

func (fn PercentRank) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type PreparedStatement ¶ added in v1.9.4

type PreparedStatement struct {
	Name            string
	StatementString string
	Statements      []parser.Statement
	HolderNumber    int
}

func NewPreparedStatement ¶ added in v1.9.4

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

type PreparedStatementMap ¶ added in v1.9.4

type PreparedStatementMap map[string]*PreparedStatement

func (PreparedStatementMap) Dispose ¶ added in v1.9.4

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

func (PreparedStatementMap) Get ¶ added in v1.9.4

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

func (PreparedStatementMap) Prepare ¶ added in v1.9.4

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

type PreparedStatementSyntaxError ¶ added in v1.9.4

type PreparedStatementSyntaxError struct {
	*BaseError
}

type Processor ¶ added in v1.9.3

type Processor struct {
	Tx     *Transaction
	Filter *Filter
	// contains filtered or unexported fields
}

func NewProcessor ¶ added in v1.9.3

func NewProcessor(tx *Transaction) *Processor

func NewProcessorWithFilter ¶ added in v1.9.3

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

func (*Processor) AutoCommit ¶ added in v1.9.3

func (proc *Processor) AutoCommit() error

func (*Processor) AutoRollback ¶ added in v1.9.3

func (proc *Processor) AutoRollback() error

func (*Processor) Case ¶ added in v1.9.3

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

func (*Processor) Commit ¶ added in v1.9.3

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

func (*Processor) ExecExternalCommand ¶ added in v1.9.3

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

func (*Processor) Execute ¶ added in v1.9.3

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

func (*Processor) ExecuteStatement ¶ added in v1.9.3

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

func (*Processor) IfStmt ¶ added in v1.9.3

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

func (*Processor) Log ¶ added in v1.9.3

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

func (*Processor) LogError ¶ added in v1.9.3

func (proc *Processor) LogError(log string)

func (*Processor) LogNotice ¶ added in v1.9.3

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

func (*Processor) LogWarn ¶ added in v1.9.3

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

func (*Processor) NewChildProcessor ¶ added in v1.9.3

func (proc *Processor) NewChildProcessor() *Processor

func (*Processor) ReleaseResources ¶ added in v1.9.3

func (proc *Processor) ReleaseResources() error

func (*Processor) ReleaseResourcesWithErrors ¶ added in v1.9.3

func (proc *Processor) ReleaseResourcesWithErrors() error

func (*Processor) Rollback ¶ added in v1.9.3

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

func (*Processor) While ¶ added in v1.9.3

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

func (*Processor) WhileInCursor ¶ added in v1.9.3

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

type Prompt ¶ added in v1.6.2

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

func NewPrompt ¶ added in v1.6.2

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

func (*Prompt) LoadConfig ¶ added in v1.6.2

func (p *Prompt) LoadConfig() error

func (*Prompt) Render ¶ added in v1.6.2

func (p *Prompt) Render(ctx context.Context, sequence []PromptElement) (string, error)

func (*Prompt) RenderContinuousPrompt ¶ added in v1.6.2

func (p *Prompt) RenderContinuousPrompt(ctx context.Context) (string, error)

func (*Prompt) RenderPrompt ¶ added in v1.6.2

func (p *Prompt) RenderPrompt(ctx context.Context) (string, error)

func (*Prompt) StripEscapeSequence ¶ added in v1.6.2

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

type PromptElement ¶ added in v1.6.2

type PromptElement struct {
	Text string
	Type excmd.ElementType
}

type PromptEvaluationError ¶ added in v1.6.2

type PromptEvaluationError struct {
	Message string
}

func (PromptEvaluationError) Error ¶ added in v1.6.2

func (e PromptEvaluationError) Error() string

type PseudoCursorError ¶ added in v0.4.10

type PseudoCursorError struct {
	*BaseError
}

type Rank ¶ added in v0.2.3

type Rank struct{}

func (Rank) CheckArgsLen ¶ added in v0.5.6

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

func (Rank) Execute ¶ added in v0.5.6

func (fn Rank) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type ReadFileError ¶ added in v0.4.9

type ReadFileError struct {
	*BaseError
}

type ReadLineTerminal ¶ added in v1.6.2

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

func (ReadLineTerminal) GetSize ¶ added in v1.6.2

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

func (ReadLineTerminal) ReadLine ¶ added in v1.6.2

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

func (ReadLineTerminal) ReloadConfig ¶ added in v1.7.0

func (t ReadLineTerminal) ReloadConfig() error

func (ReadLineTerminal) SaveHistory ¶ added in v1.6.2

func (t ReadLineTerminal) SaveHistory(s string) error

func (ReadLineTerminal) SetContinuousPrompt ¶ added in v1.6.2

func (t ReadLineTerminal) SetContinuousPrompt(ctx context.Context)

func (ReadLineTerminal) SetPrompt ¶ added in v1.6.2

func (t ReadLineTerminal) SetPrompt(ctx context.Context)

func (ReadLineTerminal) Teardown ¶ added in v1.6.2

func (t ReadLineTerminal) Teardown() error

func (ReadLineTerminal) UpdateCompleter ¶ added in v1.7.0

func (t ReadLineTerminal) UpdateCompleter()

func (ReadLineTerminal) Write ¶ added in v1.6.2

func (t ReadLineTerminal) Write(s string) error

func (ReadLineTerminal) WriteError ¶ added in v1.6.2

func (t ReadLineTerminal) WriteError(s string) error

type ReadlineListener ¶ added in v1.7.0

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

func (ReadlineListener) OnChange ¶ added in v1.7.0

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

type Record ¶

type Record []Cell

func NewEmptyRecord ¶

func NewEmptyRecord(len int) Record

func NewRecord ¶

func NewRecord(values []value.Primary) Record

func NewRecordWithId ¶ added in v0.5.6

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

func (Record) Copy ¶ added in v0.1.6

func (r Record) Copy() Record

func (Record) GroupLen ¶

func (r Record) GroupLen() int

func (Record) SerializeComparisonKeys ¶ added in v0.6.6

func (r Record) SerializeComparisonKeys(buf *bytes.Buffer, flags *cmd.Flags)

type RecordReader ¶ added in v1.5.0

type RecordReader interface {
	Read() ([]text.RawText, error)
}

type RecordSet ¶ added in v0.7.9

type RecordSet []Record

func MergeRecordSetList ¶ added in v0.7.9

func MergeRecordSetList(list []RecordSet) RecordSet

func (RecordSet) Copy ¶ added in v0.7.9

func (r RecordSet) Copy() RecordSet

type RemoveFlagNotSupportedNameError ¶ added in v1.6.5

type RemoveFlagNotSupportedNameError struct {
	*BaseError
}

type ReplaceValueLengthError ¶ added in v1.5.3

type ReplaceValueLengthError struct {
	*BaseError
}

type ReplaceValues ¶ added in v1.9.4

type ReplaceValues struct {
	Values []parser.QueryExpression
	Names  map[string]int
}

func NewReplaceValues ¶ added in v1.9.4

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

type RollbackError ¶ added in v1.6.0

type RollbackError struct {
	*BaseError
}

type RowNumber ¶ added in v0.2.3

type RowNumber struct{}

func (RowNumber) CheckArgsLen ¶ added in v0.5.6

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

func (RowNumber) Execute ¶ added in v0.5.6

func (fn RowNumber) Execute(ctx context.Context, filter *Filter, partition Partition, expr parser.AnalyticFunction) (map[int]value.Primary, error)

type RowValueLengthInComparisonError ¶ added in v0.4.3

type RowValueLengthInComparisonError struct {
	*BaseError
}

type RowValueLengthInListError ¶ added in v0.4.3

type RowValueLengthInListError struct {
	*BaseError
	Index int
}

type SelectFieldLengthInComparisonError ¶ added in v0.4.3

type SelectFieldLengthInComparisonError struct {
	*BaseError
}

type Session ¶ added in v1.9.3

type Session struct {
	ScreenFd uintptr
	Stdin    io.ReadCloser
	Stdout   io.WriteCloser
	Stderr   io.WriteCloser
	OutFile  io.Writer
	Terminal VirtualTerminal
}

func NewSession ¶ added in v1.9.3

func NewSession() *Session

func (*Session) Log ¶ added in v1.9.3

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

func (*Session) LogError ¶ added in v1.9.3

func (sess *Session) LogError(log string)

func (*Session) LogNotice ¶ added in v1.9.3

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

func (*Session) LogWarn ¶ added in v1.9.3

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

func (*Session) WriteToStderr ¶ added in v1.9.3

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

func (*Session) WriteToStderrWithLineBreak ¶ added in v1.9.3

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

func (*Session) WriteToStdout ¶ added in v1.9.3

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

func (*Session) WriteToStdoutWithLineBreak ¶ added in v1.9.3

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

type ShowInvalidObjectTypeError ¶ added in v1.5.0

type ShowInvalidObjectTypeError struct {
	*BaseError
}

type SortValue ¶ added in v0.6.3

type SortValue struct {
	Type SortValueType

	Integer  int64
	Float    float64
	Datetime int64
	String   string
	Boolean  bool
}

func NewSortValue ¶ added in v0.6.3

func NewSortValue(val value.Primary, flags *cmd.Flags) *SortValue

func (*SortValue) EquivalentTo ¶ added in v0.6.3

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

func (*SortValue) Less ¶ added in v0.6.3

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

type SortValueType ¶ added in v0.6.3

type SortValueType int

const (
	NullType SortValueType = iota
	IntegerType
	FloatType
	DatetimeType
	BooleanType
	StringType
)

type SortValues ¶ added in v0.6.3

type SortValues []*SortValue

func (SortValues) EquivalentTo ¶ added in v0.6.3

func (values SortValues) EquivalentTo(compareValues SortValues) bool

func (SortValues) Less ¶ added in v0.6.3

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

func (SortValues) Serialize ¶ added in v0.6.8

func (values SortValues) Serialize(buf *bytes.Buffer)

type SourceInvalidFilePathError ¶ added in v1.5.3

type SourceInvalidFilePathError struct {
	*BaseError
}

type StatementFlow ¶ added in v0.1.8

type StatementFlow int

const (
	Terminate StatementFlow = iota
	TerminateWithError
	Exit
	Break
	Continue
	Return
)

type StatementNotExistError ¶ added in v1.9.4

type StatementNotExistError struct {
	*BaseError
}

type StatementReplaceValueNotSpecifiedError ¶ added in v1.9.4

type StatementReplaceValueNotSpecifiedError struct {
	*BaseError
}

type StdinEmptyError ¶ added in v0.4.3

type StdinEmptyError struct {
	*BaseError
}

type StringFormatter ¶ added in v1.5.3

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

func NewStringFormatter ¶ added in v1.5.3

func NewStringFormatter() *StringFormatter

func (*StringFormatter) Format ¶ added in v1.5.3

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

type SubqueryTooManyFieldsError ¶ added in v0.4.3

type SubqueryTooManyFieldsError struct {
	*BaseError
}

type SubqueryTooManyRecordsError ¶ added in v0.4.3

type SubqueryTooManyRecordsError struct {
	*BaseError
}

type SyntaxError ¶ added in v0.4.3

type SyntaxError struct {
	*BaseError
}

type SystemError ¶ added in v1.9.3

type SystemError struct {
	*BaseError
}

type TableAttributeUnchangedError ¶ added in v1.6.2

type TableAttributeUnchangedError struct {
	Path    string
	Message string
}

func (TableAttributeUnchangedError) Error ¶ added in v1.6.2

func (e TableAttributeUnchangedError) Error() string

type TableAttributeValueNotAllowedFormatError ¶ added in v1.5.0

type TableAttributeValueNotAllowedFormatError struct {
	*BaseError
}

type TableFieldLengthError ¶ added in v0.6.7

type TableFieldLengthError struct {
	*BaseError
}

type TableNotLoadedError ¶ added in v0.4.3

type TableNotLoadedError struct {
	*BaseError
}

type TableObjectArgumentsLengthError ¶ added in v1.5.0

type TableObjectArgumentsLengthError struct {
	*BaseError
}

type TableObjectInvalidArgumentError ¶ added in v1.5.0

type TableObjectInvalidArgumentError struct {
	*BaseError
}

type TableObjectInvalidDelimiterError ¶ added in v1.5.0

type TableObjectInvalidDelimiterError struct {
	*BaseError
}

type TableObjectInvalidDelimiterPositionsError ¶ added in v1.5.0

type TableObjectInvalidDelimiterPositionsError struct {
	*BaseError
}

type TableObjectInvalidJsonQueryError ¶ added in v1.5.0

type TableObjectInvalidJsonQueryError struct {
	*BaseError
}

type TableObjectJsonArgumentsLengthError ¶ added in v1.5.0

type TableObjectJsonArgumentsLengthError struct {
	*BaseError
}

type TemporaryTableFieldLengthError ¶ added in v0.4.3

type TemporaryTableFieldLengthError struct {
	*BaseError
}

type TemporaryTableRedeclaredError ¶ added in v0.4.3

type TemporaryTableRedeclaredError struct {
	*BaseError
}

type TemporaryViewScopes ¶ added in v0.7.9

type TemporaryViewScopes []ViewMap

func (TemporaryViewScopes) All ¶ added in v1.5.0

func (list TemporaryViewScopes) All() ViewMap

func (TemporaryViewScopes) Dispose ¶ added in v0.7.9

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

func (TemporaryViewScopes) Exists ¶ added in v0.7.9

func (list TemporaryViewScopes) Exists(name string) bool

func (TemporaryViewScopes) Get ¶ added in v0.7.9

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

func (TemporaryViewScopes) GetWithInternalId ¶ added in v0.7.9

func (list TemporaryViewScopes) GetWithInternalId(ctx context.Context, name parser.Identifier, flags *cmd.Flags) (*View, error)

func (TemporaryViewScopes) Replace ¶ added in v0.7.9

func (list TemporaryViewScopes) Replace(view *View)

func (TemporaryViewScopes) Restore ¶ added in v0.7.10

func (list TemporaryViewScopes) Restore(uncomittedViews map[string]*FileInfo) []string

func (TemporaryViewScopes) Set ¶ added in v0.7.9

func (list TemporaryViewScopes) Set(view *View)

func (TemporaryViewScopes) Store ¶ added in v0.7.10

func (list TemporaryViewScopes) Store(uncomittedViews map[string]*FileInfo) []string

type Transaction ¶ added in v1.9.3

type Transaction struct {
	Session *Session

	Environment *cmd.Environment
	Flags       *cmd.Flags

	WaitTimeout   time.Duration
	RetryDelay    time.Duration
	FileContainer *file.Container

	PreparedStatements PreparedStatementMap

	SelectedViews []*View
	AffectedRows  int

	AutoCommit bool
	// contains filtered or unexported fields
}

func NewTransaction ¶ added in v1.9.3

func NewTransaction(ctx context.Context, defaultWaitTimeout time.Duration, retryDelay time.Duration, session *Session) (*Transaction, error)

func (*Transaction) Commit ¶ added in v1.9.3

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

func (*Transaction) ReleaseResources ¶ added in v1.9.3

func (tx *Transaction) ReleaseResources() error

func (*Transaction) ReleaseResourcesWithErrors ¶ added in v1.9.3

func (tx *Transaction) ReleaseResourcesWithErrors() error

func (*Transaction) Rollback ¶ added in v1.9.3

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

func (*Transaction) UpdateWaitTimeout ¶ added in v1.9.3

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

type TransactionOpenError ¶ added in v1.9.4

type TransactionOpenError struct {
	*BaseError
}

type UncommittedViews ¶ added in v1.6.2

type UncommittedViews struct {
	Created map[string]*FileInfo
	Updated map[string]*FileInfo
	// contains filtered or unexported fields
}

func NewUncommittedViews ¶ added in v1.9.4

func NewUncommittedViews() *UncommittedViews

func (*UncommittedViews) Clean ¶ added in v1.9.4

func (m *UncommittedViews) Clean()

func (*UncommittedViews) CountCreatedTables ¶ added in v1.9.4

func (m *UncommittedViews) CountCreatedTables() int

func (*UncommittedViews) CountUpdatedTables ¶ added in v1.9.4

func (m *UncommittedViews) CountUpdatedTables() int

func (*UncommittedViews) CountUpdatedViews ¶ added in v1.9.4

func (m *UncommittedViews) CountUpdatedViews() int

func (*UncommittedViews) IsEmpty ¶ added in v1.9.4

func (m *UncommittedViews) IsEmpty() bool

func (*UncommittedViews) SetForCreatedView ¶ added in v1.9.4

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

func (*UncommittedViews) SetForUpdatedView ¶ added in v1.9.4

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

func (*UncommittedViews) UncommittedFiles ¶ added in v1.9.4

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

func (*UncommittedViews) UncommittedTempViews ¶ added in v1.9.4

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

func (*UncommittedViews) Unset ¶ added in v1.9.4

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

type UndeclaredCursorError ¶ added in v0.8.7

type UndeclaredCursorError struct {
	*BaseError
}

type UndeclaredTemporaryTableError ¶ added in v0.8.7

type UndeclaredTemporaryTableError struct {
	*BaseError
}

type UndeclaredVariableError ¶ added in v0.8.7

type UndeclaredVariableError struct {
	*BaseError
}

type UndefinedInLineTableError ¶ added in v0.4.3

type UndefinedInLineTableError struct {
	*BaseError
}

type UnknownFormatPlaceholderError ¶ added in v1.5.3

type UnknownFormatPlaceholderError struct {
	*BaseError
}

type UnpermittedFunctionStatementError ¶ added in v1.9.4

type UnpermittedFunctionStatementError struct {
	*BaseError
}

type UpdateFieldNotExistError ¶ added in v0.4.3

type UpdateFieldNotExistError struct {
	*BaseError
}

type UpdateValueAmbiguousError ¶ added in v0.4.3

type UpdateValueAmbiguousError struct {
	*BaseError
}

type UserDefinedFunction ¶ added in v0.4.3

type UserDefinedFunction struct {
	Name         parser.Identifier
	Statements   []parser.Statement
	Parameters   []parser.Variable
	Defaults     map[string]parser.QueryExpression
	RequiredArgs int

	IsAggregate bool
	Cursor      parser.Identifier // For Aggregate Functions
}

func (*UserDefinedFunction) CheckArgsLen ¶ added in v0.5.0

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

func (*UserDefinedFunction) Execute ¶ added in v0.4.3

func (fn *UserDefinedFunction) Execute(ctx context.Context, filter *Filter, args []value.Primary) (value.Primary, error)

func (*UserDefinedFunction) ExecuteAggregate ¶ added in v0.4.11

func (fn *UserDefinedFunction) ExecuteAggregate(ctx context.Context, filter *Filter, values []value.Primary, args []value.Primary) (value.Primary, error)

type UserDefinedFunctionMap ¶ added in v0.4.3

type UserDefinedFunctionMap map[string]*UserDefinedFunction

func (UserDefinedFunctionMap) CheckDuplicate ¶ added in v0.4.10

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

func (UserDefinedFunctionMap) Declare ¶ added in v0.4.3

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

func (UserDefinedFunctionMap) DeclareAggregate ¶ added in v0.4.10

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

func (UserDefinedFunctionMap) Dispose ¶ added in v1.0.1

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

func (UserDefinedFunctionMap) Get ¶ added in v0.4.3

func (m UserDefinedFunctionMap) Get(fn parser.QueryExpression, name string) (*UserDefinedFunction, error)

func (UserDefinedFunctionMap) Keys ¶ added in v1.5.0

func (m UserDefinedFunctionMap) Keys() []string

func (UserDefinedFunctionMap) SortedKeys ¶ added in v1.5.0

func (m UserDefinedFunctionMap) SortedKeys() []string

type UserDefinedFunctionScopes ¶ added in v0.7.9

type UserDefinedFunctionScopes []UserDefinedFunctionMap

func (UserDefinedFunctionScopes) All ¶ added in v1.5.0

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

func (UserDefinedFunctionScopes) Declare ¶ added in v0.7.9

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

func (UserDefinedFunctionScopes) DeclareAggregate ¶ added in v0.7.9

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

func (UserDefinedFunctionScopes) Dispose ¶ added in v1.0.1

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

func (UserDefinedFunctionScopes) Get ¶ added in v0.7.9

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

type UserTriggeredError ¶ added in v0.5.0

type UserTriggeredError struct {
	*BaseError
}

type VariableMap ¶ added in v0.7.9

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

func NewVariableMap ¶ added in v1.6.6

func NewVariableMap() VariableMap

func (*VariableMap) Add ¶ added in v0.7.9

func (m *VariableMap) Add(variable parser.Variable, value value.Primary) error

func (*VariableMap) Declare ¶ added in v0.7.9

func (m *VariableMap) Declare(ctx context.Context, filter *Filter, declaration parser.VariableDeclaration) error

func (*VariableMap) Dispose ¶ added in v0.7.9

func (m *VariableMap) Dispose(variable parser.Variable) error

func (*VariableMap) Get ¶ added in v0.7.9

func (m *VariableMap) Get(variable parser.Variable) (value.Primary, error)

func (*VariableMap) Set ¶ added in v0.7.9

func (m *VariableMap) Set(variable parser.Variable, value value.Primary) error

func (*VariableMap) SortedKeys ¶ added in v1.7.0

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

func (*VariableMap) Substitute ¶ added in v0.7.9

func (m *VariableMap) Substitute(ctx context.Context, filter *Filter, substitution parser.VariableSubstitution) (value.Primary, error)

func (*VariableMap) SubstituteDirectly ¶ added in v0.7.9

func (m *VariableMap) SubstituteDirectly(variable parser.Variable, value value.Primary) (value.Primary, error)

type VariableRedeclaredError ¶ added in v0.4.3

type VariableRedeclaredError struct {
	*BaseError
}

type VariableScopes ¶ added in v0.7.9

type VariableScopes []VariableMap

func (VariableScopes) All ¶ added in v1.7.0

func (list VariableScopes) All() VariableMap

func (VariableScopes) Declare ¶ added in v0.7.9

func (list VariableScopes) Declare(ctx context.Context, filter *Filter, expr parser.VariableDeclaration) error

func (VariableScopes) Dispose ¶ added in v0.7.9

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

func (VariableScopes) Get ¶ added in v0.7.9

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

func (VariableScopes) Substitute ¶ added in v0.7.9

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

func (VariableScopes) SubstituteDirectly ¶ added in v0.7.9

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

type View ¶

type View struct {
	Header    Header
	RecordSet RecordSet
	FileInfo  *FileInfo

	Tx     *Transaction
	Filter *Filter
	// contains filtered or unexported fields
}

func NewView ¶

func NewView(tx *Transaction) *View

func NewViewFromGroupedRecord ¶

func NewViewFromGroupedRecord(filterRecord filterRecord) *View

func Select ¶ added in v0.1.6

func Select(ctx context.Context, parentFilter *Filter, query parser.SelectQuery) (*View, error)

func (*View) Copy ¶ added in v0.1.6

func (view *View) Copy() *View

func (*View) Except ¶ added in v0.2.1

func (view *View) Except(ctx context.Context, calcView *View, all bool) (err error)

func (*View) ExtendRecordCapacity ¶ added in v0.6.8

func (view *View) ExtendRecordCapacity(ctx context.Context, exprs []parser.QueryExpression) error

func (*View) FieldIndex ¶ added in v0.1.6

func (view *View) FieldIndex(fieldRef parser.QueryExpression) (int, error)

func (*View) FieldIndices ¶ added in v0.1.6

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

func (*View) FieldLen ¶

func (view *View) FieldLen() int

func (*View) FieldViewName ¶ added in v0.1.8

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

func (*View) Fix ¶

func (view *View) Fix(ctx context.Context) error

func (*View) GenerateComparisonKeys ¶ added in v0.6.6

func (view *View) GenerateComparisonKeys(ctx context.Context) error

func (*View) GroupBy ¶

func (view *View) GroupBy(ctx context.Context, clause parser.GroupByClause) error

func (*View) Having ¶

func (view *View) Having(ctx context.Context, clause parser.HavingClause) error

func (*View) InsertFromQuery ¶ added in v0.1.6

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

func (*View) InsertValues ¶ added in v0.1.6

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

func (*View) InternalRecordId ¶ added in v0.1.6

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

func (*View) Intersect ¶ added in v0.2.1

func (view *View) Intersect(ctx context.Context, calcView *View, all bool) (err error)

func (*View) Len ¶

func (view *View) Len() int

func (*View) Less ¶

func (view *View) Less(i, j int) bool

func (*View) Limit ¶

func (view *View) Limit(ctx context.Context, clause parser.LimitClause) error

func (*View) ListValuesForAggregateFunctions ¶ added in v0.4.9

func (view *View) ListValuesForAggregateFunctions(ctx context.Context, expr parser.QueryExpression, arg parser.QueryExpression, distinct bool, filter *Filter) ([]value.Primary, error)

func (*View) Load ¶ added in v0.1.6

func (view *View) Load(ctx context.Context, filter *Filter, clause parser.FromClause, forUpdate bool, useInternalId bool) error

func (*View) LoadFromTableIdentifier ¶ added in v0.4.8

func (view *View) LoadFromTableIdentifier(ctx context.Context, filter *Filter, table parser.QueryExpression, forUpdate bool, useInternalId bool) error

func (*View) Offset ¶ added in v0.2.2

func (view *View) Offset(ctx context.Context, clause parser.OffsetClause) error

func (*View) OrderBy ¶

func (view *View) OrderBy(ctx context.Context, clause parser.OrderByClause) error

func (*View) RecordLen ¶

func (view *View) RecordLen() int

func (*View) RestoreHeaderReferences ¶ added in v0.4.10

func (view *View) RestoreHeaderReferences() error

func (*View) Select ¶

func (view *View) Select(ctx context.Context, clause parser.SelectClause) error

func (*View) SelectAllColumns ¶ added in v0.1.6

func (view *View) SelectAllColumns(ctx context.Context) error

func (*View) Swap ¶

func (view *View) Swap(i, j int)

func (*View) Union ¶ added in v0.2.1

func (view *View) Union(ctx context.Context, calcView *View, all bool) (err error)

func (*View) Where ¶

func (view *View) Where(ctx context.Context, clause parser.WhereClause) error

type ViewMap ¶ added in v0.1.6

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

func NewViewMap ¶ added in v0.1.6

func NewViewMap() ViewMap

func (ViewMap) Clean ¶ added in v0.7.10

func (m ViewMap) Clean(container *file.Container) error

func (ViewMap) CleanWithErrors ¶ added in v1.6.0

func (m ViewMap) CleanWithErrors(container *file.Container) error

func (ViewMap) Dispose ¶ added in v0.7.10

func (m ViewMap) Dispose(container *file.Container, name string) error

func (ViewMap) DisposeTemporaryTable ¶ added in v0.4.1

func (m ViewMap) DisposeTemporaryTable(table parser.Identifier) error

func (ViewMap) Exists ¶ added in v0.1.6

func (m ViewMap) Exists(fpath string) bool

func (ViewMap) Get ¶ added in v0.1.6

func (m ViewMap) Get(fpath parser.Identifier) (*View, error)

func (ViewMap) GetWithInternalId ¶ added in v0.1.6

func (m ViewMap) GetWithInternalId(ctx context.Context, fpath parser.Identifier, flags *cmd.Flags) (*View, error)

func (ViewMap) Keys ¶ added in v1.5.0

func (m ViewMap) Keys() []string

func (ViewMap) Replace ¶ added in v0.2.0

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

func (ViewMap) Set ¶ added in v0.1.6

func (m ViewMap) Set(view *View)

func (ViewMap) SortedKeys ¶ added in v1.5.0

func (m ViewMap) SortedKeys() []string

type VirtualTerminal ¶ added in v1.6.2

type VirtualTerminal interface {
	ReadLine() (string, error)
	Write(string) error
	WriteError(string) error
	SetPrompt(ctx context.Context)
	SetContinuousPrompt(ctx context.Context)
	SaveHistory(string) error
	Teardown() error
	GetSize() (int, int, error)
	ReloadConfig() error
	UpdateCompleter()
}

func NewTerminal ¶ added in v1.6.2

func NewTerminal(ctx context.Context, filter *Filter) (VirtualTerminal, error)

type WindowFrame ¶ added in v1.0.1

type WindowFrame struct {
	Low     int
	High    int
	Records []int
}

func WindowFrameSet ¶ added in v1.0.1

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

type WriteFileError ¶ added in v0.4.9

type WriteFileError struct {
	*BaseError
}

Source Files ¶

View all Source files

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