PowerShell 通過(guò)ADO.NET連接SQL Server數(shù)據(jù)庫(kù)，并執(zhí)行SQL腳本。工作中整理的一小段腳本，后來(lái)沒(méi)有用上，先記錄在這里：

建立數(shù)據(jù)庫(kù)連接

查詢返回一個(gè)DataTatble對(duì)象

執(zhí)行一條SQL語(yǔ)句

通過(guò)事物執(zhí)行多條SQL語(yǔ)句

#

# 建立數(shù)據(jù)庫(kù)連接.

#

function New-SqlConnection([string]$connectionStr)

{

$SqlConnection = New-Object System.Data.SqlClient.SqlConnection

$SqlConnection.ConnectionString = $connectionStr

try{

$SqlConnection.Open()

Write-Host 'Connected to sql server.'

return $SqlConnection

}

catch [exception] {

Write-Warning ('Connect to database failed with error message:{0}' -f ,$_)

$SqlConnection.Dispose()

return $null

}

}

#

# 查詢返回一個(gè)DataTable對(duì)象

#

function Get-SqlDataTable

{

param

(

[System.Data.SqlClient.SqlConnection]$SqlConnection,

[string]$query

)

$dataSet = new-object "System.Data.DataSet" "WrestlersDataset"

$dataAdapter = new-object "System.Data.SqlClient.SqlDataAdapter" ($query,$SqlConnection)

$dataAdapter.Fill($dataSet) | Out-Null

return $dataSet.Tables | select -First 1

}

#

# 執(zhí)行一條SQL命令

#

function Execute-SqlCommandNonQuery

{

param

(

[System.Data.SqlClient.SqlConnection]$SqlConnection,

[string]$Command

)

$cmd = $SqlConnection.CreateCommand()

try

{

$cmd.CommandText = $Command

$cmd.ExecuteNonQuery() | Out-Null

return $true

}

catch [Exception] {

Write-Warning ('Execute Sql command failed with error message:{0}' -f $_)

return $false

}

finally{

$SqlConnection.Close()

}

}

#

# 通過(guò)事物處理執(zhí)行多條SQL命令

#

function Execute-SqlCommandsNonQuery

{

param

(

[System.Data.SqlClient.SqlConnection]$SqlConnection,

[string[]]$Commands

)

$transaction = $SqlConnection.BeginTransaction()

$command = $SqlConnection.CreateCommand()

$command.Transaction = $transaction

try

{

foreach($cmd in $Commands) {

#Write-Host $cmd -ForegroundColor Blue

$command.CommandText = $cmd

$command.ExecuteNonQuery()

}

$transaction.Commit()

return $true

}

catch [Exception] {

$transaction.Rollback()

Write-Warning ('Execute Sql commands failed with error message:{0}' -f $_)

return $false

}

finally{

$SqlConnection.Close()

}

}

×用微信掃描并分享