使用 SSIS 将 SQL 导出到 Excel (xlsx)?

npi*_*ani 5 sql-server unicode excel ssis

我是一名 SSIS 菜鸟(经验不足一周),所以请耐心等待。
我正在运行一个存储过程以将其结果导出到 Excel 文件。

根据我的研究,我发现 SSIS 的 Excel 目标不能很好地处理 .xlsx 文件(不能是 xls,因为结果中的行数超过了约 65K 行),但我发现我可以使用 OLE DB 目标来写入 Excel 文件。

我看到的问题是运行时出现的错误消息:

OLE DB Destination [212]] Error: 
An error occurred while setting up a binding for the "Main Job Notes" column. 
The binding status was "DT_NTEXT"."
Run Code Online (Sandbox Code Playgroud)

出错的字段以文本流 ([DT_TEXT]) 形式传入,由于我收到无法在 unicode 和非 unicode 之间转换的错误,因此我使用数据转换将其转换为 Unicode 文本流([DT_NTEXT])

如果有帮助的话,我的设置如下:

在此输入图像描述

任何帮助都会很棒。谢谢。

小智 1

您应该考虑使用脚本组件来执行此操作,请记住,在数据流任务中,您无法直接调试,但可以使用 mbox snipped 来检查结果。另请记住,Excel 将始终尝试自动假设您的列数据类型,例如,当您尝试从 Excel 导入文件时,其中一列以数字开头,但在第 3455 行中有一个字符,它将导入列作为数字,您将丢失 char 值,您将在数据库中发现它为空。

我会给你一些代码来以编程方式构建你需要的文件,也许它可以给你一个想法。(此示例将文件读取为一列,然后它将进行拆分,就像您在 excel 中选择使用分隔值固定一样,并将输出到 csv 文件中。

/* Microsoft SQL Server Integration Services Script Component
*  Write scripts using Microsoft Visual C# 2008.
*  ScriptMain is the entry point class of the script.*/

using System;
using System.IO;
using System.Linq;
using System.Text;

[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{

    #region Variables
    private string _jumexDailyData;
    private string[] _jumexValues;
    private string[] _jumexWidthValues;      
    #endregion

    /// <summary>
    /// Default constructor
    /// </summary>
    public ScriptMain()
    {        
        this._jumexValues = new string[22];        
    }

    public override void PreExecute()
    {
        base.PreExecute();
        /*
          Add your code here for preprocessing or remove if not needed
        */
    }

    public override void PostExecute()
    {
        base.PostExecute();
        /*
          Add your code here for postprocessing or remove if not needed
          You can set read/write variables here, for example:
          Variables.MyIntVar = 100
        */
    }

    public override void JumexDailyData_ProcessInput(JumexDailyDataBuffer Buffer)
    {        
        while (Buffer.NextRow())
            JumexDailyData_ProcessInputRow(Buffer);        
    }

    public override void JumexDailyData_ProcessInputRow(JumexDailyDataBuffer Row)
    {
        this._jumexDailyData = Row.JumexDailyData;
        if (this._jumexDailyData != null)
        {
            this._jumexWidthValues = this.Variables.JUMEXLOADSALESATTACHMENTFILEWIDTHVALUES.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
            if (this._jumexWidthValues != null && this._jumexWidthValues.Count() > 0)
                for (int i = 0; i < this._jumexWidthValues.Count(); i++)
                {
                    this._jumexValues[i] = this._jumexDailyData.Substring(0, int.Parse(this._jumexWidthValues[i])).Trim();
                    this._jumexDailyData = this._jumexDailyData.Substring(int.Parse(this._jumexWidthValues[i]), (this._jumexDailyData.Length - int.Parse(this._jumexWidthValues[i])));
                }

            if (string.IsNullOrEmpty(this._jumexValues[3].Trim()) == false &&
                string.IsNullOrEmpty(this._jumexValues[17].Trim()) == false &&
                !this._jumexValues[3].Contains("---") &&
                !this._jumexValues[17].Contains("---") &&
                !this._jumexValues[3].Trim().ToUpper().Contains("FACTURA") &&
                !this._jumexValues[17].Trim().ToUpper().Contains("PEDIDO"))                
                using (StreamWriter streamWriter = new StreamWriter(this.Variables.JUMEXFULLQUALIFIEDLOADSALESATTACHMENTFILENAME.Replace(".TXT", ".CSV"), true, Encoding.Default))
                {
                    streamWriter.WriteLine(string.Join("|", this._jumexValues));
                }
        }        
    }

}
Run Code Online (Sandbox Code Playgroud)