在 Ubuntu 下使用 C++ 实现 MySql 基础操作#

前置条件#

安装 C++ MySeql 驱动#

在 Ubuntu 终端中执行下列命令:

1
sudo apt updata
2
sudo apt install libmysqlcppconn-dev

包含头文件: <mysql_drver.h> <mysql_connection.h>

第一次链接到数据库#

1
#include <mysql_driver.h>
2
#include <mysql_connection.h>
3

4
#include <iostream>
5

6
int main(){
7
    sql::mysql::MySQL_Driver* driver;
8

9
    driver = sql::mysql::get_mysql_driver_instance();
10

11
    sql::Connection* conn = driver->connect(
12
        "tcp://127.0.0.1:3306",
13
        "root",
14
        "password"
15
    );
16

17
    conn->setSchema("test");
18

19
    std::cout << "connect success";
20
}

语句解释#

定义驱动对象#

单例模式创建 MySql 操作入口:

单例模式: 整个程序运行期间, 只允许存在一个对象。

1
sql::MySQL_Driver* driver;

获取 MySql 驱动#

1
get_mysql_driver_instance();

与数据库建立连接#

指针访问指针对象成员:

1
driver->connect()

其中所包含参数:

"tcp://127.0.0.1:3306" 服务器地址, 3306 是数据库的默认端口号。

在 MySql 中执行 SHOW GLOBAL VARIABLES LIKE 'port'; 以获取端口。

"root" 用户名。
"password" 数据库密码。

Ubuntu 下可以直接使用 sudo mysql 直接进入。但是 C++ 不能直接链接, 因此需要创建一个专用的链接用户。执行下面的语句可以创建一个用户:
1
CREATE USER 'cpp_user'@'localhost' IDENTIFIED BY '123456';
上述语句用于创建一个名为 cpp_user , 密码为 123456 的用户。对新创建的用户进行授权:
1
GRANT ALL PRIVILEGES ON test.* TO 'cpp_user'@'localhost';
允许 cpp_user 操作 test数据库。刷新:
1
FLUSH PRIVILEGES;
此后在代码中可以使用上述创建账号进行创建。

完成此步骤后 C++ 已经与 MySql 成功建立 TCP 链接。

选择需要使用的数据库#

1
conn->setSchema("test");

等价于:

1
USE test;

之后所有的操作都将使用 test数据库。

执行基础操作#

创建 SQL 执行对象#

1
sql::PreparedStatement* stmt;

表示一条准备执行的 SQL语句。

插入数据#

创建插入模板:

需要插入 <cppconn/prepared_statement.h> 头文件

1
stmt = conn -> prepareStatement("INSERT INTO users(username, password) VALUES(?, ?)");

使用 ? 作为插入占位符, 防止恶意输入。

填入插入数据#

对占位符进行填充:

1
stmt -> setString(1, username);
2
stmt -> setString(2, password);

占位符起始从 1 开始。

提交语句到数据库#

将模板中的内容添加进数据库:

1
stmt -> execute();

完整的测试用例#

链接至数据库 test，并尝试向库中 users 表添加一条数据:

1
#include <mysql_driver.h>
2
#include <mysql_connection.h>
3
#include <cppconn/prepared_statement.h>
4

5
#include <string>
6

7
int main(){
8
    sql::mysql::MySQL_Driver* driver;
9

10
    driver = sql::mysql::get_mysql_driver_instance();
11

12
    sql::Connection* conn = driver->connect(
13
        "tcp://127.0.0.1:3306",
14
        "cpp_user",
15
        "123456"
16
    );
17

18
    conn->setSchema("test");
19

20
    sql::PreparedStatement* stmt;
21

22
    stmt = conn -> prepareStatement("INSERT INTO users(username, password) VALUES(?, ?)");
23

24
    std::string username = "LINKONG";
25
    std::string password = "123456";
26

27
    stmt->setString(1, username);
28
    stmt->setString(2, password);
29

30
    stmt->execute();
31

32
    delete stmt;
33
    delete conn;
34
}