| 116 | } |
| 117 | |
| 118 | arrow::Result<std::unique_ptr<FlightDataStream>> DoGetSQLiteQuery( |
| 119 | sqlite3* db, const std::string& query, const std::shared_ptr<Schema>& schema) { |
| 120 | std::shared_ptr<SqliteStatement> statement; |
| 121 | |
| 122 | ARROW_ASSIGN_OR_RAISE(statement, SqliteStatement::Create(db, query)); |
| 123 | |
| 124 | std::shared_ptr<SqliteStatementBatchReader> reader; |
| 125 | ARROW_ASSIGN_OR_RAISE(reader, SqliteStatementBatchReader::Create(statement, schema)); |
| 126 | |
| 127 | return std::make_unique<RecordBatchStream>(reader); |
| 128 | } |
| 129 | |
| 130 | arrow::Result<std::unique_ptr<FlightInfo>> GetFlightInfoForCommand( |
| 131 | const FlightDescriptor& descriptor, const std::shared_ptr<Schema>& schema) { |
no test coverage detected