使用C#表达式进行以成员命名为锚点的数据转换

使用C#表达式进行以成员命名为锚点的数据转换

在软件开辟中,有时由于某些原因如底层数据结构不可更改等需要将数据结构进行转换,这些数据类型之间没有继续关系,只有字段或属性名相同,往往需要手动编写数据转换代码,这样不仅繁琐,而且容易出错.
假如涉及到大量差别的类型转换,我们可以使用C#中的反射机制来转换数据.虽然使用反射很通用,但是还是太吃运行时间了,有没有一种既通用又高效的方法呢?
有的,兄弟有的,在C#中提供了动态创建表达式的功能,我们将基于C#表达式(Expression),设计一个通用的数据转换工具.
结构界说

起首,我们需要明确工具接口和一些结构界说.
我们的转换工具需要一个GetData方法,传入object,输出想要的数据结构;还需要一个标志表示某个类型是需要转换的,这个标志可以使用Attribute或接口表示,我们这里使用一个空的接口IConvertTarget来界说:

1. public interface IConvertTarget
2. {
3. }
5. public static class DataTransformer
6. {
7.     public static T GetData<T>(object source) where T : IConvertTarget, new()
8.     {
9.     }
10. }

复制代码

传入source时我们需要一个转换器生存source->T的处理,这里界说一个委托类型DataTransformer来生存,差别的类型到类型的转换需要差别的转换器,为了可读性我们界说一个以[Type,Type]为索引的ConvertorDataBase结构:

1.     public static class DataTransformer
2.     {
3.         private delegate IConvertTarget DataConvertor(object source);
4.         
5.         private class ConvertorDataBase
6.         {
7.             private readonly Dictionary<Type, Dictionary<Type, DataConvertor>> m_dictionary = new();
9.             public DataConvertor? this[Type targetType, Type sourceType]
10.             {
11.                 get => m_dictionary.GetValueOrDefault(targetType)?.GetValueOrDefault(sourceType);
12.                 set
13.                 {
14.                     if (value == null) return;
15.                     m_dictionary.TryAdd(targetType, new Dictionary<Type, DataConvertor>());
16.                     m_dictionary[targetType].Add(sourceType, value);
17.                 }
18.             }
20.             public void ClearData()
21.             {
22.                 m_dictionary.Clear();
23.             }
24.         }
25.     }

复制代码

GetData接口实现

GetData方法如下实现,_dataBase假如能找到convertor则直接调用,否则创建新的convertor,CreateConverter会在下文中实现.为CreateConverter和InvokeConverter添加Try Catch,便于发现接口中的异常.

1. public static class DataTransformer
2. {
3.     private static ConvertorDataBase _dataBase = new();
4.     private static MethodInfo _getDataMethodInfo;
6.     static DataTransformer()
7.     {
8.         // GetData的Info,递归调用需要
9.         _getDataMethodInfo = typeof(DataTransformer).GetMethod(nameof(GetData)) ?? throw new InvalidOperationException();
10.     }
11.    
12.     public static T GetData<T>(object source) where T : IConvertTarget, new()
13.     {
14.         var targetType = typeof(T);
15.         var sourceType = source.GetType();
16.         var convertor = _dataBase[targetType, sourceType];
17.         if (convertor == null)
18.         {
19.             try
20.             {
21.                 convertor = CreateConverter(targetType, sourceType);
22.                 _dataBase[targetType, sourceType] = convertor;
23.             }
24.             catch (Exception e)
25.             {
26.                 Console.Write("Something wrong when creating converter.\n" +
27.                               $"targetType:{targetType}.\n" +
28.                               $"sourceType:{sourceType}\n" +
29.                               $"{e.Message}");
30.                 throw;
31.             }
32.         }
34.         try
35.         {
36.             return (T)convertor(source);
37.         }
38.         catch (Exception e)
39.         {
40.             Console.Write("Something wrong when invoking  converter.\n" +
41.                           $"targetType:{targetType}.\n" +
42.                           $"sourceType:{sourceType}\n" +
43.                           $"{e.Message}");
44.             throw;
45.         }
46.     }
48.     public static void Reset() => _dataBase.ClearData();
49. }

复制代码

CreateConverter方法实现

CreateConverter与详细实例无关,只需要关注输入输出的类型,这里就需要使用Expression来创建表达式.
我们的基本思路时先new一个目的实例,在使用成员初始化器设置字段和属性.

1. public static class DataTransformer
2. {
3.     private static DataConvertor CreateConverter(Type targetType, Type sourceType)
4.     {
5.         // 参数obj的表达式
6.         var parameterExpression = Expression.Parameter(typeof(object), "obj");
8.         // 创建新的目标实例的表达式
9.         var targetInstanceExpression = Expression.New(targetType);
10.         // 用来保存确切类型的源数据的局部变量表达式
11.         var sourceInstanceExpression = Expression.Variable(sourceType, "source");
13.         // 获取target中所有公共的字段和属性
14.         var targetMembers = targetType.GetMembers(BindingFlags.Public | BindingFlags.Instance)
15.             .Where(info => info.MemberType is MemberTypes.Property or MemberTypes.Field).ToArray();
16.         // 获取source中所有公共的字段和属性
17.         var sourceMembers = sourceType.GetMembers(BindingFlags.Public | BindingFlags.Instance)
18.             .Where(info => info.MemberType is MemberTypes.Property or MemberTypes.Field).ToArray();
20.         //获取成员绑定表达式,具体实现在下文中
21.         var memberBindings = GetMemberBindings(targetMembers, sourceMembers, sourceInstanceExpression);
23.         //封装代码块
24.         var finalBlock = Expression.Block(
25.             new[]
26.             {
27.                 //声明的局部变量source
28.                 sourceInstanceExpression
29.             },
30.             //将obj强转后赋值给source
31.             Expression.Assign(sourceInstanceExpression, Expression.Convert(parameterExpression, sourceType)),
32.             //new Target 的 成员绑定
33.             Expression.MemberInit(targetInstanceExpression, memberBindings)
34.         );
35.         // 将表达式块编译为委托,返回一个 DataConvertor 类型的转换器.
36.         var lambda = Expression.Lambda<DataConvertor>(finalBlock, parameterExpression);
37.         return lambda.Compile();
38.     }
39. }

复制代码

获取MemberBindings

简单的遍历,不表明.

1. public static class DataTransformer
2. {
3.     private static IEnumerable<MemberBinding> GetMemberBindings(MemberInfo[] targetMembers, MemberInfo[] sourceMembers, ParameterExpression sourceInstanceExpression)
4.     {
5.         var memberBindings = new List<MemberBinding>();
7.         foreach (var targetMember in targetMembers)
8.         {
9.             var sourceMember = sourceMembers.FirstOrDefault(info => info.Name == targetMember.Name);
10.             if (sourceMember == null) continue;
11.             var sourceExpression = GetSourceExpression(targetMember, sourceMember, sourceInstanceExpression);
12.             if (sourceExpression != null)
13.                 memberBindings.Add(Expression.Bind(targetMember, sourceExpression));
14.         }
16.         return memberBindings;
17.     }
18. }

复制代码

获取SourceExpression

1. public static class DataTransformer
2. {
3.     private static Expression? GetSourceExpression(MemberInfo targetMember, MemberInfo sourceMember, ParameterExpression sourceInstanceExpression)
4.     {
5.         // 目标成员类型
6.         var targetMemberType = GetMemberType(targetMember);
7.         // 源成员类型
8.         var sourceMemberType = GetMemberType(sourceMember);
9.         // 获取源数据的成员表达式
10.         var sourceMemberExpression = Expression.PropertyOrField(sourceInstanceExpression, sourceMember.Name);
11.         // 如果类型可直接赋值(继承目标类型)直接返回成员表达式(直接赋值)
12.         if (targetMemberType.IsAssignableFrom(sourceMemberType))
13.         {
14.             return sourceMemberExpression;
15.         }
17.         // 如果目标类型也是IConvertTarget,则递归调用GetData
18.         if (typeof(IConvertTarget).IsAssignableFrom(targetMemberType))
19.         {
20.             return Expression.Call(_getDataMethodInfo.MakeGenericMethod(targetMemberType), sourceMemberExpression);
21.         }
23.         return null;
24.     }
26.     // 获取成员的类型
27.     private static Type GetMemberType(MemberInfo memberInfo)
28.     {
29.         if (memberInfo is FieldInfo fieldInfo)
30.         {
31.             return fieldInfo.FieldType;
32.         }
34.         if (memberInfo is PropertyInfo propertyInfo)
35.         {
36.             return propertyInfo.PropertyType;
37.         }
39.         throw new ArgumentException("MemberInfo must be of type FieldInfo, PropertyInfo or PropertyInfo.");
40.     }
41. }

复制代码

完备代码

数据转换中经常会有List数据需要转换,完备代码中给出了实现,请自行查看,假如有字典类型等数据结构需要转换可以添加雷同的处理.(末端有彩蛋)

