Выполнение хранимой процедуры mutliple раз одновременно

Question

Как я могу запускать один и тот же хранимый procdure несколько раз с различным набором значений параметров и не ожидая завершения первого выполнения.

Пример:

, если я получил прок sp_loaddatafrom @sourceId, @containerId

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

Если у вас есть доступ to .net 4.5 Я бы использовал следующий код.

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

Если у меня только .net 4.0, я бы использовал TPL. Немного более громоздко, все же намного лучше, чем работник фона.

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 использует Serializable вариант для Isolation Level, которая блокирует все данные считываются и сохраняет блокировку до завершения транзакции. Поэтому для параллельного выполнения запросов вам необходимо изменить 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 
    } 
}