AI 助理
备案控制台
开发者社区 数据库 文章 正文

Linux下C语言实现MySQL操作——连接、查询、插入与客户端打造

2022-06-27 452
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
云数据库 RDS PostgreSQL，集群系列 2核4GB
简介： Linux下C语言实现MySQL操作——连接、查询、插入与客户端打造

准备工作

数据库


创建一个数据库（我的是test），并建表（我的是example）



知识准备


https://blog.csdn.net/weixin_45525272/article/details/108015027


1.连接代码


/*************************************************************************
    > File Name: connect.c
    > Author: 杨永利
    > Mail: 1795018360@qq.com 
    > Created Time: 2020年08月14日 星期五 20时39分56秒
 ************************************************************************/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
// 定义连接时所需要的数据宏
#define HOST "127.0.0.1"    // 所连数据库的ip 127.0.0.1是本机ip
#define USER "root"         // 数据库用户
#define PASSWORD "123456"   // 该用户密码（自设）
#define DBNAME "test"       // 要操作的数据库名
int main(int argc, char* argv[])
{
    // 定义mysql指针并初始化
    MYSQL *mysql=mysql_init(NULL);
    if(mysql== NULL)
    {
        printf("init err! 数据库初始化错误！\n");
        return -1;
    }
    // 初始化成功就连接数据库
    mysql = mysql_real_connect(mysql,HOST,USER,PASSWORD,DBNAME,0,NULL,0);
    if(mysql == NULL)
    {
        printf("connect err! 数据库连接失败！ \n");
        return -1;
    }
    printf("测试成功！\n");
    // 最后关闭连接
    mysql_close(mysql);
    return 0;
}


2.查询代码


/*************************************************************************
    > File Name: connect.c
    > Author: 杨永利
    > Mail: 1795018360@qq.com 
    > Created Time: 2020年08月14日 星期五 20时39分56秒
 ************************************************************************/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
// 定义连接时所需要的数据宏
#define HOST "127.0.0.1"    // 所连数据库的ip 127.0.0.1是本机ip
#define USER "root"         // 数据库用户
#define PASSWORD "123456"   // 该用户密码（自设）
#define DBNAME "test"       // 要操作的数据库名
// 打印结果集函数
void show_result(MYSQL_RES * result)
{
  //打印表头
  unsigned int num_fields;
  unsigned int i;
    // MYSQL_FIELD 该结构包含关于字段的信息，如字段名、类型和大小
  MYSQL_FIELD *fields;
  // 返回结果集中的行数。
  num_fields = mysql_num_fields(result);
    // mysql_fetch_fields 对于结果集，返回所有MYSQL_FIELD结构的数组。每个结构提供了结果集中1列的字段定义。
  fields = mysql_fetch_fields(result);
    // 输出结果
  for(i = 0; i < num_fields; i++)
  {
     printf("%s\t", fields[i].name);
  }
    // 这个输出是打造表的结构边框便于查看数据，准确的输出按照你的数据自行增加减去+号
  printf("\n+----+-------+\n");
  // 行数
  MYSQL_ROW row;
    num_fields = mysql_num_fields(result);//取字段个数
  while ((row = mysql_fetch_row(result)))//循环取一行
  {
     for(i = 0; i < num_fields; i++)
     {
           // 看是否为空
         printf("%s\t",  row[i] ? row[i] : "NULL");
     }
     printf("\n");
  }
}
int main(int argc, char* argv[])
{
    // 定义mysql指针并初始化
    MYSQL *mysql=mysql_init(NULL);
    if(mysql== NULL)
    {
        printf("init err! 数据库初始化错误！\n");
        return -1;
    }
    // 初始化成功就连接数据库
    mysql = mysql_real_connect(mysql,HOST,USER,PASSWORD,DBNAME,0,NULL,0);
    if(mysql == NULL)
    {
        printf("connect err! 数据库连接失败！ \n");
        return -1;
    }
    printf("数据库连接成功！\n"); 
    // 定义查询语句
    char rSql[256]={0};
    // 我的表名为example
    strcpy(rSql,"select * from example");
    // 查询指向的SQL查询
    if(mysql_query(mysql,rSql) != 0){
      printf("mysql_query err! 查询失败\n");
      exit(1);
    }
    // 取回结果集
    int i=0;
    // mysql_store_result()将查询的全部结果读取到客户端，分配1个MYSQL_RES结构，并将结果置于该结构中。
    MYSQL_RES * result = mysql_store_result(mysql);
    MYSQL_ROW row;
    if(result != NULL){
      //需要打印结果集
      show_result(result);
    mysql_free_result(result);//释放结果集
    }
    // 最后关闭连接
    mysql_close(mysql);
    printf("数据库关闭成功！\n");
    return 0;
}


