### 如何使用Python进行数据库查询 #### 使用`sqlite3`模块进行基本查询操作 对于简单的SQLite数据库查询，可以利用Python内置的`sqlite3`模块。此方法适用于小型项目或测试环境。 ```python import sqlite3 connection = sqlite3.connect('example.db') # 建立连接到名为 example 的 SQLite 数据库文件 cursor = connection.cursor() query = "SELECT * FROM table_name" cursor.execute(query) results = cursor.fetchall() # 获取所有记录作为列表返回 for row in results: print(row) connection.close() ``` 当涉及到更复杂的SQL语句或是其他类型的数据库（如MySQL），则推荐采用专门设计用于这些系统的驱动程序来代替`sqlite3`[^3]。 #### 利用`mysql.connector`处理MySQL数据库 为了与MySQL交互，在安装好相应的包之后，可以通过如下方式构建应用程序： ```python import mysql.connector db_config = { 'user': 'root', 'password': '', 'host': 'localhost', 'database': 'test' } connnection_mysql = mysql.connector.connect(**db_config) if connnection_mysql.is_connected(): db_info = connnection_mysql.get_server_info() print(f"Connected to MySQL Server version {db_info}") else: print("Failed to connect.") try: cursor = connnection_mysql.cursor(prepared=True) sql_select_query = """select * from EMPLOYEE where salary > %s""" cursor.execute(sql_select_query, (1000,)) records = cursor.fetchall() for record in records: print(record) except Exception as e: print(e) finally: if(connnection_mysql.is_connected()): cursor.close() connnection_mysql.close() print("MySQL connection is closed.") ``` 这段代码展示了如何安全地准备并执行带有参数化的SQL命令以防止SQL注入攻击，并且正确关闭资源[^4]。 #### ORM框架——SQLAlchemy简介 除了直接编写SQL外，还可以考虑使用对象关系映射器(Object Relational Mapper)，比如SQLAlchemy。它允许开发者通过面向对象的方式定义模型并与之互动，而无需关心底层的具体实现细节。 ```python from sqlalchemy import create_engine, Column, Integer, String from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker Base = declarative_base() class Employee(Base): __tablename__ = 'employee' id = Column(Integer, primary_key=True) name = Column(String) engine = create_engine('sqlite:///employees.sqlite') Session = sessionmaker(bind=engine) session = Session() # 查询员工信息 employees = session.query(Employee).filter(Employee.salary > 1000).all() for emp in employees: print(emp.name) ``` 上述例子说明了怎样借助ORM工具简化开发流程的同时保持良好的性能表现。