C++ 连接 MySQL 数据库

发表： 分类： 本文字数： 3.9k 阅读时长 ≈ 4 分钟

1、环境准备

环境：VS2019、MySQL8.0.26 x86_64

通过 MySQL 官方 API 连接数据库。

2、添加 MySQL 连接器头文件

新建 C++ 项目，将项目平台改为 x64

在项目名称处点击右键，选择 属性 -> C/C++ -> 常规，在附加包含目录处添加连接器头文件路径：

C:\Program Files\MySQL\MySQL Server 8.0\include，路径根据自己安装目录进行调整。

3、添加静态和动态库依赖

在路径C:\Program Files\MySQL\MySQL Server 8.0\lib下找到 libmysql.lib 和 libmysql.dll文件，将其复制到新建项目的根目录中。

在项目中添加以下代码，使项目链接到libmysql.lib库

1
#pragma comment(lib, "libmysql.lib")

4、利用官方 API 连接数据库

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
#include <iostream>
#include "mysql.h" 
#pragma comment(lib, "libmysql.lib")
using namespace std;

int main()
{
    //创建mysql实例
    MYSQL mysql;
    mysql_init(&mysql);
    if (!mysql_real_connect(&mysql, "localhost", "root", "admin", "itcast", 3306, NULL, 0))
        cout << "数据库连接失败" << endl;
    else
        cout << "数据库连接成功" << endl;

    // 防止中文乱码,设置读取格式为 GBK
    mysql_query(&mysql, "set names gbk");

    // 插入数据
    string insertStr = "INSERT INTO people(name,age) VALUES('测试1', 12)";
    // 执行SQL语句
    if (mysql_query(&mysql, insertStr.c_str()))
        cout << "插入失败：" << mysql_error(&mysql) << endl;
    else
        cout << "插入成功..." << endl;

    // 查询数据
    string sql = "select * from people";
    // 执行SQL语句
    mysql_query(&mysql, sql.c_str()); 
    // 获取查询内容
    MYSQL_RES* result = mysql_store_result(&mysql); 
    // 打印查询行数
    cout << "数据行数：" << result->row_count << endl; 
    cout << "数据行数：" << mysql_affected_rows(&mysql) << endl;
    // 遍历数据
    while (MYSQL_ROW row = mysql_fetch_row(result)) //获取整条数据内容
    {
        for (int i = 0; i < result->field_count; i++)
        {
            if (NULL == row[i])
                cout << " NULL";
            else
                cout << " " << row[i];
        }
        cout << endl;
    }
}

5、MySQL 常用 API 函数

函数名 功能
mysql_affected_rows() 返回被最新的UPDATE, DELETE或INSERT查询影响的行数。
mysql_close() 关闭一个服务器连接。
mysql_connect() 连接一个MySQL服务器。该函数不推荐；使用mysql_real_connect()代替。
mysql_change_user() 改变在一个打开的连接上的用户和数据库。
mysql_create_db() 创建一个数据库。该函数不推荐；而使用SQL命令CREATE DATABASE。
mysql_data_seek() 在一个查询结果集合中搜寻一任意行。
mysql_debug() 用给定字符串做一个DBUG_PUSH。
mysql_drop_db() 抛弃一个数据库。该函数不推荐；而使用SQL命令DROP DATABASE。
mysql_dump_debug_info() 让服务器将调试信息写入日志文件。
mysql_eof() 确定是否已经读到一个结果集合的最后一行。这功能被反对; mysql_errno()或mysql_error()可以相反被使用。
mysql_errno() 返回最近被调用的MySQL函数的出错编号。
mysql_error() 返回最近被调用的MySQL函数的出错消息。
mysql_escape_string() 用在SQL语句中的字符串的转义特殊字符。
mysql_fetch_field() 返回下一个表字段的类型。
mysql_fetch_field_direct () 返回一个表字段的类型，给出一个字段编号。
mysql_fetch_fields() 返回一个所有字段结构的数组。
mysql_fetch_lengths() 返回当前行中所有列的长度。
mysql_fetch_row() 从结果集合中取得下一行。
mysql_field_seek() 把列光标放在一个指定的列上。
mysql_field_count() 返回最近查询的结果列的数量。
mysql_field_tell() 返回用于最后一个mysql_fetch_field()的字段光标的位置。
mysql_free_result() 释放一个结果集合使用的内存。
mysql_get_client_info() 返回客户版本信息。
mysql_get_host_info() 返回一个描述连接的字符串。
mysql_get_proto_info() 返回连接使用的协议版本。
mysql_get_server_info() 返回服务器版本号。
mysql_info() 返回关于最近执行得查询的信息。
mysql_init() 获得或初始化一个MYSQL结构。
mysql_insert_id() 返回有前一个查询为一个AUTO_INCREMENT列生成的ID。
mysql_kill() 杀死一个给定的线程。
mysql_list_dbs() 返回匹配一个简单的正则表达式的数据库名。
mysql_list_fields() 返回匹配一个简单的正则表达式的列名。
mysql_list_processes() 返回当前服务器线程的一张表。
mysql_list_tables() 返回匹配一个简单的正则表达式的表名。
mysql_num_fields() 返回一个结果集合重的列的数量。
mysql_num_rows() 返回一个结果集合中的行的数量。
mysql_options() 设置对mysql_connect()的连接选项。
mysql_ping() 检查对服务器的连接是否正在工作，必要时重新连接。
mysql_query() 执行指定为一个空结尾的字符串的SQL查询。
mysql_real_connect() 连接一个MySQL服务器。
mysql_real_query() 执行指定为带计数的字符串的SQL查询。
mysql_reload() 告诉服务器重装授权表。
mysql_row_seek() 搜索在结果集合中的行，使用从mysql_row_tell()返回的值。
mysql_row_tell() 返回行光标位置。
mysql_select_db() 连接一个数据库。
mysql_shutdown() 关掉数据库服务器。
mysql_stat() 返回作为字符串的服务器状态。
mysql_store_result() 检索一个完整的结果集合给客户。
mysql_thread_id() 返回当前线程的ID。
mysql_use_result() 初始化一个一行一行地结果集合的检索。