From ac9e1be58c7d43df18f971ad872d256af17a36a2 Mon Sep 17 00:00:00 2001
From: Steven Murray <steven.murray@cern.ch>
Date: Tue, 6 Dec 2016 11:33:57 +0100
Subject: [PATCH] cta-database-poll now uses rdbms::ConnPool
---
catalogue/PollDatabaseCmd.cpp | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/catalogue/PollDatabaseCmd.cpp b/catalogue/PollDatabaseCmd.cpp
index 4333fc20d6..f9b36333ba 100644
--- a/catalogue/PollDatabaseCmd.cpp
+++ b/catalogue/PollDatabaseCmd.cpp
@@ -20,6 +20,7 @@
#include "catalogue/PollDatabaseCmd.hpp"
#include "catalogue/PollDatabaseCmdLineArgs.hpp"
#include "rdbms/ConnFactoryFactory.hpp"
+#include "rdbms/ConnPool.hpp"
#include <unistd.h>
@@ -46,12 +47,14 @@ int PollDatabaseCmd::exceptionThrowingMain(const int argc, char *const *const ar
const PollDatabaseCmdLineArgs cmdLineArgs(argc, argv);
const auto dbLogin = rdbms::Login::parseFile(cmdLineArgs.dbConfigPath);
auto factory = rdbms::ConnFactoryFactory::create(dbLogin);
- auto conn = factory->create();
+ const uint64_t nbConns = 1;
+ rdbms::ConnPool connPool(*factory, nbConns);
uint32_t elapsedSeconds = 0;
for(uint32_t i = 0; i < cmdLineArgs.numberOfSecondsToKeepPolling; i++) {
- m_out << "Querying the database" << std::endl;
try {
+ m_out << "Querying the database" << std::endl;
+ auto conn = connPool.getConn();
conn->getTableNames();
} catch(exception::Exception &ex) {
m_out << "Database error: " << ex.getMessage().str() << std::endl;
--
GitLab