Компонент сценария служб SSIS: Microsoft.SqlServer.Dts.Pipeline.BlobColumn

Question

Борьба с компонентом C #.То, что я пытаюсь сделать, это взять столбец, который является ntext в моем входном источнике, который разделен с помощью каналов, а затем записать массив в текстовый файл.Когда я запускаю свой компонент, мой вывод выглядит так:

DealerID,StockNumber,Option
161552,P1427,Microsoft.SqlServer.Dts.Pipeline.BlobColumn

Я работал с методом GetBlobData и борюсь с ним.Любая помощь с благодарностью!Вот полный сценарий:

public override void Input0_ProcessInputRow(Input0Buffer Row)
{
    string vehicleoptionsdelimited = Row.Options.ToString();
    //string OptionBlob = Row.Options.GetBlobData(int ;
    //string vehicleoptionsdelimited = System.Text.Encoding.GetEncoding(Row.Options.ColumnInfo.CodePage).GetChars(OptionBlob);
    string[] option = vehicleoptionsdelimited.Split('|');
    string path = @"C:\Users\User\Desktop\Local_DS_CSVs\";

    string[] headerline =
    {
        "DealerID" + "," + "StockNumber" + "," + "Option"
    };

    System.IO.File.WriteAllLines(path + "OptionInput.txt", headerline);

    using (System.IO.StreamWriter file = new System.IO.StreamWriter(path + "OptionInput.txt", true))
    {
        foreach (string s in option)
        {
            file.WriteLine(Row.DealerID.ToString() + "," + Row.StockNumber.ToString() + "," + s);
        }
    }

Answer 1

Попробуйте использовать

BlobToString(Row.Options)

, используя эту функцию:

  private string BlobToString(BlobColumn blob)
    {
        string result = "";
        try
        {
            if (blob != null)
            {
                result = System.Text.Encoding.Unicode.GetString(blob.GetBlobData(0, Convert.ToInt32(blob.Length)));
            }
        }
        catch (Exception ex)
        {
            result = ex.Message;
        }
        return result;
    }

Адаптировано с: http://mscrmtech.com/201001257/converting-microsoftsqlserverdtspipelineblobcolumn-to-string-in-ssis-using-c

Answer 2

Другое очень простое решение этой проблемы, потому что это общий PITA, состоит в том, чтобы направить вывод ошибок в производный компонент столбца и преобразовать данные большого двоичного объекта в STR или WSTR в качестве нового столбца.

Направьте вывод этого в ваш компонент скрипта, и данные будут представлены в виде дополнительного столбца в конвейере, готовом для анализа.

Это, вероятно, будет работать, только если ваши данные имеют длину менее 8000 символов.