adomanager.h

用VC写的日记笔小程序,采用的序列化存储.

#if !defined(AFX_ADOMANAGER_H__3A604471_FB9D_4C6A_99A3_31DB05E1AF60__INCLUDED_)
#define AFX_ADOMANAGER_H__3A604471_FB9D_4C6A_99A3_31DB05E1AF60__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
// AdoManager.h : header file
//

#import "c:\Program Files\Common Files\System\ADO\msado15.dll" no_namespace rename("EOF", "EndOfFile")

/////////////////////////////////////////////////////////////////////////////
// CAdoManager command target
void dump_com_error(_com_error &e);

class CRecordSet
{
public:
	CRecordSet() {};
	CRecordSet(_ConnectionPtr gconnection,char *SqlStr);
	~CRecordSet();

public:
	void Release();
	BOOL GetColVar(int *pvalue, int index);
	BOOL GetColVar(DATE *pDate, int index);
	BOOL GetColVar(CString *pStr, int index);
	void Delete(enum AffectEnum AffectRecords);
	BOOL GetColVar(DATE* pdata,char* colName);
	BOOL GetColVar(CString* pStr,char* colName);
	BOOL GetColVar(DWORD* pvalue,char* colName);
	BOOL GetColVar(int* pvalue,char* colName);
	BOOL GetColVar(DWORD *pvalue, int index);
	BOOL Open(_ConnectionPtr gconnection,char* filterstr);
	BOOL GetColVar(char *pStr, char *colName);
	BOOL GetColVar(char *pStr, int index);
	BOOL GetColVar(float &pvalue, int index);
	BOOL GetColVar(double &pvalue, int index);
	BOOL Close();
	UINT GetCount();

	long  GetCol();  //-1 = error
	
	BOOL MoveFirst();
	BOOL MoveNext();
	BOOL MoveLast();
	BOOL Move(long nNumber);
	BOOL IsEOF();
//	int  GetRow();//get current row  index

	BOOL GetFields(VARIANT v[],int fieldnum);//get current row values
	BOOL GetColValue(VARIANT* v,int Col);//get specified col value
	BOOL GetColValue(VARIANT* v,char* ColName);//get specified col value

private:
	_RecordsetPtr	m_pRecordSet;
	
};

//1) com connection manage
//2) recorderset_s manage | connection between recoderset and com
class CAdoManager
{
// Attributes
public:
	CAdoManager();           // protected constructor used by dynamic creation
	~CAdoManager();

	_CommandPtr		gcommand;

// Operations
public:
	//Dbopen
	BOOL OpenDb(char* ConnectionString = "DSN=sm;uid=sm;pwd=smpwd");
	//DbClose
	void CloseDb();
	BOOL IsOpen();

	//insert,update db
	BOOL Execute(char* query);

	int Exec(LPCTSTR lpszStoreName);

	BOOL BeginTrans();
	BOOL CommitTrans();
	BOOL RollBackTrans();
    //
    CRecordSet* CreateRecordSet(char* query);
	//
	void DestroyRecordSet(CRecordSet* );

private:
	_ConnectionPtr	gconnection; //com interface

};

/////////////////////////////////////////////////////////////////////////////

//{{AFX_INSERT_LOCATION}}
// Microsoft Visual C++ will insert additional declarations immediately before the previous line.

#endif // !defined(AFX_ADOMANAGER_H__3A604471_FB9D_4C6A_99A3_31DB05E1AF60__INCLUDED_)