mysqlxcrud

package
v0.9.8 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_CreateView_Algorithm       = ViewAlgorithm_UNDEFINED
	Default_CreateView_Security        = ViewSqlSecurity_DEFINER
	Default_CreateView_ReplaceExisting = bool(false)
)

Default values for CreateView fields.

View Source 
const (
	Default_DropView_IfExists = bool(false)
)

Default values for DropView fields.

View Source 
const (
	Default_Insert_Upsert = bool(false)
)

Default values for Insert fields.

View Source 
const (
	Default_Order_Direction = Order_ASC
)

Default values for Order fields.

Variables

View Source 
var (
	DataModel_name = map[int32]string{
		1: "DOCUMENT",
		2: "TABLE",
	}
	DataModel_value = map[string]int32{
		"DOCUMENT": 1,
		"TABLE":    2,
	}
)

Enum value maps for DataModel.

View Source 
var (
	ViewAlgorithm_name = map[int32]string{
		1: "UNDEFINED",
		2: "MERGE",
		3: "TEMPTABLE",
	}
	ViewAlgorithm_value = map[string]int32{
		"UNDEFINED": 1,
		"MERGE":     2,
		"TEMPTABLE": 3,
	}
)

Enum value maps for ViewAlgorithm.

View Source 
var (
	ViewSqlSecurity_name = map[int32]string{
		1: "INVOKER",
		2: "DEFINER",
	}
	ViewSqlSecurity_value = map[string]int32{
		"INVOKER": 1,
		"DEFINER": 2,
	}
)

Enum value maps for ViewSqlSecurity.

View Source 
var (
	ViewCheckOption_name = map[int32]string{
		1: "LOCAL",
		2: "CASCADED",
	}
	ViewCheckOption_value = map[string]int32{
		"LOCAL":    1,
		"CASCADED": 2,
	}
)

Enum value maps for ViewCheckOption.

View Source 
var (
	Order_Direction_name = map[int32]string{
		1: "ASC",
		2: "DESC",
	}
	Order_Direction_value = map[string]int32{
		"ASC":  1,
		"DESC": 2,
	}
)

Enum value maps for Order_Direction.

View Source 
var (
	UpdateOperation_UpdateType_name = map[int32]string{
		1: "SET",
		2: "ITEM_REMOVE",
		3: "ITEM_SET",
		4: "ITEM_REPLACE",
		5: "ITEM_MERGE",
		6: "ARRAY_INSERT",
		7: "ARRAY_APPEND",
		8: "MERGE_PATCH",
	}
	UpdateOperation_UpdateType_value = map[string]int32{
		"SET":          1,
		"ITEM_REMOVE":  2,
		"ITEM_SET":     3,
		"ITEM_REPLACE": 4,
		"ITEM_MERGE":   5,
		"ARRAY_INSERT": 6,
		"ARRAY_APPEND": 7,
		"MERGE_PATCH":  8,
	}
)

Enum value maps for UpdateOperation_UpdateType.

View Source 
var (
	Find_RowLock_name = map[int32]string{
		1: "SHARED_LOCK",
		2: "EXCLUSIVE_LOCK",
	}
	Find_RowLock_value = map[string]int32{
		"SHARED_LOCK":    1,
		"EXCLUSIVE_LOCK": 2,
	}
)

Enum value maps for Find_RowLock.

View Source 
var (
	Find_RowLockOptions_name = map[int32]string{
		1: "NOWAIT",
		2: "SKIP_LOCKED",
	}
	Find_RowLockOptions_value = map[string]int32{
		"NOWAIT":      1,
		"SKIP_LOCKED": 2,
	}
)

Enum value maps for Find_RowLockOptions.

View Source 
var File_mysqlx_crud_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Collection 

type Collection struct {
	Name   *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Schema *string `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*Collection) Descriptor deprecated 

func (*Collection) Descriptor() ([]byte, []int)

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetName 

func (x *Collection) GetName() string

func (*Collection) GetSchema 

func (x *Collection) GetSchema() string

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect 

func (x *Collection) ProtoReflect() protoreflect.Message

func (*Collection) Reset 

func (x *Collection) Reset()

func (*Collection) String 

func (x *Collection) String() string

type Column 

type Column struct {
	Name         *string                        `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Alias        *string                        `protobuf:"bytes,2,opt,name=alias" json:"alias,omitempty"`
	DocumentPath []*mysqlxexpr.DocumentPathItem `protobuf:"bytes,3,rep,name=document_path,json=documentPath" json:"document_path,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

func (*Column) Descriptor() ([]byte, []int)

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetAlias 

func (x *Column) GetAlias() string

func (*Column) GetDocumentPath 

func (x *Column) GetDocumentPath() []*mysqlxexpr.DocumentPathItem

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

func (x *Column) ProtoReflect() protoreflect.Message

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type CreateView 

type CreateView struct {

	// * name of the VIEW object, which should be created
	Collection *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	// * user name of the definer, if the value isn't set then the definer
	// is current user
	Definer *string `protobuf:"bytes,2,opt,name=definer" json:"definer,omitempty"`
	// * defines how MySQL Server processes the view
	Algorithm *ViewAlgorithm `protobuf:"varint,3,opt,name=algorithm,enum=Mysqlx.Crud.ViewAlgorithm,def=1" json:"algorithm,omitempty"`
	// * defines the security context in which the view is going be executed
	Security *ViewSqlSecurity `protobuf:"varint,4,opt,name=security,enum=Mysqlx.Crud.ViewSqlSecurity,def=2" json:"security,omitempty"`
	// * limits the write operations done on a VIEW
	Check *ViewCheckOption `protobuf:"varint,5,opt,name=check,enum=Mysqlx.Crud.ViewCheckOption" json:"check,omitempty"`
	// * defines the list of aliases for column names specified in `stmt`
	Column []string `protobuf:"bytes,6,rep,name=column" json:"column,omitempty"`
	// * Mysqlx.Crud.Find message from which the SELECT statement
	// is going to be build
	Stmt *Find `protobuf:"bytes,7,req,name=stmt" json:"stmt,omitempty"`
	// * if true then suppress error when created view already exists;
	// just replace it
	ReplaceExisting *bool `protobuf:"varint,8,opt,name=replace_existing,json=replaceExisting,def=0" json:"replace_existing,omitempty"`
	// contains filtered or unexported fields
}

* CreateView create view based on indicated @ref Mysqlx::Crud::Find message

func (*CreateView) Descriptor deprecated 

func (*CreateView) Descriptor() ([]byte, []int)

Deprecated: Use CreateView.ProtoReflect.Descriptor instead.

func (*CreateView) GetAlgorithm 

func (x *CreateView) GetAlgorithm() ViewAlgorithm

func (*CreateView) GetCheck 

func (x *CreateView) GetCheck() ViewCheckOption

func (*CreateView) GetCollection 

func (x *CreateView) GetCollection() *Collection

func (*CreateView) GetColumn 

func (x *CreateView) GetColumn() []string

func (*CreateView) GetDefiner 

func (x *CreateView) GetDefiner() string

func (*CreateView) GetReplaceExisting 

func (x *CreateView) GetReplaceExisting() bool

func (*CreateView) GetSecurity 

func (x *CreateView) GetSecurity() ViewSqlSecurity

func (*CreateView) GetStmt 

func (x *CreateView) GetStmt() *Find

func (*CreateView) ProtoMessage 

func (*CreateView) ProtoMessage()

func (*CreateView) ProtoReflect 

func (x *CreateView) ProtoReflect() protoreflect.Message

func (*CreateView) Reset 

func (x *CreateView) Reset()

func (*CreateView) String 

func (x *CreateView) String() string

type DataModel 

type DataModel int32

* DataModel to use for filters, names, ... 

const (
	DataModel_DOCUMENT DataModel = 1
	DataModel_TABLE    DataModel = 2
)

func (DataModel) Descriptor 

func (DataModel) Descriptor() protoreflect.EnumDescriptor

func (DataModel) Enum 

func (x DataModel) Enum() *DataModel

func (DataModel) EnumDescriptor deprecated 

func (DataModel) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataModel.Descriptor instead.

func (DataModel) Number 

func (x DataModel) Number() protoreflect.EnumNumber

func (DataModel) String 

func (x DataModel) String() string

func (DataModel) Type 

func (DataModel) Type() protoreflect.EnumType

func (*DataModel) UnmarshalJSON deprecated 

func (x *DataModel) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Delete 

type Delete struct {

	// * collection to change
	Collection *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	// * data model that the operations refer to
	DataModel *DataModel `protobuf:"varint,2,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	// * filter expression to match rows that the operations will apply on
	Criteria *mysqlxexpr.Expr `protobuf:"bytes,3,opt,name=criteria" json:"criteria,omitempty"`
	// * limits the number of rows to match
	// (user can set one of: limit, limit_expr)
	Limit *Limit `protobuf:"bytes,4,opt,name=limit" json:"limit,omitempty"`
	// * specifies order of matched rows
	Order []*Order `protobuf:"bytes,5,rep,name=order" json:"order,omitempty"`
	// * values for parameters used in filter expression
	Args []*mysqlxdatatypes.Scalar `protobuf:"bytes,6,rep,name=args" json:"args,omitempty"`
	// * limits the number of rows to match
	// (user can set one of: limit, limit_expr)
	LimitExpr *LimitExpr `protobuf:"bytes,7,opt,name=limit_expr,json=limitExpr" json:"limit_expr,omitempty"`
	// contains filtered or unexported fields
}

* Delete documents/rows from a Collection/Table

@returns @ref Mysqlx::Resultset

func (*Delete) Descriptor deprecated 

func (*Delete) Descriptor() ([]byte, []int)

Deprecated: Use Delete.ProtoReflect.Descriptor instead.

func (*Delete) GetArgs 

func (x *Delete) GetArgs() []*mysqlxdatatypes.Scalar

func (*Delete) GetCollection 

func (x *Delete) GetCollection() *Collection

func (*Delete) GetCriteria 

func (x *Delete) GetCriteria() *mysqlxexpr.Expr

func (*Delete) GetDataModel 

func (x *Delete) GetDataModel() DataModel

func (*Delete) GetLimit 

func (x *Delete) GetLimit() *Limit

func (*Delete) GetLimitExpr 

func (x *Delete) GetLimitExpr() *LimitExpr

func (*Delete) GetOrder 

func (x *Delete) GetOrder() []*Order

func (*Delete) ProtoMessage 

func (*Delete) ProtoMessage()

func (*Delete) ProtoReflect 

func (x *Delete) ProtoReflect() protoreflect.Message

func (*Delete) Reset 

func (x *Delete) Reset()

func (*Delete) String 

func (x *Delete) String() string

type DropView 

type DropView struct {

	// * name of the VIEW object, which should be deleted
	Collection *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	// * if true then suppress error when deleted view does not exists
	IfExists *bool `protobuf:"varint,2,opt,name=if_exists,json=ifExists,def=0" json:"if_exists,omitempty"`
	// contains filtered or unexported fields
}

* DropView removing existing view

func (*DropView) Descriptor deprecated 

func (*DropView) Descriptor() ([]byte, []int)

Deprecated: Use DropView.ProtoReflect.Descriptor instead.

func (*DropView) GetCollection 

func (x *DropView) GetCollection() *Collection

func (*DropView) GetIfExists 

func (x *DropView) GetIfExists() bool

func (*DropView) ProtoMessage 

func (*DropView) ProtoMessage()

func (*DropView) ProtoReflect 

func (x *DropView) ProtoReflect() protoreflect.Message

func (*DropView) Reset 

func (x *DropView) Reset()

func (*DropView) String 

func (x *DropView) String() string

type Find 

