~ 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_optsoraclec | 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)connectexecutecfgengidentconns x/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/oracle/provision.py_oracle_create_dbr s/
E$ 6>??? :UBCCC :UBCCC %%1222 7%?@@@ ;eCDDD ;eCDDDE E E E E E E E E E E E E E E E E Es B)C CCc . 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
DatabaseErrorwarning)r dbnameerrs r _ora_drop_ignorer* % sx +f4555 &)))t *C000uuuuus -1 A AA 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% /000x% /0001 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s 7AA A c d S N )db_urldb_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 )zrun 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
stmtcachesizedialectdbapiInterfaceErrorclear)r! dbclsr cx_oracle_connscs r r
r
A s
)t '((() ) ) ) ) ) ) ) ) ) ) ) ) ) ) % . . . -B
,-N (+-N ( ( z . D s 7;; A""A98A9c P ddl m} | |d d }d S )Nr4 )eventcheckoutc : t | d S r. )r6 add) dbapi_con
con_record con_proxys r rB z/_oracle_post_configure_engine..checkoutb s y!!!!!r# )
sqlalchemyrA listens_for)r enginefollower_identrA rB s r _oracle_post_configure_enginerL ^ sH
vz**" " +*" " "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, zselect 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).0usernames r z#_reap_oracle_dbs..t s$ AAA+8X^^%%AAAr# _ts1_ts2r r r4 z-Dropped %d out of %d stale databases detected) r
r% r r joinr setendswithrD enumerater* ) r identsr r to_reap all_namesto_dropnamedroppedtotalrQ s r _reap_oracle_dbsra g s H
)3///
C
$ *DIIf,=,=>>>,,
8
BAAAA %% 1 1D}}V$$
1
f(=(=
1 D!!!d?i//KK4000d?i//KK4000% (! 4 4 OE8 h//
1 ;We
3
s D$E**E.1E.c J t j | } || _ d| _ | S )Nxe)sa_urlmake_urlrQ password)r r s r _oracle_follower_url_from_mainrg s$
/#
CCLCL Jr# c dgddS )NzGLOBAL TEMPORARYz
PRESERVE ROWS)prefixesoracle_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 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 SUU
h''" " ('" X
B x(( )( )) *) r#