discussiondb.cs

一个功能完善的论坛系统,有数据库备分,希望对你有所帮助

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

namespace bbs.Components
{

	
	/// <summary>
	/// 留言信息管理类
	/// </summary>
	public class DiscussionDB 
	{
		#region 获取模块列表
		/// <summary>
		/// 获取模块列表
		/// </summary>
		/// <param name="strConn"></param>
		/// <returns></returns>
		public DataSet GetFunctionList()
		{

			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			DataSet ds = new DataSet();
			string sqltxt = "select * from bbs_function";
			SqlDataAdapter Adapter = new SqlDataAdapter(sqltxt,myConnection); 
			Adapter.Fill(ds);
			return ds;
		}
		#endregion

		#region 得到当前Function的主题列表
		//得到当前Function的主题列表
		public DataSet GetTopicByFunction(string strFunctionID,bool IsDelete)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			DataSet ds= new DataSet();
			
			string strSelect = "Select * from bbs_Topic TP left outer Join Operator OP on TP.OperatorID = OP.UserID " +
				"left outer join bbs_Function Fun on TP.FunctionID=Fun.FunctionID where Fun.FunctionID="+strFunctionID;
			
			SqlDataAdapter Adapter = new SqlDataAdapter(strSelect,myConnection);
			Adapter.Fill(ds);
			return ds;	
		}
		#endregion

		#region 添加新主题
		
		/// <summary>
		/// 添加留言
		/// </summary>
		public void AddMessage(String TopicCaption,String TopicDetail,String TopicMiange,String OperatorID,String FunctionID) 
		{

			//参数 标题,内容,发贴人,发贴时间,功能ID
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["forum"]);
			string sqltxt="Insert Into bbs_Topic(TopicCaption,TopicDetail,TopicMiange,OperatorID,CreateTime,IsTop,IsGood,IsDelete,FunctionID) ";
		    sqltxt+="values(@TopicCaption,@TopicDetail,@TopicMiange,@OperatorID,@CreateTime,@IsTop,@IsGood,@IsDelete,@FunctionID)";
			SqlCommand myCommand = new SqlCommand(sqltxt, myConnection);

			SqlParameter parameterTopicCaption= new SqlParameter("@TopicCaption", SqlDbType.VarChar,50);
			parameterTopicCaption.Value = TopicCaption;
			myCommand.Parameters.Add(parameterTopicCaption);

			SqlParameter parameterTopicDetail = new SqlParameter("@TopicDetail", SqlDbType.VarChar, 200);
			parameterTopicDetail.Value = TopicDetail;
			myCommand.Parameters.Add(parameterTopicDetail);

			SqlParameter parameterTopicMiange= new SqlParameter("@TopicMiange", SqlDbType.VarChar,50);
			parameterTopicMiange.Value = TopicMiange;
			myCommand.Parameters.Add(parameterTopicMiange);

			SqlParameter parameterOperatorID = new SqlParameter("@OperatorID", SqlDbType.VarChar, 50);
			parameterOperatorID.Value = OperatorID;
			myCommand.Parameters.Add(parameterOperatorID);

			SqlParameter parameterCreateTime = new SqlParameter("@CreateTime", SqlDbType.DateTime, 4);
			parameterCreateTime.Value = DateTime.Now;
			myCommand.Parameters.Add(parameterCreateTime);

			SqlParameter parameterIsTop= new SqlParameter("@IsTop", SqlDbType.Bit, 1);
			parameterIsTop.Value = false;
			myCommand.Parameters.Add(parameterIsTop);

			SqlParameter parameterIsGood= new SqlParameter("@IsGood", SqlDbType.Bit, 1);
			parameterIsGood.Value = false;
			myCommand.Parameters.Add(parameterIsGood);

			SqlParameter parameterIsDelete= new SqlParameter("@IsDelete", SqlDbType.Bit, 1);
			parameterIsDelete.Value = false;
			myCommand.Parameters.Add(parameterIsDelete);

