C / C++ / MFC

/ SRecordset.h<br />
<br />
#pragma once<br />
#include "afx.h"<br />
#include <afxdb.h><br />
class SRecordset : public CObject<br />
{<br />
    DECLARE_SERIAL(SRecordset)<br />
public:<br />
    SRecordset(void);<br />
  <br />
public:<br />
    ~SRecordset(void);<br />
<br />
public:<br />
    int iNumFldCount;<br />
    int iNumRec;<br />
    int iTotalSize;<br />
    int iRecCount;<br />
public:<br />
    void SSDbConnector();<br />
    void SSDataExtractor(CString sQuery);<br />
<br />
public:<br />
    CDatabase dbFASP;<br />
    CStringArray saDataContainer;<br />
<br />
//////////////////////////////////////////////////////////////<br />
    CString sunami; //Sunami variable<br />
//////////////////////////////////////////////////////////<br />
<br />
public:<br />
    void SSGetFieldValue(int iIndex,CString &FldValue);<br />
<br />
};<br />
<br />
<br />
//SRecordset.cpp<br />
<br />
#include "StdAfx.h"<br />
#include "FASPRecordset.h"<br />
<br />
IMPLEMENT_SERIAL(SRecordset,CObject,VERSIONABLE_SCHEMA | 2)<br />
<br />
<br />
SRecordset::SRecordset(void)<br />
{<br />
    sunami = "Sunami";<br />
   <br />
}<br />
<br />
<br />
void SRecordset::SSDbConnector()<br />
{<br />
    CString sIp,sDb,sPwd,sConn,sPort,sUn;<br />
    sIp="192.168.2.17";<br />
    sPort="5432";<br />
    sPwd="fasp";<br />
   <br />
    try<br />
    {       <br />
        sConn = "DRIVER={PostgreSQL ANSI};SERVER=" + sIp + ";port=" + sPort + ";DATABASE=" + sPwd + ";UID=" + sPwd + ";PWD=" + sPwd + ";";<br />
        dbFASP.OpenEx(sConn);<br />
        AfxMessageBox("Success");<br />
    }<br />
    catch(CDBException *e)<br />
    {<br />
        MessageBox(0,"Database Connection Refused."+e->m_strError,"DataBase Connection Error",MB_OK|MB_ICONERROR);<br />
        e->Delete();<br />
       <br />
    }<br />
<br />
}<br />
<br />
<br />
void SRecordset::SSDataExtractor(CString sQuery)<br />
{<br />
    CRecordset rsFASP(&dbFASP);<br />
    CString sValue;<br />
<br />
    rsFASP.Open(AFX_DB_USE_DEFAULT_TYPE,sQuery);<br />
<br />
    iNumFldCount = rsFASP.GetODBCFieldCount();<br />
   <br />
    iNumRec = 0;<br />
   <br />
<br />
    while(!rsFASP.IsEOF())<br />
    {<br />
        rsFASP.MoveNext();<br />
        iNumRec++;<br />
    }<br />
<br />
    iTotalSize = iNumFldCount * iNumRec;<br />
<br />
    sunami.Format("%d",iTotalSize);<br />
    AfxMessageBox(sunami);<br />
<br />
    saDataContainer.SetSize(iTotalSize);<br />
<br />
    rsFASP.MoveFirst();<br />
<br />
    iRecCount = 0;<br />
<br />
    while(!rsFASP.IsEOF())<br />
    {<br />
        for(int ic=0; ic < iNumFldCount; ic++)<br />
        {<br />
            sValue = "";<br />
            rsFASP.GetFieldValue(ic,sValue);<br />
            saDataContainer[iRecCount] = sValue;<br />
           <br />
            iRecCount++;<br />
           <br />
           <br />
        }<br />
       <br />
        rsFASP.MoveNext();<br />
        sunami = saDataContainer[1];<br />
       <br />
    }<br />
    rsFASP.Close();<br />
    dbFASP.Close();<br />
<br />
}<br />
<br />
void SRecordset::SSGetFieldValue(int iIndex, CString &FldValue)<br />
{<br />
        FldValue = "";<br />
        FldValue = saDataContainer[iIndex];<br />
<br />
}

void CSerializeDbDataDlg::OnBnClickedConnect()<br />
{<br />
   SRecordset *set = new SRecordset;<br />
  set->SSDbConnector();<br />
  set->SSDataExtractor("select name from master;");<br />
<br />
    CFile file;<br />
    file.Open("dragon.bin",CFile::modeCreate | CFile::modeWrite | CFile::typeBinary);<br />
    CArchive ar(&file,CArchive::store);<br />
<br />
    if(ar.IsStoring())<br />
        ar << set;  //Manualy write object into archive file<br />
    ar.Flush();<br />
    ar.Close();<br />
    file.Close();<br />
    delete set;<br />
}

void CSerializeDbDataDlg::OnBnClickedRead()<br />
{<br />
<br />
     SRecordset *set1 = new SRecordset;<br />
<br />
    CFile filee;<br />
    filee.Open("dragon.bin", CFile::modeRead | CFile::typeBinary);<br />
    CArchive arr(&filee,CArchive::load);<br />
<br />
    if(arr.IsLoading())<br />
        arr >> set1; <br />
      <br />
     AfxMessageBox(set1->sunami);<br />
<br />
    for(int i=0;i<set1->iTotalSize;i++)<br />
        AfxMessageBox(set2->saDataContainer[i]);<br />
<br />
    arr.Flush();<br />
    arr.Close();<br />
    filee.Close();<br />
    delete set1;<br />
}