node

package
v0.52.3 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrVitessChildCount = gmserrors.NewKind("invalid vitess child count, expected `%d` but got `%d`")

ErrVitessChildCount is returned by WithResolvedChildren to indicate that the expected child count is incorrect.

Functions

This section is empty.

Types

type AlterRole added in v0.13.0 

type AlterRole struct {
	Name    string
	Options map[string]any
}

AlterRole handles the ALTER ROLE and ALTER USER statements (ALTER USER is an alias).

func (*AlterRole) Children added in v0.13.0 

func (c *AlterRole) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*AlterRole) IsReadOnly added in v0.13.0 

func (c *AlterRole) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*AlterRole) Resolved added in v0.13.0 

func (c *AlterRole) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*AlterRole) RowIter added in v0.13.0 

func (c *AlterRole) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*AlterRole) Schema added in v0.13.0 

func (c *AlterRole) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*AlterRole) String added in v0.13.0 

func (c *AlterRole) String() string

String implements the interface sql.ExecSourceRel.

func (*AlterRole) WithChildren added in v0.13.0 

func (c *AlterRole) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*AlterRole) WithResolvedChildren added in v0.13.0 

func (c *AlterRole) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type AlterSequence added in v0.52.2 

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

AlterSequence handles the ALTER SEQUENCE statement.

func NewAlterSequence added in v0.52.2 

func NewAlterSequence(ifExists bool, targetSchema string, targetSequence string, ownedBy AlterSequenceOwnedBy, warnings ...string) *AlterSequence

NewAlterSequence returns a new *AlterSequence.

func (*AlterSequence) Children added in v0.52.2 

func (c *AlterSequence) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*AlterSequence) IsReadOnly added in v0.52.2 

func (c *AlterSequence) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*AlterSequence) Resolved added in v0.52.2 

func (c *AlterSequence) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*AlterSequence) RowIter added in v0.52.2 

func (c *AlterSequence) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*AlterSequence) Schema added in v0.52.2 

func (c *AlterSequence) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*AlterSequence) String added in v0.52.2 

func (c *AlterSequence) String() string

String implements the interface sql.ExecSourceRel.

func (*AlterSequence) WithChildren added in v0.52.2 

func (c *AlterSequence) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*AlterSequence) WithResolvedChildren added in v0.52.2 

func (c *AlterSequence) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type AlterSequenceOwnedBy added in v0.52.2 

type AlterSequenceOwnedBy struct {
	IsSet  bool
	Table  string
	Column string
}

AlterSequenceOwnedBy is an option in AlterSequence to represent OWNED BY.

type Call added in v0.52.3 

type Call struct {
	SchemaName    string
	ProcedureName string
	Exprs         []sql.Expression
	Runner        pgexprs.StatementRunner
	// contains filtered or unexported fields
}

Call is used to call stored procedures.

func NewCall added in v0.52.3 

func NewCall(schema string, name string, originalExprs vitess.Exprs) *Call

NewCall returns a new *Call.

func (*Call) Children added in v0.52.3 

func (c *Call) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*Call) Expressions added in v0.52.3 

func (c *Call) Expressions() []sql.Expression

Expressions implements the interface sql.Expressioner.

func (*Call) IsReadOnly added in v0.52.3 

func (c *Call) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*Call) Resolved added in v0.52.3 

func (c *Call) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*Call) RowIter added in v0.52.3 

func (c *Call) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*Call) Schema added in v0.52.3 

func (c *Call) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*Call) String added in v0.52.3 

func (c *Call) String() string

String implements the interface sql.ExecSourceRel.

func (*Call) WithChildren added in v0.52.3 

func (c *Call) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*Call) WithExpressions added in v0.52.3 

func (c *Call) WithExpressions(exprs ...sql.Expression) (sql.Node, error)

WithExpressions implements the interface sql.Expressioner.

func (*Call) WithResolvedChildren added in v0.52.3 

func (c *Call) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CompositeAsType added in v0.16.0 

type CompositeAsType struct {
	AttrName  string
	Typ       *types.DoltgresType
	Collation string
}

CompositeAsType represents an attribute name and data type for a composite type.

type ContextRootFinalizer 

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

ContextRootFinalizer is a node that finalizes any changes persisted within the context.

func NewContextRootFinalizer 

func NewContextRootFinalizer(child sql.Node) *ContextRootFinalizer

NewContextRootFinalizer returns a new *ContextRootFinalizer.

func (*ContextRootFinalizer) Child 

func (rf *ContextRootFinalizer) Child() sql.Node

Child returns the single child of this node

func (*ContextRootFinalizer) Children 

func (rf *ContextRootFinalizer) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) DebugString 

func (rf *ContextRootFinalizer) DebugString() string

func (*ContextRootFinalizer) IsReadOnly 

func (rf *ContextRootFinalizer) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) Resolved 

func (rf *ContextRootFinalizer) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) RowIter 

func (rf *ContextRootFinalizer) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) Schema 

func (rf *ContextRootFinalizer) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) String 

func (rf *ContextRootFinalizer) String() string

String implements the interface sql.ExecSourceRel.

func (*ContextRootFinalizer) WithChildren 

func (rf *ContextRootFinalizer) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

type CopyFrom added in v0.12.0 

type CopyFrom struct {
	DatabaseName string
	TableName    doltdb.TableName
	File         string
	Stdin        bool
	Columns      tree.NameList
	CopyOptions  tree.CopyOptions
	InsertStub   *vitess.Insert
	DataLoader   dataloader.DataLoader
}

CopyFrom handles the COPY ... FROM ... statement.

func NewCopyFrom added in v0.12.0 

func NewCopyFrom(
	databaseName string,
	tableName doltdb.TableName,
	options tree.CopyOptions,
	fileName string,
	stdin bool,
	columns tree.NameList,
	insertStub *vitess.Insert,
) *CopyFrom

NewCopyFrom returns a new *CopyFrom.

func (*CopyFrom) Children added in v0.12.0 

func (cf *CopyFrom) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CopyFrom) IsReadOnly added in v0.12.0 

func (cf *CopyFrom) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CopyFrom) Resolved added in v0.12.0 

func (cf *CopyFrom) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CopyFrom) RowIter added in v0.12.0 

func (cf *CopyFrom) RowIter(ctx *sql.Context, r sql.Row) (_ sql.RowIter, err error)

RowIter implements the interface sql.ExecSourceRel.

func (*CopyFrom) Schema added in v0.12.0 

func (cf *CopyFrom) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CopyFrom) String added in v0.12.0 

func (cf *CopyFrom) String() string

String implements the interface sql.ExecSourceRel.

func (*CopyFrom) WithChildren added in v0.12.0 

func (cf *CopyFrom) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CopyFrom) WithResolvedChildren added in v0.12.0 

func (cf *CopyFrom) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateDomain added in v0.14.0 

type CreateDomain struct {
	SchemaName           string
	Name                 string
	AsType               *types.DoltgresType
	Collation            string
	HasDefault           bool
	DefaultExpr          sql.Expression
	IsNotNull            bool
	CheckConstraintNames []string
	CheckConstraints     sql.CheckConstraints
}

CreateDomain handles the CREATE DOMAIN statement.

func (*CreateDomain) Children added in v0.14.0 

func (c *CreateDomain) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateDomain) IsReadOnly added in v0.14.0 

func (c *CreateDomain) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateDomain) Resolved added in v0.14.0 

func (c *CreateDomain) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateDomain) RowIter added in v0.14.0 

func (c *CreateDomain) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateDomain) Schema added in v0.14.0 

func (c *CreateDomain) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateDomain) String added in v0.14.0 

func (c *CreateDomain) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateDomain) WithChildren added in v0.14.0 

func (c *CreateDomain) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateDomain) WithResolvedChildren added in v0.14.0 

func (c *CreateDomain) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateExtension added in v0.51.0 

type CreateExtension struct {
	Name        string
	IfNotExists bool
	SchemaName  string
	Version     string
	Cascade     bool
	Runner      pgexprs.StatementRunner
}

CreateExtension implements CREATE EXTENSION.

func NewCreateExtension added in v0.51.0 

func NewCreateExtension(name string, ifNotExists bool, schemaName string, version string, cascade bool) *CreateExtension

NewCreateExtension returns a new *CreateExtension.

func (*CreateExtension) Children added in v0.51.0 

func (c *CreateExtension) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateExtension) Expressions added in v0.51.0 

func (c *CreateExtension) Expressions() []sql.Expression

Expressions implements the interface sql.Expressioner.

func (*CreateExtension) IsReadOnly added in v0.51.0 

func (c *CreateExtension) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateExtension) Resolved added in v0.51.0 

func (c *CreateExtension) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateExtension) RowIter added in v0.51.0 

func (c *CreateExtension) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateExtension) Schema added in v0.51.0 

func (c *CreateExtension) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateExtension) String added in v0.51.0 

func (c *CreateExtension) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateExtension) WithChildren added in v0.51.0 

func (c *CreateExtension) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateExtension) WithExpressions added in v0.51.0 

func (c *CreateExtension) WithExpressions(expressions ...sql.Expression) (sql.Node, error)

WithExpressions implements the interface sql.Expressioner.

func (*CreateExtension) WithResolvedChildren added in v0.51.0 

func (c *CreateExtension) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateFunction added in v0.17.0 

type CreateFunction struct {
	FunctionName    string
	SchemaName      string
	Replace         bool
	ReturnType      *pgtypes.DoltgresType
	ParameterNames  []string
	ParameterTypes  []*pgtypes.DoltgresType
	Strict          bool
	Statements      []plpgsql.InterpreterOperation
	ExtensionName   string
	ExtensionSymbol string
	Definition      string
	SqlDef          string
	SqlDefParsed    vitess.Statement
	SetOf           bool
}

CreateFunction implements CREATE FUNCTION.

func NewCreateFunction added in v0.17.0 

func NewCreateFunction(
	functionName string,
	schemaName string,
	replace bool,
	retType *pgtypes.DoltgresType,
	paramNames []string,
	paramTypes []*pgtypes.DoltgresType,
	strict bool,
	definition string,
	extensionName string,
	extensionSymbol string,
	statements []plpgsql.InterpreterOperation,
	sqlDef string,
	sqlDefParsed vitess.Statement,
	setOf bool) *CreateFunction

NewCreateFunction returns a new *CreateFunction.

func (*CreateFunction) Children added in v0.17.0 

func (c *CreateFunction) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateFunction) IsReadOnly added in v0.17.0 

func (c *CreateFunction) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateFunction) Resolved added in v0.17.0 

func (c *CreateFunction) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateFunction) RowIter added in v0.17.0 

func (c *CreateFunction) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateFunction) Schema added in v0.17.0 

func (c *CreateFunction) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateFunction) String added in v0.17.0 

func (c *CreateFunction) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateFunction) WithChildren added in v0.17.0 

func (c *CreateFunction) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateFunction) WithResolvedChildren added in v0.17.0 

func (c *CreateFunction) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateProcedure added in v0.52.3 

type CreateProcedure struct {
	ProcedureName   string
	SchemaName      string
	Replace         bool
	ParameterNames  []string
	ParameterTypes  []*pgtypes.DoltgresType
	ParameterModes  []procedures.ParameterMode
	Statements      []plpgsql.InterpreterOperation
	ExtensionName   string
	ExtensionSymbol string
	Definition      string
	SqlDef          string
	SqlDefParsed    vitess.Statement
}

CreateProcedure implements CREATE PROCEDURE.

func NewCreateProcedure added in v0.52.3 

func NewCreateProcedure(
	procedureName string,
	schemaName string,
	replace bool,
	paramNames []string,
	paramTypes []*pgtypes.DoltgresType,
	paramModes []procedures.ParameterMode,
	definition string,
	extensionName string,
	extensionSymbol string,
	statements []plpgsql.InterpreterOperation,
	sqlDef string,
	sqlDefParsed vitess.Statement) *CreateProcedure

NewCreateProcedure returns a new *CreateProcedure.

func (*CreateProcedure) Children added in v0.52.3 

func (c *CreateProcedure) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateProcedure) IsReadOnly added in v0.52.3 

func (c *CreateProcedure) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateProcedure) Resolved added in v0.52.3 

func (c *CreateProcedure) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateProcedure) RowIter added in v0.52.3 

func (c *CreateProcedure) RowIter(ctx *sql.Context, _ sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateProcedure) Schema added in v0.52.3 

func (c *CreateProcedure) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateProcedure) String added in v0.52.3 

func (c *CreateProcedure) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateProcedure) WithChildren added in v0.52.3 

func (c *CreateProcedure) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateProcedure) WithResolvedChildren added in v0.52.3 

func (c *CreateProcedure) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateRole added in v0.13.0 

type CreateRole struct {
	Name                      string
	IfNotExists               bool
	Password                  string // PASSWORD 'password'
	IsPasswordNull            bool   // PASSWORD NULL
	IsSuperUser               bool   // SUPERUSER | NOSUPERUSER
	CanCreateDB               bool   // CREATEDB | NOCREATEDB
	CanCreateRoles            bool   // CREATEROLE | NOCREATEROLE
	InheritPrivileges         bool   // INHERIT | NOINHERIT
	CanLogin                  bool   // LOGIN | NOLOGIN
	IsReplicationRole         bool   // REPLICATION | NOREPLICATION
	CanBypassRowLevelSecurity bool   // BYPASSRLS | NOBYPASSRLS
	ConnectionLimit           int32  // CONNECTION LIMIT connlimit
	ValidUntil                string // VALID UNTIL 'timestamp'
	IsValidUntilSet           bool
	AddToRoles                []string // IN ROLE role_name [, ...]
	AddAsMembers              []string // ROLE role_name [, ...]
	AddAsAdminMembers         []string // ADMIN role_name [, ...]
}

CreateRole handles the CREATE ROLE and CREATE USER statements (CREATE USER is an alias).

func (*CreateRole) Children added in v0.13.0 

func (c *CreateRole) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateRole) IsReadOnly added in v0.13.0 

func (c *CreateRole) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateRole) Resolved added in v0.13.0 

func (c *CreateRole) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateRole) RowIter added in v0.13.0 

func (c *CreateRole) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateRole) Schema added in v0.13.0 

func (c *CreateRole) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateRole) String added in v0.13.0 

func (c *CreateRole) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateRole) WithChildren added in v0.13.0 

func (c *CreateRole) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateRole) WithResolvedChildren added in v0.13.0 

func (c *CreateRole) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateSequence 

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

CreateSequence handles the CREATE SEQUENCE statement, along with SERIAL type definitions.

func NewCreateSequence 

func NewCreateSequence(ifNotExists bool, schema string, fromAlter bool, sequence *sequences.Sequence) *CreateSequence

