| 632 | } |
| 633 | |
| 634 | arrow::Result<int64_t> |
| 635 | DoPutCommandStatementUpdate( |
| 636 | const arrow::flight::ServerCallContext &context, |
| 637 | const arrow::flight::sql::StatementUpdate &command) override |
| 638 | { |
| 639 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 640 | auto gacommand = gaflightsql_statement_update_new_raw(&command); |
| 641 | GError *gerror = nullptr; |
| 642 | auto n_changed_records = |
| 643 | gaflightsql_server_do_put_command_statement_update(gaserver_, |
| 644 | gacontext, |
| 645 | gacommand, |
| 646 | &gerror); |
| 647 | g_object_unref(gacommand); |
| 648 | g_object_unref(gacontext); |
| 649 | if (gerror) { |
| 650 | return garrow_error_to_status( |
| 651 | gerror, |
| 652 | arrow::StatusCode::UnknownError, |
| 653 | "[flight-sql-server][do-put-command-statement-update]"); |
| 654 | } |
| 655 | return n_changed_records; |
| 656 | } |
| 657 | |
| 658 | arrow::Result<int64_t> |
| 659 | DoPutPreparedStatementUpdate( |
nothing calls this directly
no test coverage detected