?? pcdmaccessdb.cpp
字號(hào):
// 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> *********************************?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -