Changeset 19124

Timestamp:

08/03/18 13:42:22 (6 years ago)

Author:

tbretz

Message:

Implmented compressed connections.

File:

• trunk/FACT++/src/Database.h (modified) (5 diffs)

trunk/FACT++/src/Database.h

@@ -4 +4 @@
 #include <exception>
 #include <boost/regex.hpp>
+#include <boost/algorithm/string.hpp>
 
 #include <mysql++/mysql++.h>
@@ -14 +15 @@
     std::string db;
     int port;
+    char compression;
 
-    DatabaseName(const std::string &database)
+    DatabaseName(const std::string &database) : compression(0)
     {
-        static const boost::regex expr("(([[:word:].-]+)(:(.+))?@)?([[:word:].-]+)(:([[:digit:]]+))?(/([[:word:].-]+))");
+        static const boost::regex expr("(([[:word:].-]+)(:(.+))?@)?([[:word:].-]+)(:([[:digit:]]+))?(/([[:word:].-]+))(/[+-])?");
 
         boost::smatch what;
@@ -23 +25 @@
             throw std::runtime_error("Couldn't parse database URI '"+database+"'.");
 
-        if (what.size()!=10)
+        if (what.size()!=11)
             throw std::runtime_error("Error parsing database URI '"+database+"'.");
 
@@ -30 +32 @@
         server = what[5];
         db     = what[9];
+
+        compression = std::string(what[10])[1];
 
         try
@@ -59 +63 @@
 public:
     Database(const std::string &desc) : DatabaseName(desc),
-        mysqlpp::Connection(db.c_str(), server.c_str(), user.c_str(), passwd.c_str(), port)
+        mysqlpp::Connection()
     {
+        if ((compression!='-' && boost::algorithm::to_lower_copy(server)!="localhost" && server!="127.0.0.1")||
+            compression=='+')
+            set_option(new mysqlpp::CompressOption());
+
+        // Connect to the database
+        connect(db.c_str(), server.c_str(), user.c_str(), passwd.c_str(), port);
     }
 };