python - SqlAlchemy Python 多数据库

Question

我正在使用 SqlAlchemy 访问多个数据库(在同一台服务器上)。我当前的连接字符串如下

connect_string = "mssql+pyodbc://{0}:{1}@{2}/{3}".format(USERNAME_R, PASSWORD_R, SERVER_R, DATABASE_R)
engine = create_engine(connect_string)
session = sessionmaker(bind=engine)()
Record = declarative_base(engine)

如何修改此声明以便能够连接到同一服务器上的多个数据库(例如 DATABASE1 和 DATABASE2)。这似乎指向了正确的方向，但不是很清楚，我不确定它是否特定于 Flask:

https://pythonhosted.org/Flask-SQLAlchemy/binds.html

Answer 1

您好，您可以使用 follwing 来实现。

engines = {
    'drivers':create_engine('postgres://postgres:admin@localhost:5432/Drivers'),
    'dispatch':create_engine('postgres://postgres:admin@localhost:5432/dispatch')
}

我在服务器和两个表中有两个数据库。之后，您可以在进行查询时使用路由类为特定的数据库连接路由:

  class RoutingSession(Session):
    def get_bind(self, mapper=None, clause=None):
        if mapper and issubclass(mapper.class_, drivers):
            return engines['drivers']
        elif self._flushing:
            return engines['dispatch']

现在您可以相应地触发查询，例如，首先您需要使用这样的方式进行 session :

Session = sessionmaker(class_=RoutingSession)
session = Session()
driverssql = session.query(drivers).all()

这是你可以在 sqlalchemy 中使用多个数据库