| 422 | } |
| 423 | |
| 424 | arrow::Result<std::unique_ptr<FlightInfo>> FlightSqlClient::GetPrimaryKeys( |
| 425 | const FlightCallOptions& options, const TableRef& table_ref) { |
| 426 | flight_sql_pb::CommandGetPrimaryKeys command; |
| 427 | |
| 428 | if (table_ref.catalog.has_value()) { |
| 429 | command.set_catalog(table_ref.catalog.value()); |
| 430 | } |
| 431 | |
| 432 | if (table_ref.db_schema.has_value()) { |
| 433 | command.set_db_schema(table_ref.db_schema.value()); |
| 434 | } |
| 435 | |
| 436 | command.set_table(table_ref.table); |
| 437 | |
| 438 | return GetFlightInfoForCommand(this, options, command); |
| 439 | } |
| 440 | |
| 441 | arrow::Result<std::unique_ptr<SchemaResult>> FlightSqlClient::GetPrimaryKeysSchema( |
| 442 | const FlightCallOptions& options) { |