如何实现C语言连接数据库？

选择数据库和相应库

在C语言中，要连接不同类型的数据库（如MySQL、SQLite、PostgreSQL等），需要使用对应的数据库客户端库，要连接MySQL数据库，通常会使用MySQL官方提供的libmysqlclient库；连接SQLite则使用其自带的sqlite3库，这里以连接MySQL数据库为例进行说明。

安装数据库客户端库

对于Linux系统：

以Ubuntu为例，可以通过以下命令安装libmysqlclient-dev库（这是用于开发连接MySQL数据库的库）：

sudo apt-get update
sudo apt-get install libmysqlclient-dev

对于Windows系统：

可以从MySQL官方网站下载相应的开发库文件，并按照提示进行安装配置，确保在编译器中能够正确找到头文件和库文件。

包含必要的头文件

在C源文件中，需要包含与所选数据库客户端库相关的头文件，以便使用其中定义的函数和数据结构，对于MySQL连接，通常需要包含mysql/mysql.h头文件，示例代码如下：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>

初始化数据库连接参数

定义一些变量来存储数据库连接所需的参数，如服务器地址、用户名、密码、数据库名称等。

const char host = "localhost";
const char user = "your_username";
const char pass = "your_password";
const char dbname = "your_database_name";
unsigned int port = 3306; // 默认MySQL端口号为3306
const char unix_socket = NULL; // 一般本地连接时可设为NULL
unsigned long client_flag = 0;

请将上述代码中的your_username、your_password和your_database_name替换为实际的数据库用户名、密码和数据库名称。

建立数据库连接

使用数据库客户端库提供的函数来建立与数据库的连接，对于MySQL，可以使用mysql_init()函数初始化一个MYSQL结构体，然后使用mysql_real_connect()函数尝试连接到数据库，示例代码如下：

MYSQL conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    fprintf(stderr, "mysql_init() failed
");
    exit(EXIT_FAILURE);
}
if (mysql_real_connect(conn, host, user, pass, dbname, port, unix_socket, client_flag) == NULL) {
    fprintf(stderr, "mysql_real_connect() failed
");
    mysql_close(conn);
    exit(EXIT_FAILURE);
}

上述代码中，首先调用mysql_init()函数初始化一个MYSQL指针变量conn，如果初始化失败，程序会输出错误信息并退出，使用mysql_real_connect()函数尝试连接到指定的数据库，如果连接失败，同样会输出错误信息，关闭连接并退出程序。

执行SQL查询

连接成功后，就可以使用mysql_query()函数向数据库发送SQL查询语句了，要查询名为test_table表中的所有记录，可以这样做：

char query = "SELECT  FROM test_table";
if (mysql_query(conn, query)) {
    fprintf(stderr, "SELECT  FROM test_table failed: %s
", mysql_error(conn));
    mysql_close(conn);
    exit(EXIT_FAILURE);
}

上述代码中，定义了一个包含SQL查询语句的字符串query，然后使用mysql_query()函数将其发送到数据库，如果查询执行失败，程序会输出错误信息，关闭连接并退出。

处理查询结果

如果查询成功执行，可以使用mysql_store_result()函数获取查询结果集，然后使用相关函数遍历结果集并处理每一行数据，示例代码如下：

MYSQL_RES result = mysql_store_result(conn);
if (result == NULL) {
    fprintf(stderr, "mysql_store_result() failed: %s
", mysql_error(conn));
    mysql_close(conn);
    exit(EXIT_FAILURE);
}
int num_fields = mysql_num_fields(result);
MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
    for (int i = 0; i < num_fields; i++) {
        printf("%st", row[i] ? row[i] : "NULL");
    }
    printf("
");
}
mysql_free_result(result);

上述代码中，首先使用mysql_store_result()函数获取查询结果集并存储在result变量中，如果获取失败，程序会输出错误信息，关闭连接并退出，使用mysql_num_fields()函数获取结果集中的字段数量，然后使用mysql_fetch_row()函数逐行遍历结果集，对于每一行数据，通过循环打印每个字段的值（如果字段值为空，则打印NULL），使用mysql_free_result()函数释放结果集占用的内存。

关闭数据库连接

完成所有操作后，需要关闭与数据库的连接，以释放资源，可以使用mysql_close()函数来实现，示例代码如下：

mysql_close(conn);

完整示例代码

以下是一个完整的使用C语言连接MySQL数据库并执行简单查询的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    const char host = "localhost";
    const char user = "your_username";
    const char pass = "your_password";
    const char dbname = "your_database_name";
    unsigned int port = 3306;
    const char unix_socket = NULL;
    unsigned long client_flag = 0;
    MYSQL conn;
    MYSQL_RES result;
    MYSQL_ROW row;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    if (mysql_real_connect(conn, host, user, pass, dbname, port, unix_socket, client_flag) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed
");
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    char query = "SELECT  FROM test_table";
    if (mysql_query(conn, query)) {
        fprintf(stderr, "SELECT  FROM test_table failed: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "mysql_store_result() failed: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    int num_fields = mysql_num_fields(result);
    while ((row = mysql_fetch_row(result))) {
        for (int i = 0; i < num_fields; i++) {
            printf("%st", row[i] ? row[i] : "NULL");
        }
        printf("
");
    }
    mysql_free_result(result);
    mysql_close(conn);
    return 0;
}

在实际使用中，需要根据自己的数据库配置和需求对上述代码中的相关参数进行调整，为了提高程序的安全性和稳定性，还应该在实际应用中添加更多的错误处理和异常处理逻辑。

FAQs

问题1：如果在连接数据库时出现“Can’t connect to MySQL server on ‘localhost’ (111)”错误，可能是什么原因？

解答：这种错误通常是由于MySQL服务器没有启动或者防火墙阻止了连接导致的，可以检查MySQL服务器是否正在运行，如果是本地测试环境，可以尝试关闭防火墙或者允许MySQL的默认端口（3306）通过防火墙，还需要确认连接参数（如主机名、用户名、密码等）是否正确填写。

问题2：如何修改上述示例代码以连接到SQLite数据库？

解答：要连接到SQLite数据库，需要使用SQLite的C接口库sqlite3，要将包含的头文件从mysql/mysql.h改为sqlite3.h，然后在初始化连接部分，使用sqlite3_open()函数代替mysql_init()和mysql_real_connect()函数，将上述示例代码中的相关部分修改为以下内容：

sqlite3 db;
int rc;
rc = sqlite3_open("your_database_name.db", &db);
if (rc) {
    fprintf(stderr, "Can't open database: %s
", sqlite3_errmsg(db));
    exit(EXIT_FAILURE);
}

后续执行查询和处理结果的代码也需要根据SQLite的API进行相应的修改，执行查询语句可以使用sqlite3_exec()函数，处理结果集可以使用回调函数等方式。