관리-도구
편집 파일: provision.cpython-311.pyc
� �܋f� � �~ � d dl mZ d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d d lm Z d d lm Z d d lmZ d d lmZ d d lmZ ej d� � d� � � Z ej d� � d� � � Zd� Z e j d� � d� � � Z ej d� � d� � � Z ej d� � d� � � Z e� � Z e j d� � d� � � Z e j d� � d� � � Z e j d� � d� � � Z ej d� � d� � � Z dS )� )� create_engine)�exc)�url)�configure_follower)� create_db)�drop_db)�follower_url_from_main)�log)�post_configure_engine)� run_reap_dbs)�stop_test_class)�temp_table_keyword_args)�update_db_opts�oraclec � � |� � � 5 }|� d|z � � |� d|z � � |� d|z � � |� d|��� � |� d|z � � |� d|z � � |� d|z � � d d d � � d S # 1 swxY w Y d S )Nz create user %s identified by xez#create user %s_ts1 identified by xez#create user %s_ts2 identified by xez grant dba to z grant unlimited tablespace to %sz$grant unlimited tablespace to %s_ts1z$grant unlimited tablespace to %s_ts2)�connect�execute��cfg�eng�ident�conns �w/builddir/build/BUILD/cloudlinux-venv-1.0.6/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/oracle/provision.py�_oracle_create_dbr s/ � � ��� � � E�$� � � �6��>�?�?�?� � � �:�U�B�C�C�C� � � �:�U�B�C�C�C� � � � �%�%�1�2�2�2� � � �7�%�?�@�@�@� � � �;�e�C�D�D�D� � � �;�e�C�D�D�D�E� E� E� E� E� E� E� E� E� E� E� E���� E� E� E� E� E� Es �B)C � C�Cc �. � d|z | _ d|z | _ d S �N�%s_ts1�%s_ts2)� test_schema� test_schema_2)�configr s r �_oracle_configure_followerr" s" � �!�E�)�F��#�e�+�F���� c �� � | � d|z � � t j d|� � dS # t j $ r }t j d|� � Y d }~dS d }~ww xY w)Nzdrop user %s cascadez Reaped db: %sTzcouldn't drop db: %sF)r r �infor � DatabaseError�warning)r �dbname�errs r �_ora_drop_ignorer* % sx � �� � � �+�f�4�5�5�5� �� �&�)�)�)��t�� � � � � � � �*�C�0�0�0��u�u�u�u�u��������s �-1 �A � A�A c �� � |� � � 5 }t ||� � t |d|z � � t |d|z � � d d d � � d S # 1 swxY w Y d S r )r r* r s r �_oracle_drop_dbr, / s� � � ��� � � 1�$� ��u�%�%�%���x�%� /�0�0�0���x�%� /�0�0�0�1� 1� 1� 1� 1� 1� 1� 1� 1� 1� 1� 1���� 1� 1� 1� 1� 1� 1s �7A�A � A c � � d S �N� )�db_url�db_optss r �_oracle_update_db_optsr2 < s � ��Dr# c �. � |� � � 5 }|� d� � ddd� � n # 1 swxY w Y t D ]2} |j }d|_ ||_ �# |j j j $ r Y �/w xY wt � � � dS )z�run magic command to get rid of identity sequences # https://floo.bar/2019/11/29/drop-the-underlying-sequence-of-an-identity-column/ zpurge recyclebinN� )�beginr � _all_conns� stmtcachesize�dialect�dbapi�InterfaceError�clear)r! �db�clsr �cx_oracle_conn�scs r r r A s� � � ����� )�t� � � �'�(�(�(�)� )� )� )� )� )� )� )� )� )� )���� )� )� )� )� %� .� .�� .� �-�B� ,-�N� (�+-�N� (� (�� �z� �.� � � � �D� ���� �������s �7�;�;� A"�"A9�8A9c �P � ddl m} |� |d� � d� � � }d S )Nr4 )�event�checkoutc �: � t � | � � d S r. )r6 �add)� dbapi_con� con_record� con_proxys r rB z/_oracle_post_configure_engine.<locals>.checkoutb s � ����y�!�!�!�!�!r# )� sqlalchemyrA � listens_for)r �engine�follower_identrA rB s r � _oracle_post_configure_enginerL ^ sH � � � � � � � � ���v�z�*�*�"� "� +�*�"� "� "r# c �� � t j d| � � t | � � }|� � � 5 }t j dd� |� � � � |� d� � }d� |D � � }t � � }|D ]�}|� d� � s|� d� � r�-||v rS|� |� � d|z |v r|� d|z � � d |z |v r|� d |z � � ��d x}} t |d � � D ]\ } } t || � � r|d z }�t j d || � � d d d � � d S # 1 swxY w Y d S ) Nzdb reaper connecting to %rzidentifiers in file: %sz, z�select u.username from all_users u where username like 'TEST_%' and not exists (select username from v$session where username=u.username)c �: � h | ]\ }|� � � ��S r/ )�lower)�.0�usernames r � <setcomp>z#_reap_oracle_dbs.<locals>.<setcomp>t s$ � �A�A�A�+�8�X�^�^�%�%�A�A�Ar# �_ts1�_ts2r r r4 � z-Dropped %d out of %d stale databases detected) r r% r r �joinr �set�endswithrD � enumerater* ) r �identsr r �to_reap� all_names�to_drop�name�dropped�totalrQ s r �_reap_oracle_dbsra g s� � ��H� )�3�/�/�/� �� � �C� ��� � � �$� ��*�D�I�I�f�,=�,=�>�>�>��,�,� 8� � �� B�A��A�A�A� ��%�%�� � 1� 1�D��}�}�V�$�$� 1�� � �f�(=�(=� 1���� � �� � �D�!�!�!��d�?�i�/�/��K�K��4��0�0�0��d�?�i�/�/��K�K��4��0�0�0�����%� (��!� 4� 4� � �O�E�8� ��h�/�/� ��1� ��� �� ;�W�e� � � �3 � � � � � � � � � � � ���� � � � � � s �D$E*�*E.�1E.c �J � t j | � � } || _ d| _ | S )N�xe)�sa_url�make_urlrQ �password)r r s r � _oracle_follower_url_from_mainrg � s$ � � �/�#� � �C��C�L��C�L� �Jr# c � � dgdd�S )NzGLOBAL TEMPORARYz PRESERVE ROWS)�prefixes�oracle_on_commitr/ )r r s r � _oracle_temp_table_keyword_argsrk � s � � (�(� +� � � r# N) � r r rJ r rd �testing.provisionr r r r r r r r r r �for_dbr r" r* r, r2 rW r6 rL ra rg rk r/ r# r �<module>ro s� �� � � � � � � � � � � � � #� #� #� #� #� #� 3� 3� 3� 3� 3� 3� *� *� *� *� *� *� (� (� (� (� (� (� 7� 7� 7� 7� 7� 7� $� $� $� $� $� $� 6� 6� 6� 6� 6� 6� -� -� -� -� -� -� 0� 0� 0� 0� 0� 0� 8� 8� 8� 8� 8� 8� /� /� /� /� /� /� ���(��� E� E� �� E� ���8�$�$�,� ,� %�$�,� � � � �� ���� 1� 1� �� 1� � ��x� � � � � !� � � � ���!�!�� � "�!��2 �S�U�U� � �� �h�'�'�"� "� (�'�"� � ��X� � � � � � � �B �� �x�(�(�� � )�(�� �� ��)�)�� � *�)�� � r#