NewCreateSequence returns a new *CreateSequence.

func (*CreateSequence) Children 

func (c *CreateSequence) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateSequence) IsReadOnly 

func (c *CreateSequence) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateSequence) Resolved 

func (c *CreateSequence) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateSequence) RowIter 

func (c *CreateSequence) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateSequence) Schema 

func (c *CreateSequence) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateSequence) String 

func (c *CreateSequence) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateSequence) WithChildren 

func (c *CreateSequence) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateSequence) WithResolvedChildren 

func (c *CreateSequence) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateTable 

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

CreateTable is a node that implements functionality specifically relevant to Doltgres' table creation needs.

func NewCreateTable 

func NewCreateTable(createTable *plan.CreateTable, sequences []*CreateSequence) *CreateTable

NewCreateTable returns a new *CreateTable.

func (*CreateTable) Children 

func (c *CreateTable) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateTable) DebugString added in v0.17.0 

func (c *CreateTable) DebugString() string

DebugString implements the sql.DebugStringer interface

func (*CreateTable) Expressions added in v0.18.0 

func (c *CreateTable) Expressions() []sql.Expression

Expressions implements the sql.Expressioner interface.

func (*CreateTable) IsReadOnly 

func (c *CreateTable) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateTable) Resolved 

func (c *CreateTable) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateTable) RowIter 

func (c *CreateTable) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateTable) Schema 

func (c *CreateTable) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateTable) String 

func (c *CreateTable) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateTable) TargetSchema added in v0.17.0 

func (c *CreateTable) TargetSchema() sql.Schema

func (*CreateTable) WithChildren 

func (c *CreateTable) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateTable) WithExpressions added in v0.18.0 

func (c *CreateTable) WithExpressions(expression ...sql.Expression) (sql.Node, error)

WithExpressions implements the sql.Expressioner interface.

func (CreateTable) WithTargetSchema added in v0.17.0 

func (c CreateTable) WithTargetSchema(schema sql.Schema) (sql.Node, error)

type CreateTrigger added in v0.50.1 

type CreateTrigger struct {
	Name       id.Trigger
	Function   id.Function
	Replace    bool
	Timing     triggers.TriggerTiming
	Events     []triggers.TriggerEvent
	ForEachRow bool
	When       []plpgsql.InterpreterOperation
	Arguments  []string
	Definition string
}

CreateTrigger implements CREATE TRIGGER.

func NewCreateTrigger added in v0.50.1 

func NewCreateTrigger(
	triggerName id.Trigger,
	functionName id.Function,
	replace bool,
	timing triggers.TriggerTiming,
	events []triggers.TriggerEvent,
	forEachRow bool,
	when []plpgsql.InterpreterOperation,
	arguments []string,
	definition string) *CreateTrigger

NewCreateTrigger returns a new *CreateTrigger.

func (*CreateTrigger) Children added in v0.50.1 

func (c *CreateTrigger) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateTrigger) IsReadOnly added in v0.50.1 

func (c *CreateTrigger) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateTrigger) Resolved added in v0.50.1 

func (c *CreateTrigger) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateTrigger) RowIter added in v0.50.1 

func (c *CreateTrigger) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateTrigger) Schema added in v0.50.1 

func (c *CreateTrigger) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateTrigger) String added in v0.50.1 

func (c *CreateTrigger) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateTrigger) WithChildren added in v0.50.1 

func (c *CreateTrigger) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateTrigger) WithResolvedChildren added in v0.50.1 

func (c *CreateTrigger) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type CreateType added in v0.16.0 

type CreateType struct {
	SchemaName string
	Name       string

	// composite type
	AsTypes []CompositeAsType

	// enum type
	Labels []string
	// contains filtered or unexported fields
}

CreateType handles the CREATE TYPE statement.

func NewCreateCompositeType added in v0.16.0 

func NewCreateCompositeType(schema, name string, typs []CompositeAsType) *CreateType

NewCreateCompositeType creates CreateType node for creating COMPOSITE type.

func NewCreateEnumType added in v0.16.0 

func NewCreateEnumType(schema, name string, labels []string) *CreateType

NewCreateEnumType creates CreateType node for creating ENUM type.

func NewCreateShellType added in v0.16.0 

func NewCreateShellType(schema, name string) *CreateType

NewCreateShellType creates CreateType node for creating a placeholder for a type to be defined later.

func (*CreateType) Children added in v0.16.0 

func (c *CreateType) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*CreateType) IsReadOnly added in v0.16.0 

func (c *CreateType) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*CreateType) Resolved added in v0.16.0 

func (c *CreateType) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*CreateType) RowIter added in v0.16.0 

func (c *CreateType) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*CreateType) Schema added in v0.16.0 

func (c *CreateType) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*CreateType) String added in v0.16.0 

func (c *CreateType) String() string

String implements the interface sql.ExecSourceRel.

func (*CreateType) WithChildren added in v0.16.0 

