Python--MySQL及其使用

1. MySQL 简介

MySQL 是一个开源的关系型数据库管理系统（RDBMS），广泛用于各种应用程序，支持多种操作系统。它使用 SQL 语言进行数据查询、管理和操作。

2. MySQL 的主要特点

跨平台：支持多种操作系统，如 Linux、Windows、Mac OS 等。
高性能：优化的查询处理和缓存机制，提供高并发处理能力。
安全性：提供用户认证、访问控制和数据加密等安全机制。
易用性：通过图形界面和命令行工具简化数据库管理。

3. Python 连接 MySQL

Python 通过 pymysql 库可以方便地与 MySQL 数据库进行交互。以下是一些基础操作的示例。

3.1 安装 pymysql

首先需要安装 pymysql 库：

pip install pymysql

3.2 连接数据库

使用 pymysql 连接 MySQL 数据库：

from pymysql import Connectionconn = Connection(host="localhost",   # 主机名（IP）port=3306,          # 端口user="root",        # 账户password="123456",   # 密码autocommit=True     # 设置自动提交
)

3.3 选择数据库

conn.select_db("py_sql")

3.4 执行 SQL 语句

cursor = conn.cursor()      # 获取到游标对象
cursor.execute("insert into student values(10001, '周杰轮', 31, '男')")

3.5 查询数据

cursor.execute("SELECT * FROM orders")
result = cursor.fetchall()
for r in result:print(r)

3.6 关闭连接

conn.close()

4. 数据导入与导出

4.1 从文本文件导入数据

假设有一个文本文件 D:/2011年1月销售数据.txt，我们可以使用自定义的 TextFileReader 类读取数据，并将其导入到 MySQL 数据库中。

from file_define_mysql import TextFileReader
from data_define_mysql import Record
from pymysql import Connectiontext_file_reader = TextFileReader("D:/2011年1月销售数据.txt")
jan_data: list[Record] = text_file_reader.read_data()conn = Connection(host="localhost",port=3306,user="root",password="123456",autocommit=True
)
cursor = conn.cursor()
conn.select_db("py_sql")for record in jan_data:sql = f"insert into orders(order_date, order_id, money, province) " \f"values('{record.date}', '{record.order_id}', {record.money}, '{record.province}')"cursor.execute(sql)conn.close()

4.2 从 JSON 文件导入数据

类似地，可以从 JSON 文件读取数据并导入到 MySQL 数据库中。

from file_define_mysql import JsonFileReader
from data_define_mysql import Record
from pymysql import Connectionjson_file_reader = JsonFileReader("D:/2011年2月销售数据JSON.txt")
feb_data: list[Record] = json_file_reader.read_data()conn = Connection(host="localhost",port=3306,user="root",password="123456",autocommit=True
)
cursor = conn.cursor()
conn.select_db("py_sql")for record in feb_data:sql = f"insert into orders(order_date, order_id, money, province) " \f"values('{record.date}', '{record.order_id}', {record.money}, '{record.province}')"cursor.execute(sql)conn.close()

4.3 从 MySQL 导出数据到 JSON 文件

将 MySQL 中的数据导出到 JSON 文件。

from data_define_mysql import Record
from pymysql import Connectionf = open("d:/output.json", "w", encoding="UTF-8")
conn = Connection(host="localhost",port=3306,user="root",password="123456",autocommit=True
)
cursor = conn.cursor()
conn.select_db("py_sql")
cursor.execute("SELECT * FROM orders")
result = cursor.fetchall()for r in result:record = Record(r[0], r[1], r[2], r[3])f.write(record.to_json())f.write("\n")conn.close()
f.close()