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

news2025/1/2 0:12:02

一、引言

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