c 执行数据库语句

一、准备工作

在C语言中执行数据库语句，首先需要确保已经安装并配置好了相应的数据库系统，比如常见的MySQL数据库，还需要有对应的C语言数据库连接库，对于MySQL而言，通常会用到MySQL Connector/C。

以MySQL为例，要使用MySQL Connector/C，需要先从官方网站下载对应版本的连接器，然后按照其提供的安装说明进行安装配置，一般涉及到将库文件放置在合适的系统路径下，以及设置好相关的环境变量等操作，这样才能保证后续在C程序中可以正确引用和使用它。

二、基本步骤

1、包含头文件

在C源文件的开头，需要包含MySQL Connector/C提供的头文件，如下所示：

#include <mysql/mysql.h>

这个头文件包含了与MySQL数据库进行交互所需的各种函数声明、数据结构定义等内容，是实现数据库操作的基础。

2、初始化数据库连接句柄

通过调用mysql_init()函数来初始化一个MYSQL类型的结构体变量，该变量后续将用于存储数据库连接的相关信息，示例代码如下：

MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

这里先声明了一个指向MYSQL结构体的指针conn，然后使用mysql_init函数对其进行初始化，如果初始化失败（返回NULL），则打印错误信息并退出程序。

3、建立与数据库的连接

使用mysql_real_connect()函数来建立与目标数据库的实际连接，需要传入多个参数，例如服务器地址、用户名、密码、数据库名等，示例如下：

if (mysql_real_connect(conn, "localhost", "your_username", "your_password", "database_name", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

“localhost”表示数据库服务器在本机上运行（如果是远程服务器，则需要填写对应的IP地址或主机名），“your_username”和“your_password”要替换成实际的数据库用户名和密码，“database_name”则是要连接的数据库名称，如果连接失败，同样要打印错误信息、关闭连接句柄并退出程序。

4、执行SQL语句

当成功建立连接后，就可以使用mysql_query()函数来执行具体的SQL语句了，执行一条简单的查询语句：

if (mysql_query(conn, "SELECT * FROM your_table")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

这里的“SELECT * FROM your_table”是要执行的SQL查询语句，“your_table”需替换为实际的表名，如果执行SQL语句出错，也会进行相应的错误处理操作。

5、处理查询结果（针对查询操作）

如果执行的是查询语句（如上述的SELECT语句），那么需要对查询结果进行处理，通常可以使用mysql_store_result()函数来获取查询结果集，然后通过循环结合mysql_fetch_row()函数来逐行读取结果集中的数据，示例如下：

MYSQL_RES *result;
result = mysql_store_result(conn);
if (result == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
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);

这段代码先获取查询结果集到result变量中，然后通过mysql_num_fields()函数获取结果集中字段的数量，接着使用mysql_fetch_row()在循环中逐行读取每行的数据（每行数据以字符串数组的形式返回），最后打印输出每个字段的值（如果字段值为空则显示“NULL”），处理完结果集后调用mysql_free_result()释放相关资源。

6、关闭数据库连接

在所有数据库操作完成后，需要及时关闭与数据库的连接，以释放占用的资源，使用mysql_close()函数即可，如下：

mysql_close(conn);

三、示例代码整合

以下是一个简单的完整示例代码，实现了连接到数据库并查询表中所有数据的功能：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *result;
    MYSQL_ROW row;
    int num_fields;
    // 初始化连接句柄
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 建立连接
    if (mysql_real_connect(conn, "localhost", "root", "password", "test_db", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 执行查询语句
    if (mysql_query(conn, "SELECT * FROM student")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 处理查询结果
    result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    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;
}

在这个示例中，假设数据库名为test_db，表名为student，并且使用了用户名“root”和对应的密码“password”进行连接（实际使用时需替换为正确的信息），运行该程序会连接到指定数据库并查询student表中的所有数据，然后打印输出到控制台。

四、相关问答FAQs

问题1：如果在执行mysql_real_connect()函数时出现“Can’t connect to MySQL server on ‘localhost’ (10061)”这样的错误提示，是什么原因以及如何解决？

解答：这种错误提示通常是因为MySQL服务没有启动导致的，可以通过以下步骤来解决：

在Windows系统中，打开命令提示符，输入services.msc并回车，找到“MySQL”服务（服务名称可能因安装版本略有不同），右键点击选择“启动”，确保其状态变为“已启动”。

在Linux系统中，可以使用命令sudo systemctl start mysql（或者根据具体的MySQL服务名称可能是mysqld等）来启动MySQL服务，然后再次尝试运行C程序进行连接。

问题2：当执行插入数据的SQL语句时，如何判断数据是否成功插入到数据库中呢？

解答：在执行插入语句（如INSERT INTO table_name (column1, column2) VALUES (value1, value2)）后，可以通过检查mysql_affected_rows()函数的返回值来判断插入是否成功，该函数返回受影响的行数，对于插入操作来说，如果返回值大于0，则表示至少有一行数据成功插入到了数据库中；如果返回值为0，则可能插入失败（比如违反了数据库的约束条件等情况），示例代码如下：

char *insert_sql = "INSERT INTO student (name, age) VALUES ('Tom', 20)";
if (mysql_query(conn, insert_sql)) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
} else {
    int affected_rows = mysql_affected_rows(conn);
    if (affected_rows > 0) {
        printf("Data inserted successfully.
");
    } else {
        printf("Insertion failed.
");
    }
}

这段代码先执行插入语句，然后根据mysql_affected_rows()的返回值来判断插入操作是否成功，并输出相应的提示信息。

小编有话说

在C语言中执行数据库语句可以实现很多强大的功能，比如构建复杂的数据处理应用程序等，但在使用过程中，一定要注意正确处理各种可能出现的错误情况，像数据库连接失败、SQL语句执行错误等，并且要做好资源的管理和释放工作，避免出现内存泄漏等问题，不同的数据库系统可能在具体的细节和函数使用上会有一些差异，要根据实际使用的数据库文档来准确运用相关函数哦，希望以上内容能帮助大家更好地理解和掌握在C语言中执行数据库语句的方法呀。