1using System;
  2using System.Collections.Generic;
  3using System.Data;
  4using System.Data.OleDb;
  5using MyShop.IDAL;
  6using MyShop.Model;
  7
  8namespace MyShop.AccessDAL
  9...{
 10    public class Article : IArticle
 11    ...{
 12
 13        private ConfigInfo configInfo = new ConfigInfo();
 14        private string tableName = "Ljh_Article";
 15
 16        public Article()
 17        ...{
 18            if (!string.IsNullOrEmpty(configInfo.TablePrefix.Trim()))
 19                tableName = configInfo.TablePrefix + "Article";
 20        }
 21
 22        IArticle member#region IArticle member
 23
 24
 25        /**//// <summary>
 26        /// add  
 27        /// </summary>
 28        /// <param name="model"></param>
 29        /// <returns>返回ID, 如果发生错误则返回-1</returns>
 30        public int Add(ArticleInfo model)
 31        ...{
 32            if (model == null)
 33            ...{
 34                return -1;
 35            }
 36            string commandText = "insert into " + this.tableName + "(ChannelID,ClassID,Title,Author,CopyFrom,Inputer,Editor,Keyword,Hits,CommentCount,CreateTime,OnTop,Elite,Content,DefaultPicUrl,IncludePic,Stars,Deleted,Status,IsHot)  values(@ChannelID,@ClassID,@Title,@Author,@CopyFrom,@Inputer,@Editor,@Keyword,@Hits,@CommentCount,@CreateTime,@OnTop,@Elite,@Content,@DefaultPicUrl,@IncludePic,@Stars,@Deleted,@Status,@IsHot)  ";
 37            OleDbParameter[] commandParameters = 
 38             ...{ 
 39                    Database.MakeInParam("@ChannelID", OleDbType.Integer, 4, model.ChannelID), 
 40                 Database.MakeInParam("@ClassID", OleDbType.Integer, 4, model.ClassID), 
 41                 Database.MakeInParam("@Title", OleDbType.VarWChar, 0xff, model.Title),
 42                 Database.MakeInParam("@Author", OleDbType.VarWChar, 0xff, model.Author), 
 43                 Database.MakeInParam("@CopyFrom", OleDbType.VarWChar, 0xff, model.CopyFrom),
 44                 Database.MakeInParam("@Inputer", OleDbType.VarWChar, 20, model.Inputer), 
 45                 Database.MakeInParam("@Editor", OleDbType.VarWChar, 20, model.Editor), 
 46                 Database.MakeInParam("@Keyword", OleDbType.VarWChar, 0xff, model.Keyword), 
 47                 Database.MakeInParam("@Hits", OleDbType.Integer, 4, model.Hits), 
 48                 Database.MakeInParam("@CommentCount", OleDbType.Integer, 4, model.CommentCount), 
 49                 Database.MakeInParam("@CreateTime", OleDbType.DBTimeStamp, 8, model.CreateTime),
 50                 Database.MakeInParam("@OnTop", OleDbType.Integer, 4, model.OnTop),
 51                 Database.MakeInParam("@Elite", OleDbType.UnsignedTinyInt, 4, model.IsElite), 
 52                 Database.MakeInParam("@Content", OleDbType.VarWChar, 0, model.Content),
 53                 Database.MakeInParam("@DefaultPicUrl", OleDbType.VarWChar, 0xff, model.DefaultPicUrl), 
 54                 Database.MakeInParam("@IncludePic", OleDbType.Integer, 4, model.IncludePic), 
 55                    Database.MakeInParam("@Stars", OleDbType.Integer, 4, model.Stars), 
 56                 Database.MakeInParam("@Deleted", OleDbType.UnsignedTinyInt, 1, model.Deleted),
 57                 Database.MakeInParam("@Status", OleDbType.UnsignedTinyInt, 1, model.Status), 
 58                 Database.MakeInParam("@Ishot", OleDbType.UnsignedTinyInt, 1, model.IsHot)
 59                 };
 60            int intIdentity = -1;
 61            try
 62            ...{
 63                Database.ExecuteNonQuery(CommandType.Text, out intIdentity, commandText, commandParameters);
 64            }
 65            catch (Exception exception)
 66            ...{
 67                throw exception;
 68            }
 69            return intIdentity;
 70        }
 71
 72 
 73
 74 
 75
 76        /**//// <summary>
 77        /// 删除 
 78        /// </summary>
 79        /// <param name="filter">where后面的条件语句，不加where</param>
 80        /// <returns>返回影响行数</returns>
 81        public int Delete(string filter)
 82        ...{
 83            int count = -1;
 84            string sql = @"delete from " + tableName;
 85            if (!string.IsNullOrEmpty(filter.Trim()))
 86            ...{
 87                sql = sql + "  where  " + filter;
 88            }
 89            try
 90            ...{
 91
 92                count = Database.ExecuteNonQuery(sql);
 93            }
 94            catch (Exception ex)
 95            ...{
 96                throw ex;
 97            }
 98            return count;
 99        }
100
101        /**//// <summary>
102        /// 
103        /// </summary>
104        /// <param name="filter"></param>
105        /// <returns></returns>
106        public bool Exist(string filter)
107        ...{
108            bool result = false;
109            string sql = @"select * from " + tableName;
110            if (!string.IsNullOrEmpty(filter))
111            ...{
112                sql = sql + "  where  " + filter;
113            }
114            try
115            ...{
116
117
118                DataSet dataset = new DataSet();
119                dataset = Database.ExecuteDataSet(sql);
120                if (dataset.Tables[0].Rows.Count > 0)
121                ...{
122                    result = true;
123                }
124            }
125            catch (Exception ex)
126            ...{
127                throw ex;
128            }
129            return result;
130        }
131
132        /**//// <summary>
133        /// 返回所有
134        /// </summary>
135        /// <returns>返回所有</returns>
136        public DataSet GetDataSet()
137        ...{
138            string sql = "select * from " + tableName;
139            DataSet dataset = new DataSet();
140            try
141            ...{
142
143                dataset = Database.ExecuteDataSet(sql);
144
145            }
146            catch (Exception ex)
147            ...{
148                throw ex;
149            }
150            return dataset;
151        }
152
153        public DataSet GetDataSet(string filter)
154        ...{
155            if (string.IsNullOrEmpty(filter))
156                return null;
157
158            string sql = "select * from " + tableName + " where " + filter;
159            DataSet dataset = new DataSet();
160            try
161            ...{
162
163                dataset = Database.ExecuteDataSet(sql);
164            }
165            catch (Exception ex)
166            ...{
167                throw ex;
168            }
169            return dataset;
170        }
171
172        /**//// <summary>
173        ///
174        /// </summary>
175        /// <param name="dr"></param>
176        /// <returns></returns>
177        public ArticleInfo GetModel(DataRow dr)
178        ...{
179            if (dr == null)
180                return null;
181            ArticleInfo model = new ArticleInfo();
182
183            if (dr["ArticleID"].ToString() != "") model.ArticleID = Convert.ToInt32( dr["ArticleID"]);
184            if (dr["ChannelID"].ToString() != "") model.ChannelID = Convert.ToInt32(  dr["ChannelID"]);
185            if (dr["ClassID"].ToString() != "") model.ClassID =  Convert.ToInt32( dr["ClassID"]);
186            if (dr["Title"].ToString() != "") model.Title = dr["Title"].ToString();
187            if (dr["Author"].ToString() != "") model.Author = dr["Author"].ToString();
188            if (dr["CopyFrom"].ToString() != "") model.CopyFrom = dr["CopyFrom"].ToString();
189            if (dr["Inputer"].ToString() != "") model.Inputer = dr["Inputer"].ToString();
190            if (dr["Editor"].ToString() != "") model.Editor = dr["Editor"].ToString();
191            if (dr["Keyword"].ToString() != "") model.Keyword = dr["Keyword"].ToString();
192            if (dr["Hits"].ToString() != "") model.Hits = Convert.ToInt32(  dr["Hits"]);
193            if (dr["CommentCount"].ToString() != "") model.CommentCount = Convert.ToInt32(  dr["CommentCount"]);
194            if (dr["CreateTime"].ToString() != "") model.CreateTime = dr["CreateTime"].ToString();
195            if (dr["OnTop"].ToString() != "") model.OnTop = Convert.ToInt32(  dr["OnTop"]);
196            if (dr["Elite"].ToString() != "") model.IsElite = Convert.ToInt32(  dr["Elite"]);
197            if (dr["Content"].ToString() != "") model.Content = dr["Content"].ToString();
198            if (dr["DefaultPicUrl"].ToString() != "") model.DefaultPicUrl = dr["DefaultPicUrl"].ToString();
199            if (dr["IncludePic"].ToString() != "") model.IncludePic = Convert.ToInt32(  dr["IncludePic"]);
200            if (dr["Stars"].ToString() != "") model.Stars = Convert.ToInt32(  dr["Stars"]);
201            if (dr["Deleted"].ToString() != "") model.Deleted = Convert.ToInt32(dr["Deleted"]);
202            if (dr["Status"].ToString() != "") model.Status = Convert.ToInt32(dr["Status"]);
203            if (dr["Ishot"].ToString() != "") model.IsHot = Convert.ToInt32(dr["IsHot"]);
204
205            return model;
206        }
207
208        /**//// <summary>
209        /// 
210        /// </summary>
211        /// <param name="sql"></param>
212        /// <returns></returns>
213        public DataSet Query(string sql)
214        ...{
215            if (string.IsNullOrEmpty(sql))
216                return null;
217
218            DataSet dataset = new DataSet();
219            try
220            ...{
221
222                dataset = Database.ExecuteDataSet(sql);
223            }
224            catch (Exception ex)
225            ...{
226                throw ex;
227            }
228            return dataset;
229        }
230
231
232        /**//// <summary>
233        /// update  
234        /// </summary>
235        /// <param name="model"></param>
236        /// <param name="filter"></param>
237        /// <returns></returns>
238        public int Update(ArticleInfo model, string filter)
239        ...{
240            int result;
241            if (string.IsNullOrEmpty(filter))
242            ...{
243                throw new Exception("The 'filter' can not be null!");
244            }
245            string sql = @"update " + tableName + " set ChannelID=@ChannelID,ClassID=@ClassID,Title=@Title,Author=@Author,CopyFrom=@CopyFrom,Inputer=@Inputer,Editor=@Editor,Keyword=@Keyword,Hits=@Hits,CommentCount=@CommentCount,CreateTime=@CreateTime,OnTop=@OnTop,Elite=@Elite,Content=@Content,DefaultPicUrl=@DefaultPicUrl,IncludePic=@IncludePic,Stars=@Stars,Deleted=@Deleted,Status=@Status,IsHot=@IsHot " + " where " + filter;
246
247
248            OleDbParameter[] prams = ...{
249                                            Database.MakeInParam("@ChannelID", OleDbType.Integer    ,    4    ,model.ChannelID    ),
250                                            Database.MakeInParam("@ClassID", OleDbType.Integer    ,    4    ,model.ClassID    ),
251                                            Database.MakeInParam("@Title", OleDbType.VarWChar    ,    255    ,model.Title    ),
252                                            Database.MakeInParam("@Author", OleDbType.VarWChar        ,    255    ,model.Author    ),
253                                            Database.MakeInParam("@CopyFrom", OleDbType.VarWChar    ,    255    ,model.CopyFrom    ),
254                                            Database.MakeInParam("@Inputer", OleDbType.VarWChar        ,    20    ,model.Inputer    ),
255                                            Database.MakeInParam("@Editor", OleDbType.VarWChar    ,    20    ,model.Editor    ),
256                                            Database.MakeInParam("@Keyword", OleDbType.VarWChar        ,    255    ,model.Keyword    ),
257                                            Database.MakeInParam("@Hits", OleDbType.Integer    ,    4    ,model.Hits    ),
258                                            Database.MakeInParam("@CommentCount", OleDbType.Integer    ,    4    ,model.CommentCount    ),
259                                            Database.MakeInParam("@CreateTime", OleDbType.Date    ,    8    ,model.CreateTime    ),
260                                            Database.MakeInParam("@OnTop", OleDbType.Integer    ,    4    ,model.OnTop    ),
261