VhOddlmZmZmZeZdZdZdZddl m Z ddl m Z m Z ddlmZmZmZmZmZmZGdd eZd Zed k(rey y ) )absolute_importdivisionprint_functiona --- module: postgresql_table short_description: Create, drop, or modify a PostgreSQL table description: - Allows to create, drop, truncate a table, or change some table attributes. options: table: description: - Table name. required: true aliases: - name type: str state: description: - The table state. I(state=absent) is mutually exclusive with I(tablespace), I(owner), I(unlogged), I(like), I(including), I(columns), I(truncate), I(storage_params) and, I(rename). type: str default: present choices: [ absent, present ] tablespace: description: - Set a tablespace for the table. type: str owner: description: - Set a table owner. type: str unlogged: description: - Create an unlogged table. type: bool default: false like: description: - Create a table like another table (with similar DDL). Mutually exclusive with I(columns), I(rename), and I(truncate). type: str including: description: - Keywords that are used with like parameter, may be DEFAULTS, CONSTRAINTS, INDEXES, STORAGE, COMMENTS or ALL. Needs I(like) specified. Mutually exclusive with I(columns), I(rename), and I(truncate). type: str columns: description: - Columns that are needed. type: list elements: str rename: description: - DEPRECATED (see the L(discussion,https://github.com/ansible-collections/community.postgresql/issues/820)). This option will be removed in version 5.0.0. To rename a table, use the M(community.postgresql.postgresql_query) module. - New table name. Mutually exclusive with I(tablespace), I(owner), I(unlogged), I(like), I(including), I(columns), I(truncate), and I(storage_params). type: str truncate: description: - Truncate a table. Mutually exclusive with I(tablespace), I(owner), I(unlogged), I(like), I(including), I(columns), I(rename), and I(storage_params). type: bool default: false storage_params: description: - Storage parameters like fillfactor, autovacuum_vacuum_treshold, etc. Mutually exclusive with I(rename) and I(truncate). type: list elements: str login_db: description: - Name of database to connect and where the table will be created. - The V(db) alias is deprecated and will be removed in version 5.0.0. type: str default: '' 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 cascade: description: - Automatically drop objects that depend on the table (such as views). Used with I(state=absent) only. type: bool default: false trust_input: description: - If C(false), check whether values of parameters are potentially dangerous. - It makes sense to use C(false) only when SQL injections are possible. type: bool default: true version_added: '0.2.0' notes: - If you do not pass db parameter, tables will be created in the database named postgres. - PostgreSQL allows to create columnless table, so columns param is optional. - Unlogged tables are available from PostgreSQL server version 9.1. - If the table already exists and columns are specified they will be ignored. Columns can not be altered on an existing table. attributes: check_mode: support: full seealso: - module: community.postgresql.postgresql_sequence - module: community.postgresql.postgresql_idx - module: community.postgresql.postgresql_info - module: community.postgresql.postgresql_tablespace - module: community.postgresql.postgresql_owner - module: community.postgresql.postgresql_privs - module: community.postgresql.postgresql_copy - name: CREATE TABLE reference description: Complete reference of the CREATE TABLE command documentation. link: https://www.postgresql.org/docs/current/sql-createtable.html - name: ALTER TABLE reference description: Complete reference of the ALTER TABLE command documentation. link: https://www.postgresql.org/docs/current/sql-altertable.html - name: DROP TABLE reference description: Complete reference of the DROP TABLE command documentation. link: https://www.postgresql.org/docs/current/sql-droptable.html - name: PostgreSQL data types description: Complete reference of the PostgreSQL data types documentation. link: https://www.postgresql.org/docs/current/datatype.html author: - Andrei Klychkov (@Andersson007) extends_documentation_fragment: - community.postgresql.postgres a - name: Create tbl2 in the acme database with the DDL like tbl1 with testuser as an owner community.postgresql.postgresql_table: login_db: acme name: tbl2 like: tbl1 owner: testuser - name: Create tbl2 in the acme database and tablespace ssd with the DDL like tbl1 including comments and indexes community.postgresql.postgresql_table: login_db: acme table: tbl2 like: tbl1 including: comments, indexes tablespace: ssd - name: Create test_table with several columns in ssd tablespace with fillfactor=10 and autovacuum_analyze_threshold=1 community.postgresql.postgresql_table: name: test_table columns: - id bigserial primary key - num bigint - stories text tablespace: ssd storage_params: - fillfactor=10 - autovacuum_analyze_threshold=1 - name: Create an unlogged table in schema acme community.postgresql.postgresql_table: name: acme.useless_data columns: waste_id int unlogged: true - name: Set owner to someuser community.postgresql.postgresql_table: name: foo owner: someuser - name: Change tablespace of foo table to new_tablespace and set owner to new_user community.postgresql.postgresql_table: name: foo tablespace: new_tablespace owner: new_user - name: Truncate table foo community.postgresql.postgresql_table: name: foo truncate: true - name: Drop table foo from schema acme community.postgresql.postgresql_table: name: acme.foo state: absent - name: Drop table bar cascade community.postgresql.postgresql_table: name: bar state: absent cascade: true - name: Create table with composite primary key community.postgresql.postgresql_table: name: composite_pk_table columns: - id bigserial - num bigint - primary key (id, num) a table: description: Name of a table. returned: success type: str sample: 'foo' state: description: Table state. returned: success type: str sample: 'present' owner: description: Table owner. returned: success type: str sample: 'postgres' tablespace: description: Tablespace. returned: success type: str sample: 'ssd_tablespace' queries: description: List of executed queries. returned: success type: str sample: [ 'CREATE TABLE "test_table" (id bigint)' ] storage_params: description: Storage parameters. returned: success type: list sample: [ "fillfactor=100", "autovacuum_analyze_threshold=1" ] ) AnsibleModule) check_inputpg_quote_identifier) connect_to_dbensure_required_libsexec_sqlget_conn_paramspg_cursor_argspostgres_common_argument_specc\eZdZdZdZdZ d dZ ddZdZdZ dZ dd Z d Z d Z y )Tablec||_||_||_ddgd|_d|_|j g|_y)Nownertblspacestorage_paramsF)namemodulecursorinfoexists_Table__exists_in_dbexecuted_queries)selfrrrs y/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/postgresql/plugins/modules/postgresql_table.py__init__zTable.__init__ sF         "c$|jy)z$Getter to refresh and get table infoN)r)rs rget_infozTable.get_infos r!crd|jvr=|jjdd}|jjdd}nd}|j}d}t||||dd}|rAd |_t |d d |d d r|d d nd |d dr|d dng|_y d|_y)z#Check table exists and refresh info.publicaSELECT t.tableowner, t.tablespace, c.reloptions FROM pg_tables AS t INNER JOIN pg_class AS c ON c.relname = t.tablename INNER JOIN pg_namespace AS n ON t.schemaname = n.nspname AND c.relnamespace = n.oid WHERE t.tablename = %(tblname)s AND n.nspname = %(schema)s)tblnameschemaF) query_paramsadd_to_executedTr tableowner tablespacer reloptionsr)rsplitr rdictr)rr*r)queryress r__exists_in_dbzTable.__exists_in_dbs $)) YY__S)"-Fiiooc*2.GFiiG. tUWPV1W',. DK!f\*14Q 1EQ -27:1vl7Ks1vl3QSDI DKr!ct|jd}d}|jr|dk(r|jdn'|r%|jd|k7r|j |d}|r%|jd|k7r|j |d}|r_|j dDcgc]}|jd} }d} | D]}||jd vsd} | r|j|d}|ryyd } |r | d |zz } n| d |zz } |r | d |zz } n| dz } |r| d|zz } |r| d|zz } t|| drd}|r|j |}|Scc}w)a Create table. If table exists, check passed args (params, tblspace, owner) and, if they're different from current, change them. Arguments: params - storage params (passed by "WITH (...)" in SQL), comma separated. tblspace - tablespace. owner - table owner. unlogged - create unlogged table. columns - column string (comma separated). tableF pg_defaultrTr, rCREATE UNLOGGED TABLE %s TABLE %sz (%s)z () WITH (%s) TABLESPACE "%s" return_bool) rrrr set_tblspace set_ownerr0stripset_stor_paramsr ) rcolumnsparamsrunloggedrrchangedp param_list new_paramr2s rcreatez Table.create<s#499g6 ;;<'DIIj,A,Idii 3x?!!(+7+u4u%4:LL4EFqaggclF F! #)A *: ;;$( )((0"G  )D0 0E [4' 'E  Ww& &E UNE  \F* *E  '(2 2E D%T 2G nnU+GMGsE c@d}t|jd}d} |r | d|zz } n| d|zz } | dt|dzz } |r |jd}|D] } | d| zz } | d z } |r| d |zz } |r| d |zz } t|| d rd }|r|j |}|S)a Create table like another table (with similar DDL). Arguments: src_table - source table. including - corresponds to optional INCLUDING expression in CREATE TABLE ... LIKE statement. params - storage params (passed by "WITH (...)" in SQL), comma separated. tblspace - tablespace. owner - table owner. unlogged - create unlogged table. Fr6r:r;r<z (LIKE %sr8z INCLUDING %s)r=r>Tr?)rrr0r rB) r src_table includingrrGrFrrHrr2is r create_likezTable.create_likes"499g6  )D0 0E [4' 'E 29gFFF !,I -1,, -    \F* *E  '(2 2E D%T 2G nnU+Gr!cPdt|jdz}t||dS)NzTRUNCATE TABLE %sr6Tr?rrr )rr2s rtruncatezTable.truncates'#&9$))W&MMe66r!cjdt|jddt|d}t||dS)N ALTER TABLE r6z RENAME TO Tr?rT)rnewnamer2s rrenamez Table.renames21DTYYPW1X1DWg1VXe66r!cXdt|jdd|d}t||dS)NrWr6z OWNER TO ""Tr?rT)rusernamer2s rrBzTable.set_owners(2EdiiQX2Y[cde66r!cx|jsydt|jdz}|r|dz }t||dS)NFz DROP TABLE %sr6z CASCADETr?)rrrr )rcascader2s rdropz Table.drops>{{"5dii"II  Z Ee66r!cXdt|jdd|d}t||dS)NrWr6z SET TABLESPACE "r[Tr?rT)rrr2s rrAzTable.set_tblspaces(8KDIIW^8_aije66r!cXdt|jdd|d}t||dS)NrWr6z SET (rNTr?rT)rrFr2s rrDzTable.set_stor_paramss'-@G-TV\]e66r!N)rrrFr)rrFrr)F)__name__ __module__ __qualname__r r#rrLrRrUrYrBr_rArDr!rrr sL #<68%'DL=?57-^77 7777r!rc t}|jtdddgtddddgtddd gd d d d g tdtdtddtdtdtdd d tddtddtddtdtddtddt|d}|jd}|jd}|jd}|jd}|jd}|jd}|jd}|jd} |jd} |jd } |jd!} |jd"} |jd#}|jd$}|st ||||||| | | | |dk(r| r|j d%|dk(r'| s| s| s |s |s| s|s|s|r|jd&|z'| r%| s| s |s |s| s|s|s|r|jd(|z'| r#| s |s |s| s|s|s|r|jd)|z'|r| r|jd*|z'|r|s|jd+|z't|t||j}t||d,\}}|jd3it}| rd-j| } | rd-j| } t|||}d}i}||d<d|d<|jr7t|d|j d|j d.|j d/}|dk(r|j#| 0}n| r|j%}nm| r2|j'| }|j(}t| ||}||_n9|dk(r|s|j+| | |||}n|dk(r|r|j-||||| }|r|j.r|j1n|j3|j5|j3|jr8t|d|j d|j d.|j d/}nd|d<|j(|d1<||d2<|j7|j8d3i|y)4NstrTr)typerequiredaliasespresentabsent)rhdefaultchoicesrdbz5.0.0zcommunity.postgresql)rversioncollection_name)rhrmrjdeprecated_aliases)rhboolF)rhrm)rhremoved_in_versionremoved_from_collectionlist)rhelements)r6statelogin_dbr.rrGlikerPrYrUrEr session_roler^ trust_input) argument_specsupports_check_moder6rxr.rrGrzrPrYrrUrEr^r{r|z*cascade=true is ignored when state=presentz%s: state=absent is mutually exclusive with: truncate, rename, columns, tablespace, including, like, storage_params, unlogged, owner)msgzv%s: truncate is mutually exclusive with: rename, columns, like, unlogged, including, storage_params, owner, tablespacezl%s: rename is mutually exclusive with: columns, like, unlogged, including, storage_params, owner, tablespacez2%s: like and columns params are mutually exclusivez.%s: including param needs like param specified) autocommitr8r)r6rxrr.r)r^queriesrHre)rupdater1rrFrwarn fail_jsonr r r rr joinrrrr_rUrYrrLrR check_moderollbackcommitr#close exit_json)r}rr6rxr.rrGrzrPrXrrUrEr^r{r| conn_params db_connectiondummyr table_objrHkwqs rmainrs13Mvh?y8Y:OP5"tf"#9 R U#651 u E"7,BD651&51%8u%&%0fd3-0# F MM' "E MM' "E|,J MM' "E}}Z(H == D k*ImmH%G]]#34N}}Z(HmmI&GmmI&G==0L-- .K FE:udI^Wl D g @A h'W dVdhpty~GPRWX YW48~QVZdhqACHI JGtx>Uj\eACHI J QTYYZMPUUV !&&--8K(OM5 !] ! ! 3N 3F.1((7#eVV,IG BBwKBwK ..) ~~j1$>>*:;   ...1 $$& ""7+  & &'662 %& " ) D""7N#-x@ ) ''i(0.B     " " $  "    nnW-$>>*5(~~.>? B#BwK..ByMByMFrr!__main__N) __future__rrrrh __metaclass__ DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicrFansible_collections.community.postgresql.plugins.module_utils.databaserrFansible_collections.community.postgresql.plugins.module_utils.postgresr r r r r robjectrrrbrer!rrskA@ E ND L B5A7FA7RWt zFr!