GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-29 11:36:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/sogou/workflow into nossl

Browse Source
This commit is contained in:
Xie Han
2023-11-11 03:07:41 +08:00
parent 7c2449d1a0 dece7f57af
commit 45007303ba
1 changed files with 13 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFMySQLConnection.h
+13 -23
View File
@@ -37,13 +37,23 @@ public:
public:
WFMySQLTask *create_query_task(const std::string& query,
mysql_callback_t callback);
mysql_callback_t callback)
{
WFMySQLTask *task = WFTaskFactory::create_mysql_task(this->uri, 0,
std::move(callback));
task->get_req()->set_query(query);
return task;
}
public:
/* If you don't disconnect manually, the TCP connection will be
* kept alive after this object is deleted, and maybe reused by
* another WFMySQLConnection object with same id and url. */
WFMySQLTask *create_disconnect_task(mysql_callback_t callback);
WFMySQLTask *create_disconnect_task(mysql_callback_t callback)
{
WFMySQLTask *task = this->create_query_task("", std::move(callback));
task->set_keep_alive(0);
return task;
}
protected:
ParsedURI uri;
@@ -56,25 +66,5 @@ public:
virtual ~WFMySQLConnection() { }
};
inline WFMySQLTask *
WFMySQLConnection::create_query_task(const std::string& query,
mysql_callback_t callback)
{
WFMySQLTask *task = WFTaskFactory::create_mysql_task(this->uri, 0,
std::move(callback));
task->get_req()->set_query(query);
return task;
}
inline WFMySQLTask *
WFMySQLConnection::create_disconnect_task(mysql_callback_t callback)
{
WFMySQLTask *task = WFTaskFactory::create_mysql_task(this->uri, 0,
std::move(callback));
task->get_req()->set_query("");
task->set_keep_alive(0);
return task;
}
#endif