基于odbc的异步连接sqlite、mysql等

2020-12-18 09:31:28 编辑 0 阅读量:398

连接数据库的方式有多种，`socket`, `odbc`等等，这里使用`aioodbc`异步连接sqlite。

## 一、安装驱动
aioodbc基于pyodbc，遵循ODBC协议，在linux上需要安装odbc驱动,步骤如下：
### 安装ODBC驱动
- centos中: `$ sudo yum install unixODBC unixODBC-devel libtool-ltdl libtool-ltdl-devel`
- ubuntu中: `sudo apt install unixodbc-dev libsqlite3-dev sqlite3`

### 安装sqlite3的odbc驱动
```
$ git clone https://github.com/softace/sqliteodbc.git
$ cd sqliteodbc
$ ./configure && make
$ sudo make install    # 到这里就成功安装了驱动，接下来要配置驱动
$ odbcinst -j          # 查看系统的odbc配置
$ sudo vim /etc/odbcinst.ini  # 添加如下内容, Driver的路径自己检查一下有没有
[SQLite]  
Description=SQLite ODBC Driver  
Driver=/usr/local/lib/libsqlite3odbc.so   # 文件名可能不同
Setup=/usr/local/lib/libsqlite3odbc.so
```

## 二、简单使用
```
import asyncio
import aioodbc

loop = asyncio.get_event_loop()

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

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()

loop.run_until_complete(test_example())
```
具体可以看源码[aio-libs/aioodbc](https://github.com/aio-libs/aioodbc)

## 三、说明
后面我还是放弃了异步连接sqlite的方案，因为sqlite本身对并发支持不好，用异步也容易出现问题，如果要使用mysql的话可以直接用[aio-libs/aiomysql](https://github.com/aio-libs/aiomysql)

基于odbc的异步连接sqlite、mysql等

附件: