我正在努力为EF Core中的表属性添加模式。运行ado.net时,以下工作正常:
private static void Reademps()
{
string sql = "SELECT [Id],[empno] FROM [encrypt].[dbo].[emps]";
var connection = new SqlConnection(connectionString);
var command = new SqlCommand(sql, connection);
connection.Open();
using (SqlDataReader reader = command.ExecuteReader(System.Data.CommandBehavior.CloseConnection))
{
while (reader.Read())
{
Console.WriteLine($"id: {reader[0]} empno: {reader[1]}");
}
}
}
但是尝试转换为EF Core:
private async Task ReadempsAsync()
{
using (var context = new EmpsContext())
{
List<Emp> emps = await context.Emps.ToListAsync();
foreach (var b in emps)
{
Console.WriteLine($"{b.Id} {b.Empno}");
}
}
}
internal class EmpsContext : DbContext
{
private const string ConnectionString = @"server=localhost\SQLEXPRESS;Database=master;Integrated security=true;Database=master;Column Encryption Setting=enabled";
public DbSet<Emp> Emps { get; set; }
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
base.OnConfiguring(optionsBuilder);
optionsBuilder.UseSqlServer(ConnectionString);
}
}
[Table("emps", Schema = "encrypt")]
public class Emp
{
public int Id { get; set; }
[Required]
[StringLength(50)]
public string Empno { get; set; }
}
我一直收到错误:
System.Data.SqlClient.SqlException:'无效的对象名'encrypt.emps'。'
在你的SQL中 - [encrypt]
似乎是数据库名称 - 而不是模式名称(中间是dbo
)。
SELECT [Id],[empno] FROM [encrypt].[dbo].[emps]
********* ***** ******
* * * Table Name
* * Schema name
* Database name
因此,您的EF Core表声明是错误的,因为它将架构定义为encrypt
- 但事实并非如此。
所以这:
[Table("emps", Schema = "encrypt")]
public class Emp
应该是:
[Table("emps", Schema = "dbo")]
**************
public class Emp
你必须使用"dbo"
for Schema,因为encrypt
不是模式名称。这只是database
的名字。它会是这样的:
[Table("emps", Schema = "dbo")]
public class Emp
{
public int Id { get; set; }
[Required]
[StringLength(50)]
public string Empno { get; set; }
}
注意:
在你的连接字符串中将Database
更改为encrypt
。你的连接字符串将是:
private const string ConnectionString = @"server=localhost\SQLEXPRESS;Database=encrypt;Integrated security=true;Column Encryption Setting=enabled";