type Find struct {

	// * collection in which to find
	Collection *Collection `protobuf:"bytes,2,req,name=collection" json:"collection,omitempty"`
	// * data model that the operations refer to
	DataModel *DataModel `protobuf:"varint,3,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	// * list of column projections that shall be returned
	Projection []*Projection `protobuf:"bytes,4,rep,name=projection" json:"projection,omitempty"`
	// * values for parameters used in filter expression
	Args []*mysqlxdatatypes.Scalar `protobuf:"bytes,11,rep,name=args" json:"args,omitempty"`
	// * filter criteria
	Criteria *mysqlxexpr.Expr `protobuf:"bytes,5,opt,name=criteria" json:"criteria,omitempty"`
	// * numbers of rows that shall be skipped and returned
	// (user can set one of: limit, limit_expr)
	Limit *Limit `protobuf:"bytes,6,opt,name=limit" json:"limit,omitempty"`
	// * sort-order in which the rows/document shall be returned in
	Order []*Order `protobuf:"bytes,7,rep,name=order" json:"order,omitempty"`
	// * column expression list for aggregation (GROUP BY)
	Grouping []*mysqlxexpr.Expr `protobuf:"bytes,8,rep,name=grouping" json:"grouping,omitempty"`
	// * filter criteria for aggregated groups
	GroupingCriteria *mysqlxexpr.Expr `protobuf:"bytes,9,opt,name=grouping_criteria,json=groupingCriteria" json:"grouping_criteria,omitempty"`
	// * perform row locking on matches
	Locking *Find_RowLock `protobuf:"varint,12,opt,name=locking,enum=Mysqlx.Crud.Find_RowLock" json:"locking,omitempty"`
	// * additional options how to handle locked rows
	LockingOptions *Find_RowLockOptions `` /* 135-byte string literal not displayed */
	// * numbers of rows that shall be skipped and returned
	// (user can set one of: limit, limit_expr)
	LimitExpr *LimitExpr `protobuf:"bytes,14,opt,name=limit_expr,json=limitExpr" json:"limit_expr,omitempty"`
	// contains filtered or unexported fields
}

* Find Documents/Rows in a Collection/Table

@startuml client -> server: Find ... one or more Resultset ... @enduml

@returns @ref Mysqlx::Resultset

func (*Find) Descriptor deprecated 

func (*Find) Descriptor() ([]byte, []int)

Deprecated: Use Find.ProtoReflect.Descriptor instead.

func (*Find) GetArgs 

func (x *Find) GetArgs() []*mysqlxdatatypes.Scalar

func (*Find) GetCollection 

func (x *Find) GetCollection() *Collection

func (*Find) GetCriteria 

func (x *Find) GetCriteria() *mysqlxexpr.Expr

func (*Find) GetDataModel 

func (x *Find) GetDataModel() DataModel

func (*Find) GetGrouping 

func (x *Find) GetGrouping() []*mysqlxexpr.Expr

func (*Find) GetGroupingCriteria 

func (x *Find) GetGroupingCriteria() *mysqlxexpr.Expr

func (*Find) GetLimit 

func (x *Find) GetLimit() *Limit

func (*Find) GetLimitExpr 

func (x *Find) GetLimitExpr() *LimitExpr

func (*Find) GetLocking 

func (x *Find) GetLocking() Find_RowLock

func (*Find) GetLockingOptions 

func (x *Find) GetLockingOptions() Find_RowLockOptions

func (*Find) GetOrder 

func (x *Find) GetOrder() []*Order

func (*Find) GetProjection 

func (x *Find) GetProjection() []*Projection

func (*Find) ProtoMessage 

func (*Find) ProtoMessage()

func (*Find) ProtoReflect 

func (x *Find) ProtoReflect() protoreflect.Message

func (*Find) Reset 

func (x *Find) Reset()

func (*Find) String 

func (x *Find) String() string

type Find_RowLock 

type Find_RowLock int32
const (
	// * Lock matching rows against updates
	Find_SHARED_LOCK Find_RowLock = 1
	// * Lock matching rows so no other transaction can read or write to it
	Find_EXCLUSIVE_LOCK Find_RowLock = 2
)

func (Find_RowLock) Descriptor 

func (Find_RowLock) Descriptor() protoreflect.EnumDescriptor

func (Find_RowLock) Enum 

func (x Find_RowLock) Enum() *Find_RowLock

func (Find_RowLock) EnumDescriptor deprecated 

func (Find_RowLock) EnumDescriptor() ([]byte, []int)

Deprecated: Use Find_RowLock.Descriptor instead.

func (Find_RowLock) Number 

func (x Find_RowLock) Number() protoreflect.EnumNumber

func (Find_RowLock) String 

func (x Find_RowLock) String() string

func (Find_RowLock) Type 

func (Find_RowLock) Type() protoreflect.EnumType

func (*Find_RowLock) UnmarshalJSON deprecated 

func (x *Find_RowLock) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Find_RowLockOptions 

type Find_RowLockOptions int32
const (
	// * Do not wait to acquire row lock, fail with an error
	// if a requested row is locked
	Find_NOWAIT Find_RowLockOptions = 1
	// * Do not wait to acquire a row lock,
	// remove locked rows from the result set
	Find_SKIP_LOCKED Find_RowLockOptions = 2
)

func (Find_RowLockOptions) Descriptor 

func (Find_RowLockOptions) Descriptor() protoreflect.EnumDescriptor

func (Find_RowLockOptions) Enum 

func (x Find_RowLockOptions) Enum() *Find_RowLockOptions

func (Find_RowLockOptions) EnumDescriptor deprecated 

func (Find_RowLockOptions) EnumDescriptor() ([]byte, []int)

Deprecated: Use Find_RowLockOptions.Descriptor instead.

func (Find_RowLockOptions) Number 

func (x Find_RowLockOptions) Number() protoreflect.EnumNumber

func (Find_RowLockOptions) String 

func (x Find_RowLockOptions) String() string

func (Find_RowLockOptions) Type 

func (Find_RowLockOptions) Type() protoreflect.EnumType

func (*Find_RowLockOptions) UnmarshalJSON deprecated 

func (x *Find_RowLockOptions) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Insert 

type Insert struct {

	// * collection to insert into
	Collection *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	// * data model that the operations refer to
	DataModel *DataModel `protobuf:"varint,2,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	// * name of the columns to insert data into
	// (empty if data_model is DOCUMENT)
	Projection []*Column `protobuf:"bytes,3,rep,name=projection" json:"projection,omitempty"`
	// * set of rows to insert into the collection/table (a single expression
	// with a JSON document literal or an OBJECT expression)
	Row []*Insert_TypedRow `protobuf:"bytes,4,rep,name=row" json:"row,omitempty"`
	// * values for parameters used in row expressions
	Args []*mysqlxdatatypes.Scalar `protobuf:"bytes,5,rep,name=args" json:"args,omitempty"`
	// * true if this should be treated as an Upsert
	// (that is, update on duplicate key)
	Upsert *bool `protobuf:"varint,6,opt,name=upsert,def=0" json:"upsert,omitempty"`
	// contains filtered or unexported fields
}

* Insert documents/rows into a collection/table

@returns @ref Mysqlx::Resultset

func (*Insert) Descriptor deprecated 

func (*Insert) Descriptor() ([]byte, []int)

Deprecated: Use Insert.ProtoReflect.Descriptor instead.

func (*Insert) GetArgs 

func (x *Insert) GetArgs() []*mysqlxdatatypes.Scalar

func (*Insert) GetCollection 

func (x *Insert) GetCollection() *Collection

func (*Insert) GetDataModel 

func (x *Insert) GetDataModel() DataModel

func (*Insert) GetProjection 

func (x *Insert) GetProjection() []*Column

func (*Insert) GetRow 

func (x *Insert) GetRow() []*Insert_TypedRow

func (*Insert) GetUpsert 

func (x *Insert) GetUpsert() bool

func (*Insert) ProtoMessage 

func (*Insert) ProtoMessage()

func (*Insert) ProtoReflect 

func (x *Insert) ProtoReflect() protoreflect.Message

func (*Insert) Reset 

func (x *Insert) Reset()

func (*Insert) String 

func (x *Insert) String() string

type Insert_TypedRow 

type Insert_TypedRow struct {
	Field []*mysqlxexpr.Expr `protobuf:"bytes,1,rep,name=field" json:"field,omitempty"`
	// contains filtered or unexported fields
}

* set of fields to insert as a one row

func (*Insert_TypedRow) Descriptor deprecated 

func (*Insert_TypedRow) Descriptor() ([]byte, []int)

Deprecated: Use Insert_TypedRow.ProtoReflect.Descriptor instead.

func (*Insert_TypedRow) GetField 

func (x *Insert_TypedRow) GetField() []*mysqlxexpr.Expr

func (*Insert_TypedRow) ProtoMessage 

func (*Insert_TypedRow) ProtoMessage()

func (*Insert_TypedRow) ProtoReflect 

func (x *Insert_TypedRow) ProtoReflect() protoreflect.Message

func (*Insert_TypedRow) Reset 

func (x *Insert_TypedRow) Reset()

func (*Insert_TypedRow) String 

func (x *Insert_TypedRow) String() string

type Limit 

type Limit struct {

	// * maximum rows to filter
	RowCount *uint64 `protobuf:"varint,1,req,name=row_count,json=rowCount" json:"row_count,omitempty"`
	// * maximum rows to skip before applying the row_count
	Offset *uint64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Limit) Descriptor deprecated 

func (*Limit) Descriptor() ([]byte, []int)

Deprecated: Use Limit.ProtoReflect.Descriptor instead.

func (*Limit) GetOffset 

func (x *Limit) GetOffset() uint64

func (*Limit) GetRowCount 

func (x *Limit) GetRowCount() uint64

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) ProtoReflect 

func (x *Limit) ProtoReflect() protoreflect.Message

func (*Limit) Reset 

func (x *Limit) Reset()

func (*Limit) String 

func (x *Limit) String() string

type LimitExpr 

type LimitExpr struct {

	// * maximum rows to filter
	RowCount *mysqlxexpr.Expr `protobuf:"bytes,1,req,name=row_count,json=rowCount" json:"row_count,omitempty"`
	// * maximum rows to skip before applying the row_count
	Offset *mysqlxexpr.Expr `protobuf:"bytes,2,opt,name=offset" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

* LimitExpr, in comparison to Limit, is able to specify that row_count and offset are placeholders. This message support expressions of following types Expr/literal/UINT, Expr/PLACEHOLDER.

func (*LimitExpr) Descriptor deprecated 

func (*LimitExpr) Descriptor() ([]byte, []int)

Deprecated: Use LimitExpr.ProtoReflect.Descriptor instead.

func (*LimitExpr) GetOffset 

func (x *LimitExpr) GetOffset() *mysqlxexpr.Expr

func (*LimitExpr) GetRowCount 

func (x *LimitExpr) GetRowCount() *mysqlxexpr.Expr

func (*LimitExpr) ProtoMessage 

func (*LimitExpr) ProtoMessage()

func (*LimitExpr) ProtoReflect 

func (x *LimitExpr) ProtoReflect() protoreflect.Message

func (*LimitExpr) Reset 

func (x *LimitExpr) Reset()

func (*LimitExpr) String 

func (x *LimitExpr) String() string

type ModifyView 

type ModifyView struct {

	// * name of the VIEW object, which should be modified
	Collection *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	// * user name of the definer,
	// if the value isn't set then the definer is current user
	Definer *string `protobuf:"bytes,2,opt,name=definer" json:"definer,omitempty"`
	// * defined how MySQL Server processes the view
	Algorithm *ViewAlgorithm `protobuf:"varint,3,opt,name=algorithm,enum=Mysqlx.Crud.ViewAlgorithm" json:"algorithm,omitempty"`
	// * defines the security context in which the view is going be executed
	Security *ViewSqlSecurity `protobuf:"varint,4,opt,name=security,enum=Mysqlx.Crud.ViewSqlSecurity" json:"security,omitempty"`
	// * limits the write operations done on a VIEW
	Check *ViewCheckOption `protobuf:"varint,5,opt,name=check,enum=Mysqlx.Crud.ViewCheckOption" json:"check,omitempty"`
	// * defines the list of aliases for column names specified in `stmt`
	Column []string `protobuf:"bytes,6,rep,name=column" json:"column,omitempty"`
	// * Mysqlx.Crud.Find message from which the SELECT statement
	// is going to be build
	Stmt *Find `protobuf:"bytes,7,opt,name=stmt" json:"stmt,omitempty"`
	// contains filtered or unexported fields
}

* ModifyView modify existing view based on indicated @ref Mysqlx::Crud::Find message

func (*ModifyView) Descriptor deprecated 

func (*ModifyView) Descriptor() ([]byte, []int)

Deprecated: Use ModifyView.ProtoReflect.Descriptor instead.

func (*ModifyView) GetAlgorithm 

func (x *ModifyView) GetAlgorithm() ViewAlgorithm

func (*ModifyView) GetCheck 

func (x *ModifyView) GetCheck() ViewCheckOption

func (*ModifyView) GetCollection 

func (x *ModifyView) GetCollection() *Collection

func (*ModifyView) GetColumn 

func (x *ModifyView) GetColumn() []string

func (*ModifyView) GetDefiner 

func (x *ModifyView) GetDefiner() string

func (*ModifyView) GetSecurity 

func (x *ModifyView) GetSecurity() ViewSqlSecurity

func (*ModifyView) GetStmt 

func (x *ModifyView) GetStmt() *Find

func (*ModifyView) ProtoMessage 

func (*ModifyView) ProtoMessage()

func (*ModifyView) ProtoReflect 

func (x *ModifyView) ProtoReflect() protoreflect.Message

func (*ModifyView) Reset 

func (x *ModifyView) Reset()

func (*ModifyView) String 

func (x *ModifyView) String() string

type Order 

type Order struct {
	Expr      *mysqlxexpr.Expr `protobuf:"bytes,1,req,name=expr" json:"expr,omitempty"`
	Direction *Order_Direction `protobuf:"varint,2,opt,name=direction,enum=Mysqlx.Crud.Order_Direction,def=1" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

* Sort order

func (*Order) Descriptor deprecated 

func (*Order) Descriptor() ([]byte, []int)

Deprecated: Use Order.ProtoReflect.Descriptor instead.

func (*Order) GetDirection 

func (x *Order) GetDirection() Order_Direction

func (*Order) GetExpr 

func (x *Order) GetExpr() *mysqlxexpr.Expr

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) ProtoReflect 

func (x *Order) ProtoReflect() protoreflect.Message

func (*Order) Reset 

func (x *Order) Reset()

func (*Order) String 

func (x *Order) String() string

type Order_Direction 

type Order_Direction int32
const (
	Order_ASC  Order_Direction = 1
	Order_DESC Order_Direction = 2
)

func (Order_Direction) Descriptor 

func (Order_Direction) Descriptor() protoreflect.EnumDescriptor

func (Order_Direction) Enum 

func (x Order_Direction) Enum() *Order_Direction

func (Order_Direction) EnumDescriptor deprecated 

func (Order_Direction) EnumDescriptor() ([]byte, []int)

Deprecated: Use Order_Direction.Descriptor instead.

func (Order_Direction) Number 

func (x Order_Direction) Number() protoreflect.EnumNumber

func (Order_Direction) String 

func (x Order_Direction) String() string

func (Order_Direction) Type 

func (Order_Direction) Type() protoreflect.EnumType

func (*Order_Direction) UnmarshalJSON deprecated 

func (x *Order_Direction) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Projection 

type Projection struct {

	// * the expression identifying an element from the source data,
	// which can include a column identifier or any expression
	Source *mysqlxexpr.Expr `protobuf:"bytes,1,req,name=source" json:"source,omitempty"`
	// * optional alias. Required for DOCUMENTs (clients may use
	// the source string as default)
	Alias *string `protobuf:"bytes,2,opt,name=alias" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*Projection) Descriptor deprecated 

func (*Projection) Descriptor() ([]byte, []int)

Deprecated: Use Projection.ProtoReflect.Descriptor instead.

func (*Projection) GetAlias 

func (x *Projection) GetAlias() string

func (*Projection) GetSource 

func (x *Projection) GetSource() *mysqlxexpr.Expr

func (*Projection) ProtoMessage 

func (*Projection) ProtoMessage()

func (*Projection) ProtoReflect 

func (x *Projection) ProtoReflect() protoreflect.Message

func (*Projection) Reset 

func (x *Projection) Reset()

func (*Projection) String 

func (x *Projection) String() string

type Update 

type Update struct {

	// * collection to change
	Collection *Collection `protobuf:"bytes,2,req,name=collection" json:"collection,omitempty"`
	// * datamodel that the operations refer to
	DataModel *DataModel `protobuf:"varint,3,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	// * filter expression to match rows that the operations will apply on
	Criteria *mysqlxexpr.Expr `protobuf:"bytes,4,opt,name=criteria" json:"criteria,omitempty"`
	// * limits the number of rows to match
	// (user can set one of: limit, limit_expr)
	Limit *Limit `protobuf:"bytes,5,opt,name=limit" json:"limit,omitempty"`
	// * specifies order of matched rows
	Order []*Order `protobuf:"bytes,6,rep,name=order" json:"order,omitempty"`
	// * list of operations to be applied.
	// Valid operations will depend on the data_model
	Operation []*UpdateOperation `protobuf:"bytes,7,rep,name=operation" json:"operation,omitempty"`
	// * values for parameters used in filter expression
	Args []*mysqlxdatatypes.Scalar `protobuf:"bytes,8,rep,name=args" json:"args,omitempty"`
	// * limits the number of rows to match
	// (user can set one of: limit, limit_expr)
	LimitExpr *LimitExpr `protobuf:"bytes,9,opt,name=limit_expr,json=limitExpr" json:"limit_expr,omitempty"`
	// contains filtered or unexported fields
}

