uploadstockdata.cpp

基于MFC和ADO的股票数据上传系统

// UploadStockData.cpp : Implementation of CUploadStockData
#include "stdafx.h"
#include "STLoadData.h"
#include "UploadStockData.h"

/////////////////////////////////////////////////////////////////////////////
// CUploadStockData


STDMETHODIMP CUploadStockData::UploadRecord(BSTR fund, DATE date, double price, BSTR uplBy, DATE uplDate)
{
	// TODO: Add your implementation code here
	// Test for live connection to data source
	if( m_pConnection == NULL )
		return E_FAIL;

	// Create recordset
	_RecordsetPtr pRecordset;
	
	HRESULT hr = pRecordset.CreateInstance(__uuidof( Recordset ));
	if( FAILED( hr ) ) return hr;

	try
	{
		// Open recordset
		_variant_t vConnection = m_pConnection.GetInterfacePtr(); 
		hr = pRecordset->Open( L"pricehistory", vConnection, adOpenForwardOnly,
						  adLockOptimistic, adCmdTableDirect );

		if( FAILED( hr ) ) return hr;

		// Add new record, set fields to new values and update
		hr = pRecordset->AddNew();
		if( FAILED( hr ) ) throw _com_error( hr );

		pRecordset->Fields->GetItem( L"ph_fund")->Value = fund;
		pRecordset->Fields->GetItem( L"ph_date")->Value = date;
		pRecordset->Fields->GetItem( L"ph_price")->Value = price;
		pRecordset->Fields->GetItem( L"ph_uploadedby")->Value = uplBy;
		pRecordset->Fields->GetItem( L"ph_uploaddate")->Value = uplDate;

		hr = pRecordset->Update();
		if( FAILED( hr ) ) throw _com_error( hr );

	}
	catch( _com_error e ) 	
	{
		// very unsophisticated error handling
		try
		{
			pRecordset->Close();
		}
		catch(...) // Close() may throw another exception
		{
		}
		return E_FAIL;
	}
	
	pRecordset->Close();

	return S_OK;
}

STDMETHODIMP CUploadStockData::ConnectToDatabase()
{
	// TODO: Add your implementation code here
	if(m_pConnection)
		return S_OK;
	HRESULT hr = m_pConnection.CreateInstance(__uuidof(Connection));
	if(FAILED(hr))
		return hr;
	hr = m_pConnection->Open(L"File Name=C:\\STLink.udl",L"",L"",-1);
	if(FAILED(hr))
		return hr;
	return S_OK;
}

STDMETHODIMP CUploadStockData::Disconnect()
{
	// TODO: Add your implementation code here
	if(m_pConnection)
	{
		m_pConnection->Close();
		m_pConnection = NULL;
	}
	return S_OK;
}