使用SQLAlChemy连接数据库

导入包

首先，导入创建数据库引擎的包。

from sqlalchemy import create_engine

编写数据库配置

SQLALCHEMY_DATABASE_URL = "mysql://root:123456789@127.0.0.1:3306/tortoise"

字段解释：

• mysql:：这是数据库方言和驱动的名称。在本例中，我们使用的是 MySQL 数据库。
• root:：这是连接数据库的用户名。
• 123456789: 这是连接数据库的密码。
• @127.0.0.1:：这是数据库服务器的 IP 地址。在本例中，数据库服务器位于同一台机器上，所以我们使用了本地主机 IP 地址 127.0.0.1。
• 3306:：这是数据库服务器的端口号。对于 MySQL 数据库，缺省端口号是 3306。
• /tortoise：这是数据库的名称。在本例中，我们将连接到名为 tortoise 的数据库。

创建数据库引擎

传入数据库配置连接，来创建数据库引擎。

# 创建数据库引擎
engine = create_engine(
    SQLALCHEMY_DATABASE_URL,
)

创建测试连接

# 创建连接
with engine.connect() as connection:
    rs = connection.execute(text('select * from user_account'))
    print(rs)
    res = rs.fetchall()
    for r in res:
        print(r)

输出：

<sqlalchemy.engine.cursor.CursorResult object at 0x1059b49a0>
(4, 'yan', 'xuecan')
(5, 'yan', 'pengbo')
(6, 'zhang', 'zhangsan')
(7, 'zhang', 'xiaoming')
(10, 'zhang', 'xin')
(14, 'li', 'ming')
(15, 'yao', 'zhetian')
(16, 'fan', 'sixian')
(17, 'test_name', 'test_fullname')

数据库表内容：

注意

在执行 SQL 语句时，必须加上 text,否则会报以下错误sqlalchemy.exc.ObjectNotExecutableError: Not an executable object: 'xxxxxxx'。因为你尝试执行一个字符串，而不是一个 SQLAlchemy 的查询对象。

如果你想执行原生的 SQL 语句，你需要使用 text 函数来构建一个可执行的 SQL 文本对象。