//Load data to m_pIStream from DataBase
HRESULT CDataPluggableProtocol::LoadDataToIStream(LPCWSTR wstrUrl)
{
	//CString strUrl = wstrUrl;
	CString strFileName = wstrUrl;

	// parse URL
	//strFileName = strUrl.Right(strUrl.GetLength() - (strUrl.Find(_T("//"),0)+2));

	// open file
	HANDLE hFile = CreateFile(strFileName, GENERIC_READ,  0 , NULL, OPEN_EXISTING,  0 , NULL);
	_ASSERTE(INVALID_HANDLE_VALUE != hFile);

	// get file size
	DWORD dwFileSize = GetFileSize(hFile, NULL);
	_ASSERTE(- 1  != dwFileSize);

	LPVOID pvData = NULL;
	// alloc memory based on file size
    
	m_hGlobal = GlobalAlloc(GMEM_MOVEABLE, dwFileSize);
	_ASSERTE(NULL != m_hGlobal);

	pvData = GlobalLock(m_hGlobal);
	_ASSERTE(NULL != pvData);

	DWORD dwBytesRead =  0 ;
	// read file and store in global memory
	BOOL bRead = ReadFile(hFile, pvData, dwFileSize, &dwBytesRead, NULL);
	_ASSERTE(FALSE != bRead);
	GlobalUnlock(m_hGlobal);
	CloseHandle(hFile);

	// create IStream* from global memory
	m_pIStream.Release();
	HRESULT hr = CreateStreamOnHGlobal(m_hGlobal, TRUE, &m_pIStream);
	_ASSERTE(SUCCEEDED(hr) && m_pIStream);
	if(FAILED(hr)) return hr;

	ULARGE_INTEGER nLen;
	LARGE_INTEGER nLen1;
	nLen1.QuadPart =  0 ;
	if(FAILED(m_pIStream->Seek(nLen1, STREAM_SEEK_END, &nLen))) return E_FAIL;
	m_lSize = nLen.LowPart;
    nLen1.QuadPart =  0 ;
    if(FAILED(m_pIStream->Seek(nLen1, STREAM_SEEK_SET, &nLen))) return E_FAIL;
	m_lPosition =  0 ;
	return S_OK;


STDMETHODIMP CDataPluggableProtocol::Read(void *pv, ULONG cb, ULONG *pcbRead)
{
	if (!m_pIStream) return S_FALSE;
    if(m_lPosition >= m_lSize) return S_FALSE;
    BOOL Status = FALSE;

	//set position of begin
	LARGE_INTEGER nLen1;
	nLen1.QuadPart = m_lPosition;
    ULARGE_INTEGER nSeek;
	if(FAILED(m_pIStream->Seek(nLen1, STREAM_SEEK_SET, &nSeek)))
	{
		return INET_E_DOWNLOAD_FAILURE;
	}

	//read data to browser
    HRESULT hr = S_OK;
    hr = m_pIStream->Read(pv, cb, pcbRead);
	if ( SUCCEEDED( hr ))
	{
		if (*pcbRead !=  0 )
		{
			Status = TRUE;
			m_lPosition += *pcbRead;
		}
		else
			return S_FALSE;
	}

	ATLTRACE(_T("nBuffer is %ld\n"), *pcbRead);

	if (Status == FALSE) 
	{
		DWORD error = GetLastError();
		ATLTRACE(_T("Errno = %d\n"), error);
		return INET_E_DOWNLOAD_FAILURE;
	}
	else
		if (m_lSize - m_lPosition >  0 ) 	// more to read ?
		{
			if (m_pIProtSink != NULL)
				m_pIProtSink->ReportData(BSCF_INTERMEDIATEDATANOTIFICATION, m_lPosition, m_lSize);
			return S_OK;
		}

		if (m_pIProtSink != NULL)
		{
			m_pIProtSink->ReportData(BSCF_LASTDATANOTIFICATION, m_lSize, m_lSize);
			m_pIProtSink->ReportResult(S_OK,  0 , NULL);
            if(m_hGlobal) GlobalFree(m_hGlobal),m_hGlobal= 0 ;
            m_pIStream.Release();
            m_lSize =  0 ;
            m_lPosition =  0 ;
            return S_OK;
		}

	return S_FALSE;	
}
}