VhnddlmZmZmZeZdZdZdZddl m Z ddl m Z ddl mZddlmZdd lmZmZmZmZmZmZmZmZd Zd Zd Zd ZdZGddZdZ e!dk(re yy))absolute_importdivisionprint_functiona[ --- module: postgresql_subscription short_description: Add, update, or remove PostgreSQL subscription description: - Add, update, or remove PostgreSQL subscription. version_added: '0.2.0' options: name: description: - Name of the subscription to add, update, or remove. type: str required: true login_db: description: - Name of the database to connect to and where the subscription state will be changed. - The V(db) alias is deprecated and will be removed in version 5.0.0. aliases: [ db ] type: str required: true state: description: - The subscription state. - C(present) implies that if I(name) subscription doesn't exist, it will be created. - C(absent) implies that if I(name) subscription exists, it will be removed. - C(refresh) implies that if I(name) subscription exists, it will be refreshed. Fetch missing table information from publisher. Always returns ``changed`` is ``True``. This will start replication of tables that were added to the subscribed-to publications since the last invocation of REFRESH PUBLICATION or since CREATE SUBSCRIPTION. The existing data in the publications that are being subscribed to should be copied once the replication starts. - For more information about C(refresh) see U(https://www.postgresql.org/docs/current/sql-altersubscription.html). type: str choices: [ absent, present, refresh ] default: present owner: description: - Subscription owner. - If I(owner) is not defined, the owner will be set as I(login_user) or I(session_role). - Ignored when I(state) is not C(present). type: str publications: description: - The publication names on the publisher to use for the subscription. - Ignored when I(state) is not C(present). type: list elements: str connparams: description: - The connection dict param-value to connect to the publisher. - For more information see U(https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-CONNSTRING). - Ignored when I(state) is not C(present). - Ignored when an existing subscription's connection parameters are not available from the server (such as in CloudSQL). type: dict cascade: description: - Drop subscription dependencies. Has effect with I(state=absent) only. - Ignored when I(state) is not C(absent). type: bool default: false subsparams: description: - Dictionary of optional parameters for a subscription, e.g. copy_data, enabled, create_slot, etc. - For update the subscription allowed keys are C(enabled), C(slot_name), C(synchronous_commit), C(publication_name). - See available parameters to create a new subscription on U(https://www.postgresql.org/docs/current/sql-createsubscription.html). - Ignored when I(state) is not C(present). type: dict session_role: description: - Switch to session_role after connecting. The specified session_role must be a role that the current login_user is a member of. - Permissions checking for SQL commands is carried out as though the session_role were the one that had logged in originally. type: str version_added: '0.2.0' trust_input: description: - If C(false), check whether values of parameters I(name), I(publications), I(owner), I(session_role), I(connparams), I(subsparams) are potentially dangerous. - It makes sense to use C(true) only when SQL injections via the parameters are possible. type: bool default: true version_added: '0.2.0' comment: description: - Sets a comment on the subscription. - To reset the comment, pass an empty string. type: str version_added: '3.3.0' notes: - PostgreSQL version must be 10 or greater. attributes: check_mode: support: full seealso: - module: community.postgresql.postgresql_publication - module: community.postgresql.postgresql_info - name: CREATE SUBSCRIPTION reference description: Complete reference of the CREATE SUBSCRIPTION command documentation. link: https://www.postgresql.org/docs/current/sql-createsubscription.html - name: ALTER SUBSCRIPTION reference description: Complete reference of the ALTER SUBSCRIPTION command documentation. link: https://www.postgresql.org/docs/current/sql-altersubscription.html - name: DROP SUBSCRIPTION reference description: Complete reference of the DROP SUBSCRIPTION command documentation. link: https://www.postgresql.org/docs/current/sql-dropsubscription.html author: - Andrew Klychkov (@Andersson007) extends_documentation_fragment: - community.postgresql.postgres a+ - name: > Create acme subscription in mydb database using acme_publication and the following connection parameters to connect to the publisher. Set the subscription owner as alice. community.postgresql.postgresql_subscription: login_db: mydb name: acme state: present publications: acme_publication owner: alice connparams: host: 127.0.0.1 port: 5432 user: repl password: replpass dbname: mydb comment: Made by Ansible - name: Assuming that acme subscription exists, try to change conn parameters community.postgresql.postgresql_subscription: login_db: mydb name: acme connparams: host: 127.0.0.1 port: 5432 user: repl password: replpass connect_timeout: 100 - name: Refresh acme publication community.postgresql.postgresql_subscription: db: mydb name: acme state: refresh - name: Drop acme subscription from mydb with dependencies (cascade=true) community.postgresql.postgresql_subscription: login_db: mydb name: acme state: absent cascade: true - name: Assuming that acme subscription exists and enabled, disable the subscription community.postgresql.postgresql_subscription: login_db: mydb name: acme state: present subsparams: enabled: false a0 name: description: - Name of the subscription. returned: success type: str sample: acme exists: description: - Flag indicates the subscription exists or not at the end of runtime. returned: success type: bool sample: true queries: description: List of executed queries. returned: success type: str sample: [ 'DROP SUBSCRIPTION "mysubscription"' ] initial_state: description: Subscription configuration at the beginning of runtime. returned: success type: dict sample: {"conninfo": {}, "enabled": true, "owner": "postgres", "slotname": "test", "synccommit": true} final_state: description: Subscription configuration at the end of runtime. returned: success type: dict sample: {"conninfo": {}, "enabled": true, "owner": "postgres", "slotname": "test", "synccommit": true} )deepcopy) AnsibleModule) iteritems) check_input) connect_to_dbensure_required_libsexec_sqlget_conn_paramsget_server_versionpg_cursor_argspostgres_common_argument_spec set_commenti')enabledsynchronous_commit slot_nameczg}t|D]\}}|j|d|dj|S)zConverts the passed connection dictionary to string. Args: conn_dict (list): Dictionary which needs to be converted. Returns: Connection string. = rappendjoin) conn_dict conn_listparamvals /home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/postgresql/plugins/modules/postgresql_subscription.pyconvert_conn_paramsr sEI!),1 E3/01 88I cg}t|D](\}}|durd}n|durd}|j|d|*dj|S)zConverts the passed params dictionary to string. Args: params_dict (list): Dictionary which needs to be converted. Returns: Parameters string. FfalseTtrue = , r) params_dict params_listrrs rconvert_subscr_paramsr)s]K!+.5  %<C D[Cs34 5 99[ !!r!crt|D]\}} t|||<|S#t$r|||<Y)wxYw)zPCast the passed connparams_dict dictionary Returns: Dictionary )rint ValueError)connparams_dictrrs rcast_connparamsr.sR "/2)  )%(XOE ")  )%(OE " )s %66ceZdZdZdZdZdZddZddZddZ ddZ dd Z dd Z dd Z dd Zdd ZddZdZddZy)PgSubscriptionaClass to work with PostgreSQL subscription. Args: module (AnsibleModule): Object of AnsibleModule class. cursor (cursor): Cursor object of psycopg library to work with PostgreSQL. name (str): The name of the subscription. db (str): The database name the subscription will be associated with. Attributes: module (AnsibleModule): Object of AnsibleModule class. cursor (cursor): Cursor object of psycopg library to work with PostgreSQL. name (str): Name of subscription. executed_queries (list): List of executed queries. attrs (dict): Dict with subscription attributes. exists (bool): Flag indicates the subscription exists or not. c||_||_||_||_g|_dddidgdd|_t |j |_|j|_ y)N)ownerr synccommitconninfoslotname publicationscomment) modulecursornamedbexecuted_queriesattrsr empty_attrs check_subscrexists)selfr8r9r:r;s r__init__zPgSubscription.__init__6sg    "  $DJJ/'') r!cD|j|_|jS)z\Refresh the subscription information. Returns: ``self.attrs``. )r?r@r=)rAs rget_infozPgSubscription.get_infoHs '') zzr!c|j}|st|j|_y|j d|jd<|j d|jd<|j d|jd<|j d|jd<|j d |jd <|j d |j d |jd <nd |jd <|j d rL|d j dD]5}|j d} t |d|jd|d<7y#t$r|d|jd|d<Y\wxYw)zCheck the subscription and refresh ``self.attrs`` subscription attribute. Returns: True if the subscription with ``self.name`` exists, False otherwise. Frolnamer2 subenabledrr3 subslotnamer5subpublicationsr6r7 subconninforrr4rT)(_PgSubscription__get_general_subscr_inforr>r=getsplitr+r,)rA subscr_infortmps rr?zPgSubscription.check_subscrQsb446 !$"2"23DJ)ooi8 7 + = 9#.??<#@ < !,!? :%0__5F%G >" ??9 % 1$/OOI$>DJJy !%'DJJy ! ??= )$]399#> <kk#&<58Q[DJJz*3q62 <"<58VDJJz*3q62DIu<E3dii?Eu<N!N0 0< "))**6*45;5F5F*HG !!*-3!0!rsA@ v p2 h <4.   K  "* U;U;z X.v zFr!