VhMddlmZmZmZeZdZdZdZddl Z ddl m Z ddl m Z ddlmZdd lmZmZmZmZmZmZmZgZd Zd Zd Zd ZdZdZedk(reyy))absolute_importdivisionprint_functiona --- module: postgresql_ext short_description: Add or remove PostgreSQL extensions from a database description: - Add or remove PostgreSQL extensions from a database. options: name: description: - Name of the extension to add or remove. required: true type: str aliases: - ext login_db: description: - Name of the database to add or remove the extension to/from. - The V(db) alias is deprecated and will be removed in version 5.0.0. required: true type: str aliases: - db schema: description: - Name of the schema to add the extension to. type: str 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 state: description: - The database extension state. default: present choices: [ absent, present ] type: str cascade: description: - Automatically install/remove any extensions that this extension depends on that are not already installed/removed (supported since PostgreSQL 9.6). type: bool default: false login_unix_socket: description: - Path to a Unix domain socket for local connections. type: str ssl_mode: description: - Determines whether or with what priority a secure SSL TCP/IP connection will be negotiated with the server. - See U(https://www.postgresql.org/docs/current/static/libpq-ssl.html) for more information on the modes. - Default of C(prefer) matches libpq default. type: str default: prefer choices: [ allow, disable, prefer, require, verify-ca, verify-full ] ca_cert: description: - Specifies the name of a file containing SSL certificate authority (CA) certificate(s). - If the file exists, the server's certificate will be verified to be signed by one of these authorities. type: str aliases: [ ssl_rootcert ] version: description: - Extension version to add or update to. Has effect with I(state=present) only. - If not specified and extension is not installed in the database, the latest version available will be created. - If extension is already installed, will update to the given version if a valid update path exists. - Downgrading is only supported if the extension provides a downgrade path otherwise the extension must be removed and a lower version of the extension must be made available. - Set I(version=latest) to update the extension to the latest available version. type: str trust_input: description: - If C(false), check whether values of parameters I(ext), I(schema), I(version), I(session_role) are potentially dangerous. - It makes sense to use C(false) 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 extension. - To reset the comment, pass an empty string. type: str version_added: '3.3.0' seealso: - name: PostgreSQL extensions description: General information about PostgreSQL extensions. link: https://www.postgresql.org/docs/current/external-extensions.html - name: CREATE EXTENSION reference description: Complete reference of the CREATE EXTENSION command documentation. link: https://www.postgresql.org/docs/current/sql-createextension.html - name: ALTER EXTENSION reference description: Complete reference of the ALTER EXTENSION command documentation. link: https://www.postgresql.org/docs/current/sql-alterextension.html - name: DROP EXTENSION reference description: Complete reference of the DROP EXTENSION command documentation. link: https://www.postgresql.org/docs/current/sql-droppublication.html notes: - Incomparable versions, for example PostGIS ``unpackaged``, cannot be installed. attributes: check_mode: support: full author: - Daniel Schep (@dschep) - Thomas O'Donnell (@andytom) - Sandro Santilli (@strk) - Andrew Klychkov (@Andersson007) - Keith Fiske (@keithf4) - Daniele Giudice (@RealGreenDragon) extends_documentation_fragment: - community.postgresql.postgres a - name: Adds postgis extension to the database acme in the schema foo community.postgresql.postgresql_ext: name: postgis login_db: acme schema: foo comment: Test extension - name: Removes postgis extension to the database acme community.postgresql.postgresql_ext: name: postgis login_db: acme state: absent - name: Adds earthdistance extension to the database template1 cascade community.postgresql.postgresql_ext: name: earthdistance login_db: template1 cascade: true # In the example below, if earthdistance extension is installed, # it will be removed too because it depends on cube: - name: Removes cube extension from the database acme cascade community.postgresql.postgresql_ext: name: cube login_db: acme cascade: true state: absent - name: Create extension foo of version 1.2 or update it to that version if it's already created and a valid update path exists community.postgresql.postgresql_ext: login_db: acme name: foo version: 1.2 - name: Create the latest available version of extension foo. If already installed, update it to the latest version community.postgresql.postgresql_ext: login_db: acme name: foo version: latest a queries: description: List of executed queries. returned: success type: list sample: ["DROP EXTENSION \"acme\""] prev_version: description: Previous installed extension version or empty string if the extension was not installed. returned: success type: str sample: '1.0' version_added: '3.1.0' version: description: Current installed extension version or empty string if the extension is not installed. returned: success type: str sample: '2.0' version_added: '3.1.0' N) to_native) AnsibleModule) check_input) connect_to_dbensure_required_libs get_commentget_conn_paramspg_cursor_argspostgres_common_argument_spec set_commentcd|z}|r|dz }|s|j|tj|j|y)zRemove the extension from the database. Return True if success. Args: cursor (cursor) -- cursor object of psycopg library ext (str) -- extension name cascade (boolean) -- Pass the CASCADE flag to the DROP command zDROP EXTENSION "%s" CASCADETexecuteexecuted_queriesappendmogrify) check_modecursorextcascadequerys w/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/postgresql/plugins/modules/postgresql_ext.py ext_deletersD $c )E  uFNN512 cd|z}i}|dk7r |dz }||d<|s|j||tj|j||y)zUpdate extension version. Return True if success. Args: cursor (cursor) -- cursor object of psycopg library ext (str) -- extension name version (str) -- extension version zALTER EXTENSION "%s" UPDATElatestz TO %(ver)sverTr)rrrversionrparamss rext_update_versionr$s[ ,c 1E F( u uf%FNN5&9: rcd|z}i}|r|d|zz }|dk7r |dz }||d<|r|dz }|s|j||tj|j||y)ai Create the extension objects inside the database. Return True if success. Args: cursor (cursor) -- cursor object of psycopg library ext (str) -- extension name schema (str) -- target schema for extension objects cascade (boolean) -- Pass the CASCADE flag to the CREATE command version (str) -- extension version zCREATE EXTENSION "%s"z WITH SCHEMA "%s"r z VERSION %(ver)sr!rTr)rrrschemarr"rr#s r ext_creater's| & +E F  &//( ##u   uf%FNN5&9: rcFd}d}i}||d<d}|j|||j}|r|d}d}|j|||j}|r|d}d}|j||td|jD}|d }|d }|||fS) am Get the currently created extension version if it is installed in the database, its default version (used to update to 'latest'), and versions that are available if it is installed on the system. Return tuple (current_version, default_version, [list of available versions]). Note: the list of available versions contains only versions that higher than the current created version. If the extension is not created, this list will contain all available versions. Args: cursor (cursor) -- cursor object of psycopg library ext (str) -- extension name NrzFSELECT extversion FROM pg_catalog.pg_extension WHERE extname = %(ext)s extversionzSSELECT default_version FROM pg_catalog.pg_available_extensions WHERE name = %(ext)sdefault_versionzSSELECT version FROM pg_catalog.pg_available_extension_versions WHERE name = %(ext)sc3&K|] }|d yw)r"N).0rs r z#ext_get_versions..XsEaQy\EsF)rfetchonesetfetchall)rrcurrent_versionr*r#rresavailable_versionss rext_get_versionsr6's$OO FF5M'E NN5&! // C l+$E NN5&! // C /0$E NN5&!E6??3DEE _.@ AArc|d}i}d}||d<||d<||d<|j|||j}|d}|S)a( Check to see if the installed extension version has a valid update path to the given version. Return True if a valid path exists. Otherwise return False. Note: 'latest' is not a valid value for version here as it can be replaced with default_version specified in extension control file. Args: cursor (cursor) -- cursor object of psycopg library ext (str) -- extension name current_version (str) -- installed version of the extension. version (str) -- target extension version to update to. Fz^SELECT path FROM pg_extension_update_paths(%(ext)s) WHERE source = %(cv)s AND target = %(ver)srcvr!T)rr0)rrr3r" valid_pathr#rr4s rext_valid_update_pathr:bs\"J F$EF5M"F4LF5M NN5&! // C  rcrt}|jtddgdddddgtdddg td tdd d d g tddtd td tddtdd t|d}|jd}|jd}|jd}|jd}|jd}|jd}|jd}|jd} d} |st |||||| |r|d k(r|j dt|t||j} t|| d\} } | jd.it} t||\}}}|r|dk(r/|s|jd|z|r|}n|jd n|}|d k(rs|r|r|k(rd} n,t||||}|r\|js7| j!t|| d\} } | jd.it}t#|j|||} n|dk(r|jd!|d"|d#n|jd$|d"|d%n|vr1|dk(r|jd&|znh|jd'|znRt%|j|||||} n7|rd} n2|rt%|j||||d} n|jd|z| Yt'|d(|}||nd)}| |k7rAt)|| d(||jt*} n"|d k(r|rt-|j|||} nd} t||\}}}|r|nd)}|jr| r|d k(r}n|d k(r d)}n|r|nd)}| j!|j7| |jd,|t*-y#t.$rK}| j!|jd*t1|zt3j4+Yd}~d}~wwxYw)/NstrdbTz5.0.0zcommunity.postgresql)namer"collection_name)typealiasesrequireddeprecated_aliasesr>)r@rBrA)r@presentabsent)r@defaultchoicesboolF)r@rF) login_dbrr&stater session_roler" trust_inputcomment) argument_specsupports_check_moderr&rJrr"rKrLrMz.Parameter version is ignored when state=absent) autocommitr zExtension %s is not available)msgzRPassed version 'latest' but no default_version available in extension control filezLatest version 'zA' has no valid update path from the currently installed version ''zPassed version 'z(' or the passed version is not availablez$Latest version '%s' is not availablez$Passed version '%s' is not available extensionz-Management of PostgreSQL extension failed: %s)rQ exceptionrI)changedr=r prev_versionr"queriesr,)rupdatedictrr#rwarnr r r rr r6 fail_jsonr:rcloser$r'r rrr Exceptionr traceback format_exc exit_json)rNmodulerr&rJrr"rKrLrMrV conn_params db_connectiondummyr curr_versionr*r5 real_versionvalid_update_pathcurrent_comment new_versionnew_default_versionnew_available_versionsout_prev_version out_versiones rmainrps13M54&4"#9 U  edVH =y8Y:OP&%0u%% fd3%.$# F -- C ]]8 $F MM' "EmmI&GmmI&G==0L-- .KmmI&GG FC,H5H$ DE !&&--8K(NM5 !] ! ! 3N 3Fl->VU\^e"f  #G*",V->->VU\^f"g((-Ls-R(S""-fk3"G5D5P/VXo-)&';VM^M^`pqG h $V%6%6WMDTTZ\_C`@ (*@,8r|sA@ w r( T (04,0>8Bv PfR zFr