分享我的数据处理类库,欢迎拍砖
说明:首先在实体类中定义Attribute对象(主要包括表、字段信息),然后通过反射读取该对象信息,再进行数据处理
一、类关系图如下:
二、各类用途说明
BaseEntity:实体类的基类,实体类必须继承该类。
TableConfig/FieldConfig：描述表及字段配置信息,其中FieldConfig包括FieldName(字段名称)、DataType(数据类型)、Size(字段大小)、IsInsert(是否Insert操作)、IsUpdate(是否Update操作)五个字段信息。
QueryHelper:查询对象。
SplitPageParameter:分页对象。
IDbProvider:数据处理接口。
OperationAction:数据操作枚举。
DataProvider:实现IDbProvider接口,并提供基础数据操作。
SqlDbProvider/OleDbProvider:继承自DataProvider并提供相应操作。
DataFactory:向外部提供IDbProvider服务。
三、配置文件需提供如下信息：
Code<!--
Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/
--> <add key="CNT" value="Data Source=192.168.1.4;User ID=sa;Password=pw;Initial Catalog=DB;Pooling=true"/>
<add key="DBTYPE" value="MSSQL"/>
<add key="EntityFile" value="App.Entity,version=1.0.0.0"/>
CNT:数据连接字符串
DBTYPE:数据库类型(目前只支持MSSQL/OLEDB)
EntityFile:实体类程序集信息
四、接口说明:
void Save(BaseEntity info):保存实体类
void Update(BaseEntity info, QueryHelper query):根据条件更新实体类
void Delete(QueryHelper query):根据条件删除数据
BaseEntity Find(QueryHelper query):根据条件读取一条数据
List
List
void UpdateFields(string tableName, string[] fieldNames, object[] fieldValues, QueryHelper query):根据条件更新指定表的指定字段
五、核心函数说明
（1）、DataProvider.cs
Code<!--
Code highlighting produced by Actipro CodeHighlighter (freeware)
http://www.CodeHighlighter.com/
--> 1
/**//// 2
/// 准备生成DbCommand命令3
/// 4
/// 5
/// 6
/// 7
/// 8
/// 9
protected IDbCommand PrepareCommand(object o, Type type, OperationAction action, QueryHelper query)10
{11
IDbCommand cmd = Factory.CreateCommand();12
13
//获取当前类型的表配置信息14
TableConfig configInfo = null;15
if (type == null)16
{17
type = query.TypeInfo; 18
}19
configInfo = getTableConfigByType(type);20
21
FieldInfo fldInfo = null;22
23
IDataParameter parameter = null;24
25
if (action == OperationAction.Insert)26
{27
insert config#region insert config28
29
StringBuilder sqlInsert = new StringBuilder();30
StringBuilder sqlValues = new StringBuilder();31
32
for (int i = 0; i < configInfo.Fields.Count; ++i)33
{34
if (!configInfo.Fields[i].IsInsert)35
continue;36
if (sqlInsert.Length > 0)37
{38
sqlInsert.Append(",");39
sqlValues.Append(",");40
}41
sqlInsert.Append(configInfo.Fields[i].FieldName);42
sqlValues.Append("@").Append(configInfo.Fields[i].FieldName);43
44
parameter = MakeParameter(configInfo.Fields[i]);45
46
//获取字段信息47
fldInfo = type.GetField(configInfo.Fields[i].FieldName);48
//从对象中获取该字段的值49
if (fldInfo != null)50
{51
parameter.Value = fldInfo.GetValue(o);52
}53
cmd.Parameters.Add(parameter);54
}55
//设置Command的命令文本56
cmd.CommandText = string.Format("INSERT INTO {0}({1}) VALUES({2})", configInfo.TableName, sqlInsert.ToString(), sqlValues.ToString());57
58
#endregion59
}60
else if (action == OperationAction.Update)61
{62
update config#region update config63
64
StringBuilder sqlUpdate = new StringBuilder();65
66
for (int i = 0; i < configInfo.Fields.Count; ++i)67
{68
if (!configInfo.Fields[i].IsUpdate)69
continue;70
if (sqlUpdate.Length > 0)71
{72
sqlUpdate.Append(",");73
}74
sqlUpdate.Append(string.Format(" {0}=@{0}", configInfo.Fields[i].FieldName));75
parameter = MakeParameter(configInfo.Fields[i]);76
//获取字段信息77
fldInfo = type.GetField(configInfo.Fields[i].FieldName);78
//从对象中获取该字段的值79
if (fldInfo != null)80
{81
parameter.Value = fldInfo.GetValue(o);82
}83
cmd.Parameters.Add(parameter);84
}85
//设置Command的命令文本86
cmd.CommandText = string.Format("UPDATE {0} SET {1} ", configInfo.TableName, sqlUpdate.ToString());87
88
if (query != null)89
cmd.CommandText += string.Format(" WHERE 1=1 {0}", query.getSQLString);90
91
#endregion92
}93
else if (action == OperationAction.Delete)94
{95
delete config#region delete config96
97
cmd.CommandText = string.Format("DELETE {0}", configInfo.TableName);98
99
if (query != null)100
cmd.CommandText += string.Format(" WHERE 1=1 {0}", query.getSQLString);101
102
#endregion103
}104
else if (action == OperationAction.Select)105
{106
select config#region select config107
if (query != null)108
{109
if (query.Top > 0)110
{111
cmd.CommandText = string.Format("SELECT TOP {0} * FROM {1} WHERE 1=1 {2}", query.Top, configInfo.TableName, query.getSQLString);112
}113
else114
{115
cmd.CommandText = string.Format("SELECT * FROM {0} WHERE 1=1 {1}", configInfo.TableName, query.getSQLString);116
}117
}118
else119
{120
cmd.CommandText = string.Format("SELECT * FROM {0}", configInfo.TableName);121
}122
123
#endregion124
}125
return cmd;126
}此函数根据对象类型，通过反射获取实体类信息及实体类字段值，然后组织SQL语句为IDbCommand赋值
应用场景：
适合数据处理较小的应用
使用:
DataFactory.getDbProvider.Save(info);
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/12639172/viewspace-617186/ ，如需转载，请注明出处，否则将追究法律责任。
