c++怎么连接和操作MySQL数据库_c++数据库访问与SQL执行实例-C++-PHP中文网

c++怎么连接和操作MySQL数据库_c++数据库访问与SQL执行实例

冰火之心

发布： 2025-11-17 18:29:17

原创

944人浏览过

答案是使用MySQL C API连接数据库需先安装开发库，包含mysql.h头文件，调用mysql_init初始化，mysql_real_connect建立连接，执行查询或插入操作后释放资源。

c++怎么连接和操作mysql数据库_c++数据库访问与sql执行实例

在C++中连接和操作MySQL数据库，通常使用MySQL官方提供的C API（即 MySQL Connector/C）或其封装库如 MySQL++。本文以原生的 MySQL C API 为例，介绍如何连接、查询、插入数据，并给出完整实例。

1. 环境准备与依赖安装

确保系统已安装 MySQL 开发库：

Ubuntu/Debian：sudo apt-get install libmysqlclient-dev
CentOS/RHEL：sudo yum install mysql-devel
Windows：下载并配置 MySQL Connector/C，设置头文件和库路径

编译时需链接库：-lmysqlclient

2. 包含头文件并初始化连接

使用 <mysql.h> 提供的接口进行数据库操作。

立即学习“C++免费学习笔记（深入）”；

#include <iostream>
#include <mysql.h>

int main() {
    MYSQL *conn;
    conn = mysql_init(NULL);

    if (!conn) {
        std::cerr << "初始化失败" << std::endl;
        return 1;
    }

    // 连接数据库
    if (!mysql_real_connect(conn, "localhost", "root", "password",
                           "testdb", 3306, NULL, 0)) {
        std::cerr << "连接失败: " << mysql_error(conn) << std::endl;
        mysql_close(conn);
        return 1;
    }

    std::cout << "数据库连接成功！" << std::endl;

登录后复制

说明：

mysql_init() 初始化连接句柄
mysql_real_connect() 建立连接，参数依次为：主机、用户名、密码、数据库名、端口等

3. 执行SQL语句

使用 mysql_query() 执行非查询语句，用 mysql_use_result() 或 mysql_store_result() 处理查询结果。

阿里云-虚拟数字人

阿里云-虚拟数字人是什么？ ...

查看详情

    // 插入数据
    const char *insert_sql = "INSERT INTO users (name, age) VALUES ('张三', 25)";
    if (mysql_query(conn, insert_sql)) {
        std::cerr << "插入失败: " << mysql_error(conn) << std::endl;
    } else {
        std::cout << "插入成功，影响行数: " << mysql_affected_rows(conn) << std::endl;
    }

    // 查询数据
    if (mysql_query(conn, "SELECT id, name, age FROM users")) {
        std::cerr << "查询失败: " << mysql_error(conn) << std::endl;
    } else {
        MYSQL_RES *result = mysql_store_result(conn);
        if (result) {
            MYSQL_ROW row;
            while ((row = mysql_fetch_row(result))) {
                std::cout << "ID: " << row[0] 
                          << ", 姓名: " << row[1] 
                          << ", 年龄: " << row[2] << std::endl;
            }
            mysql_free_result(result);
        }
    }

登录后复制

关键函数说明：

mysql_query()：执行SQL字符串
mysql_store_result()：将结果集全部取回内存
mysql_fetch_row()：逐行获取数据，返回字符串数组
mysql_free_result()：释放结果集资源

4. 预处理语句（防SQL注入）

对于带参数的操作，推荐使用预处理语句。

    MYSQL_STMT *stmt = mysql_stmt_init(conn);
    const char *sql = "INSERT INTO users (name, age) VALUES (?, ?)";
    
    if (mysql_stmt_prepare(stmt, sql, strlen(sql))) {
        std::cerr << "预处理失败: " << mysql_stmt_error(stmt) << std::endl;
        mysql_stmt_close(stmt);
        return 1;
    }

    // 绑定参数
    MYSQL_BIND bind[2];
    std::string name = "李四";
    int age = 30;

    memset(bind, 0, sizeof(bind));
    bind[0].buffer_type = MYSQL_TYPE_STRING;
    bind[0].buffer = (char*)name.c_str();
    bind[0].buffer_length = name.length();

    bind[1].buffer_type = MYSQL_TYPE_LONG;
    bind[1].buffer = &age;

    if (mysql_stmt_bind_param(stmt, bind)) {
        std::cerr << "绑定参数失败: " << mysql_stmt_error(stmt) << std::endl;
    }

    if (mysql_stmt_execute(stmt)) {
        std::cerr << "执行失败: " << mysql_stmt_error(stmt) << std::endl;
    } else {
        std::cout << "预处理插入成功" << std::endl;
    }

    mysql_stmt_close(stmt);

登录后复制