同时运行存储过程多次

Question

如何使用不同的参数值集多次运行相同的存储过程，而无需等待第一次执行完成。

例子：

如果我从@sourceId，@containerId 获得了proc sp_loaddata

Execution - 1st:  exec sp_loaddatafrom 100001, 36
Execution - 2nd:  exec sp_loaddatafrom 100008, 92
Execution - 3rd:  exec sp_loaddatafrom 100005, 112

我希望所有人同时运行。

如何在 T-SQL / SSIS / C# 中实现这一点

Answer 1

如果您可以访问 .net 4.5，我会使用以下代码。

var results = Task.WhenAll(
    Task.Run(() => RunStoredProc(1)),
    Task.Run(() => RunStoredProc(2)),
    Task.Run(() => RunStoredProc(3))
).Result;

如果我只有 .net 4.0，我会使用 TPL。稍微麻烦一点，还是比后台worker好很多。

var arguments = new []{1,2,3};

var results = from x in arguments.AsParallel()
              select RunStoredProc(x);

Answer 2

如果您将使用 C#，您可以使用 3 个 BackgroundWorkers 在其 Do_Work 事件中调用所述存储过程

Answer 3

这可以在 SSIS 中通过使用 3 个不同的 Execute SQL Task 来完成，它们彼此没有连接。

默认情况下，SSIS 对Isolation Level 使用Serializable 选项，该选项锁定正在读取的整个数据并保持锁定直到事务完成。因此，为了并行运行查询，您需要将Isolation level 更改为Snapshot，它在读取数据时基本上使用NOLOCK。

更新：-

由于获取到的stored procedures被执行的数量是dynamically，那么你需要创建包programitically

public void CreatePackage()
{
  Package package= new Package();
  ConnectionManager sqlConnection = GetSQLConnection(package,
                                    "localhost", "Database Name");
  TaskHost taskHost=null;
   for(int i=0;i<GetNoOfRowFromSQL();i++)
    {
      CreateDynamicTask(package);
    }
  package.Execute();
}

public void CreateDynamicTask(package Package)
{

      //Add the Execute SQL Task
      package.Executables.Add("STOCK:SQLTask");
       taskHost = package.Executables[0] as TaskHost;
      taskHost.Properties["SqlStatementSource"].SetValue(taskHost, 
                                            "EXECUTE Stored Proc);
     //Setting the Isolation Level
     taskHost.Properties["IsolationLevel"].SetValue(taskHost, 1048576);
     //the number signify 1048576 =Serializable
    }
}