1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00

adding sqldatabase facts (#43324)

This commit is contained in:
Zim Kalinowski 2019-02-19 13:09:53 +08:00 committed by GitHub
parent 3316f00131
commit fbf4e32b43
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 373 additions and 0 deletions

View file

@ -0,0 +1,286 @@
#!/usr/bin/python
#
# Copyright (c) 2019 Zim Kalinowski, (@zikalino)
#
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
from __future__ import absolute_import, division, print_function
__metaclass__ = type
ANSIBLE_METADATA = {'metadata_version': '1.1',
'status': ['preview'],
'supported_by': 'community'}
DOCUMENTATION = '''
---
module: azure_rm_sqldatabase_facts
version_added: "2.8"
short_description: Get Azure SQL Database facts.
description:
- Get facts of Azure SQL Database.
options:
resource_group:
description:
- The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.
required: True
server_name:
description:
- The name of the server.
required: True
name:
description:
- The name of the database.
elastic_pool_name:
description:
- The name of the elastic pool.
tags:
description:
- Limit results by providing a list of tags. Format tags as 'key' or 'key:value'.
extends_documentation_fragment:
- azure
author:
- "Zim Kalinowski (@zikalino)"
'''
EXAMPLES = '''
- name: Get instance of SQL Database
azure_rm_sqldatabase_facts:
resource_group: testrg
server_name: testserver
name: testdb
- name: List instances of SQL Database
azure_rm_sqldatabase_facts:
resource_group: testrg
server_name: testserver
elastic_pool_name: testep
- name: List instances of SQL Database
azure_rm_sqldatabase_facts:
resource_group: testrg
server_name: testserver
'''
RETURN = '''
databases:
description: A list of dictionaries containing facts for SQL Database.
returned: always
type: complex
contains:
id:
description:
- Resource ID.
returned: always
type: str
sample: /subscriptions/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/resourceGroups/testrg/providers/Microsoft.Sql/servers/testserver/databases/testdb
name:
description:
- Database name.
returned: always
type: str
sample: testdb
location:
description:
- Resource location.
returned: always
type: str
sample: southeastasia
tags:
description:
- Resource tags.
returned: always
type: dict
sample:
taga: aaa
tagb: bbb
sku:
description:
- The name and tier of the SKU.
returned: always
type: complex
sample: sku
contains:
name:
description:
- The name of the SKU.
returned: always
type: str
sample: BC_Gen4_2
tier:
description:
- Service tier.
returned: always
type: str
sample: BusinessCritical
capacity:
description:
- Capacity.
returned: always
type: int
sample: 2
kind:
description:
- Kind of database. This is metadata used for the Azure portal experience.
returned: always
type: str
sample: v12.0,user
collation:
description:
- The collation of the database.
returned: always
type: str
sample: SQL_Latin1_General_CP1_CI_AS
status:
description:
- The status of the database.
returned: always
type: str
sample: Online
zone_redundant:
description:
- Whether or not this database is zone redundant, which means the replicas of this database will be spread across multiple availability zones.
returned: always
type: bool
sample: true
'''
from ansible.module_utils.azure_rm_common import AzureRMModuleBase
try:
from msrestazure.azure_exceptions import CloudError
from azure.mgmt.sql import SqlManagementClient
from msrest.serialization import Model
except ImportError:
# This is handled in azure_rm_common
pass
class AzureRMSqlDatabaseFacts(AzureRMModuleBase):
def __init__(self):
# define user inputs into argument
self.module_arg_spec = dict(
resource_group=dict(
type='str',
required=True
),
server_name=dict(
type='str',
required=True
),
name=dict(
type='str'
),
elastic_pool_name=dict(
type='str'
),
tags=dict(
type='list'
)
)
# store the results of the module operation
self.results = dict(
changed=False
)
self.resource_group = None
self.server_name = None
self.name = None
self.elastic_pool_name = None
self.tags = None
super(AzureRMSqlDatabaseFacts, self).__init__(self.module_arg_spec, supports_tags=False)
def exec_module(self, **kwargs):
for key in self.module_arg_spec:
setattr(self, key, kwargs[key])
if self.name is not None:
self.results['databases'] = self.get()
elif self.elastic_pool_name is not None:
self.results['databases'] = self.list_by_elastic_pool()
else:
self.results['databases'] = self.list_by_server()
return self.results
def get(self):
response = None
results = []
try:
response = self.sql_client.databases.get(resource_group_name=self.resource_group,
server_name=self.server_name,
database_name=self.name)
self.log("Response : {0}".format(response))
except CloudError as e:
self.log('Could not get facts for Databases.')
if response and self.has_tags(response.tags, self.tags):
results.append(self.format_item(response))
return results
def list_by_elastic_pool(self):
response = None
results = []
try:
response = self.sql_client.databases.list_by_elastic_pool(resource_group_name=self.resource_group,
server_name=self.server_name,
elastic_pool_name=self.elastic_pool_name)
self.log("Response : {0}".format(response))
except CloudError as e:
self.fail('Could not get facts for Databases.')
if response is not None:
for item in response:
if self.has_tags(item.tags, self.tags):
results.append(self.format_item(item))
return results
def list_by_server(self):
response = None
results = []
try:
response = self.sql_client.databases.list_by_server(resource_group_name=self.resource_group,
server_name=self.server_name)
self.log("Response : {0}".format(response))
except CloudError as e:
self.fail('Could not get facts for Databases.')
if response is not None:
for item in response:
if self.has_tags(item.tags, self.tags):
results.append(self.format_item(item))
return results
def format_item(self, item):
d = item.as_dict()
d = {
'resource_group': self.resource_group,
'id': d.get('id', None),
'name': d.get('name', None),
'location': d.get('location', None),
'tags': d.get('tags', None),
'sku': {
'name': d.get('sku', {}).get('name', None),
'tier': d.get('sku', {}).get('tier', None),
'capacity': d.get('sku', {}).get('capacity', None)
},
'kind': d.get('kind', None),
'collation': d.get('collation', None),
'status': d.get('status', None),
'zone_redundant': d.get('zone_redundant', None)
}
return d
def main():
AzureRMSqlDatabaseFacts()
if __name__ == '__main__':
main()

View file

@ -3,4 +3,6 @@ destructive
shippable/azure/group4
azure_rm_sqlserver_facts
azure_rm_sqldatabase
azure_rm_sqldatabase_facts
azure_rm_sqlfirewallrule
azure_rm_sqlfirewallrule_facts

View file

@ -137,6 +137,67 @@
- output.changed == false
- output.status == 'Online'
# test database facter:
- name: Create second SQL Database
azure_rm_sqldatabase:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
name: database{{ random_postfix }}second
location: eastus
- name: Gather facts SQL Database
azure_rm_sqldatabase_facts:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
name: database{{ random_postfix }}
register: output
- name: Assert that facts are returned
assert:
that:
- output.changed == False
- output.databases[0].id != None
- output.databases[0].name != None
- output.databases[0].location != None
- output.databases[0].sku.name != None
- output.databases[0].sku.tier != None
- output.databases[0].sku.capacity != None
- output.databases[0].kind != None
- output.databases[0].status != None
- name: Gather facts SQL Database
azure_rm_sqldatabase_facts:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
register: output
- name: Assert that facts are returned
assert:
that:
- output.changed == False
- output.databases[0].id != None
- output.databases[0].name != None
- output.databases[0].location != None
- output.databases[0].sku.name != None
- output.databases[0].sku.tier != None
- output.databases[0].sku.capacity != None
- output.databases[0].kind != None
- output.databases[0].status != None
- output.databases[1].id != None
- output.databases[1].name != None
- output.databases[1].location != None
- output.databases[1].sku.name != None
- output.databases[1].sku.tier != None
- output.databases[1].sku.capacity != None
- output.databases[1].kind != None
- output.databases[1].status != None
- name: Delete instance of secondary database
azure_rm_sqldatabase:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
name: database{{ random_postfix }}second
state: absent
# clean up databases
- name: Delete instance of SQL Database -- check mode
azure_rm_sqldatabase:
resource_group: "{{ resource_group }}"
@ -174,6 +235,30 @@
that:
- output.changed == false
# test database facts without databases
- name: Gather facts SQL Database
azure_rm_sqldatabase_facts:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
name: database{{ random_postfix }}
register: output
- name: Assert that empty dictionary was returned
assert:
that:
- output.changed == False
- output.databases | length == 0
- name: Gather facts SQL Database
azure_rm_sqldatabase_facts:
resource_group: "{{ resource_group }}"
server_name: sqlsrv{{ random_postfix }}
register: output
- name: Assert that empty dictionary was returned (one database is there by default)
assert:
that:
- output.changed == False
- output.databases | length == 1
# azure_rm_sqlfirewallrule tests
- name: Create instance of Firewall Rule -- check mode