SQL Server 2016 SSIS получить курсор из хранимой процедуры

Question

Я использую SQL Server 2016.

1. У меня есть хранимая процедура GET_RECORDS, которая принимает входные параметры для фильтра и выводит параметр CURSOR

2. Я хочу чтобы получить этот курсор в моем пакете SSIS

3. Я создал задачу потока данных, источник OleDb и переменные для значений параметров. Затем отображенные параметры

Params mapping screen

, но когда я хотел, чтобы сохранить компонент - я получил ошибку

error screen

Я пытался добавить пункт WITH RESULT SETS с некоторыми фиктивных столбцов, но мой процедура не возвращает никакого результирующего набора

Что я делаю неправильно?

Любые советы помогут.

спасибо.

С уважением, Юрий.

Answer 1

Исходный компонент пытается определить, какие столбцы и типы будут возвращены. Поскольку вы используете динамический SQL, метаданные могут меняться при каждом запуске.

С наборами результатов можно определить возвращаемые данные, но их следует использовать только в том случае, если у вас есть гарантированные результаты при каждом выполнении.

EDIT: Я создаю соединение и запускаю команду так, чтобы она заполняла таблицу данных. Затем я помещаю заголовки столбцов в строковый массив. Есть много примеров.

Затем я использую следующую функцию для создания таблицы назначения. Наконец, я создаю datareader и передаю это .Net SqlBulkCopy. Надеюсь это поможет.

private void CreateTable(string TableName, string[] Fields) 
     {     

      if (TableExists(TableName) && Overwrite) 
      { 
       SqlCommand = new SqlCommand($"Drop Table [{TableName}]", SqlConnection); 
       SqlCommand.ExecuteNonQuery(); 
      } 

      string Sql = $"Create Table [{TableName}] ("; 

      int ColumnNumber = 1; 
      foreach (string Field in Fields) 
      { 
       string FieldValue = Field; 
       if (! HasHeaders) 
       { 
        FieldValue = "Column" + ColumnNumber; 
        ColumnNumber++; 
       } 
       Sql += $"[{FieldValue}] Varchar(8000),"; 
      } 
      Sql = Sql + "ImportFileID Int, ID Int Identity(1,1) Not Null, Constraint [PK_" + TableName + "] Primary Key Clustered ([ID] Asc))"; 

      SqlCommand = new SqlCommand(Sql, SqlConnection); 
      SqlCommand.ExecuteNonQuery(); 
     } 

Answer 2

Используйте источник ado.net вместо источника oledb, определите простой выбор и получите столбцы, которые вы хотите вернуть. Теперь вы можете определить expresión в свойствах потока данных.

Поиск источник ado.net динамический SQL

:)

Answer 3

попытка вернуть записи и использовать Еогеасп в ETL вместо курсора

https://www.simple-talk.com/sql/ssis/implementing-foreach-looping-logic-in-ssis/

Я думаю, что вы можете это сделать простой способ, но я не знаю, что вы делаете, точно ...