Linux下如何实现C++操作Mysql数据库的详细介绍

发布时间 - 2017-05-31 00:00:00    点击率:

由于工作需要抽出一周的时间来研究c/c++++访问各种数据库的方法,并打算封装一套数据库操作类,现在奉上最简单的一部分:在linux下访问mysql数据库。

想用C++写项目,数据库是必须的,所以这两天学了一下C++操作MySQL数据库的方法。也没有什么教程,就是在网上搜的知识,下面汇总一下。

连接MySQL数据库有两种方法:第一种是使用ADO连接,不过这种只适合Windows平台;第二种是使用MySQL自己的C API函数连接数据库。我是在Linux平台下开发,所以就采用第二种方法,有很多Api函数,但是常用的就几个,我也是就用到其中的几个。

API函数

1.mysql_real_connect()

连接一个mysql服务器

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 client_flag)

如果连接成功,返回MYSQL*连接句柄。如果连接失败,返回NULL。对于成功的连接,返回值与第1个参数的值相同

2.mysql_query()

执行指定”以NULL终结的数据库操作0”的SQL数据库操作1

返回一个结果表,假定查询成功,可以调用 数据库操作2() 来查看对应于 SELECT 语句返回了多少行,或者调用 数据库操作3() 来查看对应于 数据库操作4,INSERT,REPLACE 或 UP数据库操作5 语句影响到了多少行。

3.mysql_store_result()

MYSQL_RES *mysql_store_result(MYSQL *mysql)

检索完整的结果集至客户端。客户端处理结果集最常用的方式是通过调用mysql_store_result(),一次性地检索整个结果集。该函数能从服务器获得查询返回的所有行,并将它们保存在客户端。对于成功检索了数据的每个查询(SELECT、SHOW、DESCRIBE、EXPLAIN、CHECK TABLE等),必须调用mysql_store_result()或mysql_use_result() 。对于其他查询,不需要调用mysql_store_result()或mysql_use_result(),但是如果在任何情况下均调用了mysql_store_result(),它也不会导致任何伤害或性能降低。

4.mysql_num_rows()

返回结果集中的行数。

5.数据库操作6()

返回结果集中的字段数,如果失败,则返回 false。

6.数据库操作7()

MYSQL_FIELD* mysql_fetch_field(MYSQL_RES *result);
获取下一个表字段的类型,结束返回NULL。

7.数据库操作8()

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

从结果集中获取下一行,成功返回一个数据库操作9,值大于0。

8.mysql_fetch_field_linux0ect()

MYSQL_FIELD* mysql_fetch_field_direct(MYSQL_RES *result, int i);

给定字段编号,返回表字段的类型,结束返回NULL。

简单的学生信息管理代码

