catalog: add connection pool for the database
Change-Id: Ie014a5b11081908ea1cfdf30451ef44757d37c7e
diff --git a/catalog/src/util/mysql-util.hpp b/catalog/src/util/mysql-util.hpp
index 75e5997..13078a9 100644
--- a/catalog/src/util/mysql-util.hpp
+++ b/catalog/src/util/mysql-util.hpp
@@ -20,12 +20,15 @@
#define ATMOS_UTIL_CONNECTION_DETAILS_HPP
#include "mysql/mysql.h"
-
#include <memory>
#include <string>
+#include <zdb/zdb.h>
namespace atmos {
namespace util {
+
+#define MAX_DB_CONNECTIONS 100
+
enum DatabaseOperation {CREATE, UPDATE, ADD, REMOVE, QUERY};
struct ConnectionDetails {
public:
@@ -38,15 +41,8 @@
const std::string& passwordInput, const std::string& databaseInput);
};
-std::shared_ptr<MYSQL>
-MySQLConnectionSetup(const ConnectionDetails& details);
-
-std::shared_ptr<MYSQL_RES>
-MySQLPerformQuery(std::shared_ptr<MYSQL> connection,
- const std::string& sql_query,
- DatabaseOperation op,
- bool& success,
- std::string& errMsg);
+std::shared_ptr<ConnectionPool_T>
+zdbConnectionSetup(const ConnectionDetails& details);
} // namespace util
} // namespace atmos