3.插入代码


/*************************************************************************
    > File Name: insert.c
    > Author: 杨永利
    > Mail: 1795018360@qq.com 
    > Created Time: 2020年08月14日 星期五 21时44分30秒
 ************************************************************************/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
// 定义连接时所需要的数据宏
#define HOST "127.0.0.1"    // 所连数据库的ip 127.0.0.1是本机ip
#define USER "root"         // 数据库用户
#define PASSWORD "123456"   // 该用户密码（自设）
#define DBNAME "test"       // 要操作的数据库名
int main(int argc, char* argv[]){
    // 定义mysql指针并初始化
    MYSQL *mysql=mysql_init(NULL);
    if(mysql== NULL)
    {
        printf("init err! 数据库初始化错误！\n");
        return -1;
    }
    // 初始化成功就连接数据库
    mysql = mysql_real_connect(mysql,HOST,USER,PASSWORD,DBNAME,0,NULL,0);
    if(mysql == NULL)
    {
        printf("connect err! 数据库连接失败！ \n");
        return -1;
    }
    printf("数据库连接成功！\n");
    // 定义查询语句
    char rSql[256]={0};
    strcpy(rSql,"insert into example values(4,'admin')");
    if(mysql_query(mysql,rSql) != 0){
      printf("mysql_query err\n");
      exit(1);
    }
    printf("数据插入成功！\n");
    // 最后关闭连接
    mysql_close(mysql);
    return 0;
}


4.客户端代码


/*************************************************************************
    > File Name: client.c
    > Author: 杨永利
    > Mail: 1795018360@qq.com 
    > Created Time: 2020年08月14日 星期五 21时49分15秒
 ************************************************************************/
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
// 定义连接时所需要的数据宏
#define HOST "127.0.0.1"    // 所连数据库的ip 127.0.0.1是本机ip
#define USER "root"         // 数据库用户
#define PASSWORD "123456"   // 该用户密码（自设）
#define DBNAME "test"       // 要操作的数据库名
void show_result(MYSQL_RES * result,MYSQL *mysql)
{
  //打印表头
  unsigned int num_fields;
  unsigned int i;
  MYSQL_FIELD *fields;
  num_fields = mysql_num_fields(result);
  fields = mysql_fetch_fields(result);
  for(i = 0; i < num_fields; i++)
  {
     printf("%s\t", fields[i].name);
  }
  printf("\n----------------------------------------------------------\n");//华丽分割线
  MYSQL_ROW row;
    num_fields = mysql_num_fields(result);//取字段个数
  while ((row = mysql_fetch_row(result)))//循环取一行
  {
     for(i = 0; i < num_fields; i++)
     {
         printf("%s\t",  row[i] ? row[i] : "NULL");
     }
     printf("\n");
  }
  printf("\n----------------------------------------------------------\n");//华丽分割线
  //3 rows in set (0.28 sec)
  printf("%ld rows in set \n",mysql_affected_rows(mysql));//影响的数目
}
int main(int argc, char* argv[]){
        // 定义mysql指针并初始化
    MYSQL *mysql=mysql_init(NULL);
    if(mysql== NULL)
    {
        printf("init err! 数据库初始化错误！\n");
        return -1;
    }
    // 初始化成功就连接数据库
    mysql = mysql_real_connect(mysql,HOST,USER,PASSWORD,DBNAME,0,NULL,0);
    if(mysql == NULL)
    {
        printf("connect err! 数据库连接失败！ \n");
        return -1;
    }
    printf("数据库连接成功！\n");
    // 客户端操作
    printf("welcome to mysql!\n");
    char rSql[1024]={0};
    printf("输入quit退出！\n");
    while(1)
    {
        // STDIN_FILENO表示标准输入
        write(STDOUT_FILENO,"yoursql>",8);
    memset(rSql,0x00,sizeof(rSql));
        // 标准输出 STDOUT_FILENO
        read(STDIN_FILENO,rSql,sizeof(rSql));//读入sql
        if(strncmp(rSql,"quit",4) == 0){
      printf("bye bye!欢迎下次使用！\n");
      break;
    }
        //执行sql
    if(mysql_query(mysql,rSql) != 0){
        printf("mysql_query err\n");
        continue;
      }
           //取回结果集
      int i=0;
      MYSQL_RES * result = mysql_store_result(mysql);
      MYSQL_ROW row;
      if(result != NULL){
        //需要打印结果集
        show_result(result,mysql);
      mysql_free_result(result);//释放结果集
      }else
        {
        //输出例如：Query OK, 1 row affected (0.16 sec)
        printf("Query OK, %ld row affected \n",mysql_affected_rows(mysql));
        //printf("%ld products updated",(long) mysql_affected_rows(&mysql));
      }
    }
    // 最后关闭连接
    mysql_close(mysql);
    return 0;
}



文章标签：
云数据库 RDS MySQL 版
C语言
关系型数据库
Linux
MySQL
数据库
关键词：
云数据库 RDS MySQL 版查询
linux云数据库 RDS MySQL 版
Linux Mysql
Linux连接
Linux查询
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
流楚丶格念
目录
相关文章
蓝易云
|
21天前
|
安全 关系型数据库 MySQL
Linux下安装mysql8.0（以tar.xz包安装--编译安装）
通过上述步骤，您完成了从下载、编译、安装到配置MySQL 8.0的全过程。此过程虽然较为复杂，但提供了对MySQL安装环境的完全控制，有助于满足特定的部署需求。在实际操作中，根据具体的系统环境，可能还需调整部分步骤或解决未预见的依赖问题。始终参考官方文档和社区资源，保持安装过程与最新版本的兼容性。
蓝易云
373 67
yuanzhengme
|
1天前
|
关系型数据库 MySQL Linux
Linux系统如何设置自启动服务在MySQL数据库启动后执行？
【10月更文挑战第25天】Linux系统如何设置自启动服务在MySQL数据库启动后执行？
yuanzhengme
20 3
小王老师呀
|
15天前
|
Ubuntu 关系型数据库 MySQL
Linux系统MySQL安装
【10月更文挑战第19天】本文介绍了在 Linux 系统上安装 MySQL 的步骤，包括安装前准备、安装 MySQL、启动 MySQL 服务、配置 MySQL 以及验证安装。适用于 Ubuntu/Debian 和 CentOS/Fedora 系统，提供了详细的命令示例。
小王老师呀
92 1
杀死一只知更鸟debug
|
2月前
|
关系型数据库 MySQL Linux
Linux 安装 mysql 【使用 tar.gz | tar.xz安装包-离线安装】
在Linux系统中使用tar.xz压缩包安装MySQL数据库的详细步骤。包括下载MySQL压缩包，解压到指定目录，创建mysql用户和组，设置目录权限，初始化MySQL，配置my.cnf文件，启动服务，以及修改root用户密码。此外，还提供了如何设置Windows远程登录MySQL服务器的方法。
杀死一只知更鸟debug
381 2
Linux 安装 mysql 【使用 tar.gz | tar.xz安装包-离线安装】
Codelinghu
|
21天前
|
Linux 虚拟化 C++
Linux基础知识查询总结（上）
Linux基础知识查询总结（上）
Codelinghu
33 4
Codelinghu
|
21天前
|
移动开发 Linux 开发工具
Linux基础知识查询总结（下）
Linux基础知识查询总结（下）
Codelinghu
45 2
游客cxtb2yf2r55as
|
24天前
|
关系型数据库 MySQL Linux
Linux系统绿色安装MySQL 8.0.39
Linux系统绿色安装MySQL 8.0.39
游客cxtb2yf2r55as
136 0
游客j4mujezz7vm7y
|
2月前
|
关系型数据库 MySQL Python
mysql之python客户端封装类
mysql之python客户端封装类
游客j4mujezz7vm7y
22 3
游客j4mujezz7vm7y
|
2月前
|
Linux Shell
10-10|linux命令查询 关键字在文本中出现的行数
10-10|linux命令查询 关键字在文本中出现的行数
游客j4mujezz7vm7y
109 1
游客j4mujezz7vm7y
|
2月前
|
Linux Shell
6-9|linux查询现在运行的进程
6-9|linux查询现在运行的进程
游客j4mujezz7vm7y
21 1

