Skip to content

Commit

Permalink
Merge pull request #101 from PowerShell/dev
Browse files Browse the repository at this point in the history 
Release of version 1.8.0.0 of xSQLServer
  • Loading branch information
@kwirkykat
kwirkykat authored Aug 10, 2016
2 parents 7d38ef3 + 2d9a259 commit 054ca54
Show file tree
Hide file tree
Showing 29 changed files with 2,674 additions and 166 deletions.
206 changes: 109 additions & 97 deletions DSCResources/MSFT_xSQLAOGroupEnsure/MSFT_xSQLAOGroupEnsure.psm1
View file
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ function Set-TargetResource
param
(
[parameter(Mandatory = $true)]
[ValidateSet("Present","Absent")]
[ValidateSet("Present", "Absent")]
[System.String]
$Ensure,

Expand All @@ -79,88 +79,94 @@ function Set-TargetResource
$AvailabilityGroupSubMask,

[System.UInt32]
$AvailabilityGroupPort ="1433",
$AvailabilityGroupPort = "1433",

[ValidateSet("None","ReadOnly","ReadIntent")]
[ValidateSet("None", "ReadOnly", "ReadIntent")]
[System.String]
$ReadableSecondary="ReadOnly",
$ReadableSecondary = "ReadOnly",

[ValidateSet("Primary","Secondary")]
[ValidateSet("Primary", "Secondary")]
[System.String]
$AutoBackupPrefernce ="Primary",
$AutoBackupPreference = "Primary",

[System.UInt32]
$BackupPriority = "50",

[System.UInt32]
$EndPointPort = "5022",

[System.String]
$SQLServer = $env:COMPUTERNAME,

[System.String]
$SQLInstanceName= "MSSQLSERVER",
$SQLInstanceName = "MSSQLSERVER",

[parameter(Mandatory = $true)]
[System.Management.Automation.PSCredential]
$SetupCredential
)

$null = [System.Reflection.Assembly]::LoadWithPartialName('Microsoft.SqlServer.Smo')
$null = [System.Reflection.Assembly]::LoadWithPartialName("Microsoft.SqlServer.SmoExtended")
$null = [System.Reflection.Assembly]::LoadWithPartialName('Microsoft.SqlServer.Smo')
$null = [System.Reflection.Assembly]::LoadWithPartialName("Microsoft.SqlServer.SmoExtended")

if(!$SQL)
if(!$SQL)
{
$SQL = Connect-SQL -SQLServer $SQLServer -SQLInstanceName $SQLInstanceName -SetupCredential $SetupCredential
}

if (($AvailabilityGroupNameIP -and !$AvailabilityGroupSubMask) -or (!$AvailabilityGroupNameIP -and $AvailabilityGroupSubMask))
if (($AvailabilityGroupNameIP -and !$AvailabilityGroupSubMask) -or (!$AvailabilityGroupNameIP -and $AvailabilityGroupSubMask))
{
Throw "AvailabilityGroupNameIP and AvailabilityGroupSubMask must both be passed for Static IP assignment."
Exit
}

