forumsqldataprovider.cs

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

                    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 dt.Rows[0];
            }
            else
            {
                return null;
            }
        }

        public override DataRow SetRootTopicInfo(int rootID, bool Cach)
        {
            MySql = "select * from DoNetBbs_TopicInfo where TopicInfoRootID=" + rootID.ToString() + " and TopicInfoParentID=0";
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-Root-TopicInfo" + rootID.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 dt.Rows[0];
            }
            else
            {
                return null;
            }
        }

        public override void InsertTopic(Components.Components.Topic topic)
        {
            string sql = string.Empty;
            string sqlinsert = string.Empty;

            sql = "insert into DoNetBbs_Topic (";
            sqlinsert = ") values (";
            sql += "TopicTitle,";
            sqlinsert += "'" + topic.TopicTitle + "',";
            sql += "TopicBoardID,";
            sqlinsert += "'" + topic.TopicBoardID + "',";
            sql += "TopicImages,";
            sqlinsert += "'" + topic.TopicImages + "',";
            sql += "TopicReNumber,";
            sqlinsert += "'" + topic.TopicReNumber + "',";
            sql += "TopicViewNumber,";
            sqlinsert += "'" + topic.TopicViewNumber + "',";
            sql += "TopicReLastUserID,";
            sqlinsert += "'" + topic.TopicReLastUserID + "',";
            sql += "TopicReLastUserNickName,";
            sqlinsert += "'" + topic.TopicReLastUserNickName + "',";
            sql += "TopicBest,";
            sqlinsert += "'" + topic.TopicBest + "',";
            sql += "TopicRecommend,";
            sqlinsert += "'" + topic.TopicRecommend + "',";
            sql += "TopicTotalAtTop,";
            sqlinsert += "'" + topic.TopicTotalAtTop + "',";
            sql += "TopicLastReTime,";
            sqlinsert += "'" + topic.TopicLastReTime + "',";
            sql += "TopicSubjectID,";
            sqlinsert += "'" + topic.TopicSubjectID + "',";
            sql += "TopicFalse,";
            sqlinsert += "'" + topic.TopicFalse + "',";
            sql += "TopicPostUserID,";
            sqlinsert += "'" + topic.TopicPostUserID + "',";
            sql += "TopicPostUserNickName,";
            sqlinsert += "'" + topic.TopicPostUserNickName + "',";
            sql += "TopicPostTime,";
            sqlinsert += "'" + topic.TopicPostTime + "',";
            sql += "TopicRePostEmail,";
            sqlinsert += "'" + topic.TopicRePostEmail + "',";
            sql += "TopicSpecialTitle";
            sqlinsert += "'" + topic.TopicSpecialTitle + "'";
            sql += sqlinsert + ")";
            //HttpContext.Current.Response.Write("window.open()");
            //return;
            DataConnectionHepler.Instance().ExceCuteSql(sql);
        }

        public override DataRow SetLastTopic(string topicTitle, int boardID, int userID, bool Cach)
        {
            MySql = "select * from DoNetBbs_Topic where TopicTitle='" + topicTitle.ToString() + "' and TopicBoardID=" + boardID + " and TopicPostUserID=" + userID + " order by TopicID desc";
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-LastTopic" + topicTitle.ToString() + "-" + boardID.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 void InsertTopicInfo(Components.Components.TopicInfo topicInfo)
        {
            string sql = string.Empty;
            string sqlinsert = string.Empty;
            sql = "insert into DoNetBbs_TopicInfo (";
            sqlinsert = ") values (";
            sql += "TopicInfoTitle,";
            sqlinsert += "'" + topicInfo.TopicInfoTitle + "',";
            sql += "TopicInfoUserID,";
            sqlinsert += "'" + topicInfo.TopicInfoUserID + "',";
            sql += "TopicInfoRootID,";
            sqlinsert += "'" + topicInfo.TopicInfoRootID + "',";
            sql += "TopicInfoParentID,";
            sqlinsert += "'" + topicInfo.TopicInfoParentID + "',";
            sql += "TopicInfoUserNickName,";
            sqlinsert += "'" + topicInfo.TopicInfoUserNickName + "',";
            sql += "TopicInfoUserIP,";
            sqlinsert += "'" + topicInfo.TopicInfoUserIP + "',";
            sql += "TopicInfoFalse,";
            sqlinsert += "'" + topicInfo.TopicInfoFalse + "',";
            sql += "TopicInfoHtml,";
            sqlinsert += "'" + topicInfo.TopicInfoHtml + "',";
            sql += "TopicInfoText,";
            sqlinsert += "'" + topicInfo.TopicInfoText + "',";
            sql += "TopicInfoViewRole,";
            sqlinsert += "'" + topicInfo.TopicInfoViewRole + "',";
            sql += "TopicInfoRePostRole,";
            sqlinsert += "'" + topicInfo.TopicInfoRePostRole + "',";
            sql += "TopicInfoFace,";
            sqlinsert += "'" + topicInfo.TopicInfoFace + "',";
            sql += "TopicInfoBuyMoney,";
            sqlinsert += "'" + topicInfo.TopicInfoBuyMoney + "',";
            sql += "TopicInfoPostTime,";
            sqlinsert += "'" + topicInfo.TopicInfoPostTime + "',";
            sql += "TopicInfoViewUserGroup,";
            sqlinsert += "'" + topicInfo.TopicInfoViewUserGroup + "',";
            sql += "TopicInfoRePostUserGroup,";
            sqlinsert += "'" + topicInfo.TopicInfoRePostUserGroup + "',";
            sql += "TopicInfoSignFalse,";
            sqlinsert += "'" + topicInfo.TopicInfoSignFalse + "',";
            sql += "TopicInfoReply,";
            sqlinsert += "'" + topicInfo.TopicInfoReply + "',";
            sql += "TopicInfoEditHistory";
            sqlinsert += "'" + topicInfo.TopicInfoEditHistory + "'";
            sql += sqlinsert + ")";
            //HttpContext.Current.Response.Write(sql);
            //return;
            DataConnectionHepler.Instance().ExceCuteSql(sql);
        }

        public override void UpdateTopicInfo(Components.Components.TopicInfo topicInfo)
        {
            MySql = "update DoNetBbs_TopicInfo set ";
            MySql += "TopicInfoTitle = '" + topicInfo.TopicInfoTitle + "',";
            MySql += "TopicInfoUserID = '" + topicInfo.TopicInfoUserID + "',";
            MySql += "TopicInfoRootID = '" + topicInfo.TopicInfoRootID + "',";
            MySql += "TopicInfoParentID = '" + topicInfo.TopicInfoParentID + "',";
            MySql += "TopicInfoUserNickName = '" + topicInfo.TopicInfoUserNickName + "',";
            MySql += "TopicInfoUserIP = '" + topicInfo.TopicInfoUserIP + "',";
            MySql += "TopicInfoFalse = '" + topicInfo.TopicInfoFalse + "',";
            MySql += "TopicInfoHtml = '" + topicInfo.TopicInfoHtml + "',";
            MySql += "TopicInfoText = '" + topicInfo.TopicInfoText + "',";
            MySql += "TopicInfoViewRole = '" + topicInfo.TopicInfoViewRole + "',";
            MySql += "TopicInfoRePostRole ='" + topicInfo.TopicInfoRePostRole + "',";
            MySql += "TopicInfoFace = '" + topicInfo.TopicInfoFace + "',";
            MySql += "TopicInfoBuyMoney = '" + topicInfo.TopicInfoBuyMoney + "',";
            MySql += "TopicInfoPostTime = '" + topicInfo.TopicInfoPostTime + "',";
            MySql += "TopicInfoViewUserGroup = '" + topicInfo.TopicInfoViewUserGroup + "',";
            MySql += "TopicInfoRePostUserGroup = '" + topicInfo.TopicInfoRePostUserGroup + "',";
            MySql += "TopicInfoSignFalse = '" + topicInfo.TopicInfoSignFalse + "',";
            MySql += "TopicInfoReply = '" + topicInfo.TopicInfoReply + "',";
            MySql += "TopicInfoEditHistory = '" + topicInfo.TopicInfoEditHistory + "'";
            MySql += " where TopicInfoID = " + topicInfo.TopicInfoID + "";
            DataConnectionHepler.Instance().ExceCuteSql(MySql);
        }

        public override void DeleteTopic(int topicID)
        {
            DataConnectionHepler.Instance().ExceCuteSql("delete from DoNetBbs_Topic where TopicID = " + topicID + "");
        }

        public override void DeleteTopicInfo(int topicInfoID)
        {
            DataConnectionHepler.Instance().ExceCuteSql("delete from DoNetBbs_TopicInfo where TopicInfoID = " + topicInfoID + "");
        }

        public override bool SetMyReply(int userID, int topicID, bool Cach)
        {
            MySql = "select TopicInfoID from DoNetBbs_TopicInfo where TopicInfoUserID='" + userID + "' and TopicInfoRootID='" + topicID + "'";
            //DoNetBbs.DoNetBbsClassHepler.Instance().GetHttpContext().Response.Write(MySql);
            DataTable dt;
            if (Cach)
            {
                string key = "WebSite-Topic-myReply" + userID.ToString() + "-" + 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 true;
            }
            else
            {
                return false;
            }
        }

      
    }
}