SQLAlchemy kullanarak yeni bir veritabanı nasıl oluşturulur? Sqlalchemy ile

Question

, motor böyle oluşturulur:

from sqlalchemy import create_engine 
engine = create_engine("postgresql://localhost/mydb") 

veritabanı mevcut değilse engine başarısız erişme. Belirtilen veritabanı yoksa SQLAlchemy'ye yeni veritabanı oluşturmasını söylemek mümkün mü?

Answer 1

Postgre'lerde, varsayılan olarak üç veritabanı normal olarak bulunur. Süper kullanıcı olarak bağlanabiliyorsanız (örneğin, postgres rolü), postgres veya template1 veritabanlarına bağlanabilirsiniz. Varsayılan pg_hba.conf, postgres rolünü kullanmak için yalnızca postgres adlı unix kullanıcısına izin verir, böylece en basit şey sadece o kullanıcı olmaktır. postgres Eğer işlemler içindeki veritabanlarını oluşturmasına izin vermez, çünkü

>>> engine = sqlalchemy.create_engine("postgres://postgres@/postgres") 

Bununla birlikte engine.execute() kullanamaz ve sqlalchemy daima çalışır: Her halükarda, bir veritabanı oluşturmak için gerekli izinlere sahip bir kullanıcı ile her zamanki gibi bir motoru oluşturmak Bir işlemde sorguları çalıştırmak için Bundan kaçınmak için, motordan yatan bir bağlantı olsun:

>>> conn = engine.connect() 

Ama eğer bir commit açık işlem sona zorunda bağlantı hala bir hareket içinde olacaktır:

>>> conn.execute("commit") 

Ve Daha sonra veritabanı için uygun PostgreSQL komutunu kullanarak oluşturmaya devam edebilirsiniz. Ayrıca

import sqlalchemy 

with sqlalchemy.create_engine(
    'postgresql:///postgres', 
    isolation_level='AUTOCOMMIT' 
).connect() as connection: 
    connection.execute('CREATE DATABASE my_database') 

veritabanını görmezden bir yolu yoktur veritabanı var olmadığını emin değilseniz:

>>> conn.execute("create database test") 
>>> conn.close() 

Answer 2

O create_engine işlevine isolation_level='AUTOCOMMIT' sağlayarak veritabanını oluştururken manuel işlem yönetimini önlemek mümkündür sqlalchemy.exc.ProgrammingError istisna baskılayarak varlığı nedeniyle oluşturma hatası:

import contextlib 
import sqlalchemy.exc 

with contextlib.suppress(sqlalchemy.exc.ProgrammingError): 
    # creating database as above 

Answer 3

Bkz

from sqlalchemy import create_engine 
from sqlalchemy_utils import database_exists, create_database 

engine = create_engine("postgres://localhost/mydb") 
if not database_exists(engine.url): 
    create_database(engine.url) 

print(database_exists(engine.url))