src/Object/Publish-Object.ps1
|
using namespace System.Data using module ../SqlCommandBuilder.psm1 using module ../SqlMapper.psm1 <# .SYNOPSIS Inserts the specified entity. .INPUTS The entity to insert. .OUTPUTS The generated primary key value. #> function Publish-SqlObject { [CmdletBinding()] [OutputType([long])] param ( # The connection to the data source. [Parameter(Mandatory, Position = 0)] [IDbConnection] $Connection, # The entity to insert. [Parameter(Mandatory, Position = 1, ValueFromPipeline)] [object] $InputObject, # The wait time, in seconds, before terminating the attempt to execute the command and generating an error. [ValidateRange("NonNegative")] [int] $Timeout = 30, # The transaction within which the command executes. [IDbTransaction] $Transaction ) process { $statement = [SqlCommandBuilder]::new($Connection).GetInsertCommand($InputObject) $statement[0].Timeout = $Timeout $statement[0].Transaction = $Transaction $id = Get-SqlScalar $Connection -As ([long]) -Command $statement[0] -Parameters $statement[1] $column = [SqlMapper]::Instance.GetTable($InputObject.GetType()).IdentityColumn if ($column) { $column.SetValue($InputObject, [SqlMapper]::ChangeType($id, $column)) } $id } } |