discussiondb.cs

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

		public DataSet GetForumByTopic(string strTopicID)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			DataSet ds= new DataSet();
			
			string strtxt = "select * from bbs_Forum FR left outer join bbs_Topic TP on FR.FatherID=TP.TopicID ";
			strtxt+= " left outer join Operator OP on FR.OperatorID = OP.UserID where FR.FatherID="+strTopicID;
			SqlDataAdapter Adapter = new SqlDataAdapter(strtxt,myConnection);
			Adapter.Fill(ds);
			return ds;
			
		}
		#endregion

		#region 回复主题
		/// <summary>
		/// 回复主题
		/// </summary>
		public void ReplyTopMessage(string FatherID,string OperatorID,string ForumCaption,string ForumDetail) 
		{

			SqlConnection myConnection = new SqlConnection(ConfigurationSettings.AppSettings["forum"]);
			string sqltxt="insert into bbs_Forum(ForumCaption,FatherID,ForumDetail,OperatorID,ReplyTime)";
			sqltxt+=" values(@ForumCaption,@FatherID,@ForumDetail,@OperatorID,@ReplyTime)";
			SqlCommand myCommand = new SqlCommand(sqltxt, myConnection);

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

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

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

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

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

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

		#region 计算点击率
		/// <summary>
		/// 计算点击率
		/// </summary>
		/// <param name="Itemid"></param>

		public void ClickCount(string TopicID)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			string sqltxt="Update bbs_Topic set clickcount=clickcount+1 where TopicID=" +TopicID;
			SqlCommand cmd = new SqlCommand(sqltxt,myConnection); 
			myConnection.Open(); 
			cmd.ExecuteNonQuery(); 
			myConnection.Close();
		}
		#endregion

		#region 计算回复次数
		/// <summary>
		/// 计算回复次数
		/// </summary>
		/// <param name="Itemid"></param>

		public void ReplyTopCount(string FatherID)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			string sqltxt="Select articles set replycount=replycount+1 where FatherID=" +FatherID;
			SqlCommand cmd = new SqlCommand(sqltxt,myConnection); 
			myConnection.Open(); 
			cmd.ExecuteNonQuery(); 
			myConnection.Close();
		}
		#endregion

		#region 最后更新
		/// <summary>
		/// 最后更新
		/// </summary>
		/// <param name="FunctionID"></param>
		/// <param name="LastRePerson"></param>
		/// <param name="LastReTopic"></param>
		public void UpdateRe(string FunctionID,string LastRePerson,string LastReTopic)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			string sqltxt="Update bbs_function set LastRePerson=@LastRePerson,LastReTopic=@LastReTopic,TopicForumCount=@TopicForumCount,UpdateTime=@UpdateTime where FunctionID="+FunctionID;
			SqlCommand cmd = new SqlCommand(sqltxt,myConnection); 
			SqlParameter parameterLastRePerson= new SqlParameter("@LastRePerson", SqlDbType.VarChar,50);
			parameterLastRePerson.Value = LastRePerson;
			cmd.Parameters.Add(parameterLastRePerson);

			SqlParameter parameterLastReTopic= new SqlParameter("@LastReTopic", SqlDbType.VarChar,50);
			parameterLastReTopic.Value = LastReTopic;
			cmd.Parameters.Add(parameterLastReTopic);

			SqlParameter parameterTopicForumCount= new SqlParameter("@TopicForumCount", SqlDbType.Int,50);
			parameterTopicForumCount.Value = this.GetTopicCount(FunctionID);
			cmd.Parameters.Add(parameterTopicForumCount);

			SqlParameter parameterUpdateTime = new SqlParameter("@UpdateTime", SqlDbType.DateTime, 4);
			parameterUpdateTime.Value = DateTime.Now;
			cmd.Parameters.Add(parameterUpdateTime);

			myConnection.Open(); 
			cmd.ExecuteNonQuery(); 
			myConnection.Close();
		}
		#endregion

		#region 回贴更新
		/// <summary>
		/// 回贴更新
		/// </summary>
		/// <param name="FunctionID"></param>
		/// <param name="LastRePerson"></param>
		/// <param name="LastReTopic"></param>
		public void UpdateReply(string FunctionID,string LastRePerson,string LastReTopic)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			string sqltxt="Update bbs_function set LastRePerson=@LastRePerson,LastReTopic=@LastReTopic,UpdateTime=@UpdateTime where FunctionID="+FunctionID;
			SqlCommand cmd = new SqlCommand(sqltxt,myConnection); 
			SqlParameter parameterLastRePerson= new SqlParameter("@LastRePerson", SqlDbType.VarChar,50);
			parameterLastRePerson.Value = LastRePerson;
			cmd.Parameters.Add(parameterLastRePerson);

			SqlParameter parameterLastReTopic= new SqlParameter("@LastReTopic", SqlDbType.VarChar,50);
			parameterLastReTopic.Value = LastReTopic;
			cmd.Parameters.Add(parameterLastReTopic);

			SqlParameter parameterUpdateTime = new SqlParameter("@UpdateTime", SqlDbType.DateTime, 4);
			parameterUpdateTime.Value = DateTime.Now;
			cmd.Parameters.Add(parameterUpdateTime);

			myConnection.Open(); 
			cmd.ExecuteNonQuery(); 
			myConnection.Close();
		}
		#endregion

		#region 计算个人发贴数量
		/// <summary>
		/// 计算个人发贴数量
		/// </summary>
		/// <param name="userid"></param>
		public void TopicCount(String userid)
		{
			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);
			string sqltxt="Update Operator set TopicCount=TopicCount+1 where userid=" +userid;
			SqlCommand cmd = new SqlCommand(sqltxt,myConnection); 
			myConnection.Open(); 
			cmd.ExecuteNonQuery(); 
			myConnection.Close();
		}

		#endregion

		#region 获取主题总数

		/// <summary>
		/// 获取主题总数
		/// </summary>
		/// <param name="FunctionID"></param>
		/// <returns></returns>
		public int GetTopicCount(string FunctionID)
		{

			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);

			string strtxt = "select Count(*) as CountID from bbs_topic Where FunctionID=@FunctionID";
			SqlCommand cmd=new SqlCommand(strtxt,myConnection );

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

			myConnection.Open();
			SqlDataReader dr=cmd.ExecuteReader();
			dr.Read();
			int TopicCount=Convert.ToInt32(dr["CountID"].ToString());
			dr.Close();
			myConnection.Close();

			return TopicCount;
		}

		#endregion

		#region 计算回帖总数

		/// <summary>
		/// 计算回帖总数
		/// </summary>
		/// <param name="FunctionID"></param>
		/// <param name="TopicID"></param>
		public void GetReplyCountByFunctionID(string FunctionID,string TopicID)
		{

			string connstr=ConfigurationSettings.AppSettings["forum"];
			SqlConnection myConnection = new SqlConnection(connstr);

			string strtxt1 = "Update bbs_function set ReplyForumCount=ReplyForumCount+1 Where FunctionID=@FunctionID";
			SqlCommand cmd1=new SqlCommand(strtxt1,myConnection );

			SqlParameter parameterFunctionID = new SqlParameter("@FunctionID", SqlDbType.VarChar);
			parameterFunctionID.Value = FunctionID;
			cmd1.Parameters.Add(parameterFunctionID);
			
			string strtxt2 = "Update bbs_Topic set ReplyCount=ReplyCount+1 Where TopicID=@TopicID";
			SqlCommand cmd2=new SqlCommand(strtxt2,myConnection );

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

			myConnection.Open();
			
			cmd1.ExecuteNonQuery(); 
			cmd2.ExecuteNonQuery(); 

			myConnection.Close();

			
		}
		#endregion

	}
}