通过实体框架将表值类型传递给 SQL Server 存储过程

Question

我在 SQL Server 中创建了一个用户定义的表类型：

CREATE TYPE dbo.TestType AS TABLE 
(
    ColumnA int,
    ColumnB nvarchar(500)
)

我正在使用存储过程将记录插入数据库：

create procedure [dbo].[sp_Test_CustomType]
   @testing TestType READONLY
as
    insert into [dbo].[myTable]
        select ColumnA, ColumnB 
        from @testing

我想使用 EF 来执行这个存储过程，但问题是：如何将用户定义的表传递给存储过程？

我尝试将存储过程添加到模型中，但无法在更新的上下文中找到所需的存储过程。

我要做的是对表执行批量插入，这是我目前使用的方法：

List<items> itemToInsertToDB = //fetchItems;

foreach(items i in itemToInsertToDB)
{
     context.sp_InsertToTable(i.ColumnA, i.ColumnB)
}

目前，我使用foreach循环遍历列表以将项目插入数据库，但如果列表有很多项目，那么就会出现性能问题，所以，我正在考虑传递一个列出存储过程并在里面插入。

那么如何解决这个问题呢？还是有更好的方法来做到这一点？

Answer 1

我建议你不要使用存储过程来插入批量数据，而只是依靠实体框架插入机制。

List<items> itemToInsertToDB = //fetchItems;
foreach(items i in itemToInsertToDB)
{
    TestType t = new TestType() { ColumnA = i.ColumnA, ColumnB = i.ColumnB };
    context.TestTypes.Add(t);
}
context.SaveChanges();

实体框架将智能地在单个事务中和（通常）在单个查询执行中执行这些插入，这几乎等于执行存储过程。这比仅仅依靠存储过程插入大量数据要好。

Answer 2

假设您要发送一个包含单列 GUID 的表。

首先，我们需要使用SqlMetaData 创建一个结构，它表示表（列）的架构。

下面的代码演示了GUID中名为“Id”的一列是SQL存储过程参数表类型

var tableSchema = new List<SqlMetaData>(1)
{
  new SqlMetaData("Id", SqlDbType.UniqueIdentifier)
}.ToArray();

接下来，您使用SqlDataRecord 创建与架构匹配的记录列表。

下面的代码演示了如何使用上面创建的架构在列表中添加项目。为列表中的每个项目创建一个新的 SqlDataRecord。将 SetGuid 替换为对应的类型，将 Guid.NewGuid() 替换为对应的值。 为每个项目重复新的 SqlDataRecord 并将它们添加到列表中

var tableRow = new SqlDataRecord(tableSchema);
tableRow.SetGuid(0, Guid.NewGuid());
var table = new List<SqlDataRecord>(1)
{
  tableRow
};

然后创建SqlParameter:

var parameter = new SqlParameter();
parameter.SqlDbType = SqlDbType.Structured;
parameter.ParameterName = "@UserIds"; //@UserIds is the stored procedure parameter name
parameter.TypeName = "{Your stored procedure type name}"
parameter.Value = table;

var parameters = new SqlParameter[1]
{
  parameter
};

然后只需使用Database.SqlQuery 调用存储过程。

IEnumerable<ReturnType> result;
using (var myContext = new DbContext())
{
  result = myContext.Database.SqlQuery<User>("GetUsers @UserIds", parameters)
    .ToList();         // calls the stored procedure
    // ToListAsync();  // Async
{

在 SQL Server 中，创建您的用户定义的表类型（我在它们后面加上 TTV，表类型值）：

CREATE TYPE [dbo].[UniqueidentifiersTTV] AS TABLE(
  [Id] [uniqueidentifier] NOT NULL
)
GO

然后将类型指定为参数（别忘了，Table Type Values 必须是只读的！）：

CREATE PROCEDURE [dbo].[GetUsers] (
  @UserIds [UniqueidentifiersTTV] READONLY
) AS
BEGIN
  SET NOCOUNT ON

  SELECT u.* -- Just an example :P
  FROM [dbo].[Users] u
  INNER JOIN @UserIds ids On u.Id = ids.Id
END