cachingcontroller.cs

SharpNuke源代码

using System;
using System.Collections;
using System.Data;
using System.IO;
using System.Reflection;
using System.Web.Caching;
using System.Xml.Serialization;

using DotNetNuke.Common.Utilities;
using DotNetNuke.Services.Log.EventLog;
using DotNetNuke.Services.Cache;
using DotNetNuke.Services.Cache.BroadcastPollingCachingProvider.Data;

//
// DotNetNuke -  http://www.dotnetnuke.com
// Copyright (c) 2002-2005
// by Shaun Walker ( [e-mail] ) of Perpetual Motion Interactive Systems Inc. ( http://www.perpetualmotion.ca )
//
// Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated
// documentation files (the "Software"), to deal in the Software without restriction, including without limitation
// the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and
// to permit persons to whom the Software is furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all copies or substantial portions
// of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
// TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
// THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
// CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
// DEALINGS IN THE SOFTWARE.
//

namespace DotNetNuke.Services.Cache.BroadcastPollingCachingProvider
{
	
	public class Controller
	{
		
		public object GetCachedObject(string key, Type type)
		{
			IDataReader dr = null;
			try
			{
				object instance = null;
				dr = DataProvider.Instance().GetCachedObject(key);
				if (dr != null)
				{
					while (dr.Read())
					{
						string str = Convert.ToString(dr["CachedObjectValue"]);
						instance = Deserialize(str, type);
					}
				}
				return instance;
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
		}
		
		public void AddCachedObject(string key, object obj, string serverName)
		{
			if (obj != null)
			{
				string str = Serialize(obj);
				DataProvider.Instance().AddCachedObject(key, str, serverName);
			}
		}
		
		public void DeleteCachedObject(string key)
		{
			DataProvider.Instance().DeleteCachedObject(key);
		}
		
		public int AddBroadcast(string broadcastType, string broadcastMessage, string serverName)
		{
			return DataProvider.Instance().AddBroadcast(broadcastType, broadcastMessage, serverName);
		}
		
		public ArrayList GetBroadcasts(string serverName)
		{
			return CBO.FillCollection(DataProvider.Instance().GetBroadcasts(serverName), typeof(BroadcastInfo));
		}
		
		private string Serialize(object obj)
		{
			return XmlUtils.Serialize(obj);
		}
		
		private object Deserialize(string str, Type type)
		{
			MemoryStream memoryStream;
			memoryStream = new MemoryStream(System.Text.ASCIIEncoding.Default.GetBytes(str));
			XmlSerializer serializer = new XmlSerializer(type);
			TextReader textReader = new StreamReader(memoryStream);
			return serializer.Deserialize(textReader);
		}
		
	}
	
}