光看也记不住啊,就用这些函数写了一个学生信息管理界面,唉,去年这时候linux1课程设计,当时还不知道用数据库,全用文件写的,知道晚了很后悔啊。。。。下面是代码:

 /*************************************************************************
   > File Name: student.cpp
   > Author: Tanswer_ 
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 16时50分34秒
 ************************************************************************/
          
 #include 
 #include  
 #include  
 #include 
 #include 
 #include 
 #include 
          
 using namespace std;
          
          
 MYSQL mysql;   
 MYSQL_ROW row;  
 MYSQL_FIELD* field = NULL;       
 MYSQL_RES* result;                                                  
          
 string IntToStr(int num)
 {         
   stringstream ss;
   ss.clear();
   ss << num;
   return ss.str();
 }
                                                            
 void Add()
 {
   string fname,fsex,ftel,faddr;
   int fage;
   char choice; 
   do
   {
   ┊  cout << "请依次输入以下信息:" << endl;
   ┊  cout << "\nName: ";cin >> fname;
   ┊  cout << "\nSex: ";cin >> fsex;
   ┊  cout << "\nAge: "; cin >> fage;
   ┊  cout << "\nTel: "; cin >> ftel;
   ┊  cout << "\nAddr: "; cin >> faddr;
 
   ┊  string sql = "INSERT INTO Infor (name,sex,tel,addr,age) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"',   "+IntToStr(fage)+");";
   ┊  //string sql = "INSERT INTO Infor (name,sex,age,tel,addr) values('小红','女',18,'13333333333',          '陕西省西安市雁塔区');";

   ┊  mysql_query(&mysql,sql.c_str());
   ┊  ┊               
   ┊  cout << "是否继续添加(y/n)?: ";
   ┊  cin >> choice;                                                
   }while(choice == 'y');       
                    
 }                   
                    
 void Select()             
 {                   
   int id;              
   cout << "请输入要查询学生的学号: ";
   cin >> id;             
                    
   string sql = "SELECT * FROM Infor WHERE id = "+IntToStr(id)+";";
   mysql_query(&mysql,sql.c_str());
            
   result = mysql_store_result(&mysql);
   if(result == NULL)
   ┊  cout << "fail\n";
            
   for(int i=0; iname << "\t\t";
   }                
   cout << endl;          
                   
   row = mysql_fetch_row(result);  
   while(row != NULL)        
   {                
   ┊  for(int i=0; i> id;          
   ┊  cout << endl << "请输入修改后的地址: ";
   ┊  cin >> newaddr;
   ┊  string sql = "UPDATE Infor SET addr = '"+newaddr+"'WHERE id= "+IntToStr(id)+"; ";
   ┊  mysql_query(&mysql,sql.c_str());                                       
   ┊     
 }       
        
        
 int main()  
 {       
   char choice[5];
        
   mysql_init(&mysql);
   /*连接数据库*/
   if(!mysql_real_connect(&mysql,"localhost","root","dxm242012","Student",0,NULL,0))
   {     
   ┊  cout << "connect fial\n";
   ┊  return -1;
   }     
        
   while(atoi(choice) != 'q')
   {     
   ┊  sleep(4);
   ┊  system("clear");
   ┊  cout << "1.添加学生信息" << endl;
   ┊  cout << "2.查询学生信息" << endl;
   ┊  cout << "3.修改学生信息" << endl;
                                                            
   ┊  cin >> choice;
   
   ┊  cout << choice << endl;
   ┊  switch(atoi(choice))
   ┊  {  
   ┊  ┊  case 1:
   ┊  ┊  ┊  Add();
   ┊  ┊  ┊  break;
   ┊  ┊  case 2:
   ┊  ┊  ┊  Select();
   ┊  ┊  ┊  break;
   ┊  ┊  case 3:
   ┊  ┊  ┊  Update();
   ┊  ┊  ┊  break;
   ┊  ┊  default:
   ┊  ┊  ┊  break;
   ┊  }  
   }
 
   mysql_close(&mysql);
   return 0;
 }

C++封装MyDB类

后来又把这些函数简单的封装了一下,方便以后直接用。

 /*************************************************************************
   > File Name: myDB.h
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时26分22秒
 ************************************************************************/
  
 #ifndef _MYDB_H
 #define _MYDB_H
  
 #include 
 #include 
 #include 
 using namespace std;
  
 class MyDB
 { 
  
 public:
   MyDB();
   ~MyDB();
   bool InitDB(string host,string user,string pwd,string dbname);                          
   bool ExeSQL(string sql);
 private:
   MYSQL* mysql;
   MYSQL* mysql;
   MYSQL_ROW row;
   MYSQL_RES* result;
   MYSQL_FIELD* field;                                                
 };
  
  
 #endif                                                           

 /*************************************************************************                      
   > File Name: myDB.cpp
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时27分18秒
 ************************************************************************/
 
 #include 
 #include 
 #include 
 #include    
 #include  
 #include "myDB.h"
 
 using namespace std;
 
 MyDB::MyDB()   
 {
   mysql = mysql_init(NULL);
   if(mysql == NULL)
   {
   ┊  cout << "Error: " << mysql_error(mysql);
   ┊  exit(-1);
   }      
 }
 
 MyDB::~MyDB()
 {                                                           
   if(!mysql)
   {
   ┊  mysql_close(mysql);
   }
 }
 
 bool MyDB::InitDB(string host,string user,string pwd,string dbname)
 {
   /*连接数据库*/
   if(!mysql_real_connect(mysql,host.c_str(),user.c_str(),pwd.c_str(),dbname.c_str(),0,NULL,0))
   {
   ┊  cout << "connect fial: " << mysql_error(mysql);
   ┊  exit(-1);
   }
   return true;
 }
 
 bool MyDB::ExeSQL(string sql)
 {
   /*执行失败*/
   if(mysql_query(mysql,sql.c_str()))
   {
   ┊  cout << "query fail: " << mysql_error(mysql);
   ┊  exit(1);                                                   
   }
 
   else
   {
   ┊  /*获取结果集*/
   ┊  result = mysql_store_result(mysql);
 
   ┊  int fieldnum = mysql_num_fields(result);
   ┊  for(int i=0; i File Name: main.cpp
   > Author: Tanswer_
   > Mail: 98duxm@gmail.com
   > Created Time: 2017年05月28日 星期日 22时53分43秒
 ************************************************************************/
    
 #include 
 #include 
 #include 
 #include 
 #include 
 #include "myDB.h"
    
 using namespace std;
    
    
 int main()
 {   
   MyDB db;
   db.InitDB("localhost","root","xxxxxx","Student");
   db.ExeSQL("SELECT * FROM Infor;");
   return 0;
 }

以下是运行结果:

下面是遇到的问题:
1. 编译时出错
没有那个文件或目录 

#include 
^

编译中断。
解决:除了mysql-client和mysql-server,又linux2了mysql-devel,然后就解决了。

2. 自定义的linux3传入sql语句时,出现问题

在网上查找到这样一种格式,
string sql = "INSERT INTO Infor (name,sex,tel,addr,age) values('"+fname+"','"+fsex+"','"+ftel+"','"+faddr+"', "+IntToStr(fage)+");";
然后string类型的可以成功,整型的变量还是不行,我又写了个函数把int转为string。

 string IntToStr(int num)
 {         
   stringstream ss;
   ss.clear();
   ss << num;
   return ss.str();
 }


# linux  # c++  # mysql  # 请输入  # 星期日  # 几个  # 客户端  # 连接数据库  # 写了  # 信息管理  # 自己的  # 应于  # 西安市 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Laravel怎么创建自己的包(Package)_Laravel扩展包开发入门到发布  如何快速生成橙子建站落地页链接?  Laravel全局作用域是什么_Laravel Eloquent Global Scopes应用指南  Laravel如何使用Seeder填充数据_Laravel模型工厂Factory批量生成测试数据【方法】  消息称 OpenAI 正研发的神秘硬件设备或为智能笔,富士康代工  Swift开发中switch语句值绑定模式  zabbix利用python脚本发送报警邮件的方法  网站制作怎么样才能赚钱,用自己的电脑做服务器架设网站有什么利弊,能赚钱吗?  详解Android——蓝牙技术 带你实现终端间数据传输  Laravel集合Collection怎么用_Laravel集合常用函数详解  jimdo怎样用html5做选项卡_jimdo选项卡html5实现与切换效果【指南】  想要更高端的建设网站,这些原则一定要坚持!  Laravel如何自定义错误页面(404, 500)?(代码示例)  如何用PHP快速搭建CMS系统?  如何破解联通资金短缺导致的基站建设难题?  如何快速配置高效服务器建站软件?  如何快速打造个性化非模板自助建站?  用v-html解决Vue.js渲染中html标签不被解析的问题  香港服务器网站测试全流程:性能评估、SEO加载与移动适配优化  网页设计与网站制作内容,怎样注册网站?  Laravel如何实现登录错误次数限制_Laravel自带LoginThrottles限流配置【方法】  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗?  北京的网站制作公司有哪些,哪个视频网站最好?  Laravel中的Facade(门面)到底是什么原理  宙斯浏览器怎么屏蔽图片浏览 节省手机流量使用设置方法  如何获取PHP WAP自助建站系统源码?  如何制作一个表白网站视频,关于勇敢表白的小标题?  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  Laravel Seeder怎么填充数据_Laravel数据库填充器的使用方法与技巧  Laravel模型事件有哪些_Laravel Model Event生命周期详解  Swift中switch语句区间和元组模式匹配  浅谈redis在项目中的应用  JavaScript如何实现继承_有哪些常用方法  为什么要用作用域操作符_php中访问类常量与静态属性的优势【解答】  音响网站制作视频教程,隆霸音响官方网站?  Laravel如何实现多语言支持_Laravel本地化与国际化(i18n)配置教程  java获取注册ip实例  Laravel Admin后台管理框架推荐_Laravel快速开发后台工具  Laravel观察者模式如何使用_Laravel Model Observer配置  如何快速搭建二级域名独立网站?  制作旅游网站html,怎样注册旅游网站?  *服务器网站为何频现安全漏洞?  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设?  昵图网官方站入口 昵图网素材图库官网入口  详解Nginx + Tomcat 反向代理 如何在高效的在一台服务器部署多个站点  Java垃圾回收器的方法和原理总结  如何实现建站之星域名转发设置?  通义万相免费版怎么用_通义万相免费版使用方法详细指南【教程】  网站制作软件免费下载安装,有哪些免费下载的软件网站?  北京网站制作的公司有哪些,北京白云观官方网站?