Vh)ddlmZmZmZeZdZdZdZddl m Z ddl m Z ddl mZmZmZmZmZmZmZGdd eZd Zed k(rey y ) )absolute_importdivisionprint_functiona --- module: postgresql_slot short_description: Add or remove replication slots from a PostgreSQL database description: - Add or remove physical or logical replication slots from a PostgreSQL database. options: name: description: - Name of the replication slot to add or remove. type: str required: true aliases: - slot_name slot_type: description: - Slot type. type: str default: physical choices: [ logical, physical ] state: description: - The slot state. - I(state=present) implies the slot must be present in the system. - I(state=absent) implies the I(groups) must be revoked from I(target_roles). type: str default: present choices: [ absent, present ] immediately_reserve: description: - Optional parameter that when C(true) specifies that the LSN for this replication slot be reserved immediately, otherwise the default, C(false), specifies that the LSN is reserved on the first connection from a streaming replication client. - Is available from PostgreSQL version 9.6. - Uses only with I(slot_type=physical). - Mutually exclusive with I(slot_type=logical). type: bool default: false output_plugin: description: - All logical slots must indicate which output plugin decoder they're using. - This parameter does not apply to physical slots. - It will be ignored with I(slot_type=physical). type: str default: "test_decoding" login_db: description: - Name of database to connect to. - The V(db) alias is deprecated and will be removed in version 5.0.0. type: str aliases: - db 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 trust_input: description: - If C(false), check the value of I(session_role) is potentially dangerous. - It makes sense to use C(false) only when SQL injections via I(session_role) are possible. type: bool default: true version_added: '0.2.0' notes: - Physical replication slots were introduced to PostgreSQL with version 9.4, while logical replication slots were added beginning with version 10.0. attributes: check_mode: support: full seealso: - name: PostgreSQL pg_replication_slots view reference description: Complete reference of the PostgreSQL pg_replication_slots view. link: https://www.postgresql.org/docs/current/view-pg-replication-slots.html - name: PostgreSQL streaming replication protocol reference description: Complete reference of the PostgreSQL streaming replication protocol documentation. link: https://www.postgresql.org/docs/current/protocol-replication.html - name: PostgreSQL logical replication protocol reference description: Complete reference of the PostgreSQL logical replication protocol documentation. link: https://www.postgresql.org/docs/current/protocol-logical-replication.html author: - John Scalia (@jscalia) - Andrew Klychkov (@Andersson007) - Thomas O'Donnell (@andytom) extends_documentation_fragment: - community.postgresql.postgres az - name: Create physical_one physical slot if doesn't exist become_user: postgres community.postgresql.postgresql_slot: slot_name: physical_one login_db: ansible - name: Remove physical_one slot if exists become_user: postgres community.postgresql.postgresql_slot: slot_name: physical_one db: ansible state: absent - name: Create logical_one logical slot to the database acme if doesn't exist community.postgresql.postgresql_slot: name: logical_slot_one slot_type: logical state: present output_plugin: custom_decoder_one login_db: acme - name: Remove logical_one slot if exists from the cluster running on another host and non-standard port community.postgresql.postgresql_slot: name: logical_one login_host: mydatabase.example.org port: 5433 login_user: ourSuperuser login_password: thePassword state: absent a  name: description: Name of the slot. returned: success type: str sample: "physical_one" queries: description: List of executed queries. returned: success type: str sample: [ "SELECT pg_create_physical_replication_slot('physical_one', False, False)" ] ) AnsibleModule) check_input) connect_to_dbensure_required_libsexec_sqlget_conn_paramsget_server_versionpg_cursor_argspostgres_common_argument_specc&eZdZdZddZdZdZy)PgSlotc||_||_||_d|_d|_|j d|_g|_y)NF)modulecursornameexistskind_PgSlot__slot_existschangedexecuted_queries)selfrrrs x/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/postgresql/plugins/modules/postgresql_slot.py__init__zPgSlot.__init__s@       "c|jrG|j|k(ry|jjd|jd|jdy|ry|dk(rIt |j jdkrd}nd}t|||j|d d |_ y|d k(r$d }t|||j|dd |_ yy)NFzslot with name 'z'' already exists but has another type ''physicaliaz4SELECT pg_create_physical_replication_slot(%(name)s)zCSELECT pg_create_physical_replication_slot(%(name)s, %(i_reserve)s))r i_reserveT query_params return_boollogicalzASELECT pg_create_logical_replication_slot(%(name)s, %(o_plugin)s))ro_plugin) rrrwarnrr r connectionr r)rrimmediately_reserve output_plugin just_checkquerys rcreatez PgSlot.creates ;;yyD    @D 499"VW  : !$++"8"89EAN^#D%:>))Re1f046DLY WE#D%:>))Q^1_mqsDLrcb|jsyd}t||d|jid|_y)NFz)SELECT pg_drop_replication_slot(%(name)s)rTr#)rr rr)rr-s rdropz PgSlot.drops-{{;e6499:M[_` rcld}t||d|jid}|rd|_|dd|_yy)NzESELECT slot_type FROM pg_replication_slots WHERE slot_name = %(name)srF)r$add_to_executedTr slot_type)r rrr)rr-ress r __slot_existszPgSlot.__slot_existss@WtU&$))1DV[\ DKA{+DI rN)r!FFF)__name__ __module__ __qualname__rr.r0rrrrrs#s:a,rrcpt}|jtddgddddgtdddg tdd d d g td dtdtddtddddg td dt|d}|jd}|jd}|jd}|jd}|jd}|jdst ||jd|r|d k(r|j d|d k(rd}nd}t|t||j|}t||d \} } | jd#it} t|| |} d} |jr=|dk(r$| jsd} | j|||d!nN|dk(rI| jr=d} n:|dk(r| j!n|dk(r| j|||| j"} | j%|j'| || j("y)$Nstrdbz5.0.0zcommunity.postgresql)rversioncollection_name)typealiasesdeprecated_aliasesT slot_name)r?requiredr@r!r&)r?defaultchoicesboolF)r?rD)r? test_decodingpresentabsent)login_dbrr3r* session_roler+state trust_input) argument_specsupports_check_moderr3r*rLr+rMrKzRModule parameters immediately_reserve and slot_type=logical are mutually exclusive)msg)warn_db_default) autocommit)r,)rrqueriesr9)rupdatedictrparamsr fail_jsonr r rrr r check_moderr.r0rclose exit_jsonr)rNrrr3r*rLr+rQ conn_params db_connectiondummyrpg_slotrs rmainr_s<13M54&"#9 F utk] CE: :?VW fe<u%?y8Y:OPfd3"# F == D k*I --(=> MM' "EMM/2M == 'FFMM.9:yI5qrI !&&--YK(NM5 !] ! ! 3N 3FVVT*GG  I >> NN9&9=UYN Z h ~~ H  LLN i  NN9&9= I// W49Q9QRr__main__N) __future__rrrr? __metaclass__ DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicrFansible_collections.community.postgresql.plugins.module_utils.databaserFansible_collections.community.postgresql.plugins.module_utils.postgresrr r r r r robjectrr_r6r9rrrjsmA@ ] ~ @ 54,V4,xOSd zFr