How to fix SQLITE_INTERRUPT: Operation terminated by sqlite3_interrupt() in SQLite

sqlite3_stmt *stmt;
int rc = sqlite3_step(stmt);
if (rc == SQLITE_INTERRUPT) {
  // Operation was interrupted
  sqlite3_finalize(stmt);  // Always finalize to avoid memory leak
}

if (rc == SQLITE_INTERRUPT) {
  if (user_cancelled) {
    // Expected cancellation - inform user operation was cancelled
    log_user_message("Query cancelled by user");
  } else {
    // Unexpected interruption - log for debugging
    log_error("Unexpected SQLITE_INTERRUPT on query");
  }
}

// Timer thread that interrupts after timeout
void* timeout_thread(void* arg) {
  sqlite3 *db = (sqlite3*)arg;
  sleep(QUERY_TIMEOUT_SECONDS);
  sqlite3_interrupt(db);
  return NULL;
}

// Main query execution
pthread_t timer;
pthread_create(&timer, NULL, timeout_thread, db);
int rc = sqlite3_step(stmt);
if (rc == SQLITE_INTERRUPT) {
  sqlite3_finalize(stmt);
}
pthread_join(timer, NULL);

int progress_callback(void *arg) {
  time_t *start = (time_t*)arg;
  time_t elapsed = time(NULL) - *start;
  if (elapsed > QUERY_TIMEOUT_SECONDS) {
    return 1;  // Non-zero return stops execution
  }
  return 0;    // Zero return continues execution
}

time_t query_start = time(NULL);
sqlite3_progress_handler(db, PROGRESS_OPCODES, progress_callback, &query_start);
int rc = sqlite3_step(stmt);

int rc = sqlite3_step(stmt);
if (rc == SQLITE_INTERRUPT) {
  sqlite3_finalize(stmt);
  // Transaction is automatically rolled back
  // Check if we need to retry or log the failure
  char *errmsg = sqlite3_errmsg(db);
  log_error("Transaction interrupted: %s", errmsg);
  // Optionally retry the operation
  retry_operation();
}