达梦DM.Microsoft.EntityFreameworkCore查询报错invalid cast from DateTim ...

1. 问题

达梦dotnet efcore的驱动DM.Microsoft.EntityFreameworkCore。
如果实体中存在DateTimeOffset范例字段时，查询报错：invalid cast from DateTime to DateTimeOffset。

1. Invalid cast from 'System.DateTime' to 'System.DateTimeOffset'
2.     System.Convert.DefaultToType(System.IConvertible, System.Type, System.IFormatProvider)
3.     Dm.DmDataReader.GetFieldValue<T>(int)

复制代码

同样对于TimeSpan范例的字段，会报错：invalid cast from Double to TimeSpan。
2. 原因

通过反编译DM.Provider驱动的代码，看到Dm.DmDataReader.GetFieldValue方法中非常简单，是直接显示转换成T范例的，没有很好的转换DateTimeOffset和TimeSpan范例的数据，导致报错。
3. 分析

DM.Provider驱动的代码是DM驱动代码，没法重写DmDataReader，那么就只能在DM.EFCore上想办法了，EFCore的实现都是DI依赖注入的方式实现的，所以许多类接口都可以重写，然后重新注入。
EFCore中数据范例映射重要靠RelationalTypeMapping抽象类及其派生类处理的，RelationalTypeMapping抽象类的有关这块获取DataReader数据的代码简化如下：

1. public abstract class RelationalTypeMapping : CoreTypeMapping
2. {
3.     private static readonly MethodInfo GetFieldValueMethod
4.         = GetDataReaderMethod(nameof(DbDataReader.GetFieldValue));
5.     private static readonly ConcurrentDictionary<Type, MethodInfo> GetXMethods = new()
6.     {
7.         [typeof(bool)] = GetDataReaderMethod(nameof(DbDataReader.GetBoolean)),
8.         [typeof(byte)] = GetDataReaderMethod(nameof(DbDataReader.GetByte)),
9.         [typeof(char)] = GetDataReaderMethod(nameof(DbDataReader.GetChar)),
10.         [typeof(DateTime)] = GetDataReaderMethod(nameof(DbDataReader.GetDateTime)),
11.         [typeof(decimal)] = GetDataReaderMethod(nameof(DbDataReader.GetDecimal)),
12.         [typeof(double)] = GetDataReaderMethod(nameof(DbDataReader.GetDouble)),
13.         [typeof(float)] = GetDataReaderMethod(nameof(DbDataReader.GetFloat)),
14.         [typeof(Guid)] = GetDataReaderMethod(nameof(DbDataReader.GetGuid)),
15.         [typeof(short)] = GetDataReaderMethod(nameof(DbDataReader.GetInt16)),
16.         [typeof(int)] = GetDataReaderMethod(nameof(DbDataReader.GetInt32)),
17.         [typeof(long)] = GetDataReaderMethod(nameof(DbDataReader.GetInt64)),
18.         [typeof(string)] = GetDataReaderMethod(nameof(DbDataReader.GetString))
19.     };
20.     private static MethodInfo GetDataReaderMethod(string name)
21.         => typeof(DbDataReader).GetRuntimeMethod(name, [typeof(int)])!;
22.     protected abstract RelationalTypeMapping Clone(RelationalTypeMappingParameters parameters);
23.     public virtual MethodInfo GetDataReaderMethod()
24.     {
25.         var type = (Converter?.ProviderClrType ?? ClrType).UnwrapNullableType();
27.         return GetDataReaderMethod(type);
28.     }
29.     public static MethodInfo GetDataReaderMethod(Type type)
30.         => GetXMethods.GetOrAdd(type, static t => GetFieldValueMethod.MakeGenericMethod(t));
31. }

复制代码

其中虚方法GetDataReaderMethod()返回MethodInfo，它是DataReader的方法（不同的数据库Provider都有一个自己的DataReader实现，本例中达梦的实现就是前面报错堆栈中的Dm.DmDataReader），告诉ef获取数据后任何从DataReader中获取字段值。
这个虚方法GetDataReaderMethod()返回的MethodInfo是从一个私有静态的GetXMethods字典范例中得到的，但这个GetXMethods没有定义DateTimeOffset和TimeSpan，这个时候EF就会调用DataReader.GetFieldValue(int)泛型方法，这个各自数据库实现的泛型方法如果无法处理好各种泛型的话就会报错了。
4. 办理

根据上面的分析，办理似乎也不贫苦了，我们只要重写这个虚方法GetDataReaderMethod()，让它返回精确的MethodInfo以便精确得到值就可以了。
4.1 MyDmDateTimeOffsetTypeMapping

恰好DmDataReader中有GetDateTimeOffset(int index)方法，可以改成返回这个方法就能办理问题了，下面就是重写的DmDateTimeOffsetTypeMapping类。

1. public class MyDmDateTimeOffsetTypeMapping:DmDateTimeOffsetTypeMapping
2. {
3.     public MyDmDateTimeOffsetTypeMapping([JetBrains.Annotations.NotNull] string storeType, DbType? dbType = System.Data.DbType.DateTimeOffset)
4.         : base(storeType, dbType)
5.     {
6.     }
8.     protected MyDmDateTimeOffsetTypeMapping(RelationalTypeMappingParameters parameters)
9.         : base(parameters)
10.         {
11.     }
12.     protected override RelationalTypeMapping Clone(RelationalTypeMappingParameters parameters)
13.     {
14.         return new MyDmDateTimeOffsetTypeMapping(parameters);
15.     }
16.     public override MethodInfo GetDataReaderMethod()
17.     {
18.         return typeof(DmDataReader).GetRuntimeMethod(nameof(DmDataReader.GetDateTimeOffset), new[] { typeof(int) });
19.     }
20. }

