sqlite mysql连接池,SQLite连接池

SQLite 是一种嵌入式的数据库，不支持多线程，因此没有像 MySQL 那样的连接池。但是，我们可以通过编写一些代码来实现一个简单的 SQLite 连接池。

以下是一个使用 Python 编写的 SQLite 连接池的示例：

import sqlite3
from queue import Queue
from threading import Lock

class SQLitePool:
    def __init__(self, max_conn):
        self.max_conn = max_conn
        self.pool = Queue(max_conn)
        self.lock = Lock()
        self.conn_params = {
            "database": "test.db"
        }

    def get_conn(self):
        if self.pool.qsize() == 0 and self.max_conn > self.pool.qsize():
            conn = sqlite3.connect(**self.conn_params)
            return conn
        else:
            return self.pool.get()

    def put_conn(self, conn):
        self.pool.put(conn)

    def close_all_conn(self):
        with self.lock:
            while not self.pool.empty():
                conn = self.pool.get()
                conn.close()

在上面的代码中，我们创建了一个 SQLite 连接池类 `SQLitePool`，它有三个方法：

- `get_conn()`：从连接池中获取一个连接，如果连接池为空，则创建一个新的连接返回。
- `put_conn(conn)`：将连接放回连接池中。
- `close_all_conn()`：关闭连接池中的所有连接。

使用该连接池的示例代码如下：

def run_sqlite():
    pool = SQLitePool(5)
    conn = pool.get_conn()
    cursor = conn.cursor()

    cursor.execute("CREATE TABLE IF NOT EXISTS user (id INTEGER PRIMARY KEY, name TEXT)")

    cursor.execute("INSERT INTO user (name) VALUES (?)", ("John",))
    cursor.execute("INSERT INTO user (name) VALUES (?)", ("Jane",))

    cursor.execute("SELECT * FROM user")
    rows = cursor.fetchall()
    for row in rows:
        print(row)

    cursor.close()
    pool.put_conn(conn)

    pool.close_all_conn()

在上面的代码中，我们首先创建了一个 `SQLitePool` 对象，然后从连接池中获取一个连接并执行一些 SQL 语句。最后，我们将连接放回连接池中，并关闭所有连接。

需要注意的是，由于 SQLite 不支持多线程，因此在多线程环境下使用该连接池可能会出现问题，需要自行进行线程安全处理。