Python数据库编程指南：连接与操作SQLite与MySQL

一、引言

二、SQLite数据库连接与操作

（一）安装SQLite库

（二）建立数据库连接

（三）执行SQL语句

（四）注意事项

三、MySQL数据库连接与操作

（一）安装MySQL库

（二）建立数据库连接

（三）执行SQL语句

（四）注意事项

四、高级操作与性能优化

（一）事务管理

（二）批量插入

（三）索引与查询优化

（四）连接池

五、总结

一、引言

在Python编程中，数据库操作是一个常见的任务。无论是处理大量数据、构建Web应用还是进行数据分析，数据库都是不可或缺的工具。SQLite和MySQL是两种广泛使用的数据库系统，SQLite以其轻量级、无需配置和零管理的特点而著称，而MySQL则是一个功能强大的关系型数据库管理系统。本文将详细介绍如何在Python中连接和操作这两种数据库。

二、SQLite数据库连接与操作

（一）安装SQLite库

Python标准库中自带了sqlite3模块，因此无需额外安装。

（二）建立数据库连接

使用sqlite3.connect()方法可以建立与SQLite数据库的连接。如果数据库文件不存在，SQLite会自动创建它。

import sqlite3  # 连接到SQLite数据库  
# 数据库文件是test.db  
# 如果文件不存在，会自动在当前目录创建  
conn = sqlite3.connect('test.db')  # 创建一个Cursor对象  
cursor = conn.cursor()

（三）执行SQL语句

使用Cursor对象的execute()方法可以执行SQL语句。

# 创建一个表  
cursor.execute('''  CREATE TABLE IF NOT EXISTS users (  id INTEGER PRIMARY KEY,  name TEXT,  age INTEGER  )  
''')  # 插入数据  
cursor.execute("INSERT INTO users (name, age) VALUES (?, ?)", ("Alice", 30))  # 提交事务  
conn.commit()  # 查询数据  
cursor.execute("SELECT * FROM users")  
rows = cursor.fetchall()  
for row in rows:  print(row)  # 关闭连接  
conn.close()

（四）注意事项

在插入、更新或删除数据后，需要调用commit()方法提交事务。
使用参数化查询（如上面的?占位符）可以防止SQL注入攻击。

三、MySQL数据库连接与操作

（一）安装MySQL库

Python连接MySQL数据库需要使用第三方库，如mysql-connector-python或PyMySQL。这里以mysql-connector-python为例进行介绍。

pip install mysql-connector-python

（二）建立数据库连接

使用mysql.connector.connect()方法建立与MySQL数据库的连接。

import mysql.connector  # 创建数据库连接  
cnx = mysql.connector.connect(user='yourusername', password='yourpassword',  host='127.0.0.1',  database='yourdatabase')  # 创建一个Cursor对象  
cursor = cnx.cursor()

（三）执行SQL语句

与SQLite类似，使用Cursor对象的execute()方法执行SQL语句。

# 创建一个表  
cursor.execute('''  CREATE TABLE IF NOT EXISTS users (  id INT AUTO_INCREMENT PRIMARY KEY,  name VARCHAR(255),  age INT  )  
''')  # 插入数据  
insert_stmt = (  "INSERT INTO users (name, age) "  "VALUES (%s, %s)"  
)  
data = ('Bob', 25)  
cursor.execute(insert_stmt, data)  # 提交事务  
cnx.commit()  # 查询数据  
cursor.execute("SELECT * FROM users")  
rows = cursor.fetchall()  
for row in rows:  print(row)  # 关闭连接  
cursor.close()  
cnx.close()