本文欢迎转载，唯请注明出处及作者 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();
return hr;}
二、创建客户端1)客户端文件如下：// Client.cpp 文件 -- COM+的事务特性
#include <windows.h>#include <stdio.h>//#include <winerror.h>// 加入comutil支持#include <comutil.h>#pragma comment( lib, "comsupp.lib" )
// 包含com的定义文件，以下两个文件从step05中拷贝出来#include "../step05/step05.h"#include "../step05/step05_i.c"
void main(){ ISimple05 * pISimple05=NULL; // 我们定义的接口
// 初始化 HRESULT hr = CoInitialize(NULL); if(FAILED(hr)) { printf("Coinitialize failed! hr=0x%x", hr); return ; }
// 创建COM对象 hr = CoCreateInstance(CLSID_Simple05, NULL, CLSCTX_ALL, IID_ISimple05, (void **)&pISimple05); if(FAILED(hr)) { printf("create com failed! hr=0x%x", hr); CoUninitialize(); return ; } // 修改数据 hr=pISimple05->ModifyData(); if(SUCCEEDED(hr)) printf("Modify Ok!"); else printf("Modify failed hr=0x%x/n");
pISimple05->Release(); CoUninitialize();
return ;}
三、配置COM+组件1)从管理工具打开“组件服务”，创建一个COM+组件STEP05，加入动态连接库step05.dll，操作同前面几节一样2)设置“Step05.Simple05.1”属性，如下图，将事务支持设置成“需要”
3)导出并配置com+的客户端，运行客户软件client.exe
四、说明1)本节简单介绍了COM+事务的使用，你可以发现在COM+中使用事务还是比较简单的，但是，如果事务本身比较复杂 会给程序的编写带来很多困难，例如，如果一个事务需要一个较长的时间来完成，它将长时间锁住系统的资源， 而阻止了其他并发用户访问此资源。如何解决资源的共享与死锁始终是网络软件设计一大难题。2)本节没有提到“及时激活”的特性，其实当我们将该组件的事务设置成“需要”时，它就自动支持了“及时激活” 的特性，如下图：
