当前位置： 首页 > wzjs >正文

济宁建设局网站首页购物网站建设的选题意义

wzjs 2025/9/15 17:47:16
济宁建设局网站首页,购物网站建设的选题意义,网站做支付要多少钱,seo排名策略文章目录 一、环境准备1.1 安装MySQL数据库1.2 安装Python MySQL驱动 二、连接到MySQL数据库三、执行基本的CRUD操作3.1 创建（Create）：插入数据3.2 读取（Read）：查询数据3.3 更新（Update&#xf…

文章目录

    • 一、环境准备
      • 1.1 安装MySQL数据库
      • 1.2 安装Python MySQL驱动
    • 二、连接到MySQL数据库
    • 三、执行基本的CRUD操作
      • 3.1 创建（Create）：插入数据
      • 3.2 读取（Read）：查询数据
      • 3.3 更新（Update）：更新数据
      • 3.4 删除（Delete）：删除数据
      • 3.5 完整代码示例
    • 四、使用上下文管理器简化连接和游标管理
    • 五、处理事务
    • 六、使用ORM框架（推荐）
    • 七、最佳实践
    • 八、总结

在数据采集、处理和存储过程中，MySQL作为一种广泛使用的关系型数据库管理系统，因其高性能、可靠性和易用性而备受青睐。Python提供了多种库来连接和操作MySQL数据库，其中最常用的是mysql-connector-python和PyMySQL。本文将详细介绍如何使用Python连接MySQL数据库，执行基本的CRUD（创建、读取、更新、删除）操作，并提供相应的代码示例。

一、环境准备

1.1 安装MySQL数据库

确保已经在系统中安装并运行了MySQL数据库。可以从 MySQL官方网站 下载并安装适合你操作系统的版本。

1.2 安装Python MySQL驱动

使用pip安装mysql-connector-python或PyMySQL库。这里以PyMySQL为例：

pip install PyMySQL

二、连接到MySQL数据库

首先，需要使用Python代码连接到MySQL数据库。以下是使用PyMySQL连接数据库的基本步骤：

import pymysql# 连接参数
connection = pymysql.connect(host='localhost',        # 数据库主机地址user='your_username',    # 数据库用户名password='your_password',# 数据库密码database='your_database',# 要连接的数据库名称charset='utf8mb4',       # 字符集cursorclass=pymysql.cursors.DictCursor  # 返回字典类型的结果
)try:with connection.cursor() as cursor:# 在此处执行SQL语句pass
finally:connection.close()

三、执行基本的CRUD操作

3.1 创建（Create）：插入数据

使用INSERT INTO语句向表中插入数据。

import pymysqlconnection = pymysql.connect(host='localhost',user='your_username',password='your_password',database='test_db',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor
)try:with connection.cursor() as cursor:sql = "INSERT INTO users (name, age, email) VALUES (%s, %s, %s)"cursor.execute(sql, ('张三', 28, 'zhangsan@example.com'))connection.commit()  # 提交事务
finally:connection.close()

3.2 读取（Read）：查询数据

使用SELECT语句从表中查询数据。

import pymysqlconnection = pymysql.connect(host='localhost',user='your_username',password='your_password',database='test_db',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor
)try:with connection.cursor() as cursor:sql = "SELECT id, name, age, email FROM users WHERE age > %s"cursor.execute(sql, (25,))results = cursor.fetchall()for row in results:print(row)
finally:connection.close()

3.3 更新（Update）：更新数据

使用UPDATE语句修改表中的数据。

import pymysqlconnection = pymysql.connect(host='localhost',user='your_username',password='your_password',database='test_db',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor
)try:with connection.cursor() as cursor:sql = "UPDATE users SET age = %s WHERE name = %s"cursor.execute(sql, (29, '张三'))connection.commit()
finally:connection.close()

3.4 删除（Delete）：删除数据

使用DELETE语句删除表中的数据。

import pymysqlconnection = pymysql.connect(host='localhost',user='your_username',password='your_password',database='test_db',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor
)try:with connection.cursor() as cursor:sql = "DELETE FROM users WHERE name = %s"cursor.execute(sql, ('李四',))connection.commit()
finally:connection.close()

3.5 完整代码示例

以下是一个完整的Python脚本，演示了如何连接MySQL数据库并执行CRUD操作。

