本文欢迎转载，唯请注明出处及作者 blackcolor@263.net
---------------------------------------------------
实战COM(08)----COM+的特性之事务、及时激活
一、创建组件
1)创建一个进程内组件Step05，加入一个“Simple Object”，命名为“Simple05”，修改
“Threading Model”属性为“Both”， “Interface”属性为“custom”。
2)给接口ISimple05增加一个方法HRESULT ModifyData()
3)修改文件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")); // 数据库名
dbinit.AddProperty(DBPROP_INIT_LCID, (long)2052);
dbinit.AddProperty(DBPROP_INIT_PROMPT, (short)4);
hr = Connection.Open(_T("SQLOLEDB.1"), &dbinit);
if (FAILED(hr)) return hr;
hr = Session.Open(Connection);
if (FAILED(hr))
{
Connection.Close();
return hr;
}
// 设置更新条件
strcpy(Authors.m_szAu_Id, "172-32-1176"); // 172-32-1176
strcpy(Authors.m_szAu_lName, "MY name"); // White
hr = Authors.Open(Session, "Update Authors Set Au_lName = ? Where Au_Id = ?");
if(pObjectContext)
{
if(SUCCEEDED(hr))
{
pObjectContext->SetComplete(); // 提交事务
}
else
{
pObjectContext->SetAbort();
}
}
Session.Close();
Connection.Close();
