Linux下实现C++操作Mysql数据库
发布时间 - 2026-01-11 01:31:23 点击率:次想用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终结的字符串”的SQL查询
返回一个结果表,假定查询成功,可以调用 mysql_num_rows() 来查看对应于 SELECT 语句返回了多少行,或者调用 mysql_affected_rows() 来查看对应于 DELETE,INSERT,REPLACE 或 UPDATE 语句影响到了多少行。
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.mysql_num_fields()
返回结果集中的字段数,如果失败,则返回 false。
6.mysql_fetch_field()
MYSQL_FIELD* mysql_fetch_field(MYSQL_RES *result);
获取下一个表字段的类型,结束返回NULL。
7.mysql_fetch_row()
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
从结果集中获取下一行,成功返回一个数组,值大于0。
8.mysql_fetch_field_direct()
MYSQL_FIELD* mysql_fetch_field_direct(MYSQL_RES *result, int i);
给定字段编号,返回表字段的类型,结束返回NULL。
简单的学生信息管理代码
光看也记不住啊,就用这些函数写了一个学生信息管理界面,唉,去年这时候C语言课程设计,当时还不知道用数据库,全用文件写的,知道晚了很后悔啊。。。。下面是代码:
/*************************************************************************
> File Name: student.cpp
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 16时50分34秒
************************************************************************/
#include <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <sstream>
#include <mysql/mysql.h>
#include <unistd.h>
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; i<mysql_num_fields(result); i++)
{
┊ field = mysql_fetch_field_direct(result,i);
┊ cout << field->name << "\t\t";
}
cout << endl;
row = mysql_fetch_row(result);
while(row != NULL)
{
┊ for(int i=0; i<mysql_num_fields(result); i++)
┊ {
┊ ┊ cout << row[i] << "\t\t";
┊ }
┊ cout << endl;
┊ row = mysql_fetch_row(result);
}
}
void Update()
{
int id;
char choice;
string newaddr;
┊ cout << "请输入要修改同学的学号: ";
┊ cin >> 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 <string>
#include <iostream>
#include <mysql/mysql.h>
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 <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <mysql/mysql.h>
#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<fieldnum; i++)
┊ {
┊ ┊ row = mysql_fetch_row(result);
┊ ┊ if(row <= 0)
┊ ┊ ┊ break;
┊ ┊ for(int j=0; j<fieldnum; j++)
┊ ┊ {
┊ ┊ ┊ cout << row[j] << "\t\t";
┊ ┊ }
┊ ┊ cout << endl;
┊ }
┊ mysql_free_result(result);
}
return true;
}
/*************************************************************************
> File Name: main.cpp
> Author: Tanswer_
> Mail: 98duxm@gmail.com
> Created Time: 2017年05月28日 星期日 22时53分43秒
************************************************************************/
#include <iostream>
#include <string>
#include <stack>
#include <algorithm>
#include <mysql/mysql.h>
#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/mysql.h> ^
编译中断。
解决:除了mysql-client和mysql-server,又安装了mysql-devel,然后就解决了。
2. 自定义的变量传入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();
}
大概就是这样,门卫大叔很凶,我也很绝望,就写到这吧,有问题再补充。
# C++操作MySQl
# c++连接MySQL
# C++
# API方式连接mysql
# c++连接mysql数据库的两种方法(ADO连接和mysql api连接)
# C++利用MySQL API连接和操作数据库实例详解
# C++操作MySQL大量数据插入效率低下的解决方法
# C++与mysql连接遇到的问题汇总
# 介绍一个针对C++程序的MySQL访问库soci
# C++连接mysql的方法(直接调用C-API)
# C/C++ 连接MySql数据库的方法
# C++用mysql自带的头文件连接数据库
# 用C++封装MySQL的API的教程
# C++连接并使用MySQL数据库
# 请输入
# 星期日
# 几个
# 客户端
# 连接数据库
# 写了
# 信息管理
# 自己的
# 应于
# 西安市
# 有什么
# 在网上
# 陕西省
# 是在
# 也没
# 不需要
# 有很多
# 句柄
# 还不
# 我又
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
JS中对数组元素进行增删改移的方法总结
如何制作一个表白网站视频,关于勇敢表白的小标题?
如何在宝塔面板中创建新站点?
Swift中循环语句中的转移语句 break 和 continue
C++时间戳转换成日期时间的步骤和示例代码
香港服务器建站指南:外贸独立站搭建与跨境电商配置流程
如何快速搭建个人网站并优化SEO?
canvas 画布在主流浏览器中的尺寸限制详细介绍
如何快速打造个性化非模板自助建站?
详解Android——蓝牙技术 带你实现终端间数据传输
专业商城网站制作公司有哪些,pi商城官网是哪个?
bootstrap日历插件datetimepicker使用方法
如何利用DOS批处理实现定时关机操作详解
ai格式如何转html_将AI设计稿转换为HTML页面流程【页面】
jQuery validate插件功能与用法详解
中国移动官方网站首页入口 中国移动官网网页登录
手机怎么制作网站教程步骤,手机怎么做自己的网页链接?
Laravel中间件起什么作用_Laravel Middleware请求生命周期与自定义详解
网站制作报价单模板图片,小松挖机官方网站报价?
如何在阿里云虚拟机上搭建网站?步骤解析与避坑指南
Thinkphp 中 distinct 的用法解析
大型企业网站制作流程,做网站需要注册公司吗?
Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】
网站制作壁纸教程视频,电脑壁纸网站?
Claude怎样写约束型提示词_Claude约束提示词写法【教程】
今日头条AI怎样推荐抢票工具_今日头条AI抢票工具推荐算法与筛选【技巧】
阿里云网站搭建费用解析:服务器价格与建站成本优化指南
Laravel怎么连接多个数据库_Laravel多数据库连接配置
如何用AI一键生成爆款短视频文案?小红书AI文案写作指令【教程】
Laravel软删除怎么实现_Laravel Eloquent SoftDeletes功能使用教程
Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程
百度输入法ai面板怎么关 百度输入法ai面板隐藏技巧
免费视频制作网站,更新又快又好的免费电影网站?
Zeus浏览器网页版官网入口 宙斯浏览器官网在线通道
ChatGPT 4.0官网入口地址 ChatGPT在线体验官网
如何基于云服务器快速搭建网站及云盘系统?
小视频制作网站有哪些,有什么看国内小视频的网站,求推荐?
Laravel怎么实现观察者模式Observer_Laravel模型事件监听与解耦开发【指南】
Laravel Facade的原理是什么_深入理解Laravel门面及其工作机制
Win11怎么关闭透明效果_Windows11辅助功能视觉效果设置
如何在腾讯云服务器上快速搭建个人网站?
zabbix利用python脚本发送报警邮件的方法
详解免费开源的.NET多类型文件解压缩组件SharpZipLib(.NET组件介绍之七)
google浏览器怎么清理缓存_谷歌浏览器清除缓存加速详细步骤
Laravel模型关联查询教程_Laravel Eloquent一对多关联写法
Laravel如何使用Socialite实现第三方登录?(微信/GitHub示例)
Laravel如何记录自定义日志?(Log频道配置)
phpredis提高消息队列的实时性方法(推荐)
Angular 表单中正确绑定输入值以确保提交与验证正常工作
详解Nginx + Tomcat 反向代理 如何在高效的在一台服务器部署多个站点

