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

c 如何与数据库连接

admin
行业动态
2025-03-22
1

要与数据库连接，通常需要使用相应的数据库驱动和API，如JDBC、ODBC等。

C语言如何与数据库连接

在C语言中，与数据库进行连接和交互通常需要使用数据库提供的客户端库，以下是几种常见数据库的连接方法：

MySQL数据库

安装MySQL开发库

你需要安装MySQL的开发库，在Ubuntu上可以使用以下命令：

sudo apt-get install libmysqlclient-dev

编写代码

下面是一个使用MySQL C API连接到数据库并进行简单查询的示例：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL conn;
    MYSQL_RES res;
    MYSQL_ROW row;
    const char server = "localhost";
    const char user = "root";
    const char password = "your_password"; / 替换为你的密码 /
    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, "SELECT  FROM your_table")) { // 替换为你的表名
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    res = mysql_use_result(conn);
    printf("Results:
");
    while ((row = mysql_fetch_row(res)) != NULL) {
        printf("%s 
", row[0]); // 假设你只选择了一个字段
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

PostgreSQL数据库

安装PostgreSQL开发库

c 如何与数据库连接

在Ubuntu上可以使用以下命令安装：

sudo apt-get install libpq-dev

编写代码

下面是一个使用libpq连接到PostgreSQL数据库并进行简单查询的示例：

#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>
void exit_nicely(PGconn conn) {
    PQfinish(conn);
    exit(1);
}
int main() {
    const char conninfo = "dbname=testdb user=postgres password=your_password hostaddr=127.0.0.1 port=5432"; // 替换为你的连接信息
    PGconn conn = PQconnectdb(conninfo);
    if (PQstatus(conn) != CONNECTION_OK) {
        fprintf(stderr, "Connection to database failed: %s", PQerrorMessage(conn));
        exit_nicely(conn);
    }
    PGresult res = PQexec(conn, "SELECT  FROM your_table"); // 替换为你的表名
    if (PQresultStatus(res) != PGRES_TUPLES_OK) {
        fprintf(stderr, "Query failed: %s", PQerrorMessage(conn));
        PQclear(res);
        exit_nicely(conn);
    }
    printf("Results:
");
    for (int i = 0; i < PQntuples(res); i++) {
        printf("%s
", PQgetvalue(res, i, 0)); // 假设你只选择了一个字段
    }
    PQclear(res);
    PQfinish(conn);
    return 0;
}

SQLite数据库

安装SQLite开发库

在Ubuntu上可以使用以下命令安装：

c 如何与数据库连接

sudo apt-get install libsqlite3-dev

编写代码

下面是一个使用SQLite3 C API连接到SQLite数据库并进行简单查询的示例：

#include <sqlite3.h>
#include <stdio.h>
#include <stdlib.h>
static int callback(void NotUsed, int argc, charargv, charazColName) {
    for (int i = 0; i < argc; i++) {
        printf("%s = %s
", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("
");
    return 0;
}
int main() {
    sqlite3 db;
    char zErrMsg = 0;
    int rc;
    const char sql;
    const char data = "Callback function called";
    rc = sqlite3_open("test.db", &db); // 打开数据库文件，如果不存在则创建
    if (rc) {
        fprintf(stderr, "Can't open database: %s
", sqlite3_errmsg(db));
        return 0;
    } else {
        fprintf(stderr, "Opened database successfully
");
    }
    sql = "CREATE TABLE IF NOT EXISTS test (id INTEGER PRIMARY KEY, info TEXT);";
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Table created successfully
");
    }
    sql = "INSERT INTO test (info) VALUES ('This is a test');";
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Records created successfully
");
    }
    sql = "SELECT  FROM test;";
    rc = sqlite3_exec(db, sql, callback, (void)data, &zErrMsg);
    if (rc != SQLITE_OK) {
        fprintf(stderr, "Failed to select data
");
        fprintf(stderr, "SQL error: %s
", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Operation done successfully
");
    }
    sqlite3_close(db); // 关闭数据库连接
    return 0;
}