Python筑基之旅-MySQL数据库(三)

2024-05-24 23:28
文章标签 python mysql 数据库 database 之旅 筑基

本文主要是介绍Python筑基之旅-MySQL数据库(三)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一、数据库操作

1、创建

1-1、用mysql-connector-python库

1-2、用PyMySQL库

1-3、用PeeWee库

1-4、用SQLAlchemy库

2、删除

2-1、用mysql-connector-python库

2-2、用PyMySQL库

2-3、用PeeWee库

2-4、用SQLAlchemy库

二、数据表操作

1、创建

1-1、用mysql-connector-python库

1-2、用PyMySQL库

1-3、用PeeWee库

1-4、用SQLAlchemy库

2、删除

2-1、用mysql-connector-python库

2-2、用PyMySQL库

2-3、用PeeWee库

2-4、用SQLAlchemy库

三、推荐阅读

1、Python函数之旅

2、Python算法之旅

3、博客个人主页

一、数据库操作

1、创建

        现需在MySQL服务器上新建数据库test_database；同时，在新建的数据库test_database中创建数据表test_table。不管是数据库，还是数据表，若不存在，则新建。

1-1、用mysql-connector-python库
import mysql.connector
# 配置数据库连接信息
config = {'user': 'root','password': '123456',  # 在此输入你的MySQL密码，请自行修改'host': '127.0.0.1','database': 'mysql'    # 如果要指定数据库
}
# 连接到MySQL服务器
try:cnx = mysql.connector.connect(**config)cursor = cnx.cursor()# 创建新数据库test_database（如果不存在）create_db_query = "CREATE DATABASE IF NOT EXISTS test_database"cursor.execute(create_db_query)# 切换到新数据库use_db_query = "USE test_database"cursor.execute(use_db_query)# 创建新表test_table（如果不存在）# 假设我们有一个简单的表，包含 id（整数，主键，自增）、name（字符串）和 age（整数）create_table_query = """    CREATE TABLE IF NOT EXISTS test_table (    id INT AUTO_INCREMENT PRIMARY KEY,    name VARCHAR(255) NOT NULL,    age INT    )    """cursor.execute(create_table_query)# 提交事务cnx.commit()
except mysql.connector.Error as err:print(f"Error: {err}")if cnx.is_connected():cnx.rollback()  # 如果需要回滚事务的话
finally:# 关闭游标和连接if cursor:cursor.close()if cnx.is_connected():cnx.close()
1-2、用PyMySQL库
import pymysql
# 配置数据库连接信息
config = {'user': 'root','password': '123456',  # 在此输入你的MySQL密码，请自行修改'host': '127.0.0.1','database': 'mysql'  # 如果要指定数据库，但这里我们稍后会创建新数据库
}
# 连接到MySQL服务器
try:# 注意：PyMySQL没有直接使用**config的方式，需要分别传入参数cnx = pymysql.connect(host=config['host'],user=config['user'],password=config['password'],charset='utf8mb4',  # 可选，添加字符集支持cursorclass=pymysql.cursors.DictCursor)  # 使用字典游标# 创建新数据库test_database（如果不存在）with cnx.cursor() as cursor:create_db_query = "CREATE DATABASE IF NOT EXISTS test_database"cursor.execute(create_db_query)# 切换到新数据库# 注意：PyMySQL没有直接的USE语句，我们需要断开连接并重新连接到新数据库cnx.close()config['database'] = 'test_database'cnx = pymysql.connect(**config, charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)# 创建新表test_table（如果不存在）# 假设我们有一个简单的表，包含 id（整数，主键，自增）、name（字符串）和 age（整数）with cnx.cursor() as cursor:create_table_query = """  CREATE TABLE IF NOT EXISTS test_table (  id INT AUTO_INCREMENT PRIMARY KEY,  name VARCHAR(255) NOT NULL,  age INT  )  """cursor.execute(create_table_query)# 提交事务cnx.commit()
except pymysql.MySQLError as err:print(f"Error: {err}")if cnx:cnx.rollback()  # 如果需要回滚事务的话（但对于DDL语句，通常没有回滚的必要）
finally:# 关闭游标和连接if cnx:cnx.close()
1-3、用PeeWee库
from peewee import *
# 配置数据库连接信息，这里尝试连接到名为'mysql'的数据库
db = MySQLDatabase('mysql', user='root', password='123456', host='127.0.0.1')
# 尝试连接数据库
try:db.connect()# 创建新数据库test_database（如果不存在），这里通过执行原始SQL语句来实现db.execute_sql("CREATE DATABASE IF NOT EXISTS test_database")# 更改数据库连接对象以连接到新创建的数据库（或已存在的）db = MySQLDatabase('test_database', user='root', password='123456', host='127.0.0.1')db.connect()# 定义模型（对应于数据库表）class TestTable(Model):id = AutoField()  # 自增主键name = CharField(null=False)  # 字符字段，不能为空age = IntegerField(null=True)  # 整数字段，可以为空class Meta:database = db  # 指定该模型使用的数据库连接# 自定义的创建表方法，这里实际上是覆盖了基类Model的create_table方法# 但实际上这里不需要重新定义，因为Peewee会自动在调用create_table时处理提交事务def create_table(cls, fail_silently=False, **options):super(TestTable, cls).create_table(fail_silently, **options)db.commit()  # 这里提交事务其实是不必要的，因为Peewee默认会处理# 调用自定义的create_table方法来创建表（如果不存在）# 但通常我们会直接调用 TestTable.create_table() 而无需修改它TestTable.create_table()
except Exception as e:print(f"Error: {e}")# 如果连接已关闭，这里的关闭操作是多余的，因为db.close()在连接关闭时不会引发错误if db.is_closed():db.close()  # 实际上，这里的检查是多余的，因为db在异常发生前应该是打开的else:db.rollback()  # 如果有事务在执行并且需要回滚的话（但在这个场景中，通常没有显式开启的事务）
finally:# 无论是否发生异常，都要确保数据库连接被关闭if not db.is_closed():db.close()
1-4、用SQLAlchemy库
略，该库本身不支持直接创建数据库，需要借助其他第三方库，如PyMySQL

2、删除

        现需在MySQL服务器上删除已有数据库test_database，以下为借助第三方库实现：

2-1、用mysql-connector-python库
import mysql.connector
# MySQL服务器连接参数
config = {'user': 'root','password': '123456',  # 在此输入你的MySQL密码，请自行修改'host': '127.0.0.1','database': 'mysql'    # 如果要指定数据库
}
# 连接到MySQL服务器
try:connection = mysql.connector.connect(**config)cursor = connection.cursor()# 执行SQL语句来删除test_database数据库sql = "DROP DATABASE IF EXISTS test_database"cursor.execute(sql)# 提交事务connection.commit()print("Database test_database deleted successfully.")
except mysql.connector.Error as error:print(f"Error: '{error}'")
finally:# 关闭游标和连接if connection.is_connected():cursor.close()connection.close()
2-2、用PyMySQL库
import pymysql
# MySQL服务器连接参数
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 替换为你的MySQL服务器地址'port': 3306,  # 如果你的MySQL不是默认端口，需要指定'charset': 'utf8mb4',  # 设置字符集'cursorclass': pymysql.cursors.DictCursor  # 使用字典游标，这不是必需的
}
# 连接到MySQL服务器（注意这里我们没有指定database参数）
try:# 因为我们要删除数据库，所以不需要连接到特定的数据库connection = pymysql.connect(**{k: v for k, v in config.items() if k != 'database'})with connection.cursor() as cursor:# 执行SQL语句来删除test_database数据库sql = "DROP DATABASE IF EXISTS test_database"cursor.execute(sql)# 提交事务，可省略connection.commit()print("Database test_database deleted successfully.")
except pymysql.MySQLError as error:print(f"Error: '{error}'")
finally:# 关闭连接if connection:connection.close()
2-3、用PeeWee库
略，该库本身不支持直接删除数据库，需要借助其他第三方库，如PyMySQL
2-4、用SQLAlchemy库
略，该库本身不支持直接删除数据库，需要借助其他第三方库，如PyMySQL

二、数据表操作

1、创建

        在MySQL服务器上已有数据库test_database，需在该数据库中创建数据表myelsa_table，以下为借助第三方库实现：

