File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/mysql.cpython-310.pyc
Back
o ;j�r � @ s$ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z z ddl Z ddlZ ddlZ ddl mZ ddlmZmZmZ W n; ey� z&ddlZe�� ddl Z ddlZ ddlZ ddl mZ ddlmZmZmZ W n ey� dZ Y nw Y nw zddlZdZW n ey� dZY nw e�e�Z g d�Z g d�Z e d d g Z g d �Z d d � Z!dd� Z"dd� Z#dd� Z$dd� Z%dd� Z&dd� Z'dd� Z(d d � Z)d d � Z*d�d d!�Z+d�d"d#�Z,d$d%� Z-d&d'� Z.d(d)� Z/d*d+� Z0d,d-� Z1d.d/� Z2d0d1� Z3d2d3� Z4d�d4d5�Z5d6d7� Z6d8d9� Z7d:d;� Z8d�d<d=�Z9d>d?� Z:d@dA� Z; B Cd�dDdE�Z< B Cd�dFdG�Z= B d�dHdI�Z>d�dJdK�Z? B Cd�dLdM�Z@ B Cd�dNdO�ZA B Cd�dPdQ�ZB B Cd�dRdS�ZC B Cd�dTdU�ZD B d�dVdW�ZEd�dXdY�ZFdZd[� ZGd�d\d]�ZHd�d^d_�ZId�d`da�ZJdbdc� ZKddde� ZLdfdg� ZM B d�dhdi�ZNd�djdk�ZOdldm� ZP B d�dndo�ZQ B d�dpdq�ZR B d�drds�ZSdtdu� ZTdvdw� ZUdxdy� ZVdzd{� ZWd|d}� ZXd~d� ZYd�d�d��ZZd�d�� Z[d�d�d��Z\d�d�� Z]d�d�� Z^dS )�a� Module to provide MySQL compatibility to salt. :depends: - Python module: MySQLdb, mysqlclient, or PyMYSQL :configuration: In order to connect to MySQL, certain configuration is required in either the relevant minion config (/etc/salt/minion), or pillar. Some sample configs might look like:: mysql.host: 'localhost' mysql.port: 3306 mysql.user: 'root' mysql.pass: '' mysql.db: 'mysql' mysql.unix_socket: '/tmp/mysql.sock' mysql.charset: 'utf8' You can also use a defaults file:: mysql.default_file: '/etc/mysql/debian.cnf' .. versionchanged:: 2014.1.0 'charset' connection argument added. This is a MySQL charset, not a python one. .. versionchanged:: 0.16.2 Connection arguments from the minion config file can be overridden on the CLI by using the arguments defined :mod:`here <salt.states.mysql_user>`. Additionally, it is now possible to setup a user with no password. � N)�OperationalError)�CLIENT� FIELD_TYPE�FLAGTF);�ALL PRIVILEGES�ALTER� ALTER ROUTINE� BACKUP_ADMIN� BINLOG_ADMINz BINLOG ADMIN�BINLOG MONITORz BINLOG REPLAY�CONNECTION_ADMINzCONNECTION ADMIN�CREATE� CREATE ROLE�CREATE ROUTINE�CREATE TABLESPACE�CREATE TEMPORARY TABLES� CREATE USER� CREATE VIEW�DELETEzDELETE HISTORY�DROP� DROP ROLE�ENCRYPTION_KEY_ADMIN�EVENT�EXECUTEzFEDERATED ADMIN�FILE� GRANT OPTION�GROUP_REPLICATION_ADMIN�INDEX�INSERT� LOCK TABLES�PERSIST_RO_VARIABLES_ADMIN�PROCESSzREAD_ONLY ADMIN� REFERENCES�RELOAD�REPLICA MONITOR�REPLICATION CLIENTzREPLICATION MASTER ADMIN�REPLICATION REPLICA�REPLICATION SLAVE�REPLICATION_SLAVE_ADMINzREPLICATION SLAVE ADMIN�RESOURCE_GROUP_ADMIN�RESOURCE_GROUP_USER� ROLE_ADMIN�SELECTzSET USER� SET_USER_ID�SHOW DATABASES� SHOW VIEW�SHUTDOWN� SLAVE MONITOR�SUPER�SYSTEM_VARIABLES_ADMIN�TRIGGER�UPDATE�USAGE�XA_RECOVER_ADMIN)ZCIPHERZISSUERZSUBJECTZSSLZX509)+r r r r r r r r r r r r r r r r r r r r r r r r r! r" r# r% r' r( r) r* r+ r, r- r. r/ r0 r2 r3 r4 r5 r7 c C s t t�tdu r dfS dfS )z: Confirm that a python mysql client is installed. Nz!No python mysql client installed.� )�bool�MySQLdb� r; r; �F/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/mysql.py� __virtual__ s r= c C s. t �| �� ��� }dt �|��� �� � �}|S )N�*)�hashlib�sha1�encode�digest� hexdigest�upper)�password� _passwordr; r; r< �__mysql_hash_password s rG c K �h t di |��}|d u r i S |�tjj�}t| �}t|�}d|� d|� �}t||� |�� }t� |� |S )Nz CHECK TABLE �.r; � �_connect�cursorr: �cursors� DictCursor�quote_identifier�_execute�fetchall�log�debug� �name�table�connection_args�dbc�cur�s_nameZs_table�qry�resultsr; r; r< � __check_table � r] c K rH )Nz REPAIR TABLE rI r; rJ rT r; r; r< �__repair_table r^ r_ c K rH )NzOPTIMIZE TABLE rI r; rJ rT r; r; r< �__optimize_table, r^ r` c K s| dt v rt d S td i | ��}|d u rdS |�� }d}dddd�}t|||� t|j�dkr6dt d< t d S dt d< t d S ) Nzmysql.password_columnZPasswordz�SELECT column_name from information_schema.COLUMNS WHERE table_schema=%(schema)s and table_name=%(table)s and column_name=%(column)s�mysql�user)ZschemarV �columnr Zauthentication_stringr; )� __context__rK rL rP �int�rowcount)rW rX rY r[ �argsr; r; r< �__password_column; s � �rh c K s� t di |��}|d u r g S |�tjj�}zd}| |d�}t|||� W n# tjyF } zdj|j� }|t d< t � |� W Y d }~dS d }~ww |� � } t � | � | rZ| d �dd�S dS ) NzCSELECT plugin FROM mysql.user WHERE User=%(user)s and Host=%(host)s)rb �host�MySQL Error {}: {}� mysql.error�mysql_native_passwordr Zpluginr; )rK rL r: rM rN rP r �formatrg rd rR �errorrQ rS �get) rb ri rW rX rY r[ rg �exc�errr\ r; r; r< �__get_auth_pluginR s( �� rr c s t � � d$� �fdd� }d�v rd}nd}d� d< i }tt�D ]}|�d �s.tt|�||�� < q ��d g �D ]}|�|�rG� d || O < q5t�d |� q5|d d |� |dd|� |dd|� |dd|� |dd|� |dd|� |dd|� |dd|� |dd |� d� d < |d d � d t _ t � � �D ] }� | s�� |= q�� �dd�du r�t� d!� � �d� z t jd%i � ��}W nF ty� } zd"j|j� }|td#< t�|� W Y d}~dS d}~w t jj�y } zd"j|j� }|td#< t�|� W Y d}~dS d}~ww |�d� |S )&z. wrap authentication credentials here NTc s� |du r| }| �v r�| � |< dS |rDd}| � |�r0z | t|�d� } W n ty/ Y dS w td d| � �d�}|durF|� |< dS dS dS )a� Add key to connargs, only if name exists in our kwargs or, if get_opts is true, as mysql.<name> in __opts__ or __pillar__ If get_opts is true, evaluate in said order - kwargs, opts then pillar. To avoid collision with other functions, kwargs-based connection arguments are prefixed with 'connection_' (i.e. 'connection_host', 'connection_user', etc.). NZ connection_z config.optionzmysql.)� startswith�len� IndexError�__salt__)rU �key�get_opts�prefix�val�Zconnargs�kwargsr; r< �_connargo s" � �z_connect.<locals>._connargZconnection_default_fileFr Z client_flag�__Z client_flagsz)MySQL client flag %s not valid, ignoring.Zconnection_hostri �connection_userrb �connection_pass�passwdZconnection_port�port� connection_db�db�connection_conv�convZconnection_unix_socket� unix_socketZread_default_fileZconnection_default_groupZread_default_groupZ use_unicodeZconnection_charset�charsetZpyformatz<MySQL password of None found. Attempting passwordless login.rj rk )NTr; )�dict�dirr rs �getattr�lowerro rR rn r: Z paramstyle�copy�deepcopy�warning�pop�connectr rm rg rd rq Z InternalErrorZ autocommit) r| r} rx Zavailable_client_flags�flagrw rX rp rq r; r{ r< rK i sf � � � �� rK c C s� t �d| � d}t| t�r,d}| �dd��dd�}| �di �}|�d d�}|�d d�}n| }d }t�|�}d |_d|_d |_ | j d 7 _ t |�}g }g } d} d } d} d} d }|| d� D ]�}|dkrl| dkrl| d7 } q]|dkr{| dkr{| d7 } d} q]|dkr�| dkr�| d7 } d} q]|dkr�| dkr�d} | d7 } q]|dkr�| dkr�d } | d7 } q]|dkr�| dkr�d } | d7 } q]| dkr�|| d dks�|| d dks�|| d dv r�| r�| � |� |� d� | �� g } ng| s�|}n|� d |� �}|� |� nU| � |� nO| dk�r | |7 } z || d d k�rd} W n8 t�y Y n3w | dk�r)| |7 } n#| d k�rC|�r3 n ||7 }|| d dk�rBd} n | d k�rL|} n| d7 } q]z|�s_|�d �}|�d �}t �d |||| � W n t�yu d }Y nw t|||| d �S ) a� This should correspond fairly closely to the YAML rendering of a mysql_grants state which comes out as follows: OrderedDict([ ('whatever_identifier', OrderedDict([ ('mysql_grants.present', [ OrderedDict([('database', 'testdb.*')]), OrderedDict([('user', 'testuser')]), OrderedDict([('grant', 'ALTER, SELECT, LOCK TABLES')]), OrderedDict([('host', 'localhost')]) ] ) ]) ) ]) :param grant: An un-parsed MySQL GRANT statement str, like "GRANT SELECT, ALTER, LOCK TABLES ON `mydb`.* TO 'testuser'@'localhost'" or a dictionary with 'qry' and 'args' keys for 'user' and 'host'. :return: A Python dict with the following keys/values: - user: MySQL User - host: MySQL host - grant: [grant1, grant2] (ala SELECT, USAGE, etc) - database: MySQL DB z_grant_to_tokens entry '%s'FTr[ Z undefined�%%�%rg ri rb r8 z'`�"� �grantsN�,�(�)ZONr� ZTO�tables�@zpre-host)r� r� � rI �'z%grant to token '%s'::'%s'::'%s'::'%s'�rb ri �grant�database)rR rS � isinstancer� ro �replace�shlex�quotesZwhitespace_splitZ commentersZ wordchars�list�append�joinru �strip�UnboundLocalError)r� Z dict_modeZ grant_sqlZsql_argsri rb ZlexZexploded_grant� grant_tokensZmultiword_statementZposition_trackerr� �phraserc Z current_grant�tokenr; r; r< �_grant_to_tokens� s� �� � ��r� c C s� d|vr| S d}d}d}g }| D ]C}t jj�||�dkr&|dkr&|�d� qt jj�||�dkr:|dkr:|�d � qt jj�||�dkrN|d krN|�d � q|�|� q|S ) a� There can be a situation where the database supports grants "A" and "B", where "B" is an alias for "A". In that case, when you want to grant "B" to a user, the database will actually report it added "A". We need to resolve those aliases to not report (wrong) errors. :param grants: the tokenized grants :param server_version: version string of the connected database �MariaDBz10.5.1z10.5.2z10.5.9r r& r' r% r r$ r1 )�salt�utils�versions� version_cmpr� )r� �server_versionZ+mariadb_version_compare_replication_replicaZ&mariadb_version_compare_binlog_monitorZ%mariadb_version_compare_slave_monitorZresolved_tokensr� r; r; r< �_resolve_grant_aliasesv sB �� �� �� r� c C sD |rd| � dd�� dd�� dd� d S d| � dd�� dd� d S )a� Return an identifier name (column, table, database, etc) escaped for MySQL This means surrounded by "`" character and escaping this character inside. It also means doubling the '%' character for MySQLdb internal usage. :param identifier: the table, column or database identifier :param for_grants: is False by default, when using database names on grant queries you should set it to True to also escape "_" and "%" characters as requested by MySQL. Note that theses characters should only be escaped when requesting grants on the database level (`my\_\%db`.*) but not for table level grants (`my_%db`.`foo`) CLI Example: .. code-block:: bash salt '*' mysql.quote_identifier 'foo`bar' �`z``�_z\_r� r� )r� )Z identifier� for_grantsr; r; r< rO � s ��� rO c C sP |du s|i kr|� dd�}t�d|� | �|�S t�d|t|�� | �||�S )a Internal wrapper around MySQLdb cursor.execute() function MySQLDb does not apply the same filters when arguments are used with the query. For example '%' characters on the query must be encoded as '%%' and will be restored as '%' when arguments are applied. But when there're no arguments the '%%' is not managed. We cannot apply Identifier quoting in a predictable way if the query are not always applying the same filters. So this wrapper ensure this escape is not made if no arguments are used. Nr� r� zDoing query: %szDoing query: %s args: %s )r� rR rS �execute�repr)rY r[ rg r; r; r< rP � s rP c C s t s t�d� | S tj| dd�S )NzE_sanitize_comments unavailable, no python sqlparse library installed.T)Zstrip_comments)� HAS_SQLPARSErR rn �sqlparserm )�contentr; r; r< �_sanitize_comments� s �r� c K s t jj}t|�}tt|tgt|� ��}ddi}|�t j � � �rDt j tfg|t j< t j tfg|t j< t j tfg|t j< t j tfg|t j< |�| |d�� tdi |��}|du rYi S |�� }t�� } t�d| |� zt||�} W n" ty� } zdj| j� } | t d< t� | � W Y d} ~ dS d} ~ ww |� � } t�� | }|d k r�tt |d d ��d }n tt |d ��d }i }|tt |d��d�|d< g d�}d}|D ]}|� � � � �!|�r�d} nq�|r�| |d< d}|j"D ] }||d f7 }q�||d< | |d< |S | |d< |S )a Run an arbitrary SQL query and return the results or the number of affected rows. CLI Example: .. code-block:: bash salt '*' mysql.query mydb "UPDATE mytable set myfield=1 limit 1" Return data: .. code-block:: python {'query time': {'human': '39.0ms', 'raw': '0.03899'}, 'rows affected': 1L} CLI Example: .. code-block:: bash salt '*' mysql.query mydb "SELECT id,name,cash from users limit 3" Return data: .. code-block:: python {'columns': ('id', 'name', 'cash'), 'query time': {'human': '1.0ms', 'raw': '0.001'}, 'results': ((1L, 'User 1', Decimal('110.000000')), (2L, 'User 2', Decimal('215.636756')), (3L, 'User 3', Decimal('0.040000'))), 'rows returned': 3L} CLI Example: .. code-block:: bash salt '*' mysql.query mydb 'INSERT into users values (null,"user 4", 5)' Return data: .. code-block:: python {'query time': {'human': '25.6ms', 'raw': '0.02563'}, 'rows affected': 1L} CLI Example: .. code-block:: bash salt '*' mysql.query mydb 'DELETE from users where id = 4 limit 1' Return data: .. code-block:: python {'query time': {'human': '39.0ms', 'raw': '0.03899'}, 'rows affected': 1L} Jinja Example: Run a query on ``mydb`` and use row 0, column 0's data. .. code-block:: jinja {{ salt['mysql.query']('mydb', 'SELECT info from mytable limit 1')['results'][0][0] }} ZMYSQLDBT)r� r� Nz Using db: %s to run query %srj rk Fg�������?i� r� �ms� �s� )�human�raw� query time)r, ZSHOWZDESC� rows returnedr; r �columnsr\ � rows affected)#r: Z convertersZ conversions�iterr� �zip�strrt ro � __package__rD r ZBINARYr ZBLOB�STRINGZ VAR_STRINGZVARCHAR�updaterK rL �timerR rS rP r rm rg rd rn rQ �roundr� rs � description)r� �queryrW Z orig_convZ conv_iterr� Z conv_mysqldbrX rY �startZaffectedrp rq r\ �elapsedZ elapsed_h�retZselect_keywordsZ select_query�keywordr� rc r; r; r< r� � sj F � � � � �� � r� c s� t s t�d� dS t� fdd�dD ��rtd � �� tj�� �rBtj j � � d��}tj j � |�� �}W d � n1 s<w Y nt�d � � dS d }d g g d d d id �}t|�}|�� D ]m}t�d|�sk|| }q^|| }t| |fi |��}d }|du r� dS d|v r�|d d t|d d �7 < d|v r�|d |d 7 < d|v r�|d �|d � d|v r�|d �|d � d|v r�|d |d 7 < q^ttt|d d �d��d |d d< tt|d d �d�|d d < dd� |�� D �}|S )ar Run an arbitrary SQL query from the specified file and return the the number of affected rows. .. versionadded:: 2017.7.0 database database to run script inside file_name File name of the script. This can be on the minion, or a file that is reachable by the fileserver CLI Example: .. code-block:: bash salt '*' mysql.file_query mydb file_name=/tmp/sqlfile.sql salt '*' mysql.file_query mydb file_name=salt://sqlfile.sql Return data: .. code-block:: python {'query time': {'human': '39.0ms', 'raw': '0.03899'}, 'rows affected': 1L} zCmysql.file_query unavailable, no python sqlparse library installed.Fc 3 s � | ]}� � |�V qd S �N)rs )�.0�proto�� file_namer; r< � <genexpr>� s � � �z file_query.<locals>.<genexpr>)zsalt://zhttp://zhttps://zswift://zs3://z cp.cache_file�rNzFile "%s" does not existr8 r r� )r� r� r\ r� r� z[^-;]+;r� r� r� r\ r� r� r� r� r� c S s i | ] \}}|r||�qS r; r; )r� �k�vr; r; r< � <dictcomp>� s z file_query.<locals>.<dictcomp>)r� rR rn �anyrv �os�path�existsr� r� �filesZfopenZ stringutilsZ to_unicode�readr� � splitlines�re�searchr� �floatr� r� r� �items) r� r� rW Zifile�contentsZ query_stringr� �lineZ query_resultr; r� r< � file_queryv s\ � �� � � �& r� c K s� t di | ��}|du r i S |�� }d}zt||� W n# ty= } zdj|j� }|td< t�|� i W Y d}~S d}~ww i }t |j �D ]}|� � }|d ||d < qE|S )z� Return the status of a MySQL server using the output from the ``SHOW STATUS`` query. CLI Example: .. code-block:: bash salt '*' mysql.status Nz SHOW STATUSrj rk r� r r; ) rK rL rP r rm rg rd rR rn �rangerf �fetchone) rW rX rY r[ rp rq r� r� �rowr; r; r< �status� s& ��r� c K s� dt v rt d S tdi | ��}|du rdS |�� }d}zt||� W n# tjyE } zdj|j� }|t d< t� |� W Y d}~dS d}~ww zt j j � |�� d �t d< t d W S tyb Y dS w ) z� Return the version of a MySQL server using the output from the ``SELECT VERSION()`` query. CLI Example: .. code-block:: bash salt '*' mysql.version z mysql.versionNr8 zSELECT VERSION()rj rk r r; )rd rK rL rP r: r rm rg rR rn r� r� �data�decoder� ru )rW rX rY r[ rp rq r; r; r< �version� s, �� �r� c K s� t d i | ��}|du r dS |�tjj�}d}zt||� W n# tjy@ } zdj|j� }|t d< t � |� W Y d}~dS d}~ww |� � }|j dkrLdS |d d krV|d S d S ) a� Return the number of seconds that a slave SQL server is lagging behind the master, if the host is not a slave it will return -1. If the server is configured to be a slave for replication but slave IO is not running then -2 will be returned. If there was an error connecting to the database or checking the slave status, -3 will be returned. CLI Example: .. code-block:: bash salt '*' mysql.slave_lag N����show slave statusrj rk r ���ZSlave_IO_RunningZYesZSeconds_Behind_Master���r; )rK rL r: rM rN rP r rm rg rd rR rn r� rf �rW rX rY r[ rp rq r\ r; r; r< � slave_lag s( �� r� c K s� t d i | ��}|du r dS |�tjj�}|�d� |�� }d|d i}z t d i |��}|du r2W dS |�� }|�d� |�� W n tjyJ Y nw |�d� |�d� |�d � |�d� |�� }|du rid S d S ) z� Frees a slave from its master. This is a WIP, do not use. CLI Example: .. code-block:: bash salt '*' mysql.free_slave Nr8 r� ri Z Master_Hostz flush logsz stop slavez reset masterz change master to MASTER_HOST=ZpromotedZfailedr; ) rK rL r: rM rN r� r� �closer )rW Zslave_dbZ slave_curZ slave_statusZmasterZ master_dbZ master_curr\ r; r; r< � free_slave< s2 � r� c K s� t di | ��}|du r g S |�� }d}zt||� W n$ tjy> } zdj|j� }|td< t� |� g W Y d}~S d}~ww g }|� � }|D ] }|� |d � qGt� |� |S )z� Return a list of databases of a MySQL server using the output from the ``SHOW DATABASES`` query. CLI Example: .. code-block:: bash salt '*' mysql.db_list Nr. rj rk r r; � rK rL rP r: r rm rg rd rR rn rQ r� rS � rW rX rY r[ rp rq r� r\ Zdbsr; r; r< �db_listj s( �� r c K s� t d i |��}|du r g S |�� }t| fi |��}d�| |p"|�d�|p(|�d��}i }zt|||�r<t�d| � W dS W d S tj ya } zdj| j � } | t d< t� | � W Y d} ~ d S d} ~ ww ) z� Modify database using ``ALTER DATABASE %(dbname)s CHARACTER SET %(charset)s COLLATE %(collation)s;`` query. CLI Example: .. code-block:: bash salt '*' mysql.alter_db testdb charset='latin1' Nz0ALTER DATABASE `{}` CHARACTER SET {} COLLATE {};� character_set�collatezDB '%s' alteredTrj rk Fr; ) rK rL �db_getrm ro rP rR �infor: r rg rd rn ) rU r r rW rX rY �existingr[ rg rp rq r; r; r< �alter_db� s0 � �� ��r c K s� t d i |��}|du r g S |�� }d}d| i}zt|||� W n$ tjyC } zdj|j� }|td< t� |� g W Y d}~S d}~ww |j rX|� � }|d d |d d d�S i S ) a* Return a list of databases of a MySQL server using the output from the ``SELECT DEFAULT_CHARACTER_SET_NAME, DEFAULT_COLLATION_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME='dbname';`` query. CLI Example: .. code-block:: bash salt '*' mysql.db_get test NzxSELECT DEFAULT_CHARACTER_SET_NAME, DEFAULT_COLLATION_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME=%(dbname)s;�dbnamerj rk r r� )r r r; ) rK rL rP r: r rm rg rd rR rn rf rQ ) rU rW rX rY r[ rg rp rq Zrowsr; r; r< r � s( � ��r c K s� t | fi |��st�d| � dS tdi |��}|du r g S |�� }t| �}d|� �}zt||� W n$ tjyU } zdj |j � }|t d< t� |� g W Y d}~S d}~ww g }|� � } | D ] } |�| d � q^t�|� |S ) z� Shows the tables in the given MySQL database (if exists) CLI Example: .. code-block:: bash salt '*' mysql.db_tables 'database' z Database '%s' does not existFNzSHOW TABLES IN rj rk r r; )� db_existsrR r rK rL rO rP r: r rm rg rd rn rQ r� rS ) rU rW rX rY rZ r[ rp rq r� r\ rV r; r; r< � db_tables� s0 �� r c K s� t di |��}|du r dS |�� }d| i}d}zt|||� W n# tjyB } zdj|j� }|td< t� |� W Y d}~dS d}~ww |� � |j dkS ) z� Checks if a database exists on the MySQL server. CLI Example: .. code-block:: bash salt '*' mysql.db_exists 'dbname' NFr z SHOW DATABASES LIKE %(dbname)s;rj rk r� r; ) rK rL rP r: r rm rg rd rR rn rQ rf )rU rW rX rY rg r[ rp rq r; r; r< r � s" �� r c K s� t | fi |��rt�d| � dS tdi |��}|du r dS |�� }t| �}d|� �}i }|dur8|d7 }||d< |durD|d7 }||d< |d 7 }zt|||�rXt�d | � W d S W dS tjy} } zd j | j � } | t d < t� | � W Y d} ~ dS d} ~ ww )a� Adds a databases to the MySQL server. name The name of the database to manage character_set The character set, if left empty the MySQL default will be used collate The collation, if left empty the MySQL default will be used CLI Example: .. code-block:: bash salt '*' mysql.db_create 'dbname' salt '*' mysql.db_create 'dbname' 'utf8' 'utf8_general_ci' zDB '%s' already existsFNz CREATE DATABASE IF NOT EXISTS z CHARACTER SET %(character_set)sr z COLLATE %(collate)sr �;zDB '%s' createdTrj rk r; � r rR r rK rL rO rP r: r rm rg rd rn ) rU r r rW rX rY rZ r[ rg rp rq r; r; r< � db_create s< �� ��r c K s� t | fi |��st�d| � dS | dv r t�d| � dS td i |��}|du r)dS |�� }t| �}d|� d�}zt||� W n# tjya } zdj |j � }|t d < t� |� W Y d}~dS d}~ww t | fi |��srt�d | � d S t�d | � dS )z� Removes a databases from the MySQL server. CLI Example: .. code-block:: bash salt '*' mysql.db_remove 'dbname' zDB '%s' does not existF)ra Zinformation_schemezDB '%s' may not be removedNzDROP DATABASE r rj rk z Database '%s' has been removedTz"Database '%s' has not been removedr; r )rU rW rX rY rZ r[ rp rq r; r; r< � db_removeH s4 �� r c K s� t di | ��}|du r g S |�tjj�}z d}t||� W n$ tjyA } zdj|j� }|t d< t � |� g W Y d}~S d}~ww |� � }t � |� |S )z� Return a list of users on a MySQL server CLI Example: .. code-block:: bash salt '*' mysql.user_list Nz SELECT User,Host FROM mysql.userrj rk r; )rK rL r: rM rN rP r rm rg rd rR rn rQ rS r� r; r; r< � user_listt s" �� r � localhostrl c K s6 t jj�tdi |���} d} d} i } | | d< || d< t jj�|�r@t jj�|�r4| d7 } d| d< | | fS | d| d 7 } | | fS |r�t jj�| | �d krw|d krhtt |��} | d| d 7 } t | �| d < | | fS d}t � |� |t d< | | fS | d| d 7 } t |�| d < | | fS |r�| d| d 7 } || d < | | fS )N�8.0.11�JSELECT User,Host FROM mysql.user WHERE User = %(user)s AND Host = %(host)srb ri � AND plugin=%(unix_socket)s� auth_socketr� � AND � = ''r rl � = %(password)srE zUnable to verify password.rk � = PASSWORD(%(password)s)r; ) r� r� r� r� r� �is_truer� r� rG r� rR rn rd )rb ri rE � password_hash� passwordlessr� �password_column� auth_pluginrW r� �compare_versionr[ rg rF rq r; r; r< �_mysql_user_exists� s> �� � � �r c K s� d} i } | | d< || d< t jj�|�r2t jj�|�r&| d7 } d| d< | | fS | d| d 7 } | | fS |rF| d| d 7 } t|�| d < | | fS |rT| d| d 7 } || d < | | fS ) Nr rb ri r r� r r r rE r )r� r� r� r r� ) rb ri rE r r r� r r rW r[ rg r; r; r< �_mariadb_user_exists� s& �� �r c K s� d}t jj�td i |���} | s8|r8dtd< ||d< t jj�td i |���} | s8td } d�| �} t�| � dS t d i |��} | du r_td � d| � d��r_|r_dtd< ||d< t d i |��} | du redS |snt d i |��}t | |fi |��} | � � }d| v r�t| |||||f|| d �|��\}}nt| |||||f|| d �|��\}}zt|||� W n# tjy� } zd j|j� } | td< t�| � W Y d}~dS d}~ww |jd kS ) ar Checks if a user exists on the MySQL server. A login can be checked to see if passwordless login is permitted by omitting ``password`` and ``password_hash``, and using ``passwordless=True``. .. versionadded:: 0.16.2 The ``passwordless`` option was added. CLI Example: .. code-block:: bash salt '*' mysql.user_exists 'username' 'hostname' 'password' salt '*' mysql.user_exists 'username' 'hostname' password_hash='hash' salt '*' mysql.user_exists 'username' passwordless=True salt '*' mysql.user_exists 'username' password_column='authentication_string' FNrk r� �IMySQL Error: Unable to fetch current server version. Last error was: "{}"z*MySQL Error 1045: Access denied for user 'z'@r� �r r rj r� r; )r� r� r� r� r� rd rm rR rn rK rs rh rr rL r r rP r: r rg rf )rb ri rE r r r� r rW Z run_verifyr� �last_errrq rX r rY r[ rg rp r; r; r< � user_exists� s� � ����� � �� � �� r# c K s� t di |��}|du r dS |�tjj�}d}i }| |d< ||d< zt|||� W n# tjyK } zdj|j� }|t d< t � |� W Y d}~dS d}~ww |� � } t � | � | S ) z� Get full info on a MySQL user CLI Example: .. code-block:: bash salt '*' mysql.user_info root localhost NFzBSELECT * FROM mysql.user WHERE User = %(user)s AND Host = %(host)srb ri rj rk r; )rK rL r: rM rN rP r rm rg rd rR rn r� rS ) rb ri rW rX rY r[ rg rp rq �resultr; r; r< � user_infoG s( �� r% c K sR t jj�tdi |���} d} d} i } | | d< || d< |rOtdi |��s4d} t�| � | td< d} | | fS |d kr@| d 7 } | | fS t�d � | td< d} | | fS t jj� |�s�|d ur{t jj � | | �d krm|| d < | d7 } n| d7 } t |�| d< | | fS |d ur�t jj � | | �d kr�|| d < | d7 } n| d7 } || d< | | fS t�d� d} | | fS )Nr � CREATE USER %(user)s@%(host)srb ri r �&The auth_socket plugin is not enabled.rk Fr z IDENTIFIED WITH auth_socket�7Auth via unix_socket can be set only for host=localhostr r z0 IDENTIFIED WITH %(auth_plugin)s BY %(password)s� IDENTIFIED BY %(password)srE z0 IDENTIFIED WITH %(auth_plugin)s AS %(password)s�$ IDENTIFIED BY PASSWORD %(password)s�Kpassword or password_hash must be specified, unless allow_passwordless=Truer; �r ) r� r� r� r� r� � plugin_statusrR rn rd r r� r� r� )rb ri rE r �allow_passwordlessr� r r rW r� r r[ rg rq r; r; r< �_mysql_user_createg sX $�! � �� �� ��r/ c K s� d} i } | | d< || d< |rAt di |��s&d} t�| � | td< d} | | fS |dkr2| d 7 } | | fS t�d � | td< d} | | fS tjj�|�sq|d urZ| d 7 } t|�| d < | | fS |d urj| d 7 } || d < | | fS t�d� d} | | fS )Nr& rb ri r� �&The unix_socket plugin is not enabled.rk Fr z IDENTIFIED VIA unix_socketr( r) rE r* r+ �r� ) r- rR rn rd r� r� r� r r� ) rb ri rE r r. r� r r rW r[ rg rq r; r; r< �_mariadb_user_create� s@ � �� ���r2 c K s� t jj�tdi |���} | s6|r6dtd< ||d< t jj�tdi |���} | s6td } d�| �} t�| � dS t | |fi |��rHt� d| |� dS t di |��} | du rUdS |s^t di |��}| � � } d| v ryt| |||||f||d�|��\}}nt| |||||f||d�|��\}}t|t�r�|S zt| ||� W n# tjy� } zd j|j� } | td< t�| � W Y d}~dS d}~ww t | |||fd |i|��r�d | � d |� d �}t||f�s�|d7 }t� |� dS t� d| |� dS )aq Creates a MySQL user host Host for which this user/password combo applies password The password to use for the new user. Will take precedence over the ``password_hash`` option if both are specified. password_hash The password in hashed form. Be sure to quote the password because YAML doesn't like the ``*``. A password hash can be obtained from the mysql command-line client like so:: mysql> SELECT PASSWORD('mypass'); +-------------------------------------------+ | PASSWORD('mypass') | +-------------------------------------------+ | *6C8989366EAF75BB670AD8EA7A7FC1176A95CEF4 | +-------------------------------------------+ 1 row in set (0.00 sec) allow_passwordless If ``True``, then ``password`` and ``password_hash`` can be omitted (or set to ``None``) to permit a passwordless login. unix_socket If ``True`` and allow_passwordless is ``True`` then will be used unix_socket auth plugin. password_column The password column to use in the user table. auth_plugin The authentication plugin to use, default is to use the mysql_native_password plugin. .. versionadded:: 0.16.2 The ``allow_passwordless`` option was added. CLI Examples: .. code-block:: bash salt '*' mysql.user_create 'username' 'hostname' 'password' salt '*' mysql.user_create 'username' 'hostname' password_hash='hash' salt '*' mysql.user_create 'username' 'hostname' allow_passwordless=True Nrk r� r Fz User '%s'@'%s' already existsr� r! rj r zUser 'z'@'z' has been createdz with passwordless loginTz User '%s'@'%s' was not createdr; )r� r� r� r� r� rd rm rR rn r# r rK rh rL r2 r/ r� r9 rP r: r rg r� )rb ri rE r r. r� r r rW r� r" rq rX rY r[ rg rp �msgr; r; r< � user_create� s� :� �� � �� � ����� r4 c K s� t jj�tdi |���} d} i } |d ur(t jj�| | �dkr!d} nd} || d< n|d ur3d} || d< nt jj�|�sAt� d� dS d} | | d < || d < t jj�| | �dkrm|| d < d } |d urd| d 7 } n|d url| d7 } n d| d | d } t jj�|�r�t jj�|�r�|dkr�t di |��s�d}t� |� |t d< d} | | fS d| d< t jj�| | �dkr�d} | | fS d| d | d d } | | fS t� d� | | fS ) Nr r � %(password)s�PASSWORD(%(password)s)rE r+ F�''rb ri r z=ALTER USER %(user)s@%(host)s IDENTIFIED WITH %(auth_plugin)s zBY %(password)s;zAS %(password)s;�UPDATE mysql.user SET �=�) WHERE User=%(user)s AND Host = %(host)s;r r r' rk r� zIALTER USER %(user)s@%(host)s IDENTIFIED WITH %(unix_socket)s AS %(user)s;�, plugin=%(unix_socket)sr( r; r, ) r� r� r� r� r� r� r� r rR rn r- rd �rb ri rE r r. r� r r rW r� r rg Z password_sqlr[ rq r; r; r< �_mysql_user_chpassc s� � ������� ���������� �r= c K sH t jj�tdi |���} d} i } |d urd} || d< n|d ur&d} || d< nt jj�|�s4t�d� dS d} | | d< || d < t jj� | | �d krS|| d < d } | | 7 } n d | d | d } t jj�|�r�t jj�|�r�|dkr�t di |��s�d}t�|� |t d< d} | | fS d| d< d | d | d d } | | fS t�d� | | fS )Nz10.4r6 rE r5 r+ Fr7 rb ri r r zBALTER USER %(user)s@%(host)s IDENTIFIED VIA %(auth_plugin)s USING r8 r9 r: r r� r0 rk r; r( r; r1 ) r� r� r� r� r� r rR rn r� r� r- rd r< r; r; r< �_mariadb_user_chpass� sr � ������ ������� �r> c K s$ t jj�tdi |���}|s6|r6dtd< ||d< t jj�tdi |���}|s6td } d�| �} t�| � dS t | |fi |��sHt� d| |� dS t di |��} | du rUdS |s^t di |��}t | |fi |��} | �� } d|v r�t| |||||f|| d�|��\}}nt| |||||f|| d�|��\}}zt| ||�}W n# tjy� } zd j|j� } | td< t�| � W Y d}~dS d}~ww d|v r�d nd }d}t jj�||�d kr�t| d � d}n |r�t| d � d}|r�t� d| |t||f�r�d� dS d� dS t� d| |t||f��r d� dS d� dS )a? Change password for a MySQL user host Host for which this user/password combo applies password The password to set for the new user. Will take precedence over the ``password_hash`` option if both are specified. password_hash The password in hashed form. Be sure to quote the password because YAML doesn't like the ``*``. A password hash can be obtained from the mysql command-line client like so:: mysql> SELECT PASSWORD('mypass'); +-------------------------------------------+ | PASSWORD('mypass') | +-------------------------------------------+ | *6C8989366EAF75BB670AD8EA7A7FC1176A95CEF4 | +-------------------------------------------+ 1 row in set (0.00 sec) allow_passwordless If ``True``, then ``password`` and ``password_hash`` can be omitted (or set to ``None``) to permit a passwordless login. .. versionadded:: 0.16.2 The ``allow_passwordless`` option was added. CLI Examples: .. code-block:: bash salt '*' mysql.user_chpass frank localhost newpassword salt '*' mysql.user_chpass frank localhost password_hash='hash' salt '*' mysql.user_chpass frank localhost allow_passwordless=True Nrk r� r F� User '%s'@'%s' does not existsr� r! rj z10.4.0r r zFLUSH PRIVILEGES;Tz'Password for user '%s'@'%s' has been %s�changedZclearedz&Password for user '%s'@'%s' was not %sr; )r� r� r� r� r� rd rm rR rn r# r rK rh rr rL r> r= rP r: r rg r� r� r� )rb ri rE r r. r� r rW r� r" rq rX r rY r[ rg r$ rp r �resr; r; r< � user_chpass s� 0� �� � �� � �� ������rB c K s� t | |fi |��sd| |f}|td< t�|� dS td i |��}|du r&dS |�� }d}i }| |d< ||d< zt|||� W n# tjya } zdj |j � }|td< t� |� W Y d}~dS d}~ww t | |fi |��stt�d | |� d S t�d | |� dS ) z{ Delete MySQL user CLI Example: .. code-block:: bash salt '*' mysql.user_remove frank localhost r? rk FNzDROP USER %(user)s@%(host)srb ri rj z User '%s'@'%s' has been removedTz#User '%s'@'%s' has NOT been removedr; ) r# rd rR r rK rL rP r: r rm rg rn ) rb ri rW rq rX rY r[ rg rp r; r; r< � user_remove� s6 ��rC c C s t | �S )z� External wrapper function :param grant: :return: dict CLI Example: .. code-block:: bash salt '*' mysql.tokenize_grant "GRANT SELECT, INSERT ON testdb.* TO 'testuser'@'localhost'" )r� )r� r; r; r< �tokenize_grant� s rD c K �t g }|du r(t | fi |��}|D ]}t�d| |� |�t| |fi |��� q|S t�d| |� t| |fi |��}|S )z� Repairs the full database or just a given table CLI Example: .. code-block:: bash salt '*' mysql.db_check dbname salt '*' mysql.db_check dbname dbtable Nz Checking table '%s' in db '%s'..)r rR r r� r] �rU rV rW r� r� r; r; r< �db_check� s �rG c K rE )z� Repairs the full database or just a given table CLI Example: .. code-block:: bash salt '*' mysql.db_repair dbname Nz!Repairing table '%s' in db '%s'..)r rR r r� r_ rF r; r; r< � db_repair� � �rH c K rE )z� Optimizes the full database or just a given table CLI Example: .. code-block:: bash salt '*' mysql.db_optimize dbname Nz"Optimizing table '%s' in db '%s'..)r rR r r� r` rF r; r; r< � db_optimize� rI rJ c C sN | � � �� dkr d} t| �}|D ]\}}|� � �� tvr$td|� d���q| S )N�ALLr zInvalid grant : 'r� )r� rD � __grant_split� __grants__� Exception)r� Zexploded_grantsZchkgrantr� r; r; r< �__grant_normalize s �rO c C s t �d�}|�| �S )Nz([\w\s]+)(\([^)(]*\))?\s*,?)r� �compile�findall)r� �patternr; r; r< rL ! s rL c C s� g }| D ]9}t t|�� ��}|�� �� }|tvr td|� d���|tv r4|�d� ||| � dd��� q|| r=|�|� qdd� |� S )NzInvalid SSL option : 'r� z{} '{}'r8 z REQUIRE r ) �nextr� �keysr� rD �__ssl_options__rN � __ssl_options_parameterized__r� rm r� r� )� ssl_optionZnew_ssl_option�optrw Z normal_keyr; r; r< �__ssl_option_sanitize& s � �rY c C s� t �dd| ��� } t| �} |�d�}|d }|d } |r0|dkr(t|| dkd�}| dkr0t| �} d| � d |� d| � d �} i } || d < || d < |rSt|t�rS| t|�7 } t j j � |�r^| d 7 } t �d| t| �� | | d�S )z� Validate grants and build the query that could set the given grants Note that this query contains arguments for user and host but not for grants or database. z\s*,\s*z, rI r r� r> �r� zGRANT � ON z TO %(user)s@%(host)srb ri � WITH GRANT OPTIONz!Grant Query generated: %s args %s)r[ rg )r� �subrD rO � rpartitionrO r� r� rY r� r� r� r rR rS r� ) r� r� rb ri � grant_option�escaperW �db_partrX rV r[ rg r; r; r< �__grant_generate? s( rb c K s t | |fi |��st�d| |� dS td i |��}|du r dS |�� }d}i }| |d< ||d< zt|||� W n# tjyZ } zdj|j � }|t d< t� |� W Y d}~dS d}~ww g } t j j�|�� �} | D ] } | d �d �d } d | d v r�d | vr�| � d �} | �| � qht�| � | S )z� Shows the grants for the given MySQL user (if it exists) CLI Example: .. code-block:: bash salt '*' mysql.user_grants 'frank' 'localhost' z User '%s'@'%s' does not existFNz!SHOW GRANTS FOR %(user)s@%(host)srb ri rj rk r z IDENTIFIED BYzWITH GRANT OPTIONr\ r; )r# rR r rK rL rP r: r rm rg rd rn r� r� r� r� rQ �splitr� rS ) rb ri rW rX rY r[ rg rp rq r� r\ r� �tmpr; r; r< � user_grantsl s: �� re c K s� z t di | ��}W n ty Y dS w |du rdS |�� }zt|d� W n! tyF } zd|� �}|td< t�|� W Y d}~dS d}~ww h d�}g }tjj � |� � �D ]}|s[qV|d � � � � }||v rhqV|�|� qV|pqdS )ao Return the list of privileges the connected MySQL server reports via ``SHOW PRIVILEGES`` (excluding ``USAGE``, ``GRANT OPTION``, and ``PROXY``, which are not granted by ``GRANT ALL PRIVILEGES``). Returns ``None`` if the query fails (no connection, no permission, etc.) so callers can fall back to the hard-coded ``__all_privileges__`` list. NzSHOW PRIVILEGESz MySQL Error: rk > ZPROXYr6 r r r; )rK rN rL rP rd rR rn r� r� r� r� rQ r� rD r� ) rW rX rY rp rq ZexcludedZ privilegesr� rU r; r; r< �_server_all_privileges� s6 � �� rf c s t jj�td i |���}|s td }d�|�} t�| � dS d} d| � � v rFt jj � |d�dkrFd|vrF|d krFt d i |��} t | pCt�} nd| � � v rNd } | du r�z t| |||||�} W n tyz } zt�d � t�| � W Y d} ~ dS d} ~ ww t| �}n d} ||| |d �}t||fi |��}|du r�t�d � dS i }|D ]6} t| �}t|d |�|d< |d |vr�|d |d |d |d d�||d < q�||d d �|d � q�t|d |�|d< |�� D ]�\}� zei }i }� fdd�|d D �}dD ]&}� | �dd��dd��dd�||< || �dd��dd��dd�||< q�|d |d k�rF|d |d k�rF|d |d k�rFt|��rFW dS t�d� |� W q� t�y� } z't�| � | du�rx|du�rx| |v �rxt�d � W Y d} ~ dS W Y d} ~ q�d} ~ ww t�d � dS ) z� Checks to see if a grant exists in the database CLI Example: .. code-block:: bash salt '*' mysql.grant_exists 'SELECT,INSERT,UPDATE,...' 'database.*' 'frank' 'localhost' rk r FNrK z8.0r r� z*.*r z Error during grant generation.r� z�Grant does not exist or may not be ordered properly. In some cases, this could also indicate a connection error. Check your configuration.r� r� rb ri )rb r� ri r� c s g | ] }|� d v r dnd�qS )r� TFr; )r� �i�r� r; r< � <listcomp> s ��z grant_exists.<locals>.<listcomp>)rb r� ri r� r8 �\r� Tzgrants mismatch '%s'<>'%s'z Grant exists.z9Grant does not exist, or is perhaps not ordered properly?r; )r� r� r� r� r� rd rm rR rn rD r� r� rf r� �__all_privileges__rb rN r� re r� �extendr� r� �allrS � exception)r� r� rb ri r_ r` rW r� r" rq Z target_privsZ server_privs�targetrp Z target_tokensr� Z_grantsZ grant_tokenZ _grant_tokensZ_target_tokensZ_grant_matches�itemr; rh r< � grant_exists� s� � �� ��� � � ���� �� rq c K s t d i |��}|du r dS |�� } | �� } z t| ||||||�} W n ty0 t�d� Y dS w z t| | d | d � W n& tj tj fyc } zdj | j � } | t d< t�| � W Y d} ~ dS d} ~ ww t| |||||fi |��r{t�d| ||� d S t�d | ||� dS ) a Adds a grant to the MySQL server. For database, make sure you specify database.table or database.* CLI Example: .. code-block:: bash salt '*' mysql.grant_add 'SELECT,INSERT,UPDATE,...' 'database.*' 'frank' 'localhost' NFz Error during grant generationr[ rg rj rk z/Grant '%s' on '%s' for user '%s' has been addedTz3Grant '%s' on '%s' for user '%s' has NOT been addedr; )rK rL r� rb rN rR rn rP r: r ZProgrammingErrorrm rg rd rq r ) r� r� rb ri r_ r` rW rW rX rY r[ rp rq r; r; r< � grant_addE sF � � �� ����rr c K sT t di |��}|du r dS |�� }t| �} tjj�|�r | d7 } |�d�} | d }| d } |dkr9t|| dkd�} |dkr?|} | dkrGt| �} d | � d | � d| � d �} i } || d < || d < zt || | � W n# t j y� } zdj |j � }|td< t�|� W Y d}~dS d}~ww t| |||||fi |��s�t�d| ||� dS t�d| ||� dS )z� Removes a grant from the MySQL server. CLI Example: .. code-block:: bash salt '*' mysql.grant_revoke 'SELECT,INSERT,UPDATE' 'database.*' 'frank' 'localhost' NFz, GRANT OPTIONrI r r� r> rZ zREVOKE r[ z FROM %(user)s@%(host)s;rb ri rj rk z1Grant '%s' on '%s' for user '%s' has been revokedTz5Grant '%s' on '%s' for user '%s' has NOT been revokedr; )rK rL rO r� r� r� r r^ rO rP r: r rm rg rd rR rn rq r )r� r� rb ri r_ r` rW rX rY ra rV Z s_databaser[ rg rp rq r; r; r< � grant_revoke~ s` �� ����rs c K s� g }t di | ��}|du rg S |�� }t|d� dd� |jD �}t|j�D ] }|�� }i }t|�D ] \}} || ||| < q1|�|� q%|� � |S )a( Retrieves the processlist from the MySQL server via "SHOW FULL PROCESSLIST". Returns: a list of dicts, with each dict representing a process: .. code-block:: python {'Command': 'Query', 'Host': 'localhost', 'Id': 39, 'Info': 'SHOW FULL PROCESSLIST', 'Rows_examined': 0, 'Rows_read': 1, 'Rows_sent': 0, 'State': None, 'Time': 0, 'User': 'root', 'db': 'mysql'} CLI Example: .. code-block:: bash salt '*' mysql.processlist NzSHOW FULL PROCESSLISTc S s g | ]}|d �qS )r r; )r� �cr; r; r< ri � s z processlist.<locals>.<listcomp>r; ) rK rL rP r� r� rf r� � enumerater� r� ) rW r� rX rY �hdrr� r� Zidx_rZidx_jZvalue_jr; r; r< � processlist� s rw c C s t �� jj}t�d||� g }d}z| �� }W n tjy6 t� d||� |r,|� � t�d|� | Y S w zt ||� W n tjy[ t� d||� |� � t�d|� | Y S w |� � }|D ] }d}i }|j D ]} | d } || || < |d7 }qk|�|� qb|� � t�d|� |S )zd Perform the query that is passed to it (sql_str). Returns: results in a dict. z %s<--(%s)Nz %s: Can't get cursor for SQL->%sz%s-->z %s: try to execute : SQL->%sr r� )�sys� _getframe�f_code�co_namerR rS rL r: Z MySQLErrorrn r� rP rQ r� r� ) �connZsql_str�modZ rtn_resultsrL ZqrsZrow_dataZcol_cntr� Zcol_dataZcol_namer; r; r< �__do_query_into_hash� sB � � r~ c K �p t �� jj}t�d|� tdi | ��}|du rg S t|d�}|�� |s)|� g � t�d|t |d �� |d S )a_ Retrieves the master status from the minion. Returns:: {'host.domain.com': {'Binlog_Do_DB': '', 'Binlog_Ignore_DB': '', 'File': 'mysql-bin.000021', 'Position': 107}} CLI Example: .. code-block:: bash salt '*' mysql.get_master_status �%s<--NzSHOW MASTER STATUS�%s-->%sr r; � rx ry rz r{ rR rS rK r~ r� r� rt �rW r} r| Zrtnvr; r; r< �get_master_status) s r� c K r )a� Retrieves the slave status from the minion. Returns:: {'host.domain.com': {'Connect_Retry': 60, 'Exec_Master_Log_Pos': 107, 'Last_Errno': 0, 'Last_Error': '', 'Last_IO_Errno': 0, 'Last_IO_Error': '', 'Last_SQL_Errno': 0, 'Last_SQL_Error': '', 'Master_Host': 'comet.scion-eng.com', 'Master_Log_File': 'mysql-bin.000021', 'Master_Port': 3306, 'Master_SSL_Allowed': 'No', 'Master_SSL_CA_File': '', 'Master_SSL_CA_Path': '', 'Master_SSL_Cert': '', 'Master_SSL_Cipher': '', 'Master_SSL_Key': '', 'Master_SSL_Verify_Server_Cert': 'No', 'Master_Server_Id': 1, 'Master_User': 'replu', 'Read_Master_Log_Pos': 107, 'Relay_Log_File': 'klo-relay-bin.000071', 'Relay_Log_Pos': 253, 'Relay_Log_Space': 553, 'Relay_Master_Log_File': 'mysql-bin.000021', 'Replicate_Do_DB': '', 'Replicate_Do_Table': '', 'Replicate_Ignore_DB': '', 'Replicate_Ignore_Server_Ids': '', 'Replicate_Ignore_Table': '', 'Replicate_Wild_Do_Table': '', 'Replicate_Wild_Ignore_Table': '', 'Seconds_Behind_Master': 0, 'Skip_Counter': 0, 'Slave_IO_Running': 'Yes', 'Slave_IO_State': 'Waiting for master to send event', 'Slave_SQL_Running': 'Yes', 'Until_Condition': 'None', 'Until_Log_File': '', 'Until_Log_Pos': 0}} CLI Example: .. code-block:: bash salt '*' mysql.get_slave_status r� NzSHOW SLAVE STATUSr� r r; r� r� r; r; r< �get_slave_statusK s 6 r� c K �l t �� jj}t�d|� tdi | ��}|du rg S t|d�}|�� |s)|� g � t�d|t |d �� |S )z� Retrieves the show variables from the minion. Returns:: show variables full dict CLI Example: .. code-block:: bash salt '*' mysql.showvariables r� NzSHOW VARIABLESr� r r; r� r� r; r; r< � showvariables� � r� c K r� )z� Retrieves the show global variables from the minion. Returns:: show global variables full dict CLI Example: .. code-block:: bash salt '*' mysql.showglobal r� NzSHOW GLOBAL VARIABLESr� r r; r� r� r; r; r< � showglobal� r� r� c K s< | |d< ||d< t di |��}|du r dtv rtd= dS dS )z� Attempt to login using the provided credentials. If successful, return true. Otherwise, return False. CLI Example: .. code-block:: bash salt '*' mysql.verify_login root password r r� Nrk FTr; )rK rd )rb rE rW rX r; r; r< � verify_login� s r� c K s� t di | ��}|du r g S |�� }d}zt||� W n$ tjy> } zdj|j� }|td< t� |� g W Y d}~S d}~ww g }|� � }|D ]}|� |d |d d�� qGt� |� |S ) z� Return a list of plugins and their status from the ``SHOW PLUGINS`` query. CLI Example: .. code-block:: bash salt '*' mysql.plugins_list Nz SHOW PLUGINSrj rk r r� )rU r� r; r� r� r; r; r< � plugins_list� s( �� r� c K s� | s t �d� dS t| fi |��rt �d| � dS td i |��}|du r&dS |�� }d| � �}|r:|d|� d�7 }n|d| � d �7 }zt||� W dS tjym } zd j|j � }|t d < t �|� W Y d}~dS d}~ww ) zs Add a plugina. CLI Example: .. code-block:: bash salt '*' mysql.plugin_add auth_socket �Plugin name is required.Fz Plugin %s is already installed.TNzINSTALL PLUGIN z SONAME "r� z.so"rj rk r; � rR rn r- rK rL rP r: r rm rg rd )rU ZsonamerW rX rY r[ rp rq r; r; r< � plugin_add s0 � ��r� c K s� | s t �d� dS t| fi |��st �d| � dS td i |��}|du r&dS |�� }d| � �}i }| |d< zt||� W dS tjy` } zdj|j � }|t d < t �|� W Y d}~dS d}~ww ) zx Remove a plugin. CLI Example: .. code-block:: bash salt '*' mysql.plugin_remove auth_socket r� FzPlugin %s is not installed.TNzUNINSTALL PLUGIN rU rj rk r; r� )rU rW rX rY r[ rg rp rq r; r; r< � plugin_remove+ s. � ��r� c K s� | s t �d� dS td i |��}|du rdS |�� }d}i }| |d< zt|||� W n# tjyM } zdj|j� }|t d< t �|� W Y d}~dS d}~ww z|� � }|du rZW dS |d W S t yh Y dS w ) z� Return the status of a plugin. CLI Example: .. code-block:: bash salt '*' mysql.plugin_status auth_socket r� FNr8 zQSELECT PLUGIN_STATUS FROM INFORMATION_SCHEMA.PLUGINS WHERE PLUGIN_NAME = %(name)srU rj rk r r; ) rR rn rK rL rP r: r rm rg rd r� ru ) rU rW rX rY r[ rg rp rq r� r; r; r< r- P s8 � �� �r- )Fr� )NN)r NNFFNrl )r NNFFN)r )r NNFNNrl )r NNFNN)r FTF)r FT)_�__doc__r� r? �loggingr� r� r� rx r� Zsalt.utils.datar� Zsalt.utils.filesZsalt.utils.stringutilsr: ZMySQLdb.convertersZMySQLdb.cursorsr ZMySQLdb.constantsr r r � ImportErrorZpymysqlZinstall_as_MySQLdbr� r� � getLogger�__name__rR rM rV rU rk r= rG r] r_ r` rh rr rK r� r� rO rP r� r� r� r� r� r� r� r r r r r r r r r r r# r% r/ r2 r4 r= r> rB rC rD rG rH rJ rO rL rY rb re rf rq rr rs rw r~ r� r� r� r� r� r� r� r� r- r; r; r; r< �<module> st ��� � > .Hb , = [ "*. !"#% 5, �/ �# � j" �A �0 � �X �J � ) � -)( � �= �M.0"F !( %
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings