File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/mysql_query.cpython-310.pyc
Back
o ;j4 � @ sh d Z ddlZddlZddlZddlZdd� Zdd� Z d dd �Z d d d �Z dS )a� Execution of MySQL queries ========================== .. versionadded:: 2014.7.0 :depends: - MySQLdb Python module :configuration: See :py:mod:`salt.modules.mysql` for setup instructions. The mysql_query module is used to execute queries on MySQL databases. Its output may be stored in a file or in a grain. .. code-block:: yaml query_id: mysql_query.run - database: my_database - query: "SELECT * FROM table;" - output: "/tmp/query_id.txt" � Nc C s dt v rdS dS )z@ Only load if the mysql module is available in __salt__ � mysql.queryT)Fz mysql module could not be loaded)�__salt__� r r �K/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/mysql_query.py� __virtual__ s r c C s t jtd j j�dd�S )zp Look in module context for a MySQL error. Eventually we should make a less ugly way of doing this. z test.pingz mysql.errorN)�sys�modulesr � __module__� __context__�popr r r r �_get_mysql_error& s �r Tc sV | i dd|� d�d�} | du rg } | | d< t | t�s$d| d< d | d < | S t� fd d �d D ��r9td � |p6td�� tj�� �sMd� � d�| d< d | d < | S |rxtd |fi | ��sxt� } | durj| | d< d | d < | S d| d < d|� d�| d< | S |dkr�|dur�|du r�|s�|td � v r�d| d | d< | S t d r�d| d < d| | d< | S n�|dur�|td � v r�td |�} ni } |s�|| v r�d| d | d | d< | S t d r�d| d < d| d | | d< | S nDd | d < d | d< | S |du�r|�stj� |��rd | d | d< | S t d �rd| d < d | | d< | S nt d �r)d| d < d | d< | S td |� fi | ��}|d u �r?d | d < | S g }d!|v �rk|d! D ] }i }t |d" �D ] \}}|| ||< �qT|� |� �qJ||d!< t |�| d< |dk�r�|du�r�|du �r�td# ||� d$| | d% d&< | S |du�r�|td � v �r�td |�} ni } || |< td# || � d$| d | | d% d&< | S |du�r#d'| | d% d&< tjj�|d(��C}d!|v �r�|d! D ] }|�� D ]\}}|�tjj�|d | d) �� �q�q�n|�tjj�|�� W d � | S W d � | S 1 �s w Y | S d*| d% d&< | S )+a' Execute an arbitrary query on the specified database .. versionadded:: 2017.7.0 name Used only as an ID database The name of the database to execute the query_file on query_file The file of mysql commands to run output grain: output in a grain other: the file to store results None: output to the result comment (default) grain: grain to store the output (need output=grain) key: the specified grain will be treated as a dictionary, the result of this state will be stored under the specified key. overwrite: The file or grain will be overwritten if it already exists (default) saltenv: The saltenv to pull the query_file from check_db_exists: The state run will check that the specified database exists (default=True) before running any queries client_flags: A list of client flags to pass to the MySQL connection. https://dev.mysql.com/doc/internals/en/capability-flags.html T� Database � is already present��name�changes�result�commentN� client_flags�#Error: client_flags must be a list.r Fr c s g | ]}� � |��qS r )� startswith)�.0�proto�� query_filer r � <listcomp>w s ��z run_file.<locals>.<listcomp>)zhttp://zhttps://zsalt://zs3://zswift://z cp.cache_file)�saltenvzFile z does not exist�mysql.db_exists� is not present�grain� grains.ls�No execution needed. Grain � already set�test�.Query would execute, storing result in grain: � grains.get�:�5Error: output type 'grain' needs the grain parameter �No execution needed. File �-Query would execute, storing result in file: �'Query would execute, not storing resultzmysql.file_query�results�columns� grains.setval� Executed. Output into grain: r �query�Executed. Output into �w� �Executed)� isinstance�list�anyr Z__env__�os�path�existsr �__opts__�isfile� enumerate�append�str�salt�utils�files�fopen�items�write� stringutils�to_str)r �databaser �outputr �key� overwriter �check_db_existsr �connection_args�ret�err� grain_value� query_result�mapped_results�res� mapped_line�idx�col� output_file�valr r r �run_file0 s 7 � �� �� ������ � �� � � � ��� � � � � �rX c K s6 | i dd|� d�d�} |du rg }|| d< t |t�s$d| d< d | d < | S |rOtd |fi | ��sOt� } | durA| | d< d | d < | S d| d < d| � d �| d< | S |d kr�|dur|du r|sn|td � v rnd| d | d< | S td r~d| d < d| | d< | S n||dur�|td � v r�td |�} ni } |s�|| v r�d| d | d | d< | S td r�d| d < d| d | | d< | S n?d | d < d| d< | S |dur�|s�tj�|�r�d| d | d< | S td r�d| d < d| | d< | S ntd r�d| d < d| d< | S td ||fi | ��} g }d| v �r2| d D ] }i }t| d �D ] \}}|| ||< �q|� |� �q|| d< t | �| d< |d k�r�|du�rX|du �rXtd || � d | | d d < | S |du�r�|td � v �rltd |�} ni } | | |< td || � d | d | | d d < | S |du�rd | | d d < t j j �|d!��l}d| v �r�| d D ] }|�� D ]\}}|�t j j�|d | d" �� �q��q�n+t | t ��r�|�t j j�| �� n"| �� D ]%\}}|�t j j�|� d|� d"��� �q�W d � | S W d � | S W d � | S 1 �s w Y | S d#| d d < | S )$a� Execute an arbitrary query on the specified database name Used only as an ID database The name of the database to execute the query on query The query to execute output grain: output in a grain other: the file to store results None: output to the result comment (default) grain: grain to store the output (need output=grain) key: the specified grain will be treated as a dictionary, the result of this state will be stored under the specified key. overwrite: The file or grain will be overwritten if it already exists (default) check_db_exists: The state run will check that the specified database exists (default=True) before running any queries client_flags: A list of client flags to pass to the MySQL connection. https://dev.mysql.com/doc/internals/en/capability-flags.html Tr r r Nr r r Fr r r r r r! r" r# r$ r% r& r' r( r) r* r r+ r, r- r. r r/ r0 r1 r2 r3 )r4 r5 r r r: r7 r8 r; r< r= r> r? r@ rA rB rC rD rE rF )r rG r/ rH r rI rJ rK r rL rM rN rO rP rQ rR rS rT rU rV rW r r r �run� s� 1 � �� ������ ��� � � � ��� �� �� �� �� �rY )NNNNTNTN)NNNTTN) �__doc__Zos.pathr7 r Zsalt.utils.filesr? Zsalt.utils.stringutilsr r rX rY r r r r �<module> s0 � J�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings