在 Jupyter Notebook 中将数据导入到 MySQL 数据库是一个常见的任务，通常分为几个关键步骤：准备数据、建立数据库连接、创建表结构以及插入数据。下面是详细的介绍和代码示例。 --- ### 步骤1：准备工作 确保已经在系统中安装好以下工具： - **Python环境** 已经包含 `pandas` 和 `mysql-connector-python`。 - **MySQL服务** 已开启并且可以正常访问。 如果未安装必要依赖项，请先通过 pip 安装它们： ```bash pip install pandas mysql-connector-python ``` --- ### 步骤2：构建连接并设计流程 #### 示例场景 假设我们有一个 Pandas DataFrame 对象，并希望将其存储到 MySQL 表格中。 #### 具体实现代码 以下是在 Jupyter Notebook 内部的数据导出过程： ```python # 导入所需的库 import mysql.connector from mysql.connector import Error import pandas as pd # 准备测试数据 data = { "id": [1, 2, 3], "name": ["Alice", "Bob", "Charlie"], "age": [25, 30, 35] } df = pd.DataFrame(data) print("原始DataFrame:") display(df) def connect_to_mysql(host_name, user_name, user_password): """用于连接至 MySQL""" connection = None try: connection = mysql.connector.connect( host=host_name, user=user_name, passwd=user_password ) print("成功连接到 MySQL") except Error as e: print(f"错误: {e}") return connection def create_database(connection, db_name): cursor = connection.cursor() try: drop_query = f'DROP DATABASE IF EXISTS `{db_name}`;' create_query = f'CREATE DATABASE `{db_name}` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;' cursor.execute(drop_query) # 删除已有同名DB避免冲突 cursor.execute(create_query) print(f"\n数据库 '{db_name}' 成功创建.") except Error as e: print(f"错误: {e}") def insert_data_into_table(conn, df, table_name='mytable'): """ 插入Pandas Dataframe 到指定的MYSQL表格里. 若表格不存在，则自动新建相应表格结构； 存在的话直接追加新记录进去。 """ from sqlalchemy import create_engine engine_str = ( f'mysql+mysqlconnector://{conn.user}:' f'{conn.password}@{conn.server_host}/{table_name}' ) sqlEngine = create_engine(engine_str) dbConnection = sqlEngine.connect() try: frame = df.to_sql(table_name, con=dbConnection, index=False, if_exists='replace'); print("\n数据已成功存入表:", table_name) except ValueError as vx: print(vx) finally: dbConnection.close() if __name__ == '__main__': conn = connect_to_mysql('localhost', 'root', 'yourpassword') # 创建新的数据库（可以根据需求选择是否保留） create_database(conn, 'test_import') # 设置为刚刚创建的新 DB new_conn = mysql.connector.connect( host="localhost", database="test_import", user="root", password="yourpassword" ) # 执行数据导入操作 insert_data_into_table(new_conn, df=df, table_name='people') ``` > 注释部分需替换为您的真实配置信息！ --- ### 输出解释 按照以上脚本执行完成后，控制台会显示如下提示消息： 1. 显示“成功连接到 MySQL”表示客户端顺利连上了服务器端的服务进程。 2. “数据库 test_import 成功创建.”意味着一个新的空白数据库已被构造出来供后续加载内容之用。 3. 最后一句输出：“数据已成功存入表...”，证明整个 ETL 流程顺利完成。 现在可以在 MySQL Workbench 或者其他管理界面查询得到的结果集了! --- ###