| 613 | } |
| 614 | |
| 615 | arrow::Result<std::unique_ptr<arrow::flight::FlightDataStream>> |
| 616 | DoGetStatement(const arrow::flight::ServerCallContext &context, |
| 617 | const arrow::flight::sql::StatementQueryTicket &command) override |
| 618 | { |
| 619 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 620 | auto gacommand = gaflightsql_statement_query_ticket_new_raw(&command); |
| 621 | GError *gerror = nullptr; |
| 622 | auto gastream = |
| 623 | gaflightsql_server_do_get_statement(gaserver_, gacontext, gacommand, &gerror); |
| 624 | g_object_unref(gacommand); |
| 625 | g_object_unref(gacontext); |
| 626 | if (gerror) { |
| 627 | return garrow_error_to_status(gerror, |
| 628 | arrow::StatusCode::UnknownError, |
| 629 | "[flight-sql-server][do-get-statement]"); |
| 630 | } |
| 631 | return std::make_unique<gaflight::DataStream>(gastream); |
| 632 | } |
| 633 | |
| 634 | arrow::Result<int64_t> |
| 635 | DoPutCommandStatementUpdate( |
nothing calls this directly
no test coverage detected