* Update documents/rows in a collection/table

@returns @ref Mysqlx::Resultset

func (*Update) Descriptor deprecated 

func (*Update) Descriptor() ([]byte, []int)

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetArgs 

func (x *Update) GetArgs() []*mysqlxdatatypes.Scalar

func (*Update) GetCollection 

func (x *Update) GetCollection() *Collection

func (*Update) GetCriteria 

func (x *Update) GetCriteria() *mysqlxexpr.Expr

func (*Update) GetDataModel 

func (x *Update) GetDataModel() DataModel

func (*Update) GetLimit 

func (x *Update) GetLimit() *Limit

func (*Update) GetLimitExpr 

func (x *Update) GetLimitExpr() *LimitExpr

func (*Update) GetOperation 

func (x *Update) GetOperation() []*UpdateOperation

func (*Update) GetOrder 

func (x *Update) GetOrder() []*Order

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect 

func (x *Update) ProtoReflect() protoreflect.Message

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

type UpdateOperation 

type UpdateOperation struct {

	// * specification of the value to be updated
	// - if data_model is TABLE, a column name may be specified and also
	// a document path, if the column has type JSON
	// - if data_model is DOCUMENT, only document paths are allowed
	//
	// @note in both cases, schema and table must be not set
	Source *mysqlxexpr.ColumnIdentifier `protobuf:"bytes,1,req,name=source" json:"source,omitempty"`
	// * the type of operation to be performed
	Operation *UpdateOperation_UpdateType `protobuf:"varint,2,req,name=operation,enum=Mysqlx.Crud.UpdateOperation_UpdateType" json:"operation,omitempty"`
	// * an expression to be computed as the new value for the operation
	Value *mysqlxexpr.Expr `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateOperation) Descriptor deprecated 

func (*UpdateOperation) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOperation.ProtoReflect.Descriptor instead.

func (*UpdateOperation) GetOperation 

func (x *UpdateOperation) GetOperation() UpdateOperation_UpdateType

func (*UpdateOperation) GetSource 

func (x *UpdateOperation) GetSource() *mysqlxexpr.ColumnIdentifier

func (*UpdateOperation) GetValue 

func (x *UpdateOperation) GetValue() *mysqlxexpr.Expr

func (*UpdateOperation) ProtoMessage 

func (*UpdateOperation) ProtoMessage()

func (*UpdateOperation) ProtoReflect 

func (x *UpdateOperation) ProtoReflect() protoreflect.Message

func (*UpdateOperation) Reset 

func (x *UpdateOperation) Reset()

func (*UpdateOperation) String 

func (x *UpdateOperation) String() string

type UpdateOperation_UpdateType 

type UpdateOperation_UpdateType int32
const (
	// * only allowed for TABLE
	UpdateOperation_SET UpdateOperation_UpdateType = 1
	// * no value (removes the identified path from a object or array)
	UpdateOperation_ITEM_REMOVE UpdateOperation_UpdateType = 2
	// * sets the new value on the identified path
	UpdateOperation_ITEM_SET UpdateOperation_UpdateType = 3
	// * replaces a value if the path exists
	UpdateOperation_ITEM_REPLACE UpdateOperation_UpdateType = 4
	// * source and value must be documents
	UpdateOperation_ITEM_MERGE UpdateOperation_UpdateType = 5
	// * insert the value in the array at the index identified in the source path
	UpdateOperation_ARRAY_INSERT UpdateOperation_UpdateType = 6
	// * append the value on the array at the identified path
	UpdateOperation_ARRAY_APPEND UpdateOperation_UpdateType = 7
	// * merge JSON object value with the provided patch expression
	UpdateOperation_MERGE_PATCH UpdateOperation_UpdateType = 8
)

func (UpdateOperation_UpdateType) Descriptor 

func (UpdateOperation_UpdateType) Descriptor() protoreflect.EnumDescriptor

func (UpdateOperation_UpdateType) Enum 

func (x UpdateOperation_UpdateType) Enum() *UpdateOperation_UpdateType

func (UpdateOperation_UpdateType) EnumDescriptor deprecated 

func (UpdateOperation_UpdateType) EnumDescriptor() ([]byte, []int)

Deprecated: Use UpdateOperation_UpdateType.Descriptor instead.

func (UpdateOperation_UpdateType) Number 

func (x UpdateOperation_UpdateType) Number() protoreflect.EnumNumber

func (UpdateOperation_UpdateType) String 

func (x UpdateOperation_UpdateType) String() string

func (UpdateOperation_UpdateType) Type 

func (UpdateOperation_UpdateType) Type() protoreflect.EnumType

func (*UpdateOperation_UpdateType) UnmarshalJSON deprecated 

func (x *UpdateOperation_UpdateType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ViewAlgorithm 

type ViewAlgorithm int32

* ViewAlgorithm defines how MySQL Server processes the view 

const (
	// * MySQL chooses which algorithm to use
	ViewAlgorithm_UNDEFINED ViewAlgorithm = 1
	// * the text of a statement that refers to the view and the view
	// definition are merged
	ViewAlgorithm_MERGE ViewAlgorithm = 2
	// * the view are retrieved into a temporary table
	ViewAlgorithm_TEMPTABLE ViewAlgorithm = 3
)

func (ViewAlgorithm) Descriptor 

func (ViewAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (ViewAlgorithm) Enum 

func (x ViewAlgorithm) Enum() *ViewAlgorithm

func (ViewAlgorithm) EnumDescriptor deprecated 

func (ViewAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use ViewAlgorithm.Descriptor instead.

func (ViewAlgorithm) Number 

func (x ViewAlgorithm) Number() protoreflect.EnumNumber

func (ViewAlgorithm) String 

func (x ViewAlgorithm) String() string

func (ViewAlgorithm) Type 

func (ViewAlgorithm) Type() protoreflect.EnumType

func (*ViewAlgorithm) UnmarshalJSON deprecated 

func (x *ViewAlgorithm) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ViewCheckOption 

type ViewCheckOption int32

* ViewCheckOption limits the write operations done on a `VIEW` (`INSERT`, `UPDATE`, `DELETE`) to rows in which the `WHERE` clause is `TRUE` 

const (
	// * the view WHERE clause is checked, but no underlying views are checked
	ViewCheckOption_LOCAL ViewCheckOption = 1
	// * the view WHERE clause is checked, then checking recurses
	// to underlying views
	ViewCheckOption_CASCADED ViewCheckOption = 2
)

func (ViewCheckOption) Descriptor 

func (ViewCheckOption) Descriptor() protoreflect.EnumDescriptor

func (ViewCheckOption) Enum 

func (x ViewCheckOption) Enum() *ViewCheckOption

func (ViewCheckOption) EnumDescriptor deprecated 

func (ViewCheckOption) EnumDescriptor() ([]byte, []int)

Deprecated: Use ViewCheckOption.Descriptor instead.

func (ViewCheckOption) Number 

func (x ViewCheckOption) Number() protoreflect.EnumNumber

func (ViewCheckOption) String 

func (x ViewCheckOption) String() string

func (ViewCheckOption) Type 

func (ViewCheckOption) Type() protoreflect.EnumType

func (*ViewCheckOption) UnmarshalJSON deprecated 

func (x *ViewCheckOption) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ViewSqlSecurity 

type ViewSqlSecurity int32

* ViewSqlSecurity defines the security context in which the view is going to be executed; this means that VIEW can be executed with current user permissions or with permissions of the user who defined the VIEW 

const (
	// * use current user permissions
	ViewSqlSecurity_INVOKER ViewSqlSecurity = 1
	// * use permissions of the user who defined the VIEW
	ViewSqlSecurity_DEFINER ViewSqlSecurity = 2
)

func (ViewSqlSecurity) Descriptor 

func (ViewSqlSecurity) Descriptor() protoreflect.EnumDescriptor

func (ViewSqlSecurity) Enum 

func (x ViewSqlSecurity) Enum() *ViewSqlSecurity

func (ViewSqlSecurity) EnumDescriptor deprecated 

func (ViewSqlSecurity) EnumDescriptor() ([]byte, []int)

Deprecated: Use ViewSqlSecurity.Descriptor instead.

func (ViewSqlSecurity) Number 

func (x ViewSqlSecurity) Number() protoreflect.EnumNumber

func (ViewSqlSecurity) String 

func (x ViewSqlSecurity) String() string

func (ViewSqlSecurity) Type 

func (ViewSqlSecurity) Type() protoreflect.EnumType

func (*ViewSqlSecurity) UnmarshalJSON deprecated 

func (x *ViewSqlSecurity) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

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.