Khan's Notebook GCC/GNU/Linux Delphi/Window Java/Anywhere

這個不是一個很好的解決方案，浪費了很多內存空間，我覺得比較好的，方案應該是2個vector 
一個用來存放一條記錄或字段名，另一個存放這個vector

/**dbm.hpp
 * 數據庫操作的模塊，本系統中所有的數據庫操作都集成于本模塊
 * */ 

#include <string> 
#include <map> 
#include <vector> 
#include "common.h" 
#include "sdb.h"

 using namespace std;
 typedef map<string, string> TRecord;
 typedef vector<string> Tcols;
 typedef vector<TRecord> TDataSet;
 typedef TRecord::iterator TDataSetIter;
 typedef TRecord::value_type TValueType;

 /* 本類不會主動關閉數據庫連接*/ 
class TDB_Action{
  private:
    char* db; //數據庫連接
    TDataSet dataset; //結果集 
    TDataSet *pd; //指向結果集的指針 
    static Tcols record_cols; //字段元素
  
     /*回調函數
      *@param int n 字段個數
      *@param char **p 結果集
      *@param void * data 數據的出口
     */
    static int DB_record_callback(int n, char **p, void *data){
      if (!n) return 0;
      TRecord record;
      record.clear();
      for(int i = 0; i < n; i++){
        record.insert(TValueType( record_cols[i], p[i]));
        //printf("%s %s \t" , record_cols[i].c_str() ,p[i]);//
      } //printf("\n" );//
      ((TDataSet *)data)->push_back(record);
    }

 public:
   /*構造器*/
   TDB_Action(char* the_db){
     db=the_db;
     pd=&dataset;
   }

   /*析構器*/
   ~TDB_Action(){};

   /* 執行無結果集的sql語句
    * @param char *sqlstr sql語句
    */
   int DB_Excute( char *sqlstr);

   /*執行有結果集的sql語句
    * @param Tcols 一個vector,存儲多個字段
    * @param string table_name 表名
    * @param const condstion where條件
    * @return TDataSet 一個結果集*/

   TDataSet DB_GetRecord(Tcols the_cols, string table_name, const string condtion);

 }; 

/*dbm.cpp*/

#include "dbm.hpp"

 Tcols TDB_Action::record_cols; //類靜態成員變量需要在cpp中再申明一次，剛剛才知道d

 /*
  *  */
 int TDB_Action::DB_Excute( char *sqlstr) {
   if (-1 == sdb_query(db, sqlstr, NULL, NULL)) {
     fprintf(stderr, "Error in Execute sql statement <%s>\n", sqlstr);
     return -1;
   }
   return 1;
 }

 TDataSet TDB_Action::DB_GetRecord(Tcols the_cols, string table_name, const string condtion){
   for(int i=0; i<dataset.size(); i++){
     dataset[i].clear();
   }
   dataset.clear();
   record_cols.clear();
   if (the_cols.size()<=0)
     return dataset;//如果沒有字段，直接返回
   char sqlstr[400] ;
   memset(sqlstr, '0', sizeof(sqlstr));
   string tmp(""); //構建一個sql語句

   for (int i =0; i < the_cols.size() ; i++ ){
     record_cols.push_back( the_cols[i].c_str());
     if( the_cols[i] == "*" )
       return dataset; //不能包含*

     if( i < the_cols.size() -1)
       tmp = tmp + the_cols[i] + ", ";
     else
       tmp = tmp + the_cols[i] ;
   }

   tmp = "Select " + tmp + " From " + table_name + condtion;
   sprintf(sqlstr, tmp.c_str());
   if (-1 == sdb_query(db, sqlstr, DB_record_callback, pd)) {
     fprintf(stderr, "Error in Query sql statement <%s>\n", sqlstr);
     return dataset;
   }
   return dataset;
 }

 int main(){//測試代碼
   char *db = NULL;
   char url[1024]="mysql:host=127.0.0.1:db=smscgw:uid=root";
   db=sdb_open(url);
   if (db == NULL) {
     fprintf(stderr, "Open database fault <%s>\n", url);
     exit (-1);
   }

   TDB_Action dba(db);
   Tcols te; string strs[5] = {"acttime","seq_num","msg","connname","mtmsg"};

   te.push_back(strs[0]);
   te.push_back(strs[1]);
   te.push_back(strs[2]);
   te.push_back(strs[3]);
   const string aaa(" ORDER BY acttime ");


  //取結果集
   TDataSet temp= dba.DB_GetRecord(te, strs[4],aaa);
   printf("打印結果集\n");
   for(int i=0 ; i < temp.size(); i++){
     for(TDataSetIter it=temp[i].begin();it != temp[i].end(); it++){
       printf("key:%s :%s \t", it->first.c_str(), it->second.c_str());
     }
     printf("\n");
   }
   if ( db!= NULL)
     sdb_close(db);
   return 0;
 }