mysqlxpb_crud

package
v0.0.0-...-86f4e66 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2021 License: MIT Imports: 8 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 []*mysqlxpb_expr.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() []*mysqlxpb_expr.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 *mysqlxpb_expr.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 []*mysqlxpb_datatypes.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() []*mysqlxpb_datatypes.Scalar

func (*Delete) GetCollection 

func (x *Delete) GetCollection() *Collection

func (*Delete) GetCriteria 

func (x *Delete) GetCriteria() *mysqlxpb_expr.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 []*mysqlxpb_datatypes.Scalar `protobuf:"bytes,11,rep,name=args" json:"args,omitempty"`
	//* filter criteria
	Criteria *mysqlxpb_expr.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 []*mysqlxpb_expr.Expr `protobuf:"bytes,8,rep,name=grouping" json:"grouping,omitempty"`
	//* filter criteria for aggregated groups
	GroupingCriteria *mysqlxpb_expr.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() []*mysqlxpb_datatypes.Scalar

func (*Find) GetCollection 

func (x *Find) GetCollection() *Collection

func (*Find) GetCriteria 

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

func (*Find) GetDataModel 

func (x *Find) GetDataModel() DataModel

func (*Find) GetGrouping 

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

func (*Find) GetGroupingCriteria 

func (x *Find) GetGroupingCriteria() *mysqlxpb_expr.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 []*mysqlxpb_datatypes.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() []*mysqlxpb_datatypes.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 []*mysqlxpb_expr.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() []*mysqlxpb_expr.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 *mysqlxpb_expr.Expr `protobuf:"bytes,1,req,name=row_count,json=rowCount" json:"row_count,omitempty"`
	//* maximum rows to skip before applying the row_count
	Offset *mysqlxpb_expr.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() *mysqlxpb_expr.Expr

func (*LimitExpr) GetRowCount 

func (x *LimitExpr) GetRowCount() *mysqlxpb_expr.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      *mysqlxpb_expr.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() *mysqlxpb_expr.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 *mysqlxpb_expr.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() *mysqlxpb_expr.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 *mysqlxpb_expr.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 []*mysqlxpb_datatypes.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() []*mysqlxpb_datatypes.Scalar

func (*Update) GetCollection 

func (x *Update) GetCollection() *Collection

func (*Update) GetCriteria 

func (x *Update) GetCriteria() *mysqlxpb_expr.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 *mysqlxpb_expr.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 *mysqlxpb_expr.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() *mysqlxpb_expr.ColumnIdentifier

func (*UpdateOperation) GetValue 

func (x *UpdateOperation) GetValue() *mysqlxpb_expr.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 uses who defined the VIEW 

const (
	//* use current user permissions
	ViewSqlSecurity_INVOKER ViewSqlSecurity = 1
	//* use permissions of the uses 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.