【MySQL】使用C/C++访问MySQL_c++ mysql

本篇环境是云服务器Centos上的MySQL
版本;

一. 环境准备

使用C/C++访问MySQL，首先需要MySQL的开发者库

这里提供两种方法：

1. 方法一

在MySQL的官网下载
MtySQL Community Downloads

• 

红框里的是各种语言的开发者包，本篇博客介绍C语言的接口，也就是C API

• 

选择和要访问的MySQL服务器一样环境，版本的开发者包

• 

Archives可以看到历史版本
注意不要下载成Debug版本

下载完成后，在云服务上使用rz命令将Windows的文件拷贝到云服务上

使用tar xzf 压缩包解压，然后可以再改个名

里面有很多的库文件，我们主要使用include里的mysql.h

第一种方法先介绍到这

2. 方法二

如果你的MySQL是通过yum源安装的，那么yum在安装MySQL的同时，已经帮我们下好了开发者工具，并且配置好了

头文件默认放在/usr/include/mysql中
动静态库在/lib64/mysql中

如果没有，使用以下命令安装

yum install mysql-devel
1

第三方库的使用可以移步【Linux】动静态库

这里简要说一下使用
gcc/g++默认搜索的头文件路径是/user/include
默认搜索的库路径是

• /usr/local/lib
• /usr/lib
• /lib

编译可执行时需要如下命令

g++ -o -std=c++11 -I/usr/include/mysql -L/lib64/mysql -lmysqlclient
1

-I选项：指认使用的头文件。如果代码中#include<mysql/mysql.h>，其实可以不带-I选项，因为g++找得到
-L选项：指认库路径
-l：指认链接的库的名字

---

简单使用

makefile

mytest:test.cc
	g++ -o $@ $^ -std=c++11 -L/lib64/mysql -lmysqlclient
.PHONY:clean
clean:
	rm -f mytest
1
2
3
4
5

test.cc

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

int main()
{
    std::cout<<"mysql client version: "<<mysql_get_client_info()<<std::endl;

    return 0;
}
1
2
3
4
5
6
7
8
9

mysql_get_client_info()是mysql.h中的一个函数，可以获取和次开发包相应对应的mysql客户端版本

运行成功

二. MySQL接口介绍

1. 初始化/连接/关闭

C API的各种接口和变量都可以在官方文档查找
MySQL官方文档（全）
下拉找到Conectors&APIs，可以找到C API，选择合适的版本C API 8.0

左侧的C API Basic Interface里的C API Funciton-reference是各函数C API函数
C API Basic Data Structures是各种变量，结构体C API结构体

MySQL本质是网络服务
C API使用MYSQL结构体管理客户端与服务器的链接等信息

初始化MYSQL结构体

MYSQL * mysql_init(MYSQL*mysql)
1

参数可以传nullptr，如果传入一个MYSQL，则会重置此MYSQL，结果都是返回一个新的MYSQL

链接MySQL

MYSQL * mysql_real_connect(MYSQL*mysql,
							const char*host,
							const char*user,
							const char*passwd,
							const char*db,
							unsigned int port,
							const char*unix_socket,
							unsigned long clientflag
							)
1
2
3
4
5
6
7
8
9

MYSQL是C API中一个非常重要的变量，里面内容非常丰富，有port,dbname,charset等链接基本参数，也包含一个st_mysql_methods的结构体变量，里面保存着很多函数指针，这些函数指针将会在数据库连接成功后的各种数据库操作中调用

如下是MYSQL结构体的定义

typedef struct st_mysql
{
  NET		net;			/* Communication parameters */
  unsigned char	*connector_fd;		/* ConnectorFd for SSL */
  char		*host,*user,*passwd,*unix_socket,*server_version,*host_info;
  char          *info, *db;
  struct charset_info_st *charset;
  MYSQL_FIELD	*fields;
  MEM_ROOT	field_alloc;
  my_ulonglong affected_rows;
  my_ulonglong insert_id;		/* id if insert on table with NEXTNR */
  my_ulonglong extra_info;		/* Not used */
  unsigned long thread_id;		/* Id for connection in server */
  unsigned long packet_length;
  unsigned int	port;
  unsigned long client_flag,server_capabilities;
  unsigned int	protocol_version;
  unsigned int	field_count;
  unsigned int 	server_status;
  unsigned int  server_language;
  unsigned int	warning_count;
  struct st_mysql_options options;
  enum mysql_status status;
  my_bool	free_me;		/* If free in mysql_close */
  my_bool	reconnect;		/* set to 1 if automatic reconnect */

  /* session-wide random string */
  char	        scramble[SCRAMBLE_LENGTH+1];
  my_bool unused1;
  void *unused2, *unused3, *unused4, *unused5;

  LIST  *stmts;                     /* list of all statements */
  const struct st_mysql_methods *methods;
  void *thd;
  /*
    Points to boolean flag in MYSQL_RES  or MYSQL_STMT. We set this flag 
    from mysql_stmt_close if close had to cancel result set of this object.
  */
  my_bool *unbuffered_fetch_owner;
  /* needed for embedded server - no net buffer to store the 'info' */
  char *info_buffer;
  void *extension;
} MYSQL;
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

• host：链接的MySQL服务器的主机IP
• user：登录的用户
• passwd：用户密码
• db：使用的数据库
• port：MySQL服务器的端口号
• unix_socket：域间套接字（管道通信），通常为nullptr
• clientflag：通常为0，其他设置可查看官网

连接成功会将host，port等信息绑定到MYSQL中
失败则返回空指针

可以在MySQL中使用show processlist查看当前连接的用户

关闭连接

void mysql_close(MYSQL*mysql);
1

2. 执行操作

int mysql_query(MYSQL*mysql,const char*sql);
1

mysql：要哪个连接执行
sql：具体的sql语句

成功返回0，失败返回非0

案例：

准备了一个用户名为’ljh’，密码为123456，登录方式为localhost的用户
因为本地连接，所以IP使用本地环回127.0.0.1
端口号默认为3306
使用test数据库，其中有一个user表
表结构如下：

mysql> desc user;
+-----------+-------------+------+-----+---------+----------------+
| Field     | Type        | Null | Key | Default | Extra          |
+-----------+-------------+------+-----+---------+----------------+
| id        | int(11)     | NO   | PRI | NULL    | auto_increment |
| name      | varchar(10) | YES  |     | NULL    |                |
| age       | int(11)     | YES  |     | NULL    |                |
| telephone | varchar(11) | YES  | UNI | NULL    |                |
+-----------+-------------+------+-----+---------+----------------+
1
2
3
4
5
6
7
8
9

连接代码如下：

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

const std::string host ="127.0.0.1";
const std::string user="ljh";
const std::string passwd="123456";
const std::string db="test";
const unsigned int port=3306;


int main()
{
    //初始化
    MYSQL*conn=mysql_init(nullptr);
    if(conn==nullptr)
    {
        //初始化失败
        std::cerr<<"mysql init error"<<std::endl;
        return 1;
    }

    //建立连接
    conn=mysql_real_connect(conn,host.c_str(),user.c_str(),passwd.c_str(),db.c_str(),port,nullptr,0);
    if(conn==nullptr)
    {
        std::cerr<<"mysql connect error"<<std::endl;
        return 2;
    }

    std::cout<<"mysql connect success"<<std::endl;

    //关闭连接
    mysql_close(conn);

    return 0;
}
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

insert操作
在建立连接成功后

	const std::string sql="insert into user (name,age,telephone) values ('zhangsan',23,'123456')";
    int n=mysql_query(conn,sql.c_str());
    if(n==0)
    {
        std::cout<<sql<<" success "<<std::endl;
    }
    else
    {
        std::cerr<<"sql error"<<std::endl;
        return 3;
    }
1
2
3
4
5
6
7
8
9
10
11

mysql> select * from user;
Empty set (0.01 sec)

mysql> select * from user;
+----+----------+------+-----------+
| id | name     | age  | telephone |
+----+----------+------+-----------+
|  1 | zhangsan |   23 | 123456    |
+----+----------+------+-----------+
1
2
3
4
5
6
7
8
9

delete和update操作同理，只需要更改一下sql就可以了

---

编码格式

但是如果插入的是汉字，则会出现乱码的现象

const std::string sql="insert into user (name,age,telephone) values ('张三',23,'654321')";
1

mysql> select * from user;
+----+---------------+------+-----------+
| id | name          | age  | telephone |
+----+---------------+------+-----------+
|  1 | zhangsan      |   23 | 123456    |
|  4 | å¼ ä¸‰        |   23 | 654321    |
+----+---------------+------+-----------+
1
2
3
4
5
6
7

原因是开发者包默认使用的编码格式Latin1，MySQL默认使用utf8

更改编码格式

int mysql_set_character_set(MYSQL*mysql,const char* csname);
1

csname：指明编码格式

在建立连接后设置

mysql_set_character_set(conn,"utf8");
1

mysql> select * from user;
+----+----------+------+-----------+
| id | name     | age  | telephone |
+----+----------+------+-----------+
|  1 | zhangsan |   23 | 123456    |
|  5 | 张三     |   23 | 654321    |
+----+----------+------+-----------+
1
2
3
4
5
6
7

