当前位置：首页 > 行业动态 > 正文

c 储存到数据库

admin
行业动态
2025-02-14
4

将数据存储到数据库通常涉及以下步骤：连接到数据库、创建表（如果尚不存在）、插入或更新数据、提交事务。具体实现取决于所使用的编程语言和数据库系统。

C 语言中如何将数据储存到数据库

在C语言编程中，将数据存储到数据库是一个常见的需求，这通常涉及到与数据库管理系统（DBMS）的交互，如MySQL、PostgreSQL、SQLite等，以下是使用C语言连接数据库并执行基本操作的详细步骤和示例代码。

选择数据库和驱动

你需要选择一个数据库系统，对于初学者，SQLite是一个很好的选择，因为它不需要单独的服务器进程，且易于设置，对于更复杂的应用，你可能会选用MySQL或PostgreSQL。

SQLite: 轻量级，适合嵌入式系统和小型应用。

MySQL/PostgreSQL: 功能丰富，适用于大型应用和高并发场景。

确保你有适当的数据库驱动，对于MySQL，你可以使用mysql-connector-c；对于SQLite，则通常内置于标准库中。

安装必要的库

以MySQL为例，你需要安装MySQL开发库：

c 储存到数据库

Ubuntu/Debian
sudo apt-get install libmysqlclient-dev
CentOS/RHEL
sudo yum install mysql-devel

对于SQLite，大多数情况下无需额外安装，因为它通常随C标准库一起提供。

编写代码连接数据库

以下是一个使用C语言连接MySQL数据库并插入数据的简单示例：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    const char *server = "localhost";
    const char *user = "root";
    const char *password = "your_password"; /* 替换为你的MySQL密码 */
    const char *database = "testdb";
    conn = mysql_init(NULL);
    // 连接到数据库
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 执行查询
    if (mysql_query(conn, "CREATE TABLE IF NOT EXISTS TestTable(Id INT PRIMARY KEY, Name TEXT)")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_query(conn, "INSERT INTO TestTable(Id, Name) VALUES(1, 'Alice')")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 获取结果
    res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 输出结果
    printf("Data inserted successfully!
");
    // 清理
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

编译和运行

保存上述代码为main.c，然后使用以下命令编译（确保链接了MySQL客户端库）：

gcc -o myprogram main.c $(mysql_config --cflags --libs)

运行程序：

./myprogram

错误处理和安全性

错误处理: 确保检查所有数据库函数的返回值，并适当处理错误。

c 储存到数据库

安全性: 使用预处理语句或绑定参数来防止SQL注入攻击。

SQLite示例

对于SQLite，代码会更简单，因为不需要额外的库安装：

#include <stdio.h>
#include <sqlite3.h>
int main() {
    sqlite3 *db;
    char *err_msg = 0;
    int rc = sqlite3_open("test.db", &db);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "Cannot open database: %s
", sqlite3_errmsg(db));
        sqlite3_close(db);
        return 1;
    }
    char *sql = "CREATE TABLE IF NOT EXISTS TestTable(Id INTEGER PRIMARY KEY, Name TEXT);"
                "INSERT INTO TestTable (Id, Name) VALUES (1, 'Alice');";
    rc = sqlite3_exec(db, sql, 0, 0, &err_msg);
    
    if (rc != SQLITE_OK ) {
        fprintf(stderr, "SQL error: %s
", err_msg);
        sqlite3_free(err_msg);        
        sqlite3_close(db);
        return 1;
    } 
    printf("Operation done successfully
");
    sqlite3_close(db);
    return 0;
}

编译时只需包含SQLite头文件：