温馨提示:代码在线浏览功能只能做为源码浏览参考,如果想更进一步了解该代码请下载:MyShop网络商城080617源码
当前文件:
MyShop080617/AccessDAL/Class.cs,打开代码结构图
MyShop080617/AccessDAL/Class.cs,打开代码结构图1using System; 2
using System.Collections.Generic; 3
using System.Data; 4
using System.Data.OleDb; 5
using MyShop.IDAL; 6
using MyShop.Model; 7
8
namespace 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





}
}