Enterprise Library 4.1学习笔记7----缓存应用程序块之SqlDependency

Code
 1CREATE TABLE [dbo].[Messages](
 2    [ID] [int] IDENTITY(1,1) NOT NULL,
 3    [UserID] [varchar](50) COLLATE Chinese_PRC_CI_AS NOT NULL,
 4    [Message] [nvarchar](256) COLLATE Chinese_PRC_CI_AS NOT NULL,
 5 CONSTRAINT [PK_Messages] PRIMARY KEY CLUSTERED 
 6(
 7    [ID] ASC
 8)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]
 9) ON [PRIMARY]
10
11GO
12SET ANSI_PADDING OFF
13
14
15Insert Into [Messages](UserID,[Message]) values('JIMMY','Test Message1');
16Insert Into [Messages](UserID,[Message]) values('Jack','AAAAAA');

 1  using  System;
 2  using  System.Collections.Generic;
 3  using  System.Data;
 4  using  System.Data.Common;
 5  using  Microsoft.Practices.EnterpriseLibrary.Caching;
 6  using  Microsoft.Practices.EnterpriseLibrary.Caching.Expirations;
 7  using  Microsoft.Practices.EnterpriseLibrary.Data;
 8 
 9  namespace  WebApp
10  {
11       public   partial   class  _Default : System.Web.UI.Page
12      {
13 
14           string  CacheKey = " JIMMY_Message_SqlDependency_Cache " ;
15         
16 
17           protected   void  Page_Load( object  sender, EventArgs e)
18          {
19               if  ( ! IsPostBack) 
20              {
21                   this .Repeater1.DataSource  =  GetMessages( " JIMMY " );
22                   this .Repeater1.DataBind();
23              }           
24          }
25 
26           ///   <summary>
27           ///  从数据库实时查询指定用户的Message
28           ///   </summary>
29           ///   <param name="userName"></param>
30           ///   <param name="sql"></param>
31           ///   <returns></returns>
32           private  DataTable GetMessageByUserId( string  userName, string  sql) 
33          {
34              Database db  =  DatabaseFactory.CreateDatabase();
35               if  (sql.Length == 0 ) 
36              {
37                  sql  =   " Select [ID],[UserID],[Message] From [dbo].[Messages] Where [UserID]=@UserID " ;
38              }
39              DbCommand command  =  db.GetSqlStringCommand(sql);
40              db.AddInParameter(command,  " UserID " , DbType.String, userName);
41               return  db.ExecuteDataSet(command).Tables[ 0 ];
42          
43          }
44 
45           ///   <summary>
46           ///  获取用户的Message(缓存优先，数据库其次)
47           ///   </summary>
48           ///   <param name="userName"></param>
49           ///   <returns></returns>
50           private  DataTable GetMessages( string  userName)
51          {
52              ICacheManager manager  =  CacheFactory.GetCacheManager();
53               if  (manager.GetData(CacheKey)  ==   null )
54              {
55                   string  sql  =   " Select [ID],[UserID],[Message] From [dbo].[Messages] Where [UserID]=@UserID " ;
56 
57                  Dictionary < string ,  object >  Dic  =   new  Dictionary < string ,  object > ();
58                  Dic.Add( " UserID " , userName);
59                  manager.Add(CacheKey, GetMessageByUserId(userName, sql), CacheItemPriority.Normal,  null ,  new  SqlDependencyExpiration(sql,CommandType.Text, Dic));
60              }
61              
62               return  manager.GetData(CacheKey)  as  DataTable;
63          }
64      }
65  }
66