Switch ($Ensure)
{
"Present"
{
Grant-ServerPerms -SQLServer $SQLServer -SQLInstanceName $SQLInstanceName -AuthorizedUser "NT AUTHORITY\SYSTEM" -SetupCredential $SetupCredential
New-ListenerADObject -AvailabilityGroupNameListener $AvailabilityGroupNameListener -SetupCredential $SetupCredential
Switch ($Ensure)
{
"Present"
{
Grant-ServerPerms -SQLServer $SQLServer -SQLInstanceName $SQLInstanceName -AuthorizedUser "NT AUTHORITY\SYSTEM" -SetupCredential $SetupCredential
New-ListenerADObject -AvailabilityGroupNameListener $AvailabilityGroupNameListener -SetupCredential $SetupCredential

$FailoverCondition = 3
$HealthCheckTimeout = 30000
$ConnectionModeInPrimary ="AllowAllConnections"
$ConnectionModeInSecondaryRole = switch ($ReadableSecondary)
$FailoverCondition = 3
$HealthCheckTimeout = 30000
$ConnectionModeInPrimary ="AllowAllConnections"
$ConnectionModeInSecondaryRole = switch ($ReadableSecondary)
{
'None' {"AllowNoConnections"}
'ReadOnly' {"AllowAllConnections"}
'ReadIntent'{"AllowReadIntentConnectionsOnly"}
Default {"AllowAllConnections"}
}

#Get Servers participating in the cluster
#First two nodes will account for Syncronous Automatic Failover, Any additional will be Asyncronous
try
{
#Get Servers participating in the cluster
#First two nodes will account for Syncronous Automatic Failover, Any additional will be Asyncronous
try
{
$nodes= Get-ClusterNode -cluster $sql.ClusterName -Verbose:$false | select -ExpandProperty name
$syncNodes = $nodes | Select-Object -First 2
$asyncNodes = $nodes | Select-Object -Skip 2
$availabilityGroup = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroup -ArgumentList $SQL, $AvailabilityGroupName
$availabilityGroup.AutomatedBackupPreference="Primary"
$availabilityGroup.AutomatedBackupPreference = $AutoBackupPreference
$availabilityGroup.FailureConditionLevel = $FailoverCondition
$availabilityGroup.HealthCheckTimeout =$HealthCheckTimeout
}
Catch
{
$availabilityGroup.HealthCheckTimeout = $HealthCheckTimeout
}
Catch
{
Throw "Failed to connect to Cluster Nodes from $sql.ClusterName"
Exit
}
}

#Loop through Sync nodes Create Replica Object Assign properties and add it to AvailabilityGroup
foreach ($node in $syncNodes)
{
Try
{
#Loop through Sync nodes Create Replica Object Assign properties and add it to AvailabilityGroup
foreach ($node in $syncNodes)
{
Try
{
$Replica = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityReplica -ArgumentList $availabilityGroup, $node
$Replica.EndpointUrl = "TCP://$($node):5022"
$Replica.EndpointUrl = "TCP://$($node):$EndPointPort"
$Replica.FailoverMode = [Microsoft.SqlServer.Management.Smo.AvailabilityReplicaFailoverMode]::Automatic
$Replica.AvailabilityMode = [Microsoft.SqlServer.Management.Smo.AvailabilityReplicaAvailabilityMode]::SynchronousCommit
#Backup Priority Gives the ability to set a priority of one secondany over another valid values are from 1 - 100
$Replica.BackupPriority = 50
$Replica.BackupPriority = $BackupPriority
$Replica.ConnectionModeInPrimaryRole = $ConnectionModeInPrimary
$replica.ConnectionModeInSecondaryRole = $ConnectionModeInSecondaryRole
$availabilityGroup.AvailabilityReplicas.Add($Replica)
Expand All @@ -171,98 +177,98 @@ function Set-TargetResource
Exit
}

}
}

#Loop through ASync nodes Create Replica Object Assign properties and add it to AvailabilityGroup
foreach ($node in $AsyncNodes)
{
Try
{
#Loop through ASync nodes Create Replica Object Assign properties and add it to AvailabilityGroup
foreach ($node in $AsyncNodes)
{
Try
{
$asyncReplica = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityReplica -ArgumentList $availabilityGroup, $node
$asyncReplica.EndpointUrl = "TCP://$($node):5022"
$asyncReplica.EndpointUrl = "TCP://$($node):$EndPointPort"
$asyncReplica.FailoverMode = [Microsoft.SqlServer.Management.Smo.AvailabilityReplicaFailoverMode]::Manual
$asyncReplica.AvailabilityMode = [Microsoft.SqlServer.Management.Smo.AvailabilityReplicaAvailabilityMode]::ASynchronousCommit
$asyncReplica.BackupPriority = 50
$asyncReplica.BackupPriority = $BackupPriority
$asyncReplica.ConnectionModeInPrimaryRole = $ConnectionModeInPrimary
$asyncReplica.ConnectionModeInSecondaryRole = $ConnectionModeInSecondaryRole
$AvailabilityGroup.AvailabilityReplicas.Add($asyncReplica)
}
Catch
{
}
Catch
{
Write-Error "Failed to add $asyncReplica to the Availability Group $AvailabilityGroupName"
}
}
}
}

Try{
$AgListener = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListener -ArgumentList $AvailabilityGroup, $AvailabilityGroupNameListener
$AgListener.PortNumber =$AvailabilityGroupPort
Try{
$AgListener = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListener -ArgumentList $AvailabilityGroup, $AvailabilityGroupNameListener
$AgListener.PortNumber =$AvailabilityGroupPort
}
Catch{
Write-Error -Message ((Get-Date -format yyyy-MM-dd_HH-mm-ss) + ": Failed to Create AG Listener Object");
}
Catch{
Write-Error -Message ((Get-Date -format yyyy-MM-dd_HH-mm-ss) + ": Failed to Create AG Listener Object");
}


If($AvailabilityGroupNameIP)
{
Foreach ($IP in $AvailabilityGroupNameIP)
{
$AgListenerIp = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListenerIPAddress -ArgumentList $AgListener
$AgListenerIp.IsDHCP = $false
$AgListenerIp.IPAddress = $IP
$AgListenerIp.SubnetMask = $AvailabilityGroupSubMask
$AgListener.AvailabilityGroupListenerIPAddresses.Add($AgListenerIp)
New-VerboseMessage -Message "Added Static IP $IP to $AvailabilityGroupNameListener..."
If($AvailabilityGroupNameIP)
{
Foreach ($IP in $AvailabilityGroupNameIP)
{
$AgListenerIp = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListenerIPAddress -ArgumentList $AgListener
$AgListenerIp.IsDHCP = $false
$AgListenerIp.IPAddress = $IP
$AgListenerIp.SubnetMask = $AvailabilityGroupSubMask
$AgListener.AvailabilityGroupListenerIPAddresses.Add($AgListenerIp)
New-VerboseMessage -Message "Added Static IP $IP to $AvailabilityGroupNameListener..."

}
}
Else
{
#Utilize Dynamic IP since no Ip was passed
$AgListenerIp = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListenerIPAddress -ArgumentList $AgListener
$AgListenerIp.IsDHCP = $true
$AgListener.AvailabilityGroupListenerIPAddresses.Add($AgListenerIp)
New-VerboseMessage -Message "Added DynamicIP to $AvailabilityGroupNameListener..."
}
}
}
Else
{
#Utilize Dynamic IP since no Ip was passed
$AgListenerIp = New-Object -typename Microsoft.SqlServer.Management.Smo.AvailabilityGroupListenerIPAddress -ArgumentList $AgListener
$AgListenerIp.IsDHCP = $true
$AgListener.AvailabilityGroupListenerIPAddresses.Add($AgListenerIp)
New-VerboseMessage -Message "Added DynamicIP to $AvailabilityGroupNameListener..."
}

Try{
$AvailabilityGroup.AvailabilityGroupListeners.Add($AgListener);
Try{
$AvailabilityGroup.AvailabilityGroupListeners.Add($AgListener);
}
Catch{
Throw "Failed to Add $AvailabilityGroupNameListener to $AvailabilityGroupName..."
Catch{
Throw "Failed to Add $AvailabilityGroupNameListener to $AvailabilityGroupName..."
Exit
}

#Add Availabilty Group to the SQL connection
Try{
#Add Availabilty Group to the SQL connection
Try{
$SQL.AvailabilityGroups.Add($availabilityGroup)
New-VerboseMessage -Message "Added $availabilityGroupName Availability Group to Connection"
}
Catch{
Catch{
Throw "Unable to Add $AvailabilityGroup to $SQLServer\$SQLInstanceName"
Exit
}

#Create Availability Group
Try
#Create Availability Group
Try
{
$availabilityGroup.Create()
New-VerboseMessage -Message "Created Availability Group $availabilityGroupName"
}
Catch
Catch
{
Throw "Unable to Create $AvailabilityGroup on $SQLServer\$SQLInstanceName"
Exit
}

}
"Absent"
{
Try
}
"Absent"
{
Try
{
$sql.AvailabilityGroups[$AvailabilityGroupName].Drop()
NNew-VerboseMessage -Message "Dropped $AvailabilityGroupName"
}
Catch{
Catch{
Throw "Unable to Drop $AvailabilityGroup on $SQLServer\$SQLInstanceName"
}
}
Expand All @@ -280,7 +286,7 @@ function Test-TargetResource
param
(
[parameter(Mandatory = $true)]
[ValidateSet("Present","Absent")]
[ValidateSet("Present", "Absent")]
[System.String]
$Ensure,

Expand All @@ -300,19 +306,25 @@ function Test-TargetResource
[System.UInt32]
$AvailabilityGroupPort,

[ValidateSet("None","ReadOnly","ReadIntent")]
[ValidateSet("None", "ReadOnly", "ReadIntent")]
[System.String]
$ReadableSecondary ="ReadOnly",

[ValidateSet("Primary","Secondary")]
[ValidateSet("Primary", "Secondary")]
[System.String]
$AutoBackupPrefernce="Primary",
$AutoBackupPreference = "Primary",

[System.UInt32]
$BackupPriority = "50",

[System.UInt32]
$EndPointPort = "5022",

[System.String]
$SQLServer = $env:COMPUTERNAME,

[System.String]
$SQLInstanceName= "MSSQLSERVER",
$SQLInstanceName = "MSSQLSERVER",

[parameter(Mandatory = $true)]
[System.Management.Automation.PSCredential]
Expand Down
36 changes: 19 additions & 17 deletions DSCResources/MSFT_xSQLAOGroupEnsure/MSFT_xSQLAOGroupEnsure.schema.mof
View file
Original file line number Diff line number Diff line change
@@ -1,17 +1,19 @@

[ClassVersion("1.0.0.0"), FriendlyName("xSQLAOGroupEnsure")]
class MSFT_xSQLAOGroupEnsure : OMI_BaseResource
{
[Key, ValueMap{"Present","Absent"}, Values{"Present","Absent"}] String Ensure;
[Key] String AvailabilityGroupName;
[Write] String AvailabilityGroupNameListener;
[Write] String AvailabilityGroupNameIP[];
[Write] String AvailabilityGroupSubMask[];
[Write] Uint32 AvailabilityGroupPort;
[Write, ValueMap{"None","ReadOnly","ReadIntent"}, Values{"None","ReadOnly","ReadIntent"}] String ReadableSecondary;
[Write, ValueMap{"Primary","Secondary"}, Values{"Primary","Secondary"}] String AutoBackupPrefernce;
[Write] String SQLServer;
[Write] String SQLInstanceName;
[Required, EmbeddedInstance("MSFT_Credential"), Description("Credential to be used to Grant Permissions in SQL.")] String SetupCredential;
};


[ClassVersion("1.0.0.0"), FriendlyName("xSQLAOGroupEnsure")]
class MSFT_xSQLAOGroupEnsure : OMI_BaseResource
{
[Key, ValueMap{"Present","Absent"}, Values{"Present","Absent"}] String Ensure;
[Key] String AvailabilityGroupName;
[Write] String AvailabilityGroupNameListener;
[Write] String AvailabilityGroupNameIP[];
[Write] String AvailabilityGroupSubMask[];
[Write] Uint32 AvailabilityGroupPort;
[Write, ValueMap{"None","ReadOnly","ReadIntent"}, Values{"None","ReadOnly","ReadIntent"}] String ReadableSecondary;
[Write, ValueMap{"Primary","Secondary"}, Values{"Primary","Secondary"}] String AutoBackupPreference;
[Write] Uint32 BackupPriority;
[Write] Uint32 EndPointPort;
[Write] String SQLServer;
[Write] String SQLInstanceName;
[Required, EmbeddedInstance("MSFT_Credential"), Description("Credential to be used to Grant Permissions in SQL.")] String SetupCredential;
};

Loading

0 comments on commit 054ca54

Please sign in to comment.