| 340 | } |
| 341 | |
| 342 | void DeletesFx::write_delete_condition( |
| 343 | QueryCondition& qc, uint64_t timestamp, bool encrypt) { |
| 344 | // Open array. |
| 345 | std::unique_ptr<Array> array; |
| 346 | if (encrypt) { |
| 347 | array = std::make_unique<Array>( |
| 348 | ctx_, |
| 349 | array_name_.c_str(), |
| 350 | TILEDB_DELETE, |
| 351 | TemporalPolicy(TimeTravel, timestamp), |
| 352 | EncryptionAlgorithm(AESGCM, key_.c_str())); |
| 353 | } else { |
| 354 | array = std::make_unique<Array>( |
| 355 | ctx_, |
| 356 | array_name_.c_str(), |
| 357 | TILEDB_DELETE, |
| 358 | TemporalPolicy(TimeTravel, timestamp)); |
| 359 | } |
| 360 | |
| 361 | // Create query. |
| 362 | Query query(ctx_, *array, TILEDB_DELETE); |
| 363 | |
| 364 | query.set_condition(qc); |
| 365 | query.submit(); |
| 366 | CHECK(query.query_status() == Query::Status::COMPLETE); |
| 367 | |
| 368 | // Close array. |
| 369 | array->close(); |
| 370 | } |
| 371 | |
| 372 | void DeletesFx::check_delete_conditions( |
| 373 | std::vector<QueryCondition> qcs, uint64_t timestamp, bool encrypt) { |
nothing calls this directly
no test coverage detected