guestbooksdb.cs

This is not a very mean things

//-------------------------------------------------------------
//
// WebExpert.NET 1.0 
//
// (c) 2003, www.AspCool.com. All rights reserved.
// ASP酷技术网 版权所有
//
// 该源码下载自：http://www.51aspx.com
// 邮箱：[e-mail]
//
// 版权声明：本程序仅供学习使用，你也可以修改后在网站上使用，但使用时必
// 须保留ASP酷技术网(www.AspCool.com)的版权信息和链接。本程序随《ASP.NET
// 网站建设专家》一书赠送，未经作者同意，不得随意修改、传播。
//
// 描述:
//   此文件包含下面的类：
//       GuestBooksDB
//
// 作者:     王保健
// 时间:     2004-05-23
//
//-------------------------------------------------------------


using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;


namespace AspCool.WebExpert
{
	public class GuestBooksDB
	{
		

		# region 显示GuestBook内容
		
		//-----------------------------------------------------------
		//
		// GetGuestBooks 方法
		//
		// GetGuestBooks 方法返回所有包含所有GuestBook信息的DataSet。
		//
		//-----------------------------------------------------------
		public DataSet GetGuestBooks()
		{
			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlDataAdapter myCommand = new SqlDataAdapter("GetGuestBooks", myConnection);

			// 把命令对象的命令类型设置为存储过程。
			myCommand.SelectCommand.CommandType = CommandType.StoredProcedure;

			// 建立并填充一个DataSet。
			DataSet myDataSet = new DataSet();
			myCommand.Fill(myDataSet);
		
			// 返回一个DataSet。
			return myDataSet;
		}

		//-----------------------------------------------------------
		//
		// GetGuestBooksRecords 方法
		//
		// GetGuestBooksRecords 方法是用来计算GuestBooks的总数。
		//
		//
		//-----------------------------------------------------------
		public int GetGuestBooksRecords()
		{
			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlCommand myCommand = new SqlCommand("GetGuestBooksRecords", myConnection);

			// 把命令对象的命令类型设置为存储过程
			myCommand.CommandType = CommandType.StoredProcedure;

			
			// 执行命令。
			myConnection.Open();
			SqlDataReader result = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
			return (int)result["co"];
		}

		//-----------------------------------------------------------
		//
		// CurrentPageGuestBooks 方法
		//
		// CurrentPageGuestBooks 方法是用来从一个包含所有GuestBook的DataSet中返回一个只包含
		// 当前页面的DataSet。
		//
		// 其中currentPage是指当前的页号，pageSize是指每页有多少条GuestBook，totalPage
		// 用来返回总共有多少页GuestBook。
		//
		//-----------------------------------------------------------
		public DataSet CurrentPageGuestBooks(int currentPage,int pageSize,out int totalPage,out int records)
		{

			// 建立并填充一个DataSet。
			DataSet allGuestBooks = GetGuestBooks();

			// 创建一个新的DataSet。
			DataSet dsCurrentGuestBooks = new DataSet();

			// 计算所有GuestBook的条数。
			records = allGuestBooks.Tables[0].Rows.Count;

			// 计算当前页第一条GuestBook的位置。
			int startIndex = (currentPage-1)*pageSize;

			// 计算当前页最后一条GuestBook的位置。
			int endIndex = startIndex + pageSize;

			// 计算GuestBook的页数。
			totalPage = records/pageSize;

			if (totalPage*pageSize<records)
			{
				totalPage++;
			}

			if (endIndex>records)
				endIndex = records;
			
			// 建立一个与allGuestBooks数据结构完全一样的DataSet.
			dsCurrentGuestBooks = allGuestBooks.Clone();

			// 取得当前页的所有记录，并保存到新的DataSet中去。
			for (int i=startIndex; i<endIndex; i++)
			{
				DataRow row = dsCurrentGuestBooks.Tables[0].NewRow();
				row.ItemArray = allGuestBooks.Tables[0].Rows[i].ItemArray;

				dsCurrentGuestBooks.Tables[0].Rows.Add(row);
			}
			
			// 返回当前页的DataSet。
			return dsCurrentGuestBooks;
		}

