able to backup schema

packages/tls/mysql_wrapper/Makefile

@@ -9,7 +9,7 @@ CXX=g++
 .PHONY: all
 
 
-executables:=main backFieldsToFiles client escape
+executables:=main backFieldsToFiles client escape backupSchema
 
 all: $(executables)
 
@@ -25,6 +25,9 @@ client:obj/client.o $(OBJFILES)
 escape:obj/escape.o $(OBJFILES)
 	$(CXX) -o $@ $^ $(LDFLAGS)
 
+backupSchema:obj/backupSchema.o $(OBJFILES)
+	$(CXX) -o $@ $^ $(LDFLAGS)
+
 .PHONY:clean
 
 

packages/tls/mysql_wrapper/a

+/* table_BARVVQXXXG */
+CREATE TABLE `table_BARVVQXXXG` (
+  `HNSEGFOWDWoEq` bigint(20) unsigned DEFAULT NULL,
+  `PEWGZUYZRWoOrder` varbinary(32) DEFAULT NULL,
+  `FETULHJOAZoADD` varbinary(256) DEFAULT NULL,
+  `cdb_saltLVMFMPASNF` bigint(8) unsigned DEFAULT NULL,
+  `XFAWMBQMAJoEq` varbinary(48) DEFAULT NULL,
+  `IIPECDLNRLoOrder` varbinary(32) DEFAULT NULL,
+  `MKSYYFSQHJoSWP` blob,
+  `cdb_saltTHMLLSSBQV` bigint(8) unsigned DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=latin1

packages/tls/mysql_wrapper/backupSchema.cc

+#include <iostream>
+#include <stdlib.h>
+#include "mysqllib/utilities.h"
+#include "mysqllib/MyConnect.h"
+#include <vector>
+#include <string>
+using namespace std;
+extern Connect *con;
+
+void backupSchema(string query){
+    auto dbresult = con->execute(query);
+    DBResult * result = dbresult.get();
+    vector<vector<string>> rows = result->getRows();
+    cout<<"/* "<<rows[0][0]<<" */"<<endl;
+    cout<<rows[0][1]<<endl;
+
+//    for(auto row:rows){
+//        for(int i=0;i<row.size();i++){
+//            cout<<row[i]<<endl;
+//        }
+//    }
+}
+vector<string> getTables(string db){
+    string query = string("SHOW TABLES IN ")+db;
+    auto dbresult = con->execute(query);
+    DBResult * result = dbresult.get();
+    vector<vector<string>> rows = result->getRows();
+    vector<enum_field_types> types = result->getTypes();
+    vector<string> fieldNames = result->getFields();
+    vector<string> res;
+    for(auto item:rows){
+        assert(item.size()==1);
+        res.push_back(item[0]);
+    }
+    string q = string("use ") + db;
+    con->execute(q);
+    return res;
+}
+
+int main(int argc,char**argv){
+    if(argc!=2){
+        cout<<"db"<<endl;
+        return 0;
+    }
+    string db(argv[1]);
+    vector<string> tablesprefix = getTables(db);
+    for(auto item:tablesprefix){
+        string query = string("show create table ")+item+";";
+        backupSchema(query);
+    }
+    return 0;
+}

packages/tls/mysql_wrapper/mysqllib/MyConnect.cc

@@ -83,7 +83,7 @@ Connect::execute(const std::string &query){
     MYSQL_RES *result = mysql_store_result(conn);
 
     if (result == NULL) {
-        std::cout<<"no results for this query"<<std::endl;
+        //std::cout<<"no results for this query"<<std::endl;
         return std::shared_ptr<DBResult>(NULL);
     }