MySQL Connector/C++ 接口实例

mysql的官方网站有对MySQL Connector/C++的文档解释和具体实例，但是大家也知道，如果把那些具体实例的代码只是生硬的套入项目工程中是万万不行的，因为项目安全性要求，需要对容错，资源创建释放问题严格关注，下面贴一个自己的方法函数，里面涵盖了相关安全处理而且对调用存储过程也有所涉及：

bool CommonService::......(JSONNode& in, JSONNode& out)
{
/*=====校验json传入参数=====*/
..........
/*=====解析json传入参数，得到安装码或者id, 安装时间，硬盘序列号， ip，mac=====*/
..........
/*=====通过安装码找到数据库中的对应记录写入传入的值=====*/
/********数据库操作**********/
//1.得到数据库连接
Connection* con = G<ConnectionPool>().GetConnection();
if (con == NULL)
{
LOG4CXX_ERROR(g_logger, "不能得到数据库连接");
out.push_back(JSONNode(RESULT, ACTION_FALSE));
out.push_back(JSONNode(ERROR_MESSAGE, "不能得到数据库连接"));
return false;
}
int ret = 1;
PreparedStatement* prep_stmt = NULL;
ResultSet* res = NULL;
try
{
con->setSchema(G<ConnectionPool>().GetDBName().c_str());
//执行sql改变安装状态
std::string sql_statement = "update tb_host set reg_date=?, sn=?, ip=?, mac=?, state=?, sync_state=? where reg_code =? and state=?"; //要执行的sql语句
//事务处理
con->setAutoCommit(0);
prep_stmt = con->prepareStatement(sql_statement.c_str());
prep_stmt->setString(1, install_time.c_str());
prep_stmt->setString(2, harddrive_sn.c_str());
prep_stmt->setString(3, ip_address.c_str());
prep_stmt->setString(4, mac_address.c_str());
prep_stmt->setInt(5, HAS_INSTALL);
prep_stmt->setInt(6, HAS_SYNC);
prep_stmt->setString(7, install_code.c_str());
prep_stmt->setInt(8, NO_INSTALL);
if(prep_stmt->executeUpdate() == 0)
{
ret = 2;
LOG4CXX_INFO(g_logger, ".....");
out.push_back(JSONNode(ERROR_MESSAGE, "....."));
goto Finally_handle;
}
//调用赋默认策略存储过程
std::string procedure = "CALL updateHostPolicyByModHost(?,?, @ret, @msg)";
prep_stmt = con->prepareStatement(procedure.c_str());
prep_stmt->setString(1, install_code.c_str());
prep_stmt->setInt(2, 0);
prep_stmt->execute();
std::string query = "select @ret AS ret,@msg AS msg";
prep_stmt = con->prepareStatement(query.c_str());
res = prep_stmt->executeQuery();
while(res->next())
{
if(res->getInt("ret") != 0)
{
LOG4CXX_ERROR(g_logger, "....." << res->getString("msg").c_str() << res->getInt("ret"));
out.push_back(JSONNode(ERROR_MESSAGE, "....."));
goto Finally_handle;
}
}
con ->commit();
}
catch (SQLException& e)
{
try
{
con->rollback();
}
catch (SQLException& e)
{
ret = 0;
LOG4CXX_ERROR(g_logger, "数据库异常" << e.what());
}
ret = 0;
LOG4CXX_ERROR(g_logger, "数据库异常" << e.what());
out.push_back(JSONNode(ERROR_MESSAGE, e.what()));
}
catch (...)
{
ret = 0;
LOG4CXX_ERROR(g_logger, "其他错误");
out.push_back(JSONNode(ERROR_MESSAGE, "其他错误"));
}
Finally_handle:
DestorySql(res, prep_stmt);
//将连接释放到连接池
G<ConnectionPool>().ReleaseConnection(con);
if (ret == 1)
{
out.push_back(JSONNode(RESULT, ACTION_SUCCESS));
return true;
}
else if (ret == 2)
{
out.push_back(JSONNode(RESULT, ACTION_FALSE));
return true;
}
else
{
out.push_back(JSONNode(RESULT, ACTION_FALSE));
return false;
}
}

/************************************************************************/
/* 销毁数据库记录集资源 */
/************************************************************************/
void CommonService::DestorySql(ResultSet* res, PreparedStatement* prep_stmt)
{
if (res != NULL)
{
try
{
res ->close();
}
catch(SQLException& e)
{
LOG4CXX_ERROR(g_logger, "数据库异常" << e.what());
}
delete res;
res = NULL;
}
if (prep_stmt != NULL){
try
{
prep_stmt->close();
}
catch(SQLException& e)
{
LOG4CXX_ERROR(g_logger, "数据库异常" << e.what());
}
delete prep_stmt;
prep_stmt = NULL;
}
}

本文转自永远的朋友博客51CTO博客，原文链接http://blog.51cto.com/yaocoder/643004如需转载请自行联系原作者

yaocoder

MySQL Connector/C++ 接口实例相关推荐

Linux MySQL Connector/C++ 编程实例
本篇文章介绍如何在Linux平台使用Connector/C++ 连接数据库,假定MySQL已经安装完成.如果还没有安装MySQL,请先安装.MySQL版本:8.0.19 目录 1. 安装Connect ...
mysql connector cpp_MySQL Connector/C++（一）
如果我翻译错了或者翻译的不好,欢迎指正- Developing Database Applications Using MySQL Connector/C++ 这个教程会教你搭建安装MySQL Con ...
Win10+Python+Django+Nginx+MySQL开发教程及实例（2）——Python连通操作MySQL
Win10+Python+Django+Nginx+MySQL开发教程及实例 PaulTsao 本系列教程共有四篇内容: 第一篇: 开发环境搭建第二篇:用Python连通操作MySQL 第三篇:用N ...
Developing DataBase Applications Using MySQL Connector/C++ 中文文本
日期备注 2020年6月3日对排版进行了调整. 翻译自mysql Connector C++帮助文档[http://download.csdn.net/detail/midle110/4931 ...
mysql connector python linux_MySQL Connector/Python 安装、测试
安装Connector/Python: # wget http://cdn.mysql.com/Downloads/Connector-Python/mysql-connector-python-1. ...
python连接sqlserver_python 链接sqlserver 写接口实例
我是使用pymssql完成的sqlserver,首先下载符合版本的pymssql的whl,然后安装,在pycharm的default setting->project Interpreter中确 ...
python3 操作mysql数据库（mysql.connector 和 pymysql ）
1. PyMySQL 的使用 (1) 什么是 PyMySQL? PyMySQL 是 Python 中用于连接 MySQL 服务器的一个库,它遵循 Python 数据库 API 规范 V2.0,并包 ...
Win10+Python+Django+Nginx+MySQL开发教程及实例（1）——开发环境搭建
Win10+Python+Django+Nginx+MySQL开发教程及实例 PaulTsao 本教程共有三篇内容: 第一篇:Win10+Python+Django+Nginx+MySQL 开发环境搭 ...
mysql connector c编程_MySQL数据库之MySQL Connector 编程
本文主要向大家介绍了MySQL数据库之MySQL Connector 编程 ,通过具体的内容向大家展现,希望对大家学习MySQL数据库有所帮助. MySQL Connector 是MySQL数据库客户 ...

MySQL Connector/C++ 接口实例

MySQL Connector/C++ 接口实例相关推荐

最新文章

热门文章