Added MySQL database

Makefile

@@ -10,8 +10,8 @@ TARGET = gm_telemetry_server
 
 include ../AppMake.mf
 
-INCS += -I ./websocketpp
+INCS += -I ./websocketpp -I/user/include/mysql
 
-LDFLAGS += -lboost_system
+LDFLAGS += -lboost_system -lmysqlclient -lz
 
 CXXFLAGS += -std=c++11

dataset.hpp

@@ -3,6 +3,7 @@
 #include <fstream>
 #include <string>
 #include <chrono>
+#include <mysql/mysql.h>
 
 #include <boost/any.hpp>
 
@@ -35,12 +36,17 @@ struct measurement {
 struct subsystem {
   std::string name;
 	std::vector<measurement> v;
+  MYSQL *con=mysql_init(NULL);
+  MYSQL_RES *res;
 
   void updateMeasurement(std::string m, std::string value, unsigned long t){
+    mysql_real_connect(con,"192.168.1.4","root","root","gmsec",0,NULL,0);
     for(std::vector<measurement>::iterator it = v.begin();it != v.end();++it){
       if(it->name==m){
         it->v = value;
         it->timestamp = t;
+        std::string insert = "INSERT INTO " + m + " VALUES(" + value + "," + std::to_string(t) +");";
+        mysql_query(con,insert.c_str());
         return;
       }
     }
@@ -49,6 +55,26 @@ struct subsystem {
     meas.v = value;
     meas.timestamp = t;
     v.push_back(meas);
+    //mysql_query
+    std::string str = "CREATE TABLE "+m+"(Timestamp TEXT, Value TEXT);";
+    std::cout << str << '\n';
+    mysql_query(con,str.c_str());
+    std::cout << mysql_error(con) << '\n';
+    str = "INSERT INTO " + m + " VALUES(" + value + "," + std::to_string(t) +");";
+    mysql_query(con,str.c_str());
+    std::cout << mysql_error(con) << '\n';
+    return;
+  }
+
+  void connectToDB(std::string s,std::string prefix){
+    std::cout << "Connecting to server " << s << " version: " << mysql_get_client_info() << '\n';
+    mysql_real_connect(con,s.c_str(),"root","root","gmsec",0,NULL,0);
+    std::string test = "CREATE TABLE "+ prefix +"(Timestamp TEXT, Value TEXT);";
+    mysql_query(con,test.c_str());
+    test = "INSERT INTO " + prefix +" VALUES(2000,9999);";
+    mysql_query(con,test.c_str());
+    mysql_free_result(res);
+    mysql_close(con);
     return;
   }
 

gm_telemetry_server.cpp

@@ -61,6 +61,7 @@ std::mutex systemdata_mutex;
 std::vector<std::time_t> time_vector;
 std::mutex sys_mutex;
 nlohmann::json j;
+std::string SQL_Server;
 
 class gmsub
 {
@@ -467,6 +468,12 @@ int main(int argc, char* argv[])
 	//load dictionary
 	std::string filename = example::get(config, "dictionary", "/GMSEC_API/bin/dictionary.json");
 	dictionary = load_dictionary(filename);
+	port = example::get(config, "port", 8081);
+	//set sql server
+	SQL_Server = example::get(config, "SQL_Server", "192.168.1.4");
+	nav_sys.connectToDB(SQL_Server,"N");
+	orb_sys.connectToDB(SQL_Server,"O");
+	veh_sys.connectToDB(SQL_Server,"V");
 
 	//Threads
 	std::thread gmsec(&gmsub::run,&g);