3. 查找操作

如果执行的sql语句是select，那么还需要调出结果
select语句通过mysql_query执行成功后，结果会放到MYSQL中，但为了更好的遍历，我们需要将结果拷贝到MYSQL_RES结果集中。

函数如下：

MYSQL_RES* mysql_store_result(MYSQL*mysql)
1

MYSQL_RES可以理解为一个char**的数组，一行数据其实就是一个char **
因为约束，所以MySQL的表数据时规整的，可以使用循环遍历

获取结果集的行数

uint64_t mysql_num_rows(MYSQL_RES *result)
1

获取结果集的列数

unsigned int mysql_num_fields(MYSQL_RES *result)
1

行迭代器 MYSQL_ROW
MYSQL_ROW就是char**

typedef char **MYSQL_ROW;
1

函数如下

MYSQL_ROW mysql_fetch_row(MYSQL_RES*res);
1

注意此处返回的是结构体对象，不是指针
每次调用这个函数后，下次调用都会将MYSQL_ROW定位到下一行数据

该函数会调用MYSQL变量中的st_mysql_methods中的read_rows函数指针来获取查询结果。同时malloc一片内存空间来存储查询到的数据，所以后续需要free释放这段空间

void mysql_free_result(MYSQL_RES *result)
1

案例：

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

const std::string host ="127.0.0.1";
const std::string user="ljh";
const std::string passwd="123456";
const std::string db="test";
const unsigned int port=3306;


int main()
{
    //初始化
    MYSQL*conn=mysql_init(nullptr);
    if(conn==nullptr)
    {
        //初始化失败
        std::cerr<<"mysql init error"<<std::endl;
        return 1;
    }

    //建立连接
    conn=mysql_real_connect(conn,host.c_str(),user.c_str(),passwd.c_str(),db.c_str(),port,nullptr,0);
    if(conn==nullptr)
    {
        std::cerr<<"mysql connect error"<<std::endl;
        return 2;
    }
    std::cout<<"mysql connect success"<<std::endl;
    mysql_set_character_set(conn,"utf8");//设置编码格式

    const std::string sql="select * from user";
	
	//执行sql语句
    int n=mysql_query(conn,sql.c_str());
    if(n==0)
    {
        std::cout<<sql<<" success "<<std::endl;
    }
    else
    {
        std::cerr<<"sql error"<<std::endl;
        return 3;
    }
    
    //获取结果集
    MYSQL_RES* res=mysql_store_result(conn);
    if(res==nullptr)
    {
        std::cerr<<"store error"<<std::endl;
        return 4;
    }

    int row=mysql_num_rows(res);//行数
    int field=mysql_num_fields(res);//列数
	//遍历
    for(int i=0;i<row;++i)
    {
        MYSQL_ROW rows=mysql_fetch_row(res);
        for(int j=0;j<field;++j)
        {
            std::cout<<rows[j]<<"\t";
        }
        std::cout<<std::endl;
    }

	mysql_free_result(res);

    //关闭连接
    mysql_close(conn);

    return 0;
}
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

---

获取列属性MYSQL_FIELD

MYSQL_FIELD是一个结构体，定义如下：

typedef struct st_mysql_field {
  char *name;                 /* Name of column */
  char *org_name;             /* Original column name, if an alias */
  char *table;                /* Table of column if column was a field */
  char *org_table;            /* Org table name, if table was an alias */
  char *db;                   /* Database for table */
  char *catalog;	      /* Catalog for table */
  char *def;                  /* Default value (set by mysql_list_fields) */
  unsigned long length;       /* Width of column (create length) */
  unsigned long max_length;   /* Max width for selected set */
  unsigned int name_length;
  unsigned int org_name_length;
  unsigned int table_length;
  unsigned int org_table_length;
  unsigned int db_length;
  unsigned int catalog_length;
  unsigned int def_length;
  unsigned int flags;         /* Div flags */
  unsigned int decimals;      /* Number of decimals in field */
  unsigned int charsetnr;     /* Character set */
  enum enum_field_types type; /* Type of field. See mysql_com.h for types */
  void *extension;
} MYSQL_FIELD;
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

可以通过MYSQL_FIELD获取列名，列属性等信息

案例：

	MYSQL_FIELD*fields=mysql_fetch_field(res);
    for(int i=0;i<field;++i)
    {
        std::cout<<"列名："<<fields[i].name<<std::endl;
    }
1
2
3
4
5

结束语

感谢看到此处
如果觉得本篇文章对你有所帮助的话，不妨点个赞支持一下博主，拜托啦，这对我真的很重要。