internal

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2022 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ArrayValueHeader     = "zetasqlitearray:"
	StructValueHeader    = "zetasqlitestruct:"
	DateValueHeader      = "zetasqlitedate:"
	DatetimeValueHeader  = "zetasqlitedatetime:"
	TimeValueHeader      = "zetasqlitetime:"
	TimestampValueHeader = "zetasqlitetimestamp:"
)

Variables

This section is empty.

Functions

func ConvertNamedValues 

func ConvertNamedValues(v []driver.NamedValue) ([]sql.NamedArg, error)

func CurrentTime 

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

func FormatName 

func FormatName(namePath []string) string

func JSONFromZetaSQLValue 

func JSONFromZetaSQLValue(v types.Value) string

func MergeNamePath 

func MergeNamePath(namePath []string, queryPath []string) []string

func RegisterFunctions 

func RegisterFunctions(conn *sqlite3.SQLiteConn) error

func SQLiteValue 

func SQLiteValue(v interface{}) (interface{}, error)

func WithCurrentTime 

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

Types

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(ReturnValueConverter) func() *Aggregator

type AggregateFuncInfo 

type AggregateFuncInfo struct {
	Name        string
	BindFunc    AggregateBindFunction
	ReturnTypes []types.TypeKind
}

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

func (*Analyzer) AddNamePath 

func (a *Analyzer) AddNamePath(path string)

func (*Analyzer) Analyze 

func (a *Analyzer) Analyze(ctx context.Context, query string) (*AnalyzerOutput, error)

func (*Analyzer) NamePath 

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

func (*Analyzer) SetNamePath 

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

type AnalyzerOutput 

type AnalyzerOutput struct {
	Prepare      func(context.Context, *sql.Conn) (driver.Stmt, error)
	ExecContext  func(context.Context, *sql.Conn, ...interface{}) (driver.Result, error)
	QueryContext func(context.Context, *sql.Conn, ...interface{}) (driver.Rows, error)
	// contains filtered or unexported fields
}

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

func (av *ArrayValue) Marshal() (string, 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) 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) 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 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) Marshal 

func (bv BoolValue) Marshal() (string, 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) 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) 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 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 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, spec *FunctionSpec) error

func (*Catalog) AddNewTableSpec 

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

func (*Catalog) Sync 

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

type CatalogSpecKind 

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

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 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 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 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 CreateTableStmtNode 

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

func (*CreateTableStmtNode) FormatSQL 

func (n *CreateTableStmtNode) FormatSQL(ctx context.Context) (string, 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 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) Marshal 

func (d DateValue) Marshal() (string, 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) 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) 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) Marshal 

func (d DatetimeValue) Marshal() (string, 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) 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) 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 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 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 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) Marshal 

func (fv FloatValue) Marshal() (string, 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) 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) 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 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
	ReturnTypes []types.TypeKind
}

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 {
	NamePath []string        `json:"name"`
	Language string          `json:"language"`
	Args     []*NameWithType `json:"args"`
	Return   *Type           `json:"return"`
	Body     string          `json:"body"`
	Code     string          `json:"code"`
}

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

func (iv IntValue) Marshal() (string, 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) 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) 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 JoinScanNode 

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

func (*JoinScanNode) FormatSQL 

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

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 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 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 NameAndFunc added in v0.3.1 

type NameAndFunc struct {
	Name string
	Func interface{}
}

type NameWithType 

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

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 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 QueryStmtNode 

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

func (*QueryStmtNode) FormatSQL 

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

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 ReturnValueConverter 

type ReturnValueConverter func(Value) (interface{}, 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) Close 

func (r *Rows) Close() 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

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

func (sv StringValue) Marshal() (string, 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) 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) 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) Marshal 

func (sv *StructValue) Marshal() (string, 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) 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) 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 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 {
	NamePath   []string       `json:"namePath"`
	Columns    []*ColumnSpec  `json:"columns"`
	CreateMode ast.CreateMode `json:"createMode"`
}

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 TimeValue 

type TimeValue time.Time

func (TimeValue) Add 

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

func (TimeValue) Div 

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

func (TimeValue) EQ 

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

func (TimeValue) Format 

func (d TimeValue) Format(verb rune) string

func (TimeValue) GT 

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

func (TimeValue) GTE 

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

func (TimeValue) Interface 

func (d TimeValue) Interface() interface{}

func (TimeValue) LT 

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

func (TimeValue) LTE 

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

func (TimeValue) Marshal 

func (d TimeValue) Marshal() (string, error)

func (TimeValue) Mul 

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

func (TimeValue) Sub 

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

func (TimeValue) ToArray 

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

func (TimeValue) ToBool 

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

func (TimeValue) ToFloat64 

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

func (TimeValue) ToInt64 

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

func (TimeValue) ToJSON 

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

func (TimeValue) ToString 

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

func (TimeValue) ToStruct 

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

func (TimeValue) ToTime 

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

type TimestampValue 

type TimestampValue time.Time

func (TimestampValue) Add 

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

func (TimestampValue) AddValueWithPart 

func (d TimestampValue) AddValueWithPart(v time.Duration, part string) (Value, error)

func (TimestampValue) Div 

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

func (TimestampValue) EQ 

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

func (TimestampValue) Format 

func (d TimestampValue) Format(verb rune) string

