Python databases 模块：快速入门

import databases  # 导入 databases 模块

# 定义数据库的 URL，使用 SQLite 数据库
database_url = "sqlite:///example.db"
database = databases.Database(database_url)  # 创建数据库连接

async def main():
    await database.connect()  # 连接到数据库
    print("Connected to database!")  # 输出连接成功的信息

    # 定义一条 SQL 查询
    query = "SELECT * FROM users"  
    results = await database.fetch_all(query)  # 执行查询并获取所有结果
    print(results)  # 打印查询结果

    await database.disconnect()  # 断开数据库连接

import databases  # 导入 databases 模块

database_url = "sqlite:///example.db"  # 数据库连接URL
database = databases.Database(database_url)  # 创建数据库连接

async def add_user(name, age):
    await database.connect()  # 连接到数据库
    # 定义插入用户数据的 SQL 语句
    query = "INSERT INTO users(name, age) VALUES (:name, :age)"  
    values = {"name": name, "age": age}  # 要插入的值
    await database.execute(query=query, values=values)  # 执行插入操作
    print(f"Added user {name}, age {age}")  # 打印插入成功的信息
    await database.disconnect()  # 断开连接

# 示例：添加用户
await add_user("Alice", 30)  # 调用添加用户的函数

import databases  # 导入 databases 模块

database_url = "sqlite:///example.db"  # 数据库连接URL
database = databases.Database(database_url)  # 创建数据库连接

async def delete_user(user_id):
    await database.connect()  # 连接到数据库
    # 定义删除用户的 SQL 语句
    query = "DELETE FROM users WHERE id = :id"  
    values = {"id": user_id}  # 设置要删除用户的 ID
    await database.execute(query=query, values=values)  # 执行删除操作
    print(f"Deleted user with id {user_id}")  # 打印删除成功的信息
    await database.disconnect()  # 断开连接

# 示例：删除用户
await delete_user(1)  # 调用删除用户的函数