EF Core + Oracle 踩坑记

　　EF（Entity Framework）是微软标志性且成熟的ORM，从之前的.NET Framework时代就已经很常见了，但是给人的感觉还是偏“重”，性能被不少人吐槽，倒是像Dapper这类更轻量级的更受大家待见。但是进入.NET Core时代后，EF随之进化为EF Core（Entity Framework Core），除了是为ASP.NET Core量身打造外，在性能和功能上微软也是做了很多优化，已经算是一款十分实用的ORM了。在写本文时，EF Core目前处于3.x的版本阶段，并且支持很多主流数据库MySQL，SqlServer，Oracle，SQLite等等。本文讨论的主要对象就是EF Core和Oracle的搭配，虽然目前是支持Oracle数据库的，但目前Oracle官方提供的Oracle.EntityFrameworkCore库依然是依赖于EF Core的2.1版本，并且在使用中也不像EF Core和亲儿子SqlServer配合的那样丝滑，其中有不少坑。这里做一些简单的记录，也有可能是本人才疏学浅，打开的方式不对，如有错误欢迎指正。

本文Demo源码地址：https://github.com/Xuhy0826/EFCoreTest

配置

若要使用EF Core操作Oracle数据库，首先需要安装Oracle.EntityFrameworkCore。可以直接在NuGet上直接搜索安装即可。

按照惯例创建Context类继承DbContext和其他的数据库没有区别，但是我们在配置连接字符串的时候的同时需要为其指定Oracle数据库的版本，传入“11”代表11g，传入“12”代表12c。

public class MyContext : DbContext
{
    public MyContext(DbContextOptions options) : base(options)
    { }
    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        optionsBuilder.UseOracle(
            "DATA SOURCE=LOCALHOST:1521/ORACLE1;USER ID= 你的ID ;PASSWORD=你的密码;"
            , b => b.UseOracleSQLCompatibility("12"));   //指定数据库版本
    }
}

如果我们在调试期间希望EF Core输出执行的Sql，我使用的方式自定义一个日志类，将Sql输出到Console中。

public class EFLoggerProvider : ILoggerProvider
{
    public ILogger CreateLogger(string categoryName) => new EFLogger(categoryName);
    public void Dispose() { }
}
public class EFLogger : ILogger
{
    private readonly string categoryName;
    public EFLogger(string categoryName) => this.categoryName = categoryName;
    public IDisposable BeginScope<TState>(TState state) => null;
    public bool IsEnabled(LogLevel logLevel) => true;
    public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception exception, Func<TState, Exception, string> formatter)
    {
        //ef core执行数据库查询时的categoryName为Microsoft.EntityFrameworkCore.Database.Command,日志级别为Information
        if (categoryName == "Microsoft.EntityFrameworkCore.Database.Command")
        {
            var logContent = formatter(state, exception);
            Console.WriteLine();
            Console.ForegroundColor = ConsoleColor.Green;
            Console.WriteLine(logContent);
            Console.ResetColor();
        }
    }
}

并在配置时将其注册进去。

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
    //配置数据库连接
    optionsBuilder.UseOracle(
        "DATA SOURCE=LOCALHOST:1521/ORACLE1;USER ID= 你的ID ;PASSWORD=你的密码;"
        , b => b.UseOracleSQLCompatibility("12"));
    //配置Sql输出控制台
    var loggerFactory = new LoggerFactory();
    loggerFactory.AddProvider(new EFLoggerProvider());
    optionsBuilder.UseLoggerFactory(loggerFactory);

    base.OnConfiguring(optionsBuilder);
}

如果使用依赖注入的写法，如下。

services.AddDomainContext(builder =>
{
  //配置数据库连接
  builder.UseOracle(
  "DATA SOURCE=LOCALHOST:1521/ORACLE1;USER ID= 你的ID ;PASSWORD=你的密码;"
  , b => b.UseOracleSQLCompatibility(version));
    //配置Sql输出控制台
      var loggerFactory = new LoggerFactory();
      loggerFactory.AddProvider(new EFLoggerProvider());
  builder.UseLoggerFactory(loggerFactory);
});

