You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@calcite.apache.org by fr...@apache.org on 2025/02/25 22:24:55 UTC
(calcite-avatica-go) branch main updated: [CALCITE-6861] Switch to opaque protobuf API
This is an automated email from the ASF dual-hosted git repository.
francischuang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/calcite-avatica-go.git
The following commit(s) were added to refs/heads/main by this push:
new 85ac9ad [CALCITE-6861] Switch to opaque protobuf API
85ac9ad is described below
commit 85ac9ad9f2e5471a872f5fc9db0991556d3f868b
Author: Francis Chuang <fr...@apache.org>
AuthorDate: Wed Feb 26 09:23:44 2025 +1100
[CALCITE-6861] Switch to opaque protobuf API
---
connection.go | 60 +-
docker-compose.yml | 4 +-
docker.sh | 2 +-
driver.go | 16 +-
generic/generic.go | 30 +-
hsqldb/hsqldb.go | 30 +-
http_client.go | 12 +-
message/common.pb.go | 1695 ++++++++++++++++++++++++++++-----------------
message/helper.go | 2 +-
message/requests.pb.go | 1760 +++++++++++++++++++++++++++--------------------
message/responses.pb.go | 1484 ++++++++++++++++++++++++---------------
phoenix/phoenix.go | 28 +-
rows.go | 54 +-
statement.go | 76 +-
transaction.go | 16 +-
15 files changed, 3153 insertions(+), 2116 deletions(-)
diff --git a/connection.go b/connection.go
index 3ffa0ea..29d6487 100644
--- a/connection.go
+++ b/connection.go
@@ -44,11 +44,11 @@ func (c *conn) prepare(ctx context.Context, query string) (driver.Stmt, error) {
return nil, driver.ErrBadConn
}
- response, err := c.httpClient.post(ctx, &message.PrepareRequest{
+ response, err := c.httpClient.post(ctx, message.PrepareRequest_builder{
ConnectionId: c.connectionId,
Sql: query,
MaxRowsTotal: c.config.maxRowsTotal,
- })
+ }.Build())
if err != nil {
return nil, c.avaticaErrorToResponseErrorOrError(err)
@@ -57,10 +57,10 @@ func (c *conn) prepare(ctx context.Context, query string) (driver.Stmt, error) {
prepareResponse := response.(*message.PrepareResponse)
return &stmt{
- statementID: prepareResponse.Statement.Id,
+ statementID: prepareResponse.GetStatement().GetId(),
conn: c,
- parameters: prepareResponse.Statement.Signature.Parameters,
- handle: prepareResponse.Statement,
+ parameters: prepareResponse.GetStatement().GetSignature().GetParameters(),
+ handle: prepareResponse.GetStatement(),
batchUpdates: make([]*message.UpdateBatch, 0),
}, nil
}
@@ -79,9 +79,9 @@ func (c *conn) Close() error {
return driver.ErrBadConn
}
- _, err := c.httpClient.post(context.Background(), &message.CloseConnectionRequest{
+ _, err := c.httpClient.post(context.Background(), message.CloseConnectionRequest_builder{
ConnectionId: c.connectionId,
- })
+ }.Build())
c.connectionId = ""
@@ -106,14 +106,14 @@ func (c *conn) begin(ctx context.Context, isolationLevel isoLevel) (driver.Tx, e
isolationLevel = isoLevel(c.config.transactionIsolation)
}
- _, err := c.httpClient.post(ctx, &message.ConnectionSyncRequest{
+ _, err := c.httpClient.post(ctx, message.ConnectionSyncRequest_builder{
ConnectionId: c.connectionId,
- ConnProps: &message.ConnectionProperties{
+ ConnProps: message.ConnectionProperties_builder{
AutoCommit: false,
HasAutoCommit: true,
TransactionIsolation: uint32(isolationLevel),
- },
- })
+ }.Build(),
+ }.Build())
if err != nil {
return nil, c.avaticaErrorToResponseErrorOrError(err)
@@ -137,31 +137,31 @@ func (c *conn) exec(ctx context.Context, query string, args []namedValue) (drive
return nil, driver.ErrSkip
}
- st, err := c.httpClient.post(ctx, &message.CreateStatementRequest{
+ st, err := c.httpClient.post(ctx, message.CreateStatementRequest_builder{
ConnectionId: c.connectionId,
- })
+ }.Build())
if err != nil {
return nil, c.avaticaErrorToResponseErrorOrError(err)
}
- statementID := st.(*message.CreateStatementResponse).StatementId
+ statementID := st.(*message.CreateStatementResponse).GetStatementId()
defer c.closeStatement(context.Background(), statementID)
- res, err := c.httpClient.post(ctx, &message.PrepareAndExecuteRequest{
+ res, err := c.httpClient.post(ctx, message.PrepareAndExecuteRequest_builder{
ConnectionId: c.connectionId,
StatementId: statementID,
Sql: query,
MaxRowsTotal: c.config.maxRowsTotal,
FirstFrameMaxSize: c.config.frameMaxSize,
- })
+ }.Build())
if err != nil {
return nil, c.avaticaErrorToResponseErrorOrError(err)
}
// Currently there is only 1 ResultSet per response for exec
- changed := int64(res.(*message.ExecuteResponse).Results[0].UpdateCount)
+ changed := int64(res.(*message.ExecuteResponse).GetResults()[0].GetUpdateCount())
return &result{
affectedRows: changed,
@@ -183,30 +183,30 @@ func (c *conn) query(ctx context.Context, query string, args []namedValue) (driv
return nil, driver.ErrSkip
}
- st, err := c.httpClient.post(ctx, &message.CreateStatementRequest{
+ st, err := c.httpClient.post(ctx, message.CreateStatementRequest_builder{
ConnectionId: c.connectionId,
- })
+ }.Build())
if err != nil {
return nil, c.avaticaErrorToResponseErrorOrError(err)
}
- statementID := st.(*message.CreateStatementResponse).StatementId
+ statementID := st.(*message.CreateStatementResponse).GetStatementId()
- res, err := c.httpClient.post(ctx, &message.PrepareAndExecuteRequest{
+ res, err := c.httpClient.post(ctx, message.PrepareAndExecuteRequest_builder{
ConnectionId: c.connectionId,
StatementId: statementID,
Sql: query,
MaxRowsTotal: c.config.maxRowsTotal,
FirstFrameMaxSize: c.config.frameMaxSize,
- })
+ }.Build())
if err != nil {
_ = c.closeStatement(context.Background(), statementID)
return nil, c.avaticaErrorToResponseErrorOrError(err)
}
- resultSets := res.(*message.ExecuteResponse).Results
+ resultSets := res.(*message.ExecuteResponse).GetResults()
return newRows(c, statementID, true, resultSets), nil
}
@@ -226,11 +226,11 @@ func (c *conn) avaticaErrorToResponseErrorOrError(err error) error {
}
return avaticaErrors.ResponseError{
- Exceptions: avaticaErr.message.Exceptions,
- ErrorMessage: avaticaErr.message.ErrorMessage,
- Severity: int8(avaticaErr.message.Severity),
- ErrorCode: avaticaErrors.ErrorCode(avaticaErr.message.ErrorCode),
- SqlState: avaticaErrors.SQLState(avaticaErr.message.SqlState),
+ Exceptions: avaticaErr.message.GetExceptions(),
+ ErrorMessage: avaticaErr.message.GetErrorMessage(),
+ Severity: int8(avaticaErr.message.GetSeverity()),
+ ErrorCode: avaticaErrors.ErrorCode(avaticaErr.message.GetErrorCode()),
+ SqlState: avaticaErrors.SQLState(avaticaErr.message.GetSqlState()),
Metadata: &avaticaErrors.RPCMetadata{
ServerAddress: message.ServerAddressFromMetadata(avaticaErr.message),
},
@@ -247,9 +247,9 @@ func (c *conn) ResetSession(_ context.Context) error {
}
func (c *conn) closeStatement(ctx context.Context, statementID uint32) error {
- _, err := c.httpClient.post(context.Background(), &message.CloseStatementRequest{
+ _, err := c.httpClient.post(context.Background(), message.CloseStatementRequest_builder{
ConnectionId: c.connectionId,
StatementId: statementID,
- })
+ }.Build())
return c.avaticaErrorToResponseErrorOrError(err)
}
diff --git a/docker-compose.yml b/docker-compose.yml
index 98cad06..b576cc9 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -103,8 +103,8 @@ services:
working_dir: /source
command: sh -c "./docker.sh compile-protobuf"
environment:
- AVATICA_VERSION: 1.24.0
- PROTOBUF_VERSION: 25.1
+ AVATICA_VERSION: 1.26.0
+ PROTOBUF_VERSION: 29.3
volumes:
- .:/source
- $GOPATH/pkg/mod/cache:/go/pkg/mod/cache
diff --git a/docker.sh b/docker.sh
index 093d848..2397b8a 100755
--- a/docker.sh
+++ b/docker.sh
@@ -603,7 +603,7 @@ compile_protobuf(){
# Compile the protobuf
GITHUB_PACKAGE=github.com/apache/calcite-avatica-go
- protoc --proto_path=/tmp/avatica/core/src/main/protobuf --go_out=/source --go_opt=module=$GITHUB_PACKAGE --go_opt=Mcommon.proto=$GITHUB_PACKAGE/message --go_opt=Mrequests.proto=$GITHUB_PACKAGE/message --go_opt=Mresponses.proto=$GITHUB_PACKAGE/message /tmp/avatica/core/src/main/protobuf/*.proto
+ protoc --proto_path=/tmp/avatica/core/src/main/protobuf --go_out=/source --go_opt=module=$GITHUB_PACKAGE --go_opt=Mcommon.proto=$GITHUB_PACKAGE/message --go_opt=Mrequests.proto=$GITHUB_PACKAGE/message --go_opt=Mresponses.proto=$GITHUB_PACKAGE/message /tmp/avatica/core/src/main/protobuf/*.proto --go_opt=default_api_level=API_OPAQUE #Remove API_OPAQUE when Avatica protobufs are updated to edition 2024
echo "Protobuf compiled successfully"
}
diff --git a/driver.go b/driver.go
index faa5ed9..efadfda 100644
--- a/driver.go
+++ b/driver.go
@@ -99,9 +99,9 @@ func (c *Connector) Connect(context.Context) (driver.Conn, error) {
if err != nil {
return nil, err
}
- response, err := conn.httpClient.post(context.Background(), &message.DatabasePropertyRequest{
+ response, err := conn.httpClient.post(context.Background(), message.DatabasePropertyRequest_builder{
ConnectionId: conn.connectionId,
- })
+ }.Build())
if err != nil {
return nil, conn.avaticaErrorToResponseErrorOrError(err)
@@ -111,9 +111,9 @@ func (c *Connector) Connect(context.Context) (driver.Conn, error) {
adapter := ""
- for _, property := range databasePropertyResponse.Props {
- if property.Key.Name == "GET_DRIVER_NAME" {
- adapter = property.Value.StringValue
+ for _, property := range databasePropertyResponse.GetProps() {
+ if property.GetKey().GetName() == "GET_DRIVER_NAME" {
+ adapter = property.GetValue().GetStringValue()
}
}
@@ -131,12 +131,12 @@ func registerConn(conn *conn) error {
info[k] = v
}
// Open a connection to the server
- req := &message.OpenConnectionRequest{
+ req := message.OpenConnectionRequest_builder{
ConnectionId: conn.connectionId,
Info: info,
- }
+ }.Build()
if conn.config.schema != "" {
- req.Info["schema"] = conn.config.schema
+ req.GetInfo()["schema"] = conn.config.schema
}
_, err := conn.httpClient.post(context.Background(), req)
if err != nil {
diff --git a/generic/generic.go b/generic/generic.go
index 9017b93..372ed3c 100644
--- a/generic/generic.go
+++ b/generic/generic.go
@@ -37,22 +37,22 @@ func (a Adapter) GetPingStatement() string {
func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.Column {
column := &internal.Column{
- Name: col.ColumnName,
- TypeName: col.Type.Name,
- Nullable: col.Nullable != 0,
+ Name: col.GetColumnName(),
+ TypeName: col.GetType().GetName(),
+ Nullable: col.GetNullable() != 0,
}
// Handle precision and length
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL":
- precision := int64(col.Precision)
+ precision := int64(col.GetPrecision())
if precision == 0 {
precision = math.MaxInt64
}
- scale := int64(col.Scale)
+ scale := int64(col.GetScale())
if scale == 0 {
scale = math.MaxInt64
@@ -63,11 +63,11 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
Scale: scale,
}
case "VARCHAR", "CHARACTER VARYING", "CHAR", "CHARACTER", "BINARY", "VARBINARY", "BINARY VARYING":
- column.Length = int64(col.Precision)
+ column.Length = int64(col.GetPrecision())
}
// Handle scan types
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "INTEGER", "BIGINT", "TINYINT", "SMALLINT":
column.ScanType = reflect.TypeOf(int64(0))
@@ -91,7 +91,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
}
// Handle rep type special cases for decimals, floats, date, time and timestamp
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL", "NUMERIC":
column.Rep = message.Rep_BIG_DECIMAL
case "FLOAT", "REAL":
@@ -103,7 +103,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
case "TIMESTAMP", "TIMESTAMP WITH LOCAL TIME ZONE", "TIMESTAMP WITH TIME ZONE":
column.Rep = message.Rep_JAVA_SQL_TIMESTAMP
default:
- column.Rep = col.Type.Rep
+ column.Rep = col.GetType().GetRep()
}
return column
@@ -111,11 +111,11 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
func (a Adapter) ErrorResponseToResponseError(err *message.ErrorResponse) errors.ResponseError {
return errors.ResponseError{
- Exceptions: err.Exceptions,
- ErrorMessage: err.ErrorMessage,
- Severity: int8(err.Severity),
- ErrorCode: errors.ErrorCode(err.ErrorCode),
- SqlState: errors.SQLState(err.SqlState),
+ Exceptions: err.GetExceptions(),
+ ErrorMessage: err.GetErrorMessage(),
+ Severity: int8(err.GetSeverity()),
+ ErrorCode: errors.ErrorCode(err.GetErrorCode()),
+ SqlState: errors.SQLState(err.GetSqlState()),
Metadata: &errors.RPCMetadata{
ServerAddress: message.ServerAddressFromMetadata(err),
},
diff --git a/hsqldb/hsqldb.go b/hsqldb/hsqldb.go
index 8fa9e8e..a88bf81 100644
--- a/hsqldb/hsqldb.go
+++ b/hsqldb/hsqldb.go
@@ -37,22 +37,22 @@ func (a Adapter) GetPingStatement() string {
func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.Column {
column := &internal.Column{
- Name: col.ColumnName,
- TypeName: col.Type.Name,
- Nullable: col.Nullable != 0,
+ Name: col.GetColumnName(),
+ TypeName: col.GetType().GetName(),
+ Nullable: col.GetNullable() != 0,
}
// Handle precision and length
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL", "NUMERIC":
- precision := int64(col.Precision)
+ precision := int64(col.GetPrecision())
if precision == 0 {
precision = math.MaxInt64
}
- scale := int64(col.Scale)
+ scale := int64(col.GetScale())
if scale == 0 {
scale = math.MaxInt64
@@ -63,11 +63,11 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
Scale: scale,
}
case "VARCHAR", "CHAR", "CHARACTER", "BINARY", "VARBINARY", "BIT", "BITVARYING":
- column.Length = int64(col.Precision)
+ column.Length = int64(col.GetPrecision())
}
// Handle scan types
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "INTEGER", "BIGINT", "TINYINT", "SMALLINT":
column.ScanType = reflect.TypeOf(int64(0))
@@ -91,7 +91,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
}
// Handle rep type special cases for decimals, floats, date, time and timestamp
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL", "NUMERIC":
column.Rep = message.Rep_BIG_DECIMAL
case "FLOAT":
@@ -103,7 +103,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
case "TIMESTAMP":
column.Rep = message.Rep_JAVA_SQL_TIMESTAMP
default:
- column.Rep = col.Type.Rep
+ column.Rep = col.GetType().GetRep()
}
return column
@@ -111,11 +111,11 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
func (a Adapter) ErrorResponseToResponseError(err *message.ErrorResponse) errors.ResponseError {
return errors.ResponseError{
- Exceptions: err.Exceptions,
- ErrorMessage: err.ErrorMessage,
- Severity: int8(err.Severity),
- ErrorCode: errors.ErrorCode(err.ErrorCode),
- SqlState: errors.SQLState(err.SqlState),
+ Exceptions: err.GetExceptions(),
+ ErrorMessage: err.GetErrorMessage(),
+ Severity: int8(err.GetSeverity()),
+ ErrorCode: errors.ErrorCode(err.GetErrorCode()),
+ SqlState: errors.SQLState(err.GetSqlState()),
Metadata: &errors.RPCMetadata{
ServerAddress: message.ServerAddressFromMetadata(err),
},
diff --git a/http_client.go b/http_client.go
index d510f96..af19cc9 100644
--- a/http_client.go
+++ b/http_client.go
@@ -48,7 +48,7 @@ type avaticaError struct {
}
func (e avaticaError) Error() string {
- return fmt.Sprintf("avatica encountered an error: %s", e.message.ErrorMessage)
+ return fmt.Sprintf("avatica encountered an error: %s", e.message.GetErrorMessage())
}
// NewHTTPClient creates a new httpClient from a host.
@@ -102,10 +102,10 @@ func (c *httpClient) post(ctx context.Context, message proto.Message) (proto.Mes
return nil, fmt.Errorf("error marshaling request message to protobuf: %w", err)
}
- wire := &avaticaMessage.WireMessage{
+ wire := avaticaMessage.WireMessage_builder{
Name: classNameFromRequest(message),
WrappedMessage: wrapped,
- }
+ }.Build()
body, err := proto.Marshal(wire)
@@ -145,13 +145,13 @@ func (c *httpClient) post(ctx context.Context, message proto.Message) (proto.Mes
return nil, fmt.Errorf("error unmarshaling wire message: %w", err)
}
- inner, err := responseFromClassName(result.Name)
+ inner, err := responseFromClassName(result.GetName())
if err != nil {
return nil, fmt.Errorf("error getting wrapped response from wire message: %w", err)
}
- err = proto.Unmarshal(result.WrappedMessage, inner)
+ err = proto.Unmarshal(result.GetWrappedMessage(), inner)
if err != nil {
return nil, fmt.Errorf("error unmarshaling wrapped message: %w", err)
@@ -159,7 +159,7 @@ func (c *httpClient) post(ctx context.Context, message proto.Message) (proto.Mes
if v, ok := inner.(*avaticaMessage.ErrorResponse); ok {
- for _, exception := range v.Exceptions {
+ for _, exception := range v.GetExceptions() {
if badConnRe.MatchString(exception) {
return nil, driver.ErrBadConn
}
diff --git a/message/common.pb.go b/message/common.pb.go
index 6fc4299..f3c61b1 100644
--- a/message/common.pb.go
+++ b/message/common.pb.go
@@ -16,8 +16,8 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
-// protoc-gen-go v1.30.0
-// protoc v4.25.1
+// protoc-gen-go v1.36.5
+// protoc v5.29.3
// source: common.proto
package message
@@ -26,7 +26,7 @@ import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
- sync "sync"
+ unsafe "unsafe"
)
const (
@@ -108,11 +108,6 @@ func (x StatementType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use StatementType.Descriptor instead.
-func (StatementType) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{0}
-}
-
type Rep int32
const (
@@ -238,11 +233,6 @@ func (x Rep) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use Rep.Descriptor instead.
-func (Rep) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{1}
-}
-
// The severity of some unexpected outcome to an operation.
// Protobuf enum values must be unique across all other enums
type Severity int32
@@ -292,11 +282,6 @@ func (x Severity) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use Severity.Descriptor instead.
-func (Severity) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{2}
-}
-
// Enumeration corresponding to DatabaseMetaData operations
type MetaDataOperation int32
@@ -411,11 +396,6 @@ func (x MetaDataOperation) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use MetaDataOperation.Descriptor instead.
-func (MetaDataOperation) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{3}
-}
-
type StateType int32
const (
@@ -457,11 +437,6 @@ func (x StateType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use StateType.Descriptor instead.
-func (StateType) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{4}
-}
-
type CursorFactory_Style int32
const (
@@ -515,11 +490,6 @@ func (x CursorFactory_Style) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use CursorFactory_Style.Descriptor instead.
-func (CursorFactory_Style) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{6, 0}
-}
-
type MetaDataOperationArgument_ArgumentType int32
const (
@@ -573,34 +543,26 @@ func (x MetaDataOperationArgument_ArgumentType) Number() protoreflect.EnumNumber
return protoreflect.EnumNumber(x)
}
-// Deprecated: Use MetaDataOperationArgument_ArgumentType.Descriptor instead.
-func (MetaDataOperationArgument_ArgumentType) EnumDescriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{13, 0}
-}
-
// Details about a connection
type ConnectionProperties struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- IsDirty bool `protobuf:"varint,1,opt,name=is_dirty,json=isDirty,proto3" json:"is_dirty,omitempty"`
- AutoCommit bool `protobuf:"varint,2,opt,name=auto_commit,json=autoCommit,proto3" json:"auto_commit,omitempty"`
- HasAutoCommit bool `protobuf:"varint,7,opt,name=has_auto_commit,json=hasAutoCommit,proto3" json:"has_auto_commit,omitempty"` // field is a Boolean, need to discern null and default value
- ReadOnly bool `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
- HasReadOnly bool `protobuf:"varint,8,opt,name=has_read_only,json=hasReadOnly,proto3" json:"has_read_only,omitempty"` // field is a Boolean, need to discern null and default value
- TransactionIsolation uint32 `protobuf:"varint,4,opt,name=transaction_isolation,json=transactionIsolation,proto3" json:"transaction_isolation,omitempty"`
- Catalog string `protobuf:"bytes,5,opt,name=catalog,proto3" json:"catalog,omitempty"`
- Schema string `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_IsDirty bool `protobuf:"varint,1,opt,name=is_dirty,json=isDirty,proto3"`
+ xxx_hidden_AutoCommit bool `protobuf:"varint,2,opt,name=auto_commit,json=autoCommit,proto3"`
+ xxx_hidden_HasAutoCommit bool `protobuf:"varint,7,opt,name=has_auto_commit,json=hasAutoCommit,proto3"`
+ xxx_hidden_ReadOnly bool `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3"`
+ xxx_hidden_HasReadOnly bool `protobuf:"varint,8,opt,name=has_read_only,json=hasReadOnly,proto3"`
+ xxx_hidden_TransactionIsolation uint32 `protobuf:"varint,4,opt,name=transaction_isolation,json=transactionIsolation,proto3"`
+ xxx_hidden_Catalog string `protobuf:"bytes,5,opt,name=catalog,proto3"`
+ xxx_hidden_Schema string `protobuf:"bytes,6,opt,name=schema,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ConnectionProperties) Reset() {
*x = ConnectionProperties{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[0]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ConnectionProperties) String() string {
@@ -611,7 +573,7 @@ func (*ConnectionProperties) ProtoMessage() {}
func (x *ConnectionProperties) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[0]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -621,85 +583,137 @@ func (x *ConnectionProperties) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ConnectionProperties.ProtoReflect.Descriptor instead.
-func (*ConnectionProperties) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{0}
-}
-
func (x *ConnectionProperties) GetIsDirty() bool {
if x != nil {
- return x.IsDirty
+ return x.xxx_hidden_IsDirty
}
return false
}
func (x *ConnectionProperties) GetAutoCommit() bool {
if x != nil {
- return x.AutoCommit
+ return x.xxx_hidden_AutoCommit
}
return false
}
func (x *ConnectionProperties) GetHasAutoCommit() bool {
if x != nil {
- return x.HasAutoCommit
+ return x.xxx_hidden_HasAutoCommit
}
return false
}
func (x *ConnectionProperties) GetReadOnly() bool {
if x != nil {
- return x.ReadOnly
+ return x.xxx_hidden_ReadOnly
}
return false
}
func (x *ConnectionProperties) GetHasReadOnly() bool {
if x != nil {
- return x.HasReadOnly
+ return x.xxx_hidden_HasReadOnly
}
return false
}
func (x *ConnectionProperties) GetTransactionIsolation() uint32 {
if x != nil {
- return x.TransactionIsolation
+ return x.xxx_hidden_TransactionIsolation
}
return 0
}
func (x *ConnectionProperties) GetCatalog() string {
if x != nil {
- return x.Catalog
+ return x.xxx_hidden_Catalog
}
return ""
}
func (x *ConnectionProperties) GetSchema() string {
if x != nil {
- return x.Schema
+ return x.xxx_hidden_Schema
}
return ""
}
+func (x *ConnectionProperties) SetIsDirty(v bool) {
+ x.xxx_hidden_IsDirty = v
+}
+
+func (x *ConnectionProperties) SetAutoCommit(v bool) {
+ x.xxx_hidden_AutoCommit = v
+}
+
+func (x *ConnectionProperties) SetHasAutoCommit(v bool) {
+ x.xxx_hidden_HasAutoCommit = v
+}
+
+func (x *ConnectionProperties) SetReadOnly(v bool) {
+ x.xxx_hidden_ReadOnly = v
+}
+
+func (x *ConnectionProperties) SetHasReadOnly(v bool) {
+ x.xxx_hidden_HasReadOnly = v
+}
+
+func (x *ConnectionProperties) SetTransactionIsolation(v uint32) {
+ x.xxx_hidden_TransactionIsolation = v
+}
+
+func (x *ConnectionProperties) SetCatalog(v string) {
+ x.xxx_hidden_Catalog = v
+}
+
+func (x *ConnectionProperties) SetSchema(v string) {
+ x.xxx_hidden_Schema = v
+}
+
+type ConnectionProperties_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ IsDirty bool
+ AutoCommit bool
+ HasAutoCommit bool
+ ReadOnly bool
+ HasReadOnly bool
+ TransactionIsolation uint32
+ Catalog string
+ Schema string
+}
+
+func (b0 ConnectionProperties_builder) Build() *ConnectionProperties {
+ m0 := &ConnectionProperties{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_IsDirty = b.IsDirty
+ x.xxx_hidden_AutoCommit = b.AutoCommit
+ x.xxx_hidden_HasAutoCommit = b.HasAutoCommit
+ x.xxx_hidden_ReadOnly = b.ReadOnly
+ x.xxx_hidden_HasReadOnly = b.HasReadOnly
+ x.xxx_hidden_TransactionIsolation = b.TransactionIsolation
+ x.xxx_hidden_Catalog = b.Catalog
+ x.xxx_hidden_Schema = b.Schema
+ return m0
+}
+
// Statement handle
type StatementHandle struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
- Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_Id uint32 `protobuf:"varint,2,opt,name=id,proto3"`
+ xxx_hidden_Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *StatementHandle) Reset() {
*x = StatementHandle{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[1]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *StatementHandle) String() string {
@@ -710,7 +724,7 @@ func (*StatementHandle) ProtoMessage() {}
func (x *StatementHandle) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[1]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -720,52 +734,85 @@ func (x *StatementHandle) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use StatementHandle.ProtoReflect.Descriptor instead.
-func (*StatementHandle) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{1}
-}
-
func (x *StatementHandle) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *StatementHandle) GetId() uint32 {
if x != nil {
- return x.Id
+ return x.xxx_hidden_Id
}
return 0
}
func (x *StatementHandle) GetSignature() *Signature {
if x != nil {
- return x.Signature
+ return x.xxx_hidden_Signature
}
return nil
}
+func (x *StatementHandle) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *StatementHandle) SetId(v uint32) {
+ x.xxx_hidden_Id = v
+}
+
+func (x *StatementHandle) SetSignature(v *Signature) {
+ x.xxx_hidden_Signature = v
+}
+
+func (x *StatementHandle) HasSignature() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Signature != nil
+}
+
+func (x *StatementHandle) ClearSignature() {
+ x.xxx_hidden_Signature = nil
+}
+
+type StatementHandle_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ Id uint32
+ Signature *Signature
+}
+
+func (b0 StatementHandle_builder) Build() *StatementHandle {
+ m0 := &StatementHandle{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_Id = b.Id
+ x.xxx_hidden_Signature = b.Signature
+ return m0
+}
+
// Results of preparing a statement
type Signature struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Columns []*ColumnMetaData `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
- Parameters []*AvaticaParameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
- CursorFactory *CursorFactory `protobuf:"bytes,4,opt,name=cursor_factory,json=cursorFactory,proto3" json:"cursor_factory,omitempty"`
- StatementType StatementType `protobuf:"varint,5,opt,name=statementType,proto3,enum=StatementType" json:"statementType,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Columns *[]*ColumnMetaData `protobuf:"bytes,1,rep,name=columns,proto3"`
+ xxx_hidden_Sql string `protobuf:"bytes,2,opt,name=sql,proto3"`
+ xxx_hidden_Parameters *[]*AvaticaParameter `protobuf:"bytes,3,rep,name=parameters,proto3"`
+ xxx_hidden_CursorFactory *CursorFactory `protobuf:"bytes,4,opt,name=cursor_factory,json=cursorFactory,proto3"`
+ xxx_hidden_StatementType StatementType `protobuf:"varint,5,opt,name=statementType,proto3,enum=StatementType"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *Signature) Reset() {
*x = Signature{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[2]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Signature) String() string {
@@ -776,7 +823,7 @@ func (*Signature) ProtoMessage() {}
func (x *Signature) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[2]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -786,80 +833,129 @@ func (x *Signature) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use Signature.ProtoReflect.Descriptor instead.
-func (*Signature) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{2}
-}
-
func (x *Signature) GetColumns() []*ColumnMetaData {
if x != nil {
- return x.Columns
+ if x.xxx_hidden_Columns != nil {
+ return *x.xxx_hidden_Columns
+ }
}
return nil
}
func (x *Signature) GetSql() string {
if x != nil {
- return x.Sql
+ return x.xxx_hidden_Sql
}
return ""
}
func (x *Signature) GetParameters() []*AvaticaParameter {
if x != nil {
- return x.Parameters
+ if x.xxx_hidden_Parameters != nil {
+ return *x.xxx_hidden_Parameters
+ }
}
return nil
}
func (x *Signature) GetCursorFactory() *CursorFactory {
if x != nil {
- return x.CursorFactory
+ return x.xxx_hidden_CursorFactory
}
return nil
}
func (x *Signature) GetStatementType() StatementType {
if x != nil {
- return x.StatementType
+ return x.xxx_hidden_StatementType
}
return StatementType_SELECT
}
+func (x *Signature) SetColumns(v []*ColumnMetaData) {
+ x.xxx_hidden_Columns = &v
+}
+
+func (x *Signature) SetSql(v string) {
+ x.xxx_hidden_Sql = v
+}
+
+func (x *Signature) SetParameters(v []*AvaticaParameter) {
+ x.xxx_hidden_Parameters = &v
+}
+
+func (x *Signature) SetCursorFactory(v *CursorFactory) {
+ x.xxx_hidden_CursorFactory = v
+}
+
+func (x *Signature) SetStatementType(v StatementType) {
+ x.xxx_hidden_StatementType = v
+}
+
+func (x *Signature) HasCursorFactory() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_CursorFactory != nil
+}
+
+func (x *Signature) ClearCursorFactory() {
+ x.xxx_hidden_CursorFactory = nil
+}
+
+type Signature_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Columns []*ColumnMetaData
+ Sql string
+ Parameters []*AvaticaParameter
+ CursorFactory *CursorFactory
+ StatementType StatementType
+}
+
+func (b0 Signature_builder) Build() *Signature {
+ m0 := &Signature{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Columns = &b.Columns
+ x.xxx_hidden_Sql = b.Sql
+ x.xxx_hidden_Parameters = &b.Parameters
+ x.xxx_hidden_CursorFactory = b.CursorFactory
+ x.xxx_hidden_StatementType = b.StatementType
+ return m0
+}
+
type ColumnMetaData struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Ordinal uint32 `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
- AutoIncrement bool `protobuf:"varint,2,opt,name=auto_increment,json=autoIncrement,proto3" json:"auto_increment,omitempty"`
- CaseSensitive bool `protobuf:"varint,3,opt,name=case_sensitive,json=caseSensitive,proto3" json:"case_sensitive,omitempty"`
- Searchable bool `protobuf:"varint,4,opt,name=searchable,proto3" json:"searchable,omitempty"`
- Currency bool `protobuf:"varint,5,opt,name=currency,proto3" json:"currency,omitempty"`
- Nullable uint32 `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
- Signed bool `protobuf:"varint,7,opt,name=signed,proto3" json:"signed,omitempty"`
- DisplaySize uint32 `protobuf:"varint,8,opt,name=display_size,json=displaySize,proto3" json:"display_size,omitempty"`
- Label string `protobuf:"bytes,9,opt,name=label,proto3" json:"label,omitempty"`
- ColumnName string `protobuf:"bytes,10,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
- SchemaName string `protobuf:"bytes,11,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
- Precision uint32 `protobuf:"varint,12,opt,name=precision,proto3" json:"precision,omitempty"`
- Scale uint32 `protobuf:"varint,13,opt,name=scale,proto3" json:"scale,omitempty"`
- TableName string `protobuf:"bytes,14,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
- CatalogName string `protobuf:"bytes,15,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
- ReadOnly bool `protobuf:"varint,16,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
- Writable bool `protobuf:"varint,17,opt,name=writable,proto3" json:"writable,omitempty"`
- DefinitelyWritable bool `protobuf:"varint,18,opt,name=definitely_writable,json=definitelyWritable,proto3" json:"definitely_writable,omitempty"`
- ColumnClassName string `protobuf:"bytes,19,opt,name=column_class_name,json=columnClassName,proto3" json:"column_class_name,omitempty"`
- Type *AvaticaType `protobuf:"bytes,20,opt,name=type,proto3" json:"type,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Ordinal uint32 `protobuf:"varint,1,opt,name=ordinal,proto3"`
+ xxx_hidden_AutoIncrement bool `protobuf:"varint,2,opt,name=auto_increment,json=autoIncrement,proto3"`
+ xxx_hidden_CaseSensitive bool `protobuf:"varint,3,opt,name=case_sensitive,json=caseSensitive,proto3"`
+ xxx_hidden_Searchable bool `protobuf:"varint,4,opt,name=searchable,proto3"`
+ xxx_hidden_Currency bool `protobuf:"varint,5,opt,name=currency,proto3"`
+ xxx_hidden_Nullable uint32 `protobuf:"varint,6,opt,name=nullable,proto3"`
+ xxx_hidden_Signed bool `protobuf:"varint,7,opt,name=signed,proto3"`
+ xxx_hidden_DisplaySize uint32 `protobuf:"varint,8,opt,name=display_size,json=displaySize,proto3"`
+ xxx_hidden_Label string `protobuf:"bytes,9,opt,name=label,proto3"`
+ xxx_hidden_ColumnName string `protobuf:"bytes,10,opt,name=column_name,json=columnName,proto3"`
+ xxx_hidden_SchemaName string `protobuf:"bytes,11,opt,name=schema_name,json=schemaName,proto3"`
+ xxx_hidden_Precision uint32 `protobuf:"varint,12,opt,name=precision,proto3"`
+ xxx_hidden_Scale uint32 `protobuf:"varint,13,opt,name=scale,proto3"`
+ xxx_hidden_TableName string `protobuf:"bytes,14,opt,name=table_name,json=tableName,proto3"`
+ xxx_hidden_CatalogName string `protobuf:"bytes,15,opt,name=catalog_name,json=catalogName,proto3"`
+ xxx_hidden_ReadOnly bool `protobuf:"varint,16,opt,name=read_only,json=readOnly,proto3"`
+ xxx_hidden_Writable bool `protobuf:"varint,17,opt,name=writable,proto3"`
+ xxx_hidden_DefinitelyWritable bool `protobuf:"varint,18,opt,name=definitely_writable,json=definitelyWritable,proto3"`
+ xxx_hidden_ColumnClassName string `protobuf:"bytes,19,opt,name=column_class_name,json=columnClassName,proto3"`
+ xxx_hidden_Type *AvaticaType `protobuf:"bytes,20,opt,name=type,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ColumnMetaData) Reset() {
*x = ColumnMetaData{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[3]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ColumnMetaData) String() string {
@@ -870,7 +966,7 @@ func (*ColumnMetaData) ProtoMessage() {}
func (x *ColumnMetaData) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[3]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -880,171 +976,306 @@ func (x *ColumnMetaData) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ColumnMetaData.ProtoReflect.Descriptor instead.
-func (*ColumnMetaData) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{3}
-}
-
func (x *ColumnMetaData) GetOrdinal() uint32 {
if x != nil {
- return x.Ordinal
+ return x.xxx_hidden_Ordinal
}
return 0
}
func (x *ColumnMetaData) GetAutoIncrement() bool {
if x != nil {
- return x.AutoIncrement
+ return x.xxx_hidden_AutoIncrement
}
return false
}
func (x *ColumnMetaData) GetCaseSensitive() bool {
if x != nil {
- return x.CaseSensitive
+ return x.xxx_hidden_CaseSensitive
}
return false
}
func (x *ColumnMetaData) GetSearchable() bool {
if x != nil {
- return x.Searchable
+ return x.xxx_hidden_Searchable
}
return false
}
func (x *ColumnMetaData) GetCurrency() bool {
if x != nil {
- return x.Currency
+ return x.xxx_hidden_Currency
}
return false
}
func (x *ColumnMetaData) GetNullable() uint32 {
if x != nil {
- return x.Nullable
+ return x.xxx_hidden_Nullable
}
return 0
}
func (x *ColumnMetaData) GetSigned() bool {
if x != nil {
- return x.Signed
+ return x.xxx_hidden_Signed
}
return false
}
func (x *ColumnMetaData) GetDisplaySize() uint32 {
if x != nil {
- return x.DisplaySize
+ return x.xxx_hidden_DisplaySize
}
return 0
}
func (x *ColumnMetaData) GetLabel() string {
if x != nil {
- return x.Label
+ return x.xxx_hidden_Label
}
return ""
}
func (x *ColumnMetaData) GetColumnName() string {
if x != nil {
- return x.ColumnName
+ return x.xxx_hidden_ColumnName
}
return ""
}
func (x *ColumnMetaData) GetSchemaName() string {
if x != nil {
- return x.SchemaName
+ return x.xxx_hidden_SchemaName
}
return ""
}
func (x *ColumnMetaData) GetPrecision() uint32 {
if x != nil {
- return x.Precision
+ return x.xxx_hidden_Precision
}
return 0
}
func (x *ColumnMetaData) GetScale() uint32 {
if x != nil {
- return x.Scale
+ return x.xxx_hidden_Scale
}
return 0
}
func (x *ColumnMetaData) GetTableName() string {
if x != nil {
- return x.TableName
+ return x.xxx_hidden_TableName
}
return ""
}
func (x *ColumnMetaData) GetCatalogName() string {
if x != nil {
- return x.CatalogName
+ return x.xxx_hidden_CatalogName
}
return ""
}
func (x *ColumnMetaData) GetReadOnly() bool {
if x != nil {
- return x.ReadOnly
+ return x.xxx_hidden_ReadOnly
}
return false
}
func (x *ColumnMetaData) GetWritable() bool {
if x != nil {
- return x.Writable
+ return x.xxx_hidden_Writable
}
return false
}
func (x *ColumnMetaData) GetDefinitelyWritable() bool {
if x != nil {
- return x.DefinitelyWritable
+ return x.xxx_hidden_DefinitelyWritable
}
return false
}
func (x *ColumnMetaData) GetColumnClassName() string {
if x != nil {
- return x.ColumnClassName
+ return x.xxx_hidden_ColumnClassName
}
return ""
}
func (x *ColumnMetaData) GetType() *AvaticaType {
if x != nil {
- return x.Type
+ return x.xxx_hidden_Type
}
return nil
}
+func (x *ColumnMetaData) SetOrdinal(v uint32) {
+ x.xxx_hidden_Ordinal = v
+}
+
+func (x *ColumnMetaData) SetAutoIncrement(v bool) {
+ x.xxx_hidden_AutoIncrement = v
+}
+
+func (x *ColumnMetaData) SetCaseSensitive(v bool) {
+ x.xxx_hidden_CaseSensitive = v
+}
+
+func (x *ColumnMetaData) SetSearchable(v bool) {
+ x.xxx_hidden_Searchable = v
+}
+
+func (x *ColumnMetaData) SetCurrency(v bool) {
+ x.xxx_hidden_Currency = v
+}
+
+func (x *ColumnMetaData) SetNullable(v uint32) {
+ x.xxx_hidden_Nullable = v
+}
+
+func (x *ColumnMetaData) SetSigned(v bool) {
+ x.xxx_hidden_Signed = v
+}
+
+func (x *ColumnMetaData) SetDisplaySize(v uint32) {
+ x.xxx_hidden_DisplaySize = v
+}
+
+func (x *ColumnMetaData) SetLabel(v string) {
+ x.xxx_hidden_Label = v
+}
+
+func (x *ColumnMetaData) SetColumnName(v string) {
+ x.xxx_hidden_ColumnName = v
+}
+
+func (x *ColumnMetaData) SetSchemaName(v string) {
+ x.xxx_hidden_SchemaName = v
+}
+
+func (x *ColumnMetaData) SetPrecision(v uint32) {
+ x.xxx_hidden_Precision = v
+}
+
+func (x *ColumnMetaData) SetScale(v uint32) {
+ x.xxx_hidden_Scale = v
+}
+
+func (x *ColumnMetaData) SetTableName(v string) {
+ x.xxx_hidden_TableName = v
+}
+
+func (x *ColumnMetaData) SetCatalogName(v string) {
+ x.xxx_hidden_CatalogName = v
+}
+
+func (x *ColumnMetaData) SetReadOnly(v bool) {
+ x.xxx_hidden_ReadOnly = v
+}
+
+func (x *ColumnMetaData) SetWritable(v bool) {
+ x.xxx_hidden_Writable = v
+}
+
+func (x *ColumnMetaData) SetDefinitelyWritable(v bool) {
+ x.xxx_hidden_DefinitelyWritable = v
+}
+
+func (x *ColumnMetaData) SetColumnClassName(v string) {
+ x.xxx_hidden_ColumnClassName = v
+}
+
+func (x *ColumnMetaData) SetType(v *AvaticaType) {
+ x.xxx_hidden_Type = v
+}
+
+func (x *ColumnMetaData) HasType() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Type != nil
+}
+
+func (x *ColumnMetaData) ClearType() {
+ x.xxx_hidden_Type = nil
+}
+
+type ColumnMetaData_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Ordinal uint32
+ AutoIncrement bool
+ CaseSensitive bool
+ Searchable bool
+ Currency bool
+ Nullable uint32
+ Signed bool
+ DisplaySize uint32
+ Label string
+ ColumnName string
+ SchemaName string
+ Precision uint32
+ Scale uint32
+ TableName string
+ CatalogName string
+ ReadOnly bool
+ Writable bool
+ DefinitelyWritable bool
+ ColumnClassName string
+ Type *AvaticaType
+}
+
+func (b0 ColumnMetaData_builder) Build() *ColumnMetaData {
+ m0 := &ColumnMetaData{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Ordinal = b.Ordinal
+ x.xxx_hidden_AutoIncrement = b.AutoIncrement
+ x.xxx_hidden_CaseSensitive = b.CaseSensitive
+ x.xxx_hidden_Searchable = b.Searchable
+ x.xxx_hidden_Currency = b.Currency
+ x.xxx_hidden_Nullable = b.Nullable
+ x.xxx_hidden_Signed = b.Signed
+ x.xxx_hidden_DisplaySize = b.DisplaySize
+ x.xxx_hidden_Label = b.Label
+ x.xxx_hidden_ColumnName = b.ColumnName
+ x.xxx_hidden_SchemaName = b.SchemaName
+ x.xxx_hidden_Precision = b.Precision
+ x.xxx_hidden_Scale = b.Scale
+ x.xxx_hidden_TableName = b.TableName
+ x.xxx_hidden_CatalogName = b.CatalogName
+ x.xxx_hidden_ReadOnly = b.ReadOnly
+ x.xxx_hidden_Writable = b.Writable
+ x.xxx_hidden_DefinitelyWritable = b.DefinitelyWritable
+ x.xxx_hidden_ColumnClassName = b.ColumnClassName
+ x.xxx_hidden_Type = b.Type
+ return m0
+}
+
// Base class for a column type
type AvaticaType struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
- Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
- Rep Rep `protobuf:"varint,3,opt,name=rep,proto3,enum=Rep" json:"rep,omitempty"`
- Columns []*ColumnMetaData `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"` // Only present when name = STRUCT
- Component *AvaticaType `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"` // Only present when name = ARRAY
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Id uint32 `protobuf:"varint,1,opt,name=id,proto3"`
+ xxx_hidden_Name string `protobuf:"bytes,2,opt,name=name,proto3"`
+ xxx_hidden_Rep Rep `protobuf:"varint,3,opt,name=rep,proto3,enum=Rep"`
+ xxx_hidden_Columns *[]*ColumnMetaData `protobuf:"bytes,4,rep,name=columns,proto3"`
+ xxx_hidden_Component *AvaticaType `protobuf:"bytes,5,opt,name=component,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AvaticaType) Reset() {
*x = AvaticaType{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[4]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AvaticaType) String() string {
@@ -1055,7 +1286,7 @@ func (*AvaticaType) ProtoMessage() {}
func (x *AvaticaType) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[4]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1065,68 +1296,115 @@ func (x *AvaticaType) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use AvaticaType.ProtoReflect.Descriptor instead.
-func (*AvaticaType) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{4}
-}
-
func (x *AvaticaType) GetId() uint32 {
if x != nil {
- return x.Id
+ return x.xxx_hidden_Id
}
return 0
}
func (x *AvaticaType) GetName() string {
if x != nil {
- return x.Name
+ return x.xxx_hidden_Name
}
return ""
}
func (x *AvaticaType) GetRep() Rep {
if x != nil {
- return x.Rep
+ return x.xxx_hidden_Rep
}
return Rep_PRIMITIVE_BOOLEAN
}
func (x *AvaticaType) GetColumns() []*ColumnMetaData {
if x != nil {
- return x.Columns
+ if x.xxx_hidden_Columns != nil {
+ return *x.xxx_hidden_Columns
+ }
}
return nil
}
func (x *AvaticaType) GetComponent() *AvaticaType {
if x != nil {
- return x.Component
+ return x.xxx_hidden_Component
}
return nil
}
+func (x *AvaticaType) SetId(v uint32) {
+ x.xxx_hidden_Id = v
+}
+
+func (x *AvaticaType) SetName(v string) {
+ x.xxx_hidden_Name = v
+}
+
+func (x *AvaticaType) SetRep(v Rep) {
+ x.xxx_hidden_Rep = v
+}
+
+func (x *AvaticaType) SetColumns(v []*ColumnMetaData) {
+ x.xxx_hidden_Columns = &v
+}
+
+func (x *AvaticaType) SetComponent(v *AvaticaType) {
+ x.xxx_hidden_Component = v
+}
+
+func (x *AvaticaType) HasComponent() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Component != nil
+}
+
+func (x *AvaticaType) ClearComponent() {
+ x.xxx_hidden_Component = nil
+}
+
+type AvaticaType_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Id uint32
+ Name string
+ Rep Rep
+ Columns []*ColumnMetaData
+ Component *AvaticaType
+}
+
+func (b0 AvaticaType_builder) Build() *AvaticaType {
+ m0 := &AvaticaType{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Id = b.Id
+ x.xxx_hidden_Name = b.Name
+ x.xxx_hidden_Rep = b.Rep
+ x.xxx_hidden_Columns = &b.Columns
+ x.xxx_hidden_Component = b.Component
+ return m0
+}
+
// Metadata for a parameter
type AvaticaParameter struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Signed bool `protobuf:"varint,1,opt,name=signed,proto3" json:"signed,omitempty"`
- Precision uint32 `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"`
- Scale uint32 `protobuf:"varint,3,opt,name=scale,proto3" json:"scale,omitempty"`
- ParameterType uint32 `protobuf:"varint,4,opt,name=parameter_type,json=parameterType,proto3" json:"parameter_type,omitempty"`
- TypeName string `protobuf:"bytes,5,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
- ClassName string `protobuf:"bytes,6,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
- Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Signed bool `protobuf:"varint,1,opt,name=signed,proto3"`
+ xxx_hidden_Precision uint32 `protobuf:"varint,2,opt,name=precision,proto3"`
+ xxx_hidden_Scale uint32 `protobuf:"varint,3,opt,name=scale,proto3"`
+ xxx_hidden_ParameterType uint32 `protobuf:"varint,4,opt,name=parameter_type,json=parameterType,proto3"`
+ xxx_hidden_TypeName string `protobuf:"bytes,5,opt,name=type_name,json=typeName,proto3"`
+ xxx_hidden_ClassName string `protobuf:"bytes,6,opt,name=class_name,json=className,proto3"`
+ xxx_hidden_Name string `protobuf:"bytes,7,opt,name=name,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AvaticaParameter) Reset() {
*x = AvaticaParameter{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[5]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AvaticaParameter) String() string {
@@ -1137,7 +1415,7 @@ func (*AvaticaParameter) ProtoMessage() {}
func (x *AvaticaParameter) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[5]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1147,78 +1425,124 @@ func (x *AvaticaParameter) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use AvaticaParameter.ProtoReflect.Descriptor instead.
-func (*AvaticaParameter) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{5}
-}
-
func (x *AvaticaParameter) GetSigned() bool {
if x != nil {
- return x.Signed
+ return x.xxx_hidden_Signed
}
return false
}
func (x *AvaticaParameter) GetPrecision() uint32 {
if x != nil {
- return x.Precision
+ return x.xxx_hidden_Precision
}
return 0
}
func (x *AvaticaParameter) GetScale() uint32 {
if x != nil {
- return x.Scale
+ return x.xxx_hidden_Scale
}
return 0
}
func (x *AvaticaParameter) GetParameterType() uint32 {
if x != nil {
- return x.ParameterType
+ return x.xxx_hidden_ParameterType
}
return 0
}
func (x *AvaticaParameter) GetTypeName() string {
if x != nil {
- return x.TypeName
+ return x.xxx_hidden_TypeName
}
return ""
}
func (x *AvaticaParameter) GetClassName() string {
if x != nil {
- return x.ClassName
+ return x.xxx_hidden_ClassName
}
return ""
}
func (x *AvaticaParameter) GetName() string {
if x != nil {
- return x.Name
+ return x.xxx_hidden_Name
}
return ""
}
+func (x *AvaticaParameter) SetSigned(v bool) {
+ x.xxx_hidden_Signed = v
+}
+
+func (x *AvaticaParameter) SetPrecision(v uint32) {
+ x.xxx_hidden_Precision = v
+}
+
+func (x *AvaticaParameter) SetScale(v uint32) {
+ x.xxx_hidden_Scale = v
+}
+
+func (x *AvaticaParameter) SetParameterType(v uint32) {
+ x.xxx_hidden_ParameterType = v
+}
+
+func (x *AvaticaParameter) SetTypeName(v string) {
+ x.xxx_hidden_TypeName = v
+}
+
+func (x *AvaticaParameter) SetClassName(v string) {
+ x.xxx_hidden_ClassName = v
+}
+
+func (x *AvaticaParameter) SetName(v string) {
+ x.xxx_hidden_Name = v
+}
+
+type AvaticaParameter_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Signed bool
+ Precision uint32
+ Scale uint32
+ ParameterType uint32
+ TypeName string
+ ClassName string
+ Name string
+}
+
+func (b0 AvaticaParameter_builder) Build() *AvaticaParameter {
+ m0 := &AvaticaParameter{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Signed = b.Signed
+ x.xxx_hidden_Precision = b.Precision
+ x.xxx_hidden_Scale = b.Scale
+ x.xxx_hidden_ParameterType = b.ParameterType
+ x.xxx_hidden_TypeName = b.TypeName
+ x.xxx_hidden_ClassName = b.ClassName
+ x.xxx_hidden_Name = b.Name
+ return m0
+}
+
// Information necessary to convert an Iterable into a Calcite Cursor
type CursorFactory struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Style CursorFactory_Style `protobuf:"varint,1,opt,name=style,proto3,enum=CursorFactory_Style" json:"style,omitempty"`
- ClassName string `protobuf:"bytes,2,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
- FieldNames []string `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Style CursorFactory_Style `protobuf:"varint,1,opt,name=style,proto3,enum=CursorFactory_Style"`
+ xxx_hidden_ClassName string `protobuf:"bytes,2,opt,name=class_name,json=className,proto3"`
+ xxx_hidden_FieldNames []string `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CursorFactory) Reset() {
*x = CursorFactory{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[6]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CursorFactory) String() string {
@@ -1229,7 +1553,7 @@ func (*CursorFactory) ProtoMessage() {}
func (x *CursorFactory) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[6]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1239,50 +1563,72 @@ func (x *CursorFactory) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CursorFactory.ProtoReflect.Descriptor instead.
-func (*CursorFactory) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{6}
-}
-
func (x *CursorFactory) GetStyle() CursorFactory_Style {
if x != nil {
- return x.Style
+ return x.xxx_hidden_Style
}
return CursorFactory_OBJECT
}
func (x *CursorFactory) GetClassName() string {
if x != nil {
- return x.ClassName
+ return x.xxx_hidden_ClassName
}
return ""
}
func (x *CursorFactory) GetFieldNames() []string {
if x != nil {
- return x.FieldNames
+ return x.xxx_hidden_FieldNames
}
return nil
}
+func (x *CursorFactory) SetStyle(v CursorFactory_Style) {
+ x.xxx_hidden_Style = v
+}
+
+func (x *CursorFactory) SetClassName(v string) {
+ x.xxx_hidden_ClassName = v
+}
+
+func (x *CursorFactory) SetFieldNames(v []string) {
+ x.xxx_hidden_FieldNames = v
+}
+
+type CursorFactory_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Style CursorFactory_Style
+ ClassName string
+ FieldNames []string
+}
+
+func (b0 CursorFactory_builder) Build() *CursorFactory {
+ m0 := &CursorFactory{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Style = b.Style
+ x.xxx_hidden_ClassName = b.ClassName
+ x.xxx_hidden_FieldNames = b.FieldNames
+ return m0
+}
+
// A collection of rows
type Frame struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
- Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
- Rows []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3"`
+ xxx_hidden_Done bool `protobuf:"varint,2,opt,name=done,proto3"`
+ xxx_hidden_Rows *[]*Row `protobuf:"bytes,3,rep,name=rows,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *Frame) Reset() {
*x = Frame{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[7]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Frame) String() string {
@@ -1293,7 +1639,7 @@ func (*Frame) ProtoMessage() {}
func (x *Frame) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[7]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1303,48 +1649,72 @@ func (x *Frame) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use Frame.ProtoReflect.Descriptor instead.
-func (*Frame) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{7}
-}
-
func (x *Frame) GetOffset() uint64 {
if x != nil {
- return x.Offset
+ return x.xxx_hidden_Offset
}
return 0
}
func (x *Frame) GetDone() bool {
if x != nil {
- return x.Done
+ return x.xxx_hidden_Done
}
return false
}
func (x *Frame) GetRows() []*Row {
if x != nil {
- return x.Rows
+ if x.xxx_hidden_Rows != nil {
+ return *x.xxx_hidden_Rows
+ }
}
return nil
}
+func (x *Frame) SetOffset(v uint64) {
+ x.xxx_hidden_Offset = v
+}
+
+func (x *Frame) SetDone(v bool) {
+ x.xxx_hidden_Done = v
+}
+
+func (x *Frame) SetRows(v []*Row) {
+ x.xxx_hidden_Rows = &v
+}
+
+type Frame_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Offset uint64
+ Done bool
+ Rows []*Row
+}
+
+func (b0 Frame_builder) Build() *Frame {
+ m0 := &Frame{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Offset = b.Offset
+ x.xxx_hidden_Done = b.Done
+ x.xxx_hidden_Rows = &b.Rows
+ return m0
+}
+
// A row is a collection of values
type Row struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Value []*ColumnValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Value *[]*ColumnValue `protobuf:"bytes,1,rep,name=value,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *Row) Reset() {
*x = Row{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[8]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Row) String() string {
@@ -1355,7 +1725,7 @@ func (*Row) ProtoMessage() {}
func (x *Row) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[8]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1365,35 +1735,47 @@ func (x *Row) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use Row.ProtoReflect.Descriptor instead.
-func (*Row) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{8}
-}
-
func (x *Row) GetValue() []*ColumnValue {
if x != nil {
- return x.Value
+ if x.xxx_hidden_Value != nil {
+ return *x.xxx_hidden_Value
+ }
}
return nil
}
+func (x *Row) SetValue(v []*ColumnValue) {
+ x.xxx_hidden_Value = &v
+}
+
+type Row_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Value []*ColumnValue
+}
+
+func (b0 Row_builder) Build() *Row {
+ m0 := &Row{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Value = &b.Value
+ return m0
+}
+
// Database property, list of functions the database provides for a certain operation
type DatabaseProperty struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
- Functions []string `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Name string `protobuf:"bytes,1,opt,name=name,proto3"`
+ xxx_hidden_Functions []string `protobuf:"bytes,2,rep,name=functions,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *DatabaseProperty) Reset() {
*x = DatabaseProperty{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[9]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *DatabaseProperty) String() string {
@@ -1404,7 +1786,7 @@ func (*DatabaseProperty) ProtoMessage() {}
func (x *DatabaseProperty) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[9]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1414,42 +1796,58 @@ func (x *DatabaseProperty) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use DatabaseProperty.ProtoReflect.Descriptor instead.
-func (*DatabaseProperty) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{9}
-}
-
func (x *DatabaseProperty) GetName() string {
if x != nil {
- return x.Name
+ return x.xxx_hidden_Name
}
return ""
}
func (x *DatabaseProperty) GetFunctions() []string {
if x != nil {
- return x.Functions
+ return x.xxx_hidden_Functions
}
return nil
}
+func (x *DatabaseProperty) SetName(v string) {
+ x.xxx_hidden_Name = v
+}
+
+func (x *DatabaseProperty) SetFunctions(v []string) {
+ x.xxx_hidden_Functions = v
+}
+
+type DatabaseProperty_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Name string
+ Functions []string
+}
+
+func (b0 DatabaseProperty_builder) Build() *DatabaseProperty {
+ m0 := &DatabaseProperty{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Name = b.Name
+ x.xxx_hidden_Functions = b.Functions
+ return m0
+}
+
// Message which encapsulates another message to support a single RPC endpoint
type WireMessage struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
- WrappedMessage []byte `protobuf:"bytes,2,opt,name=wrapped_message,json=wrappedMessage,proto3" json:"wrapped_message,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Name string `protobuf:"bytes,1,opt,name=name,proto3"`
+ xxx_hidden_WrappedMessage []byte `protobuf:"bytes,2,opt,name=wrapped_message,json=wrappedMessage,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *WireMessage) Reset() {
*x = WireMessage{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[10]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *WireMessage) String() string {
@@ -1460,7 +1858,7 @@ func (*WireMessage) ProtoMessage() {}
func (x *WireMessage) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[10]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1470,44 +1868,63 @@ func (x *WireMessage) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use WireMessage.ProtoReflect.Descriptor instead.
-func (*WireMessage) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{10}
-}
-
func (x *WireMessage) GetName() string {
if x != nil {
- return x.Name
+ return x.xxx_hidden_Name
}
return ""
}
func (x *WireMessage) GetWrappedMessage() []byte {
if x != nil {
- return x.WrappedMessage
+ return x.xxx_hidden_WrappedMessage
}
return nil
}
+func (x *WireMessage) SetName(v string) {
+ x.xxx_hidden_Name = v
+}
+
+func (x *WireMessage) SetWrappedMessage(v []byte) {
+ if v == nil {
+ v = []byte{}
+ }
+ x.xxx_hidden_WrappedMessage = v
+}
+
+type WireMessage_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Name string
+ WrappedMessage []byte
+}
+
+func (b0 WireMessage_builder) Build() *WireMessage {
+ m0 := &WireMessage{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Name = b.Name
+ x.xxx_hidden_WrappedMessage = b.WrappedMessage
+ return m0
+}
+
// A value might be a TypedValue or an Array of TypedValue's
type ColumnValue struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Value []*TypedValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` // deprecated, use array_value or scalar_value
- ArrayValue []*TypedValue `protobuf:"bytes,2,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`
- HasArrayValue bool `protobuf:"varint,3,opt,name=has_array_value,json=hasArrayValue,proto3" json:"has_array_value,omitempty"` // Is an array value set?
- ScalarValue *TypedValue `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue,proto3" json:"scalar_value,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Value *[]*TypedValue `protobuf:"bytes,1,rep,name=value,proto3"`
+ xxx_hidden_ArrayValue *[]*TypedValue `protobuf:"bytes,2,rep,name=array_value,json=arrayValue,proto3"`
+ xxx_hidden_HasArrayValue bool `protobuf:"varint,3,opt,name=has_array_value,json=hasArrayValue,proto3"`
+ xxx_hidden_ScalarValue *TypedValue `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ColumnValue) Reset() {
*x = ColumnValue{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[11]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ColumnValue) String() string {
@@ -1518,7 +1935,7 @@ func (*ColumnValue) ProtoMessage() {}
func (x *ColumnValue) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[11]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1528,65 +1945,107 @@ func (x *ColumnValue) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ColumnValue.ProtoReflect.Descriptor instead.
-func (*ColumnValue) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{11}
-}
-
func (x *ColumnValue) GetValue() []*TypedValue {
if x != nil {
- return x.Value
+ if x.xxx_hidden_Value != nil {
+ return *x.xxx_hidden_Value
+ }
}
return nil
}
func (x *ColumnValue) GetArrayValue() []*TypedValue {
if x != nil {
- return x.ArrayValue
+ if x.xxx_hidden_ArrayValue != nil {
+ return *x.xxx_hidden_ArrayValue
+ }
}
return nil
}
func (x *ColumnValue) GetHasArrayValue() bool {
if x != nil {
- return x.HasArrayValue
+ return x.xxx_hidden_HasArrayValue
}
return false
}
func (x *ColumnValue) GetScalarValue() *TypedValue {
if x != nil {
- return x.ScalarValue
+ return x.xxx_hidden_ScalarValue
}
return nil
}
+func (x *ColumnValue) SetValue(v []*TypedValue) {
+ x.xxx_hidden_Value = &v
+}
+
+func (x *ColumnValue) SetArrayValue(v []*TypedValue) {
+ x.xxx_hidden_ArrayValue = &v
+}
+
+func (x *ColumnValue) SetHasArrayValue(v bool) {
+ x.xxx_hidden_HasArrayValue = v
+}
+
+func (x *ColumnValue) SetScalarValue(v *TypedValue) {
+ x.xxx_hidden_ScalarValue = v
+}
+
+func (x *ColumnValue) HasScalarValue() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_ScalarValue != nil
+}
+
+func (x *ColumnValue) ClearScalarValue() {
+ x.xxx_hidden_ScalarValue = nil
+}
+
+type ColumnValue_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Value []*TypedValue
+ ArrayValue []*TypedValue
+ HasArrayValue bool
+ ScalarValue *TypedValue
+}
+
+func (b0 ColumnValue_builder) Build() *ColumnValue {
+ m0 := &ColumnValue{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Value = &b.Value
+ x.xxx_hidden_ArrayValue = &b.ArrayValue
+ x.xxx_hidden_HasArrayValue = b.HasArrayValue
+ x.xxx_hidden_ScalarValue = b.ScalarValue
+ return m0
+}
+
// Generic wrapper to support any SQL type. Struct-like to work around no polymorphism construct.
type TypedValue struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Type Rep `protobuf:"varint,1,opt,name=type,proto3,enum=Rep" json:"type,omitempty"` // The actual type that was serialized in the general attribute below
- BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"` // boolean
- StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"` // char/varchar
- NumberValue int64 `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue,proto3" json:"number_value,omitempty"` // var-len encoding lets us shove anything from byte to long
- // includes numeric types and date/time types.
- BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"` // binary/varbinary
- DoubleValue float64 `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"` // big numbers
- Null bool `protobuf:"varint,7,opt,name=null,proto3" json:"null,omitempty"` // a null object
- ArrayValue []*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"` // The Array
- ComponentType Rep `protobuf:"varint,9,opt,name=component_type,json=componentType,proto3,enum=Rep" json:"component_type,omitempty"` // If an Array, the representation for the array values
- ImplicitlyNull bool `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull,proto3" json:"implicitly_null,omitempty"` // Differentiate between explicitly null (user-set) and implicitly null
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Type Rep `protobuf:"varint,1,opt,name=type,proto3,enum=Rep"`
+ xxx_hidden_BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3"`
+ xxx_hidden_StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3"`
+ xxx_hidden_NumberValue int64 `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue,proto3"`
+ xxx_hidden_BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3"`
+ xxx_hidden_DoubleValue float64 `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue,proto3"`
+ xxx_hidden_Null bool `protobuf:"varint,7,opt,name=null,proto3"`
+ xxx_hidden_ArrayValue *[]*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue,proto3"`
+ xxx_hidden_ComponentType Rep `protobuf:"varint,9,opt,name=component_type,json=componentType,proto3,enum=Rep"`
+ xxx_hidden_ImplicitlyNull bool `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *TypedValue) Reset() {
*x = TypedValue{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[12]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[12]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *TypedValue) String() string {
@@ -1597,7 +2056,7 @@ func (*TypedValue) ProtoMessage() {}
func (x *TypedValue) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[12]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1607,102 +2066,172 @@ func (x *TypedValue) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.
-func (*TypedValue) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{12}
-}
-
func (x *TypedValue) GetType() Rep {
if x != nil {
- return x.Type
+ return x.xxx_hidden_Type
}
return Rep_PRIMITIVE_BOOLEAN
}
func (x *TypedValue) GetBoolValue() bool {
if x != nil {
- return x.BoolValue
+ return x.xxx_hidden_BoolValue
}
return false
}
func (x *TypedValue) GetStringValue() string {
if x != nil {
- return x.StringValue
+ return x.xxx_hidden_StringValue
}
return ""
}
func (x *TypedValue) GetNumberValue() int64 {
if x != nil {
- return x.NumberValue
+ return x.xxx_hidden_NumberValue
}
return 0
}
func (x *TypedValue) GetBytesValue() []byte {
if x != nil {
- return x.BytesValue
+ return x.xxx_hidden_BytesValue
}
return nil
}
func (x *TypedValue) GetDoubleValue() float64 {
if x != nil {
- return x.DoubleValue
+ return x.xxx_hidden_DoubleValue
}
return 0
}
func (x *TypedValue) GetNull() bool {
if x != nil {
- return x.Null
+ return x.xxx_hidden_Null
}
return false
}
func (x *TypedValue) GetArrayValue() []*TypedValue {
if x != nil {
- return x.ArrayValue
+ if x.xxx_hidden_ArrayValue != nil {
+ return *x.xxx_hidden_ArrayValue
+ }
}
return nil
}
func (x *TypedValue) GetComponentType() Rep {
if x != nil {
- return x.ComponentType
+ return x.xxx_hidden_ComponentType
}
return Rep_PRIMITIVE_BOOLEAN
}
func (x *TypedValue) GetImplicitlyNull() bool {
if x != nil {
- return x.ImplicitlyNull
+ return x.xxx_hidden_ImplicitlyNull
}
return false
}
+func (x *TypedValue) SetType(v Rep) {
+ x.xxx_hidden_Type = v
+}
+
+func (x *TypedValue) SetBoolValue(v bool) {
+ x.xxx_hidden_BoolValue = v
+}
+
+func (x *TypedValue) SetStringValue(v string) {
+ x.xxx_hidden_StringValue = v
+}
+
+func (x *TypedValue) SetNumberValue(v int64) {
+ x.xxx_hidden_NumberValue = v
+}
+
+func (x *TypedValue) SetBytesValue(v []byte) {
+ if v == nil {
+ v = []byte{}
+ }
+ x.xxx_hidden_BytesValue = v
+}
+
+func (x *TypedValue) SetDoubleValue(v float64) {
+ x.xxx_hidden_DoubleValue = v
+}
+
+func (x *TypedValue) SetNull(v bool) {
+ x.xxx_hidden_Null = v
+}
+
+func (x *TypedValue) SetArrayValue(v []*TypedValue) {
+ x.xxx_hidden_ArrayValue = &v
+}
+
+func (x *TypedValue) SetComponentType(v Rep) {
+ x.xxx_hidden_ComponentType = v
+}
+
+func (x *TypedValue) SetImplicitlyNull(v bool) {
+ x.xxx_hidden_ImplicitlyNull = v
+}
+
+type TypedValue_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Type Rep
+ BoolValue bool
+ StringValue string
+ NumberValue int64
+ // includes numeric types and date/time types.
+ BytesValue []byte
+ DoubleValue float64
+ Null bool
+ ArrayValue []*TypedValue
+ ComponentType Rep
+ ImplicitlyNull bool
+}
+
+func (b0 TypedValue_builder) Build() *TypedValue {
+ m0 := &TypedValue{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Type = b.Type
+ x.xxx_hidden_BoolValue = b.BoolValue
+ x.xxx_hidden_StringValue = b.StringValue
+ x.xxx_hidden_NumberValue = b.NumberValue
+ x.xxx_hidden_BytesValue = b.BytesValue
+ x.xxx_hidden_DoubleValue = b.DoubleValue
+ x.xxx_hidden_Null = b.Null
+ x.xxx_hidden_ArrayValue = &b.ArrayValue
+ x.xxx_hidden_ComponentType = b.ComponentType
+ x.xxx_hidden_ImplicitlyNull = b.ImplicitlyNull
+ return m0
+}
+
// Represents the breadth of arguments to DatabaseMetaData functions
type MetaDataOperationArgument struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
- BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
- IntValue int32 `protobuf:"zigzag32,3,opt,name=int_value,json=intValue,proto3" json:"int_value,omitempty"`
- StringArrayValues []string `protobuf:"bytes,4,rep,name=string_array_values,json=stringArrayValues,proto3" json:"string_array_values,omitempty"`
- IntArrayValues []int32 `protobuf:"zigzag32,5,rep,packed,name=int_array_values,json=intArrayValues,proto3" json:"int_array_values,omitempty"`
- Type MetaDataOperationArgument_ArgumentType `protobuf:"varint,6,opt,name=type,proto3,enum=MetaDataOperationArgument_ArgumentType" json:"type,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3"`
+ xxx_hidden_BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3"`
+ xxx_hidden_IntValue int32 `protobuf:"zigzag32,3,opt,name=int_value,json=intValue,proto3"`
+ xxx_hidden_StringArrayValues []string `protobuf:"bytes,4,rep,name=string_array_values,json=stringArrayValues,proto3"`
+ xxx_hidden_IntArrayValues []int32 `protobuf:"zigzag32,5,rep,packed,name=int_array_values,json=intArrayValues,proto3"`
+ xxx_hidden_Type MetaDataOperationArgument_ArgumentType `protobuf:"varint,6,opt,name=type,proto3,enum=MetaDataOperationArgument_ArgumentType"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *MetaDataOperationArgument) Reset() {
*x = MetaDataOperationArgument{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[13]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[13]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *MetaDataOperationArgument) String() string {
@@ -1713,7 +2242,7 @@ func (*MetaDataOperationArgument) ProtoMessage() {}
func (x *MetaDataOperationArgument) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[13]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1723,74 +2252,114 @@ func (x *MetaDataOperationArgument) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use MetaDataOperationArgument.ProtoReflect.Descriptor instead.
-func (*MetaDataOperationArgument) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{13}
-}
-
func (x *MetaDataOperationArgument) GetStringValue() string {
if x != nil {
- return x.StringValue
+ return x.xxx_hidden_StringValue
}
return ""
}
func (x *MetaDataOperationArgument) GetBoolValue() bool {
if x != nil {
- return x.BoolValue
+ return x.xxx_hidden_BoolValue
}
return false
}
func (x *MetaDataOperationArgument) GetIntValue() int32 {
if x != nil {
- return x.IntValue
+ return x.xxx_hidden_IntValue
}
return 0
}
func (x *MetaDataOperationArgument) GetStringArrayValues() []string {
if x != nil {
- return x.StringArrayValues
+ return x.xxx_hidden_StringArrayValues
}
return nil
}
func (x *MetaDataOperationArgument) GetIntArrayValues() []int32 {
if x != nil {
- return x.IntArrayValues
+ return x.xxx_hidden_IntArrayValues
}
return nil
}
func (x *MetaDataOperationArgument) GetType() MetaDataOperationArgument_ArgumentType {
if x != nil {
- return x.Type
+ return x.xxx_hidden_Type
}
return MetaDataOperationArgument_STRING
}
-type QueryState struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *MetaDataOperationArgument) SetStringValue(v string) {
+ x.xxx_hidden_StringValue = v
+}
+
+func (x *MetaDataOperationArgument) SetBoolValue(v bool) {
+ x.xxx_hidden_BoolValue = v
+}
+
+func (x *MetaDataOperationArgument) SetIntValue(v int32) {
+ x.xxx_hidden_IntValue = v
+}
+
+func (x *MetaDataOperationArgument) SetStringArrayValues(v []string) {
+ x.xxx_hidden_StringArrayValues = v
+}
- Type StateType `protobuf:"varint,1,opt,name=type,proto3,enum=StateType" json:"type,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
- Op MetaDataOperation `protobuf:"varint,3,opt,name=op,proto3,enum=MetaDataOperation" json:"op,omitempty"`
- Args []*MetaDataOperationArgument `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
- HasArgs bool `protobuf:"varint,5,opt,name=has_args,json=hasArgs,proto3" json:"has_args,omitempty"`
- HasSql bool `protobuf:"varint,6,opt,name=has_sql,json=hasSql,proto3" json:"has_sql,omitempty"`
- HasOp bool `protobuf:"varint,7,opt,name=has_op,json=hasOp,proto3" json:"has_op,omitempty"`
+func (x *MetaDataOperationArgument) SetIntArrayValues(v []int32) {
+ x.xxx_hidden_IntArrayValues = v
+}
+
+func (x *MetaDataOperationArgument) SetType(v MetaDataOperationArgument_ArgumentType) {
+ x.xxx_hidden_Type = v
+}
+
+type MetaDataOperationArgument_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ StringValue string
+ BoolValue bool
+ IntValue int32
+ StringArrayValues []string
+ IntArrayValues []int32
+ Type MetaDataOperationArgument_ArgumentType
+}
+
+func (b0 MetaDataOperationArgument_builder) Build() *MetaDataOperationArgument {
+ m0 := &MetaDataOperationArgument{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_StringValue = b.StringValue
+ x.xxx_hidden_BoolValue = b.BoolValue
+ x.xxx_hidden_IntValue = b.IntValue
+ x.xxx_hidden_StringArrayValues = b.StringArrayValues
+ x.xxx_hidden_IntArrayValues = b.IntArrayValues
+ x.xxx_hidden_Type = b.Type
+ return m0
+}
+
+type QueryState struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Type StateType `protobuf:"varint,1,opt,name=type,proto3,enum=StateType"`
+ xxx_hidden_Sql string `protobuf:"bytes,2,opt,name=sql,proto3"`
+ xxx_hidden_Op MetaDataOperation `protobuf:"varint,3,opt,name=op,proto3,enum=MetaDataOperation"`
+ xxx_hidden_Args *[]*MetaDataOperationArgument `protobuf:"bytes,4,rep,name=args,proto3"`
+ xxx_hidden_HasArgs bool `protobuf:"varint,5,opt,name=has_args,json=hasArgs,proto3"`
+ xxx_hidden_HasSql bool `protobuf:"varint,6,opt,name=has_sql,json=hasSql,proto3"`
+ xxx_hidden_HasOp bool `protobuf:"varint,7,opt,name=has_op,json=hasOp,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *QueryState) Reset() {
*x = QueryState{}
- if protoimpl.UnsafeEnabled {
- mi := &file_common_proto_msgTypes[14]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_common_proto_msgTypes[14]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *QueryState) String() string {
@@ -1801,7 +2370,7 @@ func (*QueryState) ProtoMessage() {}
func (x *QueryState) ProtoReflect() protoreflect.Message {
mi := &file_common_proto_msgTypes[14]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1811,63 +2380,114 @@ func (x *QueryState) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use QueryState.ProtoReflect.Descriptor instead.
-func (*QueryState) Descriptor() ([]byte, []int) {
- return file_common_proto_rawDescGZIP(), []int{14}
-}
-
func (x *QueryState) GetType() StateType {
if x != nil {
- return x.Type
+ return x.xxx_hidden_Type
}
return StateType_SQL
}
func (x *QueryState) GetSql() string {
if x != nil {
- return x.Sql
+ return x.xxx_hidden_Sql
}
return ""
}
func (x *QueryState) GetOp() MetaDataOperation {
if x != nil {
- return x.Op
+ return x.xxx_hidden_Op
}
return MetaDataOperation_GET_ATTRIBUTES
}
func (x *QueryState) GetArgs() []*MetaDataOperationArgument {
if x != nil {
- return x.Args
+ if x.xxx_hidden_Args != nil {
+ return *x.xxx_hidden_Args
+ }
}
return nil
}
func (x *QueryState) GetHasArgs() bool {
if x != nil {
- return x.HasArgs
+ return x.xxx_hidden_HasArgs
}
return false
}
func (x *QueryState) GetHasSql() bool {
if x != nil {
- return x.HasSql
+ return x.xxx_hidden_HasSql
}
return false
}
func (x *QueryState) GetHasOp() bool {
if x != nil {
- return x.HasOp
+ return x.xxx_hidden_HasOp
}
return false
}
+func (x *QueryState) SetType(v StateType) {
+ x.xxx_hidden_Type = v
+}
+
+func (x *QueryState) SetSql(v string) {
+ x.xxx_hidden_Sql = v
+}
+
+func (x *QueryState) SetOp(v MetaDataOperation) {
+ x.xxx_hidden_Op = v
+}
+
+func (x *QueryState) SetArgs(v []*MetaDataOperationArgument) {
+ x.xxx_hidden_Args = &v
+}
+
+func (x *QueryState) SetHasArgs(v bool) {
+ x.xxx_hidden_HasArgs = v
+}
+
+func (x *QueryState) SetHasSql(v bool) {
+ x.xxx_hidden_HasSql = v
+}
+
+func (x *QueryState) SetHasOp(v bool) {
+ x.xxx_hidden_HasOp = v
+}
+
+type QueryState_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Type StateType
+ Sql string
+ Op MetaDataOperation
+ Args []*MetaDataOperationArgument
+ HasArgs bool
+ HasSql bool
+ HasOp bool
+}
+
+func (b0 QueryState_builder) Build() *QueryState {
+ m0 := &QueryState{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Type = b.Type
+ x.xxx_hidden_Sql = b.Sql
+ x.xxx_hidden_Op = b.Op
+ x.xxx_hidden_Args = &b.Args
+ x.xxx_hidden_HasArgs = b.HasArgs
+ x.xxx_hidden_HasSql = b.HasSql
+ x.xxx_hidden_HasOp = b.HasOp
+ return m0
+}
+
var File_common_proto protoreflect.FileDescriptor
-var file_common_proto_rawDesc = []byte{
+var file_common_proto_rawDesc = string([]byte{
0x0a, 0x0c, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa2,
0x02, 0x0a, 0x14, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f,
0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x69, 0x73, 0x5f, 0x64, 0x69,
@@ -2165,23 +2785,11 @@ var file_common_proto_rawDesc = []byte{
0x72, 0x67, 0x2e, 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2e, 0x63, 0x61, 0x6c, 0x63, 0x69, 0x74,
0x65, 0x2e, 0x61, 0x76, 0x61, 0x74, 0x69, 0x63, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
-
-var (
- file_common_proto_rawDescOnce sync.Once
- file_common_proto_rawDescData = file_common_proto_rawDesc
-)
-
-func file_common_proto_rawDescGZIP() []byte {
- file_common_proto_rawDescOnce.Do(func() {
- file_common_proto_rawDescData = protoimpl.X.CompressGZIP(file_common_proto_rawDescData)
- })
- return file_common_proto_rawDescData
-}
+})
var file_common_proto_enumTypes = make([]protoimpl.EnumInfo, 7)
var file_common_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
-var file_common_proto_goTypes = []interface{}{
+var file_common_proto_goTypes = []any{
(StatementType)(0), // 0: StatementType
(Rep)(0), // 1: Rep
(Severity)(0), // 2: Severity
@@ -2240,193 +2848,11 @@ func file_common_proto_init() {
if File_common_proto != nil {
return
}
- if !protoimpl.UnsafeEnabled {
- file_common_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ConnectionProperties); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*StatementHandle); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*Signature); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ColumnMetaData); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*AvaticaType); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*AvaticaParameter); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CursorFactory); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*Frame); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*Row); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*DatabaseProperty); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*WireMessage); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ColumnValue); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*TypedValue); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*MetaDataOperationArgument); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_common_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*QueryState); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- }
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
- RawDescriptor: file_common_proto_rawDesc,
+ RawDescriptor: unsafe.Slice(unsafe.StringData(file_common_proto_rawDesc), len(file_common_proto_rawDesc)),
NumEnums: 7,
NumMessages: 15,
NumExtensions: 0,
@@ -2438,7 +2864,6 @@ func file_common_proto_init() {
MessageInfos: file_common_proto_msgTypes,
}.Build()
File_common_proto = out.File
- file_common_proto_rawDesc = nil
file_common_proto_goTypes = nil
file_common_proto_depIdxs = nil
}
diff --git a/message/helper.go b/message/helper.go
index ad7e47c..8f3529a 100644
--- a/message/helper.go
+++ b/message/helper.go
@@ -25,7 +25,7 @@ func ServerAddressFromMetadata(message MetadataProvider) string {
serverAddress := "unknown"
md := message.GetMetadata()
if md != nil {
- serverAddress = md.ServerAddress
+ serverAddress = md.GetServerAddress()
}
return serverAddress
}
diff --git a/message/requests.pb.go b/message/requests.pb.go
index f136217..c5f91de 100644
--- a/message/requests.pb.go
+++ b/message/requests.pb.go
@@ -16,8 +16,8 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
-// protoc-gen-go v1.30.0
-// protoc v4.25.1
+// protoc-gen-go v1.36.5
+// protoc v5.29.3
// source: requests.proto
package message
@@ -26,7 +26,7 @@ import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
- sync "sync"
+ unsafe "unsafe"
)
const (
@@ -38,20 +38,17 @@ const (
// Request for Meta#getCatalogs()
type CatalogsRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CatalogsRequest) Reset() {
*x = CatalogsRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[0]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CatalogsRequest) String() string {
@@ -62,7 +59,7 @@ func (*CatalogsRequest) ProtoMessage() {}
func (x *CatalogsRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[0]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -72,34 +69,44 @@ func (x *CatalogsRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CatalogsRequest.ProtoReflect.Descriptor instead.
-func (*CatalogsRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{0}
-}
-
func (x *CatalogsRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *CatalogsRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type CatalogsRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 CatalogsRequest_builder) Build() *CatalogsRequest {
+ m0 := &CatalogsRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request for Meta#getDatabaseProperties()
type DatabasePropertyRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *DatabasePropertyRequest) Reset() {
*x = DatabasePropertyRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[1]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *DatabasePropertyRequest) String() string {
@@ -110,7 +117,7 @@ func (*DatabasePropertyRequest) ProtoMessage() {}
func (x *DatabasePropertyRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[1]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -120,38 +127,48 @@ func (x *DatabasePropertyRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use DatabasePropertyRequest.ProtoReflect.Descriptor instead.
-func (*DatabasePropertyRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{1}
-}
-
func (x *DatabasePropertyRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *DatabasePropertyRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type DatabasePropertyRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 DatabasePropertyRequest_builder) Build() *DatabasePropertyRequest {
+ m0 := &DatabasePropertyRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request for Meta#getSchemas(String, org.apache.calcite.avatica.Meta.Pat)}
type SchemasRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
- ConnectionId string `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- HasCatalog bool `protobuf:"varint,4,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
- HasSchemaPattern bool `protobuf:"varint,5,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3"`
+ xxx_hidden_SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_HasCatalog bool `protobuf:"varint,4,opt,name=has_catalog,json=hasCatalog,proto3"`
+ xxx_hidden_HasSchemaPattern bool `protobuf:"varint,5,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *SchemasRequest) Reset() {
*x = SchemasRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[2]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *SchemasRequest) String() string {
@@ -162,7 +179,7 @@ func (*SchemasRequest) ProtoMessage() {}
func (x *SchemasRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[2]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -172,72 +189,106 @@ func (x *SchemasRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use SchemasRequest.ProtoReflect.Descriptor instead.
-func (*SchemasRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{2}
-}
-
func (x *SchemasRequest) GetCatalog() string {
if x != nil {
- return x.Catalog
+ return x.xxx_hidden_Catalog
}
return ""
}
func (x *SchemasRequest) GetSchemaPattern() string {
if x != nil {
- return x.SchemaPattern
+ return x.xxx_hidden_SchemaPattern
}
return ""
}
func (x *SchemasRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *SchemasRequest) GetHasCatalog() bool {
if x != nil {
- return x.HasCatalog
+ return x.xxx_hidden_HasCatalog
}
return false
}
func (x *SchemasRequest) GetHasSchemaPattern() bool {
if x != nil {
- return x.HasSchemaPattern
+ return x.xxx_hidden_HasSchemaPattern
}
return false
}
+func (x *SchemasRequest) SetCatalog(v string) {
+ x.xxx_hidden_Catalog = v
+}
+
+func (x *SchemasRequest) SetSchemaPattern(v string) {
+ x.xxx_hidden_SchemaPattern = v
+}
+
+func (x *SchemasRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *SchemasRequest) SetHasCatalog(v bool) {
+ x.xxx_hidden_HasCatalog = v
+}
+
+func (x *SchemasRequest) SetHasSchemaPattern(v bool) {
+ x.xxx_hidden_HasSchemaPattern = v
+}
+
+type SchemasRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Catalog string
+ SchemaPattern string
+ ConnectionId string
+ HasCatalog bool
+ HasSchemaPattern bool
+}
+
+func (b0 SchemasRequest_builder) Build() *SchemasRequest {
+ m0 := &SchemasRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Catalog = b.Catalog
+ x.xxx_hidden_SchemaPattern = b.SchemaPattern
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_HasCatalog = b.HasCatalog
+ x.xxx_hidden_HasSchemaPattern = b.HasSchemaPattern
+ return m0
+}
+
// Request for Request for Meta#getTables(String, org.apache.calcite.avatica.Meta.Pat,
//
// org.apache.calcite.avatica.Meta.Pat, java.util.List)
type TablesRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
- TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
- TypeList []string `protobuf:"bytes,4,rep,name=type_list,json=typeList,proto3" json:"type_list,omitempty"`
- HasTypeList bool `protobuf:"varint,6,opt,name=has_type_list,json=hasTypeList,proto3" json:"has_type_list,omitempty"` // Having an empty type_list is distinct from a null type_list
- ConnectionId string `protobuf:"bytes,7,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- HasCatalog bool `protobuf:"varint,8,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
- HasSchemaPattern bool `protobuf:"varint,9,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
- HasTableNamePattern bool `protobuf:"varint,10,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3" json:"has_table_name_pattern,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3"`
+ xxx_hidden_SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3"`
+ xxx_hidden_TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3"`
+ xxx_hidden_TypeList []string `protobuf:"bytes,4,rep,name=type_list,json=typeList,proto3"`
+ xxx_hidden_HasTypeList bool `protobuf:"varint,6,opt,name=has_type_list,json=hasTypeList,proto3"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,7,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_HasCatalog bool `protobuf:"varint,8,opt,name=has_catalog,json=hasCatalog,proto3"`
+ xxx_hidden_HasSchemaPattern bool `protobuf:"varint,9,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3"`
+ xxx_hidden_HasTableNamePattern bool `protobuf:"varint,10,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *TablesRequest) Reset() {
*x = TablesRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[3]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *TablesRequest) String() string {
@@ -248,7 +299,7 @@ func (*TablesRequest) ProtoMessage() {}
func (x *TablesRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[3]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -258,90 +309,148 @@ func (x *TablesRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use TablesRequest.ProtoReflect.Descriptor instead.
-func (*TablesRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{3}
-}
-
func (x *TablesRequest) GetCatalog() string {
if x != nil {
- return x.Catalog
+ return x.xxx_hidden_Catalog
}
return ""
}
func (x *TablesRequest) GetSchemaPattern() string {
if x != nil {
- return x.SchemaPattern
+ return x.xxx_hidden_SchemaPattern
}
return ""
}
func (x *TablesRequest) GetTableNamePattern() string {
if x != nil {
- return x.TableNamePattern
+ return x.xxx_hidden_TableNamePattern
}
return ""
}
func (x *TablesRequest) GetTypeList() []string {
if x != nil {
- return x.TypeList
+ return x.xxx_hidden_TypeList
}
return nil
}
func (x *TablesRequest) GetHasTypeList() bool {
if x != nil {
- return x.HasTypeList
+ return x.xxx_hidden_HasTypeList
}
return false
}
func (x *TablesRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *TablesRequest) GetHasCatalog() bool {
if x != nil {
- return x.HasCatalog
+ return x.xxx_hidden_HasCatalog
}
return false
}
func (x *TablesRequest) GetHasSchemaPattern() bool {
if x != nil {
- return x.HasSchemaPattern
+ return x.xxx_hidden_HasSchemaPattern
}
return false
}
func (x *TablesRequest) GetHasTableNamePattern() bool {
if x != nil {
- return x.HasTableNamePattern
+ return x.xxx_hidden_HasTableNamePattern
}
return false
}
+func (x *TablesRequest) SetCatalog(v string) {
+ x.xxx_hidden_Catalog = v
+}
+
+func (x *TablesRequest) SetSchemaPattern(v string) {
+ x.xxx_hidden_SchemaPattern = v
+}
+
+func (x *TablesRequest) SetTableNamePattern(v string) {
+ x.xxx_hidden_TableNamePattern = v
+}
+
+func (x *TablesRequest) SetTypeList(v []string) {
+ x.xxx_hidden_TypeList = v
+}
+
+func (x *TablesRequest) SetHasTypeList(v bool) {
+ x.xxx_hidden_HasTypeList = v
+}
+
+func (x *TablesRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *TablesRequest) SetHasCatalog(v bool) {
+ x.xxx_hidden_HasCatalog = v
+}
+
+func (x *TablesRequest) SetHasSchemaPattern(v bool) {
+ x.xxx_hidden_HasSchemaPattern = v
+}
+
+func (x *TablesRequest) SetHasTableNamePattern(v bool) {
+ x.xxx_hidden_HasTableNamePattern = v
+}
+
+type TablesRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Catalog string
+ SchemaPattern string
+ TableNamePattern string
+ TypeList []string
+ HasTypeList bool
+ ConnectionId string
+ HasCatalog bool
+ HasSchemaPattern bool
+ HasTableNamePattern bool
+}
+
+func (b0 TablesRequest_builder) Build() *TablesRequest {
+ m0 := &TablesRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Catalog = b.Catalog
+ x.xxx_hidden_SchemaPattern = b.SchemaPattern
+ x.xxx_hidden_TableNamePattern = b.TableNamePattern
+ x.xxx_hidden_TypeList = b.TypeList
+ x.xxx_hidden_HasTypeList = b.HasTypeList
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_HasCatalog = b.HasCatalog
+ x.xxx_hidden_HasSchemaPattern = b.HasSchemaPattern
+ x.xxx_hidden_HasTableNamePattern = b.HasTableNamePattern
+ return m0
+}
+
// Request for Meta#getTableTypes()
type TableTypesRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *TableTypesRequest) Reset() {
*x = TableTypesRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[4]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *TableTypesRequest) String() string {
@@ -352,7 +461,7 @@ func (*TableTypesRequest) ProtoMessage() {}
func (x *TableTypesRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[4]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -362,44 +471,54 @@ func (x *TableTypesRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use TableTypesRequest.ProtoReflect.Descriptor instead.
-func (*TableTypesRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{4}
-}
-
func (x *TableTypesRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *TableTypesRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type TableTypesRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 TableTypesRequest_builder) Build() *TableTypesRequest {
+ m0 := &TableTypesRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request for Meta#getColumns(String, org.apache.calcite.avatica.Meta.Pat,
//
// org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.Pat).
type ColumnsRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
- TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
- ColumnNamePattern string `protobuf:"bytes,4,opt,name=column_name_pattern,json=columnNamePattern,proto3" json:"column_name_pattern,omitempty"`
- ConnectionId string `protobuf:"bytes,5,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- HasCatalog bool `protobuf:"varint,6,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
- HasSchemaPattern bool `protobuf:"varint,7,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
- HasTableNamePattern bool `protobuf:"varint,8,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3" json:"has_table_name_pattern,omitempty"`
- HasColumnNamePattern bool `protobuf:"varint,9,opt,name=has_column_name_pattern,json=hasColumnNamePattern,proto3" json:"has_column_name_pattern,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3"`
+ xxx_hidden_SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3"`
+ xxx_hidden_TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3"`
+ xxx_hidden_ColumnNamePattern string `protobuf:"bytes,4,opt,name=column_name_pattern,json=columnNamePattern,proto3"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,5,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_HasCatalog bool `protobuf:"varint,6,opt,name=has_catalog,json=hasCatalog,proto3"`
+ xxx_hidden_HasSchemaPattern bool `protobuf:"varint,7,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3"`
+ xxx_hidden_HasTableNamePattern bool `protobuf:"varint,8,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3"`
+ xxx_hidden_HasColumnNamePattern bool `protobuf:"varint,9,opt,name=has_column_name_pattern,json=hasColumnNamePattern,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ColumnsRequest) Reset() {
*x = ColumnsRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[5]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ColumnsRequest) String() string {
@@ -410,7 +529,7 @@ func (*ColumnsRequest) ProtoMessage() {}
func (x *ColumnsRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[5]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -420,90 +539,148 @@ func (x *ColumnsRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ColumnsRequest.ProtoReflect.Descriptor instead.
-func (*ColumnsRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{5}
-}
-
func (x *ColumnsRequest) GetCatalog() string {
if x != nil {
- return x.Catalog
+ return x.xxx_hidden_Catalog
}
return ""
}
func (x *ColumnsRequest) GetSchemaPattern() string {
if x != nil {
- return x.SchemaPattern
+ return x.xxx_hidden_SchemaPattern
}
return ""
}
func (x *ColumnsRequest) GetTableNamePattern() string {
if x != nil {
- return x.TableNamePattern
+ return x.xxx_hidden_TableNamePattern
}
return ""
}
func (x *ColumnsRequest) GetColumnNamePattern() string {
if x != nil {
- return x.ColumnNamePattern
+ return x.xxx_hidden_ColumnNamePattern
}
return ""
}
func (x *ColumnsRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *ColumnsRequest) GetHasCatalog() bool {
if x != nil {
- return x.HasCatalog
+ return x.xxx_hidden_HasCatalog
}
return false
}
func (x *ColumnsRequest) GetHasSchemaPattern() bool {
if x != nil {
- return x.HasSchemaPattern
+ return x.xxx_hidden_HasSchemaPattern
}
return false
}
func (x *ColumnsRequest) GetHasTableNamePattern() bool {
if x != nil {
- return x.HasTableNamePattern
+ return x.xxx_hidden_HasTableNamePattern
}
return false
}
func (x *ColumnsRequest) GetHasColumnNamePattern() bool {
if x != nil {
- return x.HasColumnNamePattern
+ return x.xxx_hidden_HasColumnNamePattern
}
return false
}
+func (x *ColumnsRequest) SetCatalog(v string) {
+ x.xxx_hidden_Catalog = v
+}
+
+func (x *ColumnsRequest) SetSchemaPattern(v string) {
+ x.xxx_hidden_SchemaPattern = v
+}
+
+func (x *ColumnsRequest) SetTableNamePattern(v string) {
+ x.xxx_hidden_TableNamePattern = v
+}
+
+func (x *ColumnsRequest) SetColumnNamePattern(v string) {
+ x.xxx_hidden_ColumnNamePattern = v
+}
+
+func (x *ColumnsRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *ColumnsRequest) SetHasCatalog(v bool) {
+ x.xxx_hidden_HasCatalog = v
+}
+
+func (x *ColumnsRequest) SetHasSchemaPattern(v bool) {
+ x.xxx_hidden_HasSchemaPattern = v
+}
+
+func (x *ColumnsRequest) SetHasTableNamePattern(v bool) {
+ x.xxx_hidden_HasTableNamePattern = v
+}
+
+func (x *ColumnsRequest) SetHasColumnNamePattern(v bool) {
+ x.xxx_hidden_HasColumnNamePattern = v
+}
+
+type ColumnsRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Catalog string
+ SchemaPattern string
+ TableNamePattern string
+ ColumnNamePattern string
+ ConnectionId string
+ HasCatalog bool
+ HasSchemaPattern bool
+ HasTableNamePattern bool
+ HasColumnNamePattern bool
+}
+
+func (b0 ColumnsRequest_builder) Build() *ColumnsRequest {
+ m0 := &ColumnsRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Catalog = b.Catalog
+ x.xxx_hidden_SchemaPattern = b.SchemaPattern
+ x.xxx_hidden_TableNamePattern = b.TableNamePattern
+ x.xxx_hidden_ColumnNamePattern = b.ColumnNamePattern
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_HasCatalog = b.HasCatalog
+ x.xxx_hidden_HasSchemaPattern = b.HasSchemaPattern
+ x.xxx_hidden_HasTableNamePattern = b.HasTableNamePattern
+ x.xxx_hidden_HasColumnNamePattern = b.HasColumnNamePattern
+ return m0
+}
+
// Request for Meta#getTypeInfo()
type TypeInfoRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *TypeInfoRequest) Reset() {
*x = TypeInfoRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[6]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *TypeInfoRequest) String() string {
@@ -514,7 +691,7 @@ func (*TypeInfoRequest) ProtoMessage() {}
func (x *TypeInfoRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[6]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -524,39 +701,49 @@ func (x *TypeInfoRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use TypeInfoRequest.ProtoReflect.Descriptor instead.
-func (*TypeInfoRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{6}
-}
-
func (x *TypeInfoRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *TypeInfoRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type TypeInfoRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 TypeInfoRequest_builder) Build() *TypeInfoRequest {
+ m0 := &TypeInfoRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request for Meta#prepareAndExecute(Meta.StatementHandle, String, long, Meta.PrepareCallback)
type PrepareAndExecuteRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
- MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"` // Deprecated
- StatementId uint32 `protobuf:"varint,4,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- MaxRowsTotal int64 `protobuf:"varint,5,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"` // The maximum number of rows that will be allowed for this query
- FirstFrameMaxSize int32 `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"` // The maximum number of rows that will be returned in the
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_Sql string `protobuf:"bytes,2,opt,name=sql,proto3"`
+ xxx_hidden_MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,4,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_MaxRowsTotal int64 `protobuf:"varint,5,opt,name=max_rows_total,json=maxRowsTotal,proto3"`
+ xxx_hidden_FirstFrameMaxSize int32 `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PrepareAndExecuteRequest) Reset() {
*x = PrepareAndExecuteRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[7]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PrepareAndExecuteRequest) String() string {
@@ -567,7 +754,7 @@ func (*PrepareAndExecuteRequest) ProtoMessage() {}
func (x *PrepareAndExecuteRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[7]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -577,72 +764,112 @@ func (x *PrepareAndExecuteRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use PrepareAndExecuteRequest.ProtoReflect.Descriptor instead.
-func (*PrepareAndExecuteRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{7}
-}
-
func (x *PrepareAndExecuteRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *PrepareAndExecuteRequest) GetSql() string {
if x != nil {
- return x.Sql
+ return x.xxx_hidden_Sql
}
return ""
}
func (x *PrepareAndExecuteRequest) GetMaxRowCount() uint64 {
if x != nil {
- return x.MaxRowCount
+ return x.xxx_hidden_MaxRowCount
}
return 0
}
func (x *PrepareAndExecuteRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *PrepareAndExecuteRequest) GetMaxRowsTotal() int64 {
if x != nil {
- return x.MaxRowsTotal
+ return x.xxx_hidden_MaxRowsTotal
}
return 0
}
func (x *PrepareAndExecuteRequest) GetFirstFrameMaxSize() int32 {
if x != nil {
- return x.FirstFrameMaxSize
+ return x.xxx_hidden_FirstFrameMaxSize
}
return 0
}
+func (x *PrepareAndExecuteRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *PrepareAndExecuteRequest) SetSql(v string) {
+ x.xxx_hidden_Sql = v
+}
+
+func (x *PrepareAndExecuteRequest) SetMaxRowCount(v uint64) {
+ x.xxx_hidden_MaxRowCount = v
+}
+
+func (x *PrepareAndExecuteRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *PrepareAndExecuteRequest) SetMaxRowsTotal(v int64) {
+ x.xxx_hidden_MaxRowsTotal = v
+}
+
+func (x *PrepareAndExecuteRequest) SetFirstFrameMaxSize(v int32) {
+ x.xxx_hidden_FirstFrameMaxSize = v
+}
+
+type PrepareAndExecuteRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ Sql string
+ MaxRowCount uint64
+ StatementId uint32
+ MaxRowsTotal int64
+ FirstFrameMaxSize int32
+}
+
+func (b0 PrepareAndExecuteRequest_builder) Build() *PrepareAndExecuteRequest {
+ m0 := &PrepareAndExecuteRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_Sql = b.Sql
+ x.xxx_hidden_MaxRowCount = b.MaxRowCount
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_MaxRowsTotal = b.MaxRowsTotal
+ x.xxx_hidden_FirstFrameMaxSize = b.FirstFrameMaxSize
+ return m0
+}
+
// Request for Meta.prepare(Meta.ConnectionHandle, String, long)
type PrepareRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
- MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"` // Deprecated
- MaxRowsTotal int64 `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"` // The maximum number of rows that will be allowed for this query
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_Sql string `protobuf:"bytes,2,opt,name=sql,proto3"`
+ xxx_hidden_MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3"`
+ xxx_hidden_MaxRowsTotal int64 `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PrepareRequest) Reset() {
*x = PrepareRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[8]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PrepareRequest) String() string {
@@ -653,7 +880,7 @@ func (*PrepareRequest) ProtoMessage() {}
func (x *PrepareRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[8]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -663,59 +890,87 @@ func (x *PrepareRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.
-func (*PrepareRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{8}
-}
-
func (x *PrepareRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *PrepareRequest) GetSql() string {
if x != nil {
- return x.Sql
+ return x.xxx_hidden_Sql
}
return ""
}
func (x *PrepareRequest) GetMaxRowCount() uint64 {
if x != nil {
- return x.MaxRowCount
+ return x.xxx_hidden_MaxRowCount
}
return 0
}
func (x *PrepareRequest) GetMaxRowsTotal() int64 {
if x != nil {
- return x.MaxRowsTotal
+ return x.xxx_hidden_MaxRowsTotal
}
return 0
}
+func (x *PrepareRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *PrepareRequest) SetSql(v string) {
+ x.xxx_hidden_Sql = v
+}
+
+func (x *PrepareRequest) SetMaxRowCount(v uint64) {
+ x.xxx_hidden_MaxRowCount = v
+}
+
+func (x *PrepareRequest) SetMaxRowsTotal(v int64) {
+ x.xxx_hidden_MaxRowsTotal = v
+}
+
+type PrepareRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ Sql string
+ MaxRowCount uint64
+ MaxRowsTotal int64
+}
+
+func (b0 PrepareRequest_builder) Build() *PrepareRequest {
+ m0 := &PrepareRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_Sql = b.Sql
+ x.xxx_hidden_MaxRowCount = b.MaxRowCount
+ x.xxx_hidden_MaxRowsTotal = b.MaxRowsTotal
+ return m0
+}
+
// Request for Meta#fetch(Meta.StatementHandle, List, long, int)
type FetchRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
- FetchMaxRowCount uint32 `protobuf:"varint,4,opt,name=fetch_max_row_count,json=fetchMaxRowCount,proto3" json:"fetch_max_row_count,omitempty"` // Maximum number of rows to be returned in the frame. Negative means no limit. Deprecated!
- FrameMaxSize int32 `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize,proto3" json:"frame_max_size,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3"`
+ xxx_hidden_FetchMaxRowCount uint32 `protobuf:"varint,4,opt,name=fetch_max_row_count,json=fetchMaxRowCount,proto3"`
+ xxx_hidden_FrameMaxSize int32 `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *FetchRequest) Reset() {
*x = FetchRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[9]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *FetchRequest) String() string {
@@ -726,7 +981,7 @@ func (*FetchRequest) ProtoMessage() {}
func (x *FetchRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[9]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -736,62 +991,96 @@ func (x *FetchRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.
-func (*FetchRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{9}
-}
-
func (x *FetchRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *FetchRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *FetchRequest) GetOffset() uint64 {
if x != nil {
- return x.Offset
+ return x.xxx_hidden_Offset
}
return 0
}
func (x *FetchRequest) GetFetchMaxRowCount() uint32 {
if x != nil {
- return x.FetchMaxRowCount
+ return x.xxx_hidden_FetchMaxRowCount
}
return 0
}
func (x *FetchRequest) GetFrameMaxSize() int32 {
if x != nil {
- return x.FrameMaxSize
+ return x.xxx_hidden_FrameMaxSize
}
return 0
}
+func (x *FetchRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *FetchRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *FetchRequest) SetOffset(v uint64) {
+ x.xxx_hidden_Offset = v
+}
+
+func (x *FetchRequest) SetFetchMaxRowCount(v uint32) {
+ x.xxx_hidden_FetchMaxRowCount = v
+}
+
+func (x *FetchRequest) SetFrameMaxSize(v int32) {
+ x.xxx_hidden_FrameMaxSize = v
+}
+
+type FetchRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ Offset uint64
+ FetchMaxRowCount uint32
+ FrameMaxSize int32
+}
+
+func (b0 FetchRequest_builder) Build() *FetchRequest {
+ m0 := &FetchRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_Offset = b.Offset
+ x.xxx_hidden_FetchMaxRowCount = b.FetchMaxRowCount
+ x.xxx_hidden_FrameMaxSize = b.FrameMaxSize
+ return m0
+}
+
// Request for Meta#createStatement(Meta.ConnectionHandle)
type CreateStatementRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CreateStatementRequest) Reset() {
*x = CreateStatementRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[10]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CreateStatementRequest) String() string {
@@ -802,7 +1091,7 @@ func (*CreateStatementRequest) ProtoMessage() {}
func (x *CreateStatementRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[10]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -812,35 +1101,45 @@ func (x *CreateStatementRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CreateStatementRequest.ProtoReflect.Descriptor instead.
-func (*CreateStatementRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{10}
-}
-
func (x *CreateStatementRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *CreateStatementRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type CreateStatementRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 CreateStatementRequest_builder) Build() *CreateStatementRequest {
+ m0 := &CreateStatementRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request for Meta#closeStatement(Meta.StatementHandle)
type CloseStatementRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CloseStatementRequest) Reset() {
*x = CloseStatementRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[11]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CloseStatementRequest) String() string {
@@ -851,7 +1150,7 @@ func (*CloseStatementRequest) ProtoMessage() {}
func (x *CloseStatementRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[11]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -861,42 +1160,58 @@ func (x *CloseStatementRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CloseStatementRequest.ProtoReflect.Descriptor instead.
-func (*CloseStatementRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{11}
-}
-
func (x *CloseStatementRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *CloseStatementRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
+func (x *CloseStatementRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *CloseStatementRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+type CloseStatementRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+}
+
+func (b0 CloseStatementRequest_builder) Build() *CloseStatementRequest {
+ m0 := &CloseStatementRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ return m0
+}
+
// Request for Meta#openConnection(Meta.ConnectionHandle, Map<String, String>)
type OpenConnectionRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- Info map[string]string `protobuf:"bytes,2,rep,name=info,proto3" json:"info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_Info map[string]string `protobuf:"bytes,2,rep,name=info,proto3" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *OpenConnectionRequest) Reset() {
*x = OpenConnectionRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[12]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[12]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *OpenConnectionRequest) String() string {
@@ -907,7 +1222,7 @@ func (*OpenConnectionRequest) ProtoMessage() {}
func (x *OpenConnectionRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[12]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -917,41 +1232,57 @@ func (x *OpenConnectionRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use OpenConnectionRequest.ProtoReflect.Descriptor instead.
-func (*OpenConnectionRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{12}
-}
-
func (x *OpenConnectionRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *OpenConnectionRequest) GetInfo() map[string]string {
if x != nil {
- return x.Info
+ return x.xxx_hidden_Info
}
return nil
}
+func (x *OpenConnectionRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *OpenConnectionRequest) SetInfo(v map[string]string) {
+ x.xxx_hidden_Info = v
+}
+
+type OpenConnectionRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ Info map[string]string
+}
+
+func (b0 OpenConnectionRequest_builder) Build() *OpenConnectionRequest {
+ m0 := &OpenConnectionRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_Info = b.Info
+ return m0
+}
+
// Request for Meta#closeConnection(Meta.ConnectionHandle)
type CloseConnectionRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CloseConnectionRequest) Reset() {
*x = CloseConnectionRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[13]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[13]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CloseConnectionRequest) String() string {
@@ -962,7 +1293,7 @@ func (*CloseConnectionRequest) ProtoMessage() {}
func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[13]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -972,34 +1303,44 @@ func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CloseConnectionRequest.ProtoReflect.Descriptor instead.
-func (*CloseConnectionRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{13}
-}
-
func (x *CloseConnectionRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
-type ConnectionSyncRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *CloseConnectionRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type CloseConnectionRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- ConnProps *ConnectionProperties `protobuf:"bytes,2,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
+func (b0 CloseConnectionRequest_builder) Build() *CloseConnectionRequest {
+ m0 := &CloseConnectionRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
+type ConnectionSyncRequest struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_ConnProps *ConnectionProperties `protobuf:"bytes,2,opt,name=conn_props,json=connProps,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ConnectionSyncRequest) Reset() {
*x = ConnectionSyncRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[14]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[14]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ConnectionSyncRequest) String() string {
@@ -1010,7 +1351,7 @@ func (*ConnectionSyncRequest) ProtoMessage() {}
func (x *ConnectionSyncRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[14]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1020,45 +1361,72 @@ func (x *ConnectionSyncRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ConnectionSyncRequest.ProtoReflect.Descriptor instead.
-func (*ConnectionSyncRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{14}
-}
-
func (x *ConnectionSyncRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *ConnectionSyncRequest) GetConnProps() *ConnectionProperties {
if x != nil {
- return x.ConnProps
+ return x.xxx_hidden_ConnProps
}
return nil
}
+func (x *ConnectionSyncRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *ConnectionSyncRequest) SetConnProps(v *ConnectionProperties) {
+ x.xxx_hidden_ConnProps = v
+}
+
+func (x *ConnectionSyncRequest) HasConnProps() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_ConnProps != nil
+}
+
+func (x *ConnectionSyncRequest) ClearConnProps() {
+ x.xxx_hidden_ConnProps = nil
+}
+
+type ConnectionSyncRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ ConnProps *ConnectionProperties
+}
+
+func (b0 ConnectionSyncRequest_builder) Build() *ConnectionSyncRequest {
+ m0 := &ConnectionSyncRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_ConnProps = b.ConnProps
+ return m0
+}
+
// Request for Meta#execute(Meta.ConnectionHandle, list, long)
type ExecuteRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- StatementHandle *StatementHandle `protobuf:"bytes,1,opt,name=statementHandle,proto3" json:"statementHandle,omitempty"`
- ParameterValues []*TypedValue `protobuf:"bytes,2,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
- DeprecatedFirstFrameMaxSize uint64 `protobuf:"varint,3,opt,name=deprecated_first_frame_max_size,json=deprecatedFirstFrameMaxSize,proto3" json:"deprecated_first_frame_max_size,omitempty"` // Deprecated, use the signed int instead.
- HasParameterValues bool `protobuf:"varint,4,opt,name=has_parameter_values,json=hasParameterValues,proto3" json:"has_parameter_values,omitempty"`
- FirstFrameMaxSize int32 `protobuf:"varint,5,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"` // The maximum number of rows to return in the first Frame
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_StatementHandle *StatementHandle `protobuf:"bytes,1,opt,name=statementHandle,proto3"`
+ xxx_hidden_ParameterValues *[]*TypedValue `protobuf:"bytes,2,rep,name=parameter_values,json=parameterValues,proto3"`
+ xxx_hidden_DeprecatedFirstFrameMaxSize uint64 `protobuf:"varint,3,opt,name=deprecated_first_frame_max_size,json=deprecatedFirstFrameMaxSize,proto3"`
+ xxx_hidden_HasParameterValues bool `protobuf:"varint,4,opt,name=has_parameter_values,json=hasParameterValues,proto3"`
+ xxx_hidden_FirstFrameMaxSize int32 `protobuf:"varint,5,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ExecuteRequest) Reset() {
*x = ExecuteRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[15]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[15]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ExecuteRequest) String() string {
@@ -1069,7 +1437,7 @@ func (*ExecuteRequest) ProtoMessage() {}
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[15]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1079,64 +1447,111 @@ func (x *ExecuteRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
-func (*ExecuteRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{15}
-}
-
func (x *ExecuteRequest) GetStatementHandle() *StatementHandle {
if x != nil {
- return x.StatementHandle
+ return x.xxx_hidden_StatementHandle
}
return nil
}
func (x *ExecuteRequest) GetParameterValues() []*TypedValue {
if x != nil {
- return x.ParameterValues
+ if x.xxx_hidden_ParameterValues != nil {
+ return *x.xxx_hidden_ParameterValues
+ }
}
return nil
}
func (x *ExecuteRequest) GetDeprecatedFirstFrameMaxSize() uint64 {
if x != nil {
- return x.DeprecatedFirstFrameMaxSize
+ return x.xxx_hidden_DeprecatedFirstFrameMaxSize
}
return 0
}
func (x *ExecuteRequest) GetHasParameterValues() bool {
if x != nil {
- return x.HasParameterValues
+ return x.xxx_hidden_HasParameterValues
}
return false
}
func (x *ExecuteRequest) GetFirstFrameMaxSize() int32 {
if x != nil {
- return x.FirstFrameMaxSize
+ return x.xxx_hidden_FirstFrameMaxSize
}
return 0
}
-type SyncResultsRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *ExecuteRequest) SetStatementHandle(v *StatementHandle) {
+ x.xxx_hidden_StatementHandle = v
+}
+
+func (x *ExecuteRequest) SetParameterValues(v []*TypedValue) {
+ x.xxx_hidden_ParameterValues = &v
+}
+
+func (x *ExecuteRequest) SetDeprecatedFirstFrameMaxSize(v uint64) {
+ x.xxx_hidden_DeprecatedFirstFrameMaxSize = v
+}
+
+func (x *ExecuteRequest) SetHasParameterValues(v bool) {
+ x.xxx_hidden_HasParameterValues = v
+}
+
+func (x *ExecuteRequest) SetFirstFrameMaxSize(v int32) {
+ x.xxx_hidden_FirstFrameMaxSize = v
+}
+
+func (x *ExecuteRequest) HasStatementHandle() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_StatementHandle != nil
+}
+
+func (x *ExecuteRequest) ClearStatementHandle() {
+ x.xxx_hidden_StatementHandle = nil
+}
+
+type ExecuteRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ StatementHandle *StatementHandle
+ ParameterValues []*TypedValue
+ DeprecatedFirstFrameMaxSize uint64
+ HasParameterValues bool
+ FirstFrameMaxSize int32
+}
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- State *QueryState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
- Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
+func (b0 ExecuteRequest_builder) Build() *ExecuteRequest {
+ m0 := &ExecuteRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_StatementHandle = b.StatementHandle
+ x.xxx_hidden_ParameterValues = &b.ParameterValues
+ x.xxx_hidden_DeprecatedFirstFrameMaxSize = b.DeprecatedFirstFrameMaxSize
+ x.xxx_hidden_HasParameterValues = b.HasParameterValues
+ x.xxx_hidden_FirstFrameMaxSize = b.FirstFrameMaxSize
+ return m0
+}
+
+type SyncResultsRequest struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_State *QueryState `protobuf:"bytes,3,opt,name=state,proto3"`
+ xxx_hidden_Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *SyncResultsRequest) Reset() {
*x = SyncResultsRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[16]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[16]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *SyncResultsRequest) String() string {
@@ -1147,7 +1562,7 @@ func (*SyncResultsRequest) ProtoMessage() {}
func (x *SyncResultsRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[16]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1157,55 +1572,94 @@ func (x *SyncResultsRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use SyncResultsRequest.ProtoReflect.Descriptor instead.
-func (*SyncResultsRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{16}
-}
-
func (x *SyncResultsRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *SyncResultsRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *SyncResultsRequest) GetState() *QueryState {
if x != nil {
- return x.State
+ return x.xxx_hidden_State
}
return nil
}
func (x *SyncResultsRequest) GetOffset() uint64 {
if x != nil {
- return x.Offset
+ return x.xxx_hidden_Offset
}
return 0
}
+func (x *SyncResultsRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *SyncResultsRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *SyncResultsRequest) SetState(v *QueryState) {
+ x.xxx_hidden_State = v
+}
+
+func (x *SyncResultsRequest) SetOffset(v uint64) {
+ x.xxx_hidden_Offset = v
+}
+
+func (x *SyncResultsRequest) HasState() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_State != nil
+}
+
+func (x *SyncResultsRequest) ClearState() {
+ x.xxx_hidden_State = nil
+}
+
+type SyncResultsRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ State *QueryState
+ Offset uint64
+}
+
+func (b0 SyncResultsRequest_builder) Build() *SyncResultsRequest {
+ m0 := &SyncResultsRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_State = b.State
+ x.xxx_hidden_Offset = b.Offset
+ return m0
+}
+
// Request to invoke a commit on a Connection
type CommitRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CommitRequest) Reset() {
*x = CommitRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[17]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[17]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CommitRequest) String() string {
@@ -1216,7 +1670,7 @@ func (*CommitRequest) ProtoMessage() {}
func (x *CommitRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[17]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1226,34 +1680,44 @@ func (x *CommitRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.
-func (*CommitRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{17}
-}
-
func (x *CommitRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *CommitRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type CommitRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 CommitRequest_builder) Build() *CommitRequest {
+ m0 := &CommitRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request to invoke rollback on a Connection
type RollbackRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RollbackRequest) Reset() {
*x = RollbackRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[18]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[18]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RollbackRequest) String() string {
@@ -1264,7 +1728,7 @@ func (*RollbackRequest) ProtoMessage() {}
func (x *RollbackRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[18]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1274,36 +1738,46 @@ func (x *RollbackRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead.
-func (*RollbackRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{18}
-}
-
func (x *RollbackRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
+func (x *RollbackRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+type RollbackRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+}
+
+func (b0 RollbackRequest_builder) Build() *RollbackRequest {
+ m0 := &RollbackRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ return m0
+}
+
// Request to prepare and execute a collection of sql statements.
type PrepareAndExecuteBatchRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- SqlCommands []string `protobuf:"bytes,3,rep,name=sql_commands,json=sqlCommands,proto3" json:"sql_commands,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_SqlCommands []string `protobuf:"bytes,3,rep,name=sql_commands,json=sqlCommands,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PrepareAndExecuteBatchRequest) Reset() {
*x = PrepareAndExecuteBatchRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[19]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[19]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PrepareAndExecuteBatchRequest) String() string {
@@ -1314,7 +1788,7 @@ func (*PrepareAndExecuteBatchRequest) ProtoMessage() {}
func (x *PrepareAndExecuteBatchRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[19]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1324,48 +1798,70 @@ func (x *PrepareAndExecuteBatchRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use PrepareAndExecuteBatchRequest.ProtoReflect.Descriptor instead.
-func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{19}
-}
-
func (x *PrepareAndExecuteBatchRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *PrepareAndExecuteBatchRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *PrepareAndExecuteBatchRequest) GetSqlCommands() []string {
if x != nil {
- return x.SqlCommands
+ return x.xxx_hidden_SqlCommands
}
return nil
}
+func (x *PrepareAndExecuteBatchRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *PrepareAndExecuteBatchRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *PrepareAndExecuteBatchRequest) SetSqlCommands(v []string) {
+ x.xxx_hidden_SqlCommands = v
+}
+
+type PrepareAndExecuteBatchRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ SqlCommands []string
+}
+
+func (b0 PrepareAndExecuteBatchRequest_builder) Build() *PrepareAndExecuteBatchRequest {
+ m0 := &PrepareAndExecuteBatchRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_SqlCommands = b.SqlCommands
+ return m0
+}
+
// Each command is a list of TypedValues
type UpdateBatch struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ParameterValues []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ParameterValues *[]*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *UpdateBatch) Reset() {
*x = UpdateBatch{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[20]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[20]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *UpdateBatch) String() string {
@@ -1376,7 +1872,7 @@ func (*UpdateBatch) ProtoMessage() {}
func (x *UpdateBatch) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[20]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1386,35 +1882,47 @@ func (x *UpdateBatch) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use UpdateBatch.ProtoReflect.Descriptor instead.
-func (*UpdateBatch) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{20}
-}
-
func (x *UpdateBatch) GetParameterValues() []*TypedValue {
if x != nil {
- return x.ParameterValues
+ if x.xxx_hidden_ParameterValues != nil {
+ return *x.xxx_hidden_ParameterValues
+ }
}
return nil
}
-type ExecuteBatchRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *UpdateBatch) SetParameterValues(v []*TypedValue) {
+ x.xxx_hidden_ParameterValues = &v
+}
+
+type UpdateBatch_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ParameterValues []*TypedValue
+}
+
+func (b0 UpdateBatch_builder) Build() *UpdateBatch {
+ m0 := &UpdateBatch{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ParameterValues = &b.ParameterValues
+ return m0
+}
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- Updates []*UpdateBatch `protobuf:"bytes,3,rep,name=updates,proto3" json:"updates,omitempty"` // A batch of updates is a list<list<typevalue>>
+type ExecuteBatchRequest struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_Updates *[]*UpdateBatch `protobuf:"bytes,3,rep,name=updates,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ExecuteBatchRequest) Reset() {
*x = ExecuteBatchRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_requests_proto_msgTypes[21]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_requests_proto_msgTypes[21]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ExecuteBatchRequest) String() string {
@@ -1425,7 +1933,7 @@ func (*ExecuteBatchRequest) ProtoMessage() {}
func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message {
mi := &file_requests_proto_msgTypes[21]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1435,35 +1943,62 @@ func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ExecuteBatchRequest.ProtoReflect.Descriptor instead.
-func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) {
- return file_requests_proto_rawDescGZIP(), []int{21}
-}
-
func (x *ExecuteBatchRequest) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *ExecuteBatchRequest) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *ExecuteBatchRequest) GetUpdates() []*UpdateBatch {
if x != nil {
- return x.Updates
+ if x.xxx_hidden_Updates != nil {
+ return *x.xxx_hidden_Updates
+ }
}
return nil
}
+func (x *ExecuteBatchRequest) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *ExecuteBatchRequest) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *ExecuteBatchRequest) SetUpdates(v []*UpdateBatch) {
+ x.xxx_hidden_Updates = &v
+}
+
+type ExecuteBatchRequest_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ Updates []*UpdateBatch
+}
+
+func (b0 ExecuteBatchRequest_builder) Build() *ExecuteBatchRequest {
+ m0 := &ExecuteBatchRequest{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_Updates = &b.Updates
+ return m0
+}
+
var File_requests_proto protoreflect.FileDescriptor
-var file_requests_proto_rawDesc = []byte{
+var file_requests_proto_rawDesc = string([]byte{
0x0a, 0x0e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x1a, 0x0c, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x36,
0x0a, 0x0f, 0x43, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
@@ -1670,22 +2205,10 @@ var file_requests_proto_rawDesc = []byte{
0x0a, 0x20, 0x6f, 0x72, 0x67, 0x2e, 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2e, 0x63, 0x61, 0x6c,
0x63, 0x69, 0x74, 0x65, 0x2e, 0x61, 0x76, 0x61, 0x74, 0x69, 0x63, 0x61, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
-
-var (
- file_requests_proto_rawDescOnce sync.Once
- file_requests_proto_rawDescData = file_requests_proto_rawDesc
-)
-
-func file_requests_proto_rawDescGZIP() []byte {
- file_requests_proto_rawDescOnce.Do(func() {
- file_requests_proto_rawDescData = protoimpl.X.CompressGZIP(file_requests_proto_rawDescData)
- })
- return file_requests_proto_rawDescData
-}
+})
var file_requests_proto_msgTypes = make([]protoimpl.MessageInfo, 23)
-var file_requests_proto_goTypes = []interface{}{
+var file_requests_proto_goTypes = []any{
(*CatalogsRequest)(nil), // 0: CatalogsRequest
(*DatabasePropertyRequest)(nil), // 1: DatabasePropertyRequest
(*SchemasRequest)(nil), // 2: SchemasRequest
@@ -1735,277 +2258,11 @@ func file_requests_proto_init() {
return
}
file_common_proto_init()
- if !protoimpl.UnsafeEnabled {
- file_requests_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CatalogsRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*DatabasePropertyRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*SchemasRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*TablesRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*TableTypesRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ColumnsRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*TypeInfoRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*PrepareAndExecuteRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*PrepareRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*FetchRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CreateStatementRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CloseStatementRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*OpenConnectionRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CloseConnectionRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ConnectionSyncRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ExecuteRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*SyncResultsRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CommitRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*RollbackRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*PrepareAndExecuteBatchRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*UpdateBatch); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_requests_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ExecuteBatchRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- }
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
- RawDescriptor: file_requests_proto_rawDesc,
+ RawDescriptor: unsafe.Slice(unsafe.StringData(file_requests_proto_rawDesc), len(file_requests_proto_rawDesc)),
NumEnums: 0,
NumMessages: 23,
NumExtensions: 0,
@@ -2016,7 +2273,6 @@ func file_requests_proto_init() {
MessageInfos: file_requests_proto_msgTypes,
}.Build()
File_requests_proto = out.File
- file_requests_proto_rawDesc = nil
file_requests_proto_goTypes = nil
file_requests_proto_depIdxs = nil
}
diff --git a/message/responses.pb.go b/message/responses.pb.go
index f45dcda..5bed4c7 100644
--- a/message/responses.pb.go
+++ b/message/responses.pb.go
@@ -16,8 +16,8 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
-// protoc-gen-go v1.30.0
-// protoc v4.25.1
+// protoc-gen-go v1.36.5
+// protoc v5.29.3
// source: responses.proto
package message
@@ -26,7 +26,7 @@ import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
- sync "sync"
+ unsafe "unsafe"
)
const (
@@ -38,27 +38,23 @@ const (
// Response that contains a result set.
type ResultSetResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- OwnStatement bool `protobuf:"varint,3,opt,name=own_statement,json=ownStatement,proto3" json:"own_statement,omitempty"`
- Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
- FirstFrame *Frame `protobuf:"bytes,5,opt,name=first_frame,json=firstFrame,proto3" json:"first_frame,omitempty"`
- UpdateCount uint64 `protobuf:"varint,6,opt,name=update_count,json=updateCount,proto3" json:"update_count,omitempty"` // -1 for normal result sets, else this response contains a dummy result set
- // with no signature nor other data.
- Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_OwnStatement bool `protobuf:"varint,3,opt,name=own_statement,json=ownStatement,proto3"`
+ xxx_hidden_Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3"`
+ xxx_hidden_FirstFrame *Frame `protobuf:"bytes,5,opt,name=first_frame,json=firstFrame,proto3"`
+ xxx_hidden_UpdateCount uint64 `protobuf:"varint,6,opt,name=update_count,json=updateCount,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ResultSetResponse) Reset() {
*x = ResultSetResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[0]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ResultSetResponse) String() string {
@@ -69,7 +65,7 @@ func (*ResultSetResponse) ProtoMessage() {}
func (x *ResultSetResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[0]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -79,78 +75,158 @@ func (x *ResultSetResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ResultSetResponse.ProtoReflect.Descriptor instead.
-func (*ResultSetResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{0}
-}
-
func (x *ResultSetResponse) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *ResultSetResponse) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *ResultSetResponse) GetOwnStatement() bool {
if x != nil {
- return x.OwnStatement
+ return x.xxx_hidden_OwnStatement
}
return false
}
func (x *ResultSetResponse) GetSignature() *Signature {
if x != nil {
- return x.Signature
+ return x.xxx_hidden_Signature
}
return nil
}
func (x *ResultSetResponse) GetFirstFrame() *Frame {
if x != nil {
- return x.FirstFrame
+ return x.xxx_hidden_FirstFrame
}
return nil
}
func (x *ResultSetResponse) GetUpdateCount() uint64 {
if x != nil {
- return x.UpdateCount
+ return x.xxx_hidden_UpdateCount
}
return 0
}
func (x *ResultSetResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *ResultSetResponse) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *ResultSetResponse) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *ResultSetResponse) SetOwnStatement(v bool) {
+ x.xxx_hidden_OwnStatement = v
+}
+
+func (x *ResultSetResponse) SetSignature(v *Signature) {
+ x.xxx_hidden_Signature = v
+}
+
+func (x *ResultSetResponse) SetFirstFrame(v *Frame) {
+ x.xxx_hidden_FirstFrame = v
+}
+
+func (x *ResultSetResponse) SetUpdateCount(v uint64) {
+ x.xxx_hidden_UpdateCount = v
+}
+
+func (x *ResultSetResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *ResultSetResponse) HasSignature() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Signature != nil
+}
+
+func (x *ResultSetResponse) HasFirstFrame() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_FirstFrame != nil
+}
+
+func (x *ResultSetResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *ResultSetResponse) ClearSignature() {
+ x.xxx_hidden_Signature = nil
+}
+
+func (x *ResultSetResponse) ClearFirstFrame() {
+ x.xxx_hidden_FirstFrame = nil
+}
+
+func (x *ResultSetResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type ResultSetResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ OwnStatement bool
+ Signature *Signature
+ FirstFrame *Frame
+ UpdateCount uint64
+ // with no signature nor other data.
+ Metadata *RpcMetadata
+}
+
+func (b0 ResultSetResponse_builder) Build() *ResultSetResponse {
+ m0 := &ResultSetResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_OwnStatement = b.OwnStatement
+ x.xxx_hidden_Signature = b.Signature
+ x.xxx_hidden_FirstFrame = b.FirstFrame
+ x.xxx_hidden_UpdateCount = b.UpdateCount
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to PrepareAndExecuteRequest
type ExecuteResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Results []*ResultSetResponse `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
- MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Did the request fail because of no-cached statement
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Results *[]*ResultSetResponse `protobuf:"bytes,1,rep,name=results,proto3"`
+ xxx_hidden_MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ExecuteResponse) Reset() {
*x = ExecuteResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[1]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ExecuteResponse) String() string {
@@ -161,7 +237,7 @@ func (*ExecuteResponse) ProtoMessage() {}
func (x *ExecuteResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[1]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -171,49 +247,84 @@ func (x *ExecuteResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
-func (*ExecuteResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{1}
-}
-
func (x *ExecuteResponse) GetResults() []*ResultSetResponse {
if x != nil {
- return x.Results
+ if x.xxx_hidden_Results != nil {
+ return *x.xxx_hidden_Results
+ }
}
return nil
}
func (x *ExecuteResponse) GetMissingStatement() bool {
if x != nil {
- return x.MissingStatement
+ return x.xxx_hidden_MissingStatement
}
return false
}
func (x *ExecuteResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *ExecuteResponse) SetResults(v []*ResultSetResponse) {
+ x.xxx_hidden_Results = &v
+}
+
+func (x *ExecuteResponse) SetMissingStatement(v bool) {
+ x.xxx_hidden_MissingStatement = v
+}
+
+func (x *ExecuteResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *ExecuteResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *ExecuteResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type ExecuteResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Results []*ResultSetResponse
+ MissingStatement bool
+ Metadata *RpcMetadata
+}
+
+func (b0 ExecuteResponse_builder) Build() *ExecuteResponse {
+ m0 := &ExecuteResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Results = &b.Results
+ x.xxx_hidden_MissingStatement = b.MissingStatement
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to PrepareRequest
type PrepareResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Statement *StatementHandle `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Statement *StatementHandle `protobuf:"bytes,1,opt,name=statement,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PrepareResponse) Reset() {
*x = PrepareResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[2]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PrepareResponse) String() string {
@@ -224,7 +335,7 @@ func (*PrepareResponse) ProtoMessage() {}
func (x *PrepareResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[2]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -234,44 +345,82 @@ func (x *PrepareResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.
-func (*PrepareResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{2}
-}
-
func (x *PrepareResponse) GetStatement() *StatementHandle {
if x != nil {
- return x.Statement
+ return x.xxx_hidden_Statement
}
return nil
}
func (x *PrepareResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *PrepareResponse) SetStatement(v *StatementHandle) {
+ x.xxx_hidden_Statement = v
+}
+
+func (x *PrepareResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *PrepareResponse) HasStatement() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Statement != nil
+}
+
+func (x *PrepareResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *PrepareResponse) ClearStatement() {
+ x.xxx_hidden_Statement = nil
+}
+
+func (x *PrepareResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type PrepareResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Statement *StatementHandle
+ Metadata *RpcMetadata
+}
+
+func (b0 PrepareResponse_builder) Build() *PrepareResponse {
+ m0 := &PrepareResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Statement = b.Statement
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to FetchRequest
type FetchResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Frame *Frame `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
- MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Did the request fail because of no-cached statement
- MissingResults bool `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3" json:"missing_results,omitempty"` // Did the request fail because of a cached-statement w/o ResultSet
- Metadata *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Frame *Frame `protobuf:"bytes,1,opt,name=frame,proto3"`
+ xxx_hidden_MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3"`
+ xxx_hidden_MissingResults bool `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *FetchResponse) Reset() {
*x = FetchResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[3]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *FetchResponse) String() string {
@@ -282,7 +431,7 @@ func (*FetchResponse) ProtoMessage() {}
func (x *FetchResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[3]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -292,57 +441,107 @@ func (x *FetchResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use FetchResponse.ProtoReflect.Descriptor instead.
-func (*FetchResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{3}
-}
-
func (x *FetchResponse) GetFrame() *Frame {
if x != nil {
- return x.Frame
+ return x.xxx_hidden_Frame
}
return nil
}
func (x *FetchResponse) GetMissingStatement() bool {
if x != nil {
- return x.MissingStatement
+ return x.xxx_hidden_MissingStatement
}
return false
}
func (x *FetchResponse) GetMissingResults() bool {
if x != nil {
- return x.MissingResults
+ return x.xxx_hidden_MissingResults
}
return false
}
func (x *FetchResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *FetchResponse) SetFrame(v *Frame) {
+ x.xxx_hidden_Frame = v
+}
+
+func (x *FetchResponse) SetMissingStatement(v bool) {
+ x.xxx_hidden_MissingStatement = v
+}
+
+func (x *FetchResponse) SetMissingResults(v bool) {
+ x.xxx_hidden_MissingResults = v
+}
+
+func (x *FetchResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *FetchResponse) HasFrame() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Frame != nil
+}
+
+func (x *FetchResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *FetchResponse) ClearFrame() {
+ x.xxx_hidden_Frame = nil
+}
+
+func (x *FetchResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type FetchResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Frame *Frame
+ MissingStatement bool
+ MissingResults bool
+ Metadata *RpcMetadata
+}
+
+func (b0 FetchResponse_builder) Build() *FetchResponse {
+ m0 := &FetchResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Frame = b.Frame
+ x.xxx_hidden_MissingStatement = b.MissingStatement
+ x.xxx_hidden_MissingResults = b.MissingResults
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to CreateStatementRequest
type CreateStatementResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CreateStatementResponse) Reset() {
*x = CreateStatementResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[4]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CreateStatementResponse) String() string {
@@ -353,7 +552,7 @@ func (*CreateStatementResponse) ProtoMessage() {}
func (x *CreateStatementResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[4]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -363,48 +562,81 @@ func (x *CreateStatementResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CreateStatementResponse.ProtoReflect.Descriptor instead.
-func (*CreateStatementResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{4}
-}
-
func (x *CreateStatementResponse) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *CreateStatementResponse) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *CreateStatementResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *CreateStatementResponse) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *CreateStatementResponse) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *CreateStatementResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *CreateStatementResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *CreateStatementResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type CreateStatementResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ Metadata *RpcMetadata
+}
+
+func (b0 CreateStatementResponse_builder) Build() *CreateStatementResponse {
+ m0 := &CreateStatementResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to CloseStatementRequest
type CloseStatementResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CloseStatementResponse) Reset() {
*x = CloseStatementResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[5]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CloseStatementResponse) String() string {
@@ -415,7 +647,7 @@ func (*CloseStatementResponse) ProtoMessage() {}
func (x *CloseStatementResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[5]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -425,34 +657,55 @@ func (x *CloseStatementResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CloseStatementResponse.ProtoReflect.Descriptor instead.
-func (*CloseStatementResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{5}
-}
-
func (x *CloseStatementResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *CloseStatementResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *CloseStatementResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *CloseStatementResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type CloseStatementResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Metadata *RpcMetadata
+}
+
+func (b0 CloseStatementResponse_builder) Build() *CloseStatementResponse {
+ m0 := &CloseStatementResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to OpenConnectionRequest {
type OpenConnectionResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *OpenConnectionResponse) Reset() {
*x = OpenConnectionResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[6]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *OpenConnectionResponse) String() string {
@@ -463,7 +716,7 @@ func (*OpenConnectionResponse) ProtoMessage() {}
func (x *OpenConnectionResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[6]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -473,34 +726,55 @@ func (x *OpenConnectionResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use OpenConnectionResponse.ProtoReflect.Descriptor instead.
-func (*OpenConnectionResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{6}
-}
-
func (x *OpenConnectionResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *OpenConnectionResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *OpenConnectionResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *OpenConnectionResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type OpenConnectionResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Metadata *RpcMetadata
+}
+
+func (b0 OpenConnectionResponse_builder) Build() *OpenConnectionResponse {
+ m0 := &OpenConnectionResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to CloseConnectionRequest {
type CloseConnectionResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CloseConnectionResponse) Reset() {
*x = CloseConnectionResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[7]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CloseConnectionResponse) String() string {
@@ -511,7 +785,7 @@ func (*CloseConnectionResponse) ProtoMessage() {}
func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[7]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -521,35 +795,56 @@ func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CloseConnectionResponse.ProtoReflect.Descriptor instead.
-func (*CloseConnectionResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{7}
-}
-
func (x *CloseConnectionResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *CloseConnectionResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *CloseConnectionResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *CloseConnectionResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type CloseConnectionResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Metadata *RpcMetadata
+}
+
+func (b0 CloseConnectionResponse_builder) Build() *CloseConnectionResponse {
+ m0 := &CloseConnectionResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response to ConnectionSyncRequest
type ConnectionSyncResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnProps *ConnectionProperties `protobuf:"bytes,1,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnProps *ConnectionProperties `protobuf:"bytes,1,opt,name=conn_props,json=connProps,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ConnectionSyncResponse) Reset() {
*x = ConnectionSyncResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[8]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ConnectionSyncResponse) String() string {
@@ -560,7 +855,7 @@ func (*ConnectionSyncResponse) ProtoMessage() {}
func (x *ConnectionSyncResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[8]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -570,42 +865,80 @@ func (x *ConnectionSyncResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ConnectionSyncResponse.ProtoReflect.Descriptor instead.
-func (*ConnectionSyncResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{8}
-}
-
func (x *ConnectionSyncResponse) GetConnProps() *ConnectionProperties {
if x != nil {
- return x.ConnProps
+ return x.xxx_hidden_ConnProps
}
return nil
}
func (x *ConnectionSyncResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
-type DatabasePropertyElement struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *ConnectionSyncResponse) SetConnProps(v *ConnectionProperties) {
+ x.xxx_hidden_ConnProps = v
+}
+
+func (x *ConnectionSyncResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *ConnectionSyncResponse) HasConnProps() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_ConnProps != nil
+}
+
+func (x *ConnectionSyncResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
- Key *DatabaseProperty `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
- Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+func (x *ConnectionSyncResponse) ClearConnProps() {
+ x.xxx_hidden_ConnProps = nil
+}
+
+func (x *ConnectionSyncResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type ConnectionSyncResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnProps *ConnectionProperties
+ Metadata *RpcMetadata
+}
+
+func (b0 ConnectionSyncResponse_builder) Build() *ConnectionSyncResponse {
+ m0 := &ConnectionSyncResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnProps = b.ConnProps
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
+type DatabasePropertyElement struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Key *DatabaseProperty `protobuf:"bytes,1,opt,name=key,proto3"`
+ xxx_hidden_Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *DatabasePropertyElement) Reset() {
*x = DatabasePropertyElement{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[9]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *DatabasePropertyElement) String() string {
@@ -616,7 +949,7 @@ func (*DatabasePropertyElement) ProtoMessage() {}
func (x *DatabasePropertyElement) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[9]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -626,49 +959,104 @@ func (x *DatabasePropertyElement) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use DatabasePropertyElement.ProtoReflect.Descriptor instead.
-func (*DatabasePropertyElement) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{9}
-}
-
func (x *DatabasePropertyElement) GetKey() *DatabaseProperty {
if x != nil {
- return x.Key
+ return x.xxx_hidden_Key
}
return nil
}
func (x *DatabasePropertyElement) GetValue() *TypedValue {
if x != nil {
- return x.Value
+ return x.xxx_hidden_Value
}
return nil
}
func (x *DatabasePropertyElement) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *DatabasePropertyElement) SetKey(v *DatabaseProperty) {
+ x.xxx_hidden_Key = v
+}
+
+func (x *DatabasePropertyElement) SetValue(v *TypedValue) {
+ x.xxx_hidden_Value = v
+}
+
+func (x *DatabasePropertyElement) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *DatabasePropertyElement) HasKey() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Key != nil
+}
+
+func (x *DatabasePropertyElement) HasValue() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Value != nil
+}
+
+func (x *DatabasePropertyElement) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *DatabasePropertyElement) ClearKey() {
+ x.xxx_hidden_Key = nil
+}
+
+func (x *DatabasePropertyElement) ClearValue() {
+ x.xxx_hidden_Value = nil
+}
+
+func (x *DatabasePropertyElement) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type DatabasePropertyElement_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Key *DatabaseProperty
+ Value *TypedValue
+ Metadata *RpcMetadata
+}
+
+func (b0 DatabasePropertyElement_builder) Build() *DatabasePropertyElement {
+ m0 := &DatabasePropertyElement{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Key = b.Key
+ x.xxx_hidden_Value = b.Value
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Response for Meta#getDatabaseProperties()
type DatabasePropertyResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Props []*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props,proto3" json:"props,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Props *[]*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *DatabasePropertyResponse) Reset() {
*x = DatabasePropertyResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[10]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *DatabasePropertyResponse) String() string {
@@ -679,7 +1067,7 @@ func (*DatabasePropertyResponse) ProtoMessage() {}
func (x *DatabasePropertyResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[10]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -689,47 +1077,76 @@ func (x *DatabasePropertyResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use DatabasePropertyResponse.ProtoReflect.Descriptor instead.
-func (*DatabasePropertyResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{10}
-}
-
func (x *DatabasePropertyResponse) GetProps() []*DatabasePropertyElement {
if x != nil {
- return x.Props
+ if x.xxx_hidden_Props != nil {
+ return *x.xxx_hidden_Props
+ }
}
return nil
}
func (x *DatabasePropertyResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *DatabasePropertyResponse) SetProps(v []*DatabasePropertyElement) {
+ x.xxx_hidden_Props = &v
+}
+
+func (x *DatabasePropertyResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *DatabasePropertyResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *DatabasePropertyResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type DatabasePropertyResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Props []*DatabasePropertyElement
+ Metadata *RpcMetadata
+}
+
+func (b0 DatabasePropertyResponse_builder) Build() *DatabasePropertyResponse {
+ m0 := &DatabasePropertyResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Props = &b.Props
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Send contextual information about some error over the wire from the server.
type ErrorResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Exceptions []string `protobuf:"bytes,1,rep,name=exceptions,proto3" json:"exceptions,omitempty"` // exception stacktraces, many for linked exceptions.
- HasExceptions bool `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3" json:"has_exceptions,omitempty"` // are there stacktraces contained?
- ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // human readable description
- Severity Severity `protobuf:"varint,3,opt,name=severity,proto3,enum=Severity" json:"severity,omitempty"`
- ErrorCode uint32 `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` // numeric identifier for error
- SqlState string `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"` // five-character standard-defined value
- Metadata *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_Exceptions []string `protobuf:"bytes,1,rep,name=exceptions,proto3"`
+ xxx_hidden_HasExceptions bool `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3"`
+ xxx_hidden_ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3"`
+ xxx_hidden_Severity Severity `protobuf:"varint,3,opt,name=severity,proto3,enum=Severity"`
+ xxx_hidden_ErrorCode uint32 `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3"`
+ xxx_hidden_SqlState string `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ErrorResponse) Reset() {
*x = ErrorResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[11]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ErrorResponse) String() string {
@@ -740,7 +1157,7 @@ func (*ErrorResponse) ProtoMessage() {}
func (x *ErrorResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[11]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -750,77 +1167,134 @@ func (x *ErrorResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.
-func (*ErrorResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{11}
-}
-
func (x *ErrorResponse) GetExceptions() []string {
if x != nil {
- return x.Exceptions
+ return x.xxx_hidden_Exceptions
}
return nil
}
func (x *ErrorResponse) GetHasExceptions() bool {
if x != nil {
- return x.HasExceptions
+ return x.xxx_hidden_HasExceptions
}
return false
}
func (x *ErrorResponse) GetErrorMessage() string {
if x != nil {
- return x.ErrorMessage
+ return x.xxx_hidden_ErrorMessage
}
return ""
}
func (x *ErrorResponse) GetSeverity() Severity {
if x != nil {
- return x.Severity
+ return x.xxx_hidden_Severity
}
return Severity_UNKNOWN_SEVERITY
}
func (x *ErrorResponse) GetErrorCode() uint32 {
if x != nil {
- return x.ErrorCode
+ return x.xxx_hidden_ErrorCode
}
return 0
}
func (x *ErrorResponse) GetSqlState() string {
if x != nil {
- return x.SqlState
+ return x.xxx_hidden_SqlState
}
return ""
}
func (x *ErrorResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
-type SyncResultsResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
+func (x *ErrorResponse) SetExceptions(v []string) {
+ x.xxx_hidden_Exceptions = v
+}
+
+func (x *ErrorResponse) SetHasExceptions(v bool) {
+ x.xxx_hidden_HasExceptions = v
+}
+
+func (x *ErrorResponse) SetErrorMessage(v string) {
+ x.xxx_hidden_ErrorMessage = v
+}
+
+func (x *ErrorResponse) SetSeverity(v Severity) {
+ x.xxx_hidden_Severity = v
+}
+
+func (x *ErrorResponse) SetErrorCode(v uint32) {
+ x.xxx_hidden_ErrorCode = v
+}
+
+func (x *ErrorResponse) SetSqlState(v string) {
+ x.xxx_hidden_SqlState = v
+}
+
+func (x *ErrorResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
- MissingStatement bool `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Server doesn't have the statement with the ID from the request
- MoreResults bool `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3" json:"more_results,omitempty"` // Should the client fetch() to get more results
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+func (x *ErrorResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *ErrorResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type ErrorResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ Exceptions []string
+ HasExceptions bool
+ ErrorMessage string
+ Severity Severity
+ ErrorCode uint32
+ SqlState string
+ Metadata *RpcMetadata
+}
+
+func (b0 ErrorResponse_builder) Build() *ErrorResponse {
+ m0 := &ErrorResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_Exceptions = b.Exceptions
+ x.xxx_hidden_HasExceptions = b.HasExceptions
+ x.xxx_hidden_ErrorMessage = b.ErrorMessage
+ x.xxx_hidden_Severity = b.Severity
+ x.xxx_hidden_ErrorCode = b.ErrorCode
+ x.xxx_hidden_SqlState = b.SqlState
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
+type SyncResultsResponse struct {
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_MissingStatement bool `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3"`
+ xxx_hidden_MoreResults bool `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *SyncResultsResponse) Reset() {
*x = SyncResultsResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[12]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[12]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *SyncResultsResponse) String() string {
@@ -831,7 +1305,7 @@ func (*SyncResultsResponse) ProtoMessage() {}
func (x *SyncResultsResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[12]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -841,48 +1315,81 @@ func (x *SyncResultsResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use SyncResultsResponse.ProtoReflect.Descriptor instead.
-func (*SyncResultsResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{12}
-}
-
func (x *SyncResultsResponse) GetMissingStatement() bool {
if x != nil {
- return x.MissingStatement
+ return x.xxx_hidden_MissingStatement
}
return false
}
func (x *SyncResultsResponse) GetMoreResults() bool {
if x != nil {
- return x.MoreResults
+ return x.xxx_hidden_MoreResults
}
return false
}
func (x *SyncResultsResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *SyncResultsResponse) SetMissingStatement(v bool) {
+ x.xxx_hidden_MissingStatement = v
+}
+
+func (x *SyncResultsResponse) SetMoreResults(v bool) {
+ x.xxx_hidden_MoreResults = v
+}
+
+func (x *SyncResultsResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *SyncResultsResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *SyncResultsResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type SyncResultsResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ MissingStatement bool
+ MoreResults bool
+ Metadata *RpcMetadata
+}
+
+func (b0 SyncResultsResponse_builder) Build() *SyncResultsResponse {
+ m0 := &SyncResultsResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_MissingStatement = b.MissingStatement
+ x.xxx_hidden_MoreResults = b.MoreResults
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
// Generic metadata for the server to return with each response.
type RpcMetadata struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"` // The host:port of the server
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RpcMetadata) Reset() {
*x = RpcMetadata{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[13]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[13]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RpcMetadata) String() string {
@@ -893,7 +1400,7 @@ func (*RpcMetadata) ProtoMessage() {}
func (x *RpcMetadata) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[13]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -903,32 +1410,43 @@ func (x *RpcMetadata) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use RpcMetadata.ProtoReflect.Descriptor instead.
-func (*RpcMetadata) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{13}
-}
-
func (x *RpcMetadata) GetServerAddress() string {
if x != nil {
- return x.ServerAddress
+ return x.xxx_hidden_ServerAddress
}
return ""
}
+func (x *RpcMetadata) SetServerAddress(v string) {
+ x.xxx_hidden_ServerAddress = v
+}
+
+type RpcMetadata_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ServerAddress string
+}
+
+func (b0 RpcMetadata_builder) Build() *RpcMetadata {
+ m0 := &RpcMetadata{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ServerAddress = b.ServerAddress
+ return m0
+}
+
// Response to a commit request
type CommitResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
+ state protoimpl.MessageState `protogen:"opaque.v1"`
unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *CommitResponse) Reset() {
*x = CommitResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[14]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[14]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *CommitResponse) String() string {
@@ -939,7 +1457,7 @@ func (*CommitResponse) ProtoMessage() {}
func (x *CommitResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[14]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -949,25 +1467,30 @@ func (x *CommitResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.
-func (*CommitResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{14}
+type CommitResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+}
+
+func (b0 CommitResponse_builder) Build() *CommitResponse {
+ m0 := &CommitResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ return m0
}
// Response to a rollback request
type RollbackResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
+ state protoimpl.MessageState `protogen:"opaque.v1"`
unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RollbackResponse) Reset() {
*x = RollbackResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[15]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[15]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RollbackResponse) String() string {
@@ -978,7 +1501,7 @@ func (*RollbackResponse) ProtoMessage() {}
func (x *RollbackResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[15]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -988,31 +1511,35 @@ func (x *RollbackResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead.
-func (*RollbackResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{15}
+type RollbackResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+}
+
+func (b0 RollbackResponse_builder) Build() *RollbackResponse {
+ m0 := &RollbackResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ return m0
}
// Response to a batch update request
type ExecuteBatchResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
- UpdateCounts []uint64 `protobuf:"varint,3,rep,packed,name=update_counts,json=updateCounts,proto3" json:"update_counts,omitempty"`
- MissingStatement bool `protobuf:"varint,4,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Did the request fail because of no-cached statement
- Metadata *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ state protoimpl.MessageState `protogen:"opaque.v1"`
+ xxx_hidden_ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3"`
+ xxx_hidden_StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3"`
+ xxx_hidden_UpdateCounts []uint64 `protobuf:"varint,3,rep,packed,name=update_counts,json=updateCounts,proto3"`
+ xxx_hidden_MissingStatement bool `protobuf:"varint,4,opt,name=missing_statement,json=missingStatement,proto3"`
+ xxx_hidden_Metadata *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ExecuteBatchResponse) Reset() {
*x = ExecuteBatchResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_responses_proto_msgTypes[16]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_responses_proto_msgTypes[16]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ExecuteBatchResponse) String() string {
@@ -1023,7 +1550,7 @@ func (*ExecuteBatchResponse) ProtoMessage() {}
func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message {
mi := &file_responses_proto_msgTypes[16]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1033,49 +1560,97 @@ func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
-// Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead.
-func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) {
- return file_responses_proto_rawDescGZIP(), []int{16}
-}
-
func (x *ExecuteBatchResponse) GetConnectionId() string {
if x != nil {
- return x.ConnectionId
+ return x.xxx_hidden_ConnectionId
}
return ""
}
func (x *ExecuteBatchResponse) GetStatementId() uint32 {
if x != nil {
- return x.StatementId
+ return x.xxx_hidden_StatementId
}
return 0
}
func (x *ExecuteBatchResponse) GetUpdateCounts() []uint64 {
if x != nil {
- return x.UpdateCounts
+ return x.xxx_hidden_UpdateCounts
}
return nil
}
func (x *ExecuteBatchResponse) GetMissingStatement() bool {
if x != nil {
- return x.MissingStatement
+ return x.xxx_hidden_MissingStatement
}
return false
}
func (x *ExecuteBatchResponse) GetMetadata() *RpcMetadata {
if x != nil {
- return x.Metadata
+ return x.xxx_hidden_Metadata
}
return nil
}
+func (x *ExecuteBatchResponse) SetConnectionId(v string) {
+ x.xxx_hidden_ConnectionId = v
+}
+
+func (x *ExecuteBatchResponse) SetStatementId(v uint32) {
+ x.xxx_hidden_StatementId = v
+}
+
+func (x *ExecuteBatchResponse) SetUpdateCounts(v []uint64) {
+ x.xxx_hidden_UpdateCounts = v
+}
+
+func (x *ExecuteBatchResponse) SetMissingStatement(v bool) {
+ x.xxx_hidden_MissingStatement = v
+}
+
+func (x *ExecuteBatchResponse) SetMetadata(v *RpcMetadata) {
+ x.xxx_hidden_Metadata = v
+}
+
+func (x *ExecuteBatchResponse) HasMetadata() bool {
+ if x == nil {
+ return false
+ }
+ return x.xxx_hidden_Metadata != nil
+}
+
+func (x *ExecuteBatchResponse) ClearMetadata() {
+ x.xxx_hidden_Metadata = nil
+}
+
+type ExecuteBatchResponse_builder struct {
+ _ [0]func() // Prevents comparability and use of unkeyed literals for the builder.
+
+ ConnectionId string
+ StatementId uint32
+ UpdateCounts []uint64
+ MissingStatement bool
+ Metadata *RpcMetadata
+}
+
+func (b0 ExecuteBatchResponse_builder) Build() *ExecuteBatchResponse {
+ m0 := &ExecuteBatchResponse{}
+ b, x := &b0, m0
+ _, _ = b, x
+ x.xxx_hidden_ConnectionId = b.ConnectionId
+ x.xxx_hidden_StatementId = b.StatementId
+ x.xxx_hidden_UpdateCounts = b.UpdateCounts
+ x.xxx_hidden_MissingStatement = b.MissingStatement
+ x.xxx_hidden_Metadata = b.Metadata
+ return m0
+}
+
var File_responses_proto protoreflect.FileDescriptor
-var file_responses_proto_rawDesc = []byte{
+var file_responses_proto_rawDesc = string([]byte{
0x0a, 0x0f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x1a, 0x0c, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
0xa0, 0x02, 0x0a, 0x11, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73,
@@ -1218,22 +1793,10 @@ var file_responses_proto_rawDesc = []byte{
0x70, 0x61, 0x63, 0x68, 0x65, 0x2e, 0x63, 0x61, 0x6c, 0x63, 0x69, 0x74, 0x65, 0x2e, 0x61, 0x76,
0x61, 0x74, 0x69, 0x63, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x33,
-}
-
-var (
- file_responses_proto_rawDescOnce sync.Once
- file_responses_proto_rawDescData = file_responses_proto_rawDesc
-)
-
-func file_responses_proto_rawDescGZIP() []byte {
- file_responses_proto_rawDescOnce.Do(func() {
- file_responses_proto_rawDescData = protoimpl.X.CompressGZIP(file_responses_proto_rawDescData)
- })
- return file_responses_proto_rawDescData
-}
+})
var file_responses_proto_msgTypes = make([]protoimpl.MessageInfo, 17)
-var file_responses_proto_goTypes = []interface{}{
+var file_responses_proto_goTypes = []any{
(*ResultSetResponse)(nil), // 0: ResultSetResponse
(*ExecuteResponse)(nil), // 1: ExecuteResponse
(*PrepareResponse)(nil), // 2: PrepareResponse
@@ -1297,217 +1860,11 @@ func file_responses_proto_init() {
return
}
file_common_proto_init()
- if !protoimpl.UnsafeEnabled {
- file_responses_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ResultSetResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ExecuteResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*PrepareResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*FetchResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CreateStatementResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CloseStatementResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*OpenConnectionResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CloseConnectionResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ConnectionSyncResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*DatabasePropertyElement); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*DatabasePropertyResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ErrorResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*SyncResultsResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*RpcMetadata); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*CommitResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*RollbackResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_responses_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*ExecuteBatchResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- }
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
- RawDescriptor: file_responses_proto_rawDesc,
+ RawDescriptor: unsafe.Slice(unsafe.StringData(file_responses_proto_rawDesc), len(file_responses_proto_rawDesc)),
NumEnums: 0,
NumMessages: 17,
NumExtensions: 0,
@@ -1518,7 +1875,6 @@ func file_responses_proto_init() {
MessageInfos: file_responses_proto_msgTypes,
}.Build()
File_responses_proto = out.File
- file_responses_proto_rawDesc = nil
file_responses_proto_goTypes = nil
file_responses_proto_depIdxs = nil
}
diff --git a/phoenix/phoenix.go b/phoenix/phoenix.go
index 9bf4a2f..d3f1751 100644
--- a/phoenix/phoenix.go
+++ b/phoenix/phoenix.go
@@ -39,22 +39,22 @@ func (a Adapter) GetPingStatement() string {
func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.Column {
column := &internal.Column{
- Name: col.ColumnName,
- TypeName: col.Type.Name,
- Nullable: col.Nullable != 0,
+ Name: col.GetColumnName(),
+ TypeName: col.GetType().GetName(),
+ Nullable: col.GetNullable() != 0,
}
// Handle precision and length
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL":
- precision := int64(col.Precision)
+ precision := int64(col.GetPrecision())
if precision == 0 {
precision = math.MaxInt64
}
- scale := int64(col.Scale)
+ scale := int64(col.GetScale())
if scale == 0 {
scale = math.MaxInt64
@@ -65,13 +65,13 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
Scale: scale,
}
case "VARCHAR", "CHAR", "BINARY":
- column.Length = int64(col.Precision)
+ column.Length = int64(col.GetPrecision())
case "VARBINARY":
column.Length = math.MaxInt64
}
// Handle scan types
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "INTEGER", "UNSIGNED_INT", "BIGINT", "UNSIGNED_LONG", "TINYINT", "UNSIGNED_TINYINT", "SMALLINT", "UNSIGNED_SMALLINT":
column.ScanType = reflect.TypeOf(int64(0))
@@ -95,7 +95,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
}
// Handle rep type special cases for decimals, floats, date, time and timestamp
- switch col.Type.Name {
+ switch col.GetType().GetName() {
case "DECIMAL":
column.Rep = message.Rep_BIG_DECIMAL
case "FLOAT":
@@ -109,7 +109,7 @@ func (a Adapter) GetColumnTypeDefinition(col *message.ColumnMetaData) *internal.
case "TIMESTAMP", "UNSIGNED_TIMESTAMP":
column.Rep = message.Rep_JAVA_SQL_TIMESTAMP
default:
- column.Rep = col.Type.Rep
+ column.Rep = col.GetType().GetRep()
}
return column
@@ -122,7 +122,7 @@ func (a Adapter) ErrorResponseToResponseError(err *message.ErrorResponse) errors
)
re := regexp.MustCompile(`ERROR (\d+) \(([0-9a-zA-Z]+)\)`)
- codes := re.FindStringSubmatch(err.ErrorMessage)
+ codes := re.FindStringSubmatch(err.GetErrorMessage())
if len(codes) > 1 {
errorCode, _ = strconv.Atoi(codes[1])
@@ -133,9 +133,9 @@ func (a Adapter) ErrorResponseToResponseError(err *message.ErrorResponse) errors
}
return errors.ResponseError{
- Exceptions: err.Exceptions,
- ErrorMessage: err.ErrorMessage,
- Severity: int8(err.Severity),
+ Exceptions: err.GetExceptions(),
+ ErrorMessage: err.GetErrorMessage(),
+ Severity: int8(err.GetSeverity()),
ErrorCode: errors.ErrorCode(errorCode),
SqlState: errors.SQLState(sqlState),
Metadata: &errors.RPCMetadata{
diff --git a/rows.go b/rows.go
index 3bc6a7b..82d511a 100644
--- a/rows.go
+++ b/rows.go
@@ -96,41 +96,41 @@ func (r *rows) Next(dest []driver.Value) error {
}
// Fetch more results from the server
- res, err := r.conn.httpClient.post(context.Background(), &message.FetchRequest{
+ res, err := r.conn.httpClient.post(context.Background(), message.FetchRequest_builder{
ConnectionId: r.conn.connectionId,
StatementId: r.statementID,
Offset: resultSet.offset + uint64(len(resultSet.data)),
FrameMaxSize: r.conn.config.frameMaxSize,
- })
+ }.Build())
if err != nil {
return r.conn.avaticaErrorToResponseErrorOrError(err)
}
- frame := res.(*message.FetchResponse).Frame
+ frame := res.(*message.FetchResponse).GetFrame()
var data [][]*message.TypedValue
// In some cases the server does not return done as true
// until it returns a result with no rows
- if len(frame.Rows) == 0 {
+ if len(frame.GetRows()) == 0 {
return io.EOF
}
- for _, row := range frame.Rows {
+ for _, row := range frame.GetRows() {
var rowData []*message.TypedValue
- for _, col := range row.Value {
- rowData = append(rowData, col.ScalarValue)
+ for _, col := range row.GetValue() {
+ rowData = append(rowData, col.GetScalarValue())
}
data = append(data, rowData)
}
- resultSet.done = frame.Done
+ resultSet.done = frame.GetDone()
resultSet.data = data
resultSet.currentRow = 0
- resultSet.offset = frame.Offset
+ resultSet.offset = frame.GetOffset()
}
@@ -149,26 +149,26 @@ func newRows(conn *conn, statementID uint32, closeStatement bool, resultSets []*
var rsets []*resultSet
for _, result := range resultSets {
- if result.Signature == nil {
+ if result.GetSignature() == nil {
break
}
var columns []*internal.Column
- for _, col := range result.Signature.Columns {
+ for _, col := range result.GetSignature().GetColumns() {
column := conn.adapter.GetColumnTypeDefinition(col)
columns = append(columns, column)
}
- frame := result.FirstFrame
+ frame := result.GetFirstFrame()
var data [][]*message.TypedValue
- for _, row := range frame.Rows {
+ for _, row := range frame.GetRows() {
var rowData []*message.TypedValue
- for _, col := range row.Value {
- rowData = append(rowData, col.ScalarValue)
+ for _, col := range row.GetValue() {
+ rowData = append(rowData, col.GetScalarValue())
}
data = append(data, rowData)
@@ -176,8 +176,8 @@ func newRows(conn *conn, statementID uint32, closeStatement bool, resultSets []*
rsets = append(rsets, &resultSet{
columns: columns,
- done: frame.Done,
- offset: frame.Offset,
+ done: frame.GetDone(),
+ offset: frame.GetOffset(),
data: data,
})
}
@@ -194,20 +194,20 @@ func newRows(conn *conn, statementID uint32, closeStatement bool, resultSets []*
// typedValueToNative converts values from avatica's types to Go's native types
func typedValueToNative(rep message.Rep, v *message.TypedValue, config *Config) interface{} {
- if v.Type == message.Rep_NULL {
+ if v.GetType() == message.Rep_NULL {
return nil
}
switch rep {
case message.Rep_BOOLEAN, message.Rep_PRIMITIVE_BOOLEAN:
- return v.BoolValue
+ return v.GetBoolValue()
case message.Rep_STRING, message.Rep_PRIMITIVE_CHAR, message.Rep_CHARACTER, message.Rep_BIG_DECIMAL:
- return v.StringValue
+ return v.GetStringValue()
case message.Rep_FLOAT, message.Rep_PRIMITIVE_FLOAT:
- return float32(v.DoubleValue)
+ return float32(v.GetDoubleValue())
case message.Rep_LONG,
message.Rep_PRIMITIVE_LONG,
@@ -219,13 +219,13 @@ func typedValueToNative(rep message.Rep, v *message.TypedValue, config *Config)
message.Rep_PRIMITIVE_BYTE,
message.Rep_SHORT,
message.Rep_PRIMITIVE_SHORT:
- return v.NumberValue
+ return v.GetNumberValue()
case message.Rep_BYTE_STRING:
- return v.BytesValue
+ return v.GetBytesValue()
case message.Rep_DOUBLE, message.Rep_PRIMITIVE_DOUBLE:
- return v.DoubleValue
+ return v.GetDoubleValue()
case message.Rep_JAVA_SQL_DATE, message.Rep_JAVA_UTIL_DATE:
@@ -234,7 +234,7 @@ func typedValueToNative(rep message.Rep, v *message.TypedValue, config *Config)
// we first do all our calculations in UTC and then force the timezone to
// the one the user has chosen.
t, _ := time.ParseInLocation("2006-Jan-02", "1970-Jan-01", time.UTC)
- days := time.Hour * 24 * time.Duration(v.NumberValue)
+ days := time.Hour * 24 * time.Duration(v.GetNumberValue())
t = t.Add(days)
return forceTimezone(t, config.location)
@@ -246,7 +246,7 @@ func typedValueToNative(rep message.Rep, v *message.TypedValue, config *Config)
// we first do all our calculations in UTC and then force the timezone to
// the one the user has chosen.
t, _ := time.ParseInLocation("15:04:05", "00:00:00", time.UTC)
- ms := time.Millisecond * time.Duration(v.NumberValue)
+ ms := time.Millisecond * time.Duration(v.GetNumberValue())
t = t.Add(ms)
return forceTimezone(t, config.location)
@@ -254,7 +254,7 @@ func typedValueToNative(rep message.Rep, v *message.TypedValue, config *Config)
// We receive the number of milliseconds since 1970-01-01 00:00:00.000 from the server
// Force to UTC for consistency because time.Unix uses the local timezone
- t := time.Unix(0, v.NumberValue*int64(time.Millisecond)).In(time.UTC)
+ t := time.Unix(0, v.GetNumberValue()*int64(time.Millisecond)).In(time.UTC)
return forceTimezone(t, config.location)
default:
diff --git a/statement.go b/statement.go
index 014b71a..c0ff133 100644
--- a/statement.go
+++ b/statement.go
@@ -45,20 +45,20 @@ func (s *stmt) Close() error {
}
if s.conn.config.batching {
- _, err := s.conn.httpClient.post(context.Background(), &message.ExecuteBatchRequest{
+ _, err := s.conn.httpClient.post(context.Background(), message.ExecuteBatchRequest_builder{
ConnectionId: s.conn.connectionId,
StatementId: s.statementID,
Updates: s.batchUpdates,
- })
+ }.Build())
if err != nil {
return s.conn.avaticaErrorToResponseErrorOrError(err)
}
}
- _, err := s.conn.httpClient.post(context.Background(), &message.CloseStatementRequest{
+ _, err := s.conn.httpClient.post(context.Background(), message.CloseStatementRequest_builder{
ConnectionId: s.conn.connectionId,
StatementId: s.statementID,
- })
+ }.Build())
if err != nil {
return s.conn.avaticaErrorToResponseErrorOrError(err)
@@ -99,25 +99,25 @@ func (s *stmt) exec(ctx context.Context, args []namedValue) (driver.Result, erro
s.Lock()
defer s.Unlock()
- s.batchUpdates = append(s.batchUpdates, &message.UpdateBatch{
+ s.batchUpdates = append(s.batchUpdates, message.UpdateBatch_builder{
ParameterValues: values,
- })
+ }.Build())
return &result{
affectedRows: -1,
}, nil
}
- msg := &message.ExecuteRequest{
+ msg := message.ExecuteRequest_builder{
StatementHandle: s.handle,
ParameterValues: values,
FirstFrameMaxSize: s.conn.config.frameMaxSize,
HasParameterValues: true,
- }
+ }.Build()
if s.conn.config.frameMaxSize <= -1 {
- msg.FirstFrameMaxSize = math.MaxInt32
+ msg.SetFirstFrameMaxSize(math.MaxInt32)
} else {
- msg.FirstFrameMaxSize = s.conn.config.frameMaxSize
+ msg.SetFirstFrameMaxSize(s.conn.config.frameMaxSize)
}
res, err := s.conn.httpClient.post(ctx, msg)
@@ -126,14 +126,14 @@ func (s *stmt) exec(ctx context.Context, args []namedValue) (driver.Result, erro
return nil, s.conn.avaticaErrorToResponseErrorOrError(err)
}
- results := res.(*message.ExecuteResponse).Results
+ results := res.(*message.ExecuteResponse).GetResults()
if len(results) <= 0 {
return nil, errors.New("empty ResultSet in ExecuteResponse")
}
// Currently there is only 1 ResultSet per response
- changed := int64(results[0].UpdateCount)
+ changed := int64(results[0].GetUpdateCount())
return &result{
affectedRows: changed,
@@ -152,17 +152,17 @@ func (s *stmt) query(ctx context.Context, args []namedValue) (driver.Rows, error
return nil, driver.ErrBadConn
}
- msg := &message.ExecuteRequest{
+ msg := message.ExecuteRequest_builder{
StatementHandle: s.handle,
ParameterValues: s.parametersToTypedValues(args),
FirstFrameMaxSize: s.conn.config.frameMaxSize,
HasParameterValues: true,
- }
+ }.Build()
if s.conn.config.frameMaxSize <= -1 {
- msg.FirstFrameMaxSize = math.MaxInt32
+ msg.SetFirstFrameMaxSize(math.MaxInt32)
} else {
- msg.FirstFrameMaxSize = s.conn.config.frameMaxSize
+ msg.SetFirstFrameMaxSize(s.conn.config.frameMaxSize)
}
res, err := s.conn.httpClient.post(ctx, msg)
@@ -171,7 +171,7 @@ func (s *stmt) query(ctx context.Context, args []namedValue) (driver.Rows, error
return nil, s.conn.avaticaErrorToResponseErrorOrError(err)
}
- resultSet := res.(*message.ExecuteResponse).Results
+ resultSet := res.(*message.ExecuteResponse).GetResults()
return newRows(s.conn, s.statementID, false, resultSet), nil
}
@@ -183,38 +183,38 @@ func (s *stmt) parametersToTypedValues(vals []namedValue) []*message.TypedValue
for i, val := range vals {
typed := message.TypedValue{}
if val.Value == nil {
- typed.Null = true
- typed.Type = message.Rep_NULL
+ typed.SetNull(true)
+ typed.SetType(message.Rep_NULL)
} else {
switch v := val.Value.(type) {
case int64:
- typed.Type = message.Rep_LONG
- typed.NumberValue = v
+ typed.SetType(message.Rep_LONG)
+ typed.SetNumberValue(v)
case float64:
- typed.Type = message.Rep_DOUBLE
- typed.DoubleValue = v
+ typed.SetType(message.Rep_DOUBLE)
+ typed.SetDoubleValue(v)
case bool:
- typed.Type = message.Rep_BOOLEAN
- typed.BoolValue = v
+ typed.SetType(message.Rep_BOOLEAN)
+ typed.SetBoolValue(v)
case []byte:
- typed.Type = message.Rep_BYTE_STRING
- typed.BytesValue = v
+ typed.SetType(message.Rep_BYTE_STRING)
+ typed.SetBytesValue(v)
case string:
- if s.parameters[i].TypeName == "DECIMAL" {
- typed.Type = message.Rep_BIG_DECIMAL
+ if s.parameters[i].GetTypeName() == "DECIMAL" {
+ typed.SetType(message.Rep_BIG_DECIMAL)
} else {
- typed.Type = message.Rep_STRING
+ typed.SetType(message.Rep_STRING)
}
- typed.StringValue = v
+ typed.SetStringValue(v)
case time.Time:
avaticaParameter := s.parameters[i]
- switch avaticaParameter.TypeName {
+ switch avaticaParameter.GetTypeName() {
case "TIME", "UNSIGNED_TIME":
- typed.Type = message.Rep_JAVA_SQL_TIME
+ typed.SetType(message.Rep_JAVA_SQL_TIME)
// Because a location can have multiple time zones due to daylight savings,
// we need to be explicit and get the offset
@@ -222,10 +222,10 @@ func (s *stmt) parametersToTypedValues(vals []namedValue) []*message.TypedValue
// Calculate milliseconds since 00:00:00.000
base := time.Date(v.Year(), v.Month(), v.Day(), 0, 0, 0, 0, time.FixedZone(zone, offset))
- typed.NumberValue = v.Sub(base).Nanoseconds() / int64(time.Millisecond)
+ typed.SetNumberValue(v.Sub(base).Nanoseconds() / int64(time.Millisecond))
case "DATE", "UNSIGNED_DATE":
- typed.Type = message.Rep_JAVA_SQL_DATE
+ typed.SetType(message.Rep_JAVA_SQL_DATE)
// Because a location can have multiple time zones due to daylight savings,
// we need to be explicit and get the offset
@@ -233,10 +233,10 @@ func (s *stmt) parametersToTypedValues(vals []namedValue) []*message.TypedValue
// Calculate number of days since 1970/1/1
base := time.Date(1970, 1, 1, 0, 0, 0, 0, time.FixedZone(zone, offset))
- typed.NumberValue = int64(v.Sub(base) / (24 * time.Hour))
+ typed.SetNumberValue(int64(v.Sub(base) / (24 * time.Hour)))
case "TIMESTAMP", "UNSIGNED_TIMESTAMP":
- typed.Type = message.Rep_JAVA_SQL_TIMESTAMP
+ typed.SetType(message.Rep_JAVA_SQL_TIMESTAMP)
// Because a location can have multiple time zones due to daylight savings,
// we need to be explicit and get the offset
@@ -244,7 +244,7 @@ func (s *stmt) parametersToTypedValues(vals []namedValue) []*message.TypedValue
// Calculate number of milliseconds since 1970-01-01 00:00:00.000
base := time.Date(1970, 1, 1, 0, 0, 0, 0, time.FixedZone(zone, offset))
- typed.NumberValue = v.Sub(base).Nanoseconds() / int64(time.Millisecond)
+ typed.SetNumberValue(v.Sub(base).Nanoseconds() / int64(time.Millisecond))
}
}
}
diff --git a/transaction.go b/transaction.go
index 58338cb..af13339 100644
--- a/transaction.go
+++ b/transaction.go
@@ -32,9 +32,9 @@ func (t *tx) Commit() error {
defer t.enableAutoCommit()
- _, err := t.conn.httpClient.post(context.Background(), &message.CommitRequest{
+ _, err := t.conn.httpClient.post(context.Background(), message.CommitRequest_builder{
ConnectionId: t.conn.connectionId,
- })
+ }.Build())
if err != nil {
return t.conn.avaticaErrorToResponseErrorOrError(err)
@@ -48,9 +48,9 @@ func (t *tx) Rollback() error {
defer t.enableAutoCommit()
- _, err := t.conn.httpClient.post(context.Background(), &message.RollbackRequest{
+ _, err := t.conn.httpClient.post(context.Background(), message.RollbackRequest_builder{
ConnectionId: t.conn.connectionId,
- })
+ }.Build())
if err != nil {
return t.conn.avaticaErrorToResponseErrorOrError(err)
@@ -62,14 +62,14 @@ func (t *tx) Rollback() error {
// enableAutoCommit enables auto-commit on the server
func (t *tx) enableAutoCommit() error {
- _, err := t.conn.httpClient.post(context.Background(), &message.ConnectionSyncRequest{
+ _, err := t.conn.httpClient.post(context.Background(), message.ConnectionSyncRequest_builder{
ConnectionId: t.conn.connectionId,
- ConnProps: &message.ConnectionProperties{
+ ConnProps: message.ConnectionProperties_builder{
AutoCommit: true,
HasAutoCommit: true,
TransactionIsolation: t.conn.config.transactionIsolation,
- },
- })
+ }.Build(),
+ }.Build())
if err != nil {
return t.conn.avaticaErrorToResponseErrorOrError(err)