irods
4.2.8
About: iRODS (the integrated Rule Oriented Data System) is a distributed data-management system for creating data grids, digital libraries, persistent archives, and real-time data systems.
![]() ![]() |
#include <query_processor.hpp>
Classes | |
class | future |
Public Types | |
using | error = std::tuple< int, std::string > |
using | errors = std::vector< error > |
using | result_row = typename query< ConnectionType >::value_type |
using | job = std::function< void(const result_row &)> |
using | query_type = typename query< ConnectionType >::query_type |
Public Member Functions | |
query_processor (const std::string &_query, job _job, uint32_t _limit=0, query_type _type=query_type::GENERAL) | |
query_processor (const query_processor &)=delete | |
query_processor & | operator= (const query_processor &)=delete |
uint32_t | size () |
auto | execute (thread_pool &_thread_pool, ConnectionType &_conn) |
Private Attributes | |
uint32_t | size_ |
std::string | query_ |
job | job_ |
uint32_t | limit_ |
query_type | type_ |
Definition at line 19 of file query_processor.hpp.
using irods::query_processor< ConnectionType >::error = std::tuple<int, std::string> |
Definition at line 23 of file query_processor.hpp.
using irods::query_processor< ConnectionType >::errors = std::vector<error> |
Definition at line 24 of file query_processor.hpp.
using irods::query_processor< ConnectionType >::job = std::function<void (const result_row&)> |
Definition at line 26 of file query_processor.hpp.
using irods::query_processor< ConnectionType >::query_type = typename query<ConnectionType>::query_type |
Definition at line 27 of file query_processor.hpp.
using irods::query_processor< ConnectionType >::result_row = typename query<ConnectionType>::value_type |
Definition at line 25 of file query_processor.hpp.
|
inline |
Definition at line 30 of file query_processor.hpp.
|
delete |
|
inline |
Definition at line 67 of file query_processor.hpp.
References terminate_irods_processes::e, irods::query_processor< ConnectionType >::job_, irods::query_processor< ConnectionType >::limit_, pid_age::p, irods::thread_pool::post(), irods::query_processor< ConnectionType >::future::push_back(), irods::query_processor< ConnectionType >::query_, irods::query_processor< ConnectionType >::size_, SYS_UNKNOWN_ERROR, and irods::query_processor< ConnectionType >::type_.
Referenced by irods.pypyodbc.Cursor::executemany().
|
delete |
|
inline |
Definition at line 40 of file query_processor.hpp.
References irods::query_processor< ConnectionType >::size_.
|
private |
Definition at line 102 of file query_processor.hpp.
Referenced by irods::query_processor< ConnectionType >::execute().
|
private |
Definition at line 103 of file query_processor.hpp.
Referenced by irods::query_processor< ConnectionType >::execute().
|
private |
Definition at line 101 of file query_processor.hpp.
Referenced by irods::query_processor< ConnectionType >::execute().
|
private |
Definition at line 100 of file query_processor.hpp.
Referenced by irods::query_processor< ConnectionType >::execute(), and irods::query_processor< ConnectionType >::size().
|
private |
Definition at line 104 of file query_processor.hpp.
Referenced by irods::query_processor< ConnectionType >::execute().