Python3作为常用的开发语言，在数据处理、后端开发等场景中经常需要和数据库交互，掌握不同数据库的连接与操作方法是非常必要的技能。不同的数据库对应的Python驱动不同，操作逻辑也存在一定差异，下面会逐一讲解常见数据库的连接与操作方式。
常用数据库驱动选择
Python3连接数据库需要先安装对应的驱动库，不同数据库的主流驱动如下：
- SQLite：Python3内置了
sqlite3模块，无需额外安装 - MySQL：常用驱动有
pymysql、mysql-connector-python - PostgreSQL：常用驱动为
psycopg2
SQLite数据库连接与操作
SQLite是轻量级嵌入式数据库，适合本地存储小体量数据，不需要单独启动数据库服务，使用起来非常便捷。
连接数据库
使用sqlite3模块连接本地数据库，如果数据库文件不存在会自动创建：
import sqlite3
# 连接数据库，test.db不存在则自动创建
conn = sqlite3.connect("test.db")
# 创建游标对象，用于执行SQL语句
cursor = conn.cursor()
基础增删改查操作
通过游标执行SQL语句完成数据操作，操作完成后需要提交事务并关闭连接：
import sqlite3
conn = sqlite3.connect("test.db")
cursor = conn.cursor()
# 创建数据表
create_table_sql = """CREATE TABLE IF NOT EXISTS user (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT NOT NULL,
age INTEGER
)"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO user (name, age) VALUES (?, ?)"
cursor.execute(insert_sql, ("张三", 25))
# 批量插入数据
cursor.executemany(insert_sql, [("李四", 28), ("王五", 22)])
# 提交事务，不提交的话插入的数据不会生效
conn.commit()
# 查询数据
cursor.execute("SELECT * FROM user")
# 获取所有查询结果
result = cursor.fetchall()
for row in result:
print(f"id:{row[0]}, name:{row[1]}, age:{row[2]}")
# 更新数据
update_sql = "UPDATE user SET age = ? WHERE name = ?"
cursor.execute(update_sql, (26, "张三"))
conn.commit()
# 删除数据
delete_sql = "DELETE FROM user WHERE name = ?"
cursor.execute(delete_sql, ("王五",))
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
MySQL数据库连接与操作
MySQL是常用的关系型数据库，需要提前启动MySQL服务，并且安装对应的驱动库，这里以pymysql为例讲解。
安装驱动
使用pip命令安装pymysql：
pip install pymysql
连接数据库
连接MySQL需要提供主机地址、端口、用户名、密码、数据库名等信息：
import pymysql
# 连接MySQL数据库
conn = pymysql.connect(
host="127.0.0.1", # 数据库主机地址
port=3306, # 端口号，默认3306
user="root", # 用户名
password="123456", # 密码
database="test_db",# 要连接的数据库名
charset="utf8mb4" # 字符集
)
cursor = conn.cursor()
基础增删改查操作
MySQL的操作逻辑和SQLite类似，只是SQL语法和参数占位符有细微差异：
import pymysql
conn = pymysql.connect(
host="127.0.0.1",
port=3306,
user="root",
password="123456",
database="test_db",
charset="utf8mb4"
)
cursor = conn.cursor()
# 创建数据表
create_table_sql = """CREATE TABLE IF NOT EXISTS user (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(50) NOT NULL,
age INT
)"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO user (name, age) VALUES (%s, %s)"
cursor.execute(insert_sql, ("张三", 25))
cursor.executemany(insert_sql, [("李四", 28), ("王五", 22)])
conn.commit()
# 查询数据
cursor.execute("SELECT * FROM user")
result = cursor.fetchall()
for row in result:
print(f"id:{row[0]}, name:{row[1]}, age:{row[2]}")
# 更新数据
update_sql = "UPDATE user SET age = %s WHERE name = %s"
cursor.execute(update_sql, (26, "张三"))
conn.commit()
# 删除数据
delete_sql = "DELETE FROM user WHERE name = %s"
cursor.execute(delete_sql, ("王五",))
conn.commit()
cursor.close()
conn.close()
连接异常处理
数据库连接和操作过程中可能会出现各种异常，比如连接失败、SQL语法错误等，需要添加异常处理逻辑保证程序稳定性：
import pymysql
from pymysql import MySQLError
try:
conn = pymysql.connect(
host="127.0.0.1",
port=3306,
user="root",
password="123456",
database="test_db",
charset="utf8mb4"
)
cursor = conn.cursor()
cursor.execute("SELECT * FROM user")
print(cursor.fetchall())
except MySQLError as e:
print(f"数据库操作异常：{e}")
finally:
# 无论是否出现异常，都尝试关闭连接
if "cursor" in locals():
cursor.close()
if "conn" in locals():
conn.close()
注意事项
- 操作完数据库后一定要关闭游标和连接，避免资源泄露
- 插入、更新、删除操作执行后需要调用
commit()提交事务，查询操作不需要 - SQL语句中的参数使用占位符，不要直接拼接字符串，避免SQL注入风险
- 连接远程数据库时需要确保数据库服务允许远程连接，并且防火墙开放对应端口
Python3数据库连接MySQL_connectorsqlite3pymysql修改时间：2026-07-11 07:36:24