func (TimestampValue) GT 

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

func (TimestampValue) GTE 

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

func (TimestampValue) Interface 

func (d TimestampValue) Interface() interface{}

func (TimestampValue) LT 

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

func (TimestampValue) LTE 

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

func (TimestampValue) Marshal 

func (d TimestampValue) Marshal() (string, error)

func (TimestampValue) Mul 

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

func (TimestampValue) Sub 

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

func (TimestampValue) ToArray 

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

func (TimestampValue) ToBool 

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

func (TimestampValue) ToFloat64 

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

func (TimestampValue) ToInt64 

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

func (TimestampValue) ToJSON 

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

func (TimestampValue) ToString 

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

func (TimestampValue) ToStruct 

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

func (TimestampValue) ToTime 

func (d TimestampValue) ToTime() (time.Time, 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"`
	ElementType *Type           `json:"elementType"`
	FieldTypes  []*NameWithType `json:"fieldTypes"`
}

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 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)
	ToFloat64() (float64, error)
	ToBool() (bool, error)
	ToArray() (*ArrayValue, error)
	ToStruct() (*StructValue, error)
	ToJSON() (string, error)
	ToTime() (time.Time, error)
	Marshal() (string, 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(a, b 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 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 ArrayValueOf 

func ArrayValueOf(v string) (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_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 CASE_NO_VALUE 

func CASE_NO_VALUE(args ...Value) (Value, error)

func CASE_WITH_VALUE 

func CASE_WITH_VALUE(caseV Value, args ...Value) (Value, error)

func CEIL 

func CEIL(x Value) (Value, error)

func COALESCE 

func COALESCE(args ...Value) (Value, error)

func CONCAT 

func CONCAT(a, b Value) (Value, error)

func COS 

func COS(x Value) (Value, error)

func COSH 

func COSH(x Value) (Value, error)

func CURRENT_DATE 

func CURRENT_DATE() (Value, error)

func CURRENT_DATETIME 

func CURRENT_DATETIME() (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() (Value, error)

func CURRENT_TIMESTAMP 

func CURRENT_TIMESTAMP() (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 DATE 

func DATE(args ...Value) (Value, error)

func DATE_ADD 

func DATE_ADD(a, b Value) (Value, error)

func DATE_SUB 

func DATE_SUB(a, b Value) (Value, error)

func DECODE_ARRAY 

func DECODE_ARRAY(v string) (Value, error)

func DISTINCT 

func DISTINCT() (Value, error)

func DIV 

func DIV(x, y Value) (Value, error)

func DateValueOf 

func DateValueOf(v string) (Value, error)

func DatetimeValueOf 

func DatetimeValueOf(v string) (Value, error)

func EQ 

func EQ(a, b Value) (Value, error)

func EXP 

func EXP(x Value) (Value, error)

func FLOOR 

func FLOOR(x Value) (Value, error)

func FORMAT 

func FORMAT(format string, args ...Value) (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 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 IEEE_DIVIDE 

func IEEE_DIVIDE(x, y Value) (Value, error)

func IF 

func IF(cond bool, 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 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_NULL 

func IS_NULL(a Value) (Value, error)

func IS_TRUE 

func IS_TRUE(a Value) (Value, error)

func LEAST 

func LEAST(args ...Value) (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 LT 

func LT(a, b Value) (Value, error)

func LTE 

func LTE(a, b Value) (Value, error)

func MAKE_STRUCT 

func MAKE_STRUCT(args ...Value) (Value, error)

func MOD 

func MOD(x, y Value) (Value, error)

func MUL 

func MUL(a, b Value) (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(a, b Value) (Value, error)

func ORDER_BY 

func ORDER_BY(value Value, isAsc bool) (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 ROUND 

func ROUND(x Value) (Value, error)

func SAFE_ADD 

func SAFE_ADD(x, y Value) (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 SIGN 

func SIGN(a Value) (Value, error)

func SIN 

func SIN(x Value) (Value, error)

func SINH 

func SINH(x Value) (Value, error)

func SQRT 

func SQRT(x 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 StructValueOf 

func StructValueOf(v string) (Value, error)

func TAN 

func TAN(x Value) (Value, error)

func TANH 

func TANH(x Value) (Value, error)

func TRUNC 

func TRUNC(x Value) (Value, error)

func TimeValueOf 

func TimeValueOf(v string) (Value, error)

func TimestampValueOf 

func TimestampValueOf(v string) (Value, error)

func ValueOf 

func ValueOf(v interface{}) (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) (Value, error)

func WINDOW_PARTITION 

func WINDOW_PARTITION(partition Value) (Value, error)

func WINDOW_ROWID 

func WINDOW_ROWID(id int64) (Value, 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_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_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_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_SUM 

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

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 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(ReturnValueConverter) 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) Done 

func (s *WindowFuncAggregatedStatus) Done(cb func([]Value, int, int) error) error

func (*WindowFuncAggregatedStatus) FilteredValues 

func (s *WindowFuncAggregatedStatus) FilteredValues() []*WindowOrderedValue

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
	ReturnTypes []types.TypeKind
}

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
	Partition Value
	RowID     int64
	OrderBy   []Value
}

type WindowOrderedValue 

type WindowOrderedValue struct {
	OrderBy []Value
	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.