当前文件路径：hevod/DAL/Admins.cs 
1
using System;
2using System.Data;
3using System.Data.OleDb;
4
5namespace DAL
6
...{
7
/**//// <summary>
8
/// admins数据层
9
/// </summary>
10 public class Admins
11 ...{
12 public DBConn dbConn = new DBConn();
13 /**//// <summary>
14 /// 读取数据库中所有管理员
15 /// </summary>
16 public DataSet GetAdmins()
17 ...{
18 string sql = "select id,name,pwd,type,ip,pDate from admins order by id desc";
19 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
20 OleDbDataAdapter da = new OleDbDataAdapter(cmd);
21 DataSet ds = null;
22 try
23 ...{
24 dbConn.Open();
25 ds = new DataSet();
26 da.Fill(ds);
27 }
28 catch (OleDbException ex)
29 ...{
30 throw ex;
31 }
32 catch (Exception ex)
33 ...{
34 throw ex;
35 }
36 finally
37 ...{
38 dbConn.Close();
39 }
40 return ds;
41 }
42
43 /**//// <summary>
44 /// 根据id读取单条admin信息
45 /// </summary>
46 /// <returns></returns>
47 public Model.Admins GetAdminInfo(int id)
48 ...{
49 Model.Admins modelAdmin = new Model.Admins();
50 string sql = "select name,type,ip,pdate from admins where id="+id;
51 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
52 dbConn.Open();
53 OleDbDataReader dr = cmd.ExecuteReader();
54 if (dr.Read())
55 ...{
56 modelAdmin.Name = dr["name"].ToString();
57 modelAdmin.Type = dr["type"].ToString();
58 modelAdmin.Ip = dr["ip"].ToString();
59 modelAdmin.Pdate = Convert.ToDateTime(dr["pdate"]);
60 }
61 else
62 ...{
63 modelAdmin.Name = "暂无";
64 modelAdmin.Type = "1";
65 modelAdmin.Ip = "127.0.0.1";
66 modelAdmin.Pdate = DateTime.Now.ToLocalTime();
67 }
68 dr.Close();
69 dbConn.Close();
70 return modelAdmin;
71
72 }
73
74 /**//// <summary>
75 /// 根据用户名读取单条admin信息(用于记录用户登录信息)
76 /// </summary>
77 /// <returns></returns>
78 public Model.Admins GetAdminInfoByName(string name)
79 ...{
80 Model.Admins modelAdmin = new Model.Admins();
81 string sql = "select id,name,type,ip,pdate from admins where name='"+name+"'";
82 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
83 dbConn.Open();
84 OleDbDataReader dr = cmd.ExecuteReader();
85 if (dr.Read())
86 ...{
87 modelAdmin.Id =Convert.ToInt32(dr["id"]);
88 modelAdmin.Type = dr["type"].ToString();
89 modelAdmin.Ip = dr["ip"].ToString();
90 modelAdmin.Pdate = Convert.ToDateTime(dr["pdate"]);
91 }
92 else
93 ...{
94 modelAdmin.Name = "暂无";
95 modelAdmin.Type = "1";
96 modelAdmin.Ip = "127.0.0.1";
97 modelAdmin.Pdate = DateTime.Now.ToLocalTime();
98 }
99 dr.Close();
100 dbConn.Close();
101 return modelAdmin;
102
103 }
104
105
106 /**//// <summary>
107 /// 根据条件读取数据库中admin
108 /// 不包括pdate等时间函数
109 /// </summary>
110 /// <returns>DataSet</returns>
111 public DataSet GetAdminsBy(string condition)
112 ...{
113 string sql = "select name,pwd,Type,ip,pdate from admins where " + condition;
114 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
115 OleDbDataAdapter da = new OleDbDataAdapter(cmd);
116 DataSet ds = null;
117 try
118 ...{
119 dbConn.Open();
120 ds = new DataSet();
121 da.Fill(ds);
122 }
123 catch (OleDbException ex)
124 ...{
125 throw ex;
126 }
127 catch (Exception ex)
128 ...{
129 throw ex;
130 }
131 finally
132 ...{
133 dbConn.Close();
134 }
135 return ds;
136 }
137
138 /**//// <summary>
139 /// 根据条件判断是否存在admins数据
140 /// 不包括pdate等时间函数
141 /// </summary>
142 /// <returns>true-存在;false-不存在</returns>
143 public bool IsAdminHasBy(string condition)
144 ...{
145 bool isOK = false;
146 string sql = "select id,name,pwd,pdate from admins where "+condition;
147 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
148 dbConn.Open();
149 OleDbDataReader dr = cmd.ExecuteReader();
150 if (dr.Read())
151 ...{
152 isOK = true;
153 }
154 dr.Close();
155 dbConn.Close();
156
157 return isOK;
158 }
159
160 /**//// <summary>
161 /// 添加用户
162 /// </summary>
163 /// <returns>true-成功;false-失败</returns>
164 public bool AddAdmin(string name,string pwd,string type,string ip)
165 ...{
166 bool isOK = false;
167 string sql = "insert into admins (name,pwd,type,ip,pDate) values ('"+name+"','"+pwd+"','"+type+"','"+ip+"','"+DateTime.Now.ToString()+"')";
168 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
169 try
170 ...{
171 dbConn.Open();
172 //如果添加成功则返回
173 if (cmd.ExecuteNonQuery() > 0)
174 isOK = true;
175 }
176 catch (OleDbException ex)
177 ...{
178 throw ex;
179 }
180 catch (Exception ex)
181 ...{
182 throw ex;
183 }
184 finally
185 ...{
186
187 dbConn.Close();
188 }
189 return isOK;
190 }
191
192 /**//// <summary>
193 /// 修改admins，修改用户类型
194 /// </summary>
195 /// <returns>true-成功;false-失败</returns>
196 public bool UpdateAdminPwd(int id, string pwd)
197 ...{
198 bool isOK = false;
199 string sql = "update admins set pwd='" + pwd + "' where id=" + id;
200 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
201 try
202 ...{
203 dbConn.Open();
204 if(cmd.ExecuteNonQuery()>0)
205 isOK = true;
206 }
207 catch (OleDbException ex)
208 ...{
209 throw ex;
210 }
211 catch (Exception ex)
212 ...{
213 throw ex;
214 }
215 finally
216 ...{
217 dbConn.Close();
218 }
219 return isOK;
220 }
221
222 /**//// <summary>
223 /// 修改用户类型
224 /// </summary>
225 /// <param name="id"></param>
226 /// <param name="type"></param>
227 /// <returns></returns>
228 public bool UpdateAdminType(int id, string type)
229 ...{
230 bool isOK = false;
231 string sql = "update admins set type='" + type + "' where id=" + id;
232 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
233 try
234 ...{
235 dbConn.Open();
236 if (cmd.ExecuteNonQuery() > 0)
237 isOK = true;
238 }
239 catch (OleDbException ex)
240 ...{
241 throw ex;
242 }
243 catch (Exception ex)
244 ...{
245 throw ex;
246 }
247 finally
248 ...{
249 dbConn.Close();
250 }
251 return isOK;
252 }
253
254
255 /**//// <summary>
256 /// 删除admins，根据ID
257 /// </summary>
258 /// <returns>true-成功;false-失败</returns>
259 public bool DelAdmin(int id)
260 ...{
261 bool isOK = false;
262 string sql = "delete from admins where id=" + id;
263 OleDbCommand cmd = new OleDbCommand(sql, dbConn.conn);
264 try
265 ...{
266 dbConn.Open();
267 cmd.ExecuteNonQuery();
268 isOK = true;
269 }
270 catch (OleDbException ex)
271 ...{
272 throw ex;
273 }
274 catch (Exception ex)
275 ...{
276 throw ex;
277 }
278 finally
279 ...{
280 dbConn.Close();
281 }
282 return isOK;
283 }
284 }
285
}
286
打包下载该项目完整源码：燕赵宽频点播系统V1.0源码