test/hikyuu2
1
0
Fork 0
mirror of https://gitee.com/fasiondog/hikyuu.git synced 2024-12-02 20:08:26 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

MySQL重连更新

Browse Source
This commit is contained in:
fasiondog 2018-05-03 00:45:13 +08:00
parent 1d9939d193
commit 7492d2ffe0
2 changed files with 21 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
libs/hikyuu/data_driver/kdata/mysql/MySQLKDataDriver.cpp
View File

@ -87,32 +87,32 @@ bool MySQLKDataDriver::_query(const string& sql_str) {
return true;
}
if(CR_SERVER_LOST == res || CR_SERVER_GONE_ERROR == res) {
//重新连接数据库
shared_ptr<MYSQL> mysql(new MYSQL, MySQLCloser());
if (!mysql_init(mysql.get())) {
HKU_ERROR(" Initial MySQL handle error!" << func_name);
return false;
}
//重新连接数据库
HKU_INFO("MySQL connect invalid, will retry connect!" << func_name);
m_mysql = NULL;
if (!mysql_real_connect(mysql.get(), m_host.c_str(), m_usr.c_str(),
m_pwd.c_str(), NULL, m_port, NULL, 0) ) {
HKU_ERROR(" Failed to connect to database!" << func_name);
return false;
}
shared_ptr<MYSQL> mysql(new MYSQL, MySQLCloser());
if (!mysql_init(mysql.get())) {
HKU_ERROR(" Initial MySQL handle error!" << func_name);
return false;
}
if (mysql_set_character_set(mysql.get(), "utf8")) {
HKU_ERROR(" mysql_set_character_set error!" << func_name);
return false;
}
if (!mysql_real_connect(mysql.get(), m_host.c_str(), m_usr.c_str(),
m_pwd.c_str(), NULL, m_port, NULL, 0) ) {
HKU_ERROR(" Failed to connect to database!" << func_name);
return false;
}
m_mysql = mysql;
if (mysql_set_character_set(mysql.get(), "utf8")) {
HKU_ERROR(" mysql_set_character_set error!" << func_name);
return false;
}
int res = mysql_query(m_mysql.get(), sql_str.c_str());
if(!res) {
return true;
}
m_mysql = mysql;
res = mysql_query(m_mysql.get(), sql_str.c_str());
if(!res) {
return true;
}
HKU_ERROR("mysql_query error! error no: " << res

2
libs/hikyuu/data_driver/kdata/mysql/MySQLKDataDriver.h
View File

@ -12,10 +12,8 @@
#if defined(BOOST_WINDOWS)
#include <mysql.h>
#include <errmsg.h>
#else
#include <mysql/mysql.h>
#include <mysql/errmsg.h>
#endif
namespace hku {