| 788 | } |
| 789 | |
| 790 | void IdoPgsqlConnection::ExecuteMultipleQueries(const std::vector<DbQuery>& queries) |
| 791 | { |
| 792 | if (IsPaused()) |
| 793 | return; |
| 794 | |
| 795 | if (queries.empty()) |
| 796 | return; |
| 797 | |
| 798 | IncreasePendingQueries(queries.size()); |
| 799 | m_QueryQueue.Enqueue([this, queries]() { InternalExecuteMultipleQueries(queries); }, queries[0].Priority, true); |
| 800 | } |
| 801 | |
| 802 | bool IdoPgsqlConnection::CanExecuteQuery(const DbQuery& query) |
| 803 | { |