QuantaCore: include/mysql_connector.h Source File

00001 #if !defined (MYSQL_CONNECTOR_H)
00002 #define MYSQL_CONNECTOR_H
00003 #include "mysql.h"
00004 #include "petsc.h"
00005 #include <string>
00006 #include <iostream>
00007 #include "distributed_data.h"
00008 #include "time_series.h"
00009 
00010 /*************************************************************************/
00012 class MySQL_Connector {
00013 
00014  private:
00015   MYSQL mysql; 
00016   MYSQL_RES *mysql_result; 
00017   int core_id;
00018   int num_cores;
00019 
00020   //Data for a result
00021   int num_fields;
00022   int num_local_fields;
00023   int num_rows;
00024   int num_local_rows;
00025 
00026 
00027 public:
00028   void create(string host, string user, string passwd, string db);
00029   void query(string sql_query);
00030   void get_data(bool store_local_copy, Vector* v);
00031   void get_time_series(TimeSeries &ts, bool get_returns);
00032 };
00033 #endif