idddlZddlmZddlmZddlmZddlmZddlmZddlmZej d d Z ej d d Z ej d d Z dS) N)exc)text) create_db)drop_db)log)temp_table_keyword_args postgresqlc,|jj}|d5} t |||n#t $rYnwxYw|s|d}d} |d|d|nk#tj $rW}|dz }|d krd t|vr0tj d ||j |tjd Yd}~n d}~wxYw ddddS#1swxYwYdS) N AUTOCOMMITisolation_levelzselect current_database()rTzCREATE DATABASE z TEMPLATE rzaccessed by other userszFWaiting to create %s, URI %r, template DB %s is in use sleeping for .5g?)optionspostgresql_templatedbconnectexecution_options _pg_drop_db ExceptionscalarexecuterOperationalErrorstrrinfourltimesleep)cfgengident template_dbconnattempterrs ]/opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/dialects/postgresql/provision.py _pg_create_dbr& s+3K  ( ( ( F F$  T5 ) ) ) )    D  C++&ABBK   8={{K&!' $ $ $1 a<<,C88HC# JsOOO ' *=s_D A D  AD AD 4BD C7A C1,D 1C77D  D D c|d5}|td||d|zddddS#1swxYwYdS)Nr r zselect pg_terminate_backend(pid) from pg_stat_activity where usename=current_user and pid != pg_backend_pid() and datname=:dname)dnamezDROP DATABASE %s)rrrr)rrr r"s r%rr0s  ( ( ( F F 1$ %        '%/000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s=A33A7:A7c ddgiS)Nprefixes TEMPORARY)rrs r%#_postgresql_temp_table_keyword_argsr->s  &&) rrrtesting.provisionrrrr for_dbr&rr-r,r.r%r2s ******(((((($$$$$$888888,!! !H  1 1 1  --''.-'''r.