diff --git a/dbms/include/DB/Client/ConnectionPool.h b/dbms/include/DB/Client/ConnectionPool.h index 062c83b5a33..aece5616f36 100644 --- a/dbms/include/DB/Client/ConnectionPool.h +++ b/dbms/include/DB/Client/ConnectionPool.h @@ -28,11 +28,7 @@ public: typedef PoolBase::Entry Entry; virtual Entry get(Settings * settings = nullptr) = 0; - /** Выделяет до указанного количества соединений для работы. - * Соединения предоставляют доступ к разным репликам одного шарда. - * Выкидывает исключение, если не удалось выделить ни одного соединения. - */ - virtual std::vector getMany(Settings * settings = nullptr) + virtual std::vector getMany(unsigned max_connections, Settings * settings = nullptr) { return std::vector{ get(settings) }; } diff --git a/dbms/include/DB/Client/ConnectionPoolWithFailover.h b/dbms/include/DB/Client/ConnectionPoolWithFailover.h index 04c7ed296f1..d468e10f5a9 100644 --- a/dbms/include/DB/Client/ConnectionPoolWithFailover.h +++ b/dbms/include/DB/Client/ConnectionPoolWithFailover.h @@ -57,13 +57,11 @@ public: return Base::get(settings); } - /** Выделяет до указанного количества соединений для работы. - * Соединения предоставляют доступ к разным репликам одного шарда. - */ - std::vector getMany(Settings * settings = nullptr) override + /** Выделяет до указанного количества соединений. */ + std::vector getMany(unsigned max_connections, Settings * settings = nullptr) override { applyLoadBalancing(settings); - return Base::getMany(settings); + return Base::getMany(max_connections, settings); } protected: