【Pandas】pandas Series to_sql

Pandas2.2 Series

Serialization & IO & conversion

方法	描述
Series.to_pickle(path, *[, compression, …])	用于将 Series 对象序列化为二进制格式并保存到文件中
Series.to_csv([path_or_buf, sep, na_rep, …])	用于将 Series 对象以 CSV（逗号分隔值）格式保存到文件中
Series.to_dict(*[, into])	用于将 Series 对象转换为 Python 字典
Series.to_excel(excel_writer, *[, …])	用于将 Series 对象写入 Excel 文件
Series.to_frame([name])	用于将 Series 对象转换为 DataFrame
Series.to_xarray()	用于将 Series 对象转换为 xarray 的 DataArray 对象
Series.to_hdf(path_or_buf, *, key[, mode, …])	用于将 Series 数据保存为 HDF5 格式（一种高效存储大型科学数据的文件格式）
Series.to_sql(name, con, *[, schema, …])	用于将 Series 对象写入 SQL 数据库

pandas.Series.to_sql

pandas.Series.to_sql 方法用于将 Series 对象写入 SQL 数据库。该方法允许将 Series 数据存储在关系型数据库中，便于后续的数据查询和分析。

参数说明

• name：字符串，指定数据库中的表名。
• con：SQLAlchemy 引擎或数据库连接对象，用于连接到数据库。
• schema：可选，字符串，指定数据库中的模式（schema）。默认为 None。
• if_exists：可选，字符串，指定如何处理已存在的表。可选值包括 'fail'（如果表存在则失败）、'replace'（如果表存在则替换）、'append'（如果表存在则追加数据）。默认为 'fail'。
• index：可选，布尔值，指定是否将 Series 的索引写入数据库。默认为 True。
• index_label：可选，字符串或列表，指定索引列的名称。默认为 None。
• chunksize：可选，整数，指定每次写入的行数。默认为 None。
• dtype：可选，字典或 SQLAlchemy 类型，指定列的数据类型。默认为 None。
• method：可选，字符串或函数，指定数据写入方法。可选值包括 'multi'（使用多行插入）或自定义函数。默认为 None。

示例

首先，确保你已经安装了 sqlalchemy 和 pymysql（或其他数据库驱动）：

pip install sqlalchemy pymysql

然后，使用以下示例代码：

import pandas as pd
from sqlalchemy import create_engine

# 创建一个示例 Series
data = pd.Series([10, 20, 30, 40, 50], index=['A', 'B', 'C', 'D', 'E'], name='values')

# 创建 SQLAlchemy 引擎（这里使用 SQLite 作为示例）
engine = create_engine('sqlite:///example.db')

# 将 Series 写入 SQL 数据库
data.to_sql('series_table', con=engine, if_exists='replace', index=True, index_label='index')

# 从 SQL 数据库读取数据
loaded_data = pd.read_sql('series_table', con=engine)
print("Loaded Data:\n", loaded_data)

# 使用自定义索引标签
data.to_sql('series_table_with_label', con=engine, if_exists='replace', index=True, index_label='custom_index')

# 从 SQL 数据库读取数据
loaded_data_with_label = pd.read_sql('series_table_with_label', con=engine)
print("Loaded Data with Custom Index Label:\n", loaded_data_with_label)

# 使用 chunksize 写入数据
data.to_sql('series_table_chunked', con=engine, if_exists='replace', index=True, chunksize=2)

# 从 SQL 数据库读取数据
loaded_data_chunked = pd.read_sql('series_table_chunked', con=engine)
print("Loaded Chunked Data:\n", loaded_data_chunked)

结果

1. 将 Series 写入 SQL 数据库

   • 表名：series_table
   • 数据内容：

        index  values
     0      A      10
     1      B      20
     2      C      30
     3      D      40
     4      E      50
     

   • 索引列名：index
   • 处理方式：replace（如果表存在则替换）

2. 从 SQL 数据库读取数据

   • 表名：series_table
   • 加载的数据：

        index  values
     0      A      10
     1      B      20
     2      C      30
     3      D      40
     4      E      50
     

3. 使用自定义索引标签

   • 表名：series_table_with_label
   • 数据内容：

       custom_index  values
     0            A      10
     1            B      20
     2            C      30
     3            D      40
     4            E      50
     

   • 索引列名：custom_index
   • 处理方式：replace（如果表存在则替换）

4. 从 SQL 数据库读取数据

   • 表名：series_table_with_label
   • 加载的数据：

       custom_index  values
     0            A      10
     1            B      20
     2            C      30
     3            D      40
     4            E      50
     

5. 使用 chunksize 写入数据

   • 表名：series_table_chunked
   • 数据内容：

        index  values
     0      A      10
     1      B      20
     2      C      30
     3      D      40
     4      E      50
     

   • 索引列名：index
   • 处理方式：replace（如果表存在则替换）
   • 每次写入行数：2

6. 从 SQL 数据库读取数据

   • 表名：series_table_chunked
   • 加载的数据：

        index  values
     0      A      10
     1      B      20
     2      C      30
     3      D      40
     4      E      50
     

通过这些示例，可以看到 pandas.Series.to_sql 方法如何将 Series 对象写入 SQL 数据库，并支持不同的处理方式、索引标签和分块写入。读取时可以使用 pd.read_sql 方法恢复数据。