Mysqlx_Crud

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2018 License: Apache-2.0, Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package Mysqlx_Crud is a generated protocol buffer package.

Basic CRUD operations

It is generated from these files: 

github.com/pingcap/tipb/go-mysqlx/Crud/mysqlx_crud.proto

It has these top-level messages: 

Column
Projection
Collection
Limit
Order
UpdateOperation
Find
Insert
Update
Delete
CreateView
ModifyView
DropView

Index

Constants

View Source 
const Default_CreateView_ReplaceExisting bool = false
View Source 
const Default_DropView_IfExists bool = false

Variables

View Source 
var (
	ErrInvalidLengthMysqlxCrud = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMysqlxCrud   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DataModel_name = map[int32]string{
	1: "DOCUMENT",
	2: "TABLE",
}
View Source 
var DataModel_value = map[string]int32{
	"DOCUMENT": 1,
	"TABLE":    2,
}
View Source 
var Order_Direction_name = map[int32]string{
	1: "ASC",
	2: "DESC",
}
View Source 
var Order_Direction_value = map[string]int32{
	"ASC":  1,
	"DESC": 2,
}
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",
}
View Source 
var 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,
}
View Source 
var ViewAlgorithm_name = map[int32]string{
	1: "UNDEFINED",
	2: "MERGE",
	3: "TEMPTABLE",
}
View Source 
var ViewAlgorithm_value = map[string]int32{
	"UNDEFINED": 1,
	"MERGE":     2,
	"TEMPTABLE": 3,
}
View Source 
var ViewCheckOption_name = map[int32]string{
	1: "LOCAL",
	2: "CASCADED",
}
View Source 
var ViewCheckOption_value = map[string]int32{
	"LOCAL":    1,
	"CASCADED": 2,
}
View Source 
var ViewSqlSecurity_name = map[int32]string{
	1: "INVOKER",
	2: "DEFINER",
}
View Source 
var ViewSqlSecurity_value = map[string]int32{
	"INVOKER": 1,
	"DEFINER": 2,
}

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"`
	XXX_unrecognized []byte  `json:"-"`
}

collection

func (*Collection) Descriptor 

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

func (*Collection) GetName 

func (m *Collection) GetName() string

func (*Collection) GetSchema 

func (m *Collection) GetSchema() string

func (*Collection) Marshal 

func (m *Collection) Marshal() (dAtA []byte, err error)

func (*Collection) MarshalTo 

func (m *Collection) MarshalTo(dAtA []byte) (int, error)

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) Reset 

func (m *Collection) Reset()

func (*Collection) Size 

func (m *Collection) Size() (n int)

func (*Collection) String 

func (m *Collection) String() string

func (*Collection) Unmarshal 