复制代码

4.2 MyDmTimeSpanTypeMapping

对于TimeSpan范例要复杂点，因为DmDataReader中没有GetTimeSpan(int index)方法，那么就只能先返回Double的方法GetDouble(int index)，之后重写CustomizeDataReaderExpression方法改变下表单试，就是给表达式加点转换代码，代码如下。

1. public class MyDmTimeSpanTypeMapping : DmTimeSpanTypeMapping
2. {
3.     public MyDmTimeSpanTypeMapping([JetBrains.Annotations.NotNull] string storeType, DbType? dbType = null)
4.         : base(storeType, dbType)
5.     {
6.     }
8.     protected MyDmTimeSpanTypeMapping(RelationalTypeMappingParameters parameters)
9.         : base(parameters)
10.     {
11.     }
13.     protected override RelationalTypeMapping Clone(RelationalTypeMappingParameters parameters)
14.     {
15.         return new MyDmTimeSpanTypeMapping(parameters);
16.     }
17.     public override MethodInfo GetDataReaderMethod()
18.     {
19.         return typeof(DmDataReader).GetRuntimeMethod(nameof(DmDataReader.GetDouble), new[] { typeof(int) });
20.     }
21.     public override Expression CustomizeDataReaderExpression(Expression expression)
22.     {
23.         return Expression.Call(GetTimeSpanMethod, expression);
24.     }
25.     private static readonly MethodInfo GetTimeSpanMethod
26.         = typeof(MyDmTimeSpanTypeMapping).GetMethod(nameof(GetTimeSpan), new[] { typeof(double) })!;
27.     public static TimeSpan GetTimeSpan(double value)
28.     {
29.         return TimeSpan.FromDays(value);
30.     }
31. }

复制代码

这两个TypeMapping类一定要注意，必要实现克隆方法protected override RelationalTypeMapping Clone(RelationalTypeMappingParameters parameters)，并且返回我们新定义的类，否则后面的GetDataReaderMethod无法运行进来的。
4.3 MyDmTypeMappingSource

现在问题来了，那就是如果把MyDmDateTimeOffsetTypeMapping类加到EFCore中，可以重写RelationalTypeMappingSource的达梦实现类DmTypeMappingSource。

1. public class MyDmTypeMappingSource : DmTypeMappingSource
2. {
3.     private MyDmDateTimeOffsetTypeMapping _datetimeoffset = new MyDmDateTimeOffsetTypeMapping("DATETIME WITH TIME ZONE", DbType.DateTimeOffset);
4.     private MyDmDateTimeOffsetTypeMapping _datetimeoffset3 = new MyDmDateTimeOffsetTypeMapping("DATETIME(3) WITH TIME ZONE", DbType.DateTimeOffset);
5.     private MyDmTimeSpanTypeMapping _intervaldt = new MyDmTimeSpanTypeMapping("INTERVAL DAY TO SECOND");
6.     private Dictionary<string, RelationalTypeMapping> _storeTypeMappings;
7.     private Dictionary<Type, RelationalTypeMapping> _clrTypeMappings;
9.     public MyDmTypeMappingSource([JetBrains.Annotations.NotNull] TypeMappingSourceDependencies dependencies, [JetBrains.Annotations.NotNull] RelationalTypeMappingSourceDependencies relationalDependencies)
10.             : base(dependencies, relationalDependencies)
11.     {
12.         _storeTypeMappings = new Dictionary<string, RelationalTypeMapping>(StringComparer.OrdinalIgnoreCase)
13.         {
14.             { "datetime with time zone", _datetimeoffset },
15.             { "timestamp with time zone", _datetimeoffset },
16.             { "datetime(3) with time zone", _datetimeoffset3 },
17.             { "timestamp(3) with time zone", _datetimeoffset3 },
18.             { "interval day to second", _intervaldt },
19.         };
20.         _clrTypeMappings = new Dictionary<Type, RelationalTypeMapping>
21.         {
22.             { typeof(DateTimeOffset), _datetimeoffset },
23.             { typeof(TimeSpan), _intervaldt }
24.         };
25.     }
26.     protected override RelationalTypeMapping FindMapping(in RelationalTypeMappingInfo mappingInfo)
27.     {
28.         Type clrType = mappingInfo.ClrType;
29.         string storeTypeName = mappingInfo.StoreTypeName;
30.         string storeTypeNameBase = mappingInfo.StoreTypeNameBase;
31.         if (storeTypeName != null && _storeTypeMappings.ContainsKey(storeTypeName))
32.             return _storeTypeMappings.GetValueOrDefault(storeTypeName)?.Clone(mappingInfo);
33.         if (clrType != null && _clrTypeMappings.ContainsKey(clrType))
34.             return _clrTypeMappings.GetValueOrDefault(clrType)?.Clone(mappingInfo);
36.         return FindMapping(mappingInfo);
37.     }
38. }

复制代码

4.4 AddEntityFrameworkDm

现在的问题是怎么把新实现的MyDmTypeMappingSource加入到efcore中的问题，只要更换注入IRelationalTypeMappingSource接口实现就可以了。

1. protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
2. {
3.     base.OnConfiguring(optionsBuilder);
4.     optionsBuilder.ReplaceService<IRelationalTypeMappingSource, MyDmTypeMappingSource>();
5. }

复制代码

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