Oracle数据库上的ASP.NET缓存依赖
现在考虑这样一个情景：数据存放于Oracle数据库中，一个ASP.NET应用通过ADO.NET来访问。进一步，我们假设数据库表中的数据一般是静态的，并被这个Web应用频繁访问。表上的DML操作很少而对数据有很多Select。这种情况是数据缓存技术的理想应用。但不幸的是，ASP.NET并不允许设定一个缓存项依赖于存放在数据库表中的数据。进一步，现实世界中，基于Web的系统，Web服务器和Oracle数据库服务器总是会运行在不同的机器上，使得缓存无效操作更有挑战性。另外，多数基于Web的应用采用Web farms，同一个应用的实例在不同的Web服务器上跑以负载均衡。这种情况使得数据库缓存问题稍稍复杂一些。
为了进一步研究上述问题的解决方案，我们举一个Web应用的例子来说明如何实现。例子中，我们使用VB.NET实现的ASP.NET应用，通过Oracle Data Provider for .NET (ODP)来访问 Oracle 9i数据库。
这个例子使用Oracle数据库中一个名为Employee的表。我们为该表上insert, update, delete设定触发器。这些触发器调用一个封装了一个Java存储过程的PL/SQL函数。这个Java存储过程负责更新缓存依赖的文件。
ASP.NET Tier的VB.NET实现
我们设计了含一个回调方法的监听类来处理缓存项无效时的通知。这个回调方法RemovedCallback用一个代理（delegate）函数来注册。回调方法onRemove的声明必须与CacheItemRemovedCallback代理声明又相同的签名。
| Dim onRemove As CacheItemRemovedCallback = Nothing onRemove = New CacheItemRemovedCallback(AddressOf RemovedCallback) |
监听事件处理方法RemovedCallback负责处理数据库触发器的通知，其定义如下。若缓存项失效，可用数据库方法调用getRecordFromdatabase()从数据库取出数据。参数”key”指从缓存中删除的项的索引位置。参数”value”指从缓存中删除的数据对象。参数"CacheItemRemovedReason"指从缓存中删除数据项的原因。
| PublicSub RemovedCallback(ByVal key AsString, ByVal value AsObject, ByVal reason As CacheItemRemovedReason) Dim Source As DataView Source = getRecordFromdatabase() Cache.Insert("employeeTable ", Source, New System.Web.Caching.CacheDependency("d:/download/tblemployee.txt"), Cache.NoAbsoluteExpiration, Cache.NoSlidingExpiration, CacheItemPriority.Normal, onRemove) EndSub |
方法getRecordFromdatabase()负责查询数据库表Employee并返回一个DataView对象引用。它使用一个名为getEmployee的存储过程来抽象从Employee表中取数据的SQL。这个方法有一个名为p_empid的参数，表示Employee的主键。
| PublicFunction getRecordFromdatabase (ByVal p_empid As Int32) As DataView Dim con As OracleConnection = Nothing Dim cmd As OracleCommand = Nothing Dim ds As DataSet = Nothing Try con = getDatabaseConnection( "UserId=scott;Password=tiger;Data Source=testingdb;") cmd = New OracleCommand("Administrator.getEmployee", con) cmd.CommandType = CommandType.StoredProcedure cmd.Parameters.Add(New OracleParameter("employeeId", OracleDbType.Int64)).Value = p_empid Dim param AsNew OracleParameter("RC1", OracleDbType.RefCursor) cmd.Parameters.Add(param).Direction = ParameterDirection.Output Dim myCommand AsNew OracleDataAdapter(cmd) ds = New DataSet myCommand.Fill(ds) Dim table As DataTable = ds.Tables(0) Dim index As Int32 = table.Rows.Count Return ds.Tables(0).DefaultView Catch ex As Exception ThrowNew Exception("Exception in Database Tier Method getRecordFromdatabase () " + ex.Message, ex) Finally Try cmd.Dispose() Catch ex As Exception Finally cmd = Nothing EndTry Try con.Close() Catch ex As Exception Finally con = Nothing EndTry EndTry EndFunction |
函数getDatabaseConnection接受一个连接字符串（connection stirng）为参数，返回一个OracleConnection对象引用。
| PublicFunction getDatabaseConnection(ByVal strconnection as string) As OracleConnection Dim con As Oracle.DataACCESS.Client.OracleConnection = Nothing Try con = New Oracle.DataACCESS.Client.OracleConnection con.ConnectionString = strconnection con.Open() Return con Catch ex As Exception ThrowNew Exception("Exception in Database Tier Method getOracleConnection() " + ex.Message, ex) EndTry EndFunction |
http://dev.xuezhishi.net/website/NET/2007-10-17/20793.html
