This is an automated email from the ASF dual-hosted git repository.
tustvold pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
The following commit(s) were added to refs/heads/master by this push:
new cd45ecbfd Update prost and tonic related crates (#2268)
cd45ecbfd is described below
commit cd45ecbfd4dc87ee62b6b71a174bedbd282d0e4f
Author: Carol (Nichols || Goulding)
<[email protected]>
AuthorDate: Tue Aug 2 01:06:38 2022 -0400
Update prost and tonic related crates (#2268)
* Update prost requirement from 0.10 to 0.11
Updates the requirements on [prost](https://github.com/tokio-rs/prost) to
permit the latest version.
- [Release notes](https://github.com/tokio-rs/prost/releases)
- [Commits](https://github.com/tokio-rs/prost/compare/v0.10.0...v0.11.0)
---
updated-dependencies:
- dependency-name: prost
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Update tonic-build requirement from 0.7 to 0.8
Updates the requirements on
[tonic-build](https://github.com/hyperium/tonic) to permit the latest version.
- [Release notes](https://github.com/hyperium/tonic/releases)
- [Changelog](https://github.com/hyperium/tonic/blob/master/CHANGELOG.md)
- [Commits](https://github.com/hyperium/tonic/compare/v0.7.0...v0.8.0)
---
updated-dependencies:
- dependency-name: tonic-build
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Update tonic requirement from 0.7 to 0.8
Updates the requirements on [tonic](https://github.com/hyperium/tonic) to
permit the latest version.
- [Release notes](https://github.com/hyperium/tonic/releases)
- [Changelog](https://github.com/hyperium/tonic/blob/master/CHANGELOG.md)
- [Commits](https://github.com/hyperium/tonic/compare/v0.7.0...v0.8.0)
---
updated-dependencies:
- dependency-name: tonic
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Update prost-derive requirement from 0.10 to 0.11
Updates the requirements on
[prost-derive](https://github.com/tokio-rs/prost) to permit the latest version.
- [Release notes](https://github.com/tokio-rs/prost/releases)
- [Commits](https://github.com/tokio-rs/prost/compare/v0.10.0...v0.11.0)
---
updated-dependencies:
- dependency-name: prost-derive
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Update prost-types requirement from 0.10.0 to 0.11.0
Updates the requirements on
[prost-types](https://github.com/tokio-rs/prost) to permit the latest version.
- [Release notes](https://github.com/tokio-rs/prost/releases)
- [Commits](https://github.com/tokio-rs/prost/compare/v0.10.0...v0.11.0)
---
updated-dependencies:
- dependency-name: prost-types
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Update vendored tonic/prost generated code
* Install protoc in CI builds
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
---
.github/workflows/rust.yml | 8 +
arrow-flight/Cargo.toml | 10 +-
arrow-flight/src/arrow.flight.protocol.rs | 154 +-
arrow-flight/src/sql/arrow.flight.protocol.sql.rs | 1643 ++++++++++++---------
integration-testing/Cargo.toml | 4 +-
5 files changed, 1089 insertions(+), 730 deletions(-)
diff --git a/.github/workflows/rust.yml b/.github/workflows/rust.yml
index 8464a22b6..52b9cfd60 100644
--- a/.github/workflows/rust.yml
+++ b/.github/workflows/rust.yml
@@ -44,6 +44,10 @@ jobs:
run: |
rustup toolchain install ${{ matrix.rust }} --no-self-update
rustup default ${{ matrix.rust }}
+ - name: Install Protoc
+ uses: arduino/setup-protoc@v1
+ with:
+ repo-token: ${{ secrets.GITHUB_TOKEN }}
- name: Run tests
shell: bash
run: |
@@ -83,6 +87,10 @@ jobs:
run: |
rustup toolchain install ${{ matrix.rust }}
rustup default ${{ matrix.rust }}
+ - name: Install Protoc
+ uses: arduino/setup-protoc@v1
+ with:
+ repo-token: ${{ secrets.GITHUB_TOKEN }}
- name: Cache Cargo
uses: actions/cache@v3
with:
diff --git a/arrow-flight/Cargo.toml b/arrow-flight/Cargo.toml
index 1400d913e..73f297d01 100644
--- a/arrow-flight/Cargo.toml
+++ b/arrow-flight/Cargo.toml
@@ -29,11 +29,11 @@ license = "Apache-2.0"
[dependencies]
arrow = { path = "../arrow", version = "19.0.0", default-features = false,
features = ["ipc"] }
base64 = { version = "0.13", default-features = false }
-tonic = { version = "0.7", default-features = false, features = ["transport",
"codegen", "prost"] }
+tonic = { version = "0.8", default-features = false, features = ["transport",
"codegen", "prost"] }
bytes = { version = "1", default-features = false }
-prost = { version = "0.10", default-features = false }
-prost-types = { version = "0.10.0", default-features = false, optional = true }
-prost-derive = { version = "0.10", default-features = false }
+prost = { version = "0.11", default-features = false }
+prost-types = { version = "0.11.0", default-features = false, optional = true }
+prost-derive = { version = "0.11", default-features = false }
tokio = { version = "1.0", default-features = false, features = ["macros",
"rt", "rt-multi-thread"] }
futures = { version = "0.3", default-features = false, features = ["alloc"]}
@@ -44,7 +44,7 @@ flight-sql-experimental = ["prost-types"]
[dev-dependencies]
[build-dependencies]
-tonic-build = { version = "0.7", default-features = false, features =
["transport", "prost"] }
+tonic-build = { version = "0.8", default-features = false, features =
["transport", "prost"] }
# Pin specific version of the tonic-build dependencies to avoid auto-generated
# (and checked in) arrow.flight.protocol.rs from changing
proc-macro2 = { version = ">1.0.30", default-features = false }
diff --git a/arrow-flight/src/arrow.flight.protocol.rs
b/arrow-flight/src/arrow.flight.protocol.rs
index c76469b39..2b085d6d1 100644
--- a/arrow-flight/src/arrow.flight.protocol.rs
+++ b/arrow-flight/src/arrow.flight.protocol.rs
@@ -1,31 +1,31 @@
// This file was automatically generated through the build.rs script, and
should not be edited.
///
-/// The request that a client provides to a server on handshake.
+/// The request that a client provides to a server on handshake.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HandshakeRequest {
///
- /// A defined protocol version
+ /// A defined protocol version
#[prost(uint64, tag="1")]
pub protocol_version: u64,
///
- /// Arbitrary auth/handshake info.
+ /// Arbitrary auth/handshake info.
#[prost(bytes="vec", tag="2")]
pub payload: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HandshakeResponse {
///
- /// A defined protocol version
+ /// A defined protocol version
#[prost(uint64, tag="1")]
pub protocol_version: u64,
///
- /// Arbitrary auth/handshake info.
+ /// Arbitrary auth/handshake info.
#[prost(bytes="vec", tag="2")]
pub payload: ::prost::alloc::vec::Vec<u8>,
}
///
-/// A message for doing simple auth.
+/// A message for doing simple auth.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BasicAuth {
#[prost(string, tag="2")]
@@ -37,8 +37,8 @@ pub struct BasicAuth {
pub struct Empty {
}
///
-/// Describes an available action, including both the name used for execution
-/// along with a short description of the purpose of the action.
+/// Describes an available action, including both the name used for execution
+/// along with a short description of the purpose of the action.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ActionType {
#[prost(string, tag="1")]
@@ -47,15 +47,15 @@ pub struct ActionType {
pub description: ::prost::alloc::string::String,
}
///
-/// A service specific expression that can be used to return a limited set
-/// of available Arrow Flight streams.
+/// A service specific expression that can be used to return a limited set
+/// of available Arrow Flight streams.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Criteria {
#[prost(bytes="vec", tag="1")]
pub expression: ::prost::alloc::vec::Vec<u8>,
}
///
-/// An opaque action specific for the service.
+/// An opaque action specific for the service.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Action {
#[prost(string, tag="1")]
@@ -64,138 +64,151 @@ pub struct Action {
pub body: ::prost::alloc::vec::Vec<u8>,
}
///
-/// An opaque result returned after executing an action.
+/// An opaque result returned after executing an action.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Result {
#[prost(bytes="vec", tag="1")]
pub body: ::prost::alloc::vec::Vec<u8>,
}
///
-/// Wrap the result of a getSchema call
+/// Wrap the result of a getSchema call
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SchemaResult {
- /// schema of the dataset as described in Schema.fbs::Schema.
+ /// schema of the dataset as described in Schema.fbs::Schema.
#[prost(bytes="vec", tag="1")]
pub schema: ::prost::alloc::vec::Vec<u8>,
}
///
-/// The name or tag for a Flight. May be used as a way to retrieve or generate
-/// a flight or be used to expose a set of previously defined flights.
+/// The name or tag for a Flight. May be used as a way to retrieve or generate
+/// a flight or be used to expose a set of previously defined flights.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlightDescriptor {
#[prost(enumeration="flight_descriptor::DescriptorType", tag="1")]
pub r#type: i32,
///
- /// Opaque value used to express a command. Should only be defined when
- /// type = CMD.
+ /// Opaque value used to express a command. Should only be defined when
+ /// type = CMD.
#[prost(bytes="vec", tag="2")]
pub cmd: ::prost::alloc::vec::Vec<u8>,
///
- /// List of strings identifying a particular dataset. Should only be
defined
- /// when type = PATH.
+ /// List of strings identifying a particular dataset. Should only be
defined
+ /// when type = PATH.
#[prost(string, repeated, tag="3")]
pub path: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// Nested message and enum types in `FlightDescriptor`.
pub mod flight_descriptor {
///
- /// Describes what type of descriptor is defined.
+ /// Describes what type of descriptor is defined.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum DescriptorType {
- /// Protobuf pattern, not used.
+ /// Protobuf pattern, not used.
Unknown = 0,
///
- /// A named path that identifies a dataset. A path is composed of a
string
- /// or list of strings describing a particular dataset. This is
conceptually
- /// similar to a path inside a filesystem.
+ /// A named path that identifies a dataset. A path is composed of a
string
+ /// or list of strings describing a particular dataset. This is
conceptually
+ /// similar to a path inside a filesystem.
Path = 1,
///
- /// An opaque command to generate a dataset.
+ /// An opaque command to generate a dataset.
Cmd = 2,
}
+ impl DescriptorType {
+ /// String value of the enum field names used in the ProtoBuf
definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for
programmatic use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ DescriptorType::Unknown => "UNKNOWN",
+ DescriptorType::Path => "PATH",
+ DescriptorType::Cmd => "CMD",
+ }
+ }
+ }
}
///
-/// The access coordinates for retrieval of a dataset. With a FlightInfo, a
-/// consumer is able to determine how to retrieve a dataset.
+/// The access coordinates for retrieval of a dataset. With a FlightInfo, a
+/// consumer is able to determine how to retrieve a dataset.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlightInfo {
- /// schema of the dataset as described in Schema.fbs::Schema.
+ /// schema of the dataset as described in Schema.fbs::Schema.
#[prost(bytes="vec", tag="1")]
pub schema: ::prost::alloc::vec::Vec<u8>,
///
- /// The descriptor associated with this info.
+ /// The descriptor associated with this info.
#[prost(message, optional, tag="2")]
pub flight_descriptor: ::core::option::Option<FlightDescriptor>,
///
- /// A list of endpoints associated with the flight. To consume the whole
- /// flight, all endpoints must be consumed.
+ /// A list of endpoints associated with the flight. To consume the whole
+ /// flight, all endpoints must be consumed.
#[prost(message, repeated, tag="3")]
pub endpoint: ::prost::alloc::vec::Vec<FlightEndpoint>,
- /// Set these to -1 if unknown.
+ /// Set these to -1 if unknown.
#[prost(int64, tag="4")]
pub total_records: i64,
#[prost(int64, tag="5")]
pub total_bytes: i64,
}
///
-/// A particular stream or split associated with a flight.
+/// A particular stream or split associated with a flight.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlightEndpoint {
///
- /// Token used to retrieve this stream.
+ /// Token used to retrieve this stream.
#[prost(message, optional, tag="1")]
pub ticket: ::core::option::Option<Ticket>,
///
- /// A list of URIs where this ticket can be redeemed. If the list is
- /// empty, the expectation is that the ticket can only be redeemed on the
- /// current service where the ticket was generated.
+ /// A list of URIs where this ticket can be redeemed. If the list is
+ /// empty, the expectation is that the ticket can only be redeemed on the
+ /// current service where the ticket was generated.
#[prost(message, repeated, tag="2")]
pub location: ::prost::alloc::vec::Vec<Location>,
}
///
-/// A location where a Flight service will accept retrieval of a particular
-/// stream given a ticket.
+/// A location where a Flight service will accept retrieval of a particular
+/// stream given a ticket.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Location {
#[prost(string, tag="1")]
pub uri: ::prost::alloc::string::String,
}
///
-/// An opaque identifier that the service can use to retrieve a particular
-/// portion of a stream.
+/// An opaque identifier that the service can use to retrieve a particular
+/// portion of a stream.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Ticket {
#[prost(bytes="vec", tag="1")]
pub ticket: ::prost::alloc::vec::Vec<u8>,
}
///
-/// A batch of Arrow data as part of a stream of batches.
+/// A batch of Arrow data as part of a stream of batches.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlightData {
///
- /// The descriptor of the data. This is only relevant when a client is
- /// starting a new DoPut stream.
+ /// The descriptor of the data. This is only relevant when a client is
+ /// starting a new DoPut stream.
#[prost(message, optional, tag="1")]
pub flight_descriptor: ::core::option::Option<FlightDescriptor>,
///
- /// Header for message data as described in Message.fbs::Message.
+ /// Header for message data as described in Message.fbs::Message.
#[prost(bytes="vec", tag="2")]
pub data_header: ::prost::alloc::vec::Vec<u8>,
///
- /// Application-defined metadata.
+ /// Application-defined metadata.
#[prost(bytes="vec", tag="3")]
pub app_metadata: ::prost::alloc::vec::Vec<u8>,
///
- /// The actual batch of Arrow data. Preferably handled with minimal-copies
- /// coming last in the definition to help with sidecar patterns (it is
- /// expected that some implementations will fetch this field off the wire
- /// with specialized code to avoid extra memory copies).
+ /// The actual batch of Arrow data. Preferably handled with minimal-copies
+ /// coming last in the definition to help with sidecar patterns (it is
+ /// expected that some implementations will fetch this field off the wire
+ /// with specialized code to avoid extra memory copies).
#[prost(bytes="vec", tag="1000")]
pub data_body: ::prost::alloc::vec::Vec<u8>,
}
-///*
-/// The response message associated with the submission of a DoPut.
+/// *
+/// The response message associated with the submission of a DoPut.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PutResult {
#[prost(bytes="vec", tag="1")]
@@ -205,6 +218,7 @@ pub struct PutResult {
pub mod flight_service_client {
#![allow(unused_variables, dead_code, missing_docs,
clippy::let_unit_value)]
use tonic::codegen::*;
+ use tonic::codegen::http::Uri;
///
/// A flight service is an endpoint for retrieving or storing Arrow data. A
/// flight service can expose one or more predefined endpoints that can be
@@ -236,6 +250,10 @@ pub mod flight_service_client {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
+ pub fn with_origin(inner: T, origin: Uri) -> Self {
+ let inner = tonic::client::Grpc::with_origin(inner, origin);
+ Self { inner }
+ }
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
@@ -255,19 +273,19 @@ pub mod flight_service_client {
{
FlightServiceClient::new(InterceptedService::new(inner,
interceptor))
}
- /// Compress requests with `gzip`.
+ /// Compress requests with the given encoding.
///
/// This requires the server to support it otherwise it might respond
with an
/// error.
#[must_use]
- pub fn send_gzip(mut self) -> Self {
- self.inner = self.inner.send_gzip();
+ pub fn send_compressed(mut self, encoding: CompressionEncoding) ->
Self {
+ self.inner = self.inner.send_compressed(encoding);
self
}
- /// Enable decompressing responses with `gzip`.
+ /// Enable decompressing responses.
#[must_use]
- pub fn accept_gzip(mut self) -> Self {
- self.inner = self.inner.accept_gzip();
+ pub fn accept_compressed(mut self, encoding: CompressionEncoding) ->
Self {
+ self.inner = self.inner.accept_compressed(encoding);
self
}
///
@@ -672,8 +690,8 @@ pub mod flight_service_server {
#[derive(Debug)]
pub struct FlightServiceServer<T: FlightService> {
inner: _Inner<T>,
- accept_compression_encodings: (),
- send_compression_encodings: (),
+ accept_compression_encodings: EnabledCompressionEncodings,
+ send_compression_encodings: EnabledCompressionEncodings,
}
struct _Inner<T>(Arc<T>);
impl<T: FlightService> FlightServiceServer<T> {
@@ -697,6 +715,18 @@ pub mod flight_service_server {
{
InterceptedService::new(Self::new(inner), interceptor)
}
+ /// Enable decompressing requests with the given encoding.
+ #[must_use]
+ pub fn accept_compressed(mut self, encoding: CompressionEncoding) ->
Self {
+ self.accept_compression_encodings.enable(encoding);
+ self
+ }
+ /// Compress responses with the given encoding, if the client supports
it.
+ #[must_use]
+ pub fn send_compressed(mut self, encoding: CompressionEncoding) ->
Self {
+ self.send_compression_encodings.enable(encoding);
+ self
+ }
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for
FlightServiceServer<T>
where
@@ -1108,7 +1138,7 @@ pub mod flight_service_server {
write!(f, "{:?}", self.0)
}
}
- impl<T: FlightService> tonic::transport::NamedService for
FlightServiceServer<T> {
+ impl<T: FlightService> tonic::server::NamedService for
FlightServiceServer<T> {
const NAME: &'static str = "arrow.flight.protocol.FlightService";
}
}
diff --git a/arrow-flight/src/sql/arrow.flight.protocol.sql.rs
b/arrow-flight/src/sql/arrow.flight.protocol.sql.rs
index ea378a0a2..77221dd1a 100644
--- a/arrow-flight/src/sql/arrow.flight.protocol.sql.rs
+++ b/arrow-flight/src/sql/arrow.flight.protocol.sql.rs
@@ -1,1008 +1,1099 @@
// This file was automatically generated through the build.rs script, and
should not be edited.
///
-/// Represents a metadata request. Used in the command member of
FlightDescriptor
-/// for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the metadata request.
+/// Represents a metadata request. Used in the command member of
FlightDescriptor
+/// for the following RPC calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// info_name: uint32 not null,
-/// value: dense_union<
-/// string_value: utf8,
-/// bool_value: bool,
-/// bigint_value: int64,
-/// int32_bitmask: int32,
-/// string_list: list<string_data: utf8>
-/// int32_to_int32_list_map: map<key: int32, value: list<$data$:
int32>>
-/// >
-/// where there is one row per requested piece of metadata information.
+/// The returned Arrow schema will be:
+/// <
+/// info_name: uint32 not null,
+/// value: dense_union<
+/// string_value: utf8,
+/// bool_value: bool,
+/// bigint_value: int64,
+/// int32_bitmask: int32,
+/// string_list: list<string_data: utf8>
+/// int32_to_int32_list_map: map<key: int32, value: list<$data$:
int32>>
+/// >
+/// where there is one row per requested piece of metadata information.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetSqlInfo {
///
- /// Values are modelled after ODBC's SQLGetInfo() function. This
information is intended to provide
- /// Flight SQL clients with basic, SQL syntax and SQL functions related
information.
- /// More information types can be added in future releases.
- /// E.g. more SQL syntax support types, scalar functions support, type
conversion support etc.
+ /// Values are modelled after ODBC's SQLGetInfo() function. This
information is intended to provide
+ /// Flight SQL clients with basic, SQL syntax and SQL functions related
information.
+ /// More information types can be added in future releases.
+ /// E.g. more SQL syntax support types, scalar functions support, type
conversion support etc.
///
- /// Note that the set of metadata may expand.
+ /// Note that the set of metadata may expand.
///
- /// Initially, Flight SQL will support the following information types:
- /// - Server Information - Range [0-500)
- /// - Syntax Information - Range [500-1000)
- /// Range [0-10,000) is reserved for defaults (see SqlInfo enum for
default options).
- /// Custom options should start at 10,000.
+ /// Initially, Flight SQL will support the following information types:
+ /// - Server Information - Range [0-500)
+ /// - Syntax Information - Range [500-1000)
+ /// Range [0-10,000) is reserved for defaults (see SqlInfo enum for
default options).
+ /// Custom options should start at 10,000.
///
- /// If omitted, then all metadata will be retrieved.
- /// Flight SQL Servers may choose to include additional metadata above and
beyond the specified set, however they must
- /// at least return the specified set. IDs ranging from 0 to 10,000
(exclusive) are reserved for future use.
- /// If additional metadata is included, the metadata IDs should start from
10,000.
+ /// If omitted, then all metadata will be retrieved.
+ /// Flight SQL Servers may choose to include additional metadata above
and beyond the specified set, however they must
+ /// at least return the specified set. IDs ranging from 0 to 10,000
(exclusive) are reserved for future use.
+ /// If additional metadata is included, the metadata IDs should start
from 10,000.
#[prost(uint32, repeated, tag="1")]
pub info: ::prost::alloc::vec::Vec<u32>,
}
///
-/// Represents a request to retrieve the list of catalogs on a Flight SQL
enabled backend.
-/// The definition of a catalog depends on vendor/implementation. It is
usually the database itself
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the list of catalogs on a Flight SQL
enabled backend.
+/// The definition of a catalog depends on vendor/implementation. It is
usually the database itself
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// catalog_name: utf8 not null
-/// >
-/// The returned data should be ordered by catalog_name.
+/// The returned Arrow schema will be:
+/// <
+/// catalog_name: utf8 not null
+/// >
+/// The returned data should be ordered by catalog_name.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetCatalogs {
}
///
-/// Represents a request to retrieve the list of database schemas on a Flight
SQL enabled backend.
-/// The definition of a database schema depends on vendor/implementation. It
is usually a collection of tables.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the list of database schemas on a Flight
SQL enabled backend.
+/// The definition of a database schema depends on vendor/implementation. It
is usually a collection of tables.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// catalog_name: utf8,
-/// db_schema_name: utf8 not null
-/// >
-/// The returned data should be ordered by catalog_name, then db_schema_name.
+/// The returned Arrow schema will be:
+/// <
+/// catalog_name: utf8,
+/// db_schema_name: utf8 not null
+/// >
+/// The returned data should be ordered by catalog_name, then db_schema_name.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetDbSchemas {
///
- /// Specifies the Catalog to search for the tables.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// Specifies the Catalog to search for the tables.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub catalog: ::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies a filter pattern for schemas to search for.
- /// When no db_schema_filter_pattern is provided, the pattern will not be
used to narrow the search.
- /// In the pattern string, two special characters can be used to denote
matching rules:
- /// - "%" means to match any substring with 0 or more characters.
- /// - "_" means to match any one character.
+ /// Specifies a filter pattern for schemas to search for.
+ /// When no db_schema_filter_pattern is provided, the pattern will not be
used to narrow the search.
+ /// In the pattern string, two special characters can be used to denote
matching rules:
+ /// - "%" means to match any substring with 0 or more characters.
+ /// - "_" means to match any one character.
#[prost(string, optional, tag="2")]
pub db_schema_filter_pattern:
::core::option::Option<::prost::alloc::string::String>,
}
///
-/// Represents a request to retrieve the list of tables, and optionally their
schemas, on a Flight SQL enabled backend.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the list of tables, and optionally their
schemas, on a Flight SQL enabled backend.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// catalog_name: utf8,
-/// db_schema_name: utf8,
-/// table_name: utf8 not null,
-/// table_type: utf8 not null,
-/// \[optional\] table_schema: bytes not null (schema of the table as
described in Schema.fbs::Schema,
-/// it is serialized as an IPC
message.)
-/// >
-/// The returned data should be ordered by catalog_name, db_schema_name,
table_name, then table_type, followed by table_schema if requested.
+/// The returned Arrow schema will be:
+/// <
+/// catalog_name: utf8,
+/// db_schema_name: utf8,
+/// table_name: utf8 not null,
+/// table_type: utf8 not null,
+/// \[optional\] table_schema: bytes not null (schema of the table as
described in Schema.fbs::Schema,
+/// it is serialized as an IPC
message.)
+/// >
+/// The returned data should be ordered by catalog_name, db_schema_name,
table_name, then table_type, followed by table_schema if requested.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetTables {
///
- /// Specifies the Catalog to search for the tables.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// Specifies the Catalog to search for the tables.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub catalog: ::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies a filter pattern for schemas to search for.
- /// When no db_schema_filter_pattern is provided, all schemas matching
other filters are searched.
- /// In the pattern string, two special characters can be used to denote
matching rules:
- /// - "%" means to match any substring with 0 or more characters.
- /// - "_" means to match any one character.
+ /// Specifies a filter pattern for schemas to search for.
+ /// When no db_schema_filter_pattern is provided, all schemas matching
other filters are searched.
+ /// In the pattern string, two special characters can be used to denote
matching rules:
+ /// - "%" means to match any substring with 0 or more characters.
+ /// - "_" means to match any one character.
#[prost(string, optional, tag="2")]
pub db_schema_filter_pattern:
::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies a filter pattern for tables to search for.
- /// When no table_name_filter_pattern is provided, all tables matching
other filters are searched.
- /// In the pattern string, two special characters can be used to denote
matching rules:
- /// - "%" means to match any substring with 0 or more characters.
- /// - "_" means to match any one character.
+ /// Specifies a filter pattern for tables to search for.
+ /// When no table_name_filter_pattern is provided, all tables matching
other filters are searched.
+ /// In the pattern string, two special characters can be used to denote
matching rules:
+ /// - "%" means to match any substring with 0 or more characters.
+ /// - "_" means to match any one character.
#[prost(string, optional, tag="3")]
pub table_name_filter_pattern:
::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies a filter of table types which must match.
- /// The table types depend on vendor/implementation. It is usually used to
separate tables from views or system tables.
- /// TABLE, VIEW, and SYSTEM TABLE are commonly supported.
+ /// Specifies a filter of table types which must match.
+ /// The table types depend on vendor/implementation. It is usually used
to separate tables from views or system tables.
+ /// TABLE, VIEW, and SYSTEM TABLE are commonly supported.
#[prost(string, repeated, tag="4")]
pub table_types: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
- /// Specifies if the Arrow schema should be returned for found tables.
+ /// Specifies if the Arrow schema should be returned for found tables.
#[prost(bool, tag="5")]
pub include_schema: bool,
}
///
-/// Represents a request to retrieve the list of table types on a Flight SQL
enabled backend.
-/// The table types depend on vendor/implementation. It is usually used to
separate tables from views or system tables.
-/// TABLE, VIEW, and SYSTEM TABLE are commonly supported.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the list of table types on a Flight SQL
enabled backend.
+/// The table types depend on vendor/implementation. It is usually used to
separate tables from views or system tables.
+/// TABLE, VIEW, and SYSTEM TABLE are commonly supported.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// table_type: utf8 not null
-/// >
-/// The returned data should be ordered by table_type.
+/// The returned Arrow schema will be:
+/// <
+/// table_type: utf8 not null
+/// >
+/// The returned data should be ordered by table_type.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetTableTypes {
}
///
-/// Represents a request to retrieve the primary keys of a table on a Flight
SQL enabled backend.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the primary keys of a table on a Flight
SQL enabled backend.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// catalog_name: utf8,
-/// db_schema_name: utf8,
-/// table_name: utf8 not null,
-/// column_name: utf8 not null,
-/// key_name: utf8,
-/// key_sequence: int not null
-/// >
-/// The returned data should be ordered by catalog_name, db_schema_name,
table_name, key_name, then key_sequence.
+/// The returned Arrow schema will be:
+/// <
+/// catalog_name: utf8,
+/// db_schema_name: utf8,
+/// table_name: utf8 not null,
+/// column_name: utf8 not null,
+/// key_name: utf8,
+/// key_sequence: int not null
+/// >
+/// The returned data should be ordered by catalog_name, db_schema_name,
table_name, key_name, then key_sequence.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetPrimaryKeys {
///
- /// Specifies the catalog to search for the table.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// Specifies the catalog to search for the table.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub catalog: ::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies the schema to search for the table.
- /// An empty string retrieves those without a schema.
- /// If omitted the schema name should not be used to narrow the search.
+ /// Specifies the schema to search for the table.
+ /// An empty string retrieves those without a schema.
+ /// If omitted the schema name should not be used to narrow the search.
#[prost(string, optional, tag="2")]
pub db_schema: ::core::option::Option<::prost::alloc::string::String>,
- /// Specifies the table to get the primary keys for.
+ /// Specifies the table to get the primary keys for.
#[prost(string, tag="3")]
pub table: ::prost::alloc::string::String,
}
///
-/// Represents a request to retrieve a description of the foreign key columns
that reference the given table's
-/// primary key columns (the foreign keys exported by a table) of a table on a
Flight SQL enabled backend.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve a description of the foreign key columns
that reference the given table's
+/// primary key columns (the foreign keys exported by a table) of a table on
a Flight SQL enabled backend.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// pk_catalog_name: utf8,
-/// pk_db_schema_name: utf8,
-/// pk_table_name: utf8 not null,
-/// pk_column_name: utf8 not null,
-/// fk_catalog_name: utf8,
-/// fk_db_schema_name: utf8,
-/// fk_table_name: utf8 not null,
-/// fk_column_name: utf8 not null,
-/// key_sequence: int not null,
-/// fk_key_name: utf8,
-/// pk_key_name: utf8,
-/// update_rule: uint1 not null,
-/// delete_rule: uint1 not null
-/// >
-/// The returned data should be ordered by fk_catalog_name, fk_db_schema_name,
fk_table_name, fk_key_name, then key_sequence.
-/// update_rule and delete_rule returns a byte that is equivalent to actions
declared on UpdateDeleteRules enum.
+/// The returned Arrow schema will be:
+/// <
+/// pk_catalog_name: utf8,
+/// pk_db_schema_name: utf8,
+/// pk_table_name: utf8 not null,
+/// pk_column_name: utf8 not null,
+/// fk_catalog_name: utf8,
+/// fk_db_schema_name: utf8,
+/// fk_table_name: utf8 not null,
+/// fk_column_name: utf8 not null,
+/// key_sequence: int not null,
+/// fk_key_name: utf8,
+/// pk_key_name: utf8,
+/// update_rule: uint1 not null,
+/// delete_rule: uint1 not null
+/// >
+/// The returned data should be ordered by fk_catalog_name,
fk_db_schema_name, fk_table_name, fk_key_name, then key_sequence.
+/// update_rule and delete_rule returns a byte that is equivalent to actions
declared on UpdateDeleteRules enum.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetExportedKeys {
///
- /// Specifies the catalog to search for the foreign key table.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// Specifies the catalog to search for the foreign key table.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub catalog: ::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies the schema to search for the foreign key table.
- /// An empty string retrieves those without a schema.
- /// If omitted the schema name should not be used to narrow the search.
+ /// Specifies the schema to search for the foreign key table.
+ /// An empty string retrieves those without a schema.
+ /// If omitted the schema name should not be used to narrow the search.
#[prost(string, optional, tag="2")]
pub db_schema: ::core::option::Option<::prost::alloc::string::String>,
- /// Specifies the foreign key table to get the foreign keys for.
+ /// Specifies the foreign key table to get the foreign keys for.
#[prost(string, tag="3")]
pub table: ::prost::alloc::string::String,
}
///
-/// Represents a request to retrieve the foreign keys of a table on a Flight
SQL enabled backend.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve the foreign keys of a table on a Flight
SQL enabled backend.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// pk_catalog_name: utf8,
-/// pk_db_schema_name: utf8,
-/// pk_table_name: utf8 not null,
-/// pk_column_name: utf8 not null,
-/// fk_catalog_name: utf8,
-/// fk_db_schema_name: utf8,
-/// fk_table_name: utf8 not null,
-/// fk_column_name: utf8 not null,
-/// key_sequence: int not null,
-/// fk_key_name: utf8,
-/// pk_key_name: utf8,
-/// update_rule: uint1 not null,
-/// delete_rule: uint1 not null
-/// >
-/// The returned data should be ordered by pk_catalog_name, pk_db_schema_name,
pk_table_name, pk_key_name, then key_sequence.
-/// update_rule and delete_rule returns a byte that is equivalent to actions:
-/// - 0 = CASCADE
-/// - 1 = RESTRICT
-/// - 2 = SET NULL
-/// - 3 = NO ACTION
-/// - 4 = SET DEFAULT
+/// The returned Arrow schema will be:
+/// <
+/// pk_catalog_name: utf8,
+/// pk_db_schema_name: utf8,
+/// pk_table_name: utf8 not null,
+/// pk_column_name: utf8 not null,
+/// fk_catalog_name: utf8,
+/// fk_db_schema_name: utf8,
+/// fk_table_name: utf8 not null,
+/// fk_column_name: utf8 not null,
+/// key_sequence: int not null,
+/// fk_key_name: utf8,
+/// pk_key_name: utf8,
+/// update_rule: uint1 not null,
+/// delete_rule: uint1 not null
+/// >
+/// The returned data should be ordered by pk_catalog_name,
pk_db_schema_name, pk_table_name, pk_key_name, then key_sequence.
+/// update_rule and delete_rule returns a byte that is equivalent to actions:
+/// - 0 = CASCADE
+/// - 1 = RESTRICT
+/// - 2 = SET NULL
+/// - 3 = NO ACTION
+/// - 4 = SET DEFAULT
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetImportedKeys {
///
- /// Specifies the catalog to search for the primary key table.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// Specifies the catalog to search for the primary key table.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub catalog: ::core::option::Option<::prost::alloc::string::String>,
///
- /// Specifies the schema to search for the primary key table.
- /// An empty string retrieves those without a schema.
- /// If omitted the schema name should not be used to narrow the search.
+ /// Specifies the schema to search for the primary key table.
+ /// An empty string retrieves those without a schema.
+ /// If omitted the schema name should not be used to narrow the search.
#[prost(string, optional, tag="2")]
pub db_schema: ::core::option::Option<::prost::alloc::string::String>,
- /// Specifies the primary key table to get the foreign keys for.
+ /// Specifies the primary key table to get the foreign keys for.
#[prost(string, tag="3")]
pub table: ::prost::alloc::string::String,
}
///
-/// Represents a request to retrieve a description of the foreign key columns
in the given foreign key table that
-/// reference the primary key or the columns representing a unique constraint
of the parent table (could be the same
-/// or a different table) on a Flight SQL enabled backend.
-/// Used in the command member of FlightDescriptor for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the catalog metadata request.
+/// Represents a request to retrieve a description of the foreign key columns
in the given foreign key table that
+/// reference the primary key or the columns representing a unique constraint
of the parent table (could be the same
+/// or a different table) on a Flight SQL enabled backend.
+/// Used in the command member of FlightDescriptor for the following RPC
calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the catalog metadata request.
///
-/// The returned Arrow schema will be:
-/// <
-/// pk_catalog_name: utf8,
-/// pk_db_schema_name: utf8,
-/// pk_table_name: utf8 not null,
-/// pk_column_name: utf8 not null,
-/// fk_catalog_name: utf8,
-/// fk_db_schema_name: utf8,
-/// fk_table_name: utf8 not null,
-/// fk_column_name: utf8 not null,
-/// key_sequence: int not null,
-/// fk_key_name: utf8,
-/// pk_key_name: utf8,
-/// update_rule: uint1 not null,
-/// delete_rule: uint1 not null
-/// >
-/// The returned data should be ordered by pk_catalog_name, pk_db_schema_name,
pk_table_name, pk_key_name, then key_sequence.
-/// update_rule and delete_rule returns a byte that is equivalent to actions:
-/// - 0 = CASCADE
-/// - 1 = RESTRICT
-/// - 2 = SET NULL
-/// - 3 = NO ACTION
-/// - 4 = SET DEFAULT
+/// The returned Arrow schema will be:
+/// <
+/// pk_catalog_name: utf8,
+/// pk_db_schema_name: utf8,
+/// pk_table_name: utf8 not null,
+/// pk_column_name: utf8 not null,
+/// fk_catalog_name: utf8,
+/// fk_db_schema_name: utf8,
+/// fk_table_name: utf8 not null,
+/// fk_column_name: utf8 not null,
+/// key_sequence: int not null,
+/// fk_key_name: utf8,
+/// pk_key_name: utf8,
+/// update_rule: uint1 not null,
+/// delete_rule: uint1 not null
+/// >
+/// The returned data should be ordered by pk_catalog_name,
pk_db_schema_name, pk_table_name, pk_key_name, then key_sequence.
+/// update_rule and delete_rule returns a byte that is equivalent to actions:
+/// - 0 = CASCADE
+/// - 1 = RESTRICT
+/// - 2 = SET NULL
+/// - 3 = NO ACTION
+/// - 4 = SET DEFAULT
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandGetCrossReference {
- ///*
- /// The catalog name where the parent table is.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// *
+ /// The catalog name where the parent table is.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="1")]
pub pk_catalog: ::core::option::Option<::prost::alloc::string::String>,
- ///*
- /// The Schema name where the parent table is.
- /// An empty string retrieves those without a schema.
- /// If omitted the schema name should not be used to narrow the search.
+ /// *
+ /// The Schema name where the parent table is.
+ /// An empty string retrieves those without a schema.
+ /// If omitted the schema name should not be used to narrow the search.
#[prost(string, optional, tag="2")]
pub pk_db_schema: ::core::option::Option<::prost::alloc::string::String>,
- ///*
- /// The parent table name. It cannot be null.
+ /// *
+ /// The parent table name. It cannot be null.
#[prost(string, tag="3")]
pub pk_table: ::prost::alloc::string::String,
- ///*
- /// The catalog name where the foreign table is.
- /// An empty string retrieves those without a catalog.
- /// If omitted the catalog name should not be used to narrow the search.
+ /// *
+ /// The catalog name where the foreign table is.
+ /// An empty string retrieves those without a catalog.
+ /// If omitted the catalog name should not be used to narrow the search.
#[prost(string, optional, tag="4")]
pub fk_catalog: ::core::option::Option<::prost::alloc::string::String>,
- ///*
- /// The schema name where the foreign table is.
- /// An empty string retrieves those without a schema.
- /// If omitted the schema name should not be used to narrow the search.
+ /// *
+ /// The schema name where the foreign table is.
+ /// An empty string retrieves those without a schema.
+ /// If omitted the schema name should not be used to narrow the search.
#[prost(string, optional, tag="5")]
pub fk_db_schema: ::core::option::Option<::prost::alloc::string::String>,
- ///*
- /// The foreign table name. It cannot be null.
+ /// *
+ /// The foreign table name. It cannot be null.
#[prost(string, tag="6")]
pub fk_table: ::prost::alloc::string::String,
}
-// SQL Execution Action Messages
+// SQL Execution Action Messages
///
-/// Request message for the "CreatePreparedStatement" action on a Flight SQL
enabled backend.
+/// Request message for the "CreatePreparedStatement" action on a Flight SQL
enabled backend.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ActionCreatePreparedStatementRequest {
- /// The valid SQL string to create a prepared statement for.
+ /// The valid SQL string to create a prepared statement for.
#[prost(string, tag="1")]
pub query: ::prost::alloc::string::String,
}
///
-/// Wrap the result of a "GetPreparedStatement" action.
+/// Wrap the result of a "GetPreparedStatement" action.
///
-/// The resultant PreparedStatement can be closed either:
-/// - Manually, through the "ClosePreparedStatement" action;
-/// - Automatically, by a server timeout.
+/// The resultant PreparedStatement can be closed either:
+/// - Manually, through the "ClosePreparedStatement" action;
+/// - Automatically, by a server timeout.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ActionCreatePreparedStatementResult {
- /// Opaque handle for the prepared statement on the server.
+ /// Opaque handle for the prepared statement on the server.
#[prost(bytes="vec", tag="1")]
pub prepared_statement_handle: ::prost::alloc::vec::Vec<u8>,
- /// If a result set generating query was provided, dataset_schema contains
the
- /// schema of the dataset as described in Schema.fbs::Schema, it is
serialized as an IPC message.
+ /// If a result set generating query was provided, dataset_schema
contains the
+ /// schema of the dataset as described in Schema.fbs::Schema, it is
serialized as an IPC message.
#[prost(bytes="vec", tag="2")]
pub dataset_schema: ::prost::alloc::vec::Vec<u8>,
- /// If the query provided contained parameters, parameter_schema contains
the
- /// schema of the expected parameters as described in Schema.fbs::Schema,
it is serialized as an IPC message.
+ /// If the query provided contained parameters, parameter_schema contains
the
+ /// schema of the expected parameters as described in Schema.fbs::Schema,
it is serialized as an IPC message.
#[prost(bytes="vec", tag="3")]
pub parameter_schema: ::prost::alloc::vec::Vec<u8>,
}
///
-/// Request message for the "ClosePreparedStatement" action on a Flight SQL
enabled backend.
-/// Closes server resources associated with the prepared statement handle.
+/// Request message for the "ClosePreparedStatement" action on a Flight SQL
enabled backend.
+/// Closes server resources associated with the prepared statement handle.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ActionClosePreparedStatementRequest {
- /// Opaque handle for the prepared statement on the server.
+ /// Opaque handle for the prepared statement on the server.
#[prost(bytes="vec", tag="1")]
pub prepared_statement_handle: ::prost::alloc::vec::Vec<u8>,
}
-// SQL Execution Messages.
+// SQL Execution Messages.
///
-/// Represents a SQL query. Used in the command member of FlightDescriptor
-/// for the following RPC calls:
-/// - GetSchema: return the Arrow schema of the query.
-/// - GetFlightInfo: execute the query.
+/// Represents a SQL query. Used in the command member of FlightDescriptor
+/// for the following RPC calls:
+/// - GetSchema: return the Arrow schema of the query.
+/// - GetFlightInfo: execute the query.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandStatementQuery {
- /// The SQL syntax.
+ /// The SQL syntax.
#[prost(string, tag="1")]
pub query: ::prost::alloc::string::String,
}
-///*
-/// Represents a ticket resulting from GetFlightInfo with a
CommandStatementQuery.
-/// This should be used only once and treated as an opaque value, that is,
clients should not attempt to parse this.
+/// *
+/// Represents a ticket resulting from GetFlightInfo with a
CommandStatementQuery.
+/// This should be used only once and treated as an opaque value, that is,
clients should not attempt to parse this.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TicketStatementQuery {
- /// Unique identifier for the instance of the statement to execute.
+ /// Unique identifier for the instance of the statement to execute.
#[prost(bytes="vec", tag="1")]
pub statement_handle: ::prost::alloc::vec::Vec<u8>,
}
///
-/// Represents an instance of executing a prepared statement. Used in the
command member of FlightDescriptor for
-/// the following RPC calls:
-/// - DoPut: bind parameter values. All of the bound parameter sets will be
executed as a single atomic execution.
-/// - GetFlightInfo: execute the prepared statement instance.
+/// Represents an instance of executing a prepared statement. Used in the
command member of FlightDescriptor for
+/// the following RPC calls:
+/// - DoPut: bind parameter values. All of the bound parameter sets will be
executed as a single atomic execution.
+/// - GetFlightInfo: execute the prepared statement instance.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandPreparedStatementQuery {
- /// Opaque handle for the prepared statement on the server.
+ /// Opaque handle for the prepared statement on the server.
#[prost(bytes="vec", tag="1")]
pub prepared_statement_handle: ::prost::alloc::vec::Vec<u8>,
}
///
-/// Represents a SQL update query. Used in the command member of
FlightDescriptor
-/// for the the RPC call DoPut to cause the server to execute the included SQL
update.
+/// Represents a SQL update query. Used in the command member of
FlightDescriptor
+/// for the the RPC call DoPut to cause the server to execute the included
SQL update.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandStatementUpdate {
- /// The SQL syntax.
+ /// The SQL syntax.
#[prost(string, tag="1")]
pub query: ::prost::alloc::string::String,
}
///
-/// Represents a SQL update query. Used in the command member of
FlightDescriptor
-/// for the the RPC call DoPut to cause the server to execute the included
-/// prepared statement handle as an update.
+/// Represents a SQL update query. Used in the command member of
FlightDescriptor
+/// for the the RPC call DoPut to cause the server to execute the included
+/// prepared statement handle as an update.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommandPreparedStatementUpdate {
- /// Opaque handle for the prepared statement on the server.
+ /// Opaque handle for the prepared statement on the server.
#[prost(bytes="vec", tag="1")]
pub prepared_statement_handle: ::prost::alloc::vec::Vec<u8>,
}
///
-/// Returned from the RPC call DoPut when a CommandStatementUpdate
-/// CommandPreparedStatementUpdate was in the request, containing
-/// results from the update.
+/// Returned from the RPC call DoPut when a CommandStatementUpdate
+/// CommandPreparedStatementUpdate was in the request, containing
+/// results from the update.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DoPutUpdateResult {
- /// The number of records updated. A return value of -1 represents
- /// an unknown updated record count.
+ /// The number of records updated. A return value of -1 represents
+ /// an unknown updated record count.
#[prost(int64, tag="1")]
pub record_count: i64,
}
-/// Options for CommandGetSqlInfo.
+/// Options for CommandGetSqlInfo.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlInfo {
- // Server Information [0-500): Provides basic information about the Flight
SQL Server.
+ // Server Information [0-500): Provides basic information about the
Flight SQL Server.
- /// Retrieves a UTF-8 string with the name of the Flight SQL Server.
+ /// Retrieves a UTF-8 string with the name of the Flight SQL Server.
FlightSqlServerName = 0,
- /// Retrieves a UTF-8 string with the native version of the Flight SQL
Server.
+ /// Retrieves a UTF-8 string with the native version of the Flight SQL
Server.
FlightSqlServerVersion = 1,
- /// Retrieves a UTF-8 string with the Arrow format version of the Flight
SQL Server.
+ /// Retrieves a UTF-8 string with the Arrow format version of the Flight
SQL Server.
FlightSqlServerArrowVersion = 2,
- ///
- /// Retrieves a boolean value indicating whether the Flight SQL Server is
read only.
+ ///
+ /// Retrieves a boolean value indicating whether the Flight SQL Server is
read only.
///
- /// Returns:
- /// - false: if read-write
- /// - true: if read only
+ /// Returns:
+ /// - false: if read-write
+ /// - true: if read only
FlightSqlServerReadOnly = 3,
- // SQL Syntax Information [500-1000): provides information about SQL
syntax supported by the Flight SQL Server.
+ // SQL Syntax Information [500-1000): provides information about SQL
syntax supported by the Flight SQL Server.
///
- /// Retrieves a boolean value indicating whether the Flight SQL Server
supports CREATE and DROP of catalogs.
+ /// Retrieves a boolean value indicating whether the Flight SQL Server
supports CREATE and DROP of catalogs.
///
- /// Returns:
- /// - false: if it doesn't support CREATE and DROP of catalogs.
- /// - true: if it supports CREATE and DROP of catalogs.
+ /// Returns:
+ /// - false: if it doesn't support CREATE and DROP of catalogs.
+ /// - true: if it supports CREATE and DROP of catalogs.
SqlDdlCatalog = 500,
///
- /// Retrieves a boolean value indicating whether the Flight SQL Server
supports CREATE and DROP of schemas.
+ /// Retrieves a boolean value indicating whether the Flight SQL Server
supports CREATE and DROP of schemas.
///
- /// Returns:
- /// - false: if it doesn't support CREATE and DROP of schemas.
- /// - true: if it supports CREATE and DROP of schemas.
+ /// Returns:
+ /// - false: if it doesn't support CREATE and DROP of schemas.
+ /// - true: if it supports CREATE and DROP of schemas.
SqlDdlSchema = 501,
///
- /// Indicates whether the Flight SQL Server supports CREATE and DROP of
tables.
+ /// Indicates whether the Flight SQL Server supports CREATE and DROP of
tables.
///
- /// Returns:
- /// - false: if it doesn't support CREATE and DROP of tables.
- /// - true: if it supports CREATE and DROP of tables.
+ /// Returns:
+ /// - false: if it doesn't support CREATE and DROP of tables.
+ /// - true: if it supports CREATE and DROP of tables.
SqlDdlTable = 502,
///
- /// Retrieves a uint32 value representing the enu uint32 ordinal for the
case sensitivity of catalog, table, schema and table names.
+ /// Retrieves a uint32 value representing the enu uint32 ordinal for the
case sensitivity of catalog, table, schema and table names.
///
- /// The possible values are listed in
`arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
+ /// The possible values are listed in
`arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
SqlIdentifierCase = 503,
- /// Retrieves a UTF-8 string with the supported character(s) used to
surround a delimited identifier.
+ /// Retrieves a UTF-8 string with the supported character(s) used to
surround a delimited identifier.
SqlIdentifierQuoteChar = 504,
///
- /// Retrieves a uint32 value representing the enu uint32 ordinal for the
case sensitivity of quoted identifiers.
+ /// Retrieves a uint32 value representing the enu uint32 ordinal for the
case sensitivity of quoted identifiers.
///
- /// The possible values are listed in
`arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
+ /// The possible values are listed in
`arrow.flight.protocol.sql.SqlSupportedCaseSensitivity`.
SqlQuotedIdentifierCase = 505,
///
- /// Retrieves a boolean value indicating whether all tables are selectable.
+ /// Retrieves a boolean value indicating whether all tables are
selectable.
///
- /// Returns:
- /// - false: if not all tables are selectable or if none are;
- /// - true: if all tables are selectable.
+ /// Returns:
+ /// - false: if not all tables are selectable or if none are;
+ /// - true: if all tables are selectable.
SqlAllTablesAreSelectable = 506,
///
- /// Retrieves the null ordering.
+ /// Retrieves the null ordering.
///
- /// Returns a uint32 ordinal for the null ordering being used, as
described in
- /// `arrow.flight.protocol.sql.SqlNullOrdering`.
+ /// Returns a uint32 ordinal for the null ordering being used, as
described in
+ /// `arrow.flight.protocol.sql.SqlNullOrdering`.
SqlNullOrdering = 507,
- /// Retrieves a UTF-8 string list with values of the supported keywords.
+ /// Retrieves a UTF-8 string list with values of the supported keywords.
SqlKeywords = 508,
- /// Retrieves a UTF-8 string list with values of the supported numeric
functions.
+ /// Retrieves a UTF-8 string list with values of the supported numeric
functions.
SqlNumericFunctions = 509,
- /// Retrieves a UTF-8 string list with values of the supported string
functions.
+ /// Retrieves a UTF-8 string list with values of the supported string
functions.
SqlStringFunctions = 510,
- /// Retrieves a UTF-8 string list with values of the supported system
functions.
+ /// Retrieves a UTF-8 string list with values of the supported system
functions.
SqlSystemFunctions = 511,
- /// Retrieves a UTF-8 string list with values of the supported datetime
functions.
+ /// Retrieves a UTF-8 string list with values of the supported datetime
functions.
SqlDatetimeFunctions = 512,
///
- /// Retrieves the UTF-8 string that can be used to escape wildcard
characters.
- /// This is the string that can be used to escape '_' or '%' in the
catalog search parameters that are a pattern
- /// (and therefore use one of the wildcard characters).
- /// The '_' character represents any single character; the '%' character
represents any sequence of zero or more
- /// characters.
+ /// Retrieves the UTF-8 string that can be used to escape wildcard
characters.
+ /// This is the string that can be used to escape '_' or '%' in the
catalog search parameters that are a pattern
+ /// (and therefore use one of the wildcard characters).
+ /// The '_' character represents any single character; the '%' character
represents any sequence of zero or more
+ /// characters.
SqlSearchStringEscape = 513,
///
- /// Retrieves a UTF-8 string with all the "extra" characters that can be
used in unquoted identifier names
- /// (those beyond a-z, A-Z, 0-9 and _).
+ /// Retrieves a UTF-8 string with all the "extra" characters that can be
used in unquoted identifier names
+ /// (those beyond a-z, A-Z, 0-9 and _).
SqlExtraNameCharacters = 514,
///
- /// Retrieves a boolean value indicating whether column aliasing is
supported.
- /// If so, the SQL AS clause can be used to provide names for computed
columns or to provide alias names for columns
- /// as required.
+ /// Retrieves a boolean value indicating whether column aliasing is
supported.
+ /// If so, the SQL AS clause can be used to provide names for computed
columns or to provide alias names for columns
+ /// as required.
///
- /// Returns:
- /// - false: if column aliasing is unsupported;
- /// - true: if column aliasing is supported.
+ /// Returns:
+ /// - false: if column aliasing is unsupported;
+ /// - true: if column aliasing is supported.
SqlSupportsColumnAliasing = 515,
///
- /// Retrieves a boolean value indicating whether concatenations between
null and non-null values being
- /// null are supported.
+ /// Retrieves a boolean value indicating whether concatenations between
null and non-null values being
+ /// null are supported.
///
- /// - Returns:
- /// - false: if concatenations between null and non-null values being null
are unsupported;
- /// - true: if concatenations between null and non-null values being null
are supported.
+ /// - Returns:
+ /// - false: if concatenations between null and non-null values being
null are unsupported;
+ /// - true: if concatenations between null and non-null values being null
are supported.
SqlNullPlusNullIsNull = 516,
///
- /// Retrieves a map where the key is the type to convert from and the
value is a list with the types to convert to,
- /// indicating the supported conversions. Each key and each item on the
list value is a value to a predefined type on
- /// SqlSupportsConvert enum.
- /// The returned map will be: map<int32, list<int32>>
+ /// Retrieves a map where the key is the type to convert from and the
value is a list with the types to convert to,
+ /// indicating the supported conversions. Each key and each item on the
list value is a value to a predefined type on
+ /// SqlSupportsConvert enum.
+ /// The returned map will be: map<int32, list<int32>>
SqlSupportsConvert = 517,
///
- /// Retrieves a boolean value indicating whether, when table correlation
names are supported,
- /// they are restricted to being different from the names of the tables.
+ /// Retrieves a boolean value indicating whether, when table correlation
names are supported,
+ /// they are restricted to being different from the names of the tables.
///
- /// Returns:
- /// - false: if table correlation names are unsupported;
- /// - true: if table correlation names are supported.
+ /// Returns:
+ /// - false: if table correlation names are unsupported;
+ /// - true: if table correlation names are supported.
SqlSupportsTableCorrelationNames = 518,
///
- /// Retrieves a boolean value indicating whether, when table correlation
names are supported,
- /// they are restricted to being different from the names of the tables.
+ /// Retrieves a boolean value indicating whether, when table correlation
names are supported,
+ /// they are restricted to being different from the names of the tables.
///
- /// Returns:
- /// - false: if different table correlation names are unsupported;
- /// - true: if different table correlation names are supported
+ /// Returns:
+ /// - false: if different table correlation names are unsupported;
+ /// - true: if different table correlation names are supported
SqlSupportsDifferentTableCorrelationNames = 519,
///
- /// Retrieves a boolean value indicating whether expressions in ORDER BY
lists are supported.
+ /// Retrieves a boolean value indicating whether expressions in ORDER BY
lists are supported.
///
- /// Returns:
- /// - false: if expressions in ORDER BY are unsupported;
- /// - true: if expressions in ORDER BY are supported;
+ /// Returns:
+ /// - false: if expressions in ORDER BY are unsupported;
+ /// - true: if expressions in ORDER BY are supported;
SqlSupportsExpressionsInOrderBy = 520,
///
- /// Retrieves a boolean value indicating whether using a column that is
not in the SELECT statement in a GROUP BY
- /// clause is supported.
+ /// Retrieves a boolean value indicating whether using a column that is
not in the SELECT statement in a GROUP BY
+ /// clause is supported.
///
- /// Returns:
- /// - false: if using a column that is not in the SELECT statement in a
GROUP BY clause is unsupported;
- /// - true: if using a column that is not in the SELECT statement in a
GROUP BY clause is supported.
+ /// Returns:
+ /// - false: if using a column that is not in the SELECT statement in a
GROUP BY clause is unsupported;
+ /// - true: if using a column that is not in the SELECT statement in a
GROUP BY clause is supported.
SqlSupportsOrderByUnrelated = 521,
///
- /// Retrieves the supported GROUP BY commands;
+ /// Retrieves the supported GROUP BY commands;
///
- /// Returns an int32 bitmask value representing the supported commands.
- /// The returned bitmask should be parsed in order to retrieve the
supported commands.
+ /// Returns an int32 bitmask value representing the supported commands.
+ /// The returned bitmask should be parsed in order to retrieve the
supported commands.
///
- /// For instance:
- /// - return 0 (\b0) => [] (GROUP BY is unsupported);
- /// - return 1 (\b1) => \[SQL_GROUP_BY_UNRELATED\];
- /// - return 2 (\b10) => \[SQL_GROUP_BY_BEYOND_SELECT\];
- /// - return 3 (\b11) => [SQL_GROUP_BY_UNRELATED,
SQL_GROUP_BY_BEYOND_SELECT].
- /// Valid GROUP BY types are described under
`arrow.flight.protocol.sql.SqlSupportedGroupBy`.
+ /// For instance:
+ /// - return 0 (\b0) => [] (GROUP BY is unsupported);
+ /// - return 1 (\b1) => \[SQL_GROUP_BY_UNRELATED\];
+ /// - return 2 (\b10) => \[SQL_GROUP_BY_BEYOND_SELECT\];
+ /// - return 3 (\b11) => [SQL_GROUP_BY_UNRELATED,
SQL_GROUP_BY_BEYOND_SELECT].
+ /// Valid GROUP BY types are described under
`arrow.flight.protocol.sql.SqlSupportedGroupBy`.
SqlSupportedGroupBy = 522,
///
- /// Retrieves a boolean value indicating whether specifying a LIKE escape
clause is supported.
+ /// Retrieves a boolean value indicating whether specifying a LIKE escape
clause is supported.
///
- /// Returns:
- /// - false: if specifying a LIKE escape clause is unsupported;
- /// - true: if specifying a LIKE escape clause is supported.
+ /// Returns:
+ /// - false: if specifying a LIKE escape clause is unsupported;
+ /// - true: if specifying a LIKE escape clause is supported.
SqlSupportsLikeEscapeClause = 523,
///
- /// Retrieves a boolean value indicating whether columns may be defined as
non-nullable.
+ /// Retrieves a boolean value indicating whether columns may be defined
as non-nullable.
///
- /// Returns:
- /// - false: if columns cannot be defined as non-nullable;
- /// - true: if columns may be defined as non-nullable.
+ /// Returns:
+ /// - false: if columns cannot be defined as non-nullable;
+ /// - true: if columns may be defined as non-nullable.
SqlSupportsNonNullableColumns = 524,
///
- /// Retrieves the supported SQL grammar level as per the ODBC
specification.
- ///
- /// Returns an int32 bitmask value representing the supported SQL grammar
level.
- /// The returned bitmask should be parsed in order to retrieve the
supported grammar levels.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (SQL grammar is unsupported);
- /// - return 1 (\b1) => \[SQL_MINIMUM_GRAMMAR\];
- /// - return 2 (\b10) => \[SQL_CORE_GRAMMAR\];
- /// - return 3 (\b11) => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR];
- /// - return 4 (\b100) => \[SQL_EXTENDED_GRAMMAR\];
- /// - return 5 (\b101) => [SQL_MINIMUM_GRAMMAR, SQL_EXTENDED_GRAMMAR];
- /// - return 6 (\b110) => [SQL_CORE_GRAMMAR, SQL_EXTENDED_GRAMMAR];
- /// - return 7 (\b111) => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR,
SQL_EXTENDED_GRAMMAR].
- /// Valid SQL grammar levels are described under
`arrow.flight.protocol.sql.SupportedSqlGrammar`.
+ /// Retrieves the supported SQL grammar level as per the ODBC
specification.
+ ///
+ /// Returns an int32 bitmask value representing the supported SQL grammar
level.
+ /// The returned bitmask should be parsed in order to retrieve the
supported grammar levels.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (SQL grammar is unsupported);
+ /// - return 1 (\b1) => \[SQL_MINIMUM_GRAMMAR\];
+ /// - return 2 (\b10) => \[SQL_CORE_GRAMMAR\];
+ /// - return 3 (\b11) => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR];
+ /// - return 4 (\b100) => \[SQL_EXTENDED_GRAMMAR\];
+ /// - return 5 (\b101) => [SQL_MINIMUM_GRAMMAR, SQL_EXTENDED_GRAMMAR];
+ /// - return 6 (\b110) => [SQL_CORE_GRAMMAR, SQL_EXTENDED_GRAMMAR];
+ /// - return 7 (\b111) => [SQL_MINIMUM_GRAMMAR, SQL_CORE_GRAMMAR,
SQL_EXTENDED_GRAMMAR].
+ /// Valid SQL grammar levels are described under
`arrow.flight.protocol.sql.SupportedSqlGrammar`.
SqlSupportedGrammar = 525,
///
- /// Retrieves the supported ANSI92 SQL grammar level.
- ///
- /// Returns an int32 bitmask value representing the supported ANSI92 SQL
grammar level.
- /// The returned bitmask should be parsed in order to retrieve the
supported commands.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (ANSI92 SQL grammar is unsupported);
- /// - return 1 (\b1) => \[ANSI92_ENTRY_SQL\];
- /// - return 2 (\b10) => \[ANSI92_INTERMEDIATE_SQL\];
- /// - return 3 (\b11) => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL];
- /// - return 4 (\b100) => \[ANSI92_FULL_SQL\];
- /// - return 5 (\b101) => [ANSI92_ENTRY_SQL, ANSI92_FULL_SQL];
- /// - return 6 (\b110) => [ANSI92_INTERMEDIATE_SQL, ANSI92_FULL_SQL];
- /// - return 7 (\b111) => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL,
ANSI92_FULL_SQL].
- /// Valid ANSI92 SQL grammar levels are described under
`arrow.flight.protocol.sql.SupportedAnsi92SqlGrammarLevel`.
+ /// Retrieves the supported ANSI92 SQL grammar level.
+ ///
+ /// Returns an int32 bitmask value representing the supported ANSI92 SQL
grammar level.
+ /// The returned bitmask should be parsed in order to retrieve the
supported commands.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (ANSI92 SQL grammar is unsupported);
+ /// - return 1 (\b1) => \[ANSI92_ENTRY_SQL\];
+ /// - return 2 (\b10) => \[ANSI92_INTERMEDIATE_SQL\];
+ /// - return 3 (\b11) => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL];
+ /// - return 4 (\b100) => \[ANSI92_FULL_SQL\];
+ /// - return 5 (\b101) => [ANSI92_ENTRY_SQL, ANSI92_FULL_SQL];
+ /// - return 6 (\b110) => [ANSI92_INTERMEDIATE_SQL, ANSI92_FULL_SQL];
+ /// - return 7 (\b111) => [ANSI92_ENTRY_SQL, ANSI92_INTERMEDIATE_SQL,
ANSI92_FULL_SQL].
+ /// Valid ANSI92 SQL grammar levels are described under
`arrow.flight.protocol.sql.SupportedAnsi92SqlGrammarLevel`.
SqlAnsi92SupportedLevel = 526,
///
- /// Retrieves a boolean value indicating whether the SQL Integrity
Enhancement Facility is supported.
+ /// Retrieves a boolean value indicating whether the SQL Integrity
Enhancement Facility is supported.
///
- /// Returns:
- /// - false: if the SQL Integrity Enhancement Facility is supported;
- /// - true: if the SQL Integrity Enhancement Facility is supported.
+ /// Returns:
+ /// - false: if the SQL Integrity Enhancement Facility is supported;
+ /// - true: if the SQL Integrity Enhancement Facility is supported.
SqlSupportsIntegrityEnhancementFacility = 527,
///
- /// Retrieves the support level for SQL OUTER JOINs.
+ /// Retrieves the support level for SQL OUTER JOINs.
///
- /// Returns a uint3 uint32 ordinal for the SQL ordering being used, as
described in
- /// `arrow.flight.protocol.sql.SqlOuterJoinsSupportLevel`.
+ /// Returns a uint3 uint32 ordinal for the SQL ordering being used, as
described in
+ /// `arrow.flight.protocol.sql.SqlOuterJoinsSupportLevel`.
SqlOuterJoinsSupportLevel = 528,
- /// Retrieves a UTF-8 string with the preferred term for "schema".
+ /// Retrieves a UTF-8 string with the preferred term for "schema".
SqlSchemaTerm = 529,
- /// Retrieves a UTF-8 string with the preferred term for "procedure".
+ /// Retrieves a UTF-8 string with the preferred term for "procedure".
SqlProcedureTerm = 530,
- /// Retrieves a UTF-8 string with the preferred term for "catalog".
+ /// Retrieves a UTF-8 string with the preferred term for "catalog".
SqlCatalogTerm = 531,
///
- /// Retrieves a boolean value indicating whether a catalog appears at the
start of a fully qualified table name.
+ /// Retrieves a boolean value indicating whether a catalog appears at the
start of a fully qualified table name.
///
- /// - false: if a catalog does not appear at the start of a fully
qualified table name;
- /// - true: if a catalog appears at the start of a fully qualified table
name.
+ /// - false: if a catalog does not appear at the start of a fully
qualified table name;
+ /// - true: if a catalog appears at the start of a fully qualified table
name.
SqlCatalogAtStart = 532,
///
- /// Retrieves the supported actions for a SQL schema.
- ///
- /// Returns an int32 bitmask value representing the supported actions for
a SQL schema.
- /// The returned bitmask should be parsed in order to retrieve the
supported actions for a SQL schema.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported actions for SQL schema);
- /// - return 1 (\b1) => \[SQL_ELEMENT_IN_PROCEDURE_CALLS\];
- /// - return 2 (\b10) => \[SQL_ELEMENT_IN_INDEX_DEFINITIONS\];
- /// - return 3 (\b11) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS];
- /// - return 4 (\b100) => \[SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS\];
- /// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
- /// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
- /// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
- /// Valid actions for a SQL schema described under
`arrow.flight.protocol.sql.SqlSupportedElementActions`.
+ /// Retrieves the supported actions for a SQL schema.
+ ///
+ /// Returns an int32 bitmask value representing the supported actions for
a SQL schema.
+ /// The returned bitmask should be parsed in order to retrieve the
supported actions for a SQL schema.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported actions for SQL schema);
+ /// - return 1 (\b1) => \[SQL_ELEMENT_IN_PROCEDURE_CALLS\];
+ /// - return 2 (\b10) => \[SQL_ELEMENT_IN_INDEX_DEFINITIONS\];
+ /// - return 3 (\b11) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS];
+ /// - return 4 (\b100) => \[SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS\];
+ /// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
+ /// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
+ /// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
+ /// Valid actions for a SQL schema described under
`arrow.flight.protocol.sql.SqlSupportedElementActions`.
SqlSchemasSupportedActions = 533,
///
- /// Retrieves the supported actions for a SQL schema.
- ///
- /// Returns an int32 bitmask value representing the supported actions for
a SQL catalog.
- /// The returned bitmask should be parsed in order to retrieve the
supported actions for a SQL catalog.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported actions for SQL catalog);
- /// - return 1 (\b1) => \[SQL_ELEMENT_IN_PROCEDURE_CALLS\];
- /// - return 2 (\b10) => \[SQL_ELEMENT_IN_INDEX_DEFINITIONS\];
- /// - return 3 (\b11) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS];
- /// - return 4 (\b100) => \[SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS\];
- /// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
- /// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
- /// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
- /// Valid actions for a SQL catalog are described under
`arrow.flight.protocol.sql.SqlSupportedElementActions`.
+ /// Retrieves the supported actions for a SQL schema.
+ ///
+ /// Returns an int32 bitmask value representing the supported actions for
a SQL catalog.
+ /// The returned bitmask should be parsed in order to retrieve the
supported actions for a SQL catalog.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported actions for SQL catalog);
+ /// - return 1 (\b1) => \[SQL_ELEMENT_IN_PROCEDURE_CALLS\];
+ /// - return 2 (\b10) => \[SQL_ELEMENT_IN_INDEX_DEFINITIONS\];
+ /// - return 3 (\b11) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS];
+ /// - return 4 (\b100) => \[SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS\];
+ /// - return 5 (\b101) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
+ /// - return 6 (\b110) => [SQL_ELEMENT_IN_INDEX_DEFINITIONS,
SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS];
+ /// - return 7 (\b111) => [SQL_ELEMENT_IN_PROCEDURE_CALLS,
SQL_ELEMENT_IN_INDEX_DEFINITIONS, SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS].
+ /// Valid actions for a SQL catalog are described under
`arrow.flight.protocol.sql.SqlSupportedElementActions`.
SqlCatalogsSupportedActions = 534,
///
- /// Retrieves the supported SQL positioned commands.
+ /// Retrieves the supported SQL positioned commands.
///
- /// Returns an int32 bitmask value representing the supported SQL
positioned commands.
- /// The returned bitmask should be parsed in order to retrieve the
supported SQL positioned commands.
+ /// Returns an int32 bitmask value representing the supported SQL
positioned commands.
+ /// The returned bitmask should be parsed in order to retrieve the
supported SQL positioned commands.
///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported SQL positioned commands);
- /// - return 1 (\b1) => \[SQL_POSITIONED_DELETE\];
- /// - return 2 (\b10) => \[SQL_POSITIONED_UPDATE\];
- /// - return 3 (\b11) => [SQL_POSITIONED_DELETE, SQL_POSITIONED_UPDATE].
- /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlSupportedPositionedCommands`.
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported SQL positioned commands);
+ /// - return 1 (\b1) => \[SQL_POSITIONED_DELETE\];
+ /// - return 2 (\b10) => \[SQL_POSITIONED_UPDATE\];
+ /// - return 3 (\b11) => [SQL_POSITIONED_DELETE, SQL_POSITIONED_UPDATE].
+ /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlSupportedPositionedCommands`.
SqlSupportedPositionedCommands = 535,
///
- /// Retrieves a boolean value indicating whether SELECT FOR UPDATE
statements are supported.
+ /// Retrieves a boolean value indicating whether SELECT FOR UPDATE
statements are supported.
///
- /// Returns:
- /// - false: if SELECT FOR UPDATE statements are unsupported;
- /// - true: if SELECT FOR UPDATE statements are supported.
+ /// Returns:
+ /// - false: if SELECT FOR UPDATE statements are unsupported;
+ /// - true: if SELECT FOR UPDATE statements are supported.
SqlSelectForUpdateSupported = 536,
///
- /// Retrieves a boolean value indicating whether stored procedure calls
that use the stored procedure escape syntax
- /// are supported.
+ /// Retrieves a boolean value indicating whether stored procedure calls
that use the stored procedure escape syntax
+ /// are supported.
///
- /// Returns:
- /// - false: if stored procedure calls that use the stored procedure
escape syntax are unsupported;
- /// - true: if stored procedure calls that use the stored procedure escape
syntax are supported.
+ /// Returns:
+ /// - false: if stored procedure calls that use the stored procedure
escape syntax are unsupported;
+ /// - true: if stored procedure calls that use the stored procedure
escape syntax are supported.
SqlStoredProceduresSupported = 537,
///
- /// Retrieves the supported SQL subqueries.
- ///
- /// Returns an int32 bitmask value representing the supported SQL
subqueries.
- /// The returned bitmask should be parsed in order to retrieve the
supported SQL subqueries.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported SQL subqueries);
- /// - return 1 (\b1) => \[SQL_SUBQUERIES_IN_COMPARISONS\];
- /// - return 2 (\b10) => \[SQL_SUBQUERIES_IN_EXISTS\];
- /// - return 3 (\b11) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS];
- /// - return 4 (\b100) => \[SQL_SUBQUERIES_IN_INS\];
- /// - return 5 (\b101) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_INS];
- /// - return 6 (\b110) => [SQL_SUBQUERIES_IN_INS,
SQL_SUBQUERIES_IN_EXISTS];
- /// - return 7 (\b111) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS];
- /// - return 8 (\b1000) => \[SQL_SUBQUERIES_IN_QUANTIFIEDS\];
- /// - return 9 (\b1001) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 10 (\b1010) => [SQL_SUBQUERIES_IN_EXISTS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 11 (\b1011) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 12 (\b1100) => [SQL_SUBQUERIES_IN_INS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 13 (\b1101) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 14 (\b1110) => [SQL_SUBQUERIES_IN_EXISTS,
SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - return 15 (\b1111) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
- /// - ...
- /// Valid SQL subqueries are described under
`arrow.flight.protocol.sql.SqlSupportedSubqueries`.
+ /// Retrieves the supported SQL subqueries.
+ ///
+ /// Returns an int32 bitmask value representing the supported SQL
subqueries.
+ /// The returned bitmask should be parsed in order to retrieve the
supported SQL subqueries.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported SQL subqueries);
+ /// - return 1 (\b1) => \[SQL_SUBQUERIES_IN_COMPARISONS\];
+ /// - return 2 (\b10) => \[SQL_SUBQUERIES_IN_EXISTS\];
+ /// - return 3 (\b11) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS];
+ /// - return 4 (\b100) => \[SQL_SUBQUERIES_IN_INS\];
+ /// - return 5 (\b101) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_INS];
+ /// - return 6 (\b110) => [SQL_SUBQUERIES_IN_INS,
SQL_SUBQUERIES_IN_EXISTS];
+ /// - return 7 (\b111) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS];
+ /// - return 8 (\b1000) => \[SQL_SUBQUERIES_IN_QUANTIFIEDS\];
+ /// - return 9 (\b1001) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 10 (\b1010) => [SQL_SUBQUERIES_IN_EXISTS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 11 (\b1011) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 12 (\b1100) => [SQL_SUBQUERIES_IN_INS,
SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 13 (\b1101) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 14 (\b1110) => [SQL_SUBQUERIES_IN_EXISTS,
SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - return 15 (\b1111) => [SQL_SUBQUERIES_IN_COMPARISONS,
SQL_SUBQUERIES_IN_EXISTS, SQL_SUBQUERIES_IN_INS, SQL_SUBQUERIES_IN_QUANTIFIEDS];
+ /// - ...
+ /// Valid SQL subqueries are described under
`arrow.flight.protocol.sql.SqlSupportedSubqueries`.
SqlSupportedSubqueries = 538,
///
- /// Retrieves a boolean value indicating whether correlated subqueries are
supported.
+ /// Retrieves a boolean value indicating whether correlated subqueries
are supported.
///
- /// Returns:
- /// - false: if correlated subqueries are unsupported;
- /// - true: if correlated subqueries are supported.
+ /// Returns:
+ /// - false: if correlated subqueries are unsupported;
+ /// - true: if correlated subqueries are supported.
SqlCorrelatedSubqueriesSupported = 539,
///
- /// Retrieves the supported SQL UNIONs.
+ /// Retrieves the supported SQL UNIONs.
///
- /// Returns an int32 bitmask value representing the supported SQL UNIONs.
- /// The returned bitmask should be parsed in order to retrieve the
supported SQL UNIONs.
+ /// Returns an int32 bitmask value representing the supported SQL UNIONs.
+ /// The returned bitmask should be parsed in order to retrieve the
supported SQL UNIONs.
///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported SQL positioned commands);
- /// - return 1 (\b1) => \[SQL_UNION\];
- /// - return 2 (\b10) => \[SQL_UNION_ALL\];
- /// - return 3 (\b11) => [SQL_UNION, SQL_UNION_ALL].
- /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlSupportedUnions`.
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported SQL positioned commands);
+ /// - return 1 (\b1) => \[SQL_UNION\];
+ /// - return 2 (\b10) => \[SQL_UNION_ALL\];
+ /// - return 3 (\b11) => [SQL_UNION, SQL_UNION_ALL].
+ /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlSupportedUnions`.
SqlSupportedUnions = 540,
- /// Retrieves a uint32 value representing the maximum number of hex
characters allowed in an inline binary literal.
+ /// Retrieves a uint32 value representing the maximum number of hex
characters allowed in an inline binary literal.
SqlMaxBinaryLiteralLength = 541,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed for a character literal.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed for a character literal.
SqlMaxCharLiteralLength = 542,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed for a column name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed for a column name.
SqlMaxColumnNameLength = 543,
- /// Retrieves a uint32 value representing the the maximum number of
columns allowed in a GROUP BY clause.
+ /// Retrieves a uint32 value representing the the maximum number of
columns allowed in a GROUP BY clause.
SqlMaxColumnsInGroupBy = 544,
- /// Retrieves a uint32 value representing the maximum number of columns
allowed in an index.
+ /// Retrieves a uint32 value representing the maximum number of columns
allowed in an index.
SqlMaxColumnsInIndex = 545,
- /// Retrieves a uint32 value representing the maximum number of columns
allowed in an ORDER BY clause.
+ /// Retrieves a uint32 value representing the maximum number of columns
allowed in an ORDER BY clause.
SqlMaxColumnsInOrderBy = 546,
- /// Retrieves a uint32 value representing the maximum number of columns
allowed in a SELECT list.
+ /// Retrieves a uint32 value representing the maximum number of columns
allowed in a SELECT list.
SqlMaxColumnsInSelect = 547,
- /// Retrieves a uint32 value representing the maximum number of columns
allowed in a table.
+ /// Retrieves a uint32 value representing the maximum number of columns
allowed in a table.
SqlMaxColumnsInTable = 548,
- /// Retrieves a uint32 value representing the maximum number of concurrent
connections possible.
+ /// Retrieves a uint32 value representing the maximum number of
concurrent connections possible.
SqlMaxConnections = 549,
- /// Retrieves a uint32 value the maximum number of characters allowed in a
cursor name.
+ /// Retrieves a uint32 value the maximum number of characters allowed in
a cursor name.
SqlMaxCursorNameLength = 550,
///
- /// Retrieves a uint32 value representing the maximum number of bytes
allowed for an index,
- /// including all of the parts of the index.
+ /// Retrieves a uint32 value representing the maximum number of bytes
allowed for an index,
+ /// including all of the parts of the index.
SqlMaxIndexLength = 551,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed in a schema name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed in a schema name.
SqlDbSchemaNameLength = 552,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed in a procedure name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed in a procedure name.
SqlMaxProcedureNameLength = 553,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed in a catalog name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed in a catalog name.
SqlMaxCatalogNameLength = 554,
- /// Retrieves a uint32 value representing the maximum number of bytes
allowed in a single row.
+ /// Retrieves a uint32 value representing the maximum number of bytes
allowed in a single row.
SqlMaxRowSize = 555,
///
- /// Retrieves a boolean indicating whether the return value for the JDBC
method getMaxRowSize includes the SQL
- /// data types LONGVARCHAR and LONGVARBINARY.
+ /// Retrieves a boolean indicating whether the return value for the JDBC
method getMaxRowSize includes the SQL
+ /// data types LONGVARCHAR and LONGVARBINARY.
///
- /// Returns:
- /// - false: if return value for the JDBC method getMaxRowSize does
- /// not include the SQL data types LONGVARCHAR and LONGVARBINARY;
- /// - true: if return value for the JDBC method getMaxRowSize includes
- /// the SQL data types LONGVARCHAR and LONGVARBINARY.
+ /// Returns:
+ /// - false: if return value for the JDBC method getMaxRowSize does
+ /// not include the SQL data types LONGVARCHAR and LONGVARBINARY;
+ /// - true: if return value for the JDBC method getMaxRowSize includes
+ /// the SQL data types LONGVARCHAR and LONGVARBINARY.
SqlMaxRowSizeIncludesBlobs = 556,
///
- /// Retrieves a uint32 value representing the maximum number of characters
allowed for an SQL statement;
- /// a result of 0 (zero) means that there is no limit or the limit is not
known.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed for an SQL statement;
+ /// a result of 0 (zero) means that there is no limit or the limit is not
known.
SqlMaxStatementLength = 557,
- /// Retrieves a uint32 value representing the maximum number of active
statements that can be open at the same time.
+ /// Retrieves a uint32 value representing the maximum number of active
statements that can be open at the same time.
SqlMaxStatements = 558,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed in a table name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed in a table name.
SqlMaxTableNameLength = 559,
- /// Retrieves a uint32 value representing the maximum number of tables
allowed in a SELECT statement.
+ /// Retrieves a uint32 value representing the maximum number of tables
allowed in a SELECT statement.
SqlMaxTablesInSelect = 560,
- /// Retrieves a uint32 value representing the maximum number of characters
allowed in a user name.
+ /// Retrieves a uint32 value representing the maximum number of
characters allowed in a user name.
SqlMaxUsernameLength = 561,
///
- /// Retrieves this database's default transaction isolation level as
described in
- /// `arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
+ /// Retrieves this database's default transaction isolation level as
described in
+ /// `arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
///
- /// Returns a uint32 ordinal for the SQL transaction isolation level.
+ /// Returns a uint32 ordinal for the SQL transaction isolation level.
SqlDefaultTransactionIsolation = 562,
///
- /// Retrieves a boolean value indicating whether transactions are
supported. If not, invoking the method commit is a
- /// noop, and the isolation level is
`arrow.flight.protocol.sql.SqlTransactionIsolationLevel.TRANSACTION_NONE`.
+ /// Retrieves a boolean value indicating whether transactions are
supported. If not, invoking the method commit is a
+ /// noop, and the isolation level is
`arrow.flight.protocol.sql.SqlTransactionIsolationLevel.TRANSACTION_NONE`.
///
- /// Returns:
- /// - false: if transactions are unsupported;
- /// - true: if transactions are supported.
+ /// Returns:
+ /// - false: if transactions are unsupported;
+ /// - true: if transactions are supported.
SqlTransactionsSupported = 563,
///
- /// Retrieves the supported transactions isolation levels.
- ///
- /// Returns an int32 bitmask value representing the supported transactions
isolation levels.
- /// The returned bitmask should be parsed in order to retrieve the
supported transactions isolation levels.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported SQL transactions isolation
levels);
- /// - return 1 (\b1) => \[SQL_TRANSACTION_NONE\];
- /// - return 2 (\b10) => \[SQL_TRANSACTION_READ_UNCOMMITTED\];
- /// - return 3 (\b11) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED];
- /// - return 4 (\b100) => \[SQL_TRANSACTION_REPEATABLE_READ\];
- /// - return 5 (\b101) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 6 (\b110) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 7 (\b111) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 8 (\b1000) => \[SQL_TRANSACTION_REPEATABLE_READ\];
- /// - return 9 (\b1001) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 10 (\b1010) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 11 (\b1011) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 12 (\b1100) => [SQL_TRANSACTION_REPEATABLE_READ,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 13 (\b1101) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 14 (\b1110) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 15 (\b1111) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ,
SQL_TRANSACTION_REPEATABLE_READ];
- /// - return 16 (\b10000) => \[SQL_TRANSACTION_SERIALIZABLE\];
- /// - ...
- /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
+ /// Retrieves the supported transactions isolation levels.
+ ///
+ /// Returns an int32 bitmask value representing the supported
transactions isolation levels.
+ /// The returned bitmask should be parsed in order to retrieve the
supported transactions isolation levels.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported SQL transactions isolation
levels);
+ /// - return 1 (\b1) => \[SQL_TRANSACTION_NONE\];
+ /// - return 2 (\b10) => \[SQL_TRANSACTION_READ_UNCOMMITTED\];
+ /// - return 3 (\b11) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED];
+ /// - return 4 (\b100) => \[SQL_TRANSACTION_REPEATABLE_READ\];
+ /// - return 5 (\b101) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 6 (\b110) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 7 (\b111) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 8 (\b1000) => \[SQL_TRANSACTION_REPEATABLE_READ\];
+ /// - return 9 (\b1001) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 10 (\b1010) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 11 (\b1011) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 12 (\b1100) => [SQL_TRANSACTION_REPEATABLE_READ,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 13 (\b1101) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 14 (\b1110) => [SQL_TRANSACTION_READ_UNCOMMITTED,
SQL_TRANSACTION_REPEATABLE_READ, SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 15 (\b1111) => [SQL_TRANSACTION_NONE,
SQL_TRANSACTION_READ_UNCOMMITTED, SQL_TRANSACTION_REPEATABLE_READ,
SQL_TRANSACTION_REPEATABLE_READ];
+ /// - return 16 (\b10000) => \[SQL_TRANSACTION_SERIALIZABLE\];
+ /// - ...
+ /// Valid SQL positioned commands are described under
`arrow.flight.protocol.sql.SqlTransactionIsolationLevel`.
SqlSupportedTransactionsIsolationLevels = 564,
///
- /// Retrieves a boolean value indicating whether a data definition
statement within a transaction forces
- /// the transaction to commit.
+ /// Retrieves a boolean value indicating whether a data definition
statement within a transaction forces
+ /// the transaction to commit.
///
- /// Returns:
- /// - false: if a data definition statement within a transaction does not
force the transaction to commit;
- /// - true: if a data definition statement within a transaction forces the
transaction to commit.
+ /// Returns:
+ /// - false: if a data definition statement within a transaction does not
force the transaction to commit;
+ /// - true: if a data definition statement within a transaction forces
the transaction to commit.
SqlDataDefinitionCausesTransactionCommit = 565,
///
- /// Retrieves a boolean value indicating whether a data definition
statement within a transaction is ignored.
+ /// Retrieves a boolean value indicating whether a data definition
statement within a transaction is ignored.
///
- /// Returns:
- /// - false: if a data definition statement within a transaction is taken
into account;
- /// - true: a data definition statement within a transaction is ignored.
+ /// Returns:
+ /// - false: if a data definition statement within a transaction is taken
into account;
+ /// - true: a data definition statement within a transaction is ignored.
SqlDataDefinitionsInTransactionsIgnored = 566,
///
- /// Retrieves an int32 bitmask value representing the supported result set
types.
- /// The returned bitmask should be parsed in order to retrieve the
supported result set types.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported result set types);
- /// - return 1 (\b1) => \[SQL_RESULT_SET_TYPE_UNSPECIFIED\];
- /// - return 2 (\b10) => \[SQL_RESULT_SET_TYPE_FORWARD_ONLY\];
- /// - return 3 (\b11) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_FORWARD_ONLY];
- /// - return 4 (\b100) => \[SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE\];
- /// - return 5 (\b101) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
- /// - return 6 (\b110) => [SQL_RESULT_SET_TYPE_FORWARD_ONLY,
SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
- /// - return 7 (\b111) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_FORWARD_ONLY, SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
- /// - return 8 (\b1000) => \[SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE\];
- /// - ...
- /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetType`.
+ /// Retrieves an int32 bitmask value representing the supported result
set types.
+ /// The returned bitmask should be parsed in order to retrieve the
supported result set types.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported result set types);
+ /// - return 1 (\b1) => \[SQL_RESULT_SET_TYPE_UNSPECIFIED\];
+ /// - return 2 (\b10) => \[SQL_RESULT_SET_TYPE_FORWARD_ONLY\];
+ /// - return 3 (\b11) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_FORWARD_ONLY];
+ /// - return 4 (\b100) => \[SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE\];
+ /// - return 5 (\b101) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
+ /// - return 6 (\b110) => [SQL_RESULT_SET_TYPE_FORWARD_ONLY,
SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
+ /// - return 7 (\b111) => [SQL_RESULT_SET_TYPE_UNSPECIFIED,
SQL_RESULT_SET_TYPE_FORWARD_ONLY, SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE];
+ /// - return 8 (\b1000) => \[SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE\];
+ /// - ...
+ /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetType`.
SqlSupportedResultSetTypes = 567,
///
- /// Returns an int32 bitmask value concurrency types supported for
- ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_UNSPECIFIED`.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
- /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
- /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
- /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
- /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
- /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
+ /// Returns an int32 bitmask value concurrency types supported for
+ ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_UNSPECIFIED`.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
+ /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
+ /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
+ /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
+ /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
+ /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
SqlSupportedConcurrenciesForResultSetUnspecified = 568,
///
- /// Returns an int32 bitmask value concurrency types supported for
- ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_FORWARD_ONLY`.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
- /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
- /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
- /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
- /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
- /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
+ /// Returns an int32 bitmask value concurrency types supported for
+ ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_FORWARD_ONLY`.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
+ /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
+ /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
+ /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
+ /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
+ /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
SqlSupportedConcurrenciesForResultSetForwardOnly = 569,
///
- /// Returns an int32 bitmask value concurrency types supported for
- ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE`.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
- /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
- /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
- /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
- /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
- /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
+ /// Returns an int32 bitmask value concurrency types supported for
+ ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE`.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
+ /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
+ /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
+ /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
+ /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
+ /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
SqlSupportedConcurrenciesForResultSetScrollSensitive = 570,
///
- /// Returns an int32 bitmask value concurrency types supported for
- ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE`.
- ///
- /// For instance:
- /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
- /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
- /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
- /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
- /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
- /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
- /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
+ /// Returns an int32 bitmask value concurrency types supported for
+ ///
`arrow.flight.protocol.sql.SqlSupportedResultSetType.SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE`.
+ ///
+ /// For instance:
+ /// - return 0 (\b0) => [] (no supported concurrency types for this
result set type)
+ /// - return 1 (\b1) => \[SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED\]
+ /// - return 2 (\b10) => \[SQL_RESULT_SET_CONCURRENCY_READ_ONLY\]
+ /// - return 3 (\b11) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY]
+ /// - return 4 (\b100) => \[SQL_RESULT_SET_CONCURRENCY_UPDATABLE\]
+ /// - return 5 (\b101) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 6 (\b110) => [SQL_RESULT_SET_CONCURRENCY_READ_ONLY,
SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// - return 7 (\b111) => [SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED,
SQL_RESULT_SET_CONCURRENCY_READ_ONLY, SQL_RESULT_SET_CONCURRENCY_UPDATABLE]
+ /// Valid result set types are described under
`arrow.flight.protocol.sql.SqlSupportedResultSetConcurrency`.
SqlSupportedConcurrenciesForResultSetScrollInsensitive = 571,
///
- /// Retrieves a boolean value indicating whether this database supports
batch updates.
+ /// Retrieves a boolean value indicating whether this database supports
batch updates.
///
- /// - false: if this database does not support batch updates;
- /// - true: if this database supports batch updates.
+ /// - false: if this database does not support batch updates;
+ /// - true: if this database supports batch updates.
SqlBatchUpdatesSupported = 572,
///
- /// Retrieves a boolean value indicating whether this database supports
savepoints.
+ /// Retrieves a boolean value indicating whether this database supports
savepoints.
///
- /// Returns:
- /// - false: if this database does not support savepoints;
- /// - true: if this database supports savepoints.
+ /// Returns:
+ /// - false: if this database does not support savepoints;
+ /// - true: if this database supports savepoints.
SqlSavepointsSupported = 573,
///
- /// Retrieves a boolean value indicating whether named parameters are
supported in callable statements.
+ /// Retrieves a boolean value indicating whether named parameters are
supported in callable statements.
///
- /// Returns:
- /// - false: if named parameters in callable statements are unsupported;
- /// - true: if named parameters in callable statements are supported.
+ /// Returns:
+ /// - false: if named parameters in callable statements are unsupported;
+ /// - true: if named parameters in callable statements are supported.
SqlNamedParametersSupported = 574,
///
- /// Retrieves a boolean value indicating whether updates made to a LOB are
made on a copy or directly to the LOB.
+ /// Retrieves a boolean value indicating whether updates made to a LOB
are made on a copy or directly to the LOB.
///
- /// Returns:
- /// - false: if updates made to a LOB are made directly to the LOB;
- /// - true: if updates made to a LOB are made on a copy.
+ /// Returns:
+ /// - false: if updates made to a LOB are made directly to the LOB;
+ /// - true: if updates made to a LOB are made on a copy.
SqlLocatorsUpdateCopy = 575,
///
- /// Retrieves a boolean value indicating whether invoking user-defined or
vendor functions
- /// using the stored procedure escape syntax is supported.
+ /// Retrieves a boolean value indicating whether invoking user-defined or
vendor functions
+ /// using the stored procedure escape syntax is supported.
///
- /// Returns:
- /// - false: if invoking user-defined or vendor functions using the stored
procedure escape syntax is unsupported;
- /// - true: if invoking user-defined or vendor functions using the stored
procedure escape syntax is supported.
+ /// Returns:
+ /// - false: if invoking user-defined or vendor functions using the
stored procedure escape syntax is unsupported;
+ /// - true: if invoking user-defined or vendor functions using the stored
procedure escape syntax is supported.
SqlStoredFunctionsUsingCallSyntaxSupported = 576,
}
+impl SqlInfo {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlInfo::FlightSqlServerName => "FLIGHT_SQL_SERVER_NAME",
+ SqlInfo::FlightSqlServerVersion => "FLIGHT_SQL_SERVER_VERSION",
+ SqlInfo::FlightSqlServerArrowVersion =>
"FLIGHT_SQL_SERVER_ARROW_VERSION",
+ SqlInfo::FlightSqlServerReadOnly => "FLIGHT_SQL_SERVER_READ_ONLY",
+ SqlInfo::SqlDdlCatalog => "SQL_DDL_CATALOG",
+ SqlInfo::SqlDdlSchema => "SQL_DDL_SCHEMA",
+ SqlInfo::SqlDdlTable => "SQL_DDL_TABLE",
+ SqlInfo::SqlIdentifierCase => "SQL_IDENTIFIER_CASE",
+ SqlInfo::SqlIdentifierQuoteChar => "SQL_IDENTIFIER_QUOTE_CHAR",
+ SqlInfo::SqlQuotedIdentifierCase => "SQL_QUOTED_IDENTIFIER_CASE",
+ SqlInfo::SqlAllTablesAreSelectable =>
"SQL_ALL_TABLES_ARE_SELECTABLE",
+ SqlInfo::SqlNullOrdering => "SQL_NULL_ORDERING",
+ SqlInfo::SqlKeywords => "SQL_KEYWORDS",
+ SqlInfo::SqlNumericFunctions => "SQL_NUMERIC_FUNCTIONS",
+ SqlInfo::SqlStringFunctions => "SQL_STRING_FUNCTIONS",
+ SqlInfo::SqlSystemFunctions => "SQL_SYSTEM_FUNCTIONS",
+ SqlInfo::SqlDatetimeFunctions => "SQL_DATETIME_FUNCTIONS",
+ SqlInfo::SqlSearchStringEscape => "SQL_SEARCH_STRING_ESCAPE",
+ SqlInfo::SqlExtraNameCharacters => "SQL_EXTRA_NAME_CHARACTERS",
+ SqlInfo::SqlSupportsColumnAliasing =>
"SQL_SUPPORTS_COLUMN_ALIASING",
+ SqlInfo::SqlNullPlusNullIsNull => "SQL_NULL_PLUS_NULL_IS_NULL",
+ SqlInfo::SqlSupportsConvert => "SQL_SUPPORTS_CONVERT",
+ SqlInfo::SqlSupportsTableCorrelationNames =>
"SQL_SUPPORTS_TABLE_CORRELATION_NAMES",
+ SqlInfo::SqlSupportsDifferentTableCorrelationNames =>
"SQL_SUPPORTS_DIFFERENT_TABLE_CORRELATION_NAMES",
+ SqlInfo::SqlSupportsExpressionsInOrderBy =>
"SQL_SUPPORTS_EXPRESSIONS_IN_ORDER_BY",
+ SqlInfo::SqlSupportsOrderByUnrelated =>
"SQL_SUPPORTS_ORDER_BY_UNRELATED",
+ SqlInfo::SqlSupportedGroupBy => "SQL_SUPPORTED_GROUP_BY",
+ SqlInfo::SqlSupportsLikeEscapeClause =>
"SQL_SUPPORTS_LIKE_ESCAPE_CLAUSE",
+ SqlInfo::SqlSupportsNonNullableColumns =>
"SQL_SUPPORTS_NON_NULLABLE_COLUMNS",
+ SqlInfo::SqlSupportedGrammar => "SQL_SUPPORTED_GRAMMAR",
+ SqlInfo::SqlAnsi92SupportedLevel => "SQL_ANSI92_SUPPORTED_LEVEL",
+ SqlInfo::SqlSupportsIntegrityEnhancementFacility =>
"SQL_SUPPORTS_INTEGRITY_ENHANCEMENT_FACILITY",
+ SqlInfo::SqlOuterJoinsSupportLevel =>
"SQL_OUTER_JOINS_SUPPORT_LEVEL",
+ SqlInfo::SqlSchemaTerm => "SQL_SCHEMA_TERM",
+ SqlInfo::SqlProcedureTerm => "SQL_PROCEDURE_TERM",
+ SqlInfo::SqlCatalogTerm => "SQL_CATALOG_TERM",
+ SqlInfo::SqlCatalogAtStart => "SQL_CATALOG_AT_START",
+ SqlInfo::SqlSchemasSupportedActions =>
"SQL_SCHEMAS_SUPPORTED_ACTIONS",
+ SqlInfo::SqlCatalogsSupportedActions =>
"SQL_CATALOGS_SUPPORTED_ACTIONS",
+ SqlInfo::SqlSupportedPositionedCommands =>
"SQL_SUPPORTED_POSITIONED_COMMANDS",
+ SqlInfo::SqlSelectForUpdateSupported =>
"SQL_SELECT_FOR_UPDATE_SUPPORTED",
+ SqlInfo::SqlStoredProceduresSupported =>
"SQL_STORED_PROCEDURES_SUPPORTED",
+ SqlInfo::SqlSupportedSubqueries => "SQL_SUPPORTED_SUBQUERIES",
+ SqlInfo::SqlCorrelatedSubqueriesSupported =>
"SQL_CORRELATED_SUBQUERIES_SUPPORTED",
+ SqlInfo::SqlSupportedUnions => "SQL_SUPPORTED_UNIONS",
+ SqlInfo::SqlMaxBinaryLiteralLength =>
"SQL_MAX_BINARY_LITERAL_LENGTH",
+ SqlInfo::SqlMaxCharLiteralLength => "SQL_MAX_CHAR_LITERAL_LENGTH",
+ SqlInfo::SqlMaxColumnNameLength => "SQL_MAX_COLUMN_NAME_LENGTH",
+ SqlInfo::SqlMaxColumnsInGroupBy => "SQL_MAX_COLUMNS_IN_GROUP_BY",
+ SqlInfo::SqlMaxColumnsInIndex => "SQL_MAX_COLUMNS_IN_INDEX",
+ SqlInfo::SqlMaxColumnsInOrderBy => "SQL_MAX_COLUMNS_IN_ORDER_BY",
+ SqlInfo::SqlMaxColumnsInSelect => "SQL_MAX_COLUMNS_IN_SELECT",
+ SqlInfo::SqlMaxColumnsInTable => "SQL_MAX_COLUMNS_IN_TABLE",
+ SqlInfo::SqlMaxConnections => "SQL_MAX_CONNECTIONS",
+ SqlInfo::SqlMaxCursorNameLength => "SQL_MAX_CURSOR_NAME_LENGTH",
+ SqlInfo::SqlMaxIndexLength => "SQL_MAX_INDEX_LENGTH",
+ SqlInfo::SqlDbSchemaNameLength => "SQL_DB_SCHEMA_NAME_LENGTH",
+ SqlInfo::SqlMaxProcedureNameLength =>
"SQL_MAX_PROCEDURE_NAME_LENGTH",
+ SqlInfo::SqlMaxCatalogNameLength => "SQL_MAX_CATALOG_NAME_LENGTH",
+ SqlInfo::SqlMaxRowSize => "SQL_MAX_ROW_SIZE",
+ SqlInfo::SqlMaxRowSizeIncludesBlobs =>
"SQL_MAX_ROW_SIZE_INCLUDES_BLOBS",
+ SqlInfo::SqlMaxStatementLength => "SQL_MAX_STATEMENT_LENGTH",
+ SqlInfo::SqlMaxStatements => "SQL_MAX_STATEMENTS",
+ SqlInfo::SqlMaxTableNameLength => "SQL_MAX_TABLE_NAME_LENGTH",
+ SqlInfo::SqlMaxTablesInSelect => "SQL_MAX_TABLES_IN_SELECT",
+ SqlInfo::SqlMaxUsernameLength => "SQL_MAX_USERNAME_LENGTH",
+ SqlInfo::SqlDefaultTransactionIsolation =>
"SQL_DEFAULT_TRANSACTION_ISOLATION",
+ SqlInfo::SqlTransactionsSupported => "SQL_TRANSACTIONS_SUPPORTED",
+ SqlInfo::SqlSupportedTransactionsIsolationLevels =>
"SQL_SUPPORTED_TRANSACTIONS_ISOLATION_LEVELS",
+ SqlInfo::SqlDataDefinitionCausesTransactionCommit =>
"SQL_DATA_DEFINITION_CAUSES_TRANSACTION_COMMIT",
+ SqlInfo::SqlDataDefinitionsInTransactionsIgnored =>
"SQL_DATA_DEFINITIONS_IN_TRANSACTIONS_IGNORED",
+ SqlInfo::SqlSupportedResultSetTypes =>
"SQL_SUPPORTED_RESULT_SET_TYPES",
+ SqlInfo::SqlSupportedConcurrenciesForResultSetUnspecified =>
"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_UNSPECIFIED",
+ SqlInfo::SqlSupportedConcurrenciesForResultSetForwardOnly =>
"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_FORWARD_ONLY",
+ SqlInfo::SqlSupportedConcurrenciesForResultSetScrollSensitive =>
"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_SENSITIVE",
+ SqlInfo::SqlSupportedConcurrenciesForResultSetScrollInsensitive =>
"SQL_SUPPORTED_CONCURRENCIES_FOR_RESULT_SET_SCROLL_INSENSITIVE",
+ SqlInfo::SqlBatchUpdatesSupported => "SQL_BATCH_UPDATES_SUPPORTED",
+ SqlInfo::SqlSavepointsSupported => "SQL_SAVEPOINTS_SUPPORTED",
+ SqlInfo::SqlNamedParametersSupported =>
"SQL_NAMED_PARAMETERS_SUPPORTED",
+ SqlInfo::SqlLocatorsUpdateCopy => "SQL_LOCATORS_UPDATE_COPY",
+ SqlInfo::SqlStoredFunctionsUsingCallSyntaxSupported =>
"SQL_STORED_FUNCTIONS_USING_CALL_SYNTAX_SUPPORTED",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedCaseSensitivity {
@@ -1011,6 +1102,20 @@ pub enum SqlSupportedCaseSensitivity {
SqlCaseSensitivityUppercase = 2,
SqlCaseSensitivityLowercase = 3,
}
+impl SqlSupportedCaseSensitivity {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedCaseSensitivity::SqlCaseSensitivityUnknown =>
"SQL_CASE_SENSITIVITY_UNKNOWN",
+ SqlSupportedCaseSensitivity::SqlCaseSensitivityCaseInsensitive =>
"SQL_CASE_SENSITIVITY_CASE_INSENSITIVE",
+ SqlSupportedCaseSensitivity::SqlCaseSensitivityUppercase =>
"SQL_CASE_SENSITIVITY_UPPERCASE",
+ SqlSupportedCaseSensitivity::SqlCaseSensitivityLowercase =>
"SQL_CASE_SENSITIVITY_LOWERCASE",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlNullOrdering {
@@ -1019,6 +1124,20 @@ pub enum SqlNullOrdering {
SqlNullsSortedAtStart = 2,
SqlNullsSortedAtEnd = 3,
}
+impl SqlNullOrdering {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlNullOrdering::SqlNullsSortedHigh => "SQL_NULLS_SORTED_HIGH",
+ SqlNullOrdering::SqlNullsSortedLow => "SQL_NULLS_SORTED_LOW",
+ SqlNullOrdering::SqlNullsSortedAtStart =>
"SQL_NULLS_SORTED_AT_START",
+ SqlNullOrdering::SqlNullsSortedAtEnd => "SQL_NULLS_SORTED_AT_END",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SupportedSqlGrammar {
@@ -1026,6 +1145,19 @@ pub enum SupportedSqlGrammar {
SqlCoreGrammar = 1,
SqlExtendedGrammar = 2,
}
+impl SupportedSqlGrammar {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SupportedSqlGrammar::SqlMinimumGrammar => "SQL_MINIMUM_GRAMMAR",
+ SupportedSqlGrammar::SqlCoreGrammar => "SQL_CORE_GRAMMAR",
+ SupportedSqlGrammar::SqlExtendedGrammar => "SQL_EXTENDED_GRAMMAR",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SupportedAnsi92SqlGrammarLevel {
@@ -1033,6 +1165,19 @@ pub enum SupportedAnsi92SqlGrammarLevel {
Ansi92IntermediateSql = 1,
Ansi92FullSql = 2,
}
+impl SupportedAnsi92SqlGrammarLevel {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SupportedAnsi92SqlGrammarLevel::Ansi92EntrySql =>
"ANSI92_ENTRY_SQL",
+ SupportedAnsi92SqlGrammarLevel::Ansi92IntermediateSql =>
"ANSI92_INTERMEDIATE_SQL",
+ SupportedAnsi92SqlGrammarLevel::Ansi92FullSql => "ANSI92_FULL_SQL",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlOuterJoinsSupportLevel {
@@ -1040,12 +1185,37 @@ pub enum SqlOuterJoinsSupportLevel {
SqlLimitedOuterJoins = 1,
SqlFullOuterJoins = 2,
}
+impl SqlOuterJoinsSupportLevel {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlOuterJoinsSupportLevel::SqlJoinsUnsupported =>
"SQL_JOINS_UNSUPPORTED",
+ SqlOuterJoinsSupportLevel::SqlLimitedOuterJoins =>
"SQL_LIMITED_OUTER_JOINS",
+ SqlOuterJoinsSupportLevel::SqlFullOuterJoins =>
"SQL_FULL_OUTER_JOINS",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedGroupBy {
SqlGroupByUnrelated = 0,
SqlGroupByBeyondSelect = 1,
}
+impl SqlSupportedGroupBy {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedGroupBy::SqlGroupByUnrelated =>
"SQL_GROUP_BY_UNRELATED",
+ SqlSupportedGroupBy::SqlGroupByBeyondSelect =>
"SQL_GROUP_BY_BEYOND_SELECT",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedElementActions {
@@ -1053,12 +1223,37 @@ pub enum SqlSupportedElementActions {
SqlElementInIndexDefinitions = 1,
SqlElementInPrivilegeDefinitions = 2,
}
+impl SqlSupportedElementActions {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedElementActions::SqlElementInProcedureCalls =>
"SQL_ELEMENT_IN_PROCEDURE_CALLS",
+ SqlSupportedElementActions::SqlElementInIndexDefinitions =>
"SQL_ELEMENT_IN_INDEX_DEFINITIONS",
+ SqlSupportedElementActions::SqlElementInPrivilegeDefinitions =>
"SQL_ELEMENT_IN_PRIVILEGE_DEFINITIONS",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedPositionedCommands {
SqlPositionedDelete = 0,
SqlPositionedUpdate = 1,
}
+impl SqlSupportedPositionedCommands {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedPositionedCommands::SqlPositionedDelete =>
"SQL_POSITIONED_DELETE",
+ SqlSupportedPositionedCommands::SqlPositionedUpdate =>
"SQL_POSITIONED_UPDATE",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedSubqueries {
@@ -1067,12 +1262,38 @@ pub enum SqlSupportedSubqueries {
SqlSubqueriesInIns = 2,
SqlSubqueriesInQuantifieds = 3,
}
+impl SqlSupportedSubqueries {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedSubqueries::SqlSubqueriesInComparisons =>
"SQL_SUBQUERIES_IN_COMPARISONS",
+ SqlSupportedSubqueries::SqlSubqueriesInExists =>
"SQL_SUBQUERIES_IN_EXISTS",
+ SqlSupportedSubqueries::SqlSubqueriesInIns =>
"SQL_SUBQUERIES_IN_INS",
+ SqlSupportedSubqueries::SqlSubqueriesInQuantifieds =>
"SQL_SUBQUERIES_IN_QUANTIFIEDS",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedUnions {
SqlUnion = 0,
SqlUnionAll = 1,
}
+impl SqlSupportedUnions {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedUnions::SqlUnion => "SQL_UNION",
+ SqlSupportedUnions::SqlUnionAll => "SQL_UNION_ALL",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlTransactionIsolationLevel {
@@ -1082,6 +1303,21 @@ pub enum SqlTransactionIsolationLevel {
SqlTransactionRepeatableRead = 3,
SqlTransactionSerializable = 4,
}
+impl SqlTransactionIsolationLevel {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlTransactionIsolationLevel::SqlTransactionNone =>
"SQL_TRANSACTION_NONE",
+ SqlTransactionIsolationLevel::SqlTransactionReadUncommitted =>
"SQL_TRANSACTION_READ_UNCOMMITTED",
+ SqlTransactionIsolationLevel::SqlTransactionReadCommitted =>
"SQL_TRANSACTION_READ_COMMITTED",
+ SqlTransactionIsolationLevel::SqlTransactionRepeatableRead =>
"SQL_TRANSACTION_REPEATABLE_READ",
+ SqlTransactionIsolationLevel::SqlTransactionSerializable =>
"SQL_TRANSACTION_SERIALIZABLE",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedTransactions {
@@ -1089,6 +1325,19 @@ pub enum SqlSupportedTransactions {
SqlDataDefinitionTransactions = 1,
SqlDataManipulationTransactions = 2,
}
+impl SqlSupportedTransactions {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedTransactions::SqlTransactionUnspecified =>
"SQL_TRANSACTION_UNSPECIFIED",
+ SqlSupportedTransactions::SqlDataDefinitionTransactions =>
"SQL_DATA_DEFINITION_TRANSACTIONS",
+ SqlSupportedTransactions::SqlDataManipulationTransactions =>
"SQL_DATA_MANIPULATION_TRANSACTIONS",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedResultSetType {
@@ -1097,6 +1346,20 @@ pub enum SqlSupportedResultSetType {
SqlResultSetTypeScrollInsensitive = 2,
SqlResultSetTypeScrollSensitive = 3,
}
+impl SqlSupportedResultSetType {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportedResultSetType::SqlResultSetTypeUnspecified =>
"SQL_RESULT_SET_TYPE_UNSPECIFIED",
+ SqlSupportedResultSetType::SqlResultSetTypeForwardOnly =>
"SQL_RESULT_SET_TYPE_FORWARD_ONLY",
+ SqlSupportedResultSetType::SqlResultSetTypeScrollInsensitive =>
"SQL_RESULT_SET_TYPE_SCROLL_INSENSITIVE",
+ SqlSupportedResultSetType::SqlResultSetTypeScrollSensitive =>
"SQL_RESULT_SET_TYPE_SCROLL_SENSITIVE",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportedResultSetConcurrency {
@@ -1104,6 +1367,19 @@ pub enum SqlSupportedResultSetConcurrency {
SqlResultSetConcurrencyReadOnly = 1,
SqlResultSetConcurrencyUpdatable = 2,
}
+impl SqlSupportedResultSetConcurrency {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+
SqlSupportedResultSetConcurrency::SqlResultSetConcurrencyUnspecified =>
"SQL_RESULT_SET_CONCURRENCY_UNSPECIFIED",
+ SqlSupportedResultSetConcurrency::SqlResultSetConcurrencyReadOnly
=> "SQL_RESULT_SET_CONCURRENCY_READ_ONLY",
+ SqlSupportedResultSetConcurrency::SqlResultSetConcurrencyUpdatable
=> "SQL_RESULT_SET_CONCURRENCY_UPDATABLE",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSupportsConvert {
@@ -1128,6 +1404,36 @@ pub enum SqlSupportsConvert {
SqlConvertVarbinary = 18,
SqlConvertVarchar = 19,
}
+impl SqlSupportsConvert {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ SqlSupportsConvert::SqlConvertBigint => "SQL_CONVERT_BIGINT",
+ SqlSupportsConvert::SqlConvertBinary => "SQL_CONVERT_BINARY",
+ SqlSupportsConvert::SqlConvertBit => "SQL_CONVERT_BIT",
+ SqlSupportsConvert::SqlConvertChar => "SQL_CONVERT_CHAR",
+ SqlSupportsConvert::SqlConvertDate => "SQL_CONVERT_DATE",
+ SqlSupportsConvert::SqlConvertDecimal => "SQL_CONVERT_DECIMAL",
+ SqlSupportsConvert::SqlConvertFloat => "SQL_CONVERT_FLOAT",
+ SqlSupportsConvert::SqlConvertInteger => "SQL_CONVERT_INTEGER",
+ SqlSupportsConvert::SqlConvertIntervalDayTime =>
"SQL_CONVERT_INTERVAL_DAY_TIME",
+ SqlSupportsConvert::SqlConvertIntervalYearMonth =>
"SQL_CONVERT_INTERVAL_YEAR_MONTH",
+ SqlSupportsConvert::SqlConvertLongvarbinary =>
"SQL_CONVERT_LONGVARBINARY",
+ SqlSupportsConvert::SqlConvertLongvarchar =>
"SQL_CONVERT_LONGVARCHAR",
+ SqlSupportsConvert::SqlConvertNumeric => "SQL_CONVERT_NUMERIC",
+ SqlSupportsConvert::SqlConvertReal => "SQL_CONVERT_REAL",
+ SqlSupportsConvert::SqlConvertSmallint => "SQL_CONVERT_SMALLINT",
+ SqlSupportsConvert::SqlConvertTime => "SQL_CONVERT_TIME",
+ SqlSupportsConvert::SqlConvertTimestamp => "SQL_CONVERT_TIMESTAMP",
+ SqlSupportsConvert::SqlConvertTinyint => "SQL_CONVERT_TINYINT",
+ SqlSupportsConvert::SqlConvertVarbinary => "SQL_CONVERT_VARBINARY",
+ SqlSupportsConvert::SqlConvertVarchar => "SQL_CONVERT_VARCHAR",
+ }
+ }
+}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord,
::prost::Enumeration)]
#[repr(i32)]
pub enum UpdateDeleteRules {
@@ -1137,3 +1443,18 @@ pub enum UpdateDeleteRules {
NoAction = 3,
SetDefault = 4,
}
+impl UpdateDeleteRules {
+ /// String value of the enum field names used in the ProtoBuf definition.
+ ///
+ /// The values are not transformed in any way and thus are considered
stable
+ /// (if the ProtoBuf definition does not change) and safe for programmatic
use.
+ pub fn as_str_name(&self) -> &'static str {
+ match self {
+ UpdateDeleteRules::Cascade => "CASCADE",
+ UpdateDeleteRules::Restrict => "RESTRICT",
+ UpdateDeleteRules::SetNull => "SET_NULL",
+ UpdateDeleteRules::NoAction => "NO_ACTION",
+ UpdateDeleteRules::SetDefault => "SET_DEFAULT",
+ }
+ }
+}
diff --git a/integration-testing/Cargo.toml b/integration-testing/Cargo.toml
index 5d98dc9eb..76a726fe2 100644
--- a/integration-testing/Cargo.toml
+++ b/integration-testing/Cargo.toml
@@ -37,11 +37,11 @@ async-trait = { version = "0.1.41", default-features =
false }
clap = { version = "3", default-features = false, features = ["std", "derive"]
}
futures = { version = "0.3", default-features = false }
hex = { version = "0.4", default-features = false }
-prost = { version = "0.10", default-features = false }
+prost = { version = "0.11", default-features = false }
serde = { version = "1.0", default-features = false, features = ["rc"] }
serde_derive = { version = "1.0", default-features = false }
serde_json = { version = "1.0", default-features = false, features = ["std"] }
tokio = { version = "1.0", default-features = false }
-tonic = { version = "0.7", default-features = false }
+tonic = { version = "0.8", default-features = false }
tracing-subscriber = { version = "0.3.1", default-features = false, features =
["fmt"], optional = true }
num = { version = "0.4", default-features = false, features = ["std"] }
