Module arrow_flight::sql

Support for execute SQL queries using Apache Arrow Flight SQL.

Flight SQL is built on top of Arrow Flight RPC framework, by defining specific messages, encoded using the protobuf format, sent in theFlightDescriptor::cmd field to FlightService endpoints such asget_flight_info and do_get.

This module contains:

1. prost generated structs for FlightSQL messages such as CommandStatementQuery
2. Helpers for encoding and decoding FlightSQL messages: Any and Command
3. A FlightSqlServiceClient for interacting with FlightSQL servers.
4. A FlightSqlService to help building FlightSQL servers from FlightService.

Modules

• client
  A FlightSQL Client FlightSqlServiceClient
• server
  Helper trait FlightSqlService for implementing a FlightService that implements FlightSQL.

Structs

• ActionClosePreparedStatementRequest
  Request message for the “ClosePreparedStatement” action on a Flight SQL enabled backend. Closes server resources associated with the prepared statement handle.
• ActionCreatePreparedStatementRequest
  Request message for the “CreatePreparedStatement” action on a Flight SQL enabled backend.
• ActionCreatePreparedStatementResult
  Wrap the result of a “GetPreparedStatement” action.
• Any
  An implementation of the protobuf Any message type
• CommandGetCatalogs
  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:
• CommandGetCrossReference
  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:
• CommandGetDbSchemas
  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:
• CommandGetExportedKeys
  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:
• CommandGetImportedKeys
  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:
• CommandGetPrimaryKeys
  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:
• CommandGetSqlInfo
  Represents a metadata request. Used in the command member of FlightDescriptor for the following RPC calls:
• CommandGetTableTypes
  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:
• CommandGetTables
  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:
• CommandGetXdbcTypeInfo
  Represents a request to retrieve information about data type supported on a Flight SQL enabled backend. Used in the command member of FlightDescriptor for the following RPC calls:
• CommandPreparedStatementQuery
  Represents an instance of executing a prepared statement. Used in the command member of FlightDescriptor for the following RPC calls:
• CommandPreparedStatementUpdate
  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.
• CommandStatementQuery
  Represents a SQL query. Used in the command member of FlightDescriptor for the following RPC calls:
• CommandStatementUpdate
  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.
• DoPutUpdateResult
  Returned from the RPC call DoPut when a CommandStatementUpdate CommandPreparedStatementUpdate was in the request, containing results from the update.
• TicketStatementQuery

Enums

• Command
  Helper to convert to/from protobuf Any message to a specific FlightSQL command message.
• SqlInfo
  Options for CommandGetSqlInfo.
• SqlNullOrdering
• SqlOuterJoinsSupportLevel
• SqlSupportedCaseSensitivity
• SqlSupportedElementActions
• SqlSupportedGroupBy
• SqlSupportedPositionedCommands
• SqlSupportedResultSetConcurrency
• SqlSupportedResultSetType
• SqlSupportedSubqueries
• SqlSupportedTransactions
• SqlSupportedUnions
• SqlSupportsConvert
• SqlTransactionIsolationLevel
• SupportedSqlGrammar
• UpdateDeleteRules

Traits

• ProstMessageExt
  ProstMessageExt are useful utility methods for prost::Message types