Vh)ddlmZmZmZeZdZdZdZddl Z ddl Z ddl m Z ddl mZmZmZmZddlmZd Zd Zd Zd Zed k(reyy))absolute_importdivisionprint_functiona\ --- module: mysql_query short_description: Run MySQL or MariaDB queries description: - Runs arbitrary MySQL or MariaDB queries. - Pay attention, the module does not support check mode! All queries will be executed in autocommit mode. - To run SQL queries from a file, use M(community.mysql.mysql_db) module. version_added: '0.1.0' options: query: description: - SQL query to run. Multiple queries can be passed using YAML list syntax. - Must be a string or YAML list containing strings. - If you use I(named_args) or I(positional_args) any C(%) will be interpreted as a formatting character. All literal C(%) characters in the query should be escaped as C(%%). - Note that if you use the C(IF EXISTS/IF NOT EXISTS) clauses in your query and C(mysqlclient) or C(PyMySQL 0.10.0+) connectors, the module will report that the state has been changed even if it has not. If it is important in your workflow, use the C(PyMySQL 0.9.3) connector instead. type: raw required: true positional_args: description: - List of values to be passed as positional arguments to the query. - Mutually exclusive with I(named_args). type: list elements: raw named_args: description: - Dictionary of key-value arguments to pass to the query. - Mutually exclusive with I(positional_args). type: dict login_db: description: - Name of database to connect to and run queries against. type: str single_transaction: description: - Where passed queries run in a single transaction (C(yes)) or commit them one-by-one (C(no)). type: bool default: false attributes: check_mode: support: none seealso: - module: community.mysql.mysql_db notes: - Compatible with MariaDB or MySQL. author: - Andrew Klychkov (@Andersson007) extends_documentation_fragment: - community.mysql.mysql a # If you encounter the "Please explicitly state intended protocol" error, # use the login_unix_socket argument - name: Simple select query to acme db community.mysql.mysql_query: login_db: acme query: SELECT * FROM orders login_unix_socket: /run/mysqld/mysqld.sock - name: Select query to db acme with positional arguments community.mysql.mysql_query: login_db: acme query: SELECT * FROM acme WHERE id = %s AND story = %s positional_args: - 1 - test - name: Select query to test_db with named_args community.mysql.mysql_query: login_db: test_db query: SELECT * FROM test WHERE id = %(id_val)s AND story = %(story_val)s named_args: id_val: 1 story_val: test - name: Run several insert queries against db test_db in single transaction community.mysql.mysql_query: login_db: test_db query: - INSERT INTO articles (id, story) VALUES (2, 'my_long_story') - INSERT INTO prices (id, price) VALUES (123, '100.00') single_transaction: true ad executed_queries: description: List of executed queries. returned: always type: list sample: ['SELECT * FROM bar', 'UPDATE bar SET id = 1 WHERE id = 2'] query_result: description: - List of lists (sublist for each query) containing dictionaries in column:value form representing returned rows. returned: changed type: list sample: [[{"Column": "Value1"},{"Column": "Value2"}], [{"ID": 1}, {"ID": 2}]] rowcount: description: Number of affected rows for each subquery. returned: changed type: list sample: [5, 1] execution_time_ms: description: - A list containing execution time per query in milliseconds. - The measurements are done right before and after passing the query to the driver for execution. returned: success type: list sample: [7104, 85] version_added: '3.12.0' N) AnsibleModule) mysql_connectmysql_common_argument_spec mysql_drivermysql_driver_fail_msg) to_native)INSERTUPDATEDELETEREPLACE)CREATEDROPALTERRENAMETRUNCATEctj}|j||ttj|z dzd}||fS)Ni)time perf_counterexecuteround)cursorqueryargs start_time exec_time_mss o/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/mysql/plugins/modules/mysql_query.pyexecute_and_return_timer!sJ""$J NN5$$++- :dBAFL < c t}|jtddtdtddtdtd d  t|d }|jd}|jd}|jd}|jd}|jd}|jd}|jd}|jd} |jd} |jd} t | t tfs|jdt| zt | t r| g} | D]4} t | t r|jd| dt| 6|jdrd } nd} |jjdr|jd}n-|jjdr|jd}nd}t|jt t|||| ||||| |d | ! \}}d }t!t#t$t&zt $}g}g}g}g}d }| D]5} t)j*5t)j,d%d&tj.' t1||\}}|j3|ddd |s6|j3j9Dcgc] }t|c}|j;d,|j=}t$D]}||vsj>d,kDsd}t&D]}||vs|rd }d }d} |j3j@|j3|j>8| sjG|||||d-}|jHd.i|y#t$r,}|jd"| d#t|Yd}~d}~wwxYw#tj.$rd}YTwxYw#1swYZxYw#t$rQ}| sj5j7|jd(|d)|d*t|Yd}~d}~wwxYwcc}w#t$r;}| sj5|jd+t|zYd}~d}~wwxYw#tB$r|j3jDY|wxYw)/NrawT)typerequiredstr)r%list)r%elementsdictboolF)r%default)rlogin_dbpositional_args named_argssingle_transaction))r.r/) argument_specmutually_exclusiver-connect_timeout login_userlogin_password client_cert client_keyca_certcheck_hostname config_filerz:the query option value must be a string or list, passed %s)msgz4the elements in query list must be strings, passed 'z' r0r.r/ DictCursor)r9r3 cursor_class autocommitzRunable to connect to database, check login_user and login_password are correct or z) has the credentials. Exception message: )keyerrorz.*already exists*)actionmessagecategoryzCannot execute SQL 'z' args [z]: z!Cannot fetch rows from cursor: %sr)changedexecuted_queries query_resultrowcountexecution_time_ms)%rupdater*rparams isinstancer'r( fail_jsonr%getr r r Exceptionr lenmaxDML_QUERY_KEYWORDSDDL_QUERY_KEYWORDSwarningscatch_warningsfilterwarningsWarningr!appendrollbackclosefetchalllstripupperrG_last_executedAttributeError _executedcommit exit_json)r1moduledbr3r4r5ssl_certssl_keyssl_car9r:relemr> argumentsr db_connectionerDmax_keyword_lenrFrErGrHalready_existsqrrowkeywordkws r mainrrs.0M-5!&59V$VU; # F z "Bmm$56O|,J]]#34N}}]+HmmL)G ]]9 %F]]#34N-- .K MM' "E ec4[ )Y\`af\ggh%t$$   aegklpgq!r  st}})*   }}*+MM"34   < (MM,/  23 T -fj..98WfVX=K>M;GT^ !` G#03EE3OPOLHN 6) i((* *''w0C1=1E1EG *+B61i+X(FL%,,\: *. U!##&//:K$L3T#Y$LM HHJq ) / / 1) G!|! 3 * #G!|!#G%*N"G # 6  # #F$9$9 : (m6)r ,$.  BFro T8CYq\S T TT6$++* &*N * * *  i&&( LLN   AyZcdeZf!g  h h  i%M U&&(   !DyQR|!S  T T  U, 6  # #F$4$4 5 6sN5P('P !O-1P:Q8Q3 +Q8R?5 O*>!O%%O*-PP PP  P P Q0AQ++Q03Q88 R<0R77R<?$S'&S'__main__) __future__rrrr% __metaclass__ DOCUMENTATIONEXAMPLESRETURNrrTansible.module_utils.basicr>ansible_collections.community.mysql.plugins.module_utils.mysqlrrr r ansible.module_utils._textr rRrSr!rr__name__rIr"r r}spCB 7 r D : 4 1>F Sl zFr"