Bug fix for delete iterator

This commit is contained in:
simon987 2023-04-13 18:35:29 -04:00
parent 237d55ec9c
commit 5b3b9911bd
2 changed files with 8 additions and 2 deletions

View File

@ -592,7 +592,11 @@ void database_add_work(database_t *db, job_t *job) {
do {
sqlite3_bind_text(db->insert_index_job_stmt, 1, job->bulk_line->doc_id, -1, SQLITE_STATIC);
sqlite3_bind_int(db->insert_index_job_stmt, 2, job->bulk_line->type);
sqlite3_bind_text(db->insert_index_job_stmt, 3, job->bulk_line->line, -1, SQLITE_STATIC);
if (job->bulk_line->type != ES_BULK_LINE_DELETE) {
sqlite3_bind_text(db->insert_index_job_stmt, 3, job->bulk_line->line, -1, SQLITE_STATIC);
} else {
sqlite3_bind_null(db->insert_index_job_stmt, 3);
}
ret = sqlite3_step(db->insert_index_job_stmt);

View File

@ -322,7 +322,6 @@ void sist2_index(index_args_t *args) {
}
free(iterator);
database_close(db, FALSE);
if (!args->print) {
database_iterator_t *del_iter = database_create_delete_list_iterator(db);
@ -330,8 +329,11 @@ void sist2_index(index_args_t *args) {
delete_document(id);
free(id);
}
free(del_iter);
}
database_close(db, FALSE);
tpool_wait(IndexCtx.pool);
tpool_destroy(IndexCtx.pool);