VhuddlmZmZmZeZdZdZdZddl Z ddl Z ddl Z ddl m Z ddlmZddlmZmZmZmZmZmZdd lmZdd lmZdd lmZgZd Zd Z ddZ ddZ!dZ"dZ#e$dk(re#yy))absolute_importdivisionprint_functionaM --- module: mysql_db short_description: Add or remove MySQL or MariaDB databases from a remote host description: - Add or remove MySQL or MariaDB databases from a remote host. options: name: description: - Name of the database to add or remove. - I(name=all) may only be provided if I(state) is C(dump) or C(import). - List of databases is provided with I(state=dump), I(state=present) and I(state=absent). - If I(name=all) it works like --all-databases option for mysqldump (Added in 2.0). required: true type: list elements: str aliases: [db] state: description: - The database state. type: str default: present choices: ['absent', 'dump', 'import', 'present'] collation: description: - Collation mode (sorting). This only applies to new table/databases and does not update existing ones, this is a limitation of MySQL. type: str default: '' encoding: description: - Encoding mode to use, examples include C(utf8) or C(latin1_swedish_ci), at creation of database, dump or importation of sql script. type: str default: '' target: description: - Location, on the remote host, of the dump file to read from or write to. - Uncompressed SQL files (C(.sql)) as well as bzip2 (C(.bz2)), gzip (C(.gz)), xz (Added in 2.0) and zstd (C(.zst)) (Added in 3.12.0) compressed files are supported. type: path single_transaction: description: - Execute the dump in a single transaction. type: bool default: false quick: description: - Option used for dumping large tables. type: bool default: true ignore_tables: description: - A list of table names that will be ignored in the dump of the form database_name.table_name. type: list elements: str default: [] hex_blob: description: - Dump binary columns using hexadecimal notation. type: bool default: false version_added: '0.1.0' force: description: - Continue dump or import even if we get an SQL error. - Used only when I(state) is C(dump) or C(import). type: bool default: false version_added: '0.1.0' master_data: description: - Option to dump a master replication server to produce a dump file that can be used to set up another server as a slave of the master. - C(0) to not include master data. - C(1) to generate a 'CHANGE MASTER TO' statement required on the slave to start the replication process. - C(2) to generate a commented 'CHANGE MASTER TO'. - Can be used when I(state=dump). type: int choices: [0, 1, 2] default: 0 version_added: '0.1.0' skip_lock_tables: description: - Skip locking tables for read. Used when I(state=dump), ignored otherwise. type: bool default: false version_added: '0.1.0' dump_extra_args: description: - Provide additional arguments for mysqldump. Used when I(state=dump) only, ignored otherwise. type: str version_added: '0.1.0' use_shell: description: - Used to prevent C(Broken pipe) errors when the imported I(target) file is compressed. - If C(yes), the module will internally execute commands via a shell. - Used when I(state=import), ignored otherwise. type: bool default: false version_added: '0.1.0' unsafe_login_password: description: - If C(no), the module will safely use a shell-escaped version of the I(login_password) value. - It makes sense to use C(yes) only if there are special symbols in the value and errors C(Access denied) occur. - Used only when I(state) is C(import) or C(dump) and I(login_password) is passed, ignored otherwise. type: bool default: false version_added: '0.1.0' restrict_config_file: description: - Read only passed I(config_file). - When I(state) is C(dump) or C(import), by default the module passes I(config_file) parameter using C(--defaults-extra-file) command-line argument to C(mysql/mysqldump) utilities under the hood that read named option file in addition to usual option files. - If this behavior is undesirable, use C(yes) to read only named option file. type: bool default: false version_added: '0.1.0' check_implicit_admin: description: - Check if mysql allows login as root/nopassword before trying supplied credentials. - If success, passed I(login_user)/I(login_password) will be ignored. type: bool default: false version_added: '0.1.0' config_overrides_defaults: description: - If C(yes), connection parameters from I(config_file) will override the default values of I(login_host) and I(login_port) parameters. - Used when I(stat) is C(present) or C(absent), ignored otherwise. - It needs Python 3.5+ as the default interpreter on a target host. type: bool default: false version_added: '0.1.0' chdir: description: - Changes the current working directory. - Can be useful, for example, when I(state=import) and a dump file contains relative paths. type: path version_added: '3.4.0' pipefail: description: - Use C(bash) instead of C(sh) and add C(-o pipefail) to catch errors from the mysql_dump command when I(state=dump) and compression is used. - The default is C(no) to prevent issues on systems without bash as a default interpreter. - The default will change to C(yes) in community.mysql 4.0.0. type: bool default: false version_added: '3.4.0' seealso: - module: community.mysql.mysql_info - module: community.mysql.mysql_variables - module: community.mysql.mysql_user - module: community.mysql.mysql_replication - name: MySQL command-line client reference description: Complete reference of the MySQL command-line client documentation. link: https://dev.mysql.com/doc/refman/8.0/en/mysql.html - name: mysqldump reference description: Complete reference of the ``mysqldump`` client utility documentation. link: https://dev.mysql.com/doc/refman/8.0/en/mysqldump.html - name: CREATE DATABASE reference description: Complete reference of the CREATE DATABASE command documentation. link: https://dev.mysql.com/doc/refman/8.0/en/create-database.html - name: DROP DATABASE reference description: Complete reference of the DROP DATABASE command documentation. link: https://dev.mysql.com/doc/refman/8.0/en/drop-database.html author: "Ansible Core Team" requirements: - mysql (command line binary) - mysqldump (command line binary) notes: - Compatible with MariaDB or MySQL. - Requires the mysql and mysqldump binaries on the remote host. - This module is B(not idempotent) when I(state) is C(import), and will import the dump file each time if run more than once. attributes: check_mode: support: full extends_documentation_fragment: - community.mysql.mysql a # If you encounter the "Please explicitly state intended protocol" error, # use the login_unix_socket argument - name: Create a new database with name 'bobdata' community.mysql.mysql_db: name: bobdata state: present login_unix_socket: /run/mysqld/mysqld.sock - name: Create new databases with names 'foo' and 'bar' community.mysql.mysql_db: name: - foo - bar state: present # Copy database dump file to remote host and restore it to database 'my_db' - name: Copy database dump file copy: src: dump.sql.bz2 dest: /tmp - name: Restore database community.mysql.mysql_db: name: my_db state: import target: /tmp/dump.sql.bz2 - name: Restore database ignoring errors community.mysql.mysql_db: name: my_db state: import target: /tmp/dump.sql.bz2 force: true - name: Dump multiple databases community.mysql.mysql_db: state: dump name: db_1,db_2 target: /tmp/dump.sql - name: Dump multiple databases community.mysql.mysql_db: state: dump name: - db_1 - db_2 target: /tmp/dump.sql - name: Dump all databases to hostname.sql community.mysql.mysql_db: state: dump name: all target: /tmp/dump.sql - name: Dump all databases to hostname.sql including master data community.mysql.mysql_db: state: dump name: all target: /tmp/dump.sql master_data: 1 # Import of sql script with encoding option - name: > Import dump.sql with specific latin1 encoding, similar to mysql -u --default-character-set=latin1 -p < dump.sql community.mysql.mysql_db: state: import name: all encoding: latin1 target: /tmp/dump.sql # Dump of database with encoding option - name: > Dump of Databse with specific latin1 encoding, similar to mysqldump -u --default-character-set=latin1 -p community.mysql.mysql_db: state: dump name: db_1 encoding: latin1 target: /tmp/dump.sql - name: Delete database with name 'bobdata' community.mysql.mysql_db: name: bobdata state: absent - name: Make sure there is neither a database with name 'foo', nor one with name 'bar' community.mysql.mysql_db: name: - foo - bar state: absent # Dump database with argument not directly supported by this module # using dump_extra_args parameter - name: Dump databases without including triggers community.mysql.mysql_db: state: dump name: foo target: /tmp/dump.sql dump_extra_args: --skip-triggers - name: Try to create database as root/nopassword first. If not allowed, pass the credentials community.mysql.mysql_db: check_implicit_admin: true login_user: bob login_password: 123456 name: bobdata state: present - name: Dump a database with compression and catch errors from mysqldump with bash pipefail community.mysql.mysql_db: state: dump name: foo target: /tmp/dump.sql.gz pipefail: true a db: description: Database names in string format delimited by white space. returned: always type: str sample: "foo bar" db_list: description: List of database names. returned: always type: list sample: ["foo", "bar"] executed_commands: description: List of commands which tried to run. returned: if executed type: list sample: ["CREATE DATABASE acme"] version_added: '0.1.0' N) AnsibleModule)mysql_quote_identifier) mysql_connect mysql_drivermysql_driver_fail_msgmysql_common_argument_specget_server_implementationget_server_version) LooseVersion) shlex_quote) to_nativec\d}|D]}||jd|fz }|t|k(S)NrzJSELECT SCHEMA_NAME FROM information_schema.SCHEMATA WHERE SCHEMA_NAME = %s)executelen)cursordbreseach_dbs l/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/mysql/plugins/modules/mysql_db.py db_existsrms@ Cx v~~jmtlvwwx #b'>c|sy|D]7}dt|dz}tj||j|9y)NFzDROP DATABASE %sdatabaseT)rexecuted_commandsappendr)rrrquerys r db_deleter tsH "%;GZ%PP  'u rc d}| dk(rt| tdk\rd} |j|dg}|r=|r|j d t |zn|j d t |z|r|j d nU||j d t |z|4|s|j d t |zn|j d |z| |j dt | z| |j dt | z||j dt |z|r|j d| |j dt | zn|j dt ||fz|r|j dnjt |dkDr0|j djdj|n,|j dt dj|z|r|j d|"|dk7r|j dt |z|r|j d|r|j d|r'|D]"}|j dj|$|r|j d|rE| dk(r,t| tdk\r|j d |zn|j d!|z||j |d} tjj|d"d#k(r|jd$d} ntjj|d"d%k(r|jd&d} notjj|d"d'k(r|jd(d} n7tjj|d"d)k(r|jd*d} dj|}| r|d+| d,t |}|rd-|z}n|d.t |zz }tj ||r|j|dd/0\}!}"}#n|j|d1\}!}"}#|!|"|#fS#t$r}dddt|zfcYd}~Sd}~wwxYw)2N mysqldumpmariadb10.4.6z mariadb-dumpTz"Error determining dump command: %s--defaults-file=%s--defaults-extra-file=%s--user=root --password='' --user=%s --password=%s --ssl-cert=%s --ssl-key=%s --ssl-ca=%sz--force --socket=%sz--host=%s --port=%iz--all-databasesz--databases {0} %sz--skip-lock-tables--default-character-set=%sz--single-transaction=truez--quickz--ignore-table={0}z --hex-blobmysqlz8.2.0z--source-data=%sz--master-data=%s.gzgzip.bz2bzip2.xzxz.zstzstd | z > zset -o pipefail && z > %sbash)use_unsafe_shell executabler?)r get_bin_path Exceptionstrrrrformatjoinospathsplitextr run_command)$modulehostuserpassworddb_nametarget all_databasesport config_fileserver_implementationserver_versionsocketssl_certssl_keyssl_casingle_transactionquick ignore_tableshex_blobencodingforce master_dataskip_lock_tablesdump_extra_argsunsafe_passwordrestrict_config_filecheck_implicit_adminpipefailcmd_strcmdean_ignored_tablerHrcstdoutstderrs$ rdb_dumprn~s2G )l>.Jl[cNd.d D""7D12   JJ+k+.FF G JJ1K 4LL M ./   JJ{[%66 7  " ?[-BBC ?X56 ?[%::; >K$889  =;v#667  9  =;v#667 (K,=t+DDE $% W  $++CHHW,=>? 4+chhw&7889 '(8r> /+h2GGH ./  9 - F  JJ+223CD E F <  !W ,^, W0EE JJ)K7 8 JJ)K7 8" ?# D ww#u,""640   & !" % /""7D1   & !" % .""4.   & !" % /""640 ((3-C #T;v+>? '#-C wV,,,S!#//dW]/^FF#//d/KFF vv u D":SVCCCDsQ)) R 2RR R c tjj|s|jd|zSd}| dk(rt | t dk\rd} |j |dg}|r=|r|jd t|zn|jd t|z|r|jd nU|r|jd t|z|r4|s|jdt|zn|jd|z| |jdt| z| |jdt| z||jdt|z|r|jd| |jdt| zn1|jdt|z|jd|z|"|dk7r|jdt|z|s:|jd|jtdj|d}tjj|ddk(r|j dd}ntjj|ddk(r|j dd}nqtjj|ddk(r|j dd}n8tjj|dd k(r|j d!d}|rYtj|d"|d#||stj|d$|gtjtj%}tj||j tjtj&}|j#\}}|j j%|j'|j(d'k7r)|j*j-}|j(d|fS|j(||fSd(j|}|d"t|d#|}|j/|d)\}}} ||| fSd(j|}|d*t|zz }tj||j/|d)\}}} ||| fS#t $r}ddd t|zfcYd}~Sd}~wwxYw)+Nz$target %s does not exist on the hostmsgr3r#r$Tr%r&z+Error determining mysql/mariadb command: %sr'r(r)r*r+r,r-r.z-fr/z --host=%sz --port=%ir2z--one-databaser4r5r6)requiredr7r8r9r:r;r<z -dc r=z-dc)rlrm)stdinrlrmrr0rAz < %s)rGrHexists fail_jsonrrBrCrDrrrFrIr subprocessPopenPIPErl communicateclosewait returncodermreadrJ)!rKrLrMrNrOrPrQrRrSrTrUrVrWrXrYr^r_ use_shellrcrdrergrhricomp_prog_pathp1p2stdout2stderr2stderr1rkrlrms! r db_importrsP 77>>& !$JV$STTG )l>.Jl[cNd.dM""7D12   JJ+k+.FF G JJ1K 4LL M ./  JJ{[%66 7 " ?[-BBC ?X56 ?[%::; >K$889  =;v#667  4  =;v#667 ;T!223 ;%&8r> /+h2GGH  #$ ;rwww/01N ww#u,,,Vd,C   & !" % /,,Wt,D   & !" % .,,TD,A   & !" % /,,Vd,C  ^VS!QR!!>5&"A*//blbqbqrB!!#RYYzWaWfWfgB!#!1 Wg IIOO  GGI}}!))..*}}b'11}}gw66 ((3-C&4k&6I3OC!'!3!3C$!3!O Bvv% %hhsm wV,,,  %#//d/KFF66!!c M"Cc!fLLLMsS S*S%S*%S*c|syt||}d}|D]}dt|djddzg}|r|jd|r|jd d j |}||j ||z } t j|j|||dkDS#t$r"t j|jYt$rt j|YwxYw) NF)enccollaterzCREATE DATABASE %sr%z%%zCHARACTER SET %(enc)szCOLLATE %(collate)sr0) dictrreplacerrFrrmogrifyAttributeError _executedrC)rrr^ collation query_paramsrrrs r db_createrIs Hi8L C,%(>w (S([([\_ae(ffg  LL0 1  LL. / v~~e\22 ,  $ $V^^E<%H I, 7N  7  $ $V%5%5 6 ,  $ $U + ,s%B11(C;C;:C;cZt}|jtddddgtddtddtd tdd gd  td dtd dtddgtdd td dtddgd td dtd td dtd ddtd dtd dtd dtd td dt|d}t|j t |jd}|s|jd|g|Dcgc]}|j}}|jd}|jd}|jd}|jd}|jd}|jd} | dks| d kDr|j d!|jd"} |jd#} |jd$} |jd%} |jd&}|jd'}|jd(}|jd)}|jd*}|jd+}|jd,}|D]}|dk(s |j d-|jd.}|jd/}|jd0}|jd1}|jd2}|jd3}|jd4}|jd5}|jd6}|jd7}|jd8} |jd9}!|jd:}"|!r tj|!t|d=kDr|d>k(r|j d?d@j|}$d}%|dAvr ||j dB|z|dCgk(rd}%n|dCgk(r|j dD d}&|r t|dEd|| | | || | F \}&}'|&st||||| | | || | G \}&}'t'&}(t)|&})d}*tj j#|sd}g}+g},|%s7|D]2}-t+|&|-gr|+j-|-"|,j-|-4|dLk(rP|j.r|jt1|+|$| t3|&|+}*|j|*|$|t4Ny|d k(rV|j.r|jt1|,|$|d}*|,r t7|&|,||}*|j|*|$|t4Ny|dQk(r|,r&|%s$|j dRdSj|,z|j.r|jd|$|t=|||||||%| ||(|)|| | | |||||||||||||"\}.}/}0|.dk7r|j dT|0z|jd|$||/t4Uy|d>k(r|j.r|jd|$||,r|%s t7|&|,||t?|||||||%| ||(|)|| | | ||||||\}.}/}0|.dk7r|j dT|0z|jd|$||/t4Uyycc}w#t$r"}#|j d;|!d<|#Yd}#~#:d}#~#wwxYw#t$r }#d}Yd}#~#d}#~#wwxYw#t$rm}#tj j#|r"|j dH|dIt%|#n!|j dJ|dKt%|#Yd}#~# d}#~#wwxYw#t$r)}#|j dMt%|#zYd}#~#d}#~#wwxYw#t$r<}#|j dOt%|#zt9j:PYd}#~#d}#~#wwxYw#t$r<}#|j dOt%|#zt9j:PYd}#~#d}#~#wwxYw)VNlistrDTr)typeelementsrraliasesr&)rdefaultrH)rpresent)absentdumpimportr)rrchoicesboolF)rrr)rrintr)rr%)rrno_log)namer^rrPstaterZr[r\r]r_r`rarbr~unsafe_login_passwordrdreconfig_overrides_defaultschdirrf) argument_specsupports_check_moderpr)changedrdb_listr^rrrPlogin_unix_socket login_portiz5login_port must be a valid unix port number (0-65535) client_cert client_keyca_certcheck_hostnameconnect_timeoutrSlogin_passwordr login_user login_hostr\z%Name of ignored table cannot be emptyrZr[r]r_r`rarbr~rdrerrrfz'Cannot change the current directory to z: r%rz6Multiple databases are not supported with state=importr0)rrz with state=%s target is requiredallzGname is not allowed to equal 'all' unless state equals import, or dump.root)rrr)rrrzRunable to connect to database, check login_user and login_password are correct or z) has the credentials. Exception message: zunable to find z. Exception message: rzerror deleting database: %s)rrrrzerror creating database: %s)rq exceptionrz&Cannot dump database(s) %r - not foundz, r1)rrrrqr) r updaterrr rur params exit_jsonstriprGrrCrrFrrHrtrr r rr check_moderr rr traceback format_excrnr)1rrKrrr^rrrPrVrrWrXrYrrrSrrrrr\a_tablerZr[r]r_r`rarbr~rdrerrrfrirOrQrdb_connrTrUrexistence_listnon_existence_list each_databaserkrlrms1 rmainres.0M vtf M5"-E2. y:abVU;-Ce&1.eQ B659%(FE2"dK!vu=!vu="&FE"B651).# F 23 v B 2r:)+ ,g'--/ ,B ,}}Z(H k*I MM' "E ]]8 $F ]]. /F|,JA~e+TU}}]+HmmL)G ]]9 %F]]#34Nmm$56O-- .K]]#34N"MM*AB|,J|,JMM/2M J b=   !H  IJ ';< MM' "E}}Z(H MM' "E-- .K}}%78mm$56O k*I!==)?@!==)?@ & .I J MM' "E}}Z(H  [ HHUO 2w{u(UVhhrlGM "" >   !Ce!K  L %= M %=   !j  kk  "/KQY[bdj@O`nJc#e+FJP[]egnpv>+ & N  9M-1%%m4"))-8  9        T.%9gr  R O7G WbTef )       T*<%='SU  V  C#F,>)T WbTef & m   !ITYYWiMj!k  l      Tgr  B$VZ%3R%/>SUc%+Xw%+-? %-x M]%46KMa%98EFF 7     /'26+<  > (       Tgr  B m C&"4h J'vz:'5r6'4'1;@U'5vxRX'/ CX';=Q SFF 7     /'26+<  >% I -R [   PUWXY Z Z [. ',$  k 77>>+ &   1!M  N N O C  %BYq\%Q+4+?+?+A!CC C6 C  %BYq\%Q+4+?+?+A!CC Cs&Z#?Z( [/[&[/% ](>^<_%( [1[[ [,['![/'[,,[// ]%8A"]  ]%( ^1^^ _"&1__"% `*.1`%%`*__main__)NNNNNNNNNFrFNFFFF) NNNNNFFFFF)% __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESRETURNrGrvransible.module_utils.basicrAansible_collections.community.mysql.plugins.module_utils.databaser>ansible_collections.community.mysql.plugins.module_utils.mysqlrr r r r r @ansible_collections.community.mysql.plugins.module_utils.versionransible.module_utils.six.movesransible.module_utils._textrrrr rnrrr__name__rrrsA@ } ~u n & 4dZ60HL04NRHMNS16 gVgk#(KP#( ^"B8{>| zFr