func (m *Collection) Unmarshal(dAtA []byte) error

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     []*Mysqlx_Expr.DocumentPathItem `protobuf:"bytes,3,rep,name=document_path,json=documentPath" json:"document_path,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

column definition

func (*Column) Descriptor 

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

func (*Column) GetAlias 

func (m *Column) GetAlias() string

func (*Column) GetDocumentPath 

func (m *Column) GetDocumentPath() []*Mysqlx_Expr.DocumentPathItem

func (*Column) GetName 

func (m *Column) GetName() string

func (*Column) Marshal 

func (m *Column) Marshal() (dAtA []byte, err error)

func (*Column) MarshalTo 

func (m *Column) MarshalTo(dAtA []byte) (int, error)

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) Reset 

func (m *Column) Reset()

func (*Column) Size 

func (m *Column) Size() (n int)

func (*Column) String 

func (m *Column) String() string

func (*Column) Unmarshal 

func (m *Column) Unmarshal(dAtA []byte) error

type CreateView 

type CreateView struct {
	Collection       *Collection      `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	Definer          *string          `protobuf:"bytes,2,opt,name=definer" json:"definer,omitempty"`
	Algorithm        *ViewAlgorithm   `protobuf:"varint,3,opt,name=algorithm,enum=Mysqlx.Crud.ViewAlgorithm,def=1" json:"algorithm,omitempty"`
	Security         *ViewSqlSecurity `protobuf:"varint,4,opt,name=security,enum=Mysqlx.Crud.ViewSqlSecurity,def=2" json:"security,omitempty"`
	Check            *ViewCheckOption `protobuf:"varint,5,opt,name=check,enum=Mysqlx.Crud.ViewCheckOption" json:"check,omitempty"`
	Column           []string         `protobuf:"bytes,6,rep,name=column" json:"column,omitempty"`
	Stmt             *Find            `protobuf:"bytes,7,req,name=stmt" json:"stmt,omitempty"`
	ReplaceExisting  *bool            `protobuf:"varint,8,opt,name=replace_existing,json=replaceExisting,def=0" json:"replace_existing,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*CreateView) Descriptor 

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

func (*CreateView) GetAlgorithm 

func (m *CreateView) GetAlgorithm() ViewAlgorithm

func (*CreateView) GetCheck 

func (m *CreateView) GetCheck() ViewCheckOption

func (*CreateView) GetCollection 

func (m *CreateView) GetCollection() *Collection

func (*CreateView) GetColumn 

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

func (*CreateView) GetDefiner 

func (m *CreateView) GetDefiner() string

func (*CreateView) GetReplaceExisting 

func (m *CreateView) GetReplaceExisting() bool

func (*CreateView) GetSecurity 

func (m *CreateView) GetSecurity() ViewSqlSecurity

func (*CreateView) GetStmt 

func (m *CreateView) GetStmt() *Find

func (*CreateView) Marshal 

func (m *CreateView) Marshal() (dAtA []byte, err error)

func (*CreateView) MarshalTo 

func (m *CreateView) MarshalTo(dAtA []byte) (int, error)

func (*CreateView) ProtoMessage 

func (*CreateView) ProtoMessage()

func (*CreateView) Reset 

func (m *CreateView) Reset()

func (*CreateView) Size 

func (m *CreateView) Size() (n int)

func (*CreateView) String 

func (m *CreateView) String() string

func (*CreateView) Unmarshal 

func (m *CreateView) Unmarshal(dAtA []byte) error

type DataModel 

type DataModel int32

DataModel to use for filters, names, ... 

const (
	DataModel_DOCUMENT DataModel = 1
	DataModel_TABLE    DataModel = 2
)

func (DataModel) Enum 

func (x DataModel) Enum() *DataModel

func (DataModel) EnumDescriptor 

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

func (DataModel) String 

func (x DataModel) String() string

func (*DataModel) UnmarshalJSON 

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

type Delete 

type Delete struct {
	Collection       *Collection                `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	DataModel        *DataModel                 `protobuf:"varint,2,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	Criteria         *Mysqlx_Expr.Expr          `protobuf:"bytes,3,opt,name=criteria" json:"criteria,omitempty"`
	Args             []*Mysqlx_Datatypes.Scalar `protobuf:"bytes,6,rep,name=args" json:"args,omitempty"`
	Limit            *Limit                     `protobuf:"bytes,4,opt,name=limit" json:"limit,omitempty"`
	Order            []*Order                   `protobuf:"bytes,5,rep,name=order" json:"order,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

Delete documents/rows from a Collection/Table

:param collection: collection to change :param data_model: datamodel that the operations refer to :param criteria: filter expression to match rows that the operations will apply on :param args: values for parameters used in filter expression :param limit: limits the number of rows to match :param order: specifies order of matched rows :Returns: :protobuf:msg:`Mysqlx.Resultset::`

func (*Delete) Descriptor 

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

func (*Delete) GetArgs 

func (m *Delete) GetArgs() []*Mysqlx_Datatypes.Scalar

func (*Delete) GetCollection 

func (m *Delete) GetCollection() *Collection

func (*Delete) GetCriteria 

func (m *Delete) GetCriteria() *Mysqlx_Expr.Expr

func (*Delete) GetDataModel 

func (m *Delete) GetDataModel() DataModel

func (*Delete) GetLimit 

func (m *Delete) GetLimit() *Limit

func (*Delete) GetOrder 

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

