利用泛型和反射,管理配置文件,把Model转换成数据行,并把数据行转换成Model

小贝 · 发表于 2018-3-23 08:00:05

使用场景:网站配置项目,为了便于管理,网站有几个Model类来管理配置文件,

比如ConfigWebsiteModel 用来管理基本信息

ConfigSeoModel 用来管理SEO信息

ConfigCacheModel 用来管理网站缓存信息

不用Model之间不能有重名属性字段

现在需要把他们储存到数据库中,并从数据库中读取出来转换成Model以便修改.不使用 List和Dictionary的原因是想利用MVC提供的强大数据自检能力.

核心类: 两个方法Load和Save Load传入T并返回T的实例 Save 传入T并储存到数据库

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Data;
using System.Text;
using ChengChenXu.Blog.Models;
using System.Reflection;
using System.Data.SqlClient;
namespace ChengChenXu.Blog.DAL.SqlServer
{
public class ConfigModelDAL:IConfigModelDAL
{
private readonly string tableName = "blog_Config";//表名
private readonly string columnKey = "c_Key";//key列名
private readonly string columnValue = "c_Value";//Value列名
private readonly string columnType = "c_Type";//Type列名
/// <summary>
/// 加载
/// </summary>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
public T Load<T>()
{
//通过sqlhelper获取datatable
string sql = "select * from " + tableName;
DataTable dt = SqlHelper.ExecuteDataTable(sql);
//不存在记录
if (dt.Rows.Count == 0) return default(T);
//表行转换成列 ,临时表
DataTable temp = new DataTable();
foreach (DataRow dr in dt.Rows)
{
//添加一列,设置列的数据类型
DataColumn dc = new DataColumn();
dc.ColumnName = dr[columnKey].ToString();
//根据字符串设置数据类型
dc.DataType = System.Type.GetType(dr[columnType].ToString());
temp.Columns.Add(dc);
//如果时第一列,添加一行
int index = temp.Columns.Count - 1;
if (temp.Rows.Count == 0) temp.Rows.Add();
//如果不是第一例,则行必定已经存在,直接赋值
temp.Rows[0][index] = dr[columnValue];
}
if (temp.Columns.Count == 0) return default(T);
//把临时表转换成Model并返回
return temp.Rows[0].ToModel<T>();
}
/// <summary>
/// 保存
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="t"></param>
public void Save<T>(T t)
{
//利用反射获取对象所有属性
string attributeName = String.Empty;
PropertyInfo[] propertys = t.GetType().GetProperties();
//获取数据库配置表放到内存中,对比数据是否已经存在
DataTable dt = new DataTable();
if (propertys.Length > 0)
{
dt = SqlHelper.ExecuteDataTable("select * from "+tableName+"");
//给表设置主键,方便查找.
dt.PrimaryKey=new[] {(dt.Columns[columnKey])};
}
//依次保存对象属性到数据库
foreach (PropertyInfo pi in propertys)
{
//获取属性值
var a = pi.GetValue(t, null);
//值为NULL跳出,不保存,进入下个循环
if (a == null)
{
SqlHelper.ExecuteNonQuery("delete from "+tableName+" where "+columnKey+" ='"+pi.Name+"' ");
continue;
}
//准备sql参数
SqlParameter[] parameters = SqlHelper.CreatParameters(
new string[] { "Key", "Value" ,"Type"},
new object[] { pi.Name, a, a.GetType().ToString() }
);
//查找属性是否已经存在于数据库中
if(dt.Rows.Contains(pi.Name))
{
//存在更新属性
SqlHelper.ExecuteNonQuery(
"update " + tableName + " set " + columnValue + " = @Value , " + columnType + " = @Type where " + columnKey + " = @Key",
parameters
);
}
else
{
//不存在插入属性
SqlHelper.ExecuteNonQuery(
"insert into " + tableName + " (" + columnKey + "," + columnValue + "," + columnType + ") values (@key,@value,@type) ",
parameters
);
}
}
}
}
}