SQLAlchemyを使用して新しいデータベースを作成するには？ SQLAlchemyので

Question

は、エンジンは、このように作成されます。

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

は、データベースが存在しない場合engineが失敗したアクセス。指定されたデータベースが存在しない場合、新しいデータベースを作成するようにSQLAlchemyに指示できますか？

Answer 1

postgresでは、デフォルトで3つのデータベースが通常存在します。スーパーユーザー（たとえばpostgresロール）として接続できる場合は、postgresまたはtemplate1データベースに接続できます。デフォルトのpg_hba.confは、postgresという名前のUNIXユーザーのみがpostgresロールを使用することを許可しているので、最も単純なのはそのユーザーになることです。 Postgresはあなたが取引の内部データベースを作成することはできませんので、

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

あなたはしかしengine.execute()を使用することはできません、とSQLAlchemyのは常にしようとします：任意のレートでは、データベースを作成する権限を持つユーザーでいつものようにエンジンを作成トランザクション内でクエリを実行します。これを回避するには、エンジンからの基になる接続を取得：

>>> conn = engine.connect() 

をしかし、あなたはcommitとのオープン・トランザクション終了する必要がありますので接続が、トランザクションの内部で次のようになります。

>>> conn.execute("commit") 

をと適切なPostgreSQLコマンドを使用してデータベースを作成することができます。 isolation_level='AUTOCOMMIT'create_engineする機能を提供することで、データベースを作成中

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

Answer 2

これは、手動トランザクション管理を回避することが可能です：

import sqlalchemy 

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

また、あなたは、データベースが存在しないことを確認していない場合は、データベースを無視する方法がありますsqlalchemy.exc.ProgrammingError例外を抑制することによって存在による作成エラーは：

import contextlib 
import sqlalchemy.exc 

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

Answer 3

を参照してください。

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))