localdbservice.cs

来自「《征服Ajax》原书的例题源码」· CS 代码 · 共 119 行

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using Microsoft.Practices.EnterpriseLibrary.Data;
using Microsoft.Practices.EnterpriseLibrary.Data.Sql;
using System.Data.Common;
using System.Text;
using System.Xml;
using System.Xml.Xsl;

namespace Db
{
	/// <summary>
	/// Summary description for LocalDbService
	/// </summary>
	public class LocalDbService : DbService
	{
		private Database _db;
		public LocalDbService()
		{
			_db = DatabaseFactory.CreateDatabase("DatabaseConnectionString");
		}

		#region DbService Members

		public bool InsertMail(string from, string to, string subject, string body, int status, int size)
		{
			string sqlCommand = "InsertMail";
			DbCommand dbCommand = _db.GetStoredProcCommand(sqlCommand);

			_db.AddInParameter(dbCommand, "from", DbType.String, from);
			_db.AddInParameter(dbCommand, "to", DbType.String, to);
			_db.AddInParameter(dbCommand, "subject", DbType.String, subject);
			_db.AddInParameter(dbCommand, "body", DbType.String, body);
			_db.AddInParameter(dbCommand, "status", DbType.Int32, status);
			_db.AddInParameter(dbCommand, "size", DbType.Int32, size);

			_db.ExecuteNonQuery(dbCommand);

			return true;
		}

		public bool DeleteMail(int id)
		{
			string sqlCommand = "DeleteMail";
			DbCommand dbCommand = _db.GetStoredProcCommand(sqlCommand);

			_db.AddInParameter(dbCommand, "id", DbType.Int32, id);

			_db.ExecuteNonQuery(dbCommand);

			return true;
		}

		public bool ChangeMailStatus(int id, int read)
		{
			string sqlCommand = "ChangeMailStatus";
			DbCommand dbCommand = _db.GetStoredProcCommand(sqlCommand);

			_db.AddInParameter(dbCommand, "id", DbType.Int32, id);
			_db.AddInParameter(dbCommand, "read", DbType.Int32, read);

			_db.ExecuteNonQuery(dbCommand);

			return true;
		}

		public bool ChangeMailFolder(int id, int folder)
		{
			string sqlCommand = "ChangeMailFolder";
			DbCommand dbCommand = _db.GetStoredProcCommand(sqlCommand);

			_db.AddInParameter(dbCommand, "id", DbType.Int32, id);
			_db.AddInParameter(dbCommand, "folder", DbType.Int32, folder);

			_db.ExecuteNonQuery(dbCommand);

			return true;
		}

		public void WriteMailList(string sql, string strXslPath, System.IO.TextWriter writer)
		{
			SqlDatabase db = DatabaseFactory.CreateDatabase("DatabaseConnectionString") as SqlDatabase;
			DbCommand dbCommand = db.GetSqlStringCommand(sql);

			XmlReader reader = null;

			try
			{
				reader = db.ExecuteXmlReader(dbCommand);

				// xslt转换
				XslCompiledTransform xslt = new XslCompiledTransform();
				xslt.Load(strXslPath);

				XmlWriter xmlWriter = new XmlTextWriter(writer);
				xslt.Transform(reader, xmlWriter);
			}
			finally
			{
				if (dbCommand.Connection != null)
				{
					dbCommand.Connection.Close();
				}
			}


		}
 
		#endregion
	}
}