Skip to main content

*asyncpg* 的全部功能和 *sqlalchemy.core* 的用户友好 api

项目描述

核心基础

具有用户友好的sqlalchemy.core api 的asyncpg的全部功能

Corebases - 是 Sqlalchemy.Core异步适配器。基于encode/databases的接口和代码,但有位差。现在仅支持asycnpg驱动程序(但可以扩展)

当前状态 -实验性

创建分叉的原因

安装

> pip install corebases

用法

# Create a database instance, and connect to it.
from corebases import database
database = database('postgres://user:pass@localhost:5432')
await database.connect()

# Insert some data.
query = "INSERT INTO HighScores(name, score) VALUES (:name, :score)"
value =  {"name": "Daisy", "score": 92}

with database.transaction() as db:
    await db.execute(query=query, value=value)

# Run a database query.
query = "SELECT * FROM HighScores"
rows = await database.fetch_all(query=query)
print('High Scores:', rows)

await database.disconnect()

编码/数据库之间的区别

Principal 是事务接口的一点区别:

编码/数据库

with database.transaction():
    await database.execute(query=query, value=value)

核心基础

with database.transaction() as db:
    await db.execute(query=query, value=value)

此外,corebases不支持方法:

  • feach_val
  • 执行多

但我们可以在未来添加。

项目详情


下载文件

下载适用于您平台的文件。如果您不确定要选择哪个,请了解有关安装包的更多信息。

源分布

corebases-0.1.2.tar.gz (4.7 kB 查看哈希

已上传 source

内置分布

corebases-0.1.2-py3-none-any.whl (5.3 kB 查看哈希

已上传 py3