lwordtask.cs

来自「该项目中对 SQLHelper 类进行了简单封装」· CS 代码 · 共 131 行

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

using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.OleDb;

using NET.AfritXia.MyHome.Model.Message;
using NET.AfritXia.MyHome.DBTask.Definition;

namespace NET.AfritXia.MyHome.DBTask.Access2000
{
	/// <summary>
	/// LWordTask 留言板数据库任务实现类
	/// </summary>
	public partial class LWordTask : DBTaskBase, ILWordTask
	{
		#region 类 LWordTask 构造器
		/// <summary>
		/// 类 LWordTask 默认构造器
		/// </summary>
		public LWordTask()
			: base()
		{
		}
		#endregion

		#region ILWordTask 成员
		/// <summary>
		/// 添加新留言信息
		/// </summary>
		/// <param name="lword">新留言对象</param>
		public void Append(LWord lword)
		{
			MyOleDbParamCollection paramList = new MyOleDbParamCollection();

			// 设置留言发送人昵称
			paramList.Add("@FromName", OleDbType.VarWChar, 20).Value = lword.PostUser;
			// 留言内容
			paramList.Add("@TextContent", OleDbType.LongVarWChar).Value = lword.TextContent;
			// IP 地址
			paramList.Add("@ClientIP", OleDbType.VarWChar, 256).Value = lword.ClientIP;

			// 执行 SQL 查询
			CustomSQLHelper.ExecuteNoneQuery(SQL_Append, paramList.ToArray(), 
				this.DBConn, this.DBTranx);
		}

		/// <summary>
		/// 删除一个留言信息
		/// </summary>
		/// <param name="lwordID">要删除的留言 ID</param>
		public void Delete(int lwordID)
		{
			if (lwordID <= 0)
				return;

			MyOleDbParamCollection paramList = new MyOleDbParamCollection();

			// 设置留言编号
			paramList.Add("@LWordID", OleDbType.Integer).Value = lwordID;

			// 执行 SQL 查询
			CustomSQLHelper.ExecuteNoneQuery(SQL_Delete, paramList.ToArray(), 
				this.DBConn, this.DBTranx);
		}

		/// <summary>
		/// 获取留言集合
		/// </summary>
		/// <param name="startRecord">起始记录位置</param>
		/// <param name="maxRecords">最大记录个数</param>
		/// <param name="allRecordCount">总记录个数</param>
		/// <returns></returns>
		public IList<LWord> ViewLWordList(int startRecord, int maxRecords, out int allRecordCount)
		{
			allRecordCount = 0;

			if (maxRecords <= 0)
				return null;

			List<LWord> lwordList = new List<LWord>();

			// 执行 SQL 查询
			using (OleDbDataReader dr = CustomSQLHelper.ExecuteReader(SQL_ViewLWordList(startRecord, maxRecords)))
			{
				while (dr.Read())
				{
					LWord lword = CustomSQLHelper.CreateObject<LWord>(dr);
					// 将留言添加到集合
					lwordList.Add(lword);
				}
			}

			return lwordList;
		}

		/// <summary>
		/// 浏览留言板
		/// </summary>
		/// <param name="lwordUID">留言板 ID</param>
		/// <returns></returns>
		public LWord ViewLWord(int lwordUID)
		{
			LWord viewLWord = null;

			MyOleDbParamCollection paramList = new MyOleDbParamCollection();

			// 留言 ID
			paramList.Add("@LWordUID", OleDbType.Integer).Value = lwordUID;

			// 执行 SQL 查询
			using (OleDbDataReader dr = CustomSQLHelper.ExecuteReader(SQL_ViewLWord, paramList.ToArray()))
			{
				if (dr.Read())
					viewLWord = CustomSQLHelper.CreateObject<LWord>(dr);
			}

			return viewLWord;
		}
		#endregion
	}
}