【MySql】C语言连接mysql|图形化工具
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语句:
也可以直接进行图形化进行增删改操作等等:这是图形化带来的好处