### 连接与操作 MySQL 数据库 在 Python 中，可以使用 `pymysql` 或 `mysql-connector-python` 等库来连接和操作 MySQL 数据库。以下是一个使用 `pymysql` 的示例代码： ```python import pymysql # 创建数据库连接 conn = pymysql.connect( host='localhost', port=3306, user='root', password='password', database='test_db', charset='utf8mb4' ) # 获取游标对象 cursor = conn.cursor() # 执行 SQL 查询 cursor.execute('SELECT * FROM test_table') # 获取查询结果 results = cursor.fetchall() # 输出结果 for row in results: print(row) # 关闭连接 conn.close() ``` 插入数据的示例： ```python # 插入数据 try: with conn.cursor() as cursor: affected_rows = cursor.execute( 'INSERT INTO tb_dept (dno, dname, dloc) VALUES (%s, %s, %s)', ('10', '研发部', '北京') ) conn.commit() if affected_rows == 1: print('添加部门成功！！') except pymysql.MySQLError: conn.rollback() finally: conn.close() ``` ### 连接与操作 Excel 文件 Python 提供了多种库用于读写 Excel 文件，如 `openpyxl`（适用于 `.xlsx` 文件）和 `xlrd`、`xlwt`（适用于 `.xls` 文件）。下面是一个使用 `openpyxl` 读取 Excel 文件并输出部分内容的示例： ```python from openpyxl import load_workbook # 加载 Excel 文件 wb = load_workbook(filename='example.xlsx') # 获取活动的工作表 ws = wb.active # 遍历工作表中的数据 for row in ws.iter_rows(values_only=True): print(row) ``` 写入 Excel 文件的示例： ```python from openpyxl import Workbook # 创建一个新的工作簿 wb = Workbook() ws = wb.active # 写入数据 ws['A1'] = '部门编号' ws['B1'] = '部门名称' ws['C1'] = '部门所在地' # 添加多行数据 data = [ ('10', '研发部', '北京'), ('20', '市场部', '上海') ] for row in data: ws.append(row) # 保存文件 wb.save('output.xlsx') ``` ### 将 Excel 数据导入 MySQL 结合上述两个部分的功能，可以实现将 Excel 文件中的数据批量导入到 MySQL 数据库中。以下是完整的脚本示例： ```python import pymysql from openpyxl import load_workbook # 数据库连接配置 db_config = { 'host': 'localhost', 'port': 3306, 'user': 'root', 'password': 'password', 'database': 'test_db', 'charset': 'utf8mb4' } # 连接数据库 conn = pymysql.connect(**db_config) cursor = conn.cursor() # 加载 Excel 文件 wb = load_workbook(filename='departments.xlsx') ws = wb.active # 跳过标题行，从第二行开始读取数据 rows = list(ws.rows)[1:] # 插入数据到数据库 for row in rows: dno, dname, dloc = [cell.value for cell in row] try: with conn.cursor() as cur: cur.execute( 'INSERT INTO tb_dept (dno, dname, dloc) VALUES (%s, %s, %s)', (dno, dname, dloc) ) conn.commit() except pymysql.MySQLError as e: print(f"Error: {e}") conn.rollback() # 关闭数据库连接 conn.close() ```