SQLAlchemy Core - 连接到数据库


在上一章中,我们讨论了 SQLAlchemy 中的表达式语言。现在让我们继续执行连接数据库所涉及的步骤。

引擎类将Pool 和 Dialect 连接在一起以提供数据库连接和Behave的源。Engine 类的对象是使用create_engine()函数实例化的。

create_engine() 函数将数据库作为一个参数。不需要在任何地方定义数据库。标准调用形式必须发送 URL 作为第一个位置参数,通常是一个指示数据库方言和连接参数的字符串。使用下面给出的代码,我们可以创建一个数据库。

>>> from sqlalchemy import create_engine
>>> engine = create_engine('sqlite:///college.db', echo = True)

对于MySQL 数据库,请使用以下命令 -

engine = create_engine("mysql://user:pwd@localhost/college",echo = True)

为了特别提到用于连接的DB-API , URL 字符串采用以下形式 -

dialect[+driver]://user:password@host/dbname

例如,如果您将PyMySQL 驱动程序与 MySQL 一起使用,请使用以下命令 -

mysql+pymysql://<username>:<password>@<host>/<dbname>

echo 标志是设置 SQLAlchemy 日志记录的快捷方式,这是通过 Python 的标准日志记录模块完成的。在后续章节中,我们将学习所有生成的SQL。要隐藏详细输出,请将 echo 属性设置为None。create_engine() 函数的其他参数可能是特定于方言的。

create_engine() 函数返回一个Engine 对象。Engine 类的一些重要方法是 -

先生。 方法及说明
1

连接()

返回连接对象

2

执行()

执行 SQL 语句构造

3

开始()

返回一个上下文管理器,提供一个已建立事务的连接。操作成功后,事务被提交,否则回滚

4

处置()

释放引擎使用的连接池

5

司机()

引擎使用的方言的驱动程序名称

6

表名()

返回数据库中所有可用表名的列表

7

交易()

在事务边界内执行给定的函数