查询数据

　　在执行查询时，需要注意的有两点，一是Table映射的实体类的属性名称如果不显式指定的话需要使用全大写的形式，不然会报错“ORA-00904:标识符无效”。因为生成的Sql中是将所有的字段名都用双引号修饰的，而Oracle中存储字段名默认都是采用全大写的形式的。

所以如果我们不想将实体类所有的属性名称写成大写，就需要显式的指定映射的column的名称。可以使用DataAnnotations的特性标注所有属性，或者在Context中指定列映射。另外如果执行查询时需要指定Schema，也像下面这样配置。

方法1：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    //判断当前数据库是Oracle
    if (this.Database.IsOracle())
    {   //如果需要，手动添加Schema名称，如果是默认或者表前不需要Schema名就可以不用配置
        modelBuilder.HasDefaultSchema("XUHY");
    }
    modelBuilder.Entity<Employee>(entity =>
    {
        entity.ToTable("EMPLOYEE");
        entity.Property(e => e.Id).IsRequired();
        entity.Property(e => e.Id).ForOracleUseSequenceHiLo("SEQ_EMPLOYEE_ID");
        //列映射
        entity.Property(e => e.Id).HasColumnName("ID");
        entity.Property(e => e.BirthDay).HasColumnName("BIRTHDAY");
        entity.Property(e => e.Department).HasColumnName("DEPARTMENT");
        entity.Property(e => e.EmployeeNo).HasColumnName("EMPLOYEENO");
        entity.Property(e => e.IsValid).HasColumnName("ISVALID");
        entity.Property(e => e.Name).HasColumnName("NAME");
    });
    base.OnModelCreating(modelBuilder);
}

方法2：

[Table("EMPLOYEE ")]  //指定数据库对应表名
public class Employee
{
    [Key]  //主键
    [Column("ID")] //指定数据库对应表栏位名称
    public long Id { get; set; }
    [Column("EMPLOYEENO")]
    public int EmployeeNo { get; set; }
    [Column("NAME")]
    public string Name { get; set; }
    [Column("BIRTHDAY")]
    public DateTime BirthDay { get; set; }
    [Column("DEPARTMENT")]
    public string Department { get; set; }
    [Column("ISVALID")]
    public bool IsValid { get; set; }
}

经过上面的这些配置，便可以正常的执行数据的查询了。

using (var context = new MyContext(options))
{
    var options = new DbContextOptions<MyContext>();
    var res = context.Employee.ToListAsync();
    //var res = context.Employee.OrderBy("EMPLOYEENO").Skip(0).Take(5).ToListAsync();//分页
    if (res.Status == TaskStatus.Faulted)
    {
        Console.WriteLine(res.Exception.Message);
    }
    Console.ReadLine();
}

插入数据

插入数据倒是和其他数据库差别不大，但是由于Oracle天生是没有自增Id的，如果我们设计的表的主键需要采用自增键就需要使用Sequence代替。在这种情况下就需要为实体类的主键指定Sequence的名称了。

entity.Property(e => e.Id).ForOracleUseSequenceHiLo("SEQ_EMPLOYEE_ID");

随后便可以执行插入数据了。

var employee = new Employee()
{
    EmployeeNo = 6,
    Name = "老周",
    Department = "d6",
    BirthDay = DateTime.Now.AddYears(-40),
    IsValid = true
};
using (var context = new MyContext(options))
{
    var res = context.Employee.AddAsync(employee);
    if (res.Status == TaskStatus.Faulted)
    {
        Console.WriteLine(res.Exception.Message);
    }
    context.SaveChanges();
    Console.WriteLine("添加成功");
    Console.ReadLine();
}

以上就是简单总结的使用EF Core操作Oracle数据库时的一些比较特别的地方，当然本人仍在探索实践中，如有新发现会第一时间更新上来。当然更加期望的是Oracle.EntityFrameworkCore库能早日优化造福我等。