1. using System;
2. using System.Collections;
3. using System.Collections.Generic;
4. using System.Linq;
5. using System.Linq.Expressions;
6. using System.Reflection;
8. public interface IConvertTarget
9. {
10. }
12. public static class DataTransformer
13. {
14.     private delegate IConvertTarget DataConvertor(object source);
16.     private class ConvertorDataBase
17.     {
18.         private readonly Dictionary<Type, Dictionary<Type, DataConvertor>> m_dictionary = new();
20.         public DataConvertor? this[Type targetType, Type sourceType]
21.         {
22.             get => m_dictionary.GetValueOrDefault(targetType)?.GetValueOrDefault(sourceType);
23.             set
24.             {
25.                 if (value == null) return;
26.                 m_dictionary.TryAdd(targetType, new Dictionary<Type, DataConvertor>());
27.                 m_dictionary[targetType].Add(sourceType, value);
28.             }
29.         }
31.         public void ClearData()
32.         {
33.             m_dictionary.Clear();
34.         }
35.     }
37.     private static ConvertorDataBase _dataBase = new();
38.     private static MethodInfo _getDataMethodInfo;
39.     private static MethodInfo _getListDataMethodInfo;
41.     static DataTransformer()
42.     {
43.         _getDataMethodInfo = typeof(DataTransformer).GetMethod(nameof(GetData)) ?? throw new InvalidOperationException();
44.         _getListDataMethodInfo = typeof(DataTransformer).GetMethod(nameof(GetDataList)) ?? throw new InvalidOperationException();
45.     }
47.     public static T GetData<T>(object source) where T : IConvertTarget, new()
48.     {
49.         var targetType = typeof(T);
50.         var sourceType = source.GetType();
51.         var convertor = _dataBase[targetType, sourceType];
52.         if (convertor == null)
53.         {
54.             try
55.             {
56.                 convertor = CreateConverter(targetType, sourceType);
57.                 _dataBase[targetType, sourceType] = convertor;
58.             }
59.             catch (Exception e)
60.             {
61.                 Console.Write("Something wrong when creating converter.\n" +
62.                               $"targetType:{targetType}.\n" +
63.                               $"sourceType:{sourceType}\n" +
64.                               $"{e.Message}");
65.                 throw;
66.             }
67.         }
69.         try
70.         {
71.             return (T)convertor(source);
72.         }
73.         catch (Exception e)
74.         {
75.             Console.Write("Something wrong when invoking  converter.\n" +
76.                           $"targetType:{targetType}.\n" +
77.                           $"sourceType:{sourceType}\n" +
78.                           $"{e.Message}");
79.             throw;
80.         }
81.     }
84.     public static TList? GetDataList<TList, T>(IEnumerable? source) where T : IConvertTarget, new() where TList : IList<T>, new()
85.     {
86.         if (source == null)
87.             return default;
88.         var targetList = new TList();
89.         foreach (var obj in source)
90.         {
91.             targetList.Add(GetData<T>(obj));
92.         }
94.         return targetList;
95.     }
97.     public static void Reset() => _dataBase.ClearData();
99.     private static DataConvertor CreateConverter(Type targetType, Type sourceType)
100.     {
101.         var parameterExpression = Expression.Parameter(typeof(object), "obj");
103.         var targetInstanceExpression = Expression.New(targetType);
104.         var sourceInstanceExpression = Expression.Variable(sourceType, "source");
106.         var targetMembers = targetType.GetMembers(BindingFlags.Public | BindingFlags.Instance).Where(info => info.MemberType is MemberTypes.Property or MemberTypes.Field).ToArray();
107.         var sourceMembers = sourceType.GetMembers(BindingFlags.Public | BindingFlags.Instance).Where(info => info.MemberType is MemberTypes.Property or MemberTypes.Field).ToArray();
109.         var memberBindings = GetMemberBindings(targetMembers, sourceMembers, sourceInstanceExpression);
111.         var finalBlock = Expression.Block(
112.             new[]
113.             {
114.                 sourceInstanceExpression
115.             },
116.             Expression.Assign(sourceInstanceExpression, Expression.Convert(parameterExpression, sourceType)),
117.             Expression.MemberInit(targetInstanceExpression, memberBindings)
118.         );
119.         var lambda = Expression.Lambda<DataConvertor>(finalBlock, parameterExpression);
120.         return lambda.Compile();
121.     }
123.     private static IEnumerable<MemberBinding> GetMemberBindings(MemberInfo[] targetMembers, MemberInfo[] sourceMembers, ParameterExpression sourceInstanceExpression)
124.     {
125.         var memberBindings = new List<MemberBinding>();
127.         foreach (var targetMember in targetMembers)
128.         {
129.             var sourceMember = sourceMembers.FirstOrDefault(info => info.Name == targetMember.Name);
130.             if (sourceMember == null) continue;
131.             var sourceExpression = GetSourceExpression(targetMember, sourceMember, sourceInstanceExpression);
132.             if (sourceExpression != null)
133.                 memberBindings.Add(Expression.Bind(targetMember, sourceExpression));
134.         }
136.         return memberBindings;
137.     }
139.     private static Expression? GetSourceExpression(MemberInfo targetMember, MemberInfo sourceMember, ParameterExpression sourceInstanceExpression)
140.     {
141.         var targetMemberType = GetMemberType(targetMember);
142.         var sourceMemberType = GetMemberType(sourceMember);
143.         var sourceMemberExpression = Expression.PropertyOrField(sourceInstanceExpression, sourceMember.Name);
144.         if (targetMemberType.IsAssignableFrom(sourceMemberType))
145.         {
146.             return sourceMemberExpression;
147.         }
149.         if (typeof(IConvertTarget).IsAssignableFrom(targetMemberType))
150.         {
151.             return Expression.Call(_getDataMethodInfo.MakeGenericMethod(targetMemberType), sourceMemberExpression);
152.         }
154.         var itemType = targetMemberType.GetGenericArguments().FirstOrDefault();
155.         if (itemType != null && typeof(IList<>).MakeGenericType(itemType).IsAssignableFrom(targetMemberType) && typeof(IConvertTarget).IsAssignableFrom(itemType) && typeof(IEnumerable).IsAssignableFrom(sourceMemberType))
156.         {
157.             return Expression.Call(_getListDataMethodInfo.MakeGenericMethod(targetMemberType, itemType), sourceMemberExpression);
158.         }
160.         return null;
161.     }
163.     private static Type GetMemberType(MemberInfo memberInfo)
164.     {
165.         if (memberInfo is FieldInfo fieldInfo)
166.         {
167.             return fieldInfo.FieldType;
168.         }
170.         if (memberInfo is PropertyInfo propertyInfo)
171.         {
172.             return propertyInfo.PropertyType;
173.         }
175.         throw new ArgumentException("MemberInfo must be of type FieldInfo, PropertyInfo or PropertyInfo.");
176.     }
177. }

