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

如何编写 C 语言代码来连接 MySQL 数据库？

admin
行业动态
2025-01-17
2

要连接MySQL数据库，可以使用Python的 mysql-connector-python库。以下是一个简单的示例代码：，，“

python，import mysql.connector，，# 创建数据库连接，conn = mysql.connector.connect(， host="localhost",， user="yourusername",， password="yourpassword",， database="yourdatabase"，)，，# 检查连接是否成功，if conn.is_connected():， print("Connected to MySQL database")，else:， print("Failed to connect to MySQL database")，，# 关闭连接，conn.close()，

` ，，请确保替换yourusername 、yourpassword 和yourdatabase`为实际的数据库用户名、密码和数据库名称。

在使用C语言连接MySQL数据库时，通常需要通过MySQL提供的C API来实现，以下是详细的步骤和示例代码：

安装MySQL开发库

确保你的系统上安装了MySQL开发库，在Linux系统上，你可以使用包管理器来安装，

sudo apt-get install libmysqlclient-dev

包含必要的头文件

在你的C程序中，需要包含MySQL的头文件：

#include <mysql/mysql.h>

初始化MySQL连接

创建一个MYSQL结构体实例，用于存储连接信息，然后使用mysql_init()函数初始化该实例。

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

设置连接参数并连接数据库

使用mysql_real_connect()函数连接到MySQL服务器，你需要提供主机名、用户名、密码、数据库名等信息。

如何编写 C 语言代码来连接 MySQL 数据库？

if (mysql_real_connect(conn, "localhost", "username", "password", "database", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

执行SQL查询

使用mysql_query()函数执行SQL查询，如果查询成功，可以使用mysql_store_result()或mysql_use_result()获取结果集。

if (mysql_query(conn, "SELECT * FROM table_name")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}
MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

处理查询结果

遍历结果集，处理每一行数据。

MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
    for (int i = 0; i < mysql_num_fields(result); i++) {
        printf("%s ", row[i] ? row[i] : "NULL");
    }
    printf("
");
}

释放资源并关闭连接

使用完毕后，释放结果集并关闭MySQL连接。

如何编写 C 语言代码来连接 MySQL 数据库？

mysql_free_result(result);
mysql_close(conn);

完整示例代码

以下是一个完整的示例代码，展示了如何在C语言中使用MySQL C API连接数据库并执行查询：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(1);
    }
    if (mysql_real_connect(conn, "localhost", "username", "password", "database", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    if (mysql_query(conn, "SELECT * FROM table_name")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    MYSQL_RES *result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result))) {
        for (int i = 0; i < mysql_num_fields(result); i++) {
            printf("%s ", row[i] ? row[i] : "NULL");
        }
        printf("
");
    }
    mysql_free_result(result);
    mysql_close(conn);
    return 0;
}