-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #4 from Akaizoku/develop
Oracle update
- Loading branch information
Showing
5 changed files
with
492 additions
and
71 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,192 @@ | ||
| function Invoke-OracleCmd { | ||
| <# | ||
| .SYNOPSIS | ||
| Invoke Oracle SQL command | ||
| .DESCRIPTION | ||
| Run a SQL command on an Oracle database | ||
| .NOTES | ||
| File name: Invoke-OracleCmd.ps1 | ||
| Author: Florian Carrier | ||
| Creation date: 04/02/2020 | ||
| Last modified: 06/02/2020 | ||
| Dependencies: Invoke-OracleCmd requires Oracle Data Provider for .NET | ||
| .LINK | ||
| https://www.powershellgallery.com/packages/PSTK | ||
| .LINK | ||
| Invoke-SqlCmd | ||
| .LINK | ||
| https://www.oracle.com/database/technologies/appdev/dotnet/odp.html | ||
| .LINK | ||
| https://www.nuget.org/packages/Oracle.ManagedDataAccess.Core | ||
| #> | ||
| [CmdletBinding ( | ||
| SupportsShouldProcess = $true | ||
| )] | ||
| Param ( | ||
| [Parameter ( | ||
| Position = 1, | ||
| Mandatory = $true, | ||
| HelpMessage = "Name of the database host" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [Alias ("Server")] | ||
| [System.String] | ||
| $Hostname, | ||
| [Parameter ( | ||
| Position = 2, | ||
| Mandatory = $true, | ||
| HelpMessage = "Database server port number" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.String] | ||
| $PortNumber, | ||
| [Parameter ( | ||
| Position = 3, | ||
| Mandatory = $true, | ||
| HelpMessage = "Name of the Oracle service" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.String] | ||
| $ServiceName, | ||
| [Parameter ( | ||
| Position = 4, | ||
| Mandatory = $true, | ||
| HelpMessage = "SQL query" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.String] | ||
| $Query, | ||
| [Parameter ( | ||
| Position = 5, | ||
| Mandatory = $false, | ||
| HelpMessage = "Database user credentials", | ||
| ParameterSetName = "Credentials" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.Management.Automation.PSCredential] | ||
| $Credentials, | ||
| [Parameter ( | ||
| Position = 5, | ||
| Mandatory = $false, | ||
| HelpMessage = "User name", | ||
| ParameterSetName = "UserPassword" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [Alias ("Name")] | ||
| [System.String] | ||
| $Username, | ||
| [Parameter ( | ||
| Position = 6, | ||
| Mandatory = $false, | ||
| HelpMessage = "Password", | ||
| ParameterSetName = "UserPassword" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [Alias ("Pw")] | ||
| [System.String] | ||
| $Password, | ||
| [Parameter ( | ||
| Mandatory = $false, | ||
| HelpMessage = "Connection timeout (in seconds)" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.Int32] | ||
| $ConnectionTimeOut, | ||
| [Parameter ( | ||
| Mandatory = $false, | ||
| HelpMessage = "Query timeout (in seconds)" | ||
| )] | ||
| [ValidateNotNullOrEmpty ()] | ||
| [System.Int32] | ||
| $QueryTimeOut, | ||
| [Parameter ( | ||
| HelpMessage = "Abort on error" | ||
| )] | ||
| [Switch] | ||
| $AbortOnError, | ||
| [Parameter ( | ||
| HelpMessage = "Encrypt connection" | ||
| )] | ||
| [Switch] | ||
| $EncryptConnection, | ||
| [Parameter ( | ||
| HelpMessage = "Include SQL user errors" | ||
| )] | ||
| [Switch] | ||
| $IncludeSqlUserErrors, | ||
| [Parameter ( | ||
| HelpMessage = "Out SQL errors" | ||
| )] | ||
| [Switch] | ||
| $OutputSqlErrors | ||
| ) | ||
| Begin { | ||
| # Get global preference variables | ||
| Get-CallerPreference -Cmdlet $PSCmdlet -SessionState $ExecutionContext.SessionState | ||
| } | ||
| Process { | ||
| # Define connection string | ||
| $ConnectionString = "Data Source='(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=$Hostname)(PORT=$PortNumber))(CONNECT_DATA=(SERVICE_NAME=$ServiceName)))';" | ||
| # Check authentication mode | ||
| if ($PSBoundParameters.ContainsKey("Credentials")) { | ||
| # If "secured" credentials are provided | ||
| $ConnectionString = $ConnectionString + "User ID=$($Credentials.Username);Password=$($Credentials.GetNetworkCredential().Password);" | ||
| $SensitiveData = $Credentials.GetNetworkCredential().Password | ||
| } elseif ($PSBoundParameters.ContainsKey("Username") -And $PSBoundParameters.ContainsKey("Password")) { | ||
| # If plain text credentials are provided | ||
| if ($Username) { | ||
| $ConnectionString = $ConnectionString + "User ID=$Username;Password=$Password;" | ||
| $SensitiveData = $Password | ||
| } else { | ||
| Write-Log -Type "ERROR" -Message "Invalid username ""$Username""" -ExitCode 1 | ||
| } | ||
| } else { | ||
| # Else default to integrated security (Windows authentication) | ||
| Write-Log -Type "DEBUG" -Message "Using Integrated Security" | ||
| $ConnectionString = $ConnectionString + "Integrated Security=True;" | ||
| } | ||
| # Technical parameters (Min Pool Size=10;Connection Lifetime=120;Connection Timeout=60;Incr Pool Size=5;Decr Pool Size=2;) | ||
| if ($PSBoundParameters.ContainsKey("ConnectionTimeOut") -And $ConnectionTimeOut -ne $null) { | ||
| $ConnectionString = $ConnectionString + "Connection Timeout=$ConnectionTimeOut;" | ||
| } | ||
| # Create connection object | ||
| Write-Log -Type "DEBUG" -Object $ConnectionString -Obfuscate $SensitiveData | ||
| $Connection = New-Object -TypeName "Oracle.ManagedDataAccess.Client.OracleConnection" -ArgumentList $ConnectionString | ||
| # Try to open the connection | ||
| try { | ||
| $Connection.Open() | ||
| } catch { | ||
| Write-Log -Type "ERROR" -Object "Unable to reach database $($Hostname):$PortNumber/$ServiceName" | ||
| return $Error | ||
| } | ||
| # Create SQL command | ||
| $Command = $Connection.CreateCommand() | ||
| # TODO sanitize query | ||
| $Command.CommandText = $Query | ||
| Write-Log -Type "DEBUG" -Object $Command | ||
| # Execute command | ||
| try { | ||
| $Reader = $Command.ExecuteReader() | ||
| } catch { | ||
| Write-Log -Type "ERROR" -Object "Could not execute statement`n$Query" | ||
| return $Error | ||
| } | ||
| # Get result | ||
| $Result = $Reader.Read() | ||
| # Close connection | ||
| $Connection.Close() | ||
| # Check outcome | ||
| if ($Result) { | ||
| # TODO return actual result | ||
| return $Result | ||
| } else { | ||
| return $null | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.