pcdmaccessdb.cpp

《Windows CE 权威指南》（作者：(美)CHRIS MUENCH

// PCDMAccessDB.cpp : Implementation of CPCDMAccessDB
#include "stdafx.h"
#include "PCDMDLL.h"
#include "PCDMAccessDB.h"

/////////////////////////////////////////////////////////////////////////////
// CPCDMAccessDB
// <BOOK ADDON STEP5 Chapter 8.4.2> **************************************************
void __stdcall _com_issue_error(HRESULT hr)
{
	// Error handling goes here!
}
// </BOOK ADDON STEP5 Chapter 8.4.2> **************************************************

// <BOOK_ADDON STEP4 Chapter 8.3.3> ******************************************
#define	PCDM_DB	833

STDMETHODIMP CPCDMAccessDB::AddProperty(VARIANT PID, long Sorted)
{
#ifdef UNDER_CE
VARIANT tvPID;

//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		if (m_SortCnt<10)
		{
			VariantInit(&tvPID);
			VariantChangeType(&tvPID,&PID,0,VT_I4);
			m_DBSortOrder[m_SortCnt].propid=MAKELONG(CEVT_LPWSTR,tvPID.lVal);
			if (Sorted)
				m_DBSortOrder[m_SortCnt].dwFlags=CEDB_SORT_GENERICORDER;
			else
				m_DBSortOrder[m_SortCnt].dwFlags=0;
			m_SortCnt++;
		}
		return S_OK;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (Sorted==TRUE)
	{
		VariantInit(&tvPID);
		VariantChangeType(&tvPID,&PID,0,VT_I4);
		m_DBSortOrder[m_SortCnt].propid=MAKELONG(CEVT_LPWSTR,tvPID.lVal);
		m_DBSortOrder[m_SortCnt].dwFlags=CEDB_SORT_GENERICORDER;
		m_SortCnt++;
	}
#endif
	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::CreateTable(BSTR FileLocation, BSTR Name)
{
#ifdef UNDER_CE
CEOID	CeOid=0;
HANDLE	tHandle;

//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		TCHAR strSQL[1024],tStr[200];

		wsprintf(strSQL,TEXT("CREATE DATABASE '%s'"),FileLocation);
		HRESULT hr=m_RS->Open(_variant_t(strSQL),_variant_t(TEXT("")),adOpenForwardOnly , adLockReadOnly , 1);
		wsprintf(strSQL,TEXT("DROP TABLE %s"),Name);
		hr=m_RS->Open(_variant_t(strSQL),_variant_t(FileLocation),adOpenForwardOnly , adLockReadOnly , 1);
		wsprintf(strSQL,TEXT("CREATE TABLE %s ("),Name);
		for (int i=0; i<m_SortCnt; i++)
		{
			wsprintf(tStr,TEXT("Fld%d varchar(200)"),HIWORD(m_DBSortOrder[i].propid));
			wcscat(strSQL,tStr);
			if (i<m_SortCnt-1)
				wcscat(strSQL,TEXT(","));
			else
				wcscat(strSQL,TEXT(")"));
		}
		hr=m_RS->Open(_variant_t(strSQL),_variant_t(FileLocation),adOpenForwardOnly , adLockReadOnly , 1);
		m_SortCnt=0;
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************

	tHandle = CeOpenDatabase(&CeOid,Name,0,0,NULL);          	
	if (tHandle!= INVALID_HANDLE_VALUE)
	{
		CloseHandle(tHandle);
		CeDeleteDatabase(CeOid);
	}
	if ((CeOid = CeCreateDatabase(Name,PCDM_DB,
      m_SortCnt,m_DBSortOrder))==NULL)
		return S_FALSE;
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::OpenTable(BSTR FileLocation, BSTR Name, VARIANT PID, long *Handle)
{
#ifdef UNDER_CE
CEOID	CeOid=0;
HANDLE	hDataBase; 
CEPROPID	tPID=0;
VARIANT tvPID;

	VariantInit(&tvPID);
	VariantChangeType(&tvPID,&PID,0,VT_I4);
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
TCHAR strSQL[1024],tStr[200];
HRESULT hr;
		wsprintf(strSQL,TEXT("SELECT * FROM %s "),Name);
		wsprintf(tStr,TEXT("Order By Fld%d "),tvPID.lVal);
		wcscat(strSQL,tStr);
		hr=m_RS->Open(_variant_t(strSQL),_variant_t(FileLocation),adOpenKeyset , adLockOptimistic , 1);
		*Handle=(long)m_RS;
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************

	for (int i=0;i<m_SortCnt;i++)
	{
		if (HIWORD(m_DBSortOrder[i].propid)==tvPID.lVal)
		{
			tPID=MAKELONG(LOWORD(m_DBSortOrder[i].propid),tvPID.lVal);
			break;
		}
	}
	hDataBase = CeOpenDatabase(&CeOid,Name,tPID,0,NULL);          	
	if (hDataBase == INVALID_HANDLE_VALUE)
	{
		*Handle=0;
		return S_FALSE;	
	}
	*Handle=(long)hDataBase;
	VariantCopy(&m_ActPID,&PID);
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::CloseTable(long Handle)
{
	m_SortCnt=0;
	m_rfldCnt=0;
#ifdef UNDER_CE
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->Close();
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	CloseHandle((HANDLE)Handle);
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::MoveFirst(long Handle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->MoveFirst();
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (!(m_curRec=CeSeekDatabase((HANDLE)Handle,CEDB_SEEK_BEGINNING, 0, &m_dwIndex)))
		return S_FALSE;
#endif
	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::MoveLast(long Handle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->MoveLast();
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (!(m_curRec=CeSeekDatabase((HANDLE)Handle, CEDB_SEEK_END,0, &m_dwIndex)))
		return S_FALSE;
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::MoveNext(long Handle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->MoveNext();
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (!(m_curRec=CeSeekDatabase((HANDLE)Handle, CEDB_SEEK_CURRENT, 1, &m_dwIndex)))
		return S_FALSE;
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::MovePrevious(long Handle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->MovePrevious();
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (!(m_curRec=CeSeekDatabase((HANDLE)Handle, CEDB_SEEK_CURRENT, -1, &m_dwIndex)))
		return S_FALSE;
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::FindRecord(long Handle, VARIANT PID, VARIANT Value)
{
#ifdef UNDER_CE
VARIANT tvPID,tvValue;
		
VariantInit(&tvPID);
VariantInit(&tvValue);
VariantChangeType(&tvPID,&PID,0,VT_I4);
VariantChangeType(&tvValue,&Value,0,VT_BSTR);
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	switch (m_useADO)
	{
		case PCDMADO_V2:
		case PCDMADO_V3:
			{
				Fields		*pFields;
				Field20		*pField20;
Field	*pField;
				HRESULT hr;
				TCHAR tFldName[10];
				VARIANT_BOOL	tBOF,tEOF;
				VARIANT value,tBookMark;

				VariantInit(&tBookMark);
				m_RS->get_Bookmark(&tBookMark);
				m_RS->get_BOF(&tBOF);
				m_RS->get_EOF(&tEOF);
				if(!(tBOF==VARIANT_TRUE && tEOF==VARIANT_TRUE))
				{
					while (tEOF!=VARIANT_TRUE)
					{
						m_RS->get_Fields(&pFields);
						wsprintf(tFldName,TEXT("Fld%d"),tvPID.lVal);
	if (m_useADO==PCDMADO_V3)
	{
		hr=pFields->get_Item(_variant_t(tFldName),(struct Field **)&pField);
		pField->get_Value(&value);
	}
	else
	{
						hr=pFields->get_Item(_variant_t(tFldName),(struct Field **)&pField20);
						pField20->get_Value(&value);
	}
						VariantChangeType(&value,&value,0,VT_BSTR);	// just to be sure...
						if (value.vt==VT_BSTR && tvValue.vt==VT_BSTR)
						{
							if (!(CompareString(LOCALE_USER_DEFAULT,NORM_IGNORECASE,value.bstrVal,-1,tvValue.bstrVal, -1)-2))
							{
								hr=S_OK;
								break;
							}
						}
						hr=m_RS->MoveNext(); 
						hr=m_RS->get_EOF(&tEOF);
					}
				}
				if (FAILED(hr) || tEOF==VARIANT_TRUE)
					m_RS->put_Bookmark(tBookMark);
				return hr;
			}
			break;
		case 1:
			{
				VARIANT tBookMark;
				TCHAR tFldName[10];
				VariantInit(&tBookMark);

				HRESULT hr=m_RS->get_Bookmark(&tBookMark);
				wsprintf(tFldName,TEXT("Fld%d='%s'"),tvPID.lVal,tvValue.bstrVal);
				hr=m_RS->Find(tFldName,0,adSearchForward,tBookMark);
				if (FAILED(hr))
					m_RS->put_Bookmark(tBookMark);
				return hr;
			}
			break;
		default:
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
			CEPROPVAL tPropVal;
			DWORD	tdwIndex;
		
			if (tvPID.lVal!=m_ActPID.lVal) return S_FALSE;
			tPropVal.wLenData = 0;
			tPropVal.wFlags = 0;
			tPropVal.propid=MAKELONG(CEVT_LPWSTR,m_ActPID.lVal);
			tPropVal.val.lpwstr=tvValue.bstrVal;
		
			tdwIndex=m_dwIndex;
			if (!(m_curRec=CeSeekDatabase((HANDLE)Handle,CEDB_SEEK_VALUEFIRSTEQUAL,(DWORD)&tPropVal, &tdwIndex)))
			{
				m_curRec=CeSeekDatabase((HANDLE)Handle, CEDB_SEEK_BEGINNING, m_dwIndex, &m_dwIndex);
				return S_FALSE;
			}
			m_dwIndex=tdwIndex;
			break;
	}
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::AddNewRecord(long Handle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		_variant_t	vaEmpty;
		HRESULT hr=m_RS->AddNew(vaEmpty,vaEmpty); 
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	m_curRec=0;
#endif
	m_wfldCnt=0;

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::SetValue(VARIANT PID, VARIANT Value)
{
#ifdef UNDER_CE
VARIANT tValue,tvPID;

	if (m_wfldCnt>9) return S_FALSE; 
	VariantInit(&tValue);
	VariantChangeType(&tValue,&Value,0,VT_BSTR);
	VariantInit(&tvPID);
	VariantChangeType(&tvPID,&PID,0,VT_I4);
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		Fields	*pFields;
		Field	*pField;
		Field20	*pField20;
		TCHAR tFldName[10];

		HRESULT hr=m_RS->get_Fields(&pFields);
		wsprintf(tFldName,TEXT("Fld%d"),tvPID.lVal);
	
		if (m_useADO==PCDMADO_V3)
		{
			hr=pFields->get_Item(_variant_t(tFldName),&pField);
			hr=pField->put_Value(tValue);
		}
		else
		{
			hr=pFields->get_Item(_variant_t(tFldName),(struct Field **)&pField20);
			hr=pField20->put_Value(tValue);
		}
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	m_wFields[m_wfldCnt].propid=MAKELONG(CEVT_LPWSTR,tvPID.lVal);
	m_BStr[m_wfldCnt]=SysAllocString(tValue.bstrVal);
	m_wFields[m_wfldCnt].val.lpwstr=m_BStr[m_wfldCnt];
	m_wFields[m_wfldCnt].wLenData = 0;
	m_wFields[m_wfldCnt].wFlags = 0;
	m_wfldCnt++;
#endif
	return S_OK;
}


STDMETHODIMP CPCDMAccessDB::WriteRecord(long DBHandle)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		_variant_t	vaEmpty;
		HRESULT hr=m_RS->Update(vaEmpty,vaEmpty);
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if(!CeWriteRecordProps((HANDLE)DBHandle, m_curRec, m_wfldCnt, m_wFields) )
		return S_FALSE; 
	for (int i=0;i<m_wfldCnt;i++)
		SysFreeString(m_BStr[i]);	
	m_wfldCnt=0;
#endif

	return S_OK;
}

STDMETHODIMP CPCDMAccessDB::ReadRecord(long DBHandle, long *Count)
{
#ifdef UNDER_CE
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		Fields			*pFields;
		long tCnt;

		HRESULT hr=m_RS->get_Fields(&pFields);
		hr=pFields->get_Count(&tCnt);
		*Count=tCnt;
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
LPBYTE	pData=NULL;
DWORD	cbData=0;

	m_rfldCnt=0;
	if(!CeReadRecordProps((HANDLE)DBHandle, CEDB_ALLOWREALLOC, &m_rfldCnt,NULL,&pData,&cbData))
	{
		DWORD err=GetLastError();
		m_rFields=NULL;
		return S_FALSE; 
	}
	m_rFields=(CEPROPVAL*)pData;
	*Count=m_rfldCnt;
#endif
	return S_OK;
}


STDMETHODIMP CPCDMAccessDB::GetValue(VARIANT PID, VARIANT *Value)
{
#ifdef UNDER_CE
VARIANT		tvPID;

	VariantInit(Value);
	VariantInit(&tvPID);
	VariantChangeType(&tvPID,&PID,0,VT_I4);
//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
	if (m_useADO!=PCDMADO_NONE)
	{
		Fields			*pFields;
		Field			*pField;
		Field20			*pField20;
		long tCnt;
		HRESULT hr;
		TCHAR tFldName[10];

		VariantInit(Value);
		m_RS->get_Fields(&pFields);
		hr=pFields->get_Count(&tCnt);
		wsprintf(tFldName,TEXT("Fld%d"),tvPID.lVal);
		if (m_useADO==PCDMADO_V3)
		{
			hr=pFields->get_Item(_variant_t(tFldName),&pField);
			hr=pField->get_Value(Value);
		}
		else
		{
			hr=pFields->get_Item(_variant_t(tFldName),(struct Field **)&pField20);
			hr=pField20->get_Value(Value);
		}
		return hr;
	}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
CEPROPVAL	*Flds=NULL;

	if (m_rFields==NULL || m_rfldCnt==0) return S_FALSE; 
	for (int i=0;i<m_rfldCnt;i++)
	{
		if (HIWORD(m_rFields[i].propid)==tvPID.lVal)
		{
			Flds=&m_rFields[i];
			break;
		}
	}
	if (Flds==NULL) return S_FALSE;

	Value->vt=VT_BSTR;
	Value->bstrVal=SysAllocString((TCHAR*)Flds->val.lpwstr);
#endif
	return S_OK;
}

//<BOOK_ADDON STEP5 Chapter 8.4.2> *********************************
STDMETHODIMP CPCDMAccessDB::Execute(BSTR FileLocation, BSTR Command)
{
#ifdef UNDER_CE
	if (m_useADO!=PCDMADO_NONE)
	{
		HRESULT hr=m_RS->Open(_variant_t(Command),_variant_t(FileLocation),adOpenForwardOnly , adLockReadOnly , 1);
		return hr;
	}
#endif
	return S_OK;
}
//</BOOK_ADDON STEP5 Chapter 8.4.2> *********************************