C++如何连接MySQL数据库?API使用示例详解

来源:Android社区作者:USDT程序员头衔:程序员
导读:本期聚焦于小伙伴创作的《C++如何连接MySQL数据库?API使用示例详解》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《C++如何连接MySQL数据库?API使用示例详解》有用,将其分享出去将是对创作者最好的鼓励。

C++连接MySQL数据库主要依赖MySQL官方提供的C语言API接口,也就是MySQL C API,该接口可以直接在C++项目中调用,实现数据库的连接、查询、修改等各类操作。在使用前需要先完成对应的环境配置,确保开发环境可以正常加载MySQL的相关库文件。

C++如何连接MySQL数据库?API使用示例详解

环境准备

首先需要安装MySQL数据库服务,同时获取MySQL的开发库文件。如果是Windows系统,可以下载MySQL Installer,安装时勾选开发组件,获取include目录下的头文件和lib目录下的库文件。如果是Linux系统,可以通过包管理器安装libmysqlclient-dev包,安装完成后头文件会存放在/usr/include/mysql目录,库文件存放在/usr/lib目录。

在项目中需要引入对应的头文件,同时链接MySQL的库文件。如果是使用GCC编译,需要添加-lmysqlclient参数,如果是使用Visual Studio,需要在项目属性中添加头文件目录和库文件目录,同时在链接器输入中添加libmysql.lib。

核心API介绍

连接和操作MySQL数据库需要用到以下几个核心函数:

  • mysql_init:初始化一个MYSQL对象,用于后续的连接和操作
  • mysql_real_connect:使用指定的参数连接MySQL数据库
  • mysql_query:执行SQL语句,支持查询、插入、修改、删除等操作
  • mysql_store_result:获取查询语句返回的结果集
  • mysql_fetch_row:从结果集中逐行获取数据
  • mysql_free_result:释放结果集占用的内存
  • mysql_close:关闭数据库连接,释放相关资源

完整连接与操作示例

以下是一个完整的C++连接MySQL数据库并执行各类操作的示例代码,代码中包含详细的注释说明每一步的作用:

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

using namespace std;

int main() {
    // 初始化MYSQL对象
    MYSQL* mysql = mysql_init(nullptr);
    if (mysql == nullptr) {
        cout << "MySQL初始化失败" << endl;
        return -1;
    }

    // 设置数据库连接参数
    const char* host = "127.0.0.1";    // 数据库地址
    const char* user = "root";        // 数据库用户名
    const char* password = "123456";  // 数据库密码
    const char* db = "test_db";       // 要连接的数据库名
    unsigned int port = 3306;         // 数据库端口
    const char* unix_socket = nullptr;
    unsigned long client_flag = 0;

    // 连接数据库
    MYSQL* connect_ret = mysql_real_connect(mysql, host, user, password, db, port, unix_socket, client_flag);
    if (connect_ret == nullptr) {
        cout << "数据库连接失败,错误信息:" << mysql_error(mysql) << endl;
        mysql_close(mysql);
        return -1;
    }
    cout << "数据库连接成功" << endl;

    // 执行查询操作,查询user表的所有数据
    string query_sql = "SELECT id, name, age FROM user";
    if (mysql_query(mysql, query_sql.c_str()) != 0) {
        cout << "查询语句执行失败,错误信息:" << mysql_error(mysql) << endl;
    } else {
        // 获取查询结果集
        MYSQL_RES* result = mysql_store_result(mysql);
        if (result == nullptr) {
            cout << "获取结果集失败,错误信息:" << mysql_error(mysql) << endl;
        } else {
            // 获取结果集的列数
            unsigned int field_count = mysql_num_fields(result);
            // 获取列名
            MYSQL_FIELD* fields = mysql_fetch_fields(result);
            cout << "查询结果:" << endl;
            for (unsigned int i = 0; i < field_count; i++) {
                cout << fields[i].name << "t";
            }
            cout << endl;

            // 逐行获取结果数据
            MYSQL_ROW row;
            while ((row = mysql_fetch_row(result)) != nullptr) {
                for (unsigned int i = 0; i < field_count; i++) {
                    cout << (row[i] ? row[i] : "NULL") << "t";
                }
                cout << endl;
            }

            // 释放结果集
            mysql_free_result(result);
        }
    }

    // 执行插入操作
    string insert_sql = "INSERT INTO user (name, age) VALUES ('张三', 25)";
    if (mysql_query(mysql, insert_sql.c_str()) != 0) {
        cout << "插入语句执行失败,错误信息:" << mysql_error(mysql) << endl;
    } else {
        cout << "数据插入成功,影响行数:" << mysql_affected_rows(mysql) << endl;
    }

    // 执行修改操作
    string update_sql = "UPDATE user SET age = 26 WHERE name = '张三'";
    if (mysql_query(mysql, update_sql.c_str()) != 0) {
        cout << "修改语句执行失败,错误信息:" << mysql_error(mysql) << endl;
    } else {
        cout << "数据修改成功,影响行数:" << mysql_affected_rows(mysql) << endl;
    }

    // 执行删除操作
    string delete_sql = "DELETE FROM user WHERE name = '张三'";
    if (mysql_query(mysql, delete_sql.c_str()) != 0) {
        cout << "删除语句执行失败,错误信息:" << mysql_error(mysql) << endl;
    } else {
        cout << "数据删除成功,影响行数:" << mysql_affected_rows(mysql) << endl;
    }

    // 关闭数据库连接
    mysql_close(mysql);
    cout << "数据库连接已关闭" << endl;

    return 0;
}

注意事项

在实际使用中需要注意以下几点:

  • 每次执行mysql_query之后,如果是查询语句,需要及时获取结果集并释放,避免内存泄漏
  • SQL语句拼接时需要注意防范SQL注入问题,如果是用户输入的参数,建议使用预处理语句接口mysql_stmt_init等函数处理
  • 数据库连接参数不要硬编码在代码中,建议通过配置文件或者环境变量获取,提高代码的安全性和可维护性
  • 操作完成后一定要调用mysql_close关闭连接,释放相关资源

常见问题排查

如果连接数据库失败,可以先检查以下几点:

  • MySQL服务是否正常运行,端口是否正确
  • 数据库用户名和密码是否正确,对应的用户是否有访问目标数据库的权限
  • 开发环境的头文件和库文件路径是否配置正确,编译时是否成功链接了MySQL的库文件
  • 如果是远程连接,需要检查MySQL是否开启了远程访问权限,防火墙是否放行了对应端口

C++MySQLMySQL_C_API数据库连接数据库操作修改时间:2026-07-10 16:42:34

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。