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