【MySql】C语言连接mysql|图形化工具

Connector/C 使用

说完了mysql的基础,后面我们只关心使用,要使用C语言连接mysql,需要使用mysql官网提供的库,前往官网下载即可。

image-20230625185446125

但是实际上我们并不需要这样去做,我们之前用yum安装mysql的时候就已经包含了,我们前往lib64/mysql/下查看即可:直接用就行了

image-20230625192007704

现在,我们直接来对相关的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库的名称

image-20230625194115886

测试运行:运行成功,结果如下

image-20230625194148650

mysql接口介绍

我们可以先看一看官方文档:

image-20230625195447739

image-20230625195549329

  • 初始化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;
}

结果如下,更新成功

image-20230626204951000

  • 获取执行结果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;
}

结果如下:

image-20230627213240361

Navicat远程连接数据库

图形化管理mysql的工具有挺多,这里使用的是Navicat,下面进行连接的演示,

  • 准备工作

首先,在服务器端创建mysql用于远程连接的账户worjkbench:

create user 'workbench'@'%' identified by '123456';

同时,创建完毕之后,我们把数据库conn的权限下放给这个账户:

grant all on conn.* to 'workbench'@'%';
flush privileges;

查看创建的信息:

image-20230628123045572

在这个账户下就可以看到这个数据库了:

image-20230628123655147

  • 进行Navicat连接

image-20230628123933367

进行测试连接:连接成功

image-20230628123949830

image-20230628124118942

这就连接成功了。现在我们可以直接来写sql语句:

image-20230628125719192

也可以直接进行图形化进行增删改操作等等:这是图形化带来的好处

image-20230628125758732