forumsqldataprovider.cs

Dos 以功能个性化和人性化为基础

            string sqlinsert = string.Empty;

            sql = "insert into DoNetBbs_Board (";
            sqlinsert = ") values (";
            sql += "BoardParentID,";
            sqlinsert += "'" + board.BoardParentID + "',";
            sql += "BoardName,";
            sqlinsert += "'" + board.BoardName + "',";
            sql += "BoardTypeID,";
            sqlinsert += "'" + board.BoardTypeID + "',";
            sql += "BoardSubject,";
            sqlinsert += "'" + board.BoardSubject + "',";
            sql += "BoardOrders,";
            sqlinsert += "'" + board.BoardOrders + "',";
            sql += "BoardMaster,";
            sqlinsert += "'" + board.BoardMaster + "',";
            sql += "BoardLastTopicTitle,";
            sqlinsert += "'" + board.BoardLastTopicTitle + "',";
            sql += "BoardLastTopicID,";
            sqlinsert += "'" + board.BoardLastTopicID + "',";
            sql += "BoardLastTopicTime,";
            sqlinsert += "'" + board.BoardLastTopicTime + "',";
            sql += "BoardLastTopicUserNickName,";
            sqlinsert += "'" + board.BoardLastTopicUserNickName + "',";
            sql += "BoardLastTopicUserID,";
            sqlinsert += "'" + board.BoardLastTopicUserID + "',";
            sql += "BoardFalse,";
            sqlinsert += "'" + board.BoardFalse + "',";
            sql += "BoardImages,";
            sqlinsert += "'" + board.BoardImages + "',";
            sql += "BoardAbout,";
            sqlinsert += "'" + board.BoardAbout + "',";
            sql += "BoardPostNumber,";
            sqlinsert += "'" + board.BoardPostNumber + "',";
            sql += "BoardTodayPostNumber,";
            sqlinsert += "'" + board.BoardTodayPostNumber + "',";
            sql += "BoardTopicNumber,";
            sqlinsert += "'" + board.BoardTopicNumber + "',";
            sql += "BoardDelPoint,";
            sqlinsert += "'" + board.BoardDelPoint + "',";
            sql += "BoardPostRole,";
            sqlinsert += "'" + board.BoardPostRole + "',";
            sql += "BoardRePostRole,";
            sqlinsert += "'" + board.BoardRePostRole + "',";
            sql += "BoardViewRole";
            sqlinsert += "'" + board.BoardViewRole + "'";


            sql += sqlinsert + ")";
            DataConnectionHepler.Instance().ExceCuteSql(sql);
        }

        public override int SetTopicCount(string query, bool Cach)
        {
            MySql = "select count(TopicID) as CountNumber from DoNetBbs_Topic " + query;
            //DoNetBbs.DoNetBbsClassHepler.Instance().GetHttpContext().Response.Write(MySql);
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-Topic-count" + query.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {
                    dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_Topic");
                    Components.CsCache.Insert(key, dt, null);
                }
                else
                {
                    dt = _cachetable;
                }
            }
            else
            {
                dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_Topic");
            }

            if (dt.Rows.Count > 0)
            {
                return int.Parse(dt.Rows[0][0].ToString());
            }
            else
            {
                return 0;
            }
        }//

        public override ArrayList SetTopic(string query, int start, int size, bool Cach)
        {
            Components.Components.Topic Rs = new Components.Components.Topic();
            DataTable dt;
            MySql = "select * from DoNetBbs_Topic " + query;
            if (Cach)
            {
                string key = "WebSite-Topic" + query.ToString() + "-" + start.ToString() + "-" + size.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {
                    dt = DataConnectionHepler.Instance().DataAdapter(MySql, start, size, "DoNetBbs_Topic");
                    Components.CsCache.Insert(key, dt, null);
                }
                else
                {
                    dt = _cachetable;
                }
            }
            else
            {
                dt = DataConnectionHepler.Instance().DataAdapter(MySql, start, size, "DoNetBbs_Topic");
            }

            if (dt.Rows.Count > 0)
            {
                foreach (DataRow row in dt.Rows)
                {
                    Components.Components.Topic _Arraylist = new Components.Components.Topic();
                    _Arraylist.SetDataProviders(row);
                    Rs.Arraylist.Add(_Arraylist);
                }
            }
            return Rs.Arraylist;
        }//

        public override DataRow SetTopic(int topicID, bool Cach)
        {
            MySql = "select * from DoNetBbs_Topic where TopicID=" + topicID.ToString() + "";
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-Topic" + topicID.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {
                    dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_Topic");
                    Components.CsCache.Insert(key, dt, null);
                }
                else
                {
                    dt = _cachetable;
                }
            }
            else
            {
                dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_Topic");
            }

            if (dt.Rows.Count > 0)
            {
                return dt.Rows[0];
            }
            else
            {
                return null;
            }

        }//

        public override int SetTopicInfoCount(int topicID, bool Cach)
        {
            MySql = "select count(TopicInfoID) as CountNumber from DoNetBbs_TopicInfo where TopicInfoRootID=" + topicID + "";
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-TopicInfo-Count-" + topicID.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {
                    dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_TopicInfo");
                    Components.CsCache.Insert(key, dt, null);
                }
                else
                {
                    dt = _cachetable;
                }
            }
            else
            {
                dt = DataConnectionHepler.Instance().DataAdapter(MySql, 0, 1, "DoNetBbs_TopicInfo");
            }
            if (dt.Rows.Count > 0)
            {
                return int.Parse(dt.Rows[0][0].ToString());
            }
            else
            {
                return 0;
            }
        }
        
        //
        public override ArrayList SetTopicInfoList(int topicID, int index, int count, bool Cach)
        {
            Components.Components.TopicInfo Rs = new Components.Components.TopicInfo();
            DataTable dt;
            MySql = "select * from DoNetBbs_TopicInfo where TopicInfoRootID=" + topicID + " order by TopicInfoPostTime asc";
            if (Cach)
            {
                string key = "DoNetBbs-TopicInfo-List-" + topicID.ToString() + "-" + index.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {
                    dt = DataConnectionHepler.Instance().DataAdapter(MySql, index, count, "DoNetBbs_TopicInfo");
                    Components.CsCache.Insert(key, dt, null);
                }
                else
                {
                    dt = _cachetable;
                }
            }
            else
            {
                dt = DataConnectionHepler.Instance().DataAdapter(MySql, index, count, "DoNetBbs_TopicInfo");
            }
            if (dt.Rows.Count > 0)
            {
                foreach (DataRow row in dt.Rows)
                {
                    Components.Components.TopicInfo _Arraylist = new Components.Components.TopicInfo();
                    _Arraylist.SetDataProviders(row);
                    Rs.Arraylist.Add(_Arraylist);
                }
            }
            return Rs.Arraylist;
        }//

        public override void UpdateTopic(Components.Components.Topic topic)
        {
            MySql = "update DoNetBbs_Topic set ";
            MySql += "TopicTitle = '" + topic.TopicTitle + "',";
            MySql += "TopicBoardID =  '" + topic.TopicBoardID + "',";
            MySql += "TopicImages = '" + topic.TopicImages + "',";
            MySql += "TopicRePostEmail = '" + topic.TopicRePostEmail + "',";
            MySql += "TopicReNumber = '" + topic.TopicReNumber + "',";
            MySql += "TopicViewNumber = '" + topic.TopicViewNumber + "',";
            MySql += "TopicReLastUserID = '" + topic.TopicReLastUserID + "',";
            MySql += "TopicReLastUserNickName = '" + topic.TopicReLastUserNickName + "',";
            MySql += "TopicBest =  '" + topic.TopicBest + "',";
            MySql += "TopicRecommend = '" + topic.TopicRecommend + "',";
            MySql += "TopicTotalAtTop = '" + topic.TopicTotalAtTop + "',";
            MySql += "TopicLastReTime = '" + topic.TopicLastReTime + "',";
            MySql += "TopicSubjectID = '" + topic.TopicSubjectID + "',";
            MySql += "TopicFalse = '" + topic.TopicFalse + "',";
            MySql += "TopicPostUserID = '" + topic.TopicPostUserID + "',";
            MySql += "TopicPostUserNickName = '" + topic.TopicPostUserNickName + "',";
            MySql += "TopicPostTime = '" + topic.TopicPostTime + "',";
            MySql += "TopicSpecialTitle = '" + topic.TopicSpecialTitle + "'";
            MySql += " where TopicID=" + topic.TopicID + "";
            DataConnectionHepler.Instance().ExceCuteSql(MySql);
        }
        public override void UpdateTopicView(int topicID)
        {
            MySql = "update DoNetBbs_Topic set TopicViewNumber=TopicViewNumber+1 where TopicID=" + topicID + "";
            DataProviders.DataConnectionHepler.Instance().ExceCuteSql(MySql);
        }

        public override DataRow SetTopicInfo(int topicInfoID, bool Cach)
        {
            MySql = "select * from DoNetBbs_TopicInfo where TopicInfoID=" + topicInfoID.ToString() + "";
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-TopicInfo" + topicInfoID.ToString();
                DataTable _cachetable = Components.CsCache.Get(key) as DataTable;
                if (_cachetable == null)
                {