Skip to content

Commit fc7f78c

Browse files
committed
增加调试信息
1 parent 88d0f7b commit fc7f78c

File tree

4 files changed

+25
-14
lines changed

4 files changed

+25
-14
lines changed

kbe/src/lib/db_mysql/db_interface_mysql.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,7 @@ hasLostConnection_(false),
149149
inTransaction_(false),
150150
lock_(NULL, false),
151151
characterSet_(characterSet),
152-
collation_(collation),
153-
lastquery_()
152+
collation_(collation)
154153
{
155154
lock_.pdbi(this);
156155
}

kbe/src/lib/db_mysql/db_interface_mysql.hpp

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ class DBInterfaceMysql : public DBInterface
119119
{
120120
if(pMysql_ == NULL)
121121
return "pMysql is NULL";
122+
122123
return mysql_error( pMysql_ );
123124
}
124125

@@ -162,11 +163,6 @@ class DBInterfaceMysql : public DBInterface
162163
处理异常
163164
*/
164165
bool processException(std::exception & e);
165-
166-
/**
167-
获取最后一次查询的sql语句
168-
*/
169-
std::string lastquery()const{ return lastquery_; }
170166
protected:
171167
MYSQL* pMysql_;
172168

@@ -178,8 +174,6 @@ class DBInterfaceMysql : public DBInterface
178174

179175
std::string characterSet_;
180176
std::string collation_;
181-
182-
std::string lastquery_;
183177
};
184178

185179

kbe/src/lib/dbmgr_lib/db_interface.hpp

Lines changed: 17 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,17 @@ class DBInterface
4343
};
4444

4545
friend class DBUtil;
46-
DBInterface(){};
47-
virtual ~DBInterface(){};
46+
47+
DBInterface():
48+
db_port_(3306),
49+
db_numConnections_(1),
50+
lastquery_()
51+
{
52+
};
53+
54+
virtual ~DBInterface()
55+
{
56+
};
4857

4958
/**
5059
检查环境
@@ -116,6 +125,11 @@ class DBInterface
116125
处理异常
117126
*/
118127
virtual bool processException(std::exception & e) = 0;
128+
129+
/**
130+
获取最后一次查询的sql语句
131+
*/
132+
virtual const std::string& lastquery()const{ return lastquery_; }
119133
protected:
120134
char db_type_[MAX_BUF]; // 数据库的类别
121135
uint32 db_port_; // 数据库的端口
@@ -124,6 +138,7 @@ class DBInterface
124138
char db_password_[MAX_BUF]; // 数据库的密码
125139
char db_name_[MAX_BUF]; // 数据库名
126140
uint16 db_numConnections_; // 数据库最大连接
141+
std::string lastquery_; // 最后一次查询描述
127142
};
128143

129144
/*

kbe/src/server/dbmgr/dbtasks.cpp

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ bool DBTask::process()
9696
if (duration > stampsPerSecond())
9797
{
9898
WARNING_MSG(boost::format("DBTask::process(): took %.2f seconds\nsql:(%s)\n") %
99-
(double(duration)/stampsPerSecondD()) % static_cast<DBInterfaceMysql*>(pdbi_)->lastquery().c_str());
99+
(double(duration)/stampsPerSecondD()) % pdbi_->lastquery());
100100
}
101101

102102
return ret;
@@ -670,6 +670,7 @@ bool DBTaskCreateMailAccount::db_thread_process()
670670
ACCOUNT_INFOS info;
671671
if(accountName_.size() == 0)
672672
{
673+
ERROR_MSG("DBTaskCreateMailAccount::db_thread_process(): accountName is NULL!\n");
673674
return false;
674675
}
675676

@@ -682,7 +683,7 @@ bool DBTaskCreateMailAccount::db_thread_process()
682683
{
683684
if(pdbi_->getlasterror() > 0)
684685
{
685-
WARNING_MSG(boost::format("DBTaskCreateMailAccount::db_thread_process(): queryAccount error: %1%\n") %
686+
WARNING_MSG(boost::format("DBTaskCreateMailAccount::db_thread_process(): queryAccount is error: %1%\n") %
686687
pdbi_->getstrerror());
687688
}
688689

@@ -707,6 +708,8 @@ bool DBTaskCreateMailAccount::db_thread_process()
707708
}
708709
catch (...)
709710
{
711+
WARNING_MSG(boost::format("DBTaskCreateMailAccount::db_thread_process(): logAccount(kbe_accountinfos) is error: %1%\n%2%\n") %
712+
pdbi_->getstrerror() % pdbi_->lastquery());
710713
}
711714

712715
unsigned char md[16];
@@ -730,7 +733,7 @@ bool DBTaskCreateMailAccount::db_thread_process()
730733
//-------------------------------------------------------------------------------------
731734
thread::TPTask::TPTaskState DBTaskCreateMailAccount::presentMainThread()
732735
{
733-
DEBUG_MSG(boost::format("Dbmgr::reqCreateMailAccount:%1%.\n") % registerName_.c_str());
736+
DEBUG_MSG(boost::format("Dbmgr::reqCreateMailAccount:%1%, success=%2%.\n") % registerName_ % success_);
734737

735738
Mercury::Bundle* pBundle = Mercury::Bundle::ObjPool().createObject();
736739
(*pBundle).newMessage(LoginappInterface::onReqCreateMailAccountResult);

0 commit comments

Comments
 (0)