Rooba
/
drogon
mirror of https://github.com/drogonframework/drogon.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Modify DbClientImpl

This commit is contained in:
antao 2019-02-24 09:55:26 +08:00
parent 1b9e91361c
commit 429490bd78
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
orm_lib/src/DbClientImpl.cc
View File

@ -127,9 +127,13 @@ void DbClientImpl::execSql(const DbConnectionPtr &conn,
} }
return; return;
} }
std::weak_ptr<DbConnection> weakConn = conn; conn->execSql(std::move(sql),
conn->execSql(std::move(sql), paraNum, std::move(parameters), std::move(length), std::move(format), paraNum,
std::move(rcb), std::move(exceptCallback)); std::move(parameters),
std::move(length),
std::move(format),
std::move(rcb),
std::move(exceptCallback));
} }
void DbClientImpl::execSql(std::string &&sql, void DbClientImpl::execSql(std::string &&sql,
size_t paraNum, size_t paraNum,
@ -245,7 +249,7 @@ std::shared_ptr<Transaction> DbClientImpl::newTransaction(const std::function<vo
} }
conn->loop()->queueInLoop([weakThis, conn]() { conn->loop()->queueInLoop([weakThis, conn]() {
auto thisPtr = weakThis.lock(); auto thisPtr = weakThis.lock();
if(!thisPtr) if (!thisPtr)
return; return;
std::weak_ptr<DbConnection> weakConn = conn; std::weak_ptr<DbConnection> weakConn = conn;
conn->setIdleCallback([weakThis, weakConn]() { conn->setIdleCallback([weakThis, weakConn]() {