复制代码

???

有人说直接调方法也太没有手法了,实在获取List数据转换的还有更复杂的做法,做法如下:

1.                 private Expression GetListMemberAssignment(FieldInfo targetField, PropertyInfo sourceField, MemberExpression sourceList)
2.                 {
3.                         var targetElementType = targetField.FieldType.GetGenericArguments()[0];
4.                         var sourceElementType = sourceField.PropertyType.GetGenericArguments()[0];
5.                         var genericGetItemMethod = GetIndexerMethod(sourceElementType);//此处为获取Generic方法,太麻烦懒得写了
6.                         var genericAddItemMethod = GetAddMethod(targetElementType);
8.                         var targetList = Expression.Variable(targetField.FieldType, "targetList");
9.                         var targetListInit = Expression.Assign(targetList, Expression.New(targetField.FieldType));
12.                         //sourceList.Count
13.                         var countExpression = Expression.Property(sourceList, m_countMethod);
14.                         //var i = 0
15.                         var loopVariable = Expression.Variable(typeof(int), "i");
16.                         var loopVariableInit = Expression.Assign(loopVariable, Expression.Constant(0));
18.                         //sourceList[i]
19.                         var getItemMethod = Expression.Call(sourceList, genericGetItemMethod, loopVariable);
20.                         //GetData<TargetType>(sourceList[i]);
21.                         var getDataExpression = Expression.Call(m_thisInstance, m_getDataMethod.MakeGenericMethod(targetElementType), getItemMethod);
22.                         //targetList.Add(GetData<TargetType>(sourceList[i]))
23.                         var addItemMethod = Expression.Call(targetList, genericAddItemMethod, getDataExpression);
25.                         var targetLabel = Expression.Label();
26.                         var loopBody = Expression.Block(
27.                                 Expression.IfThen(
28.                                         Expression.Equal(loopVariable, countExpression),
29.                                         Expression.Break(targetLabel)
30.                                 ),
31.                                 addItemMethod,
32.                                 Expression.PostIncrementAssign(loopVariable) //i++
33.                         );
34.                         var loop = Expression.Loop(loopBody, targetLabel);
35.                         var block = Expression.Block(new[] { loopVariable }, loopVariableInit, targetListInit, loop);
37.                         var blockNull = Expression.Block(Expression.Assign(targetList, Expression.Constant(null, targetField.FieldType)));
38.                         // 检查 sourceList 是否为空
39.                         var ifThenElse = Expression.IfThenElse(
40.                                 Expression.Equal(sourceList, Expression.Constant(null)),
41.                                 blockNull,
42.                                 block
43.                         );
45.                         var ret = Expression.Block(new[] { targetList }, ifThenElse, targetList);
46.                         return ret;
47.                 }

复制代码

你就说有没有手法把.这种做法虽然工作量大,但实在效果也不如上一种写法,直接调用方法有泛型约束,并且编译的也更快.不过可以手写一下训练Expression的循环和条件的用法.

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。