一、引入库
1.1 下载库文件
要使用C语言连接MySQL，需使用MySQL官网提供的库
MySQL :: Download Connector/C++
https://dev.mysql.com/downloads/connector/cpp/
上传到云服务器
下载完毕后将其上传到云服务器即可。下面将下载的库文件解压后存放在一个名为makeuse的目录中
进入解压后的目录中，可以看到有一个include子目录和一个lib子目录
include目录下存放的是一批头文件
bin目录下存放的是动静态库
1.2 在项目中引入库
为了方便在项目中使用刚才的库文件，可以在项目目录下创建两个软连接，分别连接到刚才的include目录和lib目录
此时在项目目录下，就能直接看到刚才include和lib目录下的内容
下面先通过调用mysql_get_client_info来判断库是否引入成功，该函数的作用就是获取客户端的版本信息
#include <iostream> #include <mysql.h> using namespace std; int main() { //获取客户端的版本信息 cout<<"mysql client version: "<<mysql_get_client_info()<<endl; return 0; }
为了方便后续重复编译源文件，在项目目录下创建一个makefile
mysqlConnect:mysqlConnect.cc g++ $^ -o $@ -std=c++11 -I./include -L./lib -lmysqlclient .PHONY:clean clean: rm -rf mysqlConnect
-I：指明头文件的搜索路径
-L：指明库文件的搜索路径
-l：指明需要连接库文件路径下的哪一个库
makefile编写完毕后，使用make命令编译代码生成可执行程序
但此时生成的可执行程序还不能直接运行，通过ldd命令可以发现，该可执行程序所依赖的mysqlclient库找不到
gcc/g++编译器默认都是动态链接，编译代码时默认使用动态库，所以生成的可执行程序在运行时需要找到对应的动态库进行链接，而使用的mysqlclient库并不在系统的搜索路径下
Makefile中的-I，-L和-l这三个选项，只是在编译期间告诉编译器头文件和库文件在哪里，而可执行程序生成后就与编译器无关了
动态库如何使用，在《Linux动静态库》这篇文章中讲解过，不知道如何配置的可以参考下面这篇文章
(28条消息) Linux动静态库_GG_Bond19的博客-CSDN博客
https://blog.csdn.net/GG_Bruse/article/details/128810497
配置完成后可执行程序所依赖的mysqlclient库就能够被找到了
运行可执行程序后，可以看到客户端的版本为6.1.11，即刚才下载的库文件的版本
二、使用库
2.1 连接数据库
创建MySQL对象
MYSQL* mysql_init(MYSQL *mysql);
该函数用来分配或者初始化一个MySQL对象，用于连接MySQL服务器
若传入的参数是NULL，那么mysql_init将自动为你分配一个MySQL对象并返回
若传入的参数是一个地址，那么mysql_init将在该地址处完成初始化
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;
注意：MYSQL对象中的methods变量是一个结构体变量，该变量里面保存着很多函数指针，这些函数指针将会在数据库连接成功以后的各种数据操作中被调用
连接数据库
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);
mysql： 表示在连接数据库前，调用mysql_init函数创建的MySQL对象
host： 表示需要连接的MySQL服务器的IP地址，"127.0.0.1"表示连接本地MySQL服务器
user： 表示连接MySQL服务器时，所使用用户的用户名
passwd： 表示连接MySQL服务器时，所使用用户的密码
db： 表示连接MySQL服务器后，要使用的数据库
port： 表示连接的MySQL服务器，所对应的端口号
unix_socket： 表示连接时应该使用的套接字或命名管道，通常设置为NULL
clientflag： 可以设置为多个标志位的组合，表示允许特定的功能，通常设置为0
返回值：
若连接数据库成功，则返回一个MySQL对象，该对象与第一个参数的值相同
若连接数据库失败，则返回NULL
关闭数据库连接
void mysql_close(MYSQL *sock);
该函数的参数，就是连接数据库前调用mysql_init创建的MySQL对象
若传入的MySQL对象是mysql_init自动创建的，那么调用mysql_close时就会释放这个对象
2.2 SQL请求
下发SQL请求
int mysql_query(MYSQL *mysql, const char *q);
mysql： 表示在连接数据库前，调用mysql_init函数创建的MySQL对象
q： 表示向MySQL服务器下发的SQL请求，SQL最后可以不带分号
返回值：返回值为0表示SQL执行成功，否则表示SQL执行失败
设置编码格式
连接数据库后，需统一客户端和服务器的编码格式，避免在数据交互过程中出现乱码
int mysql_set_character_set(MYSQL *mysql, const char *csname);
mysql： 表示在连接数据库前，调用mysql_init函数创建的MySQL对象
csname： 表示要设置的编码格式，如"utf8"
返回值：返回值为0表示设置成功，否则表示设置失败
2.3 获取查询结果
对数据库中的数据进行增删改操作时，都只需调用mysql_query向服务器下发对应的SQL请求
而对数据库中的数据进行查询操作时，除了需要调用mysql_query向服务器下发对应的查询SQL，还需获取查询结果
获取查询结果
该函数会调用指定MySQMYSQL_RES* mysql_store_result(MYSQL *mysql);L对象中对应的函数指针来获取查询结果，并将获取到的查询结果保存到MYSQL_RES变量中进行返回
MYSQL_RES变量的内存空间是malloc出来的，因此在使用完后需要调用free函数进行释放，否则会造成内存泄露
typedef struct st_mysql_res { my_ulonglong row_count; MYSQL_FIELD *fields; MYSQL_DATA *data; MYSQL_ROWS *data_cursor; unsigned long *lengths; /* column lengths of current row */ MYSQL *handle; /* for unbuffered reads */ const struct st_mysql_methods *methods; MYSQL_ROW row; /* If unbuffered read */ MYSQL_ROW current_row; /* buffer to current row */ MEM_ROOT field_alloc; unsigned int field_count, current_field; my_bool eof; /* Used by mysql_fetch_row */ /* mysql_stmt_close() had to cancel this result */ my_bool unbuffered_fetch_cancelled; void *extension; } MYSQL_RES;
获取查询结果的行数
该函数会从指定的MYSQL_RES对象中，获取查询结果的行数
unsigned int mysql_num_fields(MYSQL_RES *res);
获取查询结果的列数
该函数会从指定的MYSQL_RES对象中，获取查询结果的列数
MYSQL_FIELD* mysql_fetch_fields(MYSQL_RES *res);
获取查询结果的列属性
该函数会从指定的MYSQL_RES对象中，获取查询结果的列属性
MYSQL_FIELD* mysql_fetch_fields(MYSQL_RES *res);
mysql_fetch_fields函数将会返回多个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;
获取查询结果中的一行数据
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
MYSQL_ROW对象中保存着一行数据，这一行数据中可能包含多个字符串，对应就是这行数据中的多个列信息，因此MYSQL_ROW本质就是char**类型，其类型定义如下：
typedef char **MYSQL_ROW; /* return data as array of strings */
2.4 使用案例
查询user表中的数据并进行打印输出
#include <iostream> #include <string> #include <mysql.h> using namespace std; const string host = "43.139.44.157"; const string passwd = "123qwe@@@QWE"; const string user = "bjy"; const string db = "olinejudge"; const int port = 3306; int main() { //1、获取MySQL实例（相当于创建了一个MySQL句柄） MYSQL* ms = mysql_init(nullptr); //2、连接数据库 if(mysql_real_connect(ms, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr) { cerr<<"数据库连接失败!"<<endl; return 1; } cout<<"数据库连接成功!"<<endl; mysql_set_character_set(ms, "utf8"); //设置编码格式为utf8 //3、查询数据库表中的记录 //a、执行查询语句 string sql = "select * from user"; if(mysql_query(ms, sql.c_str()) != 0) { cout<<"查询数据失败!"<<endl; return 2; } cout<<"查询数据成功!"<<endl; //b、获取查询结果 MYSQL_RES* res = mysql_store_result(ms); int rows = mysql_num_rows(res); //行数 int cols = mysql_num_fields(res); //列数 //获取每列的属性并打印列名 MYSQL_FIELD* fields = mysql_fetch_fields(res); for(int i = 0;i < cols;i++) cout<<fields[i].name<<"\t"; cout<<endl; for(int i = 0;i < rows;i++) { //获取一行数据并进行打印 MYSQL_ROW row = mysql_fetch_row(res); for(int j = 0;j < cols;j++) { cout<<row[j]<<"\t"; } cout<<endl; } free(res); //释放内存空间 //4、关闭数据库 mysql_close(ms); cout<<"数据库关闭成功!"<<endl; return 0; }
使用make命令生成可执行程序，运行后在即可看到数据的查询结果
