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;

示例代码

接下来，我们使用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)

首先，解释一下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())