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