### 使用Python连接数据库并实现增删改查功能 在Python中，可以通过多种库和框架与数据库交互以完成增删改查操作。以下是一个完整的解决方案，涵盖连接数据库、执行SQL语句以及实现CRUD功能的详细方法。 #### 1. 连接数据库 Python提供了丰富的库来连接不同类型的数据库。例如，可以使用`pymysql`连接MySQL数据库[^3]，或者使用`sqlite3`模块连接SQLite数据库[^1]。以下是一个使用`pymysql`连接MySQL数据库的示例： ```python import pymysql # 创建数据库连接 connection = pymysql.connect( host='localhost', port=3306, user='root', password='123456', database='draw' # 数据库名 ) ``` #### 2. 实现增删改查功能 通过SQL语句可以实现对数据库的增删改查操作。以下是具体的代码示例： ##### (1) 插入数据 插入数据时，可以使用`INSERT INTO`语句。以下是一个插入数据的示例： ```python def insert_data(connection, name): try: with connection.cursor() as cursor: sql = "INSERT INTO items (name) VALUES (%s)" cursor.execute(sql, (name,)) connection.commit() except Exception as e: print(f"Error: {e}") ``` ##### (2) 查询数据 查询数据时，可以使用`SELECT`语句。以下是一个查询数据的示例： ```python def fetch_data(connection, item_id): try: with connection.cursor() as cursor: sql = "SELECT * FROM items WHERE id = %s" cursor.execute(sql, (item_id,)) result = cursor.fetchone() return result except Exception as e: print(f"Error: {e}") ``` ##### (3) 更新数据 更新数据时，可以使用`UPDATE`语句。以下是一个更新数据的示例： ```python def update_data(connection, item_id, new_name): try: with connection.cursor() as cursor: sql = "UPDATE items SET name = %s WHERE id = %s" cursor.execute(sql, (new_name, item_id)) connection.commit() except Exception as e: print(f"Error: {e}") ``` ##### (4) 删除数据 删除数据时，可以使用`DELETE`语句。以下是一个删除数据的示例： ```python def delete_data(connection, item_id): try: with connection.cursor() as cursor: sql = "DELETE FROM items WHERE id = %s" cursor.execute(sql, (item_id,)) connection.commit() except Exception as e: print(f"Error: {e}") ``` #### 3. 使用ORM简化数据库操作 除了直接执行SQL语句外，还可以使用ORM（对象关系映射）工具如SQLAlchemy或Django ORM来简化数据库操作[^2]。以下是一个使用SQLAlchemy实现CRUD的示例： ```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 Item(Base): __tablename__ = 'items' id = Column(Integer, primary_key=True) name = Column(String) # 创建数据库引擎和会话 engine = create_engine('sqlite:///test.db') Session = sessionmaker(bind=engine) session = Session() # 插入数据 def add_item(name): new_item = Item(name=name) session.add(new_item) session.commit() # 查询数据 def get_item(item_id): return session.query(Item).filter_by(id=item_id).first() # 更新数据 def modify_item(item_id, new_name): item = session.query(Item).filter_by(id=item_id).first() if item: item.name = new_name session.commit() # 删除数据 def remove_item(item_id): item = session.query(Item).filter_by(id=item_id).first() if item: session.delete(item) session.commit() ``` --- ###