文章目录
- Connector/C 使用
- mysql接口介绍
- Navicat远程连接数据库
Connector/C 使用
说完了mysql的基础,后面我们只关心使用，要使用C语言连接mysql，需要使用mysql官网提供的库，前往官网下载即可。
但是实际上我们并不需要这样去做，我们之前用yum安装mysql的时候就已经包含了，我们前往lib64/mysql/下查看即可：直接用就行了
现在，我们直接来对相关的API进行调用即可。
我们来通过 mysql_get_client_info() 函数，来验证我们的引入是否成功
#include <iostream>
#include <mysql/mysql.h>
int main()
{
std::cout<<"mysql cilent version: "<<mysql_get_client_info()<<std::endl;
return 0;
}
进行编译：记得带上-L库的位置与-l库的名称
测试运行：运行成功，结果如下
mysql接口介绍
我们可以先看一看官方文档：
- 初始化mysql_init()
要使用库，必须先进行初始化！
MYSQL *mysql_init(MYSQL *mysql);
- 关闭mysql链接mysql_close
void mysql_close(MYSQL *sock);
初始化与关闭是最基础的操作：
#include <iostream>
#include <mysql/mysql.h>
int main()
{
MYSQL* my = mysql_init(nullptr);
if(nullptr == my)
{
std::cerr<<"init MySQL error"<<std::endl;
return 1;
}
mysql_close(my);
return 0;
}
- 链接数据库mysql_real_connect
初始化完毕之后，必须先链接数据库，在进行后续操作。（mysql网络部分是基于TCP/IP的)
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);
//建立好链接之后，获取英文没有问题，如果获取中文是乱码：
//设置链接的默认字符集是utf8，原始默认是latin1
mysql_set_character_set(myfd, "utf8");
第一个参数 MYSQL是 C api中一个非常重要的变量（mysql_init的返回值），里面内存非常丰富，有port,dbname,charset等连接基本参数。它也包含了一个叫 st_mysql_methods的结构体变量，该变量里面保存着很多函数指针，这些函数指针将会在数据库连接成功以后的各种数据操作中被调用。mysql_real_connect函数中各参数，基本都是顾名思意
- 下发mysql命令mysql_query
int mysql_query(MYSQL *mysql, const char *q);
第一个参数上面已经介绍过，第二个参数为要执行的sql语句,如“select * from table”
举个例子，直接更新数据库表中的数据：
#include <iostream>
#include <mysql/mysql.h>
#include <string>
#include <unistd.h>
const std::string host="127.0.0.1";
const std::string user = "connector";
const std::string passwd="123456";
const std::string db="conn";
const unsigned int port = 3306;
int main()
{
MYSQL* my = mysql_init(nullptr);
if(nullptr == my)
{
std::cerr<<"init MySQL error"<<std::endl;
return 1;
}
if(mysql_real_connect(my,host.c_str(),user.c_str(),passwd.c_str(),db.c_str(),port,nullptr,0) == nullptr)
{
std::cerr<<"connect MySQL error"<<std::endl;
return 2;
}
mysql_set_character_set(my,"utf8");
std::string sql="update user set name='Jimmy' where id=2";
int n = mysql_query(my,sql.c_str());
if(n==0) std::cout<<sql<<"success"<<std::endl;
else std::cout<<sql<<"failed"<<std::endl;
mysql_free_result(res);
mysql_close(my);
return 0;
}
结果如下，更新成功
- 获取执行结果mysql_store_result
sql执行完以后，如果是查询语句，我们当然还要读取数据，如果update，insert等语句，那么就看下操作成功与否即可。我们来看看如何获取查询结果： 如果mysql_query返回成功，那么我们就通过mysql_store_result这个函数来读取结果。原型如下 ：
MYSQL_RES *mysql_store_result(MYSQL *mysql);
该函数会调用MYSQL变量中的st_mysql_methods中的 read_rows 函数指针来获取查询的结果。同时该函数会返回MYSQL_RES 这样一个变量，该变量主要用于保存查询的结果。同时该函数malloc了一片内存空间来存储查询过来的数据，所以我们一定要记的 free(result),不然是肯定会造成内存泄漏的。 执行完mysql_store_result以后，其实数据都已经在MYSQL_RES 变量中了，下面的api基本就是读取
MYSQL_RES 中的数据
- 获取结果行数mysql_num_rows
my_ulonglong mysql_num_rows(MYSQL_RES *res);
- 获取结果列数mysql_num_fields
unsigned int mysql_num_fields(MYSQL_RES *res);
- 获取列名mysql_fetch_fields
MYSQL_FIELD *mysql_fetch_fields(MYSQL_RES *res);
- 获取结果内容mysql_fetch_row
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
返回一个MYSQL_ROW变量，MYSQL_ROW其实就是char **.当成一个二维数组来用吧
举个例子：
const std::string host="127.0.0.1";
const std::string user = "connector";
const std::string passwd="123456";
const std::string db="conn";
const unsigned int port = 3306;
int main()
{
MYSQL* my = mysql_init(nullptr);
if(nullptr == my)
{
std::cerr<<"init MySQL error"<<std::endl;
return 1;
}
if(mysql_real_connect(my,host.c_str(),user.c_str(),passwd.c_str(),db.c_str(),port,nullptr,0) == nullptr)
{
std::cerr<<"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);
if(res==nullptr)
{
std::cerr<<"mysql_store_result_error"<<std::endl;
}
int rows = mysql_num_rows(res);
int fields = mysql_num_fields(res);
std::cout<<"行: "<<rows<<std::endl;
std::cout<<"列："<<fields<<std::endl;
//属性
MYSQL_FIELD * fields_array = mysql_fetch_fields(res);
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_close(my);
return 0;
}
结果如下：
Navicat远程连接数据库
图形化管理mysql的工具有挺多，这里使用的是Navicat，下面进行连接的演示，
- 准备工作
首先，在服务器端创建mysql用于远程连接的账户worjkbench：
create user 'workbench'@'%' identified by '123456';
同时，创建完毕之后，我们把数据库conn的权限下放给这个账户：
grant all on conn.* to 'workbench'@'%';
flush privileges;
查看创建的信息：
在这个账户下就可以看到这个数据库了：
- 进行Navicat连接
进行测试连接：连接成功
这就连接成功了。现在我们可以直接来写sql语句：
也可以直接进行图形化进行增删改操作等等：这是图形化带来的好处
