database.h

wince下对sqlserver数据库的操作,增删改操作,单进程单线程

// DataBase.h: interface for the CDataBase class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_DATABASE_H__3FE010D5_85A5_485F_8DF7_7700FE0C2CF1__INCLUDED_)
#define AFX_DATABASE_H__3FE010D5_85A5_485F_8DF7_7700FE0C2CF1__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000


#define CC_MAX_FIELDS_LEN	300
inline DWORD ROUND_UP(DWORD dwSize, DWORD dwAmount) { return ((dwSize + (dwAmount-1)) & ~(dwAmount-1));}
typedef struct tagNodeSql{
	WCHAR *pSql;
	struct tagNodeSql *pNext;
}NodeSql,*pNodeSql;
class CDataBase  
{
public:
	int CountSql(WCHAR *pSql);
	int GetRows(pBusTableStruct pBusStr,WCHAR *wcWhere,RetResultStruct **ppResult);
	int GetCombRows(pBusTableStruct pBusStr,WCHAR *wcSql,RetResultStruct **ppResult);
	int Update(pBusTableStruct pBusStr,char *pRowStr);
	int Insert(pBusTableStruct pBusStr,char *pRowStr,BOOL bAutoKey=TRUE);
	void CloseData();
	BOOL ExecuteSql(WCHAR *pSql);
	BOOL ExecuteSql(NodeSql *pNode);
	CDataBase();
	virtual ~CDataBase();
	BOOL OpenData(const WCHAR *wpDbfile=NULL);
	void ReplaceYinhao(WCHAR *p);
private:
	IDBCreateSession *m_pIDBCreateSession;  // The IDBCreateSession interface
	HRESULT PrintErrorInfo(REFIID riid, IUnknown *pComponent);
	BOOL m_bOpen;

};

#endif // !defined(AFX_DATABASE_H__3FE010D5_85A5_485F_8DF7_7700FE0C2CF1__INCLUDED_)