| 656 | } |
| 657 | |
| 658 | arrow::Result<int64_t> |
| 659 | DoPutPreparedStatementUpdate( |
| 660 | const arrow::flight::ServerCallContext &context, |
| 661 | const arrow::flight::sql::PreparedStatementUpdate &command, |
| 662 | arrow::flight::FlightMessageReader *reader) override |
| 663 | { |
| 664 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 665 | auto gacommand = gaflightsql_prepared_statement_update_new_raw(&command); |
| 666 | auto gareader = gaflight_message_reader_new_raw(reader, FALSE); |
| 667 | GError *gerror = nullptr; |
| 668 | auto n_changed_records = |
| 669 | gaflightsql_server_do_put_prepared_statement_update(gaserver_, |
| 670 | gacontext, |
| 671 | gacommand, |
| 672 | gareader, |
| 673 | &gerror); |
| 674 | g_object_unref(gareader); |
| 675 | g_object_unref(gacommand); |
| 676 | g_object_unref(gacontext); |
| 677 | if (gerror) { |
| 678 | return garrow_error_to_status( |
| 679 | gerror, |
| 680 | arrow::StatusCode::UnknownError, |
| 681 | "[flight-sql-server][do-put-prepared-statement-update]"); |
| 682 | } |
| 683 | return n_changed_records; |
| 684 | } |
| 685 | |
| 686 | arrow::Result<arrow::flight::sql::ActionCreatePreparedStatementResult> |
| 687 | CreatePreparedStatement( |
nothing calls this directly
no test coverage detected