			SqlParameter parameterFunctionID= new SqlParameter("@FunctionID", SqlDbType.VarChar, 50);
			parameterFunctionID.Value = FunctionID;
			myCommand.Parameters.Add(parameterFunctionID);


			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();	
			TopicCount(OperatorID);
		}
		#endregion 

		#region 修改主题内容
		/// <summary>
		/// 修改主题内容
		/// </summary>
		public void EditTopic(String TopicCaption,String TopicDetail, String OperatorID,String TopicID) 
		{

			//参数 标题,内容,发贴人,发贴时间,功能ID
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["forum"]);
			string sqltxt="Update bbs_Topic Set TopicCaption=@TopicCaption,TopicDetail=@TopicDetail,CreateTime=@CreateTime ";
			sqltxt+="Where OperatorID=@OperatorID And TopicID=@TopicID";
			SqlCommand myCommand = new SqlCommand(sqltxt, myConnection);

			SqlParameter parameterTopicCaption= new SqlParameter("@TopicCaption", SqlDbType.VarChar,50);
			parameterTopicCaption.Value = TopicCaption;
			myCommand.Parameters.Add(parameterTopicCaption);

			SqlParameter parameterTopicDetail = new SqlParameter("@TopicDetail", SqlDbType.VarChar, 200);
			parameterTopicDetail.Value = TopicDetail;
			myCommand.Parameters.Add(parameterTopicDetail);

			SqlParameter parameterCreateTime = new SqlParameter("@CreateTime", SqlDbType.DateTime, 4);
			parameterCreateTime.Value = DateTime.Now;
			myCommand.Parameters.Add(parameterCreateTime);

			SqlParameter parameterOperatorID = new SqlParameter("@OperatorID", SqlDbType.VarChar, 50);
			parameterOperatorID.Value = OperatorID;
			myCommand.Parameters.Add(parameterOperatorID);

			SqlParameter parameterTopicID= new SqlParameter("@TopicID", SqlDbType.VarChar, 50);
			parameterTopicID.Value = TopicID;
			myCommand.Parameters.Add(parameterTopicID);

			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();	
		}

		#endregion

		#region 修改回复内容

		/// <summary>
		/// 修改回复内容
		/// </summary>
		public void EditReply(String ForumCaption,String ForumDetail, String OperatorID,String ForumID) 
		{

			//参数 标题,内容,发贴人,发贴时间,功能ID
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["forum"]);
			string sqltxt="Update bbs_Forum Set ForumCaption=@ForumCaption,ForumDetail=@ForumDetail,ReplyTime=@ReplyTime ";
			sqltxt+="Where OperatorID=@OperatorID And ForumID=@ForumID";
			SqlCommand myCommand = new SqlCommand(sqltxt, myConnection);

			SqlParameter parameterForumCaption= new SqlParameter("@ForumCaption", SqlDbType.VarChar,50);
			parameterForumCaption.Value = ForumCaption;
			myCommand.Parameters.Add(parameterForumCaption);

			SqlParameter parameterForumDetail = new SqlParameter("@ForumDetail", SqlDbType.VarChar, 200);
			parameterForumDetail.Value = ForumDetail;
			myCommand.Parameters.Add(parameterForumDetail);

			SqlParameter parameterReplyTime = new SqlParameter("@ReplyTime", SqlDbType.DateTime, 4);
			parameterReplyTime.Value = DateTime.Now;
			myCommand.Parameters.Add(parameterReplyTime);

			SqlParameter parameterOperatorID = new SqlParameter("@OperatorID", SqlDbType.VarChar, 50);
			parameterOperatorID.Value = OperatorID;
			myCommand.Parameters.Add(parameterOperatorID);

			SqlParameter parameterForumID= new SqlParameter("@ForumID", SqlDbType.VarChar, 50);
			parameterForumID.Value = ForumID;
			myCommand.Parameters.Add(parameterForumID);

			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();	
		}

		#endregion

		#region 删除帖子

		/// <summary>
		/// 修改回复内容
		/// </summary>
		public void DeleteForum(String TopicOrForum,String TopicIDOrFatherID,String ID) 
		{

			//参数 标题,内容,发贴人,发贴时间,功能ID
			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["forum"]);
			string sqltxt="Delete " +TopicOrForum+ " Where "+TopicIDOrFatherID+"=@ID";
			SqlCommand myCommand = new SqlCommand(sqltxt, myConnection);

			SqlParameter parameterID= new SqlParameter("@ID", SqlDbType.VarChar, 50);
			parameterID.Value = ID;
			myCommand.Parameters.Add(parameterID);

			myConnection.Open();
			myCommand.ExecuteNonQuery();
			myConnection.Close();	
		}

		#endregion

		#region 得到当前主题
		//得到当前主题
		public DataSet GetTopic(string strTopicID)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			DataSet ds= new DataSet();
			
			string strtxt = "select * from bbs_Topic TP left outer join Operator OP on TP.OperatorID = OP.UserID where TP.TopicID="+strTopicID;
			SqlDataAdapter Adapter = new SqlDataAdapter(strtxt,myConnection);
			Adapter.Fill(ds);
			return ds;
			
		}
		#endregion

		#region 获取数据内容
		//得到当前主题
		public DataSet GetBody(string TopicOrForum,string TopicIDOrForumID,string ID)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			DataSet ds=new DataSet();
			string strtxt = "select * from "+TopicOrForum+" where "+TopicIDOrForumID+"="+ID;


			SqlDataAdapter Adapter = new SqlDataAdapter(strtxt,myConnection);
			Adapter.Fill(ds);
			return ds;
			
		}
		#endregion

		

		#region 得到当前主题回复
		//得到当前主题回复