26#ifndef ROUTER_SRC_MYSQL_REST_SERVICE_SRC_MRS_DATABASE_MYSQL_TASK_H_
27#define ROUTER_SRC_MYSQL_REST_SERVICE_SRC_MRS_DATABASE_MYSQL_TASK_H_
63 std::optional<std::string> user_ownership_column,
64 const std::string &schema,
const std::string &
object,
66 const rapidjson::Document &doc,
const ResultSets &rs);
71 std::optional<std::string> user_ownership_column,
72 const std::string &schema,
const std::string &
object,
74 const rapidjson::Document &doc,
const ResultSets &rs);
79 std::optional<std::string> user_ownership_column,
80 const std::string &schema,
const std::string &
object,
82 const rapidjson::Document &doc,
const ResultSets &rs);
87 std::optional<std::string> user_ownership_column,
88 const std::string &schema,
const std::string &
object,
90 const rapidjson::Document &doc,
const ResultSets &rs);
94 const std::string &task_id);
107 std::optional<std::string> user_ownership_column,
108 bool is_procedure,
const std::string &schema,
109 const std::string &
object,
111 const rapidjson::Document &doc,
const ResultSets &rs);
115 const std::string &user_name,
116 std::optional<std::string> user_ownership_column,
117 bool is_procedure,
const std::string &schema,
118 const std::string &
object,
const std::string &url,
120 const rapidjson::Document &doc,
const ResultSets &rs);
123 const std::string &schema,
const std::string &
object,
125 std::optional<std::string> user_ownership_column,
const ResultSets &rs,
126 const rapidjson::Document &doc, std::list<std::string> *out_preamble,
127 std::list<std::string> *out_postamble);
130 const std::string &schema,
const std::string &
object,
132 std::optional<std::string> user_ownership_column,
const ResultSets &rs,
133 const rapidjson::Document &doc, std::list<std::string> *out_preamble,
134 std::list<std::string> *out_postamble);
140 std::list<std::string> postamble);
143 const std::exception &e,
const std::string &task_id,
144 const std::string &progress_event_name);
Definition: cache_manager.h:41
Definition: counted_mysql_session.h:38
Definition: mysql_fixed_pool_manager.h:40
MySqlFixedCacheManagerImpl::CachedObject CachedObject
Definition: mysql_fixed_pool_manager.h:45
Definition: mysql_task_monitor.h:41
MySQLSession::Row Row
Definition: query.h:40
virtual void query(MySQLSession *session, const std::string &q)
Definition: query.cc:49
Definition: query_rest_task.h:49
void execute_function_at_router(CachedSession session, PoolManagerRef pool_ref, const mysqlrouter::sqlstring &user_id, std::optional< std::string > user_ownership_column, const std::string &schema, const std::string &object, const std::string &url, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:340
QueryRestMysqlTask(mrs::database::MysqlTaskMonitor *task_monitor)
Definition: query_rest_task.cc:101
void execute_at_server(collector::CountedMySQLSession *session, const mysqlrouter::sqlstring &user_id, const std::string &user_name, std::optional< std::string > user_ownership_column, bool is_procedure, const std::string &schema, const std::string &object, const std::string &url, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:353
uint64_t items
Definition: query_rest_task.h:97
entry::ResultSets ResultSets
Definition: query_rest_task.h:51
std::shared_ptr< PoolManager > PoolManagerRef
Definition: query_rest_task.h:55
void execute_procedure_at_router(CachedSession session, PoolManagerRef pool_ref, const mysqlrouter::sqlstring &user_id, std::optional< std::string > user_ownership_column, const std::string &schema, const std::string &object, const std::string &url, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:314
const char * get_sql_state()
Definition: query_rest_task.cc:105
mysqlrouter::sqlstring wrap_async_server_call(const std::string &schema, const mysqlrouter::sqlstring &user_id, const std::string &user_name, const MysqlTaskOptions &task_options, mysqlrouter::sqlstring query, std::list< std::string > preamble, std::list< std::string > postamble)
Definition: query_rest_task.cc:261
std::string response
Definition: query_rest_task.h:99
std::string url_
Definition: query_rest_task.h:102
mysqlrouter::sqlstring build_function_call(const std::string &schema, const std::string &object, const mysqlrouter::sqlstring &user_id, std::optional< std::string > user_ownership_column, const ResultSets &rs, const rapidjson::Document &doc, std::list< std::string > *out_preamble, std::list< std::string > *out_postamble)
Definition: query_rest_task.cc:187
void execute_function_at_server(collector::CountedMySQLSession *session, const mysqlrouter::sqlstring &user_id, const std::string &user_name, std::optional< std::string > user_ownership_column, const std::string &schema, const std::string &object, const std::string &url, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:327
static void kill_task(collector::CountedMySQLSession *session, const mysqlrouter::sqlstring &user_id, const std::string &task_id)
Definition: query_rest_task.cc:537
mrs::database::MysqlTaskMonitor * task_monitor_
Definition: query_rest_task.h:103
void execute_at_router(CachedSession session, PoolManagerRef pool_ref, const mysqlrouter::sqlstring &user_id, std::optional< std::string > user_ownership_column, bool is_procedure, const std::string &schema, const std::string &object, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:395
static std::list< std::string > on_task_error(const std::exception &e, const std::string &task_id, const std::string &progress_event_name)
Definition: query_rest_task.cc:520
mysqlrouter::sqlstring build_procedure_call(const std::string &schema, const std::string &object, const mysqlrouter::sqlstring &user_id, std::optional< std::string > user_ownership_column, const ResultSets &rs, const rapidjson::Document &doc, std::list< std::string > *out_preamble, std::list< std::string > *out_postamble)
Definition: query_rest_task.cc:110
void execute_procedure_at_server(collector::CountedMySQLSession *session, const mysqlrouter::sqlstring &user_id, const std::string &user_name, std::optional< std::string > user_ownership_column, const std::string &schema, const std::string &object, const std::string &url, const MysqlTaskOptions &task_options, const rapidjson::Document &doc, const ResultSets &rs)
Definition: query_rest_task.cc:302
Definition: rest_handler.h:121
Definition: utils_sqlstring.h:67
mrs::database::entry::ResultSets ResultSets
Definition: handler_db_object_script.cc:83
Definition: authorize_manager.h:48