lyfz_repos/经典版源码/lyfzSms/trunk/lyfzSMSApp/db/DataManager.h

#ifndef _DATAMANAGER_H_
#define _DATAMANAGER_H_

#include "Global.h"
#include "AdoInterface.h"

typedef struct _SContact
{
	CString strName;
	CString strPhone;
}SContact;

class CDataManager
{
	CDataManager();
public:
	
	~CDataManager();

	static CDataManager *GetInstance() 
	{
		static CDataManager Instance;
		return &Instance;
	}
	
	int StartThread();
	int EndofThread();
	int Work();
	static DWORD WINAPI ThreadFun(LPVOID lpParam);
	
	ThreadSection* ReturnSection(){return &s_critSection;}
	BOOL IsThreadRuning(){return m_bThreadRuning;}

public:
	int CreateInstance();
	int OpenDataBase(const TCHAR* pConnectStr, const TCHAR* pUserID, const TCHAR* pPWD, CString& errMsg);
	void CloseDataBase();


	int SelectCount(CString& strTableName);
	int Select(CArray<CStringArray, CStringArray>& arr, CString& strTableName, std::vector<CString>& vFields, CString strfilter = _T(""), const CString& strSelLineCount = _T(""), CString strSort = _T(""));
	int Insert(CString& strTableName, CString& strValues, CString strFields = _T(""));
	int Update(CString& strTableName, CString& strValues, CString strfilter = _T(""));
	int Delete(CString& strTableName, CString& strFilter);
private:
	ThreadSection			s_critSection;
	
	//ʵʱÌá½»
	HANDLE					_hThread;					// Ï߳̾ä±ú;
	BOOL					m_bThreadRuning;

	CAdoInterface			m_PhoneBookDB;
};

#endif