利用反射和泛型把Model对象按行储存进数据库以及按行取出然后转换成Model 类实例 MVC网站通用配置项管理

2

        T Load<T>();

        void Save<T>(T t);

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

    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

                        );

                }

            }

        }

    }

}

return temp.Rows[0].ToModel<T>();

2

3

4

        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列名

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

public class ConfigSeoModel

{

        [Display(Name = "Meta关键字")]

        public string KeyWord { get; set; }

        [Display(Name = "Meta描述")]

        public string Description { get; set; }

}

//

ConfigModelDAL dal=new ConfigModelDAL();

//new 一个Model

ConfigSeoModel model=new ConfigSeoModel();

model.KeyWord="关键字";

model.Description = "描述"

//完成保存

dal.Save<ConfigSeoModel>(model);

//读取

ConfigSeoModel model = dal.Load<ConfigModel>();