热门文章

最新文章

  • 1
    Linux cron crontab用法（转载）
  • 2
    1.3. Redhat Linux
  • 3
    Linux系统基础入门（最常用的操作命令）
  • 4
    linux 2.6.17-IDE驱动程序源代码分析
  • 5
    【总结】IntelliJ在Win和Linux中的快捷键
  • 6
    Linux下安装Python3.6.8（超级详细）
  • 7
    Linux下用户与组的管理-Linux学习笔记
  • 8
    Windows和Linux系统之间配置共享
  • 9
    Linux命令（20）：who命令
  • 10
    24小时学通Linux内核之如何处理输入输出操作
  • 1
    轻松入门Mysql：MySQL性能优化与监控，解锁进销存系统的潜力（23）
    121
  • 2
    轻松入门MySQL：深入探究MySQL的ER模型，数据库设计的利器与挑战（22）
    459
  • 3
    轻松入门MySQL：数据库设计之范式规范，优化企业管理系统效率（21）
    139
  • 4
    轻松入门MySQL：揭秘MySQL游标，数据处理的神秘利器（16）
    112
  • 5
    轻松入门MySQL：加速进销存！利用MySQL存储过程轻松优化每日销售统计（15）
    159
  • 6
    轻松入门MySQL：保障数据完整性，MySQL事务在进销存管理系统中的应用（12）
    71
  • 7
    轻松入门MySQL：优化进销存管理，掌握MySQL索引，提升系统效率（11）
    131
  • 8
    轻松入门MySQL：精准查询，巧用WHERE与HAVING，数据库查询如虎添翼（7）
    122
  • 9
    轻松入门MySQL：玩转数据表的增、删、改、查（4）
    73
  • 10
    轻松入门MySQL：深入学习数据库表管理，创建、修改、约束、建议与性能优化（3）
    109

    • 相关课程

    更多
  • Linux高级网络应用 - 网络管理与配置实战
  • Linux Web服务器Nginx搭建与配置
  • 计算机基础与Linux入门
  • Linux企业运维实战 - 入门及常用命令
  • 你的第一门C语言课
  • C语言学习教程

    • 相关电子书

    更多
  • Alibaba Cloud Linux 3 发布
  • ECS系统指南之Linux系统诊断
  • ECS运维指南 之 Linux系统诊断

    • 相关实验场景

    更多
  • MySQL基础-学生管理系统数据库设计
  • 如何快速连接云数据库RDS MySQL
  • MySQL引擎及架构优化
  • 基于EBS部署高性能的MySQL服务
  • 使用计算巢企业应用，一键获取专属的Linux服务器管理软件
  • 5分钟上手Flink MySQL连接器

    • 推荐镜像

    更多
  • mxlinux-iso
  • archlinuxarm
  • archlinuxcn
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月