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