c++如何连接MySQL数据库 c++ MySQL Connector/C++教程【实例】

推荐使用官方 MySQL Connector/C++(8.0.x 版本),基于 JDBC 风格 API,支持预处理语句、事务、SSL 和 X DevAPI;需正确安装依赖、配置连接参数并妥善管理资源。

使用 C++ 连接 MySQL 数据库,推荐官方方案:MySQL Connector/C++(注意不是旧版 MySQL++ 或 ODBC)。它基于 JDBC 风格 API,支持预处理语句、事务、SSL 和 X DevAPI(8.0+),是目前最稳定、持续维护的 C++ MySQL 客户端。

1. 环境准备与依赖安装

确保已安装 MySQL Server(如 8.0/5.7)和对应版本的 MySQL Connector/C++(推荐 8.0.x 版本,与 MySQL 8 兼容性更好)。

  • Linux(Ubuntu/Debian):sudo apt install libmysqlcppconn-dev
  • macOS(Homebrew):brew install mysql-connector-c++
  • Windows:从 MySQL 官网下载 MSI 安装包,安装后记下安装路径(如 C:\Program Files\MySQL\Connector C++ 8.0

编译时需链接 mysqlcppconn8(新版)或 mysqlcppconn(旧版),头文件路径通常为 mysqlx/xdevapi.h(X API)或 sql/mysql_connection.h(传统 SQL API)。

2. 基础连接与查询示例(SQL API)

以下是最简可用的同步连接 + SELECT 示例,使用传统 SQL 接口(非 X DevAPI):

#include 
#include 
#include 
#include 
#include 

int main() { sql::mysql::MySQL_Driver driver; sql::Connection con; sql::Statement stmt; sql::ResultSet res;

try {
    driver = sql::mysql::get_mysql_driver_instance();
    // 格式:host:port:database:user:password
    con = driver->connect("tcp://127.0.0.1:3306", "root", "your_password");
    con->setSchema("testdb"); // 切换数据库

    stmt = con->createStatement();
    res = stmt->executeQuery("SELECT id, name FROM users LIMIT 3");

    while (res->next()) {
        std::cout << "ID: " << res->getInt("id")
                  << ", Name: " << res->getString("name") << std::endl;
    }

} catch (sql::SQLException &e) {
    std::cerr << "# ERR: " << e.what() << std::endl;
    std::cerr << "(MySQL error code: " << e.getErrorCode()
              << ", SQLState: " << e.getSQLState() << ")" << std::endl;
}

delete res;
delete stmt;
delete con;
return 0;

}

编译命令(Linux/macOS 示例):

g++ -o demo demo.cpp -lmysqlcppconn8

注意:若报 undefined reference,确认库名是否匹配(libmysqlcppconn8.solibmysqlcppconn.so),必要时加 -L/path/to/lib 指定路径。

3. 使用预处理语句防注入(推荐实践)

执行 INSERT/UPDATE 时务必用 PreparedStatement,避免字符串拼接:

sql::PreparedStatement *pstmt = con->prepareStatement(
    "INSERT INTO users (name, email) VALUES (?, ?)"
);
pstmt->setString(1, "Alice");
pstmt->setString(2, "alice@example.com");
pstmt->executeUpdate(); // 返回影响行数
delete pstmt;

参数索引从 1 开始;支持 setIntsetDoublesetNull 等类型方法。

4. 常见问题速查

  • 报错 “Authentication plugin 'caching_sha2_password' cannot be loaded”:MySQL 8 默认认证插件不兼容旧客户端。解决方法:启动 MySQL 时加 --default-authentication-plugin=mysql_native_password,或修改用户(推荐):
    ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'your_password'; FLUSH PRIVILEGES;
  • 找不到头文件或库:检查 pkg-config 是否可用(pkg-config --modversion mysqlcppconn8),或手动指定 -I/usr/include/mysql-cppconn-8-L/usr/lib/x86_64-linux-gnu
  • 程序崩溃在 connect() 后:确认 MySQL 服务正在运行、防火墙放行 3306、用户名密码正确、用户有远程/本地连接权限(GRANT ALL ON testdb.* TO 'user'@'%' IDENTIFIED BY 'pwd';

不复杂但容易忽略。写完记得释放资源,生产环境建议封装 ConnectionPool 或用 RAII 智能指针管理生命周期。