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

如何在C语言中正确构建数据库连接字符串？

admin
行业动态
2025-01-25
3069

数据库连接字符串是用于将应用程序与数据库服务器连接的一组参数，包含服务器地址、端口号、数据库名称、用户名和密码等。

在C语言中，连接数据库通常需要借助第三方库，如MySQL的Connector/C、PostgreSQL的libpq等，这些库提供了与数据库交互的接口函数和数据结构，下面以MySQL为例，详细讲解如何在C语言中连接数据库，并执行基本的查询操作。

如何在C语言中正确构建数据库连接字符串？第1张

准备工作

你需要安装MySQL服务器和MySQL Connector/C库，可以从MySQL官方网站下载相应的安装包并进行安装。

包含必要的头文件

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

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

初始化MySQL连接

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

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

连接到数据库

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

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

执行查询

使用mysql_query()函数执行SQL查询，查询所有用户的信息：

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

处理查询结果

使用mysql_store_result()函数获取查询结果，并使用mysql_fetch_row()函数遍历结果集。

MYSQL_RES *result;
MYSQL_ROW row;
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);
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()函数关闭与数据库的连接。

mysql_close(conn);

完整示例代码

以下是一个完整的C程序示例，演示了如何连接MySQL数据库并查询所有用户信息：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *result;
    MYSQL_ROW row;
    const char *host = "localhost";
    const char *user = "root";
    const char *pass = "password";
    const char *dbname = "testdb";
    unsigned int port = 3306;
    const char *unix_socket = NULL;
    unsigned long client_flag = 0;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, host, user, pass, dbname, port, unix_socket, client_flag) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    if (mysql_query(conn, "SELECT * FROM users")) {
        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);
    }
    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

Q1: 如果连接数据库时出现“Access denied for user”错误，应该怎么办？

A1: 这通常是由于提供的用户名或密码不正确，请检查你的数据库用户名和密码是否正确，并确保该用户有足够的权限访问指定的数据库。

Q2: 如何在C语言中执行插入、更新或删除操作？

A2: 在C语言中执行插入、更新或删除操作与执行查询类似，只需将相应的SQL语句传递给mysql_query()函数即可，要插入一条新记录，可以使用如下代码：

char *insert_query = "INSERT INTO users (username, email) VALUES ('newuser', 'newuser@example.com')";
if (mysql_query(conn, insert_query)) {
    fprintf(stderr, "%s
", mysql_error(conn));
}