Python操作Sqlite的简单封装

import sqlite3
 
class SimpleSQLite:
    def __init__(self, db_name):
        self.connection = sqlite3.connect(db_name)
        self.cursor = self.connection.cursor()
 
    def execute_query(self, query, params=()):
        self.cursor.execute(query, params)
        self.connection.commit()
 
    def fetch_all(self, query, params=()):
        self.cursor.execute(query, params)
        return self.cursor.fetchall()
 
    def close(self):
        self.connection.close()
 
# 使用示例
db = SimpleSQLite('example.db')
 
# 创建表
db.execute_query('CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, email TEXT)')
 
# 插入数据
db.execute_query('INSERT INTO users (name, email) VALUES (?, ?)', ('Alice', 'alice@example.com'))
 
# 查询数据
users = db.fetch_all('SELECT * FROM users')
for user in users:
    print(user)
 
# 关闭数据库连接
db.close()

这段代码定义了一个名为SimpleSQLite的类，它封装了连接数据库、执行查询和获取所有结果的操作。它提供了一个简单的接口来执行SQLite数据库操作，并且可以用于任何需要与SQLite数据库交互的Python项目。