internal

package
v0.19.3 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2024 License: MIT Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var WeekPartToOffset = map[string]int{
	"WEEK":           0,
	"WEEK_MONDAY":    1,
	"WEEK_TUESDAY":   2,
	"WEEK_WEDNESDAY": 3,
	"WEEK_THURSDAY":  4,
	"WEEK_FRIDAY":    5,
	"WEEK_SATURDAY":  6,
}

Functions

func CurrentTime 

func CurrentTime(ctx context.Context) *time.Time

func DateFromInt64Value added in v0.8.10 

func DateFromInt64Value(v int64) (time.Time, error)

func EncodeGoValue added in v0.8.0 

func EncodeGoValue(t types.Type, v interface{}) (interface{}, error)

func EncodeGoValues added in v0.8.0 

func EncodeGoValues(v []interface{}, params []*ast.ParameterNode) ([]interface{}, error)

func EncodeNamedValues added in v0.4.0 

func EncodeNamedValues(v []driver.NamedValue, params []*ast.ParameterNode) ([]sql.NamedArg, error)

func EncodeValue added in v0.8.0 

func EncodeValue(v Value) (interface{}, error)

func LiteralFromValue added in v0.8.0 

func LiteralFromValue(v Value) (string, error)

func LiteralFromZetaSQLValue added in v0.8.0 

func LiteralFromZetaSQLValue(v types.Value) (string, error)

func RegisterFunctions 

func RegisterFunctions(conn *sqlite3.SQLiteConn) error

func TimestampFromFloatValue added in v0.8.10 

func TimestampFromFloatValue(f float64) (time.Time, error)

func TimestampFromInt64Value added in v0.8.10 

func TimestampFromInt64Value(v int64) (time.Time, error)

func WithCurrentTime 

func WithCurrentTime(ctx context.Context, now time.Time) context.Context

Types

type ANY_VALUE added in v0.12.0 

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

func (*ANY_VALUE) Done added in v0.12.0 

func (f *ANY_VALUE) Done() (Value, error)

func (*ANY_VALUE) Step added in v0.12.0 

func (f *ANY_VALUE) Step(v Value, opt *AggregatorOption) error

type APPROX_COUNT_DISTINCT added in v0.12.0 

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

func (*APPROX_COUNT_DISTINCT) Done added in v0.12.0 

func (f *APPROX_COUNT_DISTINCT) Done() (Value, error)

func (*APPROX_COUNT_DISTINCT) Step added in v0.12.0 

func (f *APPROX_COUNT_DISTINCT) Step(v Value, opt *AggregatorOption) error

type APPROX_QUANTILES added in v0.12.0 

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

func (*APPROX_QUANTILES) Done added in v0.12.0 

func (f *APPROX_QUANTILES) Done() (Value, error)

func (*APPROX_QUANTILES) Step added in v0.12.0 

func (f *APPROX_QUANTILES) Step(v Value, num int64, opt *AggregatorOption) error

type APPROX_TOP_COUNT added in v0.12.0 

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

func (*APPROX_TOP_COUNT) Done added in v0.12.0 

func (f *APPROX_TOP_COUNT) Done() (Value, error)

func (*APPROX_TOP_COUNT) Step added in v0.12.0 

func (f *APPROX_TOP_COUNT) Step(v Value, num int64, opt *AggregatorOption) error

type APPROX_TOP_SUM added in v0.12.0 

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

func (*APPROX_TOP_SUM) Done added in v0.12.0 

func (f *APPROX_TOP_SUM) Done() (Value, error)

func (*APPROX_TOP_SUM) Step added in v0.12.0 

func (f *APPROX_TOP_SUM) Step(v, weight Value, num int64, opt *AggregatorOption) error

type ARRAY 

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

func (*ARRAY) Done 

func (f *ARRAY) Done() (Value, error)

func (*ARRAY) Step 

func (f *ARRAY) Step(v Value, opt *AggregatorOption) error

type ARRAY_AGG 

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

func (*ARRAY_AGG) Done 

func (f *ARRAY_AGG) Done() (Value, error)

func (*ARRAY_AGG) Step 

func (f *ARRAY_AGG) Step(v Value, opt *AggregatorOption) error

type ARRAY_CONCAT_AGG 

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

func (*ARRAY_CONCAT_AGG) Done 

func (f *ARRAY_CONCAT_AGG) Done() (Value, error)

func (*ARRAY_CONCAT_AGG) Step 

func (f *ARRAY_CONCAT_AGG) Step(v *ArrayValue, opt *AggregatorOption) error

type AVG 

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

func (*AVG) Done 

func (f *AVG) Done() (Value, error)

func (*AVG) Step 

func (f *AVG) Step(v Value, opt *AggregatorOption) error

type AbortBatchStmtNode 

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

func (*AbortBatchStmtNode) FormatSQL 

func (n *AbortBatchStmtNode) FormatSQL(ctx context.Context) (string, error)

type AddColumnActionNode 

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

func (*AddColumnActionNode) FormatSQL 

func (n *AddColumnActionNode) FormatSQL(ctx context.Context) (string, error)

type AddConstraintActionNode 

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

func (*AddConstraintActionNode) FormatSQL 

func (n *AddConstraintActionNode) FormatSQL(ctx context.Context) (string, error)

type AddToRestricteeListActionNode 

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

func (*AddToRestricteeListActionNode) FormatSQL 

func (n *AddToRestricteeListActionNode) FormatSQL(ctx context.Context) (string, error)

type AggregateBindFunction 

type AggregateBindFunction func() func() *Aggregator

type AggregateFuncInfo 

type AggregateFuncInfo struct {
	Name     string
	BindFunc AggregateBindFunction
}

type AggregateFunctionCallNode 

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

func (*AggregateFunctionCallNode) FormatSQL 

func (n *AggregateFunctionCallNode) FormatSQL(ctx context.Context) (string, error)

type AggregateHavingModifierNode 

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

func (*AggregateHavingModifierNode) FormatSQL 

func (n *AggregateHavingModifierNode) FormatSQL(ctx context.Context) (string, error)

type AggregateOrderBy 

type AggregateOrderBy struct {
	Value Value `json:"value"`
	IsAsc bool  `json:"isAsc"`
}

func (*AggregateOrderBy) UnmarshalJSON 

func (a *AggregateOrderBy) UnmarshalJSON(b []byte) error

type AggregateScanNode 

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

func (*AggregateScanNode) FormatSQL 

func (n *AggregateScanNode) FormatSQL(ctx context.Context) (string, error)

type Aggregator 

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

func (*Aggregator) Done 

func (a *Aggregator) Done() (interface{}, error)

func (*Aggregator) Step 

func (a *Aggregator) Step(stepArgs ...interface{}) error

type AggregatorFuncOption 

type AggregatorFuncOption struct {
	Type  AggregatorFuncOptionType `json:"type"`
	Value interface{}              `json:"value"`
}

func (*AggregatorFuncOption) UnmarshalJSON 

func (o *AggregatorFuncOption) UnmarshalJSON(b []byte) error

type AggregatorFuncOptionType 

type AggregatorFuncOptionType string
const (
	AggregatorFuncOptionUnknown     AggregatorFuncOptionType = "aggregate_unknown"
	AggregatorFuncOptionDistinct    AggregatorFuncOptionType = "aggregate_distinct"
	AggregatorFuncOptionLimit       AggregatorFuncOptionType = "aggregate_limit"
	AggregatorFuncOptionOrderBy     AggregatorFuncOptionType = "aggregate_order_by"
	AggregatorFuncOptionIgnoreNulls AggregatorFuncOptionType = "aggregate_ignore_nulls"
)

type AggregatorOption 

type AggregatorOption struct {
	Distinct    bool
	IgnoreNulls bool
	Limit       *int64
	OrderBy     []*AggregateOrderBy
}

type AlterAllRowAccessPoliciesStmtNode 

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

func (*AlterAllRowAccessPoliciesStmtNode) FormatSQL 

func (n *AlterAllRowAccessPoliciesStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterColumnDropDefaultActionNode 

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

func (*AlterColumnDropDefaultActionNode) FormatSQL 

func (n *AlterColumnDropDefaultActionNode) FormatSQL(ctx context.Context) (string, error)

type AlterColumnDropNotNullActionNode 

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

func (*AlterColumnDropNotNullActionNode) FormatSQL 

func (n *AlterColumnDropNotNullActionNode) FormatSQL(ctx context.Context) (string, error)

type AlterColumnOptionsActionNode 

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

func (*AlterColumnOptionsActionNode) FormatSQL 

func (n *AlterColumnOptionsActionNode) FormatSQL(ctx context.Context) (string, error)

type AlterColumnSetDataTypeActionNode 

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

func (*AlterColumnSetDataTypeActionNode) FormatSQL 

func (n *AlterColumnSetDataTypeActionNode) FormatSQL(ctx context.Context) (string, error)

type AlterColumnSetDefaultActionNode 

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

func (*AlterColumnSetDefaultActionNode) FormatSQL 

func (n *AlterColumnSetDefaultActionNode) FormatSQL(ctx context.Context) (string, error)

type AlterDatabaseStmtNode 

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

func (*AlterDatabaseStmtNode) FormatSQL 

func (n *AlterDatabaseStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterEntityStmtNode 

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

func (*AlterEntityStmtNode) FormatSQL 

func (n *AlterEntityStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterMaterializedViewStmtNode 

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

func (*AlterMaterializedViewStmtNode) FormatSQL 

func (n *AlterMaterializedViewStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterPrivilegeRestrictionStmtNode 

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

func (*AlterPrivilegeRestrictionStmtNode) FormatSQL 

func (n *AlterPrivilegeRestrictionStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterRowAccessPolicyStmtNode 

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

func (*AlterRowAccessPolicyStmtNode) FormatSQL 

func (n *AlterRowAccessPolicyStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterSchemaStmtNode 

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

func (*AlterSchemaStmtNode) FormatSQL 

func (n *AlterSchemaStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterTableSetOptionsStmtNode 

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

func (*AlterTableSetOptionsStmtNode) FormatSQL 

func (n *AlterTableSetOptionsStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterTableStmtNode 

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

func (*AlterTableStmtNode) FormatSQL 

func (n *AlterTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type AlterViewStmtNode 

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

func (*AlterViewStmtNode) FormatSQL 

func (n *AlterViewStmtNode) FormatSQL(ctx context.Context) (string, error)

type AnalyticFunctionCallNode 

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

func (*AnalyticFunctionCallNode) FormatSQL 

func (n *AnalyticFunctionCallNode) FormatSQL(ctx context.Context) (string, error)

type AnalyticFunctionGroupNode 

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

func (*AnalyticFunctionGroupNode) FormatSQL 

func (n *AnalyticFunctionGroupNode) FormatSQL(ctx context.Context) (string, error)

type AnalyticScanNode 

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

func (*AnalyticScanNode) FormatSQL 

func (n *AnalyticScanNode) FormatSQL(ctx context.Context) (string, error)

type AnalyzeStmtNode 

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

func (*AnalyzeStmtNode) FormatSQL 

func (n *AnalyzeStmtNode) FormatSQL(ctx context.Context) (string, error)

type Analyzer 

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

func NewAnalyzer 

func NewAnalyzer(catalog *Catalog) (*Analyzer, error)

func (*Analyzer) AddNamePath 

func (a *Analyzer) AddNamePath(path string) error

func (*Analyzer) Analyze 

func (a *Analyzer) Analyze(ctx context.Context, conn *Conn, query string, args []driver.NamedValue) ([]StmtActionFunc, error)

func (*Analyzer) MaxNamePath added in v0.17.0 

func (a *Analyzer) MaxNamePath() int

func (*Analyzer) NamePath 

func (a *Analyzer) NamePath() []string

func (*Analyzer) SetAutoIndexMode added in v0.12.0 

func (a *Analyzer) SetAutoIndexMode(enabled bool)

func (*Analyzer) SetExplainMode added in v0.12.0 

func (a *Analyzer) SetExplainMode(enabled bool)

func (*Analyzer) SetMaxNamePath added in v0.17.0 

func (a *Analyzer) SetMaxNamePath(num int)

func (*Analyzer) SetNamePath 

func (a *Analyzer) SetNamePath(path []string) error

type AnonymizedAggregateScanNode 

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

func (*AnonymizedAggregateScanNode) FormatSQL 

func (n *AnonymizedAggregateScanNode) FormatSQL(ctx context.Context) (string, error)

type ArgumentDefNode 

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

func (*ArgumentDefNode) FormatSQL 

func (n *ArgumentDefNode) FormatSQL(ctx context.Context) (string, error)

type ArgumentListNode 

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

func (*ArgumentListNode) FormatSQL 

func (n *ArgumentListNode) FormatSQL(ctx context.Context) (string, error)

type ArgumentRefNode 

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

func (*ArgumentRefNode) FormatSQL 

func (n *ArgumentRefNode) FormatSQL(ctx context.Context) (string, error)

type ArrayScanNode 

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

func (*ArrayScanNode) FormatSQL 

func (n *ArrayScanNode) FormatSQL(ctx context.Context) (string, error)

type ArrayValue 

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

func (*ArrayValue) Add 

func (av *ArrayValue) Add(v Value) (Value, error)

func (*ArrayValue) Div 

func (av *ArrayValue) Div(v Value) (Value, error)

func (*ArrayValue) EQ 

func (av *ArrayValue) EQ(v Value) (bool, error)

func (*ArrayValue) Format 

func (av *ArrayValue) Format(verb rune) string

func (*ArrayValue) GT 

func (av *ArrayValue) GT(v Value) (bool, error)

func (*ArrayValue) GTE 

func (av *ArrayValue) GTE(v Value) (bool, error)

func (*ArrayValue) Has 

func (av *ArrayValue) Has(v Value) (bool, error)

func (*ArrayValue) Interface 

func (av *ArrayValue) Interface() interface{}

func (*ArrayValue) LT 

func (av *ArrayValue) LT(v Value) (bool, error)

func (*ArrayValue) LTE 

func (av *ArrayValue) LTE(v Value) (bool, error)

func (*ArrayValue) Mul 

func (av *ArrayValue) Mul(v Value) (Value, error)

func (*ArrayValue) Sub 

func (av *ArrayValue) Sub(v Value) (Value, error)

func (*ArrayValue) ToArray 

func (av *ArrayValue) ToArray() (*ArrayValue, error)

func (*ArrayValue) ToBool 

func (av *ArrayValue) ToBool() (bool, error)

func (*ArrayValue) ToBytes added in v0.7.0 

func (av *ArrayValue) ToBytes() ([]byte, error)

func (*ArrayValue) ToFloat64 

func (av *ArrayValue) ToFloat64() (float64, error)

func (*ArrayValue) ToInt64 

func (av *ArrayValue) ToInt64() (int64, error)

func (*ArrayValue) ToJSON 

func (av *ArrayValue) ToJSON() (string, error)

func (*ArrayValue) ToRat added in v0.6.2 

func (av *ArrayValue) ToRat() (*big.Rat, error)

func (*ArrayValue) ToString 

func (av *ArrayValue) ToString() (string, error)

func (*ArrayValue) ToStruct 

func (av *ArrayValue) ToStruct() (*StructValue, error)

func (*ArrayValue) ToTime 

func (av *ArrayValue) ToTime() (time.Time, error)

type AssertRowsModifiedNode 

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

func (*AssertRowsModifiedNode) FormatSQL 

func (n *AssertRowsModifiedNode) FormatSQL(ctx context.Context) (string, error)

type AssertStmtNode 

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

func (*AssertStmtNode) FormatSQL 

func (n *AssertStmtNode) FormatSQL(ctx context.Context) (string, error)

type AssignmentStmtNode 

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

func (*AssignmentStmtNode) FormatSQL 

func (n *AssignmentStmtNode) FormatSQL(ctx context.Context) (string, error)

type AuxLoadDataStmtNode 

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

func (*AuxLoadDataStmtNode) FormatSQL 

func (n *AuxLoadDataStmtNode) FormatSQL(ctx context.Context) (string, error)

type BIT_AND_AGG 

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

func (*BIT_AND_AGG) Done 

func (f *BIT_AND_AGG) Done() (Value, error)

func (*BIT_AND_AGG) Step 

func (f *BIT_AND_AGG) Step(v Value, opt *AggregatorOption) error

type BIT_OR_AGG 

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

func (*BIT_OR_AGG) Done 

func (f *BIT_OR_AGG) Done() (Value, error)

func (*BIT_OR_AGG) Step 

func (f *BIT_OR_AGG) Step(v Value, opt *AggregatorOption) error

type BIT_XOR_AGG 

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

func (*BIT_XOR_AGG) Done 

func (f *BIT_XOR_AGG) Done() (Value, error)

func (*BIT_XOR_AGG) Step 

func (f *BIT_XOR_AGG) Step(v Value, opt *AggregatorOption) error

type BeginStmtAction added in v0.8.8 

type BeginStmtAction struct{}

func (*BeginStmtAction) Args added in v0.8.8 

func (a *BeginStmtAction) Args() []interface{}

func (*BeginStmtAction) Cleanup added in v0.8.8 

func (a *BeginStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*BeginStmtAction) ExecContext added in v0.8.8 

func (a *BeginStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*BeginStmtAction) Prepare added in v0.8.8 

func (a *BeginStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*BeginStmtAction) QueryContext added in v0.8.8 

func (a *BeginStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type BeginStmtNode 

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

func (*BeginStmtNode) FormatSQL 

func (n *BeginStmtNode) FormatSQL(ctx context.Context) (string, error)

type BindFunction 

type BindFunction func(...Value) (Value, error)

type BoolValue 

type BoolValue bool

func (BoolValue) Add 

func (bv BoolValue) Add(v Value) (Value, error)

func (BoolValue) Div 

func (bv BoolValue) Div(v Value) (Value, error)

func (BoolValue) EQ 

func (bv BoolValue) EQ(v Value) (bool, error)

func (BoolValue) Format 

func (bv BoolValue) Format(verb rune) string

func (BoolValue) GT 

func (bv BoolValue) GT(v Value) (bool, error)

func (BoolValue) GTE 

func (bv BoolValue) GTE(v Value) (bool, error)

func (BoolValue) Interface 

func (bv BoolValue) Interface() interface{}

func (BoolValue) LT 

func (bv BoolValue) LT(v Value) (bool, error)

func (BoolValue) LTE 

func (bv BoolValue) LTE(v Value) (bool, error)

func (BoolValue) Mul 

func (bv BoolValue) Mul(v Value) (Value, error)

func (BoolValue) Sub 

func (bv BoolValue) Sub(v Value) (Value, error)

func (BoolValue) ToArray 

func (bv BoolValue) ToArray() (*ArrayValue, error)

func (BoolValue) ToBool 

func (bv BoolValue) ToBool() (bool, error)

func (BoolValue) ToBytes added in v0.7.0 

func (bv BoolValue) ToBytes() ([]byte, error)

func (BoolValue) ToFloat64 

func (bv BoolValue) ToFloat64() (float64, error)

func (BoolValue) ToInt64 

func (bv BoolValue) ToInt64() (int64, error)

func (BoolValue) ToJSON 

func (bv BoolValue) ToJSON() (string, error)

func (BoolValue) ToRat added in v0.6.2 

func (bv BoolValue) ToRat() (*big.Rat, error)

func (BoolValue) ToString 

func (bv BoolValue) ToString() (string, error)

func (BoolValue) ToStruct 

func (bv BoolValue) ToStruct() (*StructValue, error)

func (BoolValue) ToTime 

func (bv BoolValue) ToTime() (time.Time, error)

type BytesValue added in v0.7.0 

type BytesValue []byte

func (BytesValue) Add added in v0.7.0 

func (bv BytesValue) Add(v Value) (Value, error)

func (BytesValue) Div added in v0.7.0 

func (bv BytesValue) Div(v Value) (Value, error)

func (BytesValue) EQ added in v0.7.0 

func (bv BytesValue) EQ(v Value) (bool, error)

func (BytesValue) Format added in v0.7.0 

func (bv BytesValue) Format(verb rune) string

func (BytesValue) GT added in v0.7.0 

func (bv BytesValue) GT(v Value) (bool, error)

func (BytesValue) GTE added in v0.7.0 

func (bv BytesValue) GTE(v Value) (bool, error)

func (BytesValue) Interface added in v0.7.0 

func (bv BytesValue) Interface() interface{}

func (BytesValue) LT added in v0.7.0 

func (bv BytesValue) LT(v Value) (bool, error)

func (BytesValue) LTE added in v0.7.0 

func (bv BytesValue) LTE(v Value) (bool, error)

func (BytesValue) Mul added in v0.7.0 

func (bv BytesValue) Mul(v Value) (Value, error)

func (BytesValue) Sub added in v0.7.0 

func (bv BytesValue) Sub(v Value) (Value, error)

func (BytesValue) ToArray added in v0.7.0 

func (bv BytesValue) ToArray() (*ArrayValue, error)

func (BytesValue) ToBool added in v0.7.0 

func (bv BytesValue) ToBool() (bool, error)

func (BytesValue) ToBytes added in v0.7.0 

func (bv BytesValue) ToBytes() ([]byte, error)

func (BytesValue) ToFloat64 added in v0.7.0 

func (bv BytesValue) ToFloat64() (float64, error)

func (BytesValue) ToInt64 added in v0.7.0 

func (bv BytesValue) ToInt64() (int64, error)

func (BytesValue) ToJSON added in v0.7.0 

func (bv BytesValue) ToJSON() (string, error)

func (BytesValue) ToRat added in v0.7.0 

func (bv BytesValue) ToRat() (*big.Rat, error)

func (BytesValue) ToString added in v0.7.0 

func (bv BytesValue) ToString() (string, error)

func (BytesValue) ToStruct added in v0.7.0 

func (bv BytesValue) ToStruct() (*StructValue, error)

func (BytesValue) ToTime added in v0.7.0 

func (bv BytesValue) ToTime() (time.Time, error)

type CORR added in v0.12.0 

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

func (*CORR) Done added in v0.12.0 

func (f *CORR) Done() (Value, error)

func (*CORR) Step added in v0.12.0 

func (f *CORR) Step(x, y Value, opt *AggregatorOption) error

type COUNT 

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

func (*COUNT) Done 

func (f *COUNT) Done() (Value, error)

func (*COUNT) Step 

func (f *COUNT) Step(v Value, opt *AggregatorOption) error

type COUNTIF 

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

func (*COUNTIF) Done 

func (f *COUNTIF) Done() (Value, error)

func (*COUNTIF) Step 

func (f *COUNTIF) Step(cond Value, opt *AggregatorOption) error

type COUNT_STAR 

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

func (*COUNT_STAR) Done 

func (f *COUNT_STAR) Done() (Value, error)

func (*COUNT_STAR) Step 

func (f *COUNT_STAR) Step(opt *AggregatorOption) error

type COVAR_POP added in v0.12.0 

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

func (*COVAR_POP) Done added in v0.12.0 

func (f *COVAR_POP) Done() (Value, error)

func (*COVAR_POP) Step added in v0.12.0 

func (f *COVAR_POP) Step(x, y Value, opt *AggregatorOption) error

type COVAR_SAMP added in v0.12.0 

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

func (*COVAR_SAMP) Done added in v0.12.0 

func (f *COVAR_SAMP) Done() (Value, error)

func (*COVAR_SAMP) Step added in v0.12.0 

func (f *COVAR_SAMP) Step(x, y Value, opt *AggregatorOption) error

type CallStmtNode 

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

func (*CallStmtNode) FormatSQL 

func (n *CallStmtNode) FormatSQL(ctx context.Context) (string, error)

type CastNode 

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

func (*CastNode) FormatSQL 

func (n *CastNode) FormatSQL(ctx context.Context) (string, error)

type Catalog 

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

func NewCatalog 

func NewCatalog(db *sql.DB) *Catalog

func (*Catalog) AddNewFunctionSpec 

func (c *Catalog) AddNewFunctionSpec(ctx context.Context, conn *Conn, spec *FunctionSpec) error

func (*Catalog) AddNewTableSpec 

func (c *Catalog) AddNewTableSpec(ctx context.Context, conn *Conn, spec *TableSpec) error

func (*Catalog) DeleteFunctionSpec added in v0.6.2 

func (c *Catalog) DeleteFunctionSpec(ctx context.Context, conn *Conn, name string) error

func (*Catalog) DeleteTableSpec added in v0.6.2 

func (c *Catalog) DeleteTableSpec(ctx context.Context, conn *Conn, name string) error

func (*Catalog) ExtendedTypeSuperTypes added in v0.9.0 

func (c *Catalog) ExtendedTypeSuperTypes(typ types.Type) (*types.TypeListView, error)

func (*Catalog) FindConnection added in v0.9.0 

func (c *Catalog) FindConnection(path []string) (types.Connection, error)

func (*Catalog) FindConstant added in v0.9.0 

func (c *Catalog) FindConstant(path []string) (types.Constant, int, error)

func (*Catalog) FindConversion added in v0.9.0 

func (c *Catalog) FindConversion(from, to types.Type) (types.Conversion, error)

func (*Catalog) FindFunction added in v0.9.0 

func (c *Catalog) FindFunction(path []string) (*types.Function, error)

func (*Catalog) FindModel added in v0.9.0 

func (c *Catalog) FindModel(path []string) (types.Model, error)

func (*Catalog) FindProcedure added in v0.9.0 

func (c *Catalog) FindProcedure(path []string) (*types.Procedure, error)

func (*Catalog) FindTable added in v0.9.0 

func (c *Catalog) FindTable(path []string) (types.Table, error)

func (*Catalog) FindTableValuedFunction added in v0.9.0 

func (c *Catalog) FindTableValuedFunction(path []string) (types.TableValuedFunction, error)

func (*Catalog) FindType added in v0.9.0 

func (c *Catalog) FindType(path []string) (types.Type, error)

func (*Catalog) FullName added in v0.9.0 

func (c *Catalog) FullName() string

func (*Catalog) SuggestConstant added in v0.9.0 

func (c *Catalog) SuggestConstant(mistypedPath []string) string

func (*Catalog) SuggestFunction added in v0.9.0 

func (c *Catalog) SuggestFunction(mistypedPath []string) string

func (*Catalog) SuggestModel added in v0.9.0 

func (c *Catalog) SuggestModel(mistypedPath []string) string

func (*Catalog) SuggestTable added in v0.9.0 

func (c *Catalog) SuggestTable(mistypedPath []string) string

func (*Catalog) SuggestTableValuedFunction added in v0.9.0 

func (c *Catalog) SuggestTableValuedFunction(mistypedPath []string) string

func (*Catalog) Sync 

func (c *Catalog) Sync(ctx context.Context, conn *Conn) error

type CatalogSpecKind 

type CatalogSpecKind string
const (
	TableSpecKind    CatalogSpecKind = "table"
	ViewSpecKind     CatalogSpecKind = "view"
	FunctionSpecKind CatalogSpecKind = "function"
)

type ChangedCatalog added in v0.16.0 

type ChangedCatalog struct {
	Table    *ChangedTable
	Function *ChangedFunction
}

func (*ChangedCatalog) Changed added in v0.16.0 

func (c *ChangedCatalog) Changed() bool

type ChangedFunction added in v0.16.0 

type ChangedFunction struct {
	Added   []*FunctionSpec
	Deleted []*FunctionSpec
}

func (*ChangedFunction) Changed added in v0.16.0 

func (f *ChangedFunction) Changed() bool

type ChangedTable added in v0.16.0 

type ChangedTable struct {
	Added   []*TableSpec
	Updated []*TableSpec
	Deleted []*TableSpec
}

func (*ChangedTable) Changed added in v0.16.0 

func (t *ChangedTable) Changed() bool

type CheckConstraintNode 

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

func (*CheckConstraintNode) FormatSQL 

func (n *CheckConstraintNode) FormatSQL(ctx context.Context) (string, error)

type CloneDataStmtNode 

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

func (*CloneDataStmtNode) FormatSQL 

func (n *CloneDataStmtNode) FormatSQL(ctx context.Context) (string, error)

type ColumnAnnotationsNode 

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

func (*ColumnAnnotationsNode) FormatSQL 

func (n *ColumnAnnotationsNode) FormatSQL(ctx context.Context) (string, error)

type ColumnDefaultValueNode 

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

func (*ColumnDefaultValueNode) FormatSQL 

func (n *ColumnDefaultValueNode) FormatSQL(ctx context.Context) (string, error)

type ColumnDefinitionNode 

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

func (*ColumnDefinitionNode) FormatSQL 

func (n *ColumnDefinitionNode) FormatSQL(ctx context.Context) (string, error)

type ColumnHolderNode 

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

func (*ColumnHolderNode) FormatSQL 

func (n *ColumnHolderNode) FormatSQL(ctx context.Context) (string, error)

type ColumnRefNode 

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

func (*ColumnRefNode) FormatSQL 

func (n *ColumnRefNode) FormatSQL(ctx context.Context) (string, error)

type ColumnSpec 

type ColumnSpec struct {
	Name      string `json:"name"`
	Type      *Type  `json:"type"`
	IsNotNull bool   `json:"isNotNull"`
}

func (*ColumnSpec) SQLiteSchema 

func (s *ColumnSpec) SQLiteSchema() string

type CombinationFormatTimeInfo added in v0.14.0 

type CombinationFormatTimeInfo struct {
	AvailableTypes []TimeFormatType
	Parse          func([]rune, *time.Time) (int, error)
	Format         func(*time.Time) ([]rune, error)
}

func (*CombinationFormatTimeInfo) Available added in v0.14.0 

func (i *CombinationFormatTimeInfo) Available(typ TimeFormatType) bool

type CommitStmtAction added in v0.8.8 

type CommitStmtAction struct{}

func (*CommitStmtAction) Args added in v0.8.8 

func (a *CommitStmtAction) Args() []interface{}

func (*CommitStmtAction) Cleanup added in v0.8.8 

func (a *CommitStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*CommitStmtAction) ExecContext added in v0.8.8 

func (a *CommitStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*CommitStmtAction) Prepare added in v0.8.8 

func (a *CommitStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*CommitStmtAction) QueryContext added in v0.8.8 

func (a *CommitStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type CommitStmtNode 

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

func (*CommitStmtNode) FormatSQL 

func (n *CommitStmtNode) FormatSQL(ctx context.Context) (string, error)

type ComputedColumnNode 

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

func (*ComputedColumnNode) FormatSQL 

func (n *ComputedColumnNode) FormatSQL(ctx context.Context) (string, error)

type Conn added in v0.4.1 

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

func NewConn added in v0.4.1 

func NewConn(conn *sql.Conn, tx *sql.Tx) *Conn

func (*Conn) ExecContext added in v0.4.1 

func (c *Conn) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*Conn) PrepareContext added in v0.4.1 

func (c *Conn) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*Conn) QueryContext added in v0.4.1 

func (c *Conn) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

type ConnectionNode 

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

func (*ConnectionNode) FormatSQL 

func (n *ConnectionNode) FormatSQL(ctx context.Context) (string, error)

type ConstantNode 

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

func (*ConstantNode) FormatSQL 

func (n *ConstantNode) FormatSQL(ctx context.Context) (string, error)

type CreateConstantStmtNode 

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

func (*CreateConstantStmtNode) FormatSQL 

func (n *CreateConstantStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateDatabaseStmtNode 

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

func (*CreateDatabaseStmtNode) FormatSQL 

func (n *CreateDatabaseStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateEntityStmtNode 

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

func (*CreateEntityStmtNode) FormatSQL 

func (n *CreateEntityStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateExternalTableStmtNode 

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

func (*CreateExternalTableStmtNode) FormatSQL 

func (n *CreateExternalTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateFunctionStmt 

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

func (*CreateFunctionStmt) Close 

func (s *CreateFunctionStmt) Close() error

func (*CreateFunctionStmt) Exec 

func (s *CreateFunctionStmt) Exec(args []driver.Value) (driver.Result, error)

func (*CreateFunctionStmt) NumInput 

func (s *CreateFunctionStmt) NumInput() int

func (*CreateFunctionStmt) Query 

func (s *CreateFunctionStmt) Query(args []driver.Value) (driver.Rows, error)

type CreateFunctionStmtAction added in v0.8.8 

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

func (*CreateFunctionStmtAction) Args added in v0.8.8 

func (a *CreateFunctionStmtAction) Args() []interface{}

func (*CreateFunctionStmtAction) Cleanup added in v0.8.8 

func (a *CreateFunctionStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*CreateFunctionStmtAction) ExecContext added in v0.8.8 

func (a *CreateFunctionStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*CreateFunctionStmtAction) Prepare added in v0.8.8 

func (a *CreateFunctionStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*CreateFunctionStmtAction) QueryContext added in v0.8.8 

func (a *CreateFunctionStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type CreateFunctionStmtNode 

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

func (*CreateFunctionStmtNode) FormatSQL 

func (n *CreateFunctionStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateIndexStmtNode 

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

func (*CreateIndexStmtNode) FormatSQL 

func (n *CreateIndexStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateMaterializedViewStmtNode 

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

func (*CreateMaterializedViewStmtNode) FormatSQL 

func (n *CreateMaterializedViewStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateModelStmtNode 

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

func (*CreateModelStmtNode) FormatSQL 

func (n *CreateModelStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreatePrivilegeRestrictionStmtNode 

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

func (*CreatePrivilegeRestrictionStmtNode) FormatSQL 

func (n *CreatePrivilegeRestrictionStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateProcedureStmtNode 

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

func (*CreateProcedureStmtNode) FormatSQL 

func (n *CreateProcedureStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateRowAccessPolicyStmtNode 

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

func (*CreateRowAccessPolicyStmtNode) FormatSQL 

func (n *CreateRowAccessPolicyStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateSchemaStmtNode 

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

func (*CreateSchemaStmtNode) FormatSQL 

func (n *CreateSchemaStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateSnapshotTableStmtNode 

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

func (*CreateSnapshotTableStmtNode) FormatSQL 

func (n *CreateSnapshotTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateTableAsSelectStmtNode 

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

func (*CreateTableAsSelectStmtNode) FormatSQL 

func (n *CreateTableAsSelectStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateTableFunctionStmtNode 

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

func (*CreateTableFunctionStmtNode) FormatSQL 

func (n *CreateTableFunctionStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateTableStmt 

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

func (*CreateTableStmt) Close 

func (s *CreateTableStmt) Close() error

func (*CreateTableStmt) Exec 

func (s *CreateTableStmt) Exec(args []driver.Value) (driver.Result, error)

func (*CreateTableStmt) NumInput 

func (s *CreateTableStmt) NumInput() int

func (*CreateTableStmt) Query 

func (s *CreateTableStmt) Query(args []driver.Value) (driver.Rows, error)

type CreateTableStmtAction added in v0.8.8 

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

func (*CreateTableStmtAction) Args added in v0.8.8 

func (a *CreateTableStmtAction) Args() []interface{}

func (*CreateTableStmtAction) Cleanup added in v0.8.8 

func (a *CreateTableStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*CreateTableStmtAction) ExecContext added in v0.8.8 

func (a *CreateTableStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*CreateTableStmtAction) Prepare added in v0.8.8 

func (a *CreateTableStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*CreateTableStmtAction) QueryContext added in v0.8.8 

func (a *CreateTableStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type CreateTableStmtNode 

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

func (*CreateTableStmtNode) FormatSQL 

func (n *CreateTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type CreateViewStmt added in v0.13.4 

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

func (*CreateViewStmt) Close added in v0.13.4 

func (s *CreateViewStmt) Close() error

func (*CreateViewStmt) Exec added in v0.13.4 

func (s *CreateViewStmt) Exec(args []driver.Value) (driver.Result, error)

func (*CreateViewStmt) NumInput added in v0.13.4 

func (s *CreateViewStmt) NumInput() int

func (*CreateViewStmt) Query added in v0.13.4 

func (s *CreateViewStmt) Query(args []driver.Value) (driver.Rows, error)

type CreateViewStmtAction added in v0.13.4 

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

func (*CreateViewStmtAction) Args added in v0.13.4 

func (a *CreateViewStmtAction) Args() []interface{}

func (*CreateViewStmtAction) Cleanup added in v0.13.4 

func (a *CreateViewStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*CreateViewStmtAction) ExecContext added in v0.13.4 

func (a *CreateViewStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*CreateViewStmtAction) Prepare added in v0.13.4 

func (a *CreateViewStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*CreateViewStmtAction) QueryContext added in v0.13.4 

func (a *CreateViewStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type CreateViewStmtNode 

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

func (*CreateViewStmtNode) FormatSQL 

func (n *CreateViewStmtNode) FormatSQL(ctx context.Context) (string, error)

type DMLDefaultNode 

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

func (*DMLDefaultNode) FormatSQL 

func (n *DMLDefaultNode) FormatSQL(ctx context.Context) (string, error)

type DMLStmt 

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

func (*DMLStmt) CheckNamedValue 

func (s *DMLStmt) CheckNamedValue(value *driver.NamedValue) error

func (*DMLStmt) Close 

func (s *DMLStmt) Close() error

func (*DMLStmt) Exec 

func (s *DMLStmt) Exec(args []driver.Value) (driver.Result, error)

func (*DMLStmt) ExecContext 

func (s *DMLStmt) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

func (*DMLStmt) NumInput 

func (s *DMLStmt) NumInput() int

func (*DMLStmt) Query 

func (s *DMLStmt) Query(args []driver.Value) (driver.Rows, error)

func (*DMLStmt) QueryContext 

func (s *DMLStmt) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type DMLStmtAction added in v0.8.8 

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

func (*DMLStmtAction) Args added in v0.8.8 

func (a *DMLStmtAction) Args() []interface{}

func (*DMLStmtAction) Cleanup added in v0.8.8 

func (a *DMLStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*DMLStmtAction) ExecContext added in v0.8.8 

func (a *DMLStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*DMLStmtAction) Prepare added in v0.8.8 

func (a *DMLStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*DMLStmtAction) QueryContext added in v0.8.8 

func (a *DMLStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type DMLValueNode 

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

func (*DMLValueNode) FormatSQL 

func (n *DMLValueNode) FormatSQL(ctx context.Context) (string, error)

type DateValue 

type DateValue time.Time

func (DateValue) Add 

func (d DateValue) Add(v Value) (Value, error)

func (DateValue) AddDateWithInterval 

func (d DateValue) AddDateWithInterval(v int, interval string) (Value, error)

func (DateValue) Div 

func (d DateValue) Div(v Value) (Value, error)

func (DateValue) EQ 

func (d DateValue) EQ(v Value) (bool, error)

func (DateValue) Format 

func (d DateValue) Format(verb rune) string

func (DateValue) GT 

func (d DateValue) GT(v Value) (bool, error)

func (DateValue) GTE 

func (d DateValue) GTE(v Value) (bool, error)

func (DateValue) Interface 

func (d DateValue) Interface() interface{}

func (DateValue) LT 

func (d DateValue) LT(v Value) (bool, error)

func (DateValue) LTE 

func (d DateValue) LTE(v Value) (bool, error)

func (DateValue) Mul 

func (d DateValue) Mul(v Value) (Value, error)

func (DateValue) Sub 

func (d DateValue) Sub(v Value) (Value, error)

func (DateValue) ToArray 

func (d DateValue) ToArray() (*ArrayValue, error)

func (DateValue) ToBool 

func (d DateValue) ToBool() (bool, error)

func (DateValue) ToBytes added in v0.7.0 

func (d DateValue) ToBytes() ([]byte, error)

func (DateValue) ToFloat64 

func (d DateValue) ToFloat64() (float64, error)

func (DateValue) ToInt64 

func (d DateValue) ToInt64() (int64, error)

func (DateValue) ToJSON 

func (d DateValue) ToJSON() (string, error)

func (DateValue) ToRat added in v0.6.2 

func (d DateValue) ToRat() (*big.Rat, error)

func (DateValue) ToString 

func (d DateValue) ToString() (string, error)

func (DateValue) ToStruct 

func (d DateValue) ToStruct() (*StructValue, error)

func (DateValue) ToTime 

func (d DateValue) ToTime() (time.Time, error)

type DatetimeValue 

type DatetimeValue time.Time

func (DatetimeValue) Add 

func (d DatetimeValue) Add(v Value) (Value, error)

func (DatetimeValue) Div 

func (d DatetimeValue) Div(v Value) (Value, error)

func (DatetimeValue) EQ 

func (d DatetimeValue) EQ(v Value) (bool, error)

func (DatetimeValue) Format 

func (d DatetimeValue) Format(verb rune) string

func (DatetimeValue) GT 

func (d DatetimeValue) GT(v Value) (bool, error)

func (DatetimeValue) GTE 

func (d DatetimeValue) GTE(v Value) (bool, error)

func (DatetimeValue) Interface 

func (d DatetimeValue) Interface() interface{}

func (DatetimeValue) LT 

func (d DatetimeValue) LT(v Value) (bool, error)

func (DatetimeValue) LTE 

func (d DatetimeValue) LTE(v Value) (bool, error)

func (DatetimeValue) Mul 

func (d DatetimeValue) Mul(v Value) (Value, error)

func (DatetimeValue) Sub 

func (d DatetimeValue) Sub(v Value) (Value, error)

func (DatetimeValue) ToArray 

func (d DatetimeValue) ToArray() (*ArrayValue, error)

func (DatetimeValue) ToBool 

func (d DatetimeValue) ToBool() (bool, error)

func (DatetimeValue) ToBytes added in v0.7.0 

func (d DatetimeValue) ToBytes() ([]byte, error)

func (DatetimeValue) ToFloat64 

func (d DatetimeValue) ToFloat64() (float64, error)

func (DatetimeValue) ToInt64 

func (d DatetimeValue) ToInt64() (int64, error)

func (DatetimeValue) ToJSON 

func (d DatetimeValue) ToJSON() (string, error)

func (DatetimeValue) ToRat added in v0.6.2 

func (d DatetimeValue) ToRat() (*big.Rat, error)

func (DatetimeValue) ToString 

func (d DatetimeValue) ToString() (string, error)

func (DatetimeValue) ToStruct 

func (d DatetimeValue) ToStruct() (*StructValue, error)

func (DatetimeValue) ToTime 

func (d DatetimeValue) ToTime() (time.Time, error)

type DayOfWeek added in v0.5.0 

type DayOfWeek string
const (
	Sunday    DayOfWeek = "Sunday"
	Monday    DayOfWeek = "Monday"
	Tuesday   DayOfWeek = "Tuesday"
	Wednesday DayOfWeek = "Wednesday"
	Thursday  DayOfWeek = "Thursday"
	Friday    DayOfWeek = "Friday"
	Saturday  DayOfWeek = "Saturday"
)

type DefineTableStmtNode 

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

func (*DefineTableStmtNode) FormatSQL 

func (n *DefineTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type DeleteStmtNode 

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

func (*DeleteStmtNode) FormatSQL 

func (n *DeleteStmtNode) FormatSQL(ctx context.Context) (string, error)

type DescribeStmtNode 

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

func (*DescribeStmtNode) FormatSQL 

func (n *DescribeStmtNode) FormatSQL(ctx context.Context) (string, error)

type DescriptorNode 

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

func (*DescriptorNode) FormatSQL 

func (n *DescriptorNode) FormatSQL(ctx context.Context) (string, error)

type DropColumnActionNode 

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

func (*DropColumnActionNode) FormatSQL 

func (n *DropColumnActionNode) FormatSQL(ctx context.Context) (string, error)

type DropConstraintActionNode 

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

func (*DropConstraintActionNode) FormatSQL 

func (n *DropConstraintActionNode) FormatSQL(ctx context.Context) (string, error)

type DropFunctionStmtNode 

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

func (*DropFunctionStmtNode) FormatSQL 

func (n *DropFunctionStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropMaterializedViewStmtNode 

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

func (*DropMaterializedViewStmtNode) FormatSQL 

func (n *DropMaterializedViewStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropPrimaryKeyActionNode 

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

func (*DropPrimaryKeyActionNode) FormatSQL 

func (n *DropPrimaryKeyActionNode) FormatSQL(ctx context.Context) (string, error)

type DropPrivilegeRestrictionStmtNode 

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

func (*DropPrivilegeRestrictionStmtNode) FormatSQL 

func (n *DropPrivilegeRestrictionStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropRowAccessPolicyStmtNode 

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

func (*DropRowAccessPolicyStmtNode) FormatSQL 

func (n *DropRowAccessPolicyStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropSearchIndexStmtNode 

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

func (*DropSearchIndexStmtNode) FormatSQL 

func (n *DropSearchIndexStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropSnapshotTableStmtNode 

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

func (*DropSnapshotTableStmtNode) FormatSQL 

func (n *DropSnapshotTableStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropStmtAction added in v0.8.8 

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

func (*DropStmtAction) Args added in v0.8.8 

func (a *DropStmtAction) Args() []interface{}

func (*DropStmtAction) Cleanup added in v0.8.8 

func (a *DropStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*DropStmtAction) ExecContext added in v0.8.8 

func (a *DropStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*DropStmtAction) Prepare added in v0.8.8 

func (a *DropStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*DropStmtAction) QueryContext added in v0.8.8 

func (a *DropStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type DropStmtNode 

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

func (*DropStmtNode) FormatSQL 

func (n *DropStmtNode) FormatSQL(ctx context.Context) (string, error)

type DropTableFunctionStmtNode 

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

func (*DropTableFunctionStmtNode) FormatSQL 

func (n *DropTableFunctionStmtNode) FormatSQL(ctx context.Context) (string, error)

type ErrorGroup added in v0.8.8 

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

func (*ErrorGroup) Add added in v0.8.8 

func (eg *ErrorGroup) Add(e error)

func (*ErrorGroup) Error added in v0.8.8 

func (eg *ErrorGroup) Error() string

func (*ErrorGroup) HasError added in v0.8.8 

func (eg *ErrorGroup) HasError() bool

type ExecuteImmediateArgumentNode 

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

func (*ExecuteImmediateArgumentNode) FormatSQL 

func (n *ExecuteImmediateArgumentNode) FormatSQL(ctx context.Context) (string, error)

type ExecuteImmediateStmtNode 

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

func (*ExecuteImmediateStmtNode) FormatSQL 

func (n *ExecuteImmediateStmtNode) FormatSQL(ctx context.Context) (string, error)

type ExplainStmtNode 

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

func (*ExplainStmtNode) FormatSQL 

func (n *ExplainStmtNode) FormatSQL(ctx context.Context) (string, error)

type ExportDataStmtNode 

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

func (*ExportDataStmtNode) FormatSQL 

func (n *ExportDataStmtNode) FormatSQL(ctx context.Context) (string, error)

type ExportModelStmtNode 

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

func (*ExportModelStmtNode) FormatSQL 

func (n *ExportModelStmtNode) FormatSQL(ctx context.Context) (string, error)

type ExpressionColumnNode 

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

func (*ExpressionColumnNode) FormatSQL 

func (n *ExpressionColumnNode) FormatSQL(ctx context.Context) (string, error)

type ExtendedCastElementNode 

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

func (*ExtendedCastElementNode) FormatSQL 

func (n *ExtendedCastElementNode) FormatSQL(ctx context.Context) (string, error)

type ExtendedCastNode 

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

func (*ExtendedCastNode) FormatSQL 

func (n *ExtendedCastNode) FormatSQL(ctx context.Context) (string, error)

type FilterFieldArgNode 

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

func (*FilterFieldArgNode) FormatSQL 

func (n *FilterFieldArgNode) FormatSQL(ctx context.Context) (string, error)

type FilterFieldNode 

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

func (*FilterFieldNode) FormatSQL 

func (n *FilterFieldNode) FormatSQL(ctx context.Context) (string, error)

type FilterScanNode 

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

func (*FilterScanNode) FormatSQL 

func (n *FilterScanNode) FormatSQL(ctx context.Context) (string, error)

type FilterUsingActionNode 

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

func (*FilterUsingActionNode) FormatSQL 

func (n *FilterUsingActionNode) FormatSQL(ctx context.Context) (string, error)

type FlattenNode 

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

func (*FlattenNode) FormatSQL 

func (n *FlattenNode) FormatSQL(ctx context.Context) (string, error)

type FlattenedArgNode 

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

func (*FlattenedArgNode) FormatSQL 

func (n *FlattenedArgNode) FormatSQL(ctx context.Context) (string, error)

type FloatValue 

type FloatValue float64

func (FloatValue) Add 

func (fv FloatValue) Add(v Value) (Value, error)

func (FloatValue) Div 

func (fv FloatValue) Div(v Value) (Value, error)

func (FloatValue) EQ 

func (fv FloatValue) EQ(v Value) (bool, error)

func (FloatValue) Format 

func (fv FloatValue) Format(verb rune) string

func (FloatValue) GT 

func (fv FloatValue) GT(v Value) (bool, error)

func (FloatValue) GTE 

func (fv FloatValue) GTE(v Value) (bool, error)

func (FloatValue) Interface 

func (fv FloatValue) Interface() interface{}

func (FloatValue) LT 

func (fv FloatValue) LT(v Value) (bool, error)

func (FloatValue) LTE 

func (fv FloatValue) LTE(v Value) (bool, error)

func (FloatValue) Mul 

func (fv FloatValue) Mul(v Value) (Value, error)

func (FloatValue) Sub 

func (fv FloatValue) Sub(v Value) (Value, error)

func (FloatValue) ToArray 

func (fv FloatValue) ToArray() (*ArrayValue, error)

func (FloatValue) ToBool 

func (fv FloatValue) ToBool() (bool, error)

func (FloatValue) ToBytes added in v0.7.0 

func (fv FloatValue) ToBytes() ([]byte, error)

func (FloatValue) ToFloat64 

func (fv FloatValue) ToFloat64() (float64, error)

func (FloatValue) ToInt64 

func (fv FloatValue) ToInt64() (int64, error)

func (FloatValue) ToJSON 

func (fv FloatValue) ToJSON() (string, error)

func (FloatValue) ToRat added in v0.6.2 

func (fv FloatValue) ToRat() (*big.Rat, error)

func (FloatValue) ToString 

func (fv FloatValue) ToString() (string, error)

func (FloatValue) ToStruct 

func (fv FloatValue) ToStruct() (*StructValue, error)

func (FloatValue) ToTime 

func (fv FloatValue) ToTime() (time.Time, error)

type ForeignKeyNode 

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

func (*ForeignKeyNode) FormatSQL 

func (n *ForeignKeyNode) FormatSQL(ctx context.Context) (string, error)

type FormatContext added in v0.11.3 

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

type FormatFlag added in v0.11.3 

type FormatFlag int
const (
	FormatFlagNone  FormatFlag = 0
	FormatFlagMinus FormatFlag = 1
	FormatFlagPlus  FormatFlag = 2
	FormatFlagSpace FormatFlag = 3
	FormatFlagSharp FormatFlag = 4
	FormatFlagZero  FormatFlag = 5
	FormatFlagQuote FormatFlag = 6
)

type FormatInfo added in v0.11.3 

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

type FormatParam added in v0.11.3 

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

type FormatPrecision added in v0.11.3 

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

type FormatTimeInfo added in v0.5.0 

type FormatTimeInfo struct {
	AvailableTypes []TimeFormatType
	Parse          ParseFunction
	Format         func(*time.Time) ([]rune, error)
}

func (*FormatTimeInfo) Available added in v0.5.0 

func (i *FormatTimeInfo) Available(typ TimeFormatType) bool

type FormatWidth added in v0.11.3 

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

type Formatter 

type Formatter interface {
	FormatSQL(context.Context) (string, error)
}

func New 

func New(node ast.Node) Formatter

type FuncInfo 

type FuncInfo struct {
	Name     string
	BindFunc BindFunction
}

type FunctionArgumentNode 

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

func (*FunctionArgumentNode) FormatSQL 

func (n *FunctionArgumentNode) FormatSQL(ctx context.Context) (string, error)

type FunctionCallNode 

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

func (*FunctionCallNode) FormatSQL 

func (n *FunctionCallNode) FormatSQL(ctx context.Context) (string, error)

type FunctionSignatureHolderNode 

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

func (*FunctionSignatureHolderNode) FormatSQL 

func (n *FunctionSignatureHolderNode) FormatSQL(ctx context.Context) (string, error)

type FunctionSpec 

type FunctionSpec struct {
	IsTemp    bool            `json:"isTemp"`
	NamePath  []string        `json:"name"`
	Language  string          `json:"language"`
	Args      []*NameWithType `json:"args"`
	Return    *Type           `json:"return"`
	Body      string          `json:"body"`
	Code      string          `json:"code"`
	UpdatedAt time.Time       `json:"updatedAt"`
	CreatedAt time.Time       `json:"createdAt"`
}

func (*FunctionSpec) CallSQL added in v0.9.0 

func (s *FunctionSpec) CallSQL(ctx context.Context, callNode *ast.BaseFunctionCallNode, argValues []string) (string, error)

func (*FunctionSpec) FuncName 

func (s *FunctionSpec) FuncName() string

func (*FunctionSpec) SQL 

func (s *FunctionSpec) SQL() string

type GeneratedColumnInfoNode 

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

func (*GeneratedColumnInfoNode) FormatSQL 

func (n *GeneratedColumnInfoNode) FormatSQL(ctx context.Context) (string, error)

type GetJsonFieldNode 

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

func (*GetJsonFieldNode) FormatSQL 

func (n *GetJsonFieldNode) FormatSQL(ctx context.Context) (string, error)

type GetProtoFieldNode 

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

func (*GetProtoFieldNode) FormatSQL 

func (n *GetProtoFieldNode) FormatSQL(ctx context.Context) (string, error)

type GetStructFieldNode 

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

func (*GetStructFieldNode) FormatSQL 

func (n *GetStructFieldNode) FormatSQL(ctx context.Context) (string, error)

type GrantStmtNode 

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

func (*GrantStmtNode) FormatSQL 

func (n *GrantStmtNode) FormatSQL(ctx context.Context) (string, error)

type GrantToActionNode 

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

func (*GrantToActionNode) FormatSQL 

func (n *GrantToActionNode) FormatSQL(ctx context.Context) (string, error)

type GroupRowsScanNode 

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

func (*GroupRowsScanNode) FormatSQL 

func (n *GroupRowsScanNode) FormatSQL(ctx context.Context) (string, error)

type GroupingSetNode 

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

func (*GroupingSetNode) FormatSQL 

func (n *GroupingSetNode) FormatSQL(ctx context.Context) (string, error)

type HLL_COUNT_INIT added in v0.13.0 

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

func (*HLL_COUNT_INIT) Done added in v0.13.0 

func (f *HLL_COUNT_INIT) Done() (Value, error)

func (*HLL_COUNT_INIT) Step added in v0.13.0 

func (f *HLL_COUNT_INIT) Step(input Value, precision int64, opt *AggregatorOption) (e error)

type HLL_COUNT_MERGE added in v0.13.0 

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

func (*HLL_COUNT_MERGE) Done added in v0.13.0 

func (f *HLL_COUNT_MERGE) Done() (Value, error)

func (*HLL_COUNT_MERGE) Step added in v0.13.0 

func (f *HLL_COUNT_MERGE) Step(sketch []byte, opt *AggregatorOption) error

type HLL_COUNT_MERGE_PARTIAL added in v0.13.0 

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

func (*HLL_COUNT_MERGE_PARTIAL) Done added in v0.13.0 

func (f *HLL_COUNT_MERGE_PARTIAL) Done() (Value, error)

func (*HLL_COUNT_MERGE_PARTIAL) Step added in v0.13.0 

func (f *HLL_COUNT_MERGE_PARTIAL) Step(sketch []byte, opt *AggregatorOption) error

type ImportStmtNode 

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

func (*ImportStmtNode) FormatSQL 

func (n *ImportStmtNode) FormatSQL(ctx context.Context) (string, error)

type IndexItemNode 

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

func (*IndexItemNode) FormatSQL 

func (n *IndexItemNode) FormatSQL(ctx context.Context) (string, error)

type InlineLambdaNode 

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

func (*InlineLambdaNode) FormatSQL 

func (n *InlineLambdaNode) FormatSQL(ctx context.Context) (string, error)

type InputPattern added in v0.4.1 

type InputPattern int
const (
	InputKeep      InputPattern = 0
	InputNeedsWrap InputPattern = 1
	InputNeedsFrom InputPattern = 2
)

type InsertRowNode 

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

func (*InsertRowNode) FormatSQL 

func (n *InsertRowNode) FormatSQL(ctx context.Context) (string, error)

type InsertStmtNode 

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

func (*InsertStmtNode) FormatSQL 

func (n *InsertStmtNode) FormatSQL(ctx context.Context) (string, error)

type IntValue 

type IntValue int64

func (IntValue) Add 

func (iv IntValue) Add(v Value) (Value, error)

func (IntValue) Div 

func (iv IntValue) Div(v Value) (Value, error)

func (IntValue) EQ 

func (iv IntValue) EQ(v Value) (bool, error)

func (IntValue) Format 

func (iv IntValue) Format(verb rune) string

func (IntValue) GT 

func (iv IntValue) GT(v Value) (bool, error)

func (IntValue) GTE 

func (iv IntValue) GTE(v Value) (bool, error)

func (IntValue) Interface 

func (iv IntValue) Interface() interface{}

func (IntValue) LT 

func (iv IntValue) LT(v Value) (bool, error)

func (IntValue) LTE 

func (iv IntValue) LTE(v Value) (bool, error)

func (IntValue) Mul 

func (iv IntValue) Mul(v Value) (Value, error)

func (IntValue) Sub 

func (iv IntValue) Sub(v Value) (Value, error)

func (IntValue) ToArray 

func (iv IntValue) ToArray() (*ArrayValue, error)

func (IntValue) ToBool 

func (iv IntValue) ToBool() (bool, error)

func (IntValue) ToBytes added in v0.7.0 

func (iv IntValue) ToBytes() ([]byte, error)

func (IntValue) ToFloat64 

func (iv IntValue) ToFloat64() (float64, error)

func (IntValue) ToInt64 

func (iv IntValue) ToInt64() (int64, error)

func (IntValue) ToJSON 

func (iv IntValue) ToJSON() (string, error)

func (IntValue) ToRat added in v0.6.2 

func (iv IntValue) ToRat() (*big.Rat, error)

func (IntValue) ToString 

func (iv IntValue) ToString() (string, error)

func (IntValue) ToStruct 

func (iv IntValue) ToStruct() (*StructValue, error)

func (IntValue) ToTime 

func (iv IntValue) ToTime() (time.Time, error)

type IntervalValue added in v0.8.0 

type IntervalValue struct {
	*bigquery.IntervalValue
}

func (*IntervalValue) Add added in v0.8.0 

func (iv *IntervalValue) Add(v Value) (Value, error)

func (*IntervalValue) Div added in v0.8.0 

func (iv *IntervalValue) Div(v Value) (Value, error)

func (*IntervalValue) EQ added in v0.8.0 

func (iv *IntervalValue) EQ(v Value) (bool, error)

func (*IntervalValue) Format added in v0.8.0 

func (iv *IntervalValue) Format(verb rune) string

func (*IntervalValue) GT added in v0.8.0 

func (iv *IntervalValue) GT(v Value) (bool, error)

func (*IntervalValue) GTE added in v0.8.0 

func (iv *IntervalValue) GTE(v Value) (bool, error)

func (*IntervalValue) Interface added in v0.8.0 

func (iv *IntervalValue) Interface() interface{}

func (*IntervalValue) LT added in v0.8.0 

func (iv *IntervalValue) LT(v Value) (bool, error)

func (*IntervalValue) LTE added in v0.8.0 

func (iv *IntervalValue) LTE(v Value) (bool, error)

func (*IntervalValue) Mul added in v0.8.0 

func (iv *IntervalValue) Mul(v Value) (Value, error)

func (*IntervalValue) Sub added in v0.8.0 

func (iv *IntervalValue) Sub(v Value) (Value, error)

func (*IntervalValue) ToArray added in v0.8.0 

func (iv *IntervalValue) ToArray() (*ArrayValue, error)

func (*IntervalValue) ToBool added in v0.8.0 

func (iv *IntervalValue) ToBool() (bool, error)

func (*IntervalValue) ToBytes added in v0.8.0 

func (iv *IntervalValue) ToBytes() ([]byte, error)

func (*IntervalValue) ToFloat64 added in v0.8.0 

func (iv *IntervalValue) ToFloat64() (float64, error)

func (*IntervalValue) ToInt64 added in v0.8.0 

func (iv *IntervalValue) ToInt64() (int64, error)

func (*IntervalValue) ToJSON added in v0.8.0 

func (iv *IntervalValue) ToJSON() (string, error)

func (*IntervalValue) ToRat added in v0.8.0 

func (iv *IntervalValue) ToRat() (*big.Rat, error)

func (*IntervalValue) ToString added in v0.8.0 

func (iv *IntervalValue) ToString() (string, error)

func (*IntervalValue) ToStruct added in v0.8.0 

func (iv *IntervalValue) ToStruct() (*StructValue, error)

func (*IntervalValue) ToTime added in v0.8.0 

func (iv *IntervalValue) ToTime() (time.Time, error)

type JoinScanNode 

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

func (*JoinScanNode) FormatSQL 

func (n *JoinScanNode) FormatSQL(ctx context.Context) (string, error)

type JsonValue added in v0.6.3 

type JsonValue string

func (JsonValue) Add added in v0.6.3 

func (jv JsonValue) Add(v Value) (Value, error)

func (JsonValue) Div added in v0.6.3 

func (jv JsonValue) Div(v Value) (Value, error)

func (JsonValue) EQ added in v0.6.3 

func (jv JsonValue) EQ(v Value) (bool, error)

func (JsonValue) Format added in v0.6.3 

func (jv JsonValue) Format(verb rune) string

func (JsonValue) GT added in v0.6.3 

func (jv JsonValue) GT(v Value) (bool, error)

func (JsonValue) GTE added in v0.6.3 

func (jv JsonValue) GTE(v Value) (bool, error)

func (JsonValue) Interface added in v0.6.3 

func (jv JsonValue) Interface() interface{}

func (JsonValue) LT added in v0.6.3 

func (jv JsonValue) LT(v Value) (bool, error)

func (JsonValue) LTE added in v0.6.3 

func (jv JsonValue) LTE(v Value) (bool, error)

func (JsonValue) Mul added in v0.6.3 

func (jv JsonValue) Mul(v Value) (Value, error)

func (JsonValue) Sub added in v0.6.3 

func (jv JsonValue) Sub(v Value) (Value, error)

func (JsonValue) ToArray added in v0.6.3 

func (jv JsonValue) ToArray() (*ArrayValue, error)

func (JsonValue) ToBool added in v0.6.3 

func (jv JsonValue) ToBool() (bool, error)

func (JsonValue) ToBytes added in v0.7.0 

func (jv JsonValue) ToBytes() ([]byte, error)

func (JsonValue) ToFloat64 added in v0.6.3 

func (jv JsonValue) ToFloat64() (float64, error)

func (JsonValue) ToInt64 added in v0.6.3 

func (jv JsonValue) ToInt64() (int64, error)

func (JsonValue) ToJSON added in v0.6.3 

func (jv JsonValue) ToJSON() (string, error)

func (JsonValue) ToRat added in v0.6.3 

func (jv JsonValue) ToRat() (*big.Rat, error)

func (JsonValue) ToString added in v0.6.3 

func (jv JsonValue) ToString() (string, error)

func (JsonValue) ToStruct added in v0.6.3 

func (jv JsonValue) ToStruct() (*StructValue, error)

func (JsonValue) ToTime added in v0.6.3 

func (jv JsonValue) ToTime() (time.Time, error)

func (JsonValue) Type added in v0.6.3 

func (jv JsonValue) Type() string

type LOGICAL_AND 

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

func (*LOGICAL_AND) Done 

func (f *LOGICAL_AND) Done() (Value, error)

func (*LOGICAL_AND) Step 

func (f *LOGICAL_AND) Step(cond Value, opt *AggregatorOption) error

type LOGICAL_OR 

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

func (*LOGICAL_OR) Done 

func (f *LOGICAL_OR) Done() (Value, error)

func (*LOGICAL_OR) Step 

func (f *LOGICAL_OR) Step(cond Value, opt *AggregatorOption) error

type LetExprNode 

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

func (*LetExprNode) FormatSQL 

func (n *LetExprNode) FormatSQL(ctx context.Context) (string, error)

type LimitOffsetScanNode 

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

func (*LimitOffsetScanNode) FormatSQL 

func (n *LimitOffsetScanNode) FormatSQL(ctx context.Context) (string, error)

type LiteralNode 

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

func (*LiteralNode) FormatSQL 

func (n *LiteralNode) FormatSQL(ctx context.Context) (string, error)

type MAX added in v0.4.1 

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

func (*MAX) Done added in v0.4.1 

func (f *MAX) Done() (Value, error)

func (*MAX) Step added in v0.4.1 

func (f *MAX) Step(v Value, opt *AggregatorOption) error

type MIN added in v0.4.1 

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

func (*MIN) Done added in v0.4.1 

func (f *MIN) Done() (Value, error)

func (*MIN) Step added in v0.4.1 

func (f *MIN) Step(v Value, opt *AggregatorOption) error

type MakeProtoFieldNode 

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

func (*MakeProtoFieldNode) FormatSQL 

func (n *MakeProtoFieldNode) FormatSQL(ctx context.Context) (string, error)

type MakeProtoNode 

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

func (*MakeProtoNode) FormatSQL 

func (n *MakeProtoNode) FormatSQL(ctx context.Context) (string, error)

type MakeStructNode 

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

func (*MakeStructNode) FormatSQL 

func (n *MakeStructNode) FormatSQL(ctx context.Context) (string, error)

type MergeStmtAction added in v0.8.8 

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

func (*MergeStmtAction) Args added in v0.8.8 

func (a *MergeStmtAction) Args() []interface{}

func (*MergeStmtAction) Cleanup added in v0.8.8 

func (a *MergeStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*MergeStmtAction) ExecContext added in v0.8.8 

func (a *MergeStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*MergeStmtAction) Prepare added in v0.8.8 

func (a *MergeStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*MergeStmtAction) QueryContext added in v0.8.8 

func (a *MergeStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type MergeStmtNode 

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

func (*MergeStmtNode) FormatSQL 

func (n *MergeStmtNode) FormatSQL(ctx context.Context) (string, error)

type MergeWhenNode 

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

func (*MergeWhenNode) FormatSQL 

func (n *MergeWhenNode) FormatSQL(ctx context.Context) (string, error)

type ModelNode 

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

func (*ModelNode) FormatSQL 

func (n *ModelNode) FormatSQL(ctx context.Context) (string, error)

type ModuleStmtNode 

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

func (*ModuleStmtNode) FormatSQL 

func (n *ModuleStmtNode) FormatSQL(ctx context.Context) (string, error)

type Month added in v0.5.0 

type Month string
const (
	January   Month = "January"
	February  Month = "February"
	March     Month = "March"
	April     Month = "April"
	May       Month = "May"
	June      Month = "June"
	July      Month = "July"
	August    Month = "August"
	September Month = "September"
	October   Month = "October"
	November  Month = "November"
	December  Month = "December"
)

type NameAndFunc added in v0.3.1 

type NameAndFunc struct {
	Name string
	Func interface{}
}

type NamePath added in v0.17.0 

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

type NameWithType 

type NameWithType struct {
	Name string `json:"name"`
	Type *Type  `json:"type"`
}

func (*NameWithType) FunctionArgumentType added in v0.9.0 

func (t *NameWithType) FunctionArgumentType() (*types.FunctionArgumentType, error)

type NumericValue added in v0.6.2 

type NumericValue struct {
	*big.Rat
	// contains filtered or unexported fields
}

func (*NumericValue) Add added in v0.6.2 

func (nv *NumericValue) Add(v Value) (Value, error)

func (*NumericValue) Div added in v0.6.2 

func (nv *NumericValue) Div(v Value) (ret Value, e error)

func (*NumericValue) EQ added in v0.6.2 

func (nv *NumericValue) EQ(v Value) (bool, error)

func (*NumericValue) Format added in v0.6.2 

func (nv *NumericValue) Format(verb rune) string

func (*NumericValue) GT added in v0.6.2 

func (nv *NumericValue) GT(v Value) (bool, error)

func (*NumericValue) GTE added in v0.6.2 

func (nv *NumericValue) GTE(v Value) (bool, error)

func (*NumericValue) Interface added in v0.6.2 

func (nv *NumericValue) Interface() interface{}

func (*NumericValue) LT added in v0.6.2 

func (nv *NumericValue) LT(v Value) (bool, error)

func (*NumericValue) LTE added in v0.6.2 

func (nv *NumericValue) LTE(v Value) (bool, error)

func (*NumericValue) Mul added in v0.6.2 

func (nv *NumericValue) Mul(v Value) (Value, error)

func (*NumericValue) Sub added in v0.6.2 

func (nv *NumericValue) Sub(v Value) (Value, error)

func (*NumericValue) ToArray added in v0.6.2 

func (nv *NumericValue) ToArray() (*ArrayValue, error)

func (*NumericValue) ToBool added in v0.6.2 

func (nv *NumericValue) ToBool() (bool, error)

func (*NumericValue) ToBytes added in v0.7.0 

func (nv *NumericValue) ToBytes() ([]byte, error)

func (*NumericValue) ToFloat64 added in v0.6.2 

func (nv *NumericValue) ToFloat64() (float64, error)

func (*NumericValue) ToInt64 added in v0.6.2 

func (nv *NumericValue) ToInt64() (int64, error)

func (*NumericValue) ToJSON added in v0.6.2 

func (nv *NumericValue) ToJSON() (string, error)

func (*NumericValue) ToRat added in v0.6.2 

func (nv *NumericValue) ToRat() (*big.Rat, error)

func (*NumericValue) ToString added in v0.6.2 

func (nv *NumericValue) ToString() (string, error)

func (*NumericValue) ToStruct added in v0.6.2 

func (nv *NumericValue) ToStruct() (*StructValue, error)

func (*NumericValue) ToTime added in v0.6.2 

func (nv *NumericValue) ToTime() (time.Time, error)

type ObjectUnitNode 

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

func (*ObjectUnitNode) FormatSQL 

func (n *ObjectUnitNode) FormatSQL(ctx context.Context) (string, error)

type OptionNode 

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

func (*OptionNode) FormatSQL 

func (n *OptionNode) FormatSQL(ctx context.Context) (string, error)

type OrderByItemNode 

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

func (*OrderByItemNode) FormatSQL 

func (n *OrderByItemNode) FormatSQL(ctx context.Context) (string, error)

type OrderByScanNode 

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

func (*OrderByScanNode) FormatSQL 

func (n *OrderByScanNode) FormatSQL(ctx context.Context) (string, error)

type OrderedValue 

type OrderedValue struct {
	OrderBy []*AggregateOrderBy
	Value   Value
}

type OutputColumnNode 

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

func (*OutputColumnNode) FormatSQL 

func (n *OutputColumnNode) FormatSQL(ctx context.Context) (string, error)

type ParameterNode 

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

func (*ParameterNode) FormatSQL 

func (n *ParameterNode) FormatSQL(ctx context.Context) (string, error)

type ParseFunction added in v0.19.1 

type ParseFunction func(text []rune, t *time.Time) (int, error)

type PartitionedValue 

type PartitionedValue struct {
	Partition string
	Value     *WindowOrderedValue
}

type PivotColumnNode 

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

func (*PivotColumnNode) FormatSQL 

func (n *PivotColumnNode) FormatSQL(ctx context.Context) (string, error)

type PivotScanNode 

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

func (*PivotScanNode) FormatSQL 

func (n *PivotScanNode) FormatSQL(ctx context.Context) (string, error)

type PrimaryKeyNode 

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

func (*PrimaryKeyNode) FormatSQL 

func (n *PrimaryKeyNode) FormatSQL(ctx context.Context) (string, error)

type PrivilegeNode 

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

func (*PrivilegeNode) FormatSQL 

func (n *PrivilegeNode) FormatSQL(ctx context.Context) (string, error)

type ProjectScanNode 

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

func (*ProjectScanNode) FormatSQL 

func (n *ProjectScanNode) FormatSQL(ctx context.Context) (string, error)

type QueryStmt 

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

func (*QueryStmt) CheckNamedValue 

func (s *QueryStmt) CheckNamedValue(value *driver.NamedValue) error

func (*QueryStmt) Close 

func (s *QueryStmt) Close() error

func (*QueryStmt) Exec 

func (s *QueryStmt) Exec(args []driver.Value) (driver.Result, error)

func (*QueryStmt) ExecContext 

func (s *QueryStmt) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

func (*QueryStmt) NumInput 

func (s *QueryStmt) NumInput() int

func (*QueryStmt) OutputColumns 

func (s *QueryStmt) OutputColumns() []*ColumnSpec

func (*QueryStmt) Query 

func (s *QueryStmt) Query(args []driver.Value) (driver.Rows, error)

func (*QueryStmt) QueryContext 

func (s *QueryStmt) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type QueryStmtAction added in v0.8.8 

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

func (*QueryStmtAction) Args added in v0.8.8 

func (a *QueryStmtAction) Args() []interface{}

func (*QueryStmtAction) Cleanup added in v0.8.8 

func (a *QueryStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*QueryStmtAction) ExecContext added in v0.8.8 

func (a *QueryStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*QueryStmtAction) ExplainQueryPlan added in v0.12.0 

func (a *QueryStmtAction) ExplainQueryPlan(ctx context.Context, conn *Conn) error

func (*QueryStmtAction) Prepare added in v0.8.8 

func (a *QueryStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*QueryStmtAction) QueryContext added in v0.8.8 

func (a *QueryStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type QueryStmtNode 

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

func (*QueryStmtNode) FormatSQL 

func (n *QueryStmtNode) FormatSQL(ctx context.Context) (string, error)

FormatSQL Formats the outermost query statement that runs and produces rows of output, like a SELECT The node's `OutputColumnList()` gives user-visible column names that should be returned. There may be duplicate names, and multiple output columns may reference the same column from `Query()` https://github.com/google/zetasql/blob/master/docs/resolved_ast.md#ResolvedQueryStmt

type RecursiveRefScanNode 

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

func (*RecursiveRefScanNode) FormatSQL 

func (n *RecursiveRefScanNode) FormatSQL(ctx context.Context) (string, error)

type RecursiveScanNode 

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

func (*RecursiveScanNode) FormatSQL 

func (n *RecursiveScanNode) FormatSQL(ctx context.Context) (string, error)

type RelationArgumentScanNode 

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

func (*RelationArgumentScanNode) FormatSQL 

func (n *RelationArgumentScanNode) FormatSQL(ctx context.Context) (string, error)

type RemoveFromRestricteeListActionNode 

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

func (*RemoveFromRestricteeListActionNode) FormatSQL 

func (n *RemoveFromRestricteeListActionNode) FormatSQL(ctx context.Context) (string, error)

type RenameColumnActionNode 

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

func (*RenameColumnActionNode) FormatSQL 

func (n *RenameColumnActionNode) FormatSQL(ctx context.Context) (string, error)

type RenameStmtNode 

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

func (*RenameStmtNode) FormatSQL 

func (n *RenameStmtNode) FormatSQL(ctx context.Context) (string, error)

type RenameToActionNode 

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

func (*RenameToActionNode) FormatSQL 

func (n *RenameToActionNode) FormatSQL(ctx context.Context) (string, error)

type ReplaceFieldItemNode 

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

func (*ReplaceFieldItemNode) FormatSQL 

func (n *ReplaceFieldItemNode) FormatSQL(ctx context.Context) (string, error)

type ReplaceFieldNode 

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

func (*ReplaceFieldNode) FormatSQL 

func (n *ReplaceFieldNode) FormatSQL(ctx context.Context) (string, error)

type RestrictToActionNode 

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

func (*RestrictToActionNode) FormatSQL 

func (n *RestrictToActionNode) FormatSQL(ctx context.Context) (string, error)

type Result added in v0.16.0 

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

func (*Result) ChangedCatalog added in v0.16.0 

func (r *Result) ChangedCatalog() *ChangedCatalog

func (*Result) LastInsertId added in v0.16.0 

func (r *Result) LastInsertId() (int64, error)

func (*Result) RowsAffected added in v0.16.0 

func (r *Result) RowsAffected() (int64, error)

type ReturningClauseNode 

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

func (*ReturningClauseNode) FormatSQL 

func (n *ReturningClauseNode) FormatSQL(ctx context.Context) (string, error)

type RevokeFromActionNode 

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

func (*RevokeFromActionNode) FormatSQL 

func (n *RevokeFromActionNode) FormatSQL(ctx context.Context) (string, error)

type RevokeStmtNode 

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

func (*RevokeStmtNode) FormatSQL 

func (n *RevokeStmtNode) FormatSQL(ctx context.Context) (string, error)

type RollbackStmtNode 

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

func (*RollbackStmtNode) FormatSQL 

func (n *RollbackStmtNode) FormatSQL(ctx context.Context) (string, error)

type Rows 

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

func (*Rows) ChangedCatalog added in v0.16.0 

func (r *Rows) ChangedCatalog() *ChangedCatalog

func (*Rows) Close 

func (r *Rows) Close() (e error)

func (*Rows) ColumnTypeDatabaseTypeName 

func (r *Rows) ColumnTypeDatabaseTypeName(i int) string

func (*Rows) Columns 

func (r *Rows) Columns() []string

func (*Rows) Next 

func (r *Rows) Next(dest []driver.Value) error

func (*Rows) SetActions added in v0.8.8 

func (r *Rows) SetActions(actions []StmtAction)

type RunBatchStmtNode 

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

func (*RunBatchStmtNode) FormatSQL 

func (n *RunBatchStmtNode) FormatSQL(ctx context.Context) (string, error)

type SQLiteFunction 

type SQLiteFunction func(...interface{}) (interface{}, error)

type STDDEV added in v0.12.0 

type STDDEV = STDDEV_SAMP

type STDDEV_POP added in v0.12.0 

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

func (*STDDEV_POP) Done added in v0.12.0 

func (f *STDDEV_POP) Done() (Value, error)

func (*STDDEV_POP) Step added in v0.12.0 

func (f *STDDEV_POP) Step(v Value, opt *AggregatorOption) error

type STDDEV_SAMP added in v0.12.0 

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

func (*STDDEV_SAMP) Done added in v0.12.0 

func (f *STDDEV_SAMP) Done() (Value, error)

func (*STDDEV_SAMP) Step added in v0.12.0 

func (f *STDDEV_SAMP) Step(v Value, opt *AggregatorOption) error

type STRING_AGG 

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

func (*STRING_AGG) Done 

func (f *STRING_AGG) Done() (Value, error)

func (*STRING_AGG) Step 

func (f *STRING_AGG) Step(v Value, delim string, opt *AggregatorOption) error

type SUM 

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

func (*SUM) Done 

func (f *SUM) Done() (Value, error)

func (*SUM) Step 

func (f *SUM) Step(v Value, opt *AggregatorOption) error

type SafeValue added in v0.4.1 

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

func (*SafeValue) Add added in v0.4.1 

func (v *SafeValue) Add(arg Value) (Value, error)

func (*SafeValue) Div added in v0.4.1 

func (v *SafeValue) Div(arg Value) (Value, error)

func (*SafeValue) EQ added in v0.4.1 

func (v *SafeValue) EQ(arg Value) (bool, error)

func (*SafeValue) Format added in v0.4.1 

func (v *SafeValue) Format(verb rune) string

func (*SafeValue) GT added in v0.4.1 

func (v *SafeValue) GT(arg Value) (bool, error)

func (*SafeValue) GTE added in v0.4.1 

func (v *SafeValue) GTE(arg Value) (bool, error)

func (*SafeValue) Interface added in v0.4.1 

func (v *SafeValue) Interface() interface{}

func (*SafeValue) LT added in v0.4.1 

func (v *SafeValue) LT(arg Value) (bool, error)

func (*SafeValue) LTE added in v0.4.1 

func (v *SafeValue) LTE(arg Value) (bool, error)

func (*SafeValue) Mul added in v0.4.1 

func (v *SafeValue) Mul(arg Value) (Value, error)

func (*SafeValue) Sub added in v0.4.1 

func (v *SafeValue) Sub(arg Value) (Value, error)

func (*SafeValue) ToArray added in v0.4.1 

func (v *SafeValue) ToArray() (*ArrayValue, error)

func (*SafeValue) ToBool added in v0.4.1 

func (v *SafeValue) ToBool() (bool, error)

func (*SafeValue) ToBytes added in v0.7.0 

func (v *SafeValue) ToBytes() ([]byte, error)

func (*SafeValue) ToFloat64 added in v0.4.1 

func (v *SafeValue) ToFloat64() (float64, error)

func (*SafeValue) ToInt64 added in v0.4.1 

func (v *SafeValue) ToInt64() (int64, error)

func (*SafeValue) ToJSON added in v0.4.1 

func (v *SafeValue) ToJSON() (string, error)

func (*SafeValue) ToRat added in v0.6.2 

func (v *SafeValue) ToRat() (*big.Rat, error)

func (*SafeValue) ToString added in v0.4.1 

func (v *SafeValue) ToString() (string, error)

func (*SafeValue) ToStruct added in v0.4.1 

func (v *SafeValue) ToStruct() (*StructValue, error)

func (*SafeValue) ToTime added in v0.4.1 

func (v *SafeValue) ToTime() (time.Time, error)

type SampleScanNode 

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

func (*SampleScanNode) FormatSQL 

func (n *SampleScanNode) FormatSQL(ctx context.Context) (string, error)

type SetAsActionNode 

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

func (*SetAsActionNode) FormatSQL 

func (n *SetAsActionNode) FormatSQL(ctx context.Context) (string, error)

type SetCollateClauseNode 

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

func (*SetCollateClauseNode) FormatSQL 

func (n *SetCollateClauseNode) FormatSQL(ctx context.Context) (string, error)

type SetOperationItemNode 

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

func (*SetOperationItemNode) FormatSQL 

func (n *SetOperationItemNode) FormatSQL(ctx context.Context) (string, error)

type SetOperationScanNode 

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

func (*SetOperationScanNode) FormatSQL 

func (n *SetOperationScanNode) FormatSQL(ctx context.Context) (string, error)

type SetOptionsActionNode 

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

func (*SetOptionsActionNode) FormatSQL 

func (n *SetOptionsActionNode) FormatSQL(ctx context.Context) (string, error)

type SetTransactionStmtNode 

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

func (*SetTransactionStmtNode) FormatSQL 

func (n *SetTransactionStmtNode) FormatSQL(ctx context.Context) (string, error)

type ShowStmtNode 

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

func (*ShowStmtNode) FormatSQL 

func (n *ShowStmtNode) FormatSQL(ctx context.Context) (string, error)

type SingleRowScanNode 

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

func (*SingleRowScanNode) FormatSQL 

func (n *SingleRowScanNode) FormatSQL(ctx context.Context) (string, error)

type StartBatchStmtNode 

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

func (*StartBatchStmtNode) FormatSQL 

func (n *StartBatchStmtNode) FormatSQL(ctx context.Context) (string, error)

type StmtAction added in v0.8.8 

type StmtAction interface {
	Prepare(context.Context, *Conn) (driver.Stmt, error)
	ExecContext(context.Context, *Conn) (driver.Result, error)
	QueryContext(context.Context, *Conn) (*Rows, error)
	Cleanup(context.Context, *Conn) error
	Args() []interface{}
}

type StmtActionFunc added in v0.8.8 

type StmtActionFunc func() (StmtAction, error)

type StringValue 

type StringValue string

func (StringValue) Add 

func (sv StringValue) Add(v Value) (Value, error)

func (StringValue) Div 

func (sv StringValue) Div(v Value) (Value, error)

func (StringValue) EQ 

func (sv StringValue) EQ(v Value) (bool, error)

func (StringValue) Format 

func (sv StringValue) Format(verb rune) string

func (StringValue) GT 

func (sv StringValue) GT(v Value) (bool, error)

func (StringValue) GTE 

func (sv StringValue) GTE(v Value) (bool, error)

func (StringValue) Interface 

func (sv StringValue) Interface() interface{}

func (StringValue) LT 

func (sv StringValue) LT(v Value) (bool, error)

func (StringValue) LTE 

func (sv StringValue) LTE(v Value) (bool, error)

func (StringValue) Mul 

func (sv StringValue) Mul(v Value) (Value, error)

func (StringValue) Sub 

func (sv StringValue) Sub(v Value) (Value, error)

func (StringValue) ToArray 

func (sv StringValue) ToArray() (*ArrayValue, error)

func (StringValue) ToBool 

func (sv StringValue) ToBool() (bool, error)

func (StringValue) ToBytes added in v0.7.0 

func (sv StringValue) ToBytes() ([]byte, error)

func (StringValue) ToFloat64 

func (sv StringValue) ToFloat64() (float64, error)

func (StringValue) ToInt64 

func (sv StringValue) ToInt64() (int64, error)

func (StringValue) ToJSON 

func (sv StringValue) ToJSON() (string, error)

func (StringValue) ToRat added in v0.6.2 

func (sv StringValue) ToRat() (*big.Rat, error)

func (StringValue) ToString 

func (sv StringValue) ToString() (string, error)

func (StringValue) ToStruct 

func (sv StringValue) ToStruct() (*StructValue, error)

func (StringValue) ToTime 

func (sv StringValue) ToTime() (time.Time, error)

type StructValue 

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

func (*StructValue) Add 

func (sv *StructValue) Add(v Value) (Value, error)

func (*StructValue) Div 

func (sv *StructValue) Div(v Value) (Value, error)

func (*StructValue) EQ 

func (sv *StructValue) EQ(v Value) (bool, error)

func (*StructValue) Format 

func (sv *StructValue) Format(verb rune) string

func (*StructValue) GT 

func (sv *StructValue) GT(v Value) (bool, error)

func (*StructValue) GTE 

func (sv *StructValue) GTE(v Value) (bool, error)

func (*StructValue) Interface 

func (sv *StructValue) Interface() interface{}

func (*StructValue) LT 

func (sv *StructValue) LT(v Value) (bool, error)

func (*StructValue) LTE 

func (sv *StructValue) LTE(v Value) (bool, error)

func (*StructValue) Mul 

func (sv *StructValue) Mul(v Value) (Value, error)

func (*StructValue) Sub 

func (sv *StructValue) Sub(v Value) (Value, error)

func (*StructValue) ToArray 

func (sv *StructValue) ToArray() (*ArrayValue, error)

func (*StructValue) ToBool 

func (sv *StructValue) ToBool() (bool, error)

func (*StructValue) ToBytes added in v0.7.0 

func (sv *StructValue) ToBytes() ([]byte, error)

func (*StructValue) ToFloat64 

func (sv *StructValue) ToFloat64() (float64, error)

func (*StructValue) ToInt64 

func (sv *StructValue) ToInt64() (int64, error)

func (*StructValue) ToJSON 

func (sv *StructValue) ToJSON() (string, error)

func (*StructValue) ToRat added in v0.6.2 

func (sv *StructValue) ToRat() (*big.Rat, error)

func (*StructValue) ToString 

func (sv *StructValue) ToString() (string, error)

func (*StructValue) ToStruct 

func (sv *StructValue) ToStruct() (*StructValue, error)

func (*StructValue) ToTime 

func (sv *StructValue) ToTime() (time.Time, error)

type StructValueLayout added in v0.8.0 

type StructValueLayout struct {
	Keys   []string      `json:"keys"`
	Values []interface{} `json:"values"`
}

type SubqueryExprNode 

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

func (*SubqueryExprNode) FormatSQL 

func (n *SubqueryExprNode) FormatSQL(ctx context.Context) (string, error)

type SystemVariableNode 

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

func (*SystemVariableNode) FormatSQL 

func (n *SystemVariableNode) FormatSQL(ctx context.Context) (string, error)

type TVFScanNode 

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

func (*TVFScanNode) FormatSQL 

func (n *TVFScanNode) FormatSQL(ctx context.Context) (string, error)

type TableAndColumnInfoNode 

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

func (*TableAndColumnInfoNode) FormatSQL 

func (n *TableAndColumnInfoNode) FormatSQL(ctx context.Context) (string, error)

type TableScanNode 

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

func (*TableScanNode) FormatSQL 

func (n *TableScanNode) FormatSQL(ctx context.Context) (string, error)

type TableSpec 

type TableSpec struct {
	IsTemp     bool           `json:"isTemp"`
	IsView     bool           `json:"isView"`
	NamePath   []string       `json:"namePath"`
	Columns    []*ColumnSpec  `json:"columns"`
	PrimaryKey []string       `json:"primaryKey"`
	CreateMode ast.CreateMode `json:"createMode"`
	Query      string         `json:"query"`
	UpdatedAt  time.Time      `json:"updatedAt"`
	CreatedAt  time.Time      `json:"createdAt"`
}

func (*TableSpec) Column 

func (s *TableSpec) Column(name string) *ColumnSpec

func (*TableSpec) SQLiteSchema 

func (s *TableSpec) SQLiteSchema() string

func (*TableSpec) TableName 

func (s *TableSpec) TableName() string

type TimeFormatType added in v0.5.0 

type TimeFormatType int
const (
	FormatTypeDate      TimeFormatType = 0
	FormatTypeDatetime  TimeFormatType = 1
	FormatTypeTime      TimeFormatType = 2
	FormatTypeTimestamp TimeFormatType = 3
)

func (TimeFormatType) String added in v0.5.0 

func (t TimeFormatType) String() string

type TimeParserPostProcessor added in v0.19.1 

type TimeParserPostProcessor struct {
	ShouldPostProcessResult func(map[rune][2]int) bool
	PostProcessResult       func([]rune, *time.Time)
}

type TimeValue 

type TimeValue time.Time

func (TimeValue) Add 

func (t TimeValue) Add(v Value) (Value, error)

func (TimeValue) Div 

func (t TimeValue) Div(v Value) (Value, error)

func (TimeValue) EQ 

func (t TimeValue) EQ(v Value) (bool, error)

func (TimeValue) Format 

func (t TimeValue) Format(verb rune) string

func (TimeValue) GT 

func (t TimeValue) GT(v Value) (bool, error)

func (TimeValue) GTE 

func (t TimeValue) GTE(v Value) (bool, error)

func (TimeValue) Interface 

func (t TimeValue) Interface() interface{}

func (TimeValue) LT 

func (t TimeValue) LT(v Value) (bool, error)

func (TimeValue) LTE 

func (t TimeValue) LTE(v Value) (bool, error)

func (TimeValue) Mul 

func (t TimeValue) Mul(v Value) (Value, error)

func (TimeValue) Sub 

func (t TimeValue) Sub(v Value) (Value, error)

func (TimeValue) ToArray 

func (t TimeValue) ToArray() (*ArrayValue, error)

func (TimeValue) ToBool 

func (t TimeValue) ToBool() (bool, error)

func (TimeValue) ToBytes added in v0.7.0 

func (t TimeValue) ToBytes() ([]byte, error)

func (TimeValue) ToFloat64 

func (t TimeValue) ToFloat64() (float64, error)

func (TimeValue) ToInt64 

func (t TimeValue) ToInt64() (int64, error)

func (TimeValue) ToJSON 

func (t TimeValue) ToJSON() (string, error)

func (TimeValue) ToRat added in v0.6.2 

func (t TimeValue) ToRat() (*big.Rat, error)

func (TimeValue) ToString 

func (t TimeValue) ToString() (string, error)

func (TimeValue) ToStruct 

func (t TimeValue) ToStruct() (*StructValue, error)

func (TimeValue) ToTime 

func (t TimeValue) ToTime() (time.Time, error)

type TimestampValue 

type TimestampValue time.Time

func (TimestampValue) Add 

func (t TimestampValue) Add(v Value) (Value, error)

func (TimestampValue) AddValueWithPart 

func (t TimestampValue) AddValueWithPart(v int64, part string) (Value, error)

func (TimestampValue) Div 

func (t TimestampValue) Div(v Value) (Value, error)

func (TimestampValue) EQ 

func (t TimestampValue) EQ(v Value) (bool, error)

func (TimestampValue) Format 

func (t TimestampValue) Format(verb rune) string

func (TimestampValue) GT 

func (t TimestampValue) GT(v Value) (bool, error)

func (TimestampValue) GTE 

func (t TimestampValue) GTE(v Value) (bool, error)

func (TimestampValue) Interface 

func (t TimestampValue) Interface() interface{}

func (TimestampValue) LT 

func (t TimestampValue) LT(v Value) (bool, error)

func (TimestampValue) LTE 

func (t TimestampValue) LTE(v Value) (bool, error)

func (TimestampValue) Mul 

func (t TimestampValue) Mul(v Value) (Value, error)

func (TimestampValue) Sub 

func (t TimestampValue) Sub(v Value) (Value, error)

func (TimestampValue) ToArray 

func (t TimestampValue) ToArray() (*ArrayValue, error)

func (TimestampValue) ToBool 

func (t TimestampValue) ToBool() (bool, error)

func (TimestampValue) ToBytes added in v0.7.0 

func (t TimestampValue) ToBytes() ([]byte, error)

func (TimestampValue) ToFloat64 

func (t TimestampValue) ToFloat64() (float64, error)

func (TimestampValue) ToInt64 

func (t TimestampValue) ToInt64() (int64, error)

func (TimestampValue) ToJSON 

func (t TimestampValue) ToJSON() (string, error)

func (TimestampValue) ToRat added in v0.6.2 

func (t TimestampValue) ToRat() (*big.Rat, error)

func (TimestampValue) ToString 

func (t TimestampValue) ToString() (string, error)

func (TimestampValue) ToStruct 

func (t TimestampValue) ToStruct() (*StructValue, error)

func (TimestampValue) ToTime 

func (t TimestampValue) ToTime() (time.Time, error)

type TruncateStmtAction added in v0.8.8 

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

func (*TruncateStmtAction) Args added in v0.8.8 

func (a *TruncateStmtAction) Args() []interface{}

func (*TruncateStmtAction) Cleanup added in v0.8.8 

func (a *TruncateStmtAction) Cleanup(ctx context.Context, conn *Conn) error

func (*TruncateStmtAction) ExecContext added in v0.8.8 

func (a *TruncateStmtAction) ExecContext(ctx context.Context, conn *Conn) (driver.Result, error)

func (*TruncateStmtAction) Prepare added in v0.8.8 

func (a *TruncateStmtAction) Prepare(ctx context.Context, conn *Conn) (driver.Stmt, error)

func (*TruncateStmtAction) QueryContext added in v0.8.8 

func (a *TruncateStmtAction) QueryContext(ctx context.Context, conn *Conn) (*Rows, error)

type TruncateStmtNode 

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

func (*TruncateStmtNode) FormatSQL 

func (n *TruncateStmtNode) FormatSQL(ctx context.Context) (string, error)

type Type 

type Type struct {
	Name          string                      `json:"name"`
	Kind          int                         `json:"kind"`
	SignatureKind types.SignatureArgumentKind `json:"signatureKind"`
	ElementType   *Type                       `json:"elementType"`
	FieldTypes    []*NameWithType             `json:"fieldTypes"`
}

func (*Type) AvailableAutoIndex added in v0.12.0 

func (t *Type) AvailableAutoIndex() bool

func (*Type) FormatType added in v0.9.0 

func (t *Type) FormatType() string

func (*Type) FunctionArgumentType added in v0.9.0 

func (t *Type) FunctionArgumentType() (*types.FunctionArgumentType, error)

func (*Type) GoReflectType added in v0.6.6 

func (t *Type) GoReflectType() (reflect.Type, error)

func (*Type) IsArray 

func (t *Type) IsArray() bool

func (*Type) IsStruct 

func (t *Type) IsStruct() bool

func (*Type) ToZetaSQLType 

func (t *Type) ToZetaSQLType() (types.Type, error)

type UnnestItemNode 

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

func (*UnnestItemNode) FormatSQL 

func (n *UnnestItemNode) FormatSQL(ctx context.Context) (string, error)

type UnpivotArgNode 

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

func (*UnpivotArgNode) FormatSQL 

func (n *UnpivotArgNode) FormatSQL(ctx context.Context) (string, error)

type UnpivotScanNode 

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

func (*UnpivotScanNode) FormatSQL 

func (n *UnpivotScanNode) FormatSQL(ctx context.Context) (string, error)

type UpdateArrayItemNode 

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

func (*UpdateArrayItemNode) FormatSQL 

func (n *UpdateArrayItemNode) FormatSQL(ctx context.Context) (string, error)

type UpdateItemNode 

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

func (*UpdateItemNode) FormatSQL 

func (n *UpdateItemNode) FormatSQL(ctx context.Context) (string, error)

type UpdateStmtNode 

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

func (*UpdateStmtNode) FormatSQL 

func (n *UpdateStmtNode) FormatSQL(ctx context.Context) (string, error)

type VARIANCE added in v0.12.0 

type VARIANCE = VAR_SAMP

type VAR_POP added in v0.12.0 

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

func (*VAR_POP) Done added in v0.12.0 

func (f *VAR_POP) Done() (Value, error)

func (*VAR_POP) Step added in v0.12.0 

func (f *VAR_POP) Step(v Value, opt *AggregatorOption) error

type VAR_SAMP added in v0.12.0 

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

func (*VAR_SAMP) Done added in v0.12.0 

func (f *VAR_SAMP) Done() (Value, error)

func (*VAR_SAMP) Step added in v0.12.0 

func (f *VAR_SAMP) Step(v Value, opt *AggregatorOption) error

type Value 

type Value interface {
	Add(Value) (Value, error)
	Sub(Value) (Value, error)
	Mul(Value) (Value, error)
	Div(Value) (Value, error)
	EQ(Value) (bool, error)
	GT(Value) (bool, error)
	GTE(Value) (bool, error)
	LT(Value) (bool, error)
	LTE(Value) (bool, error)
	ToInt64() (int64, error)
	ToString() (string, error)
	ToBytes() ([]byte, error)
	ToFloat64() (float64, error)
	ToBool() (bool, error)
	ToArray() (*ArrayValue, error)
	ToStruct() (*StructValue, error)
	ToJSON() (string, error)
	ToTime() (time.Time, error)
	ToRat() (*big.Rat, error)
	Format(verb rune) string
	Interface() interface{}
}

func ABS 

func ABS(a Value) (Value, error)

func ACOS 

func ACOS(x Value) (Value, error)

func ACOSH 

func ACOSH(x Value) (Value, error)

func ADD 

func ADD(a, b Value) (Value, error)

func AND 

func AND(args ...Value) (Value, error)

func ARRAY_CONCAT 

func ARRAY_CONCAT(args ...Value) (Value, error)

func ARRAY_IN 

func ARRAY_IN(a, b Value) (Value, error)

func ARRAY_LENGTH 

func ARRAY_LENGTH(v *ArrayValue) (Value, error)

func ARRAY_OFFSET 

func ARRAY_OFFSET(v Value, idx int) (Value, error)

func ARRAY_ORDINAL 

func ARRAY_ORDINAL(v Value, idx int) (Value, error)

func ARRAY_REVERSE 

func ARRAY_REVERSE(v *ArrayValue) (Value, error)

func ARRAY_SAFE_OFFSET 

func ARRAY_SAFE_OFFSET(v Value, idx int) (Value, error)

func ARRAY_SAFE_ORDINAL 

func ARRAY_SAFE_ORDINAL(v Value, idx int) (Value, error)

func ARRAY_TO_STRING 

func ARRAY_TO_STRING(arr *ArrayValue, delim string, nullText ...string) (Value, error)

func ASCII added in v0.7.0 

func ASCII(v string) (Value, error)

func ASIN 

func ASIN(x Value) (Value, error)

func ASINH 

func ASINH(x Value) (Value, error)

func ATAN 

func ATAN(x Value) (Value, error)

func ATAN2 

func ATAN2(x, y Value) (Value, error)

func ATANH 

func ATANH(x Value) (Value, error)

func BETWEEN 

func BETWEEN(target, start, end Value) (Value, error)

func BIT_AND 

func BIT_AND(a, b Value) (Value, error)

func BIT_COUNT added in v0.13.0 

func BIT_COUNT(v Value) (Value, error)

func BIT_LEFT_SHIFT 

func BIT_LEFT_SHIFT(a, b Value) (Value, error)

func BIT_NOT 

func BIT_NOT(a Value) (Value, error)

func BIT_OR 

func BIT_OR(a, b Value) (Value, error)

func BIT_RIGHT_SHIFT 

func BIT_RIGHT_SHIFT(a, b Value) (Value, error)

func BIT_XOR 

func BIT_XOR(a, b Value) (Value, error)

func BYTE_LENGTH added in v0.7.0 

func BYTE_LENGTH(v []byte) (Value, error)

func CAST added in v0.8.0 

func CAST(expr Value, fromType, toType *Type, isSafeCast bool) (Value, error)

func CEIL 

func CEIL(x Value) (Value, error)

func CHAR_LENGTH added in v0.7.0 

func CHAR_LENGTH(v []byte) (Value, error)

func CHR added in v0.7.0 

func CHR(v int64) (Value, error)

func COALESCE 

func COALESCE(args ...Value) (Value, error)

func CODE_POINTS_TO_BYTES added in v0.7.0 

func CODE_POINTS_TO_BYTES(v *ArrayValue) (Value, error)

func CODE_POINTS_TO_STRING added in v0.7.0 

func CODE_POINTS_TO_STRING(v *ArrayValue) (Value, error)

func COLLATE added in v0.7.0 

func COLLATE(v, spec string) (Value, error)

func CONCAT 

func CONCAT(args ...Value) (Value, error)

func CONTAINS_SUBSTR added in v0.7.0 

func CONTAINS_SUBSTR(exprValue Value, search string) (Value, error)

func COS 

func COS(x Value) (Value, error)

func COSH 

func COSH(x Value) (Value, error)

func CURRENT_DATE 

func CURRENT_DATE(zone string) (Value, error)

func CURRENT_DATETIME 

func CURRENT_DATETIME(zone string) (Value, error)

func CURRENT_DATETIME_WITH_TIME 

func CURRENT_DATETIME_WITH_TIME(v time.Time) (Value, error)

func CURRENT_DATE_WITH_TIME 

func CURRENT_DATE_WITH_TIME(v time.Time) (Value, error)

func CURRENT_TIME 

func CURRENT_TIME(zone string) (Value, error)

func CURRENT_TIMESTAMP 

func CURRENT_TIMESTAMP(zone string) (Value, error)

func CURRENT_TIMESTAMP_WITH_TIME 

func CURRENT_TIMESTAMP_WITH_TIME(v time.Time) (Value, error)

func CURRENT_TIME_WITH_TIME 

func CURRENT_TIME_WITH_TIME(v time.Time) (Value, error)

func CastValue added in v0.8.0 

func CastValue(t types.Type, v Value) (Value, error)

func DATE 

func DATE(args ...Value) (Value, error)

func DATETIME added in v0.5.0 

func DATETIME(args ...Value) (Value, error)

func DATETIME_ADD added in v0.5.0 

func DATETIME_ADD(t time.Time, v int64, part string) (Value, error)

func DATETIME_DIFF added in v0.5.0 

func DATETIME_DIFF(a, b time.Time, part string) (Value, error)

func DATETIME_SUB added in v0.5.0 

func DATETIME_SUB(t time.Time, v int64, part string) (Value, error)

func DATETIME_TRUNC added in v0.5.0 

func DATETIME_TRUNC(t time.Time, part string) (Value, error)

func DATE_ADD 

func DATE_ADD(t time.Time, v int64, part string) (Value, error)

func DATE_DIFF added in v0.4.1 

func DATE_DIFF(a, b time.Time, part string) (Value, error)

func DATE_FROM_UNIX_DATE added in v0.5.0 

func DATE_FROM_UNIX_DATE(unixdate int64) (Value, error)

func DATE_SUB 

func DATE_SUB(t time.Time, v int64, part string) (Value, error)

func DATE_TRUNC added in v0.4.1 

func DATE_TRUNC(t time.Time, part string) (Value, error)

func DISTINCT 

func DISTINCT() (Value, error)

func DIV 

func DIV(x, y Value) (Value, error)

func DecodeValue added in v0.8.0 

func DecodeValue(v interface{}) (Value, error)

func ENDS_WITH added in v0.7.0 

func ENDS_WITH(value, ends Value) (Value, error)

func EQ 

func EQ(a, b Value) (Value, error)

func EVAL_JAVASCRIPT added in v0.10.0 

func EVAL_JAVASCRIPT(code string, retType *Type, argNames []string, args []Value) (Value, error)

func EXP 

func EXP(x Value) (Value, error)

func EXTRACT added in v0.5.0 

func EXTRACT(v Value, part, zone string) (Value, error)

func FARM_FINGERPRINT added in v0.5.0 

func FARM_FINGERPRINT(v []byte) (Value, error)

func FLOOR 

func FLOOR(x Value) (Value, error)

func FORMAT 

func FORMAT(format string, args ...Value) (Value, error)

func FORMAT_DATE added in v0.5.0 

func FORMAT_DATE(format string, t time.Time) (Value, error)

func FORMAT_DATETIME added in v0.5.0 

func FORMAT_DATETIME(format string, t time.Time) (Value, error)

func FORMAT_TIME added in v0.5.0 

func FORMAT_TIME(format string, t time.Time) (Value, error)

func FORMAT_TIMESTAMP added in v0.5.0 

func FORMAT_TIMESTAMP(format string, t time.Time, zone string) (Value, error)

func FROM_BASE32 added in v0.7.0 

func FROM_BASE32(v string) (Value, error)

func FROM_BASE64 added in v0.7.0 

func FROM_BASE64(v string) (Value, error)

func FROM_HEX added in v0.7.0 

func FROM_HEX(v string) (Value, error)

func GENERATE_ARRAY 

func GENERATE_ARRAY(start, end Value, step ...Value) (Value, error)

func GENERATE_DATE_ARRAY 

func GENERATE_DATE_ARRAY(start, end Value, step ...Value) (Value, error)

func GENERATE_TIMESTAMP_ARRAY 

func GENERATE_TIMESTAMP_ARRAY(start, end Value, step int64, part string) (Value, error)

func GENERATE_UUID added in v0.5.0 

func GENERATE_UUID() (Value, error)

func GREATEST 

func GREATEST(args ...Value) (Value, error)

func GT 

func GT(a, b Value) (Value, error)

func GTE 

func GTE(a, b Value) (Value, error)

func HLL_COUNT_EXTRACT added in v0.13.0 

func HLL_COUNT_EXTRACT(sketch []byte) (Value, error)

func IEEE_DIVIDE 

func IEEE_DIVIDE(x, y Value) (Value, error)

func IF 

func IF(cond, trueV, falseV Value) (Value, error)

func IFNULL 

func IFNULL(expr, nullResult Value) (Value, error)

func IGNORE_NULLS 

func IGNORE_NULLS() (Value, error)

func IN 

func IN(a Value, values ...Value) (Value, error)

func INITCAP added in v0.7.0 

func INITCAP(value string, delimiters []rune) (Value, error)

func INSTR added in v0.7.0 

func INSTR(source, search Value, position, occurrence int64) (Value, error)

func INTERVAL added in v0.8.0 

func INTERVAL(value int64, part string) (Value, error)

func IS_DISTINCT_FROM added in v0.5.0 

func IS_DISTINCT_FROM(a, b Value) (Value, error)

func IS_FALSE 

func IS_FALSE(a Value) (Value, error)

func IS_INF 

func IS_INF(a Value) (Value, error)

func IS_NAN 

func IS_NAN(a Value) (Value, error)

func IS_NOT_DISTINCT_FROM added in v0.5.0 

func IS_NOT_DISTINCT_FROM(a, b Value) (Value, error)

func IS_NULL 

func IS_NULL(a Value) (Value, error)

func IS_TRUE 

func IS_TRUE(a Value) (Value, error)

func JSON_EXTRACT added in v0.11.0 

func JSON_EXTRACT(v, path string) (Value, error)

func JSON_EXTRACT_ARRAY added in v0.11.0 

func JSON_EXTRACT_ARRAY(v, path string) (Value, error)

func JSON_EXTRACT_SCALAR added in v0.11.0 

func JSON_EXTRACT_SCALAR(v, path string) (Value, error)

func JSON_EXTRACT_STRING_ARRAY added in v0.11.0 

func JSON_EXTRACT_STRING_ARRAY(v, path string) (Value, error)

func JSON_FIELD added in v0.11.0 

func JSON_FIELD(v, fieldName string) (Value, error)

func JSON_QUERY added in v0.11.0 

func JSON_QUERY(v, path string) (Value, error)

func JSON_QUERY_ARRAY added in v0.11.0 

func JSON_QUERY_ARRAY(v, path string) (Value, error)

func JSON_SUBSCRIPT added in v0.11.0 

func JSON_SUBSCRIPT(v string, field Value) (Value, error)

func JSON_TYPE added in v0.6.3 

func JSON_TYPE(v JsonValue) (Value, error)

func JSON_VALUE added in v0.11.0 

func JSON_VALUE(v, path string) (Value, error)

func JSON_VALUE_ARRAY added in v0.11.0 

func JSON_VALUE_ARRAY(v, path string) (Value, error)

func JUSTIFY_DAYS added in v0.8.0 

func JUSTIFY_DAYS(v *IntervalValue) (Value, error)

func JUSTIFY_HOURS added in v0.8.0 

func JUSTIFY_HOURS(v *IntervalValue) (Value, error)

func JUSTIFY_INTERVAL added in v0.8.0 

func JUSTIFY_INTERVAL(v *IntervalValue) (Value, error)

func LAST_DAY added in v0.5.0 

func LAST_DAY(t time.Time, part string) (Value, error)

func LEAST 

func LEAST(args ...Value) (Value, error)

func LEFT added in v0.7.0 

func LEFT(v Value, length int64) (Value, error)

func LENGTH 

func LENGTH(v Value) (Value, error)

func LIKE 

func LIKE(a, b Value) (Value, error)

func LIMIT 

func LIMIT(limit int64) (Value, error)

func LN 

func LN(x Value) (Value, error)

func LOG 

func LOG(x, y Value) (Value, error)

func LOG10 

func LOG10(x Value) (Value, error)

func LOWER added in v0.7.0 

func LOWER(v Value) (Value, error)

func LPAD added in v0.7.0 

func LPAD(originalValue Value, returnLength int64, pattern Value) (Value, error)

func LT 

func LT(a, b Value) (Value, error)

func LTE 

func LTE(a, b Value) (Value, error)

func LTRIM added in v0.7.0 

func LTRIM(v Value, cutset string) (Value, error)

func MAKE_ARRAY added in v0.6.5 

func MAKE_ARRAY(args ...Value) (Value, error)

func MAKE_INTERVAL added in v0.8.0 

func MAKE_INTERVAL(year, month, day, hour, minute, second int64) (Value, error)

func MAKE_STRUCT 

func MAKE_STRUCT(args ...Value) (Value, error)

func MD5 added in v0.5.0 

func MD5(v []byte) (Value, error)

func MOD 

func MOD(x, y Value) (Value, error)

func MUL 

func MUL(a, b Value) (Value, error)

func NET_HOST added in v0.15.0 

func NET_HOST(v string) (Value, error)

func NET_IPV4_FROM_INT64 added in v0.15.0 

func NET_IPV4_FROM_INT64(v int64) (Value, error)

func NET_IPV4_TO_INT64 added in v0.15.0 

func NET_IPV4_TO_INT64(v []byte) (Value, error)

func NET_IP_FROM_STRING added in v0.15.0 

func NET_IP_FROM_STRING(v string) (Value, error)

func NET_IP_NET_MASK added in v0.15.0 

func NET_IP_NET_MASK(output, prefix int64) (Value, error)

func NET_IP_TO_STRING added in v0.15.0 

func NET_IP_TO_STRING(v []byte) (Value, error)

func NET_IP_TRUNC added in v0.15.0 

func NET_IP_TRUNC(v []byte, length int64) (Value, error)

func NET_PUBLIC_SUFFIX added in v0.15.0 

func NET_PUBLIC_SUFFIX(v string) (Value, error)

func NET_REG_DOMAIN added in v0.15.0 

func NET_REG_DOMAIN(v string) (Value, error)

func NET_SAFE_IP_FROM_STRING added in v0.15.0 

func NET_SAFE_IP_FROM_STRING(v string) (Value, error)

func NORMALIZE added in v0.7.0 

func NORMALIZE(v, mode string) (Value, error)

func NORMALIZE_AND_CASEFOLD added in v0.7.0 

func NORMALIZE_AND_CASEFOLD(v, mode string) (Value, error)

func NOT 

func NOT(a Value) (Value, error)

func NOT_EQ 

func NOT_EQ(a, b Value) (Value, error)

func NULLIF 

func NULLIF(expr, exprToMatch Value) (Value, error)

func OP_DIV 

func OP_DIV(a, b Value) (Value, error)

func OR 

func OR(args ...Value) (Value, error)

func ORDER_BY 

func ORDER_BY(value Value, isAsc bool) (Value, error)

func PARSE_BIGNUMERIC added in v0.8.6 

func PARSE_BIGNUMERIC(numeric string) (Value, error)

func PARSE_DATE added in v0.5.0 

func PARSE_DATE(format, date string) (Value, error)

func PARSE_DATETIME added in v0.5.0 

func PARSE_DATETIME(format, date string) (Value, error)

func PARSE_JSON added in v0.11.0 

func PARSE_JSON(expr, mode string) (Value, error)

func PARSE_NUMERIC added in v0.8.0 

func PARSE_NUMERIC(numeric string) (Value, error)

func PARSE_TIME added in v0.5.0 

func PARSE_TIME(format, date string) (Value, error)

func PARSE_TIMESTAMP added in v0.5.0 

func PARSE_TIMESTAMP(format, date string) (Value, error)

func PARSE_TIMESTAMP_WITH_TIMEZONE added in v0.11.0 

func PARSE_TIMESTAMP_WITH_TIMEZONE(format, date, zone string) (Value, error)

func POW 

func POW(x, y Value) (Value, error)

func RAND 

func RAND() (Value, error)

func RANGE_BUCKET 

func RANGE_BUCKET(point Value, array *ArrayValue) (Value, error)

func REGEXP_CONTAINS added in v0.7.0 

func REGEXP_CONTAINS(value, expr string) (Value, error)

func REGEXP_EXTRACT added in v0.7.0 

func REGEXP_EXTRACT(value Value, expr string, position, occurrence int64) (Value, error)

func REGEXP_EXTRACT_ALL added in v0.7.0 

func REGEXP_EXTRACT_ALL(value Value, expr string) (Value, error)

func REGEXP_INSTR added in v0.7.0 

func REGEXP_INSTR(sourceValue, exprValue Value, position, occurrence, occurrencePos int64) (Value, error)

func REGEXP_REPLACE added in v0.7.0 

func REGEXP_REPLACE(value, exprValue, replacementValue Value) (Value, error)

func REPEAT added in v0.7.0 

func REPEAT(originalValue Value, repetitions int64) (Value, error)

func REPLACE added in v0.7.0 

func REPLACE(originalValue, fromValue, toValue Value) (Value, error)

func REVERSE added in v0.7.0 

func REVERSE(value Value) (Value, error)
func RIGHT(value Value, length int64) (Value, error)

func ROUND 

func ROUND(x Value, precision int) (Value, error)

func RPAD added in v0.7.0 

func RPAD(originalValue Value, returnLength int64, pattern Value) (Value, error)

func RTRIM added in v0.7.0 

func RTRIM(value Value, cutset string) (Value, error)

func SAFE_ADD 

func SAFE_ADD(x, y Value) (Value, error)

func SAFE_CONVERT_BYTES_TO_STRING added in v0.7.0 

func SAFE_CONVERT_BYTES_TO_STRING(value []byte) (Value, error)

func SAFE_DIVIDE 

func SAFE_DIVIDE(x, y Value) (Value, error)

func SAFE_MULTIPLY 

func SAFE_MULTIPLY(x, y Value) (Value, error)

func SAFE_NEGATE 

func SAFE_NEGATE(x Value) (Value, error)

func SAFE_SUBTRACT 

func SAFE_SUBTRACT(x, y Value) (Value, error)

func SESSION_USER added in v0.13.0 

func SESSION_USER() (Value, error)

func SHA1 added in v0.5.0 

func SHA1(v []byte) (Value, error)

func SHA256 added in v0.5.0 

func SHA256(v []byte) (Value, error)

func SHA512 added in v0.5.0 

func SHA512(v []byte) (Value, error)

func SIGN 

func SIGN(a Value) (Value, error)

func SIN 

func SIN(x Value) (Value, error)

func SINH 

func SINH(x Value) (Value, error)

func SOUNDEX added in v0.7.0 

func SOUNDEX(value string) (Value, error)

func SPLIT added in v0.7.0 

func SPLIT(value, delimValue Value) (Value, error)

func SQRT 

func SQRT(x Value) (Value, error)

func STARTS_WITH added in v0.7.0 

func STARTS_WITH(value, starts Value) (Value, error)

func STRING added in v0.5.0 

func STRING(t time.Time, zone string) (Value, error)

func STRPOS added in v0.7.0 

func STRPOS(value, search Value) (Value, error)

func STRUCT_FIELD 

func STRUCT_FIELD(v Value, idx int) (Value, error)

func SUB 

func SUB(a, b Value) (Value, error)

func SUBSTR added in v0.7.0 

func SUBSTR(value Value, pos int64, length *int64) (Value, error)

func TAN 

func TAN(x Value) (Value, error)

func TANH 

func TANH(x Value) (Value, error)

func TIME added in v0.5.0 

func TIME(args ...Value) (Value, error)

func TIMESTAMP added in v0.5.0 

func TIMESTAMP(v Value, zone string) (Value, error)

func TIMESTAMP_ADD added in v0.5.0 

func TIMESTAMP_ADD(t time.Time, v int64, part string) (Value, error)

func TIMESTAMP_DIFF added in v0.5.0 

func TIMESTAMP_DIFF(a, b time.Time, part string) (Value, error)

func TIMESTAMP_MICROS added in v0.5.0 

func TIMESTAMP_MICROS(sec int64) (Value, error)

func TIMESTAMP_MILLIS added in v0.5.0 

func TIMESTAMP_MILLIS(sec int64) (Value, error)

func TIMESTAMP_SECONDS added in v0.5.0 

func TIMESTAMP_SECONDS(sec int64) (Value, error)

func TIMESTAMP_SUB added in v0.5.0 

func TIMESTAMP_SUB(t time.Time, v int64, part string) (Value, error)

func TIMESTAMP_TRUNC added in v0.5.0 

func TIMESTAMP_TRUNC(t time.Time, part, zone string) (Value, error)

func TIME_ADD added in v0.5.0 

func TIME_ADD(t time.Time, v int64, part string) (Value, error)

func TIME_DIFF added in v0.5.0 

func TIME_DIFF(a, b time.Time, part string) (Value, error)

func TIME_SUB added in v0.5.0 

func TIME_SUB(t time.Time, v int64, part string) (Value, error)

func TIME_TRUNC added in v0.5.0 

func TIME_TRUNC(t time.Time, part string) (Value, error)

func TO_BASE32 added in v0.7.0 

func TO_BASE32(v []byte) (Value, error)

func TO_BASE64 added in v0.7.0 

func TO_BASE64(v []byte) (Value, error)

func TO_CODE_POINTS added in v0.7.0 

func TO_CODE_POINTS(v Value) (Value, error)

func TO_HEX added in v0.7.0 

func TO_HEX(v []byte) (Value, error)

func TO_JSON added in v0.6.3 

func TO_JSON(v Value, stringifyWideNumbers bool) (Value, error)

func TO_JSON_STRING added in v0.6.3 

func TO_JSON_STRING(v Value, prettyPrint bool) (Value, error)

func TRANSLATE added in v0.7.0 

func TRANSLATE(expr, source, target Value) (Value, error)

func TRIM added in v0.7.0 

func TRIM(v, cutsetV Value) (Value, error)

func TRUNC 

func TRUNC(x Value) (Value, error)

func UNICODE added in v0.7.0 

func UNICODE(v string) (Value, error)

func UNIX_DATE added in v0.5.0 

func UNIX_DATE(t time.Time) (Value, error)

func UNIX_MICROS added in v0.5.0 

func UNIX_MICROS(t time.Time) (Value, error)

func UNIX_MILLIS added in v0.5.0 

func UNIX_MILLIS(t time.Time) (Value, error)

func UNIX_SECONDS added in v0.5.0 

func UNIX_SECONDS(t time.Time) (Value, error)

func UPPER added in v0.7.0 

func UPPER(v Value) (Value, error)

func ValueFromGoValue added in v0.8.0 

func ValueFromGoValue(v interface{}) (Value, error)

func ValueFromZetaSQLValue added in v0.8.0 

func ValueFromZetaSQLValue(v types.Value) (Value, error)

func WINDOW_BOUNDARY_END 

func WINDOW_BOUNDARY_END(boundaryType, offset int64) (Value, error)

func WINDOW_BOUNDARY_START 

func WINDOW_BOUNDARY_START(boundaryType, offset int64) (Value, error)

func WINDOW_FRAME_UNIT 

func WINDOW_FRAME_UNIT(frameUnit int64) (Value, error)

func WINDOW_ORDER_BY 

func WINDOW_ORDER_BY(value Value, isAsc bool) (Value, error)

func WINDOW_PARTITION 

func WINDOW_PARTITION(partition Value) (Value, error)

func WINDOW_ROWID 

func WINDOW_ROWID(id int64) (Value, error)

type ValueLayout added in v0.8.0 

type ValueLayout struct {
	Header ValueType `json:"header"`
	Body   string    `json:"body"`
}

type ValueType added in v0.8.0 

type ValueType string
const (
	IntValueType        ValueType = "int64"
	StringValueType     ValueType = "string"
	BytesValueType      ValueType = "bytes"
	FloatValueType      ValueType = "float"
	NumericValueType    ValueType = "numeric"
	BigNumericValueType ValueType = "bignumeric"
	BoolValueType       ValueType = "bool"
	JsonValueType       ValueType = "json"
	ArrayValueType      ValueType = "array"
	StructValueType     ValueType = "struct"
	DateValueType       ValueType = "date"
	DatetimeValueType   ValueType = "datetime"
	TimeValueType       ValueType = "time"
	TimestampValueType  ValueType = "timestamp"
	IntervalValueType   ValueType = "interval"
)

type WINDOW_ANY_VALUE added in v0.12.0 

type WINDOW_ANY_VALUE struct {
}

func (*WINDOW_ANY_VALUE) Done added in v0.12.0 

func (f *WINDOW_ANY_VALUE) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_ANY_VALUE) Step added in v0.12.0 

func (f *WINDOW_ANY_VALUE) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_ARRAY_AGG added in v0.12.0 

type WINDOW_ARRAY_AGG struct {
}

func (*WINDOW_ARRAY_AGG) Done added in v0.12.0 

func (f *WINDOW_ARRAY_AGG) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_ARRAY_AGG) Step added in v0.12.0 

func (f *WINDOW_ARRAY_AGG) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_AVG 

type WINDOW_AVG struct {
}

func (*WINDOW_AVG) Done 

func (f *WINDOW_AVG) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_AVG) Step 

func (f *WINDOW_AVG) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_CORR added in v0.6.2 

type WINDOW_CORR struct {
}

func (*WINDOW_CORR) Done added in v0.6.2 

func (f *WINDOW_CORR) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_CORR) Step added in v0.6.2 

func (f *WINDOW_CORR) Step(x, y Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_COUNT added in v0.6.2 

type WINDOW_COUNT struct {
}

func (*WINDOW_COUNT) Done added in v0.6.2 

func (f *WINDOW_COUNT) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_COUNT) Step added in v0.6.2 

func (f *WINDOW_COUNT) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_COUNTIF added in v0.12.0 

type WINDOW_COUNTIF struct {
}

func (*WINDOW_COUNTIF) Done added in v0.12.0 

func (f *WINDOW_COUNTIF) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_COUNTIF) Step added in v0.12.0 

func (f *WINDOW_COUNTIF) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_COUNT_STAR 

type WINDOW_COUNT_STAR struct {
}

func (*WINDOW_COUNT_STAR) Done 

func (f *WINDOW_COUNT_STAR) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_COUNT_STAR) Step 

func (f *WINDOW_COUNT_STAR) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_COVAR_POP added in v0.6.2 

type WINDOW_COVAR_POP struct {
}

func (*WINDOW_COVAR_POP) Done added in v0.6.2 

func (f *WINDOW_COVAR_POP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_COVAR_POP) Step added in v0.6.2 

func (f *WINDOW_COVAR_POP) Step(x, y Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_COVAR_SAMP added in v0.6.2 

type WINDOW_COVAR_SAMP struct {
}

func (*WINDOW_COVAR_SAMP) Done added in v0.6.2 

func (f *WINDOW_COVAR_SAMP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_COVAR_SAMP) Step added in v0.6.2 

func (f *WINDOW_COVAR_SAMP) Step(x, y Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_CUME_DIST added in v0.12.0 

type WINDOW_CUME_DIST struct {
}

func (*WINDOW_CUME_DIST) Done added in v0.12.0 

func (f *WINDOW_CUME_DIST) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_CUME_DIST) Step added in v0.12.0 

func (f *WINDOW_CUME_DIST) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_DENSE_RANK added in v0.4.0 

type WINDOW_DENSE_RANK struct {
}

func (*WINDOW_DENSE_RANK) Done added in v0.4.0 

func (f *WINDOW_DENSE_RANK) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_DENSE_RANK) Step added in v0.4.0 

func (f *WINDOW_DENSE_RANK) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_FIRST_VALUE added in v0.5.0 

type WINDOW_FIRST_VALUE struct {
}

func (*WINDOW_FIRST_VALUE) Done added in v0.5.0 

func (f *WINDOW_FIRST_VALUE) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_FIRST_VALUE) Step added in v0.5.0 

func (f *WINDOW_FIRST_VALUE) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_LAG added in v0.4.0 

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

func (*WINDOW_LAG) Done added in v0.4.0 

func (f *WINDOW_LAG) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_LAG) Step added in v0.4.0 

func (f *WINDOW_LAG) Step(v Value, offset int64, defaultValue Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_LAST_VALUE 

type WINDOW_LAST_VALUE struct {
}

func (*WINDOW_LAST_VALUE) Done 

func (f *WINDOW_LAST_VALUE) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_LAST_VALUE) Step 

func (f *WINDOW_LAST_VALUE) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_LEAD added in v0.12.0 

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

func (*WINDOW_LEAD) Done added in v0.12.0 

func (f *WINDOW_LEAD) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_LEAD) Step added in v0.12.0 

func (f *WINDOW_LEAD) Step(v Value, offset int64, defaultValue Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_MAX added in v0.6.2 

type WINDOW_MAX struct {
}

func (*WINDOW_MAX) Done added in v0.6.2 

func (f *WINDOW_MAX) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_MAX) Step added in v0.6.2 

func (f *WINDOW_MAX) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_MIN added in v0.6.2 

type WINDOW_MIN struct {
}

func (*WINDOW_MIN) Done added in v0.6.2 

func (f *WINDOW_MIN) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_MIN) Step added in v0.6.2 

func (f *WINDOW_MIN) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_NTH_VALUE added in v0.12.0 

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

func (*WINDOW_NTH_VALUE) Done added in v0.12.0 

func (f *WINDOW_NTH_VALUE) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_NTH_VALUE) Step added in v0.12.0 

func (f *WINDOW_NTH_VALUE) Step(v Value, num int64, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_NTILE added in v0.12.0 

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

func (*WINDOW_NTILE) Done added in v0.12.0 

func (f *WINDOW_NTILE) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_NTILE) Step added in v0.12.0 

func (f *WINDOW_NTILE) Step(num int64, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_PERCENTILE_CONT added in v0.12.0 

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

func (*WINDOW_PERCENTILE_CONT) Done added in v0.12.0 

func (f *WINDOW_PERCENTILE_CONT) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_PERCENTILE_CONT) Step added in v0.12.0 

func (f *WINDOW_PERCENTILE_CONT) Step(v, percentile Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_PERCENTILE_DISC added in v0.12.0 

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

func (*WINDOW_PERCENTILE_DISC) Done added in v0.12.0 

func (f *WINDOW_PERCENTILE_DISC) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_PERCENTILE_DISC) Step added in v0.12.0 

func (f *WINDOW_PERCENTILE_DISC) Step(v, percentile Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_PERCENT_RANK added in v0.12.0 

type WINDOW_PERCENT_RANK struct {
}

func (*WINDOW_PERCENT_RANK) Done added in v0.12.0 

func (f *WINDOW_PERCENT_RANK) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_PERCENT_RANK) Step added in v0.12.0 

func (f *WINDOW_PERCENT_RANK) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_RANK 

type WINDOW_RANK struct {
}

func (*WINDOW_RANK) Done 

func (f *WINDOW_RANK) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_RANK) Step 

func (f *WINDOW_RANK) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_ROW_NUMBER added in v0.5.0 

type WINDOW_ROW_NUMBER struct {
}

func (*WINDOW_ROW_NUMBER) Done added in v0.5.0 

func (f *WINDOW_ROW_NUMBER) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_ROW_NUMBER) Step added in v0.5.0 

func (f *WINDOW_ROW_NUMBER) Step(opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_STDDEV added in v0.12.0 

type WINDOW_STDDEV = WINDOW_STDDEV_SAMP

type WINDOW_STDDEV_POP added in v0.6.2 

type WINDOW_STDDEV_POP struct {
}

func (*WINDOW_STDDEV_POP) Done added in v0.6.2 

func (f *WINDOW_STDDEV_POP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_STDDEV_POP) Step added in v0.6.2 

func (f *WINDOW_STDDEV_POP) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_STDDEV_SAMP added in v0.6.2 

type WINDOW_STDDEV_SAMP struct {
}

func (*WINDOW_STDDEV_SAMP) Done added in v0.6.2 

func (f *WINDOW_STDDEV_SAMP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_STDDEV_SAMP) Step added in v0.6.2 

func (f *WINDOW_STDDEV_SAMP) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_STRING_AGG added in v0.12.0 

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

func (*WINDOW_STRING_AGG) Done added in v0.12.0 

func (f *WINDOW_STRING_AGG) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_STRING_AGG) Step added in v0.12.0 

func (f *WINDOW_STRING_AGG) Step(v Value, delim string, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_SUM 

type WINDOW_SUM struct {
}

func (*WINDOW_SUM) Done 

func (f *WINDOW_SUM) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_SUM) Step 

func (f *WINDOW_SUM) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_VARIANCE added in v0.12.0 

type WINDOW_VARIANCE = WINDOW_VAR_SAMP

type WINDOW_VAR_POP added in v0.6.2 

type WINDOW_VAR_POP struct {
}

func (*WINDOW_VAR_POP) Done added in v0.6.2 

func (f *WINDOW_VAR_POP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_VAR_POP) Step added in v0.6.2 

func (f *WINDOW_VAR_POP) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WINDOW_VAR_SAMP added in v0.6.2 

type WINDOW_VAR_SAMP struct {
}

func (*WINDOW_VAR_SAMP) Done added in v0.6.2 

func (f *WINDOW_VAR_SAMP) Done(agg *WindowFuncAggregatedStatus) (Value, error)

func (*WINDOW_VAR_SAMP) Step added in v0.6.2 

func (f *WINDOW_VAR_SAMP) Step(v Value, opt *WindowFuncStatus, agg *WindowFuncAggregatedStatus) error

type WildcardTable added in v0.9.0 

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

func (*WildcardTable) AnonymizationInfo added in v0.9.0 

func (t *WildcardTable) AnonymizationInfo() *types.AnonymizationInfo

func (*WildcardTable) Column added in v0.9.0 

func (t *WildcardTable) Column(idx int) types.Column

func (*WildcardTable) CreateEvaluatorTableIterator added in v0.9.0 

func (t *WildcardTable) CreateEvaluatorTableIterator(columnIdxs []int) (*types.EvaluatorTableIterator, error)

func (*WildcardTable) FindColumnByName added in v0.9.0 

func (t *WildcardTable) FindColumnByName(name string) types.Column

func (*WildcardTable) FormatSQL added in v0.9.0 

func (t *WildcardTable) FormatSQL(ctx context.Context) (string, error)

func (*WildcardTable) FullName added in v0.9.0 

func (t *WildcardTable) FullName() string

func (*WildcardTable) IsValueTable added in v0.9.0 

func (t *WildcardTable) IsValueTable() bool

func (*WildcardTable) Name added in v0.9.0 

func (t *WildcardTable) Name() string

func (*WildcardTable) NumColumns added in v0.9.0 

func (t *WildcardTable) NumColumns() int

func (*WildcardTable) PrimaryKey added in v0.9.0 

func (t *WildcardTable) PrimaryKey() []int

func (*WildcardTable) SerializationID added in v0.9.0 

func (t *WildcardTable) SerializationID() int64

func (*WildcardTable) SupportsAnonymization added in v0.9.0 

func (t *WildcardTable) SupportsAnonymization() bool

func (*WildcardTable) TableTypeName added in v0.9.0 

func (t *WildcardTable) TableTypeName(mode types.ProductMode) string

type WindowAggregator 

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

func (*WindowAggregator) Done 

func (a *WindowAggregator) Done() (interface{}, error)

func (*WindowAggregator) Step 

func (a *WindowAggregator) Step(stepArgs ...interface{}) error

type WindowBindFunction 

type WindowBindFunction func() func() *WindowAggregator

type WindowBoundary 

type WindowBoundary struct {
	Type   WindowBoundaryType `json:"type"`
	Offset int64              `json:"offset"`
}

type WindowBoundaryType 

type WindowBoundaryType int
const (
	WindowBoundaryTypeUnknown    WindowBoundaryType = 0
	WindowUnboundedPrecedingType WindowBoundaryType = 1
	WindowOffsetPrecedingType    WindowBoundaryType = 2
	WindowCurrentRowType         WindowBoundaryType = 3
	WindowOffsetFollowingType    WindowBoundaryType = 4
	WindowUnboundedFollowingType WindowBoundaryType = 5
)

type WindowFrameExprNode 

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

func (*WindowFrameExprNode) FormatSQL 

func (n *WindowFrameExprNode) FormatSQL(ctx context.Context) (string, error)

type WindowFrameNode 

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

func (*WindowFrameNode) FormatSQL 

func (n *WindowFrameNode) FormatSQL(ctx context.Context) (string, error)

type WindowFrameUnitType 

type WindowFrameUnitType int
const (
	WindowFrameUnitUnknown WindowFrameUnitType = 0
	WindowFrameUnitRows    WindowFrameUnitType = 1
	WindowFrameUnitRange   WindowFrameUnitType = 2
)

type WindowFuncAggregatedStatus 

type WindowFuncAggregatedStatus struct {
	FrameUnit WindowFrameUnitType
	Start     *WindowBoundary
	End       *WindowBoundary
	RowID     int64

	PartitionToValuesMap map[string][]*WindowOrderedValue
	PartitionedValues    []*PartitionedValue
	Values               []*WindowOrderedValue
	SortedValues         []*WindowOrderedValue
	// contains filtered or unexported fields
}

func (*WindowFuncAggregatedStatus) Distinct added in v0.12.0 

func (s *WindowFuncAggregatedStatus) Distinct() bool

func (*WindowFuncAggregatedStatus) Done 

func (s *WindowFuncAggregatedStatus) Done(cb func([]Value, int, int) error) error

func (*WindowFuncAggregatedStatus) FilteredValues 

func (s *WindowFuncAggregatedStatus) FilteredValues() []*WindowOrderedValue

func (*WindowFuncAggregatedStatus) IgnoreNulls added in v0.12.0 

func (s *WindowFuncAggregatedStatus) IgnoreNulls() bool

func (*WindowFuncAggregatedStatus) Partition 

func (s *WindowFuncAggregatedStatus) Partition() string

func (*WindowFuncAggregatedStatus) Step 

func (s *WindowFuncAggregatedStatus) Step(value Value, status *WindowFuncStatus) error

type WindowFuncInfo 

type WindowFuncInfo struct {
	Name     string
	BindFunc WindowBindFunction
}

type WindowFuncOption 

type WindowFuncOption struct {
	Type  WindowFuncOptionType `json:"type"`
	Value interface{}          `json:"value"`
}

func (*WindowFuncOption) UnmarshalJSON 

func (o *WindowFuncOption) UnmarshalJSON(b []byte) error

type WindowFuncOptionType 

type WindowFuncOptionType string
const (
	WindowFuncOptionUnknown   WindowFuncOptionType = "window_unknown"
	WindowFuncOptionFrameUnit WindowFuncOptionType = "window_frame_unit"
	WindowFuncOptionStart     WindowFuncOptionType = "window_boundary_start"
	WindowFuncOptionEnd       WindowFuncOptionType = "window_boundary_end"
	WindowFuncOptionPartition WindowFuncOptionType = "window_partition"
	WindowFuncOptionRowID     WindowFuncOptionType = "window_rowid"
	WindowFuncOptionOrderBy   WindowFuncOptionType = "window_order_by"
)

type WindowFuncStatus 

type WindowFuncStatus struct {
	FrameUnit  WindowFrameUnitType
	Start      *WindowBoundary
	End        *WindowBoundary
	Partitions []Value
	RowID      int64
	OrderBy    []*WindowOrderBy
}

func (*WindowFuncStatus) Partition 

func (s *WindowFuncStatus) Partition() (string, error)

type WindowOrderBy added in v0.4.0 

type WindowOrderBy struct {
	Value Value `json:"value"`
	IsAsc bool  `json:"isAsc"`
}

func (*WindowOrderBy) UnmarshalJSON added in v0.4.0 

func (w *WindowOrderBy) UnmarshalJSON(b []byte) error

type WindowOrderedValue 

type WindowOrderedValue struct {
	OrderBy []*WindowOrderBy
	Value   Value
}

type WindowOrderingNode 

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

func (*WindowOrderingNode) FormatSQL 

func (n *WindowOrderingNode) FormatSQL(ctx context.Context) (string, error)

type WindowPartitioningNode 

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

func (*WindowPartitioningNode) FormatSQL 

func (n *WindowPartitioningNode) FormatSQL(ctx context.Context) (string, error)

type WithEntryNode 

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

func (*WithEntryNode) FormatSQL 

func (n *WithEntryNode) FormatSQL(ctx context.Context) (string, error)

type WithPartitionColumnsNode 

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

func (*WithPartitionColumnsNode) FormatSQL 

func (n *WithPartitionColumnsNode) FormatSQL(ctx context.Context) (string, error)

type WithRefScanNode 

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

func (*WithRefScanNode) FormatSQL 

func (n *WithRefScanNode) FormatSQL(ctx context.Context) (string, error)

type WithScanNode 

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

func (*WithScanNode) FormatSQL 

func (n *WithScanNode) FormatSQL(ctx context.Context) (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.