func (c *CreateType) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*CreateType) WithResolvedChildren added in v0.16.0 

func (c *CreateType) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DiscardStatement added in v0.11.0 

type DiscardStatement struct{}

DiscardStatement is just a marker type, since all functionality is handled by the connection handler, rather than the engine. It has to conform to the sql.ExecSourceRel interface to be used in the handler, but this functionality is all unused.

func (DiscardStatement) Children added in v0.11.0 

func (d DiscardStatement) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (DiscardStatement) IsReadOnly added in v0.11.0 

func (d DiscardStatement) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (DiscardStatement) Resolved added in v0.11.0 

func (d DiscardStatement) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (DiscardStatement) RowIter added in v0.11.0 

func (d DiscardStatement) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (DiscardStatement) Schema added in v0.11.0 

func (d DiscardStatement) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (DiscardStatement) String added in v0.11.0 

func (d DiscardStatement) String() string

String implements the interface sql.ExecSourceRel.

func (DiscardStatement) WithChildren added in v0.11.0 

func (d DiscardStatement) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (DiscardStatement) WithResolvedChildren added in v0.11.0 

func (d DiscardStatement) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DomainColumn added in v0.14.0 

type DomainColumn struct {
	Typ *types.DoltgresType
}

DomainColumn represents the column name `VALUE. It is a placeholder column reference later used for column defined as the domain type.

func (*DomainColumn) Children added in v0.14.0 

func (d *DomainColumn) Children() []sql.Expression

Children implements the interface sql.Expression.

func (*DomainColumn) Eval added in v0.14.0 

func (d *DomainColumn) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

Eval implements the interface sql.Expression.

func (*DomainColumn) IsNullable added in v0.14.0 

func (d *DomainColumn) IsNullable() bool

IsNullable implements the interface sql.Expression.

func (*DomainColumn) Resolved added in v0.14.0 

func (d *DomainColumn) Resolved() bool

Resolved implements the interface sql.Expression.

func (*DomainColumn) String added in v0.14.0 

func (d *DomainColumn) String() string

String implements the interface sql.Expression.

func (*DomainColumn) Type added in v0.14.0 

func (d *DomainColumn) Type() sql.Type

Type implements the interface sql.Expression.

func (*DomainColumn) WithChildren added in v0.14.0 

func (d *DomainColumn) WithChildren(children ...sql.Expression) (sql.Expression, error)

WithChildren implements the interface sql.Expression.

func (*DomainColumn) WithResolvedChildren added in v0.14.0 

func (d *DomainColumn) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropDomain added in v0.14.0 

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

DropDomain handles the DROP DOMAIN statement.

func NewDropDomain added in v0.14.0 

func NewDropDomain(ifExists bool, db string, schema string, domain string, cascade bool) *DropDomain

NewDropDomain returns a new *DropDomain.

func (*DropDomain) Children added in v0.14.0 

func (c *DropDomain) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropDomain) IsReadOnly added in v0.14.0 

func (c *DropDomain) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropDomain) Resolved added in v0.14.0 

func (c *DropDomain) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropDomain) RowIter added in v0.14.0 

func (c *DropDomain) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropDomain) Schema added in v0.14.0 

func (c *DropDomain) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropDomain) String added in v0.14.0 

func (c *DropDomain) String() string

String implements the interface sql.ExecSourceRel.

func (*DropDomain) WithChildren added in v0.14.0 

func (c *DropDomain) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropDomain) WithResolvedChildren added in v0.14.0 

func (c *DropDomain) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropExtension added in v0.51.0 

type DropExtension struct {
	Names    []string
	IfExists bool
	Cascade  bool
}

DropExtension implements DROP EXTENSION.

func NewDropExtension added in v0.51.0 

func NewDropExtension(names []string, ifExists bool, cascade bool) *DropExtension

NewDropExtension returns a new *DropExtension.

func (*DropExtension) Children added in v0.51.0 

func (c *DropExtension) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropExtension) IsReadOnly added in v0.51.0 

func (c *DropExtension) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropExtension) Resolved added in v0.51.0 

func (c *DropExtension) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropExtension) RowIter added in v0.51.0 

func (c *DropExtension) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropExtension) Schema added in v0.51.0 

func (c *DropExtension) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropExtension) String added in v0.51.0 

func (c *DropExtension) String() string

String implements the interface sql.ExecSourceRel.

func (*DropExtension) WithChildren added in v0.51.0 

func (c *DropExtension) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropExtension) WithResolvedChildren added in v0.51.0 

func (c *DropExtension) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropFunction added in v0.18.0 

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

DropFunction implements DROP FUNCTION.

func NewDropFunction added in v0.18.0 

func NewDropFunction(ifExists bool, routinesWithArgs []tree.RoutineWithArgs, cascade bool) *DropFunction

NewDropFunction returns a new *DropFunction.

func (*DropFunction) Children added in v0.18.0 

func (d *DropFunction) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropFunction) IsReadOnly added in v0.18.0 

func (d *DropFunction) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropFunction) Resolved added in v0.18.0 

func (d *DropFunction) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropFunction) RowIter added in v0.18.0 

func (d *DropFunction) RowIter(ctx *sql.Context, r sql.Row) (iter sql.RowIter, err error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropFunction) Schema added in v0.18.0 

func (d *DropFunction) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropFunction) String added in v0.18.0 

func (d *DropFunction) String() string

String implements the interface sql.ExecSourceRel.

func (*DropFunction) WithChildren added in v0.18.0 

func (d *DropFunction) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropFunction) WithResolvedChildren added in v0.18.0 

func (d *DropFunction) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropRole added in v0.13.0 

type DropRole struct {
	Names    []string
	IfExists bool
}

DropRole handles the DROP ROLE statement.

func (*DropRole) Children added in v0.13.0 

func (c *DropRole) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropRole) IsReadOnly added in v0.13.0 

func (c *DropRole) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropRole) Resolved added in v0.13.0 

func (c *DropRole) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropRole) RowIter added in v0.13.0 

func (c *DropRole) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropRole) Schema added in v0.13.0 

func (c *DropRole) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropRole) String added in v0.13.0 

func (c *DropRole) String() string

String implements the interface sql.ExecSourceRel.

func (*DropRole) WithChildren added in v0.13.0 

func (c *DropRole) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropRole) WithResolvedChildren added in v0.13.0 

func (c *DropRole) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropSequence 

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

DropSequence handles the DROP SEQUENCE statement.

func NewDropSequence 

func NewDropSequence(ifExists bool, schema string, sequence string, cascade bool) *DropSequence

NewDropSequence returns a new *DropSequence.

func (*DropSequence) Children 

func (c *DropSequence) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropSequence) IsReadOnly 

func (c *DropSequence) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropSequence) Resolved 

func (c *DropSequence) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropSequence) RowIter 

func (c *DropSequence) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropSequence) Schema 

func (c *DropSequence) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropSequence) String 

func (c *DropSequence) String() string

String implements the interface sql.ExecSourceRel.

func (*DropSequence) WithChildren 

func (c *DropSequence) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropSequence) WithResolvedChildren 

func (c *DropSequence) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type DropTable added in v0.14.0 

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

DropTable is a node that implements functionality specifically relevant to Doltgres' table dropping needs.

func NewDropTable added in v0.14.0 

func NewDropTable(dropTable *plan.DropTable) *DropTable

NewDropTable returns a new *DropTable.

func (*DropTable) Children added in v0.14.0 

func (c *DropTable) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropTable) IsReadOnly added in v0.14.0 

func (c *DropTable) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropTable) Resolved added in v0.14.0 

func (c *DropTable) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropTable) RowIter added in v0.14.0 

func (c *DropTable) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropTable) Schema added in v0.14.0 

func (c *DropTable) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropTable) String added in v0.14.0 

func (c *DropTable) String() string

String implements the interface sql.ExecSourceRel.

func (*DropTable) WithChildren added in v0.14.0 

func (c *DropTable) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

type DropType added in v0.16.0 

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

DropType handles the DROP TYPE statement.

func NewDropType added in v0.16.0 

func NewDropType(ifExists bool, db, sch, typ string, cascade bool) *DropType

NewDropType returns a new *DropType.

func (*DropType) Children added in v0.16.0 

func (c *DropType) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*DropType) IsReadOnly added in v0.16.0 

func (c *DropType) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*DropType) Resolved added in v0.16.0 

func (c *DropType) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*DropType) RowIter added in v0.16.0 

func (c *DropType) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*DropType) Schema added in v0.16.0 

func (c *DropType) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*DropType) String added in v0.16.0 

func (c *DropType) String() string

String implements the interface sql.ExecSourceRel.

func (*DropType) WithChildren added in v0.16.0 

func (c *DropType) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*DropType) WithResolvedChildren added in v0.16.0 

func (c *DropType) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type FunctionColumn added in v0.52.1 

type FunctionColumn struct {
	Name string
	Typ  *pgtypes.DoltgresType
	Idx  uint16
}

FunctionColumn represents the deferred column used in functions. It is a placeholder column reference later used for function calls.

func (*FunctionColumn) Children added in v0.52.1 

func (f *FunctionColumn) Children() []sql.Expression

Children implements the interface sql.Expression.

func (*FunctionColumn) Eval added in v0.52.1 

func (f *FunctionColumn) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

Eval implements the interface sql.Expression.

func (*FunctionColumn) IsNullable added in v0.52.1 

func (f *FunctionColumn) IsNullable() bool

IsNullable implements the interface sql.Expression.

func (*FunctionColumn) Resolved added in v0.52.1 

func (f *FunctionColumn) Resolved() bool

Resolved implements the interface sql.Expression.

func (*FunctionColumn) String added in v0.52.1 

func (f *FunctionColumn) String() string

String implements the interface sql.Expression.

func (*FunctionColumn) Type added in v0.52.1 

func (f *FunctionColumn) Type() sql.Type

Type implements the interface sql.Expression.

func (*FunctionColumn) WithChildren added in v0.52.1 

func (f *FunctionColumn) WithChildren(children ...sql.Expression) (sql.Expression, error)

WithChildren implements the interface sql.Expression.

func (*FunctionColumn) WithResolvedChildren added in v0.52.1 

func (f *FunctionColumn) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type Grant added in v0.14.0 

type Grant struct {
	GrantTable      *GrantTable
	GrantSchema     *GrantSchema
	GrantDatabase   *GrantDatabase
	GrantRole       *GrantRole
	ToRoles         []string
	WithGrantOption bool // This is "WITH ADMIN OPTION" for GrantRole only
	GrantedBy       string
}

Grant handles all of the GRANT statements.

func (*Grant) Children added in v0.14.0 

func (g *Grant) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*Grant) IsReadOnly added in v0.14.0 

func (g *Grant) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*Grant) Resolved added in v0.14.0 

func (g *Grant) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*Grant) RowIter added in v0.14.0 

func (g *Grant) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*Grant) Schema added in v0.14.0 

func (g *Grant) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*Grant) String added in v0.14.0 

func (g *Grant) String() string

String implements the interface sql.ExecSourceRel.

func (*Grant) WithChildren added in v0.14.0 

func (g *Grant) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*Grant) WithResolvedChildren added in v0.14.0 

func (g *Grant) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type GrantDatabase added in v0.15.0 

type GrantDatabase struct {
	Privileges []auth.Privilege
	Databases  []string
}

GrantDatabase specifically handles the GRANT ... ON DATABASE statement.

type GrantRole added in v0.15.0 

type GrantRole struct {
	Groups []string
}

GrantRole specifically handles the GRANT <roles> TO <roles> statement.

type GrantSchema added in v0.15.0 

type GrantSchema struct {
	Privileges []auth.Privilege
	Schemas    []string
}

GrantSchema specifically handles the GRANT ... ON SCHEMA statement.

type GrantTable added in v0.14.0 

type GrantTable struct {
	Privileges []auth.Privilege
	Tables     []doltdb.TableName
}

GrantTable specifically handles the GRANT ... ON TABLE statement.

type NoOp added in v0.17.0 

type NoOp struct {
	Warnings []string
}

NoOp is a node that does nothing and issues zero or more warnings when run. Used when a statement should parse but isn't expected to do anything, for compatibility with Postgres dumps / tools.

func (NoOp) Children added in v0.17.0 

func (n NoOp) Children() []sql.Node

func (NoOp) IsReadOnly added in v0.17.0 

func (n NoOp) IsReadOnly() bool

func (NoOp) Resolved added in v0.17.0 

func (n NoOp) Resolved() bool

func (NoOp) RowIter added in v0.17.0 

func (n NoOp) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

func (NoOp) Schema added in v0.17.0 

func (n NoOp) Schema() sql.Schema

func (NoOp) String added in v0.17.0 

func (n NoOp) String() string

func (NoOp) WithChildren added in v0.17.0 

func (n NoOp) WithChildren(children ...sql.Node) (sql.Node, error)

func (NoOp) WithResolvedChildren added in v0.17.0 

func (n NoOp) WithResolvedChildren(children []any) (any, error)

type Revoke added in v0.14.0 

type Revoke struct {
	RevokeTable    *RevokeTable
	RevokeSchema   *RevokeSchema
	RevokeDatabase *RevokeDatabase
	RevokeRole     *RevokeRole
	FromRoles      []string
	GrantedBy      string
	GrantOptionFor bool // This is "ADMIN OPTION FOR" for RevokeRole only
	Cascade        bool // When false, represents RESTRICT
}

Revoke handles all of the REVOKE statements.

func (*Revoke) Children added in v0.14.0 

func (r *Revoke) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*Revoke) IsReadOnly added in v0.14.0 

func (r *Revoke) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*Revoke) Resolved added in v0.14.0 

func (r *Revoke) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*Revoke) RowIter added in v0.14.0 

func (r *Revoke) RowIter(ctx *sql.Context, _ sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*Revoke) Schema added in v0.14.0 

func (r *Revoke) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*Revoke) String added in v0.14.0 

func (r *Revoke) String() string

String implements the interface sql.ExecSourceRel.

func (*Revoke) WithChildren added in v0.14.0 

func (r *Revoke) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*Revoke) WithResolvedChildren added in v0.14.0 

func (r *Revoke) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.Injectable.

type RevokeDatabase added in v0.15.0 

type RevokeDatabase struct {
	Privileges []auth.Privilege
	Databases  []string
}

RevokeDatabase specifically handles the REVOKE ... ON DATABASE statement.

type RevokeRole added in v0.15.0 

type RevokeRole struct {
	Groups []string
}

RevokeRole specifically handles the REVOKE <roles> FROM <roles> statement.

type RevokeSchema added in v0.15.0 

type RevokeSchema struct {
	Privileges []auth.Privilege
	Schemas    []string
}

RevokeSchema specifically handles the REVOKE ... ON SCHEMA statement.

type RevokeTable added in v0.14.0 

type RevokeTable struct {
	Privileges []auth.Privilege
	Tables     []doltdb.TableName
}

RevokeTable specifically handles the REVOKE ... ON TABLE statement.

type ShowSchemas added in v0.51.0 

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

ShowSchemas is a node that implements the SHOW SCHEMAS statement.

func NewShowSchemas added in v0.51.0 

func NewShowSchemas(database string) *ShowSchemas

NewShowSchemas returns a new *ShowSchemas.

func (*ShowSchemas) Children added in v0.51.0 

func (s *ShowSchemas) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*ShowSchemas) IsReadOnly added in v0.51.0 

func (s *ShowSchemas) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*ShowSchemas) Resolved added in v0.51.0 

func (s *ShowSchemas) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*ShowSchemas) RowIter added in v0.51.0 

func (s *ShowSchemas) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*ShowSchemas) Schema added in v0.51.0 

func (s *ShowSchemas) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*ShowSchemas) String added in v0.51.0 

func (s *ShowSchemas) String() string

String implements the interface sql.ExecSourceRel.

func (*ShowSchemas) WithChildren added in v0.51.0 

func (s *ShowSchemas) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*ShowSchemas) WithResolvedChildren added in v0.51.0 

func (s *ShowSchemas) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.InjectedStatement.

type ShowSequences added in v0.51.0 

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

ShowSequences is a node that implements the SHOW SCHEMAS statement.

func NewShowSequences added in v0.51.0 

func NewShowSequences(database string) *ShowSequences

NewShowSequences returns a new ShowSequences.

func (*ShowSequences) Children added in v0.51.0 

func (s *ShowSequences) Children() []sql.Node

Children implements the interface sql.ExecSourceRel.

func (*ShowSequences) IsReadOnly added in v0.51.0 

func (s *ShowSequences) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*ShowSequences) Resolved added in v0.51.0 

func (s *ShowSequences) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*ShowSequences) RowIter added in v0.51.0 

func (s *ShowSequences) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*ShowSequences) Schema added in v0.51.0 

func (s *ShowSequences) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*ShowSequences) String added in v0.51.0 

func (s *ShowSequences) String() string

String implements the interface sql.ExecSourceRel.

func (*ShowSequences) WithChildren added in v0.51.0 

func (s *ShowSequences) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*ShowSequences) WithResolvedChildren added in v0.51.0 

func (s *ShowSequences) WithResolvedChildren(children []any) (any, error)

WithResolvedChildren implements the interface vitess.InjectedStatement.

type TriggerExecution added in v0.50.1 

type TriggerExecution struct {
	Triggers []triggers.Trigger
	Split    TriggerExecutionRowHandling // How the source row should be split
	Return   TriggerExecutionRowHandling // How the returned rows should be combined
	Sch      sql.Schema
	Source   sql.Node
	Runner   pgexprs.StatementRunner
}

TriggerExecution handles the execution of a set of triggers on a table.

func (*TriggerExecution) Children added in v0.50.1 

func (te *TriggerExecution) Children() []sql.Node

func (*TriggerExecution) Expressions added in v0.50.1 

func (te *TriggerExecution) Expressions() []sql.Expression

Expressions implements the interface sql.Expressioner.

func (*TriggerExecution) IsReadOnly added in v0.50.1 

func (te *TriggerExecution) IsReadOnly() bool

IsReadOnly implements the interface sql.ExecSourceRel.

func (*TriggerExecution) Resolved added in v0.50.1 

func (te *TriggerExecution) Resolved() bool

Resolved implements the interface sql.ExecSourceRel.

func (*TriggerExecution) RowIter added in v0.50.1 

func (te *TriggerExecution) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error)

RowIter implements the interface sql.ExecSourceRel.

func (*TriggerExecution) Schema added in v0.50.1 

func (te *TriggerExecution) Schema() sql.Schema

Schema implements the interface sql.ExecSourceRel.

func (*TriggerExecution) String added in v0.50.1 

func (te *TriggerExecution) String() string

String implements the interface sql.ExecSourceRel.

func (*TriggerExecution) WithChildren added in v0.50.1 

func (te *TriggerExecution) WithChildren(children ...sql.Node) (sql.Node, error)

WithChildren implements the interface sql.ExecSourceRel.

func (*TriggerExecution) WithExpressions added in v0.50.1 

func (te *TriggerExecution) WithExpressions(expressions ...sql.Expression) (sql.Node, error)

WithExpressions implements the interface sql.Expressioner.

type TriggerExecutionRowHandling added in v0.50.1 

type TriggerExecutionRowHandling uint8

TriggerExecutionRowHandling states how to interpret the source row, or how to return the resulting row. 

const (
	TriggerExecutionRowHandling_None TriggerExecutionRowHandling = iota
	TriggerExecutionRowHandling_Old
	TriggerExecutionRowHandling_OldNew
	TriggerExecutionRowHandling_NewOld
	TriggerExecutionRowHandling_New
)

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.