import pymysql# 数据库连接配置
config = {'host': 'localhost',        # 数据库主机地址'port': 3306,               # 数据库端口，默认3306'user': 'your_username',    # 数据库用户名'password': 'your_password',# 数据库密码'database': 'test_db',      # 要连接的数据库名称'charset': 'utf8mb4',       # 字符集'cursorclass': pymysql.cursors.DictCursor  # 返回字典类型的结果
}def create_database(cursor):"""创建数据库"""cursor.execute("CREATE DATABASE IF NOT EXISTS test_db CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;")print("数据库创建成功或已存在。")def create_table(cursor):"""创建表"""create_table_sql = """CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY,name VARCHAR(100) NOT NULL,age INT,email VARCHAR(150) UNIQUE) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;"""cursor.execute(create_table_sql)print("表创建成功或已存在。")def insert_data(cursor, connection, data):"""插入数据"""sql = "INSERT INTO users (name, age, email) VALUES (%s, %s, %s)"cursor.execute(sql, data)connection.commit()print(f"插入一条数据，ID: {cursor.lastrowid}")def query_data(cursor):"""查询数据"""sql = "SELECT id, name, age, email FROM users WHERE age > %s"cursor.execute(sql, (25,))results = cursor.fetchall()print("查询结果:")for row in results:print(row)def update_data(cursor, connection, user_id, new_age):"""更新数据"""sql = "UPDATE users SET age = %s WHERE id = %s"cursor.execute(sql, (new_age, user_id))connection.commit()print(f"更新ID为{user_id}的用户年龄为{new_age}")def delete_data(cursor, connection, user_id):"""删除数据"""sql = "DELETE FROM users WHERE id = %s"cursor.execute(sql, (user_id,))connection.commit()print(f"删除ID为{user_id}的用户")def main():try:# 连接到MySQL服务器connection = pymysql.connect(**config)with connection.cursor() as cursor:# 创建数据库create_database(cursor)# 使用刚创建的数据库connection.select_db('test_db')# 创建表create_table(cursor)# 插入数据users = [('张三', 28, 'zhangsan@example.com'),('李四', 34, 'lisi@example.com'),('王五', 23, 'wangwu@example.com')]for user in users:insert_data(cursor, connection, user)# 查询数据print("\n所有用户信息:")query_data(cursor)# 更新数据update_data(cursor, connection, 1, 29)# 查询更新后的数据print("\n更新后的用户信息:")query_data(cursor)# 删除数据delete_data(cursor, connection, 2)# 查询删除后的数据print("\n删除后的用户信息:")query_data(cursor)except pymysql.MySQLError as e:print(f"发生错误: {e}")finally:if 'connection' in locals() and connection.open:connection.close()print("\n数据库连接已关闭。")if __name__ == "__main__":main()

四、使用上下文管理器简化连接和游标管理

为了简化代码和提高可读性，可以使用上下文管理器（with语句）来自动管理数据库连接和游标。

import pymysqlconnection_params = {'host': 'localhost','user': 'your_username','password': 'your_password','database': 'test_db','charset': 'utf8mb4','cursorclass': pymysql.cursors.DictCursor
}sql_insert = "INSERT INTO users (name, age, email) VALUES (%s, %s, %s)"
data = ('王五', 25, 'wangwu@example.com')with pymysql.connect(**connection_params) as connection:with connection.cursor() as cursor:cursor.execute(sql_insert, data)connection.commit()

五、处理事务

事务是确保数据库操作原子性、一致性、隔离性和持久性（ACID）的重要机制。PyMySQL支持事务管理，可以通过commit()和rollback()方法来控制事务。

import pymysqlconnection_params = {'host': 'localhost','user': 'your_username','password': 'your_password','database': 'test_db','charset': 'utf8mb4','cursorclass': pymysql.cursors.DictCursor
}sql_insert = "INSERT INTO users (name, age, email) VALUES (%s, %s, %s)"
sql_update = "UPDATE users SET age = %s WHERE name = %s"data_insert = ('赵六', 30, 'zhaoliu@example.com')
data_update = (31, '赵六')try:with pymysql.connect(**connection_params) as connection:with connection.cursor() as cursor:cursor.execute(sql_insert, data_insert)cursor.execute(sql_update, data_update)connection.commit()  # 提交事务
except Exception as e:connection.rollback()  # 回滚事务print(f"发生错误: {e}")

六、使用ORM框架（推荐）

虽然直接使用SQL语句可以灵活地操作数据库，但对于复杂的项目，使用ORM（对象关系映射）框架可以提高开发效率和代码可维护性。SQLAlchemy是Python中一个强大的ORM框架，支持多种数据库，包括MySQL。

安装SQLAlchemy

pip install SQLAlchemy pymysql

使用SQLAlchemy连接MySQL

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import declarative_base, sessionmaker# 创建数据库引擎
engine = create_engine('mysql+pymysql://your_username:your_password@localhost/test_db?charset=utf8mb4')# 创建基类
Base = declarative_base()# 定义User模型
class User(Base):__tablename__ = 'users'id = Column(Integer, primary_key=True, autoincrement=True)name = Column(String(50))age = Column(Integer)email = Column(String(100))# 创建会话
Session = sessionmaker(bind=engine)
session = Session()# 创建表（如果不存在）
Base.metadata.create_all(engine)# 添加新用户
new_user = User(name='孙七', age=27, email='sunqi@example.com')
session.add(new_user)
session.commit()# 查询用户
users = session.query(User).filter(User.age > 25).all()
for user in users:print(user.name, user.age, user.email)# 关闭会话
session.close()

