在c中模拟一个损坏的sqlite3服务器

Question

我创建了一个sqlite3数据库，用于保存传感器创建的条目。我正在用valgrind检查泄漏，现在我想知道如何"模拟"一个损坏的SQL服务器。我正在使用这个功能：

rc = sqlite3_prepare_v2(conn, sql, -1, &res, 0);

这个函数工作正常，有没有办法模拟它的失败？手动将rc设置为另一个值是一种选择，但没有意义，因为数据库确实被创建了，而程序认为它没有。我将添加下面的代码，尽管我认为这对这个问题没有必要。

这是将传感器插入数据库的插入函数。这就是我想要测试prepare函数失败时会发生什么的地方。

void *insert_sensor(void *argument) {
storagemgr_insert_argument_t *storagemgr_insert_argument = (storagemgr_insert_argument_t *) argument;
DBCONN *conn = storagemgr_insert_argument->db_connection;
sqlite3_stmt *res = NULL;
uint16_t sensor_id_read;
double temperature_value_read;
time_t timestamp_read;
sensor_data_t data;
int buffer_working_check;
data.id = 0;
data.value = 0;
data.ts = 0;
buffer_working_check = 1;
while (connmgr_loopt_bool == 1 || buffer_working_check == 0) {      //connmgr aan -> moet blijven lopen, connmgr uit maar nog data beschikbaar -> moet blijven lopen
pthread_mutex_lock(&lock);
//        printf("gelockt in storagemgrn");
buffer_working_check = sbuffer_read(shared_buffer, &data, 0, 1);
pthread_mutex_unlock(&lock);
int failed_tries = 0;
if (data.id != 0 && buffer_working_check != -1 && buffer_working_check != 1) {
res = NULL;
sensor_id_read = data.id;
temperature_value_read = data.value;
timestamp_read = data.ts;
while(failed_tries<3) {
char *sql = "INSERT INTO "TO_STRING(TABLE_NAME)" (sensor_id, sensor_value, timestamp) VALUES (@sensor_id, @sensor_value, @timestamp)";
rc = sqlite3_prepare_v2(conn, sql, -1, &res, 0);
if (rc == SQLITE_OK) {
int idx1 = sqlite3_bind_parameter_index(res, "@sensor_id");
sqlite3_bind_int(res, idx1, sensor_id_read);
int idx2 = sqlite3_bind_parameter_index(res, "@sensor_value");
sqlite3_bind_double(res, idx2, temperature_value_read);
int idx = sqlite3_bind_parameter_index(res, "@timestamp");
sqlite3_bind_int(res, idx, timestamp_read);
break;
}
else {
write_to_fifo("Insert to the SQL server failed, trying again. ", 4);
failed_tries++;
//                    char *err_msg = 0;
//
//                    fprintf(stderr, "Failed to execute statement: %sn", sqlite3_errmsg(conn));
//                    sqlite3_free(err_msg);
//                    sqlite3_close(conn);
//                    return NULL;
}
sleep(2);
}
}
if (0<failed_tries && failed_tries <= 2) {            //het mag =2, want als het =2 en de db faalt dan wordt het eerst geincrementeert naar 3
write_to_fifo("Connection to SQL server re-established. ", 5);
}
if(failed_tries>2) {
db_connection_failed_bool = 1;
sqlite3_close(conn);
write_to_fifo("Connection to SQL server lost. ", 6);
break;
}
if (res != NULL) {
sqlite3_step(res);
sqlite3_finalize(res);
res = NULL;
}
}
return NULL;
}

Answer 1

如果您想保持代码的纯净，您可以始终向插入函数传递无效的文件路径或无效的文件名。如果您正在尝试测试恢复循环，但仍然希望它保持纯，则可以传递无效的文件路径，并让恢复循环尝试构建路径。使用sqlite3_prepare_v2时，SQLite不会在不存在的文件夹中构建数据库。