1-1、用mysql-connector-python库
import mysql.connector
# 数据库连接配置
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 如果数据库在远程服务器上，请替换为相应的主机名或IP地址'database': 'test_database',  # 数据库名'raise_on_warnings': True
}
# 连接到数据库
cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()
# 创建数据表的SQL语句
create_table_query = """  
CREATE TABLE IF NOT EXISTS myelsa_table (  name VARCHAR(255) NOT NULL, ID_Card VARCHAR(255) NOT NULL, age INT NOT NULL,  city VARCHAR(255) NOT NULL,  PRIMARY KEY (ID_Card)  -- 如果ID_Card字段是唯一的，可以设为主键，否则可以移除这行  
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;  
"""
# 执行SQL语句
cursor.execute(create_table_query)
# 提交更改（如果使用了事务）
cnx.commit()
# 关闭连接
cursor.close()
cnx.close()
print("Table myelsa_table created successfully!")
1-2、用PyMySQL库
import pymysql
# 数据库连接配置
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 如果数据库在远程服务器上，请替换为相应的主机名或IP地址'database': 'test_database',  # 数据库名'charset': 'utf8mb4',  # 字符集设置'cursorclass': pymysql.cursors.DictCursor  # 使用字典游标
}
# 连接到数据库
connection = pymysql.connect(**config)
try:with connection.cursor() as cursor:# 创建数据表的SQL语句create_table_query = """    CREATE TABLE IF NOT EXISTS myelsa_table (    name VARCHAR(255) NOT NULL,   ID_Card VARCHAR(255) NOT NULL,   age INT NOT NULL,    city VARCHAR(255) NOT NULL,    PRIMARY KEY (ID_Card)  -- 如果ID_Card字段是唯一的，可以设为主键  ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;    """# 执行SQL语句cursor.execute(create_table_query)# 提交更改（对于自动提交模式，这一步可能不是必须的）connection.commit()
finally:connection.close()print("Table myelsa_table created successfully!")
1-3、用PeeWee库
from peewee import *
# 数据库连接配置
db = MySQLDatabase('test_database', user='root', password='123456', host='127.0.0.1')
# 定义模型
class MyElsaTable(Model):name = CharField(max_length=255, null=False)ID_Card = CharField(max_length=255, unique=True)  # 假设ID_Card是唯一的age = IntegerField(null=False)city = CharField(max_length=255, null=False)class Meta:database = db
# 连接到数据库
db.connect()
# 创建表（如果表不存在）
db.create_tables([MyElsaTable])
# 关闭数据库连接（在 Peewee 中，通常不需要显式关闭连接，因为它会自动管理连接池）
db.close()
print("Table myelsa_table created successfully!")
1-4、用SQLAlchemy库
from sqlalchemy import create_engine, Column, Integer, String, MetaData
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
# 数据库连接配置（使用 SQLAlchemy 的 URI 格式）
DATABASE_URI = 'mysql+pymysql://root:123456@127.0.0.1/test_database?charset=utf8mb4'
# 创建一个引擎实例
engine = create_engine(DATABASE_URI, echo=True)  # echo=True 用于显示生成的 SQL 语句，调试时可以打开
# 创建基类
Base = declarative_base()
# 定义模型类
class MyElsaTable(Base):__tablename__ = 'myelsa_table'name = Column(String(255), nullable=False)ID_Card = Column(String(255), primary_key=True)  # 设置为主键age = Column(Integer, nullable=False)city = Column(String(255), nullable=False)
# 创建表（如果表不存在）
Base.metadata.create_all(engine)
# 如果你想要使用 ORM 来进行操作，可以创建一个 session 类
Session = sessionmaker(bind=engine)
session = Session()
# 这里不需要执行 SQL 语句或提交更改，因为 create_all 方法会自动处理
# 关闭 session（如果需要的话，但在这种情况下我们并没有进行任何 ORM 操作）
# session.close()
print("Table myelsa_table created successfully!")

2、删除

        在MySQL服务器上已有数据库test_database，且该数据库下已有数据表myelsa_table，现需删除数据表myelsa_table，以下为借助第三方库实现：

2-1、用mysql-connector-python库
import mysql.connector
# 数据库连接配置
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 如果数据库在远程服务器上，请替换为相应的主机名或IP地址'database': 'test_database',  # 数据库名
}
try:# 连接到数据库cnx = mysql.connector.connect(**config)cursor = cnx.cursor()# 执行SQL语句来删除表drop_table_query = "DROP TABLE IF EXISTS myelsa_table;"cursor.execute(drop_table_query)# 提交更改（在这个例子中，删除表不需要显式提交，因为不是事务的一部分）# 但如果你之前做了其他更改，这里可以调用cnx.commit()print("Table myelsa_table deleted successfully!")
except mysql.connector.Error as err:print(f"Error: '{err}'")
finally:# 关闭游标和连接if cursor:cursor.close()if cnx.is_connected():cnx.close()
2-2、用PyMySQL库
import pymysql
# 数据库连接配置
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 如果数据库在远程服务器上，请替换为相应的主机名或IP地址'database': 'test_database',  # 数据库名'charset': 'utf8mb4',  # 设置字符集，可选'cursorclass': pymysql.cursors.DictCursor  # 使用字典游标，可选
}
try:# 连接到数据库connection = pymysql.connect(**config)with connection.cursor() as cursor:# 执行SQL语句来删除表drop_table_query = "DROP TABLE IF EXISTS myelsa_table;"cursor.execute(drop_table_query)# 提交更改（在这个例子中，删除表不需要显式提交，因为不是事务的一部分）# 但如果你之前做了其他更改，并且它们是在一个事务中，这里可以调用 connection.commit()print("Table myelsa_table deleted successfully!")
except pymysql.MySQLError as err:print(f"Error: '{err}'")
finally:# 关闭连接if connection.open:connection.close()
2-3、用PeeWee库
# 注意，这里需要借助扩展库peewee-mysql，需提前安装
from peewee import *
# 数据库连接配置  
db = MySQLDatabase('test_database',user='root',password='123456',host='127.0.0.1'
)
try:# 连接到数据库  db.connect()# 创建一个用于执行原始 SQL 的游标  db.execute_sql("DROP TABLE IF EXISTS myelsa_table;")# Peewee 没有直接的“提交”操作，因为对于 DDL（数据定义语言）语句如 DROP TABLE，  # 它们通常是立即执行的，不需要事务提交。  print("Table myelsa_table deleted successfully!")
except peewee.OperationalError as e:print(f"Error: '{e}'")
finally:# 关闭数据库连接  db.close()
2-4、用SQLAlchemy库
from sqlalchemy import create_engine, MetaData, Table
# 数据库连接配置
config = {'user': 'root',  # 替换为你的MySQL用户名'password': '123456',  # 替换为你的MySQL密码'host': '127.0.0.1',  # 如果数据库在远程服务器上，请替换为相应的主机名或IP地址'database': 'test_database',  # 数据库名'dialect': 'mysql'  # 使用mysql方言
}
# 创建连接字符串
connection_string = f"{config['dialect']}+pymysql://{config['user']}:{config['password']}@{config['host']}/{config['database']}"
try:# 创建引擎engine = create_engine(connection_string)# 使用引擎连接到数据库with engine.connect() as conn:# 创建元数据对象metadata = MetaData()# 定义要删除的表（如果已知表结构，可以创建完整的 Table 对象）# 但为了简单地删除表，我们只需要表名table_name = 'myelsa_table'# 使用 SQLAlchemy 的反射机制来获取 Table 对象（如果需要）# 这里我们直接执行原始 SQL 语句来删除表# 执行SQL语句来删除表drop_table_query = f"DROP TABLE IF EXISTS {table_name};"conn.execute(drop_table_query)print("Table myelsa_table deleted successfully!")
except Exception as e:print(f"Error: '{e}'")# 在 with 语句结束后，连接会自动关闭，所以不需要显式关闭连接

三、推荐阅读

1、Python函数之旅

2、Python算法之旅

3、博客个人主页

这篇关于Python筑基之旅-MySQL数据库(三)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/999836。

相关文章

Python的Darts库实现时间序列预测

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts？二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与
阅读更多...
Python正则表达式匹配和替换的操作指南

Python正则表达式匹配和替换的操作指南

《Python正则表达式匹配和替换的操作指南》正则表达式是处理文本的强大工具,Python通过re模块提供了完整的正则表达式功能,本文将通过代码示例详细介绍Python中的正则匹配和替换操作,需要的朋... 目录基础语法导入re模块基本元字符常用匹配方法1. re.match() - 从字符串开头匹配2.
阅读更多...
Python使用FastAPI实现大文件分片上传与断点续传功能

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现（FastAPI）2.1 运行环境2.2 目录结构建议2.3 serv
阅读更多...
通过Docker容器部署Python环境的全流程

通过Docker容器部署Python环境的全流程

《通过Docker容器部署Python环境的全流程》在现代化开发流程中,Docker因其轻量化、环境隔离和跨平台一致性的特性,已成为部署Python应用的标准工具,本文将详细演示如何通过Docker容... 目录引言一、docker与python的协同优势二、核心步骤详解三、进阶配置技巧四、生产环境最佳实践
阅读更多...
Python一次性将指定版本所有包上传PyPI镜像解决方案

Python一次性将指定版本所有包上传PyPI镜像解决方案

《Python一次性将指定版本所有包上传PyPI镜像解决方案》本文主要介绍了一个安全、完整、可离线部署的解决方案,用于一次性准备指定Python版本的所有包,然后导出到内网环境,感兴趣的小伙伴可以跟随... 目录为什么需要这个方案完整解决方案1. 项目目录结构2. 创建智能下载脚本3. 创建包清单生成脚本4
阅读更多...
MySQL的JDBC编程详解

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》：本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq
阅读更多...
java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》：本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏
阅读更多...
Python实现Excel批量样式修改器(附完整代码)

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函
阅读更多...
python获取指定名字的程序的文件路径的两种方法

python获取指定名字的程序的文件路径的两种方法

《python获取指定名字的程序的文件路径的两种方法》本文主要介绍了python获取指定名字的程序的文件路径的两种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要... 最近在做项目，需要用到给定一个程序名字就可以自动获取到这个程序在Windows系统下的绝对路径，以下
阅读更多...
Linux下MySQL数据库定时备份脚本与Crontab配置教学

Linux下MySQL数据库定时备份脚本与Crontab配置教学

《Linux下MySQL数据库定时备份脚本与Crontab配置教学》在生产环境中,数据库是核心资产之一,定期备份数据库可以有效防止意外数据丢失,本文将分享一份MySQL定时备份脚本,并讲解如何通过cr... 目录备份脚本详解脚本功能说明授权与可执行权限使用 Crontab 定时执行编辑 Crontab添加定
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2