aioodbc 0.5.0

基本示例

aioodbc 基于 pyodbc 并提供相同的 API，你只需使用 yield from conn.f() 或 await conn.f() 而不是 conn.f()

属性没有变化，所以 conn.prop 是正确的，以及 conn.prop = val。

import asyncio

import aioodbc


async def test_example():
    dsn = "Driver=SQLite;Database=sqlite.db"
    conn = await aioodbc.connect(dsn=dsn)

    cur = await conn.cursor()
    await cur.execute("SELECT 42 AS age;")
    rows = await cur.fetchall()
    print(rows)
    print(rows[0])
    print(rows[0].age)
    await cur.close()
    await conn.close()


asyncio.run(test_example())

连接池

连接池是从 aiopg 迁移过来的，并依赖于 PEP492 功能

import asyncio

import aioodbc


async def test_pool():
    dsn = "Driver=SQLite3;Database=sqlite.db"
    pool = await aioodbc.create_pool(dsn=dsn)

    async with pool.acquire() as conn:
        cur = await conn.cursor()
        await cur.execute("SELECT 42;")
        r = await cur.fetchall()
        print(r)
        await cur.close()
        await conn.close()
    pool.close()
    await pool.wait_closed()


asyncio.run(test_pool())

上下文管理器

Pool、Connection 和 Cursor 对象支持上下文管理协议

import asyncio

import aioodbc


async def test_example():
    dsn = "Driver=SQLite;Database=sqlite.db"

    async with aioodbc.create_pool(dsn=dsn) as pool:
        async with pool.acquire() as conn:
            async with conn.cursor() as cur:
                await cur.execute("SELECT 42 AS age;")
                val = await cur.fetchone()
                print(val)
                print(val.age)


asyncio.run(test_example())

安装

在 Linux 环境中，pyodbc（因此 aioodbc）需要 unixODBC 库。你可以使用你的包管理器安装它，例如

$ sudo apt-get install unixodbc
$ sudo apt-get install unixodbc-dev

然后

pip install aioodbc

运行测试

要在不使用 docker 的情况下本地运行测试，请安装 unixodbc 和 sqlite 驱动程序

$ sudo apt-get install unixodbc
$ sudo apt-get install libsqliteodbc

创建虚拟环境并安装带有要求的包

$ pip install -r requirements-dev.txt

运行测试，lint 等

$ make fmt
$ make lint
$ make test

其他 SQL 驱动程序

• aiopg - PostgreSQL 的 asyncio 客户端

• aiomysql - MySQL 的 asyncio 客户端

需求

• Python 3.7+

• pyodbc

• uvloop（可选）

变更