写一个demo测试数据库每秒写入MB大小使用C语言

要在C语言中测试数据库每秒写入的MB大小，我们需要调整上述示例，以便测量写入的数据量而不是次数。这里我们以一个简单的文件操作作为模拟，因为直接操作数据库的大小可能会受到系统限制，并且需要特定库支持。我们将读取一个大文件并在数据库中插入相应内容：

首先，我们需要有读取和写入数据库的能力。如果你使用的是SQLite，可以参考之前提供的插入数据部分；如果是其他数据库，可能需要相应的驱动库。

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>
#include <unistd.h> // 包含read和write用于读取文件
#include <sys/types.h>
#include <sys/stat.h>

#define FILE_SIZE_MB (1024 * 1024) // 每次读取1MB
#define BUFFER_SIZE (1024 * 1024) // 缓冲区大小

void write_to_db(sqlite3 *db, const char *filename) {
    char buffer[BUFFER_SIZE];
    int bytes_read;

    // 打开文件
    struct stat file_info;
    if (stat(filename, &file_info) != 0) {
        perror("Could not access file");
        return;
    }

    while ((bytes_read = read(file_info.st_size - BUFFER_SIZE, buffer, BUFFER_SIZE)) > 0) {
        const char *insert_sql = "INSERT INTO your_table (data_column) VALUES (?)"; // 数据列名
        sqlite3_stmt *stmt;

        if (sqlite3_prepare_v2(db, insert_sql, -1, &stmt, NULL) == SQLITE_OK) {
            sqlite3_bind_blob(stmt, 1, buffer, bytes_read, SQLITE_STATIC);
            if (sqlite3_step(stmt) != SQLITE_DONE) {
                fprintf(stderr, "Error inserting data.\n");
            }
            sqlite3_finalize(stmt);
        } else {
            fprintf(stderr, "Error preparing SQL.\n");
        }
    }

    if (bytes_read < 0) {
        perror("Reading from file failed");
    }
}

int main() {
    sqlite3* db;
    const char* filename = "big_file.txt"; // 替换为你想要测试的大文件路径

    if (!open_database(&db)) {
        perror("Could not open database");
        return EXIT_FAILURE;
    }

    clock_gettime(CLOCK_MONOTONIC, &start_time);

    write_to_db(db, filename);

    clock_gettime(CLOCK_MONOTONIC, &end_time);
    elapsed_ns = difftime(end_time.tv_nsec, start_time.tv_nsec);
    elapsed_s = difftime(end_time.tv_sec, start_time.tv_sec);

    double total_bytes_written = (double)FILE_SIZE_MB;
    double mb_per_second = total_bytes_written / elapsed_s;

    printf("Average MB written per second: %.2f\n", mb_per_second);

    sqlite3_close(db);

    return 0;
}

在这个例子中，我们读取整个大文件（默认1MB），然后将其一次性插入数据库。实际的写入速率取决于文件大小和数据库性能。