test/drogon
1
0
Fork 0
mirror of https://gitee.com/an-tao/drogon.git synced 2024-12-02 11:47:56 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Debug postgresql connections

Browse Source
This commit is contained in:
antao 2018-12-11 15:06:04 +08:00
parent 7132cb32ca
commit 53b3eb217f
1 changed files with 14 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
orm_lib/src/postgresql_impl/PgConnection.cc
View File

@ -144,46 +144,26 @@ void PgConnection::execSql(const std::string &sql,
_idleCb = idleCb;
_isWorking = true;
_exceptCb = exceptCallback;
if (PQsendQueryParams(
_connPtr.get(),
sql.c_str(),
paraNum,
NULL,
parameters.data(),
length.data(),
format.data(),
0) == 0)
{
LOG_ERROR << "send query error: " << PQerrorMessage(_connPtr.get());
// connection broken! will be handled in handleRead()
// _loop->queueInLoop([=]() {
// try
// {
// throw InternalError(PQerrorMessage(_connPtr.get()));
// }
// catch (...)
// {
// _isWorking = false;
// _exceptCb(std::current_exception());
// _exceptCb = decltype(_exceptCb)();
// if (_idleCb)
// {
// _idleCb();
// _idleCb = decltype(_idleCb)();
// }
// }
// });
// return;
}
auto thisPtr = shared_from_this();
_loop->runInLoop([=]() {
_loop->runInLoop([thisPtr, sql, paraNum, parameters, length, format]() {
if (PQsendQueryParams(
thisPtr->_connPtr.get(),
sql.c_str(),
paraNum,
NULL,
parameters.data(),
length.data(),
format.data(),
0) == 0)
{
LOG_ERROR << "send query error: " << PQerrorMessage(thisPtr->_connPtr.get());
}
thisPtr->pgPoll();
});
}
void PgConnection::handleRead()
{
_loop->assertInLoopThread();
std::shared_ptr<PGresult> res;
if (!PQconsumeInput(_connPtr.get()))