C/C++下Mysql的api使用(连接增删改查)实例讲解
最近在了解c++下使用mysql的方法及其中各种的问题,也看了很多博客。其实对于每种的操作,基本的方法都是非常类似的,大多都是connect,select,update,delete以及insert这几个操作。之前在delphi下用过ado,但是具有一些局限性(mysql-odbc驱动、运行库)现在又刚好要做c++的,看了别人写的这个蛮适合学习的就转载一下(第一次发博,试试手感),参照例子改改就可以得到自己想要的了。
1.mysql的初始化initconnection:
1)mysql_init():初始化数据库
2)mysql_real_connect()(不推荐用mysql_connect()):连接数据库
详细代码如下:
1 bool database::initconnection() { 2 try { 3 if (mysql_init(&m_sqlcon) == null) { 4 std::cout << "初始化数据库失败" << std::endl; 5 return false; 6 } 7 // localhost:服务器 root为账号密码 test为数据库名 3306为端口 8 if (!mysql_real_connect(&m_sqlcon, host, user, pass,databasename, port, null, 0)) 9 { 10 std::cout << "数据库连接失败" << std::endl; 11 return false; 12 } 13 std::cout << "数据库连接成功" << std::endl; 14 return true; 15 } 16 catch (...) 17 { 18 std::cout << "出错啦" << std::endl; 19 return false; 20 } 21 }
2.mysql的查询select:
1)mysql_query():进行查询语句
2)mysql_store_result():获得查询结果
3 ) mysql_fetch_field()以及mysql_fetch_row():获得结果集中的内容
4)mysql_free_result()
代码如下:
1 void database::user_query() { 2 if (mysql_query(&m_sqlcon, "select * from user")) { 3 std::cout << "查询失败" << std::endl; 4 return; 5 } 6 std::cout << "查询成功" << std::endl; 7 mysql_res *result; 8 result = mysql_store_result(&m_sqlcon); 9 if (result) { 10 int row_num,col_num; 11 row_num = mysql_num_rows(result); 12 col_num = mysql_num_fields(result); 13 std::cout << "共有" << row_num << "条数据,以下为其详细内容:" << std::endl; 14 mysql_field *fd; 15 while (fd = mysql_fetch_field(result)) { 16 std::cout << fd->name << "\t"; 17 } 18 std::cout << std::endl; 19 mysql_row sql_row; 20 while (sql_row = mysql_fetch_row(result)) { 21 for (int i = 0; i < col_num; i++) { 22 if (sql_row[i] == null) std::cout << "null\t"; 23 else std::cout << sql_row[i] << "\t"; 24 } 25 std::cout << std::endl; 26 } 27 } 28 if(result!=null) 29 mysql_free_result(result); 30 31 }
3.mysql的插入语句insert:
1)mysql_query()通过select判断是否已经存在(可以省略)
2)通过mysql_query()进行插入
代码如下:
1 void database::user_insert(userbody &body) { 2 char select_user[255]; 3 char query[255]; 4 mysql_res *result; 5 sprintf(select_user, "select * from user where username='%s'", body.username); 6 if (mysql_query(&m_sqlcon, select_user)||!(result = mysql_store_result(&m_sqlcon))) { 7 std::cout << "插入查询失败" << std::endl; 8 return; 9 } 10 if (mysql_num_rows(result)) { 11 std::cout << "用户已存在" << std::endl; 12 mysql_free_result(result); 13 return; 14 } 15 mysql_free_result(result); 16 sprintf(query, "insert into user(username,userpass,connectionnum,usefor) values('%s','%s',%d,%d)", body.username, body.userpass, body.connection, body.type); 17 if (mysql_query(&m_sqlcon, query)) { 18 std::cout << "插入数据失败" << std::endl; 19 return; 20 } 21 std::cout << "插入数据成功,共插入:" <4.mysql的修改语句update
修改与添加的步骤类似,直接贴出代码就不做赘述了。
代码如下:
1 void database::user_update(userbody &body) { 2 char query[255]; 3 char select_user[255]; 4 mysql_res *result; 5 sprintf(select_user, "select * from user where username='%s'", body.username); 6 if (mysql_query(&m_sqlcon, select_user) || !(result = mysql_store_result(&m_sqlcon))) { 7 std::cout << "修改查询失败" << std::endl; 8 return; 9 } 10 if (mysql_num_rows(result) == 0) { 11 std::cout << "要修改的用户不存在" << std::endl; 12 mysql_free_result(result); 13 return; 14 } 15 mysql_free_result(result); 16 sprintf(query, "update user set userpass='%s',connectionnum=%d,usefor=%d where username='%s'", body.userpass, body.connection, body.type, body.username); 17 if (mysql_query(&m_sqlcon, query)) { 18 std::cout << "修改失败" << std::endl; 19 return; 20 } 21 std::cout << "修改成功,共修改:" << mysql_affected_rows(&m_sqlcon) << "行" << std::endl; 22 }5.mysql的删除操作delete
其实删除、修改和插入操作都是类似的,会其中一个其他应该都差不多了,我也就直接贴出代码了。
代码如下:
1 void database::user_delete(char *username) { 2 char query[255]; 3 char select_user[255]; 4 mysql_res *result; 5 sprintf(select_user, "select * from user where username='%s'", username); 6 if (mysql_query(&m_sqlcon, select_user)||!(result = mysql_store_result(&m_sqlcon))) { 7 std::cout << "删除查询失败" << std::endl; 8 return; 9 } 10 if (mysql_num_rows(result)==0) { 11 std::cout << "要删除的用户不存在" << std::endl; 12 mysql_free_result(result); 13 return; 14 } 15 mysql_free_result(result); 16 sprintf(query, "delete from user where username='%s'", username); 17 if (mysql_query(&m_sqlcon, query)) { 18 std::cout << "删除失败" << std::endl; 19 return; 20 } 21 std::cout << "删除成功,共删除:" << mysql_affected_rows(&m_sqlcon) << "行" << std::endl; 22 }以上算是对mysql中常用的一些代码的总结,有什么不完善的希望大家能够提出来,也希望这个能在平时帮到大家,起到一个模板的作用,也能方便大家对mysql的学习。我也属于一个learner,也希望能和大家在平时中相互学习。
"行">"行">
上一篇: 儿童怎样增加骨密度 四类食物告诉你答案
下一篇: macOS安装MySQL的简单使用介绍