		//-----------------------------------------------------------
		//
		// ClickGuestBooks 方法
		//
		// ClickGuestBooks 是把GuestBooks数据表中被访问的GuestBook的点击次数增加一。
		//
		//-----------------------------------------------------------

		public void ClickGuestBooks(int itemID) 
		{

			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlCommand myCommand = new SqlCommand("ClickGuestBooks", myConnection);

			// 把命令对象的命令类型设置为存储过程。
			myCommand.CommandType = CommandType.StoredProcedure;

			// 向存储过程中传递参数。
			SqlParameter parameterItemID = new SqlParameter("@ItemID", SqlDbType.Int, 4);
			parameterItemID.Value = itemID;
			myCommand.Parameters.Add(parameterItemID);

			// 打开数据库连接并执行命令。
			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();
		}

		//-----------------------------------------------------------
		//
		// GetSingleGuestBook 方法
		//
		// GetSingleGuestBook 方法是用来返回一条包含某条GuestBook记录的所有信息的SqlDataReader.
		// itemId为这条GuestBook记录的编号。
		//
		//-----------------------------------------------------------

		public SqlDataReader GetSingleGuestBook(int itemId) 
		{

			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlCommand myCommand = new SqlCommand("GetSingleGuestBook", myConnection);

			// 把命令对象的命令类型设置为存储过程
			myCommand.CommandType = CommandType.StoredProcedure;

			// 向存储过程中传递参数。
			SqlParameter parameterItemId = new SqlParameter("@ItemId", SqlDbType.Int, 4);
			parameterItemId.Value = itemId;
			myCommand.Parameters.Add(parameterItemId);

			// 执行命令。
			myConnection.Open();
			SqlDataReader result = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
            
			// 返回一个datareader。
			return result;
		}
		# endregion

		# region 增加、修改、删除GuestBook


		

		//-----------------------------------------------------------
		//
		// AddGuestBook 方法
		//
		// AddGuestBook 方法在GuestBooks表中增加一条新的GuestBook记录。
		//
		//-----------------------------------------------------------
		public void AddGuestBook(System.String userName,System.String email,System.String content,System.String subject)
		{
			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlCommand myCommand = new SqlCommand("AddGuestBook", myConnection);

			// 把命令对象的命令类型设置为存储过程。
			myCommand.CommandType = CommandType.StoredProcedure;

			// 向存储过程中传递参数。
			SqlParameter parameterUserName = new SqlParameter("@userName", SqlDbType.NVarChar,50);
			parameterUserName.Value = userName;
			myCommand.Parameters.Add(parameterUserName);

			SqlParameter parameterSubject = new SqlParameter("@subject", SqlDbType.NVarChar,100);
			parameterSubject.Value = subject;
			myCommand.Parameters.Add(parameterSubject);

			SqlParameter parameterContent = new SqlParameter("@content", SqlDbType.NText);
			parameterContent.Value = content;
			myCommand.Parameters.Add(parameterContent);

			SqlParameter parameterEmail = new SqlParameter("@email", SqlDbType.NVarChar,50);
			parameterEmail.Value = email;
			myCommand.Parameters.Add(parameterEmail);


			// 打开数据库连接并执行命令。
			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();
		}

		
		//-----------------------------------------------------------
		//
		// DeleteGuestBook 方法
		//
		// DeleteGuestBook 方法是根据GuestBook编号删除一条GuestBook记录。
		// itemID为要删除的GuestBook的编号。
		//
		//-----------------------------------------------------------

		public void DeleteGuestBook(int itemID) 
		{

			// 创建一个数据库连接实例和命令对象。
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["connectionString"]);
			SqlCommand myCommand = new SqlCommand("DeleteGuestBook", myConnection);

			// 把命令对象的命令类型设置为存储过程。
			myCommand.CommandType = CommandType.StoredProcedure;

			// 向存储过程中传递参数。
			SqlParameter parameterItemID = new SqlParameter("@ItemID", SqlDbType.Int, 4);
			parameterItemID.Value = itemID;
			myCommand.Parameters.Add(parameterItemID);

			// 打开数据库连接并执行命令。
			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();
		}

		# endregion
	}
}