七、最佳实践

​1、使用参数化查询：避免SQL注入攻击，使用参数化查询（如 %s 占位符）或ORM框架。

​2、管理连接池：对于高并发应用，使用连接池（如SQLAlchemy的连接池）来管理数据库连接。

3、​处理异常：建议使用 try-except 捕获并处理数据库操作中的异常，确保程序的健壮性。

​4、关闭连接：确保在操作完成后关闭数据库连接，释放资源。

​5、优化查询：编写高效的SQL查询，避免全表扫描和不必要的复杂查询。

6、事务管理：在执行插入、更新、删除操作后，需要调用 conn.commit() 提交事务。

八、总结

使用Python连接和操作MySQL数据库是数据采集、处理和存储中的常见需求。通过PyMySQL、mysql-connector-python等库，可以方便地执行CRUD操作；而使用ORM框架如SQLAlchemy，则可以提高开发效率和代码的可维护性。在实际应用中，结合具体需求选择合适的方法，并遵循最佳实践，可以确保数据库操作的效率和安全性。


文章转载自：

http://q55WLr5D.rkwLg.cn
http://NzCP9LP5.rkwLg.cn
http://4fjWBpkk.rkwLg.cn
http://HCjMovuf.rkwLg.cn
http://gYIJgqNh.rkwLg.cn
http://cNPuskaJ.rkwLg.cn
http://MEoqJNbb.rkwLg.cn
http://Jx3RThA6.rkwLg.cn
http://WWSSZK9P.rkwLg.cn
http://6E16VxWp.rkwLg.cn
http://N70W6yM9.rkwLg.cn
http://j1g5V0pi.rkwLg.cn
http://WUcpYDkH.rkwLg.cn
http://Y9k7cfQW.rkwLg.cn
http://MsIR0oVf.rkwLg.cn
http://ieRbPdV1.rkwLg.cn
http://ULfkrw3u.rkwLg.cn
http://ALuGOGst.rkwLg.cn
http://1rIfbqcw.rkwLg.cn
http://aCFgfbHN.rkwLg.cn
http://RqMtoJ3U.rkwLg.cn
http://15TPIReZ.rkwLg.cn
http://DZ3FEqmR.rkwLg.cn
http://zHioyOP9.rkwLg.cn
http://wDn2n1AL.rkwLg.cn
http://9GzVdimz.rkwLg.cn
http://4Eu2wCS8.rkwLg.cn
http://S8uAZfOO.rkwLg.cn
http://1NdaMlY6.rkwLg.cn
http://ao9iJKeZ.rkwLg.cn
http://www.dtcms.com/wzjs/744934.html

相关文章：

  • 为什么要用php做网站cms三合一网站源码
  • 高新区做网站程序员接单网站
  • 找建设项目的网站网站高端建设
  • 南京的网站建设公司哪家好高端建筑班
  • 陕西网页制作公司山东网络优化公司排名
  • iis网站服务被禁用住宅小区物业管理系统网站建设
  • 学校资源网站的建设方案网站模板 小说
  • 深圳网站设计|优选灵点网络网站建设需要的专业知识
  • 网站建设方案 安全用二级域名做网站对seo
  • 杭州萧山做网站wordpress手机app编辑文章
  • 旅游微网站分销电商平台的发展
  • 建立网站的基本流程有哪些步骤兰州市政建设集团办公网站
  • 正鹏建设工程有限公司网站wordpress 对象存储插件
  • title (网站开发)wordpress 调用二级分类
  • 已备案网站增加域名企业形象设计公司
  • 有什么平台可以做网站免费的ppt模板下载
  • 内容相同的 网站网站备案字号
  • 网站推荐几个免费的网站基本建设
  • 光纤网络哪个公司好流程优化的方法
  • 西安h5建站自己做婚恋网站
  • 怎么注册网站平台酒业网站建设
  • 网站手机客户端制作室内设计课程
  • 素材网站开发网站建设难么
  • 排名好的移动网站建设企业网站的建立视频
  • 中国空间站照片国企建筑单位招聘信息
  • 做网站的工作是什么湖州哪里做网站
  • 石龙仿做网站重庆关键词优化平台
  • 湖南网红网站建设有限公司wordpress多个菜单
  • 网站开发干啥的wordpress 修改发帖时间
  • 做一个宣传网站要多少钱创建官方网站网址