Как добавить две строки из двух источников в SSIS? - PullRequest
Новая
       36

Как добавить две строки из двух источников в SSIS?

3 голосов
/ 07 марта 2019

У меня есть таблица в MySQL Server.

  1. Таблица заголовков. ╔════════════╦════════╦═════════════╦═════════════════╦══════════╗ ║ RecordType ║ CustID ║ DataGenDate ║ DataCreatedDate ║ SourceID ║ ╠════════════╬════════╬═════════════╬═════════════════╬══════════╣ ║ H ║ #1234 ║ 2018-01-05 ║ 2018-01-01 ║ V301 ║ ╚════════════╩════════╩═════════════╩═════════════════╩══════════╝

  2. Таблица транзакций ╔════════════╦══════════╦══════════════╦══════════════╦════════════╗ ║ RecordType ║ ProdCode ║ OpeningValue ║ ClosingValue ║ TranDate ║ ╠════════════╬══════════╬══════════════╬══════════════╬════════════╣ ║ T ║ AL001 ║ 95 ║ 90 ║ 2018-01-01 ║ ╠════════════╬══════════╬══════════════╬══════════════╬════════════╣ ║ T ║ AL002 ║ 54 ║ 40 ║ 2018-01-01 ║ ╠════════════╬══════════╬══════════════╬══════════════╬════════════╣ ║ T ║ AL003 ║ 63 ║ 43 ║ 2018-01-02 ║ ╠════════════╬══════════╬══════════════╬══════════════╬════════════╣ ║ T ║ AL004 ║ 56 ║ 23 ║ 2018-01-01 ║ ╚════════════╩══════════╩══════════════╩══════════════╩════════════╝

Таблица заголовков содержит информацию заголовка, а таблица транзакций - данные транзакции. Я хочу, чтобы через SSIS генерировался текстовый файл (разделенный вертикальной чертой "|") в формате ниже. 

H|#1234|2018-01-05|2018-01-01|V301
----------------------------------------
T|AL001|95        |90        |2018-01-01
T|AL002|54        |40        |2018-01-01
T|AL003|63        |43        |2018-01-02
T|AL004|56        |23        |2018-01-01

Я попытался с помощью источника ole DB и назначения плоского файла экспортировать файл, но не удалось. только я получаю либо транзакцию, либо строки заголовка.

1 Ответ

3 голосов
/ 07 марта 2019

Это можно сделать с помощью задачи «Сценарий» следующим образом, в этом случае используется C #.Это создаст файл CSV с разделителем канала (|).Запустив образец теста с этим, я смог импортировать выходной CSV-файл через диспетчер соединений с плоскими файлами SSIS без каких-либо изменений в файле.В этом примере предполагается, что в таблице заголовков есть только одна строка, в противном случае вам потребуется изменить SQL для этой таблицы, чтобы она возвращала правильную строку. 

using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Text;



//Windows Authentication (Integrated Security)
 string connectionString = @"Data Source=ServerName;Initial Catalog=DatabaseName;Integrated Security=true";
 string headerCmd = @"SELECT RecordType, CustID, DataGenDate, DataCreatedDate, SourceID FROM HeaderTable";
 string rowCmd = @"SELECT RecordType, CustID, DataGenDate, DataCreatedDate, SourceID FROM TransactionTable";

 string outputFile = Dts.Variables["User::FilePathVariable"].Value.ToString();

 StringBuilder csvData = new StringBuilder();
 int headerInt = 0;
 DataTable headerDT = new DataTable();
 DataTable rowDT = new DataTable();

 using (SqlConnection conn = new SqlConnection(connectionString))
 {
     SqlCommand headerSQL = new SqlCommand(headerCmd, conn);
     SqlCommand rowSQL = new SqlCommand(rowCmd, conn);

     SqlDataAdapter da = new SqlDataAdapter();

     conn.Open();

     //get header row
     da.SelectCommand = headerSQL;
     da.Fill(headerDT);

     //get data from Transaction table
     da.SelectCommand = rowSQL;
     da.Fill(rowDT);
 }

 //build header
 foreach (DataRow hDR in headerDT.Rows)
 {
     foreach (DataColumn hDC in headerDT.Columns)
     {
         csvData.Append(hDR[headerInt].ToString() + "|");
         headerInt++;
     }
 }

 //remove last pipe then start new line                    
 csvData.Remove(csvData.Length - 1, 1);
 csvData.Append(Environment.NewLine);

 //add rows
 foreach (DataRow rDR in rowDT.Rows)
 {
     for (int i = 0; i < headerInt; i++)
     {
         csvData.Append(rDR[i] + "|");
     }
     csvData.Remove(csvData.Length - 1, 1);
     csvData.Append(Environment.NewLine);
 }
 //write to CSV
 File.WriteAllText(outputFile, csvData.ToString());
...