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

c数据库连接

admin
行业动态
2025-02-22
1

在C语言中，可通过安装相应数据库开发库（如MySQL的libmysqlclient等），包含头文件，使用对应API函数（如mysql_connect等）来建立与数据库的连接，实现数据的存储、查询等操作。

在C语言中，连接数据库是一项常见且重要的任务，它允许程序与数据库进行交互，实现数据的存储、查询和管理，以下是使用C语言连接MySQL数据库的详细步骤和示例代码：

一、准备工作

1、安装MySQL数据库：确保你的系统上已经安装了MySQL数据库，你可以从MySQL官方网站下载并安装适合你操作系统的版本。

2、获取MySQL C API库：为了在C语言中使用MySQL数据库，你需要获取MySQL C API库，这通常可以通过安装MySQL开发包或从MySQL官方网站下载得到。

二、包含头文件

在你的C程序中，需要包含MySQL C API提供的头文件mysql.h，这个头文件包含了连接数据库、执行SQL语句等所需的函数声明和数据类型定义。

#include <mysql.h>

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

使用mysql_init()函数初始化一个MYSQL类型的连接句柄，这个句柄将用于后续的数据库连接操作。

c数据库连接

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

四、设置连接参数

使用mysql_real_connect()函数来设置数据库服务器的连接参数，包括服务器主机名、用户名、密码、数据库名和端口号等，如果连接失败，函数将返回NULL。

const char *host = "localhost";
const char *user = "root";
const char *pass = "your_password";
const char *dbname = "testdb";
unsigned int port = 3306;
con = mysql_real_connect(con, host, user, pass, dbname, port, NULL, 0);
if (con == NULL) {
    fprintf(stderr, "%s
", mysql_error(con));
    mysql_close(con);
    exit(1);
}

五、执行SQL查询

一旦成功连接到数据库服务器，你就可以使用mysql_query()函数来执行SQL查询语句了，这个函数接受两个参数：一个是数据库连接句柄，另一个是要执行的SQL查询字符串。

const char *sql = "SELECT * FROM users";
if (mysql_query(con, sql)) {
    fprintf(stderr, "%s
", mysql_error(con));
    mysql_close(con);
    exit(1);
}

六、处理查询结果

使用mysql_store_result()函数来获取查询结果集，并使用mysql_fetch_row()函数逐行读取结果集中的数据。

MYSQL_RES *result = mysql_store_result(con);
if (result == NULL) {
    fprintf(stderr, "%s
", mysql_error(con));
    mysql_close(con);
    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("%s ", row[i] ? row[i] : "NULL");
    }
    printf("
");
}
mysql_free_result(result);

七、关闭连接

不要忘记在程序结束时关闭数据库连接，以释放资源。

c数据库连接

mysql_close(con);

八、完整示例代码

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

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *con = mysql_init(NULL);
    if (con == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    const char *host = "localhost";
    const char *user = "root";
    const char *pass = "your_password"; // set me first
    const char *dbname = "testdb";
    unsigned int port = 3306;
    con = mysql_real_connect(con, host, user, pass, dbname, port, NULL, 0);
    if (con == NULL) {
        fprintf(stderr, "%s
", mysql_error(con));
        mysql_close(con);
        exit(EXIT_FAILURE);
    }
    const char *sql = "SELECT * FROM users";
    if (mysql_query(con, sql)) {
        fprintf(stderr, "%s
", mysql_error(con));
        mysql_close(con);
        exit(EXIT_FAILURE);
    }
    MYSQL_RES *result = mysql_store_result(con);
    if (result == NULL) {
        fprintf(stderr, "%s
", mysql_error(con));
        mysql_close(con);
        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("%s ", row[i] ? row[i] : "NULL"); 
        } 
        printf("
"); 
    }
    mysql_free_result(result);
    mysql_close(con);
    exit(EXIT_SUCCESS);
}