Python向MySQL插入DataFrame报错：Python 'series'无法转MySQL类型

我一眼就揪出问题根源啦——你在循环里取数据的方式不对，拿到的是单个元素的Pandas Series对象，而不是MySQL驱动能识别的标量值（比如字符串、整数、datetime），这就是报错的核心原因。

问题代码的具体问题 #

先看你循环里的这段代码：

for a, b in result.iterrows():
    e_point = result['id'][[a]]
    t = result['type'][[a]]
    num = result['count'][[a]]
    first = result['first'][[a]]
    last = result['last'][[a]]

result['id'][[a]]这种写法返回的是一个Series（哪怕只有一个元素），不是单个值。而且你后续还犯了变量名错误：values = (id, type, count, first, last)里的id、type是Python内置名称，根本不是你定义的e_point、t变量，这也会导致逻辑混乱。

另外，你在循环里每次都创建数据库连接，这不仅效率极低，还可能引发连接泄露问题。

修复方案一：修正循环内的数据取值与连接逻辑 #

把数据库连接放在循环外，直接用iterrows返回的row（每一行的Series）来取单个标量值：

import mysql.connector

# 仅建立一次数据库连接，不要放在循环里
try:
    cnx_insert = mysql.connector.connect(
        user='abc', 
        password='abc', 
        host='blah', 
        port='3306', 
        database='some_database'
    )
    cursor_insert = cnx_insert.cursor()
except Exception as conn_err:
    print(f"数据库连接失败: {conn_err}")
    exit()

# 提前定义插入语句，避免重复创建
insert_query = ("INSERT INTO some_table "
                "(id, message_status, read_intervals, first_reading_time, last_reading_time) "
                "VALUES(%s, %s, %s, %s, %s)")

for idx, row in result.iterrows():
    # 直接从row中提取单个标量值，而非Series
    item_id = row['id']
    msg_type = row['type']
    count_num = row['count']
    first_time = row['first']
    last_time = row['last']
    
    try:
        values = (item_id, msg_type, count_num, first_time, last_time)
        cursor_insert.execute(insert_query, values)
        cnx_insert.commit()
    except Exception as e:
        print(f"插入id {item_id} 失败: {e}")
        cnx_insert.rollback()  # 出错时回滚，避免脏数据

# 循环结束后统一关闭连接
cursor_insert.close()
cnx_insert.close()

修复方案二：用to_sql批量插入（更高效） #

如果你的数据量不小，强烈推荐用Pandas内置的to_sql方法，不用自己写循环，效率提升不止一个档次：

from sqlalchemy import create_engine

# 创建SQLAlchemy引擎，格式为：数据库类型+驱动://用户名:密码@主机:端口/数据库名
engine = create_engine('mysql+mysqlconnector://abc:abc@blah:3306/some_database')

try:
    result.to_sql(
        name='some_table',
        con=engine,
        if_exists='append',  # 表存在时追加数据，可选replace（覆盖）/fail（报错）
        index=False,  # 不要把DataFrame的索引插入数据库
        columns=['id', 'type', 'count', 'first', 'last'],  # 指定要插入的列，对应数据库字段
        dtype={
            'id': engine.types.VARCHAR(length=20),
            'type': engine.types.VARCHAR(length=20),
            'count': engine.types.INTEGER(),
            'first': engine.types.DATETIME(),
            'last': engine.types.DATETIME()
        }
    )
    print("数据批量插入成功")
except Exception as e:
    print(f"批量插入失败: {e}")

注意：需要先安装依赖包，执行pip install sqlalchemy mysql-connector-python即可。

为什么之前转列表/元组没用？ #

你之前尝试转列表、元组，但因为取的是result['id'][[a]]这种Series，转成列表后是['ABC123']这样的结构，仍然不是单个标量值，MySQL驱动自然无法识别。而用row['id']直接拿到的是单个字符串/数值，就能正常被转换为MySQL支持的类型。

内容的提问来源于stack exchange，提问作者pol_guy