commenttask.cs

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

/* 
 * CommentTask.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 CommentTask : DBTaskBase, ICommentTask
	{
		#region ICommentTask Members
		public void Append(Comment newComment)
		{
			if (newComment == null)
				return;

			// 创建转换器
			IConverter<Comment, CommentEntity> converter = new CommentConverter();

			DataContext dataCtx = null;

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

			// 添加评论
			dataCtx.GetTable<CommentEntity>().InsertOnSubmit(converter.ModelToEntity(newComment));
			// 提交修改
			dataCtx.SubmitChanges();
		}

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

			DataContext dataCtx = null;

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

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

			// 添加留言
			dataCtx.GetTable<CommentEntity>().DeleteAllOnSubmit(from cm in commentTable where cm.UniqueID == commentUID select cm);
			// 提交修改
			dataCtx.SubmitChanges();
		}

		public IList<Comment> ViewCommentList(int belongToArticleUID)
		{
			if (belongToArticleUID <= 0)
				return null;

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

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

			// 创建转换器
			IConverter<Comment, CommentEntity> converter = new CommentConverter();

			// 创建查询
			var query = (from cm in commentTable where cm.BelongToArticleUID == belongToArticleUID select converter.EntityToModel(cm));

			return query.ToList();
		}

		public Comment ViewComment(int commentUID)
		{
			if (commentUID <= 0)
				return null;

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

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

			// 创建转换器
			IConverter<Comment, CommentEntity> converter = new CommentConverter();

			// 创建查询
			var query = (from cm in commentTable where cm.UniqueID == commentUID select converter.EntityToModel(cm));

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