lwordtask.cs

该项目中对 SQLHelper 类进行了简单封装

/* 
 * LWordTask.cs @Microsoft Visual Studio 2008 <.NET Framework 3.5>
 * AfritXia
 * 2008-02-04
 * 
 * Copyright(c) http://www.AfritXia.NET/
 * 
 */

using System;
using System.Collections.Generic;
using System.Data.Linq;
using System.Linq;

using NET.AfritXia.MyHome.DBTask.Definition;
using NET.AfritXia.MyHome.DBTask.SQLServer2005.Converter;
using NET.AfritXia.MyHome.DBTask.SQLServer2005.Entity;
using NET.AfritXia.MyHome.Model.Message;

namespace NET.AfritXia.MyHome.DBTask.SQLServer2005
{
	/// <summary>
	/// 留言数据库任务实现类
	/// </summary>
	public class LWordTask : DBTaskBase, ILWordTask
	{
		#region ILWordTask Members
		public void Append(LWord newLword)
		{
			if (newLword == null)
				return;

			// 创建转换器
			IConverter<LWord, LWordEntity> converter = new LWordConverter();

			DataContext dataCtx = null;

			// 创建数据上下文
			dataCtx = new DataContext(this.DBConn != null ? this.DBConn : ConnectionFactory.CreateConnection());
			// 设置数据库事务
			dataCtx.Transaction = this.DBTranx;

			// 添加留言
			dataCtx.GetTable<LWordEntity>().InsertOnSubmit(converter.ModelToEntity(newLword));
			// 提交修改
			dataCtx.SubmitChanges();
		}

		public void Delete(int lwordUID)
		{
			if (lwordUID <= 0)
				return;

			DataContext dataCtx = null;

			// 创建数据上下文
			dataCtx = new DataContext(this.DBConn != null ? this.DBConn : ConnectionFactory.CreateConnection());
			// 设置数据库事务
			dataCtx.Transaction = this.DBTranx;

			// 获取数据表
			var lwordTable = dataCtx.GetTable<LWordEntity>();

			// 添加留言
			dataCtx.GetTable<LWordEntity>().DeleteAllOnSubmit(from lw in lwordTable where lw.UniqueID == lwordUID select lw);
			// 提交修改
			dataCtx.SubmitChanges();
		}

		public IList<LWord> ViewLWordList(int startRecord, int maxRecords, out int allRecordCount)
		{
			allRecordCount = 0;

			// 创建数据上下文
			DataContext dataCtx = new DataContext(ConnectionFactory.CreateConnection());

			// 获取数据表
			var lwordTable = dataCtx.GetTable<LWordEntity>();

			// 创建转换器
			IConverter<LWord, LWordEntity> converter = new LWordConverter();

			// 创建查询
			var query = (from lw in lwordTable orderby lw.UniqueID descending select converter.EntityToModel(lw)).Skip(startRecord).Take(maxRecords);

			return query.ToList();
		}

		public LWord ViewLWord(int lwordUID)
		{
			// 创建数据上下文
			DataContext dataCtx = new DataContext(ConnectionFactory.CreateConnection());

			// 获取数据表
			var lwordTable = dataCtx.GetTable<LWordEntity>();

			// 创建转换器
			IConverter<LWord, LWordEntity> converter = new LWordConverter();

			// 创建查询
			var query = (from lw in lwordTable where lw.UniqueID == lwordUID select converter.EntityToModel(lw));

			return query.Single();
		}
		#endregion
	}
}