本文欢迎转载，唯请注明出处及作者 blackcolor@263.net
---------------------------------------------------
实战COM(09)----COM+的特性之对象池
本节我们将上一节的组件改造成可池化的组件。修改如下：
一、修改组件
1)头文件Simple05.h
// Simple05.h : Declaration of the CSimple05
#ifndef __SIMPLE05_H_
#define __SIMPLE05_H_
#include "resource.h" // main symbols
#include <mtx.h>
/////////////////////////////////////////////////////////////////////////////
// CSimple05
class ATL_NO_VTABLE CSimple05 :
public CComObjectRootEx<CComMultiThreadModel>,
public CComCoClass<CSimple05, &CLSID_Simple05>,
public IObjectControl, // 支持对象池操作
public ISimple05
{
public:
CSimple05()
{
}
DECLARE_REGISTRY_RESOURCEID(IDR_SIMPLE05)
DECLARE_PROTECT_FINAL_CONSTRUCT()
BEGIN_COM_MAP(CSimple05)
COM_INTERFACE_ENTRY(ISimple05)
COM_INTERFACE_ENTRY(IObjectControl)
END_COM_MAP()
// IObjectControl
public:
STDMETHOD(Activate)();
STDMETHOD_(BOOL, CanBePooled)();
STDMETHOD_(void, Deactivate)();
CComPtr<IObjectContext> m_spObjectContext;
// ISimple05
public:
STDMETHOD(ModifyData)();
};
#endif //__SIMPLE05_H_
2)应用文件Simple05.cpp
// Simple05.cpp : Implementation of CSimple05
#include "stdafx.h"
#include "Step05.h"
#include "Simple05.h"
#include <mtx.h> // 事务支持
#include <atldbcli.h> // 数据库操作
// 加入comutil支持
#include <comutil.h>
#pragma comment( lib, "comsupp.lib" )
/////////////////////////////////////////////////////////////////////////////
// CSimple05
// 定义一个新类
class CAuthors
{
public:
// 数据--宽度来源于表Authors
char m_szAu_Id[12];
char m_szAu_lName[41];
// 参数绑定
BEGIN_PARAM_MAP(CAuthors)
COLUMN_ENTRY(1, m_szAu_lName)
COLUMN_ENTRY(2, m_szAu_Id)
END_PARAM_MAP()
};
STDMETHODIMP CSimple05::ModifyData()
{
CDataSource Connection;
CSession Session;
CCommand<CAccessor<CAuthors> > Authors;
HRESULT hr;
// 创建一个事务
//IObjectContext* pObjectContext = NULL;
//hr = GetObjectContext(&pObjectContext);
//if(FAILED(hr) || ! pObjectContext) return hr;
// 检查是否存在事务环境
//if(! pObjectContext->IsInTransaction()) return E_FAIL;
// 打开数据库
CDBPropSet dbinit(DBPROPSET_DBINIT);
dbinit.AddProperty(DBPROP_INIT_DATASOURCE, OLESTR("GP2000")); // 服务器名
dbinit.AddProperty(DBPROP_AUTH_USERID, OLESTR("sa")); // 用户名
dbinit.AddProperty(DBPROP_AUTH_PASSWORD, OLESTR("123")); // 密码
dbinit.AddProperty(DBPROP_AUTH_PERSIST_SENSITIVE_AUTHINFO, false);
dbinit.AddProperty(DBPROP_INIT_CATALOG, OLESTR("pubs")); // 数据库名
