Подготовка к запросу измененных данных

На вкладке Поток управления добавьте к пакету задачу «Сценарий» после контейнера «цикл по элементам» и соедините контейнер с этой задачей.

Примечание
Здесь предполагается, что пакет выполняет добавочную загрузку из одной таблицы. Если пакет загружает данные из нескольких таблиц и содержит родительский пакет с несколькими дочерними, то эту задачу следует добавить в качестве первого компонента каждого из дочерних пакетов. Дополнительные сведения см. в разделе Выполнение добавочной загрузки нескольких таблиц.

В окне Редактор задачи «Сценарий» на странице Сценарий выберите следующие параметры.

1. Для свойства ReadOnlyVariables выберите из списка значения User::DataReady, User::ExtractStartTime и User::ExtractEndTime.

2. Для свойства ReadWriteVariables выберите из списка значение User::SqlDataQuery.

В окне Редактор задачи «Сценарий» на странице Сценарий нажмите кнопку Изменить сценарий, чтобы открыть среду разработки сценариев.

В главной процедуре введите один из следующих сегментов кода.

• При программировании на языке C# введите следующие строки кода:

      int dataReady;
      System.DateTime extractStartTime;
      System.DateTime extractEndTime;
      string sqlDataQuery;
  
      dataReady = (int)Dts.Variables["DataReady"].Value;
      extractStartTime = (System.DateTime)Dts.Variables["ExtractStartTime"].Value;
      extractEndTime = (System.DateTime)Dts.Variables["ExtractEndTime"].Value;
  
      if (dataReady == 2)
        {
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer('" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractStartTime) + "', '" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) + "')";
        }
      else
        {
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer(null" + ", '" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) + "')";
        }
  
      Dts.Variables["SqlDataQuery"].Value = sqlDataQuery;
  

  -или-

• При программировании на языке Visual Basic, введите следующие строки кода:

      Dim dataReady As Integer
      Dim extractStartTime As Date
      Dim extractEndTime As Date
      Dim sqlDataQuery As String
  
      dataReady = CType(Dts.Variables("DataReady").Value, Integer)
      extractStartTime = CType(Dts.Variables("ExtractStartTime").Value, Date)
      extractEndTime = CType(Dts.Variables("ExtractEndTime").Value, Date)
  
      If dataReady = 2 Then
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer('" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractStartTime) & _
            "', '" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) & _
            "')"
      Else
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer(null" & _
            ", '" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) & _
            "')"
      End If
  
      Dts.Variables("SqlDataQuery").Value = sqlDataQuery
  

Оставьте без изменений создаваемую по умолчанию строку кода, которая возвращает DtsExecResult.Success в результате выполнения сценария.

Закройте среду разработки сценариев и Редактор задачи «Сценарий».

На вкладке Поток управления добавьте к пакету задачу «Выполнение SQL» после контейнера «цикл по элементам» и соедините контейнер с этой задачей.

Примечание
Здесь предполагается, что пакет выполняет добавочную загрузку из одной таблицы. Если пакет загружает данные из нескольких таблиц и содержит родительский пакет с несколькими дочерними, то эту задачу следует добавить в качестве первого компонента каждого из дочерних пакетов. Дополнительные сведения см. в разделе Выполнение добавочной загрузки нескольких таблиц.

В окне Редактор задачи «Выполнение SQL» на странице Общие выберите следующие параметры:

1. Для параметра ResultSet выберите значение Одна строка.

2. Настройте допустимое соединение с базой данных-источником.

3. Для параметра SQLSourceType выберите значение Прямой ввод.

4. В поле SQLStatement введите приведенную ниже инструкцию SQL:

   declare @ExtractStartTime datetime,
   @ExtractEndTime datetime, 
   @DataReady int
   
   select @DataReady = ?, 
   @ExtractStartTime = ?, 
   @ExtractEndTime = ?
   
   if @DataReady = 2
   select N'select * from CDCSample.uf_Customer'
   + N'('''+ convert(nvarchar(30),@ExtractStartTime,120)
   + ''', '''
   + convert(nvarchar(30),@ExtractEndTime,120) + ''') ' 
   as SqlDataQuery
   else
   select N'select * from CDCSample.uf_Customer'
   + N'(null, '''
   + convert(nvarchar(30),@ExtractEndTime,120)
   + ''') '
   as SqlDataQuery
   

   Примечание
   Предложение else в этом образце формирует запрос на первоначальную загрузку измененных данных, передавая значение NULL для даты и времени начала. Этот образец не учитывает случай, когда изменения, сделанные до включения системы отслеживания измененных данных, тоже необходимо загрузить в хранилище данных.

На странице Сопоставление параметров средства Редактор задачи «Выполнение SQL» выполните следующее сопоставление.

1. Сопоставьте переменную DataReady с параметром 0.

2. Сопоставьте переменную ExtractStartTime с параметром 1.

3. Сопоставьте переменную ExtractEndTime с параметром 2.

На странице Результирующий набор средства Редактор задачи «Выполнение SQL» сопоставьте столбец «Имя результата» с переменной SqlDataQuery.

Имя результата — это имя единственного возвращаемого столбца SqlDataQuery.