Add incremental number while inserting records using SSIS(使用 SSIS 插入记录时添加增量编号)
问题描述
我有一个 SSIS 包,其中有两条记录.我需要在表中插入一个额外的列(假设是序列)的记录.如果有两条记录,Sequence 列的值应为 1(对于第一条记录)和 2(对于第二条记录).再次,下一次,我得到三个记录,然后序列再次从 1,2 和 3 开始.
I have a SSIS package in which, two records are coming. I need to insert the records in the table with an extra column (let's say Sequence). If there are two records, Sequence column should have the value 1(for the first record) and 2(for the second record). Again, next time, I'm getting three records, then again sequence starts from 1,2 and 3.
有没有办法在不使用脚本或存储过程的情况下做到这一点?
Is there anyway to do this without using script or stored procedure?
截图:
推荐答案
有两种方法可以实现:
我认为使用脚本组件更高效,更可控,你可以自己写逻辑
- 在 DataFlow 任务中添加脚本组件
- 添加
DT_I4
类型的输出列 (例如:NewID
) 在脚本编辑器中使用以下代码 (我使用 Visual Basic 语言)
Imports System
Imports System.Data
Imports System.Math
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
Imports Microsoft.SqlServer.Dts.Runtime.Wrapper
<Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute> _
<CLSCompliant(False)> _
Public Class ScriptMain
Inherits UserComponent
Private CurrentID as Integer = 0
Public Overrides Sub Input0_ProcessInputRow(ByVal Row As Input0Buffer)
CurrentID += 1
Row.NewID = CurrentID
End Sub
End Class
在OLEDB Destination
中,将NewID
列映射到目标标识列
In the OLEDB Destination
,Map the NewID
column to the destination identity column
(2) 使用临时表
类似于我在 这个答案:
- 创建一个带有标识列的临时表
- 每次截断表(这将重新启动身份),并将数据插入临时表
- 使用
DataFlow Task
或Execute SQL Task
从Staging 表插入数据
- Create a staging table with an identity column
- Each time Truncate the Table (this will restart identity), and Insert data into staging table
- Insert data from Staging table using a
DataFlow Task
or anExecute SQL Task
这篇关于使用 SSIS 插入记录时添加增量编号的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:使用 SSIS 插入记录时添加增量编号
基础教程推荐
- ERROR 2006 (HY000): MySQL 服务器已经消失 2021-01-01
- 如何在 SQL Server 的嵌套过程中处理事务? 2021-01-01
- 无法在 ubuntu 中启动 mysql 服务器 2021-01-01
- Sql Server 字符串到日期的转换 2021-01-01
- SQL Server:只有 GROUP BY 中的最后一个条目 2021-01-01
- SQL Server 2016更改对象所有者 2022-01-01
- 使用pyodbc“不安全"的Python多处理和数据库访问? 2022-01-01
- 在 VB.NET 中更新 SQL Server DateTime 列 2021-01-01
- SQL Server 中单行 MERGE/upsert 的语法 2021-01-01
- 将数据从 MS SQL 迁移到 PostgreSQL? 2022-01-01