使用C++操作MySQL数据库|极客教程

使用C++操作MySQL数据库

简介

MySQL 是一个开源的关系型数据库管理系统，被广泛应用于Web应用程序的开发中。在C++中，我们可以使用MySQL提供的C API来操作MySQL数据库。本文将介绍如何在C++中连接MySQL数据库、执行SQL语句、查询数据等操作。

环境配置

在开始之前，我们需要安装MySQL数据库并下载MySQL C API的头文件以及库文件。具体步骤可以参考MySQL官方文档。

连接数据库

首先，我们需要包含MySQL C API的头文件，并链接MySQL库文件。

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

接下来，在程序中创建一个MySQL的连接对象，并使用mysql_real_connect函数连接到MySQL数据库。

MYSQL *conn;
conn = mysql_init(NULL);

if (mysql_real_connect(conn, "localhost", "username", "password", "database", 0, NULL, 0) == NULL) {
    std::cerr << "Failed to connect to database: Error: " << mysql_error(conn) << std::endl;
    mysql_close(conn);
    return -1;
}

std::cout << "Connected to MySQL database" << std::endl;

在上面的代码中，我们使用mysql_init函数初始化一个MySQL连接对象，并通过mysql_real_connect函数连接到指定的MySQL数据库。其中，localhost 是MySQL服务器地址，username 是连接数据库的用户名，password 是连接数据库的密码，database 是要连接的数据库名称。

如果连接成功，将输出Connected to MySQL database，否则输出错误信息并退出程序。

执行SQL语句

在连接到MySQL数据库之后，我们可以执行SQL语句来操作数据库。下面是一个示例，执行一个创建表的SQL语句。

if (mysql_query(conn, "CREATE TABLE IF NOT EXISTS users (id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(50))") != 0) {
    std::cerr << "Failed to create table: Error: " << mysql_error(conn) << std::endl;
    mysql_close(conn);
    return -1;
}

std::cout << "Table created successfully" << std::endl;

在上面的代码中，我们使用mysql_query函数执行一个创建表的SQL语句。如果执行成功，将输出Table created successfully，否则输出错误信息并退出程序。

查询数据

除了执行SQL语句来操作数据库之外，我们还可以查询数据库中的数据。下面是一个示例，查询表中的数据并输出到控制台。

if (mysql_query(conn, "SELECT * FROM users") != 0) {
    std::cerr << "Failed to query table: Error: " << mysql_error(conn) << std::endl;
    mysql_close(conn);
    return -1;
}

MYSQL_RES *res = mysql_store_result(conn);
MYSQL_ROW row;

while ((row = mysql_fetch_row(res))) {
    std::cout << "ID: " << row[0] << ", Name: " << row[1] << std::endl;
}

mysql_free_result(res);

在上面的代码中，我们使用mysql_query函数执行一个查询表的SQL语句，并通过mysql_store_result函数获取查询结果的集合。然后通过mysql_fetch_row函数逐行获取查询结果，并输出到控制台。

断开连接

最后，在程序结束之前，我们需要断开与MySQL数据库的连接。

mysql_close(conn);

完整示例

下面是一个完整的示例，演示了如何在C++中连接MySQL数据库、执行SQL语句、查询数据等操作。

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

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

    if (mysql_real_connect(conn, "localhost", "username", "password", "database", 0, NULL, 0) == NULL) {
        std::cerr << "Failed to connect to database: Error: " << mysql_error(conn) << std::endl;
        mysql_close(conn);
        return -1;
    }

    std::cout << "Connected to MySQL database" << std::endl;

    if (mysql_query(conn, "CREATE TABLE IF NOT EXISTS users (id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(50))") != 0) {
        std::cerr << "Failed to create table: Error: " << mysql_error(conn) << std::endl;
        mysql_close(conn);
        return -1;
    }

    std::cout << "Table created successfully" << std::endl;

    if (mysql_query(conn, "SELECT * FROM users") != 0) {
        std::cerr << "Failed to query table: Error: " << mysql_error(conn) << std::endl;
        mysql_close(conn);
        return -1;
    }

    MYSQL_RES *res = mysql_store_result(conn);
    MYSQL_ROW row;

    while ((row = mysql_fetch_row(res))) {
        std::cout << "ID: " << row[0] << ", Name: " << row[1] << std::endl;
    }

    mysql_free_result(res);
    mysql_close(conn);

    return 0;
}