《PowerShell V3——SQL Server 2012数据库自动化运维权威指南》——2.20 使用BULK INSERT实施批量导入...

    xiaoxiao2024-04-08  150

    本节书摘来自异步社区出版社《PowerShell V3—SQL Server 2012数据库自动化运维权威指南》一书中的第2章,第2.20节,作者:【加拿大】Donabel Santos,更多章节内容可以访问云栖社区“异步社区”公众号查看。

    2.20 使用BULK INSERT实施批量导入

    本方案描述了如何用PowerShell和BULK INSERT将CSV文件导入SQL Server。

    2.20.1 准备

    为了做导入测试,我们首先需要创建一个Person表,类似于AdventureWorks2008R2数据库的Person.Person表,简单地修改一下。

    我们将在Test架构下创建,并移除一些约束,保持表简单且独立。

    为了创建本练习中需要的表,我们打开SSMS,运行如下代码。

    CREATE SCHEMA [Test] GO CREATE TABLE [Test].[Person]( [BusinessEntityID] [int] NOT NULL PRIMARY KEY, [PersonType] [nchar](2) NOT NULL, [NameStyle] [dbo].[NameStyle] NOT NULL, [Title] [nvarchar](8) NULL, [FirstName] [dbo].[Name] NOT NULL, [MiddleName] [dbo].[Name] NULL, [LastName] [dbo].[Name] NOT NULL, [Suffix] [nvarchar](10) NULL, [EmailPromotion] [int] NOT NULL, [AdditionalContactInfo] [xml] NULL, [Demographics] [xml] NULL, [rowguid] [uniqueidentifier] ROWGUIDCOL NOT NULL, [ModifiedDate] [datetime] NOT NULL ) GO

    在本方案中,我们将导入AdventureWorks2008R2.Person.Person.csv文件,Packt网站提供了可下载资源。保存在目录C:TempExports下。

    或者,创建一个CSV文件,像在使用bcp实施批量导出方案中所提到的,替换文件名。

    2.20.2 如何做…

    1.通过“Start | Accessories | Windows PowerShell | Windows PowerShell ISE”打开PowerShell控制台。

    2.首先添加一些辅助函数。输入如下并执行。

    Import-Module SQLPS -DisableNameChecking function Import-Person { <# .SYNOPSIS    Very simple function to get number    of records in Test.Person .NOTES    Author   : Donabel Santos .LINK    http://www.sqlmusings.com #> param([string]$instanceName,[string]$dbName) $query = @" TRUNCATE TABLE Test.Person GO BULK INSERT AdventureWorks2008R2.Test.Person   FROM 'C:\Temp\Exports\AdventureWorks2008R2.Person.Person.csv'   WITH     (       FIELDTERMINATOR ='|',       ROWTERMINATOR ='\n'     ) SELECT COUNT(*) AS NumRecords FROM AdventureWorks2008R2.Test.Person "@; #check number of records Invoke-Sqlcmd -Query $query ` -ServerInstance "$instanceName" ` -Database $dbName }

    3.现在在同一个会话中调用该函数。

    $instanceName = "KERRIGAN" $dbName = "AdventureWorks2008R2" Import-Person $instanceName $dbName

    2.20.3 如何实现…

    使用BULK INSERT命令,从CSV或文本文件中将记录导入到SQL Server表,需要创建BULK INSERT T-SQL语句,并使用Invoke-Sqlcmd执行以下语句。

    Invoke-Sqlcmd -Query $query ` -ServerInstance "$instanceName" ` -Database $dbName

    然而,我们的做法不同于之前的方案。在本方案中,我们首先创建了一个函数,将所有核心导入任务括起来。

    创建函数时,我们首先需要创建函数头部。

    function Import-Person {

    函数头部以function开始,然后跟随着函数名,以动词-名词的形式。函数体通过一对大括号括起来。

    在函数头部后面,创建了注释信息,对头部进行注释。

    <# .SYNOPSIS    Very simple function to get number   of records in Test.Person .NOTES    Author   : Donabel Santos .LINK    http://www.sqlmusings.com #>

    在PowerShell中,块注释以<#开始,以#>结束。此外,这是一个特别类型的块注释,可以在Get-Help中显示函数的注释。现在我们输入:

    Get-Help Import-Person

    你得到的结果与从其他的cmdlet中获得的帮助类似。

    在函数头部和注释后面是参数。Import-Person函数接受两个参数:instance name和database name。

    param([string]$instanceName,[string]$dbName)

    参数定义之后是函数定义。我们创建一个字符串,保存T-SQL语句。

    $query = @" TRUNCATE TABLE Test.Person GO BULK INSERT AdventureWorks2008R2.Test.Person   FROM 'C:\Temp\Exports\AdventureWorks2008R2.Person.Person.csv'   WITH     (       FIELDTERMINATOR ='|',       ROWTERMINATOR ='\n'     ) SELECT COUNT(*) AS NumRecords FROM AdventureWorks2008R2.Test.Person "@;

    在创建查询后,我们将其传递给Invoke-Sqlcmd cmdlet,让它在SQL Server实例中执行。

    Invoke-Sqlcmd -Query $query ` -ServerInstance "$instanceName" ` -Database $dbName

    在PowerShell中,函数默认是本地域范围,但是当通过ISE运行时,将保持一个全局域范围。在我们的方案中,一旦你运行第一部分含有函数定义的脚本,你可以在当前会话中的任何时候调用函数。我们可以看到该函数简化了导入记录,我们只需要明确实例名、数据库名和Import-Person函数。

    $instanceName = "KERRIGAN" $dbName = "AdventureWorks2008R2" Import-Person $instanceName $dbName

    如果你使用Shell,想要函数能在全局域范围内访问,保存该脚本为.ps1文件,并点号加载它。另一个方法是添加函数名和global。

    function global:Import-Person {

    2.20.4 请参阅…

    执行查询语句/SQL脚本方案使用bcp实施批量导入。

    最新回复(0)