func (*Delete) Marshal 

func (m *Delete) Marshal() (dAtA []byte, err error)

func (*Delete) MarshalTo 

func (m *Delete) MarshalTo(dAtA []byte) (int, error)

func (*Delete) ProtoMessage 

func (*Delete) ProtoMessage()

func (*Delete) Reset 

func (m *Delete) Reset()

func (*Delete) Size 

func (m *Delete) Size() (n int)

func (*Delete) String 

func (m *Delete) String() string

func (*Delete) Unmarshal 

func (m *Delete) Unmarshal(dAtA []byte) error

type DropView 

type DropView struct {
	Collection       *Collection `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	IfExists         *bool       `protobuf:"varint,2,opt,name=if_exists,json=ifExists,def=0" json:"if_exists,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*DropView) Descriptor 

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

func (*DropView) GetCollection 

func (m *DropView) GetCollection() *Collection

func (*DropView) GetIfExists 

func (m *DropView) GetIfExists() bool

func (*DropView) Marshal 

func (m *DropView) Marshal() (dAtA []byte, err error)

func (*DropView) MarshalTo 

func (m *DropView) MarshalTo(dAtA []byte) (int, error)

func (*DropView) ProtoMessage 

func (*DropView) ProtoMessage()

func (*DropView) Reset 

func (m *DropView) Reset()

func (*DropView) Size 

func (m *DropView) Size() (n int)

func (*DropView) String 

func (m *DropView) String() string

func (*DropView) Unmarshal 

func (m *DropView) Unmarshal(dAtA []byte) error

type Find 

type Find struct {
	Collection       *Collection                `protobuf:"bytes,2,req,name=collection" json:"collection,omitempty"`
	DataModel        *DataModel                 `protobuf:"varint,3,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	Projection       []*Projection              `protobuf:"bytes,4,rep,name=projection" json:"projection,omitempty"`
	Criteria         *Mysqlx_Expr.Expr          `protobuf:"bytes,5,opt,name=criteria" json:"criteria,omitempty"`
	Args             []*Mysqlx_Datatypes.Scalar `protobuf:"bytes,11,rep,name=args" json:"args,omitempty"`
	Limit            *Limit                     `protobuf:"bytes,6,opt,name=limit" json:"limit,omitempty"`
	Order            []*Order                   `protobuf:"bytes,7,rep,name=order" json:"order,omitempty"`
	Grouping         []*Mysqlx_Expr.Expr        `protobuf:"bytes,8,rep,name=grouping" json:"grouping,omitempty"`
	GroupingCriteria *Mysqlx_Expr.Expr          `protobuf:"bytes,9,opt,name=grouping_criteria,json=groupingCriteria" json:"grouping_criteria,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

Find Documents/Rows in a Collection/Table

.. uml:: 

client -> server: Find
... one or more Resultset ...

:param collection: collection to insert into :param data_model: datamodel that the operations refer to :param projection: list of column projections that shall be returned :param args: values for parameters used in filter expression :param criteria: filter criteria :param limit: numbers of rows that shall be skipped and returned :param order: sort-order in which the rows/document shall be returned in :param grouping: column expression list for aggregation (GROUP BY) :param grouping_criteria: filter criteria for aggregated groups :Returns: :protobuf:msg:`Mysqlx.Resultset::`

func (*Find) Descriptor 

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

func (*Find) GetArgs 

func (m *Find) GetArgs() []*Mysqlx_Datatypes.Scalar

func (*Find) GetCollection 

func (m *Find) GetCollection() *Collection

func (*Find) GetCriteria 

func (m *Find) GetCriteria() *Mysqlx_Expr.Expr

func (*Find) GetDataModel 

func (m *Find) GetDataModel() DataModel

func (*Find) GetGrouping 

func (m *Find) GetGrouping() []*Mysqlx_Expr.Expr

func (*Find) GetGroupingCriteria 

func (m *Find) GetGroupingCriteria() *Mysqlx_Expr.Expr

func (*Find) GetLimit 

func (m *Find) GetLimit() *Limit

func (*Find) GetOrder 

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

func (*Find) GetProjection 

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

func (*Find) Marshal 

func (m *Find) Marshal() (dAtA []byte, err error)

func (*Find) MarshalTo 

func (m *Find) MarshalTo(dAtA []byte) (int, error)

func (*Find) ProtoMessage 

func (*Find) ProtoMessage()

func (*Find) Reset 

func (m *Find) Reset()

func (*Find) Size 

func (m *Find) Size() (n int)

func (*Find) String 

func (m *Find) String() string

func (*Find) Unmarshal 

func (m *Find) Unmarshal(dAtA []byte) error

type Insert 

type Insert struct {
	Collection       *Collection                `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	DataModel        *DataModel                 `protobuf:"varint,2,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	Projection       []*Column                  `protobuf:"bytes,3,rep,name=projection" json:"projection,omitempty"`
	Row              []*Insert_TypedRow         `protobuf:"bytes,4,rep,name=row" json:"row,omitempty"`
	Args             []*Mysqlx_Datatypes.Scalar `protobuf:"bytes,5,rep,name=args" json:"args,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

Insert documents/rows into a collection/table

:param collection: collection to insert into :param data_model: datamodel that the operations refer to :param projection: name of the columns to insert data into (empty if data_model is DOCUMENT) :param row: set of rows to insert into the collection/table (a single expression with a JSON document literal or an OBJECT expression) :param args: values for parameters used in row expressions :Returns: :protobuf:msg:`Mysqlx.Resultset::`

func (*Insert) Descriptor 

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

func (*Insert) GetArgs 

func (m *Insert) GetArgs() []*Mysqlx_Datatypes.Scalar

func (*Insert) GetCollection 

func (m *Insert) GetCollection() *Collection

func (*Insert) GetDataModel 

func (m *Insert) GetDataModel() DataModel

func (*Insert) GetProjection 

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

func (*Insert) GetRow 

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

func (*Insert) Marshal 

func (m *Insert) Marshal() (dAtA []byte, err error)

func (*Insert) MarshalTo 

func (m *Insert) MarshalTo(dAtA []byte) (int, error)

func (*Insert) ProtoMessage 

func (*Insert) ProtoMessage()

func (*Insert) Reset 

func (m *Insert) Reset()

func (*Insert) Size 

func (m *Insert) Size() (n int)

func (*Insert) String 

func (m *Insert) String() string

func (*Insert) Unmarshal 

func (m *Insert) Unmarshal(dAtA []byte) error

type Insert_TypedRow 

type Insert_TypedRow struct {
	Field            []*Mysqlx_Expr.Expr `protobuf:"bytes,1,rep,name=field" json:"field,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*Insert_TypedRow) Descriptor 

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

func (*Insert_TypedRow) GetField 

func (m *Insert_TypedRow) GetField() []*Mysqlx_Expr.Expr

func (*Insert_TypedRow) Marshal 

func (m *Insert_TypedRow) Marshal() (dAtA []byte, err error)

func (*Insert_TypedRow) MarshalTo 

func (m *Insert_TypedRow) MarshalTo(dAtA []byte) (int, error)

func (*Insert_TypedRow) ProtoMessage 

func (*Insert_TypedRow) ProtoMessage()

func (*Insert_TypedRow) Reset 

func (m *Insert_TypedRow) Reset()

func (*Insert_TypedRow) Size 

func (m *Insert_TypedRow) Size() (n int)

func (*Insert_TypedRow) String 

func (m *Insert_TypedRow) String() string

func (*Insert_TypedRow) Unmarshal 

func (m *Insert_TypedRow) Unmarshal(dAtA []byte) error

type Limit 

type Limit struct {
	RowCount         *uint64 `protobuf:"varint,1,req,name=row_count,json=rowCount" json:"row_count,omitempty"`
	Offset           *uint64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

limit

:param row_count: maximum rows to filter :param offset: maximum rows to skip before applying the row_count

func (*Limit) Descriptor 

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

func (*Limit) GetOffset 

func (m *Limit) GetOffset() uint64

func (*Limit) GetRowCount 

func (m *Limit) GetRowCount() uint64

func (*Limit) Marshal 

func (m *Limit) Marshal() (dAtA []byte, err error)

func (*Limit) MarshalTo 

func (m *Limit) MarshalTo(dAtA []byte) (int, error)

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) Reset 

func (m *Limit) Reset()

func (*Limit) Size 

func (m *Limit) Size() (n int)

func (*Limit) String 

func (m *Limit) String() string

func (*Limit) Unmarshal 

func (m *Limit) Unmarshal(dAtA []byte) error

type ModifyView 

type ModifyView struct {
	Collection       *Collection      `protobuf:"bytes,1,req,name=collection" json:"collection,omitempty"`
	Definer          *string          `protobuf:"bytes,2,opt,name=definer" json:"definer,omitempty"`
	Algorithm        *ViewAlgorithm   `protobuf:"varint,3,opt,name=algorithm,enum=Mysqlx.Crud.ViewAlgorithm" json:"algorithm,omitempty"`
	Security         *ViewSqlSecurity `protobuf:"varint,4,opt,name=security,enum=Mysqlx.Crud.ViewSqlSecurity" json:"security,omitempty"`
	Check            *ViewCheckOption `protobuf:"varint,5,opt,name=check,enum=Mysqlx.Crud.ViewCheckOption" json:"check,omitempty"`
	Column           []string         `protobuf:"bytes,6,rep,name=column" json:"column,omitempty"`
	Stmt             *Find            `protobuf:"bytes,7,opt,name=stmt" json:"stmt,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*ModifyView) Descriptor 

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

func (*ModifyView) GetAlgorithm 

func (m *ModifyView) GetAlgorithm() ViewAlgorithm

func (*ModifyView) GetCheck 

func (m *ModifyView) GetCheck() ViewCheckOption

func (*ModifyView) GetCollection 

func (m *ModifyView) GetCollection() *Collection

func (*ModifyView) GetColumn 

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

func (*ModifyView) GetDefiner 

func (m *ModifyView) GetDefiner() string

func (*ModifyView) GetSecurity 

func (m *ModifyView) GetSecurity() ViewSqlSecurity

func (*ModifyView) GetStmt 

func (m *ModifyView) GetStmt() *Find

func (*ModifyView) Marshal 

func (m *ModifyView) Marshal() (dAtA []byte, err error)

func (*ModifyView) MarshalTo 

func (m *ModifyView) MarshalTo(dAtA []byte) (int, error)

func (*ModifyView) ProtoMessage 

func (*ModifyView) ProtoMessage()

func (*ModifyView) Reset 

func (m *ModifyView) Reset()

func (*ModifyView) Size 

func (m *ModifyView) Size() (n int)

func (*ModifyView) String 

func (m *ModifyView) String() string

func (*ModifyView) Unmarshal 

func (m *ModifyView) Unmarshal(dAtA []byte) error

type Order 

type Order struct {
	Expr             *Mysqlx_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"`
	XXX_unrecognized []byte            `json:"-"`
}

sort order

func (*Order) Descriptor 

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

func (*Order) GetDirection 

func (m *Order) GetDirection() Order_Direction

func (*Order) GetExpr 

func (m *Order) GetExpr() *Mysqlx_Expr.Expr

func (*Order) Marshal 

func (m *Order) Marshal() (dAtA []byte, err error)

func (*Order) MarshalTo 

func (m *Order) MarshalTo(dAtA []byte) (int, error)

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) Size 

func (m *Order) Size() (n int)

func (*Order) String 

func (m *Order) String() string

func (*Order) Unmarshal 

func (m *Order) Unmarshal(dAtA []byte) error

type Order_Direction 

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

func (Order_Direction) Enum 

func (x Order_Direction) Enum() *Order_Direction

func (Order_Direction) EnumDescriptor 

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

func (Order_Direction) String 

func (x Order_Direction) String() string

func (*Order_Direction) UnmarshalJSON 

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

type Projection 

type Projection struct {
	Source           *Mysqlx_Expr.Expr `protobuf:"bytes,1,req,name=source" json:"source,omitempty"`
	Alias            *string           `protobuf:"bytes,2,opt,name=alias" json:"alias,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

a projection

:param source: the expression identifying an element from the source data 

which can include a column identifier or any expression

:param alias: optional alias. Required for DOCUMENTs (clients may use 

the source string as default)

func (*Projection) Descriptor 

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

func (*Projection) GetAlias 

func (m *Projection) GetAlias() string

func (*Projection) GetSource 

func (m *Projection) GetSource() *Mysqlx_Expr.Expr

func (*Projection) Marshal 

func (m *Projection) Marshal() (dAtA []byte, err error)

func (*Projection) MarshalTo 

func (m *Projection) MarshalTo(dAtA []byte) (int, error)

func (*Projection) ProtoMessage 

func (*Projection) ProtoMessage()

func (*Projection) Reset 

func (m *Projection) Reset()

func (*Projection) Size 

func (m *Projection) Size() (n int)

func (*Projection) String 

func (m *Projection) String() string

func (*Projection) Unmarshal 

func (m *Projection) Unmarshal(dAtA []byte) error

type Update 

type Update struct {
	Collection       *Collection                `protobuf:"bytes,2,req,name=collection" json:"collection,omitempty"`
	DataModel        *DataModel                 `protobuf:"varint,3,opt,name=data_model,json=dataModel,enum=Mysqlx.Crud.DataModel" json:"data_model,omitempty"`
	Criteria         *Mysqlx_Expr.Expr          `protobuf:"bytes,4,opt,name=criteria" json:"criteria,omitempty"`
	Args             []*Mysqlx_Datatypes.Scalar `protobuf:"bytes,8,rep,name=args" json:"args,omitempty"`
	Limit            *Limit                     `protobuf:"bytes,5,opt,name=limit" json:"limit,omitempty"`
	Order            []*Order                   `protobuf:"bytes,6,rep,name=order" json:"order,omitempty"`
	Operation        []*UpdateOperation         `protobuf:"bytes,7,rep,name=operation" json:"operation,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

Update documents/rows in a collection/table

:param collection: collection to change :param data_model: datamodel that the operations refer to :param criteria: filter expression to match rows that the operations will apply on :param args: values for parameters used in filter expression :param limit: limits the number of rows to match :param order: specifies order of matched rows :param operation: list of operations to be applied. Valid operations will depend on the data_model. :Returns: :protobuf:msg:`Mysqlx.Resultset::`

func (*Update) Descriptor 

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

func (*Update) GetArgs 

func (m *Update) GetArgs() []*Mysqlx_Datatypes.Scalar

func (*Update) GetCollection 

func (m *Update) GetCollection() *Collection

func (*Update) GetCriteria 

func (m *Update) GetCriteria() *Mysqlx_Expr.Expr

func (*Update) GetDataModel 

func (m *Update) GetDataModel() DataModel

func (*Update) GetLimit 

func (m *Update) GetLimit() *Limit

func (*Update) GetOperation 

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

func (*Update) GetOrder 

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

func (*Update) Marshal 

func (m *Update) Marshal() (dAtA []byte, err error)

func (*Update) MarshalTo 

func (m *Update) MarshalTo(dAtA []byte) (int, error)

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) Size 

func (m *Update) Size() (n int)

func (*Update) String 

func (m *Update) String() string

func (*Update) Unmarshal 

func (m *Update) Unmarshal(dAtA []byte) error

type UpdateOperation 

type UpdateOperation struct {
	Source           *Mysqlx_Expr.ColumnIdentifier `protobuf:"bytes,1,req,name=source" json:"source,omitempty"`
	Operation        *UpdateOperation_UpdateType   `protobuf:"varint,2,req,name=operation,enum=Mysqlx.Crud.UpdateOperation_UpdateType" json:"operation,omitempty"`
	Value            *Mysqlx_Expr.Expr             `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

update operations

:param source: 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
in both cases, schema and table must be not set

:param operation: the type of operation to be performed :param value: an expression to be computed as the new value for the operation

func (*UpdateOperation) Descriptor 

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

func (*UpdateOperation) GetOperation 

func (m *UpdateOperation) GetOperation() UpdateOperation_UpdateType

func (*UpdateOperation) GetSource 

func (m *UpdateOperation) GetSource() *Mysqlx_Expr.ColumnIdentifier

func (*UpdateOperation) GetValue 

func (m *UpdateOperation) GetValue() *Mysqlx_Expr.Expr

func (*UpdateOperation) Marshal 

func (m *UpdateOperation) Marshal() (dAtA []byte, err error)

func (*UpdateOperation) MarshalTo 

func (m *UpdateOperation) MarshalTo(dAtA []byte) (int, error)

func (*UpdateOperation) ProtoMessage 

func (*UpdateOperation) ProtoMessage()

func (*UpdateOperation) Reset 

func (m *UpdateOperation) Reset()

func (*UpdateOperation) Size 

func (m *UpdateOperation) Size() (n int)

func (*UpdateOperation) String 

func (m *UpdateOperation) String() string

func (*UpdateOperation) Unmarshal 

func (m *UpdateOperation) Unmarshal(dAtA []byte) error

type UpdateOperation_UpdateType 

type UpdateOperation_UpdateType int32
const (
	UpdateOperation_SET          UpdateOperation_UpdateType = 1
	UpdateOperation_ITEM_REMOVE  UpdateOperation_UpdateType = 2
	UpdateOperation_ITEM_SET     UpdateOperation_UpdateType = 3
	UpdateOperation_ITEM_REPLACE UpdateOperation_UpdateType = 4
	UpdateOperation_ITEM_MERGE   UpdateOperation_UpdateType = 5
	UpdateOperation_ARRAY_INSERT UpdateOperation_UpdateType = 6
	UpdateOperation_ARRAY_APPEND UpdateOperation_UpdateType = 7
)

func (UpdateOperation_UpdateType) Enum 

func (x UpdateOperation_UpdateType) Enum() *UpdateOperation_UpdateType

func (UpdateOperation_UpdateType) EnumDescriptor 

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

func (UpdateOperation_UpdateType) String 

func (x UpdateOperation_UpdateType) String() string

func (*UpdateOperation_UpdateType) UnmarshalJSON 

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

type ViewAlgorithm 

type ViewAlgorithm int32

ViewAlgorithm defines how MySQL Server processes the view 

const (
	ViewAlgorithm_UNDEFINED ViewAlgorithm = 1
	ViewAlgorithm_MERGE     ViewAlgorithm = 2
	ViewAlgorithm_TEMPTABLE ViewAlgorithm = 3
)
const Default_CreateView_Algorithm ViewAlgorithm = ViewAlgorithm_UNDEFINED

func (ViewAlgorithm) Enum 

func (x ViewAlgorithm) Enum() *ViewAlgorithm

func (ViewAlgorithm) EnumDescriptor 

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

func (ViewAlgorithm) String 

func (x ViewAlgorithm) String() string

func (*ViewAlgorithm) UnmarshalJSON 

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

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 (
	ViewCheckOption_LOCAL    ViewCheckOption = 1
	ViewCheckOption_CASCADED ViewCheckOption = 2
)

func (ViewCheckOption) Enum 

func (x ViewCheckOption) Enum() *ViewCheckOption

func (ViewCheckOption) EnumDescriptor 

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

func (ViewCheckOption) String 

func (x ViewCheckOption) String() string

func (*ViewCheckOption) UnmarshalJSON 

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

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 (
	ViewSqlSecurity_INVOKER ViewSqlSecurity = 1
	ViewSqlSecurity_DEFINER ViewSqlSecurity = 2
)
const Default_CreateView_Security ViewSqlSecurity = ViewSqlSecurity_DEFINER

func (ViewSqlSecurity) Enum 

func (x ViewSqlSecurity) Enum() *ViewSqlSecurity

func (ViewSqlSecurity) EnumDescriptor 

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

func (ViewSqlSecurity) String 

func (x ViewSqlSecurity) String() string

func (*ViewSqlSecurity) UnmarshalJSON 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.