C / C++ / MFC

BOOL CALLBACK DSEnumProc(LPGUID lpGUID, LPCSTR lpszDescription, LPCSTR lpszDriverName, LPVOID lpContext)
{
	HWND	hCombo = (HWND)lpContext;
	LPGUID	lpTemp = NULL;

	if(lpGUID != NULL)
	{
		if((lpTemp = (LPGUID)malloc(sizeof(GUID))) == NULL)
			return TRUE;
		memcpy(lpTemp, lpGUID, sizeof(GUID));
	}
	ComboBox_AddString(hCombo, lpszDescription);
	ComboBox_SetItemData(hCombo, ComboBox_FindString(hCombo, 0, lpszDescription), lpTemp);
	free(lpTemp);
	return TRUE;
}

BOOL CALLBACK DLG_AudioDeviceSelectionProc(HWND hDlg, UINT message, WPARAM wParam, LPARAM lParam)
{
	HWND	hCombo, hEntryCountText;
	int	iCount;
	TCHAR	szBuffer[32];

	switch(message)
	{
	case WM_INITDIALOG:
		hCombo = GetDlgItem(hDlg, IDC_COMBO);
		if(DirectSoundEnumerate((LPDSENUMCALLBACK)DSEnumProc,(VOID*)&hCombo) != DS_OK)
		{
			EndDialog(hDlg, TRUE);
			return TRUE;
		}
		iCount = ComboBox_GetCount(hCombo);
		hEntryCountText = GetDlgItem(hDlg, IDC_ENTRY_COUNT);
		wsprintf(szBuffer, TEXT("Num Entries: %i"), iCount);
		SetWindowText(hEntryCountText, szBuffer);
		
	case WM_COMMAND:
		switch(LOWORD(wParam))
		{
		case IDCANCEL:			
		case IDOK:
			EndDialog(hDlg, 0);
			return TRUE;
		}
		break;
	}
	return FALSE;
}

BOOL CTestDlg::ReadBinary()
{
	try
	{
		OleInitialize(NULL);
		CString	strTemp = _T("");
		CString strDat  = _T("");
		CString	strVer  = _T("");
		char	*pBuf = NULL;
		_bstr_t bstrsource = "select * from db_somedatease";

		m_pRecordset.CreateInstance("ADODB.Recordset");
		m_pRecordset->Open(bstrsource,_variant_t((IDispatch*)m_pConnection,TRUE),adOpenStatic,adLockOptimistic,adCmdText);
		m_pRecordset->MoveFirst();
		while(VARIANT_FALSE == m_pRecordset->adoEOF)
		{
			HANDLE		m_hFile	   = INVALID_HANDLE_VALUE;
			HANDLE		m_hMapping = INVALID_HANDLE_VALUE;
			DWORD		m_dwSize   = 0;
			char		*m_pSrc    = NULL;
			char		*m_pBuffer = NULL;
			_variant_t	vtVer = m_pRecordset->GetCollect("Version");
			VARIANT		varBLOB;

			// get the file path by version field.
			strVer = VariantToCString(vtVer);
			strTemp.Format(_T("%s\\Dat\\%s.tmp"),GetExePath(),strVer);

			// get the file size, and then use file mapping.
			m_dwSize = m_pRecordset->GetFields()->GetItem("Buffer")->ActualSize;
			if (m_dwSize > 0)
			{
				m_hFile = CreateFile(strTemp,GENERIC_ALL,FILE_SHARE_READ | FILE_SHARE_WRITE,NULL,
					CREATE_ALWAYS,FILE_ATTRIBUTE_NORMAL,NULL);
				
				if(m_hFile == INVALID_HANDLE_VALUE)
				{
					CString	strError = _T("");
					strError.Format(_T("CreateFile Failed！Error Code: %d"),GetLastError());
					::MessageBox(NULL,strError,NULL,NULL);
					return FALSE;
				}
				
				m_hMapping = CreateFileMapping(m_hFile,NULL,PAGE_READWRITE,0,m_dwSize,NULL);
				if(m_hMapping == NULL)
				{
					CString	strError = _T("");
					strError.Format(_T("CreateFileMapping Failed！Error Code: %d"),GetLastError());
					::MessageBox(NULL,strError,NULL,NULL);
					CloseHandle(m_hFile);
					return FALSE;
				}
				
				m_pSrc = (char *)MapViewOfFile(m_hMapping,FILE_MAP_ALL_ACCESS,0,0,0);
				if(m_pSrc == NULL)
				{
					CString	strError = _T("");
					strError.Format(_T("MapViewOfFile Failed！Error Code: %d"),GetLastError());
					::MessageBox(NULL,strError,NULL,NULL);
					CloseHandle(m_hMapping);
					CloseHandle(m_hFile);
				}
				memset(m_pSrc,0xFF,m_dwSize);
				VariantInit(&varBLOB);
				
				// get the binary file size.
				varBLOB = m_pRecordset->GetFields()->GetItem("Buffer")->GetChunk(m_dwSize);
				if(varBLOB.vt == (VT_ARRAY | VT_UI1))
				{
					if(m_pBuffer = new char[m_dwSize + 1])
					{
						// I use new char ,or the file mapping, is 0x00 all the same. 
						memset(m_pBuffer,0x00,m_dwSize);

						// Here the m_pBuffer is 0x00 all the same. why ?
						SafeArrayAccessData(varBLOB.parray,(void **)m_pBuffer);
						memcpy(m_pSrc,m_pBuffer,m_dwSize);

						// close handle
						UnmapViewOfFile(m_pSrc);
						CloseHandle(m_hMapping);
						CloseHandle(m_hFile);
						
						SafeArrayUnaccessData(varBLOB.parray);
						
						delete [] m_pBuffer;
						m_pBuffer = NULL;
					}
				}
			}
			m_pRecordset->MoveNext();
		}
	}
	catch (_com_error e)
	{
		CString errormessage;  
		errormessage.Format("read version error！\r\n\r\nerror code:『%s』",e.ErrorMessage());
		AfxMessageBox(errormessage);
		return FALSE;
	}
	return TRUE;
}

if(varBLOB.vt == (VT_ARRAY | VT_UI1))
{
        memcpy(m_pSrc,varBLOB.parray->pvData,m_dwSize);
        UnmapViewOfFile(m_pSrc);
        CloseHandle(m_hMapping);
        CloseHandle(m_hFile);

        SafeArrayUnaccessData(varBLOB.parray);
        VariantClear(&varBLOB);
}