目录
问题：为什么不使用C++？
解答：使用C的库已经可以完成绝大部分MySQL操作了，并且C++的库的使用更加复杂，C的库使用相对简单，目前我们学习好C的库的部分使用即可（其实是我太菜了不会用C++的库）
一，下载库
下载地址：MySQL :: Download MySQL Connector/C (Archived Versions)
下面是我的环境版本：
下载后在XShell使用rz命令上传至服务器然后解压即可：
其中include目录下有一堆头文件，lib目录下的则色一堆的动静态库：
二，安装库
我们可以选择把这个include放到lib目录下，也可以直接在代码中指定头文件路径，也可以在编译时指定使用的库，下面我们采用的是第二种方法
当完成上面的步骤后，我们现在要做的就是验证我们的库能否正常使用，我们可以调用mysql_get_client_info函数来获取客户端基本信息：
#include<iostream>
#include "./mysql-connector/include/mysql.h"
int main()
{
std::cout << mysql_get_client_info() << std::endl;
return 0;
}makefile如下：
test:test.cc
g++ -o $@ $^ -std=c++11 -lmysqlclient
.PHONY:clean
clean:
rm -rf test
如果能正常打印，说明我们的库已经能使用了
三，使用库
3.1 连接数据库
①初始化数据库
在连接数据库之前，我们需要先创建一个MySQL对象，如下函数声明：
MYSQL * STDCALL mysql_init(MYSQL *mysql);- 对于参数，我们一般传入nullptr，那么这个函数会自动分配一个MySQL对象并返回
- 如果传入一个地址，那么该函数会在指定的地址完成初始化
对于 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 * STDCALL 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地址
- user： 连接MySQL服务器时，所使用用户的用户名。
- passwd： 连接MySQL服务器时，所使用用户的密码
- db： 连接MySQL服务器后，需要使用的数据库。
- port： 连接的MySQL服务器，所对应的端口号。
- unix_socket： 连接时应该使用的套接字或命名管道，通常设置为NULL。
- clientflag： 可以设置为多个标志位的组合，表示允许特定的功能，通常设置为0。
- 返回值：如果连接成功，返回一个MySQL对象，就是将第一个参数作为输出型参数输出，如果连接hi白就返回null
③断开连接
断开连接函数声明：
void STDCALL mysql_close(MYSQL *sock);参数就是我们前面的MySQL对象
③连接断开测试
#include <iostream>
#include <string>
#include "./mysql-connector/include/mysql.h"
using namespace std;
const string host = "127.0.0.1";
const string user = "root";
const string passwd = "123456";
const string db = "db"; //要使用的库
const int port = 3306;
int main()
{
//1、创建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<<"MySQL connect error"<<endl;
return 1;
}
cout<<"MySQL connect success" << endl;
//3、关闭数据库
mysql_close(ms);
cout<<"MySQL connect close"<<endl;
return 0;
}
3.2 发送SQL
①SQL发送函数
与数据库成功连接之后，就可以向其发送SQL了，发送SQL的函数声明如下：
int STDCALL mysql_query(MYSQL *mysql, const char *q);- 第一个参数就是MySQL对象，第二个参数就是指向需要发送SQL字符串指针
- 返回0表示SQL执行成功，否则表示执行失败
②设置编码格式
客户端和服务器的编码格式可能不一样，会导致双方在进行数据交互时可能会出现乱码，设置编码格式的函数如下：
int STDCALL mysql_set_character_set(MYSQL *mysql, const char *csname);- 第一个参数是MySQL对象，第二个参数就是要设置的编码格式，我们后面都会设置成“utf8”
- 返回0表示成功，否则失败
③准备测试表
④插入，删除，修改SQL
⑤执行结果
先编译运行
再次查看数据库，可以发现结果已变化
3.3 获取结果
获取结果分为：“获取”、“打印”，
①获取查询结果函数
函数声明如下：
MYSQL_RES * STDCALL mysql_store_result(MYSQL *mysql);- 该函数会调用指定MySQL对象对应的函数指针来获取查询结果，并将结果保存到MYSQL_RES结构体中
MYSQL_RES结构体定义如下：
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：
mysql的表分为表的属性和表的内容两种，查的结果是被查出来的数据，所以在内存中一定是有一段空间来保存这段数据的，因为mysql将所有的数据读取出来的时候都当作字符串
所以可以把MYSQL_RES *当成char**[]数组，数组里面存的都是另一个char*[]数组的首地址，而这些数组里面的指针分别指向表每一行的各个列数据的地址
②获取查询结果行数和列数
查询行数函数：
my_ulonglong STDCALL mysql_num_rows(MYSQL_RES *res);查询列数函数：
unsigned int STDCALL mysql_num_fields(MYSQL_RES *res);③获取表属性
前面获取行数和列数输入获取表的内容，而我们现在这个表示获取表的属性
获取表的属性函数如下：
MYSQL_FIELD * STDCALL mysql_fetch_fields(MYSQL_RES *res);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 STDCALL mysql_fetch_row(MYSQL_RES *result);MYSQL_ROW本质是一个二级指针，这个二级指针指向一个类似数组的结构，而这个数组里面也是一个一个的指针，这些指针指向的就是这行数据中的多个列信息
⑤查询示例
⑥效果演示
完整代码如下：
#include<iostream>
#include<string>
#include<unistd.h>
#include "./mysql-connector/include/mysql.h"
const std::string host = "127.0.0.1";
const std::string user = "root";
const std::string password = "123456";
const std::string db = "db";
const unsigned int port = 3306;
int main()
{
MYSQL* my = mysql_init(nullptr); //MYSQL就是一个大型结构体，保存了mysql的一些属性,my类似于文件操作的file
if (nullptr == my)
{
std::cout << "init MYSQL error" << std::endl;
return 1; //退出码
}
if (mysql_real_connect(my, host.c_str(), user.c_str(), password.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
{
std::cout << "connect MySql error" << std::endl;
return 2; //退出码
}
mysql_set_character_set(my, "utf8");
std::string sql = "select * from user;";
int n = mysql_query(my, sql.c_str());
if (n == 0) std::cout << sql << "success" << std::endl;
else
{
std::cout << sql << "failed" << std::endl;
return 3;
}
MYSQL_RES* res = mysql_store_result(my); //MYSQL_RES是一个结构体
if (nullptr == res)
{
std::cout << "mysql_store_result error" << std::endl;
return 4;
}
int rows = mysql_num_rows(res); //获取行数
int fields = mysql_num_fields(res); //获取列数
//打印表属性
MYSQL_FIELD* fields_array = mysql_fetch_fields(res); //MYSQL_FIELD也是一个结构体，里面存的是各种属性类型
for (int i = 0; i < fields; i++)
{
std::cout << fields_array[i].name << "\t";
}
std::cout << "\n";
//打印内容
for (int i = 0; i < rows; i++)
{
MYSQL_ROW row = mysql_fetch_row(res); //这个类似迭代器,会自动向后走
for (int j = 0; j < fields; j++)
{
std::cout << row[j] << "\t";
}
std::cout << "\n";
}
//打印库名和表名(可以打印很多属性，根据自己需要可以自行打印)
std::cout << fields_array[0].db << " " << fields_array[0].table << std::endl;
mysql_free_result(res); //释放结果集
mysql_init(my); //已完成对象的创建和初始化，以及清理释放的过程
return 0;
}
