SQL Alchemy连接数据库_sqlalchemy连接数据库

SQL Alchemy连接数据库

使用 SQLAlchemy 连接数据库需要创建一个 Engine 的对象。此对象充当与特定数据库的连接的中心源，为这些数据库连接提供工厂和连接池。Engine通常是一个只为特定数据库（例如MySQL）创建一次的全局对象，并且使用 URL 字符串进行配置，该字符串将描述它应如何连接到数据库主机或后端。在本文中，我们使用MySQL作为SQL Alchemy的后端数据库。Engine是通过create_engine()创建的。

创建数据库

SQL Alchemy不能直接创建库，只能是表级别的操作。因此，需要我们手动创建数据库。创建名为sqlalchemy的数据库。

CREATE DATABASE IF NOT EXISTS sqlalchemy CHARATER SET UTF8;
1

示例代码

接下来，我们使用SQL Alchemy来连接数据库。示例代码如下：

from sqlalchemy import create_engine

# 创建Engine连接MySQL数据库
url = "mysql+mysqldb://sa:jZ3FPwfwz8phiSzA@127.0.0.1:3306/sqlalchemy?charset=utf8"
engine = create_engine(url=url, echo=True, future=True)
1
2
3
4
5

首先，解释一下create_engine中url参数的组成。

echo参数记录Engine发出的所有SQL到Python记录器，该记录器将写入标准输出。此标志对于脚本中的试验非常有用；而指定future=True则是以便我们充分使用SQL Alchemy 2.0 样式用法。

最后，为了测试我们是否成功连接到数据库，可以在使用下面这段代码：

from sqlalchemy import create_engine
from sqlalchemy import text

# 连接数据库
url = "mysql+mysqldb://sa:jZ3FPwfwz8phiSzA@127.0.0.1:3306/sqlalchemy?charset=utf8"
engine = create_engine(url=url, echo=True, future=True)

# 测试连接是否成功
with engine.connect() as conn:
    result = conn.execute(text("select 'hello world'"))
    print(result.all())
1
2
3
4
5
6
7
8
9
10
11

懒惰连接

当engine首次由create_engine()返回时，实际上尚未尝试连接到数据库；只有在第一次要求它对数据库执行任务时才会发生真正连接到数据库，这是一种称为延迟初始化的软件设计模式。