### Python SQLite3 库详细教程 #### 1. 导入SQLite3模块 要使用Python中的SQLite3库，首先需要导入`sqlite3`模块。这是标准库的一部分，因此不需要额外安装即可直接使用[^1]。 ```python import sqlite3 ``` #### 2. 创建数据库连接 可以通过调用`connect()`方法来创建一个新的数据库或者连接到现有的数据库文件。如果指定的数据库不存在，则会自动创建它。还可以使用`:memory:`作为参数，在内存中创建临时数据库用于测试目的[^3]。 ```python def create_connection(db_file): """ 创建一个数据库连接 """ conn = None try: conn = sqlite3.connect(db_file) print(f"Connected to {db_file}") except Exception as e: print(e) return conn ``` #### 3. 执行SQL命令 执行SQL语句通常涉及以下几个步骤： - 使用`cursor()`方法获得游标对象。 - 调用`execute()`或`executemany()`方法运行单条或多条SQL指令。 - 对于写操作（INSERT/UPDATE），记得提交更改(`commit()`)；对于读取操作则可以立即获取结果集。 ##### 示例 - 创建表格 这里展示如何定义并构建一张存储用户信息的新表： ```sql CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, username TEXT UNIQUE NOT NULL, password TEXT NOT NULL ); ``` 将其转换成Python脚本如下所示： ```python def create_table(conn, create_table_sql): """ 根据给定的 SQL 查询字符串创建表""" try: c = conn.cursor() c.execute(create_table_sql) except Exception as e: print(e) create_users_table = ''' CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, username TEXT UNIQUE NOT NULL, password TEXT NOT NULL );''' conn = create_connection('example.db') if conn is not None: create_table(conn, create_users_table) else: print("Error! cannot create the database connection.") ``` #### 4. 插入数据 向已存在的表里添加新记录时，推荐采用占位符方式传参以防止SQL注入攻击[^2]。 ```python def insert_user(conn, user_data): sql = ''' INSERT INTO users(username,password) VALUES(?,?) ''' cur = conn.cursor() cur.execute(sql, user_data) conn.commit() insert_user(conn, ('alice', 'passw0rd')) ``` #### 5. 数据检索 利用`fetchall()`函数可以从当前的结果集中提取所有的行作为一个列表返回。另外还有`fetchone()`以及`fetchmany(size)`可供选择依据实际需求选用不同的形式。 ```python def select_all_users(conn): cur = conn.cursor() cur.execute("SELECT * FROM users") rows = cur.fetchall() for row in rows: print(row) select_all_users(conn) ``` #### 6. 更新与删除 同样遵循先编写相应的SQL语句再传递至`execute()`的过程完成修改现有数据或是移除特定项的任务。 ```python update_query = "UPDATE users SET password=? WHERE username=?" delete_query = "DELETE FROM users WHERE username=?" cur = conn.cursor() cur.execute(update_query, ("newpassword", "alice")) cur.execute(delete_query, ("bob",)) conn.commit() ``` #### 7. 处理并发问题 当涉及到多线程环境下的应用开发时，需注意设置`check_same_thread=False`选项允许跨多个线程共享同一个连接实例[^5]。 ```python connection = sqlite3.connect('database.db', check_same_thread=False) ``` #### 8. 获取元数据 为了了解某个具体模式下有哪些实体存在及其属性详情等基础资料，可通过查询系统视图`sqlite_master`达成目标[^4]。 ```sql SELECT name, type, tbl_name, rootpage, sql FROM sqlite_master; ``` --- ###