Python连接MySQL插入maskedarray无法转换为MySQL类型如何解决

报错的核心是你从netCDF文件中读取的rainc变量是numpy MaskedArray（掩码数组）类型，MySQL连接器没有内置这种复杂数组类型的转换规则，无法直接写入数据库。

你需要根据业务需求，把MaskedArray转换成MySQL支持的类型，常见处理方式如下：

• 存储整个二维数组所有值：先将MaskedArray转成普通numpy数组，再序列化为JSON字符串存入，修改代码如下：

import json

# 把MaskedArray转为普通numpy数组，掩码位置默认填充为nan
rainc_arr = rainc.filled(np.nan)
# 序列化为JSON字符串
rainc_str = json.dumps(rainc_arr.tolist())

# 替换data中的rainc
data = ("01", "2021030100", rainc_str)

注意：对应MySQL表gis的var1字段需要设为JSON或TEXT类型。

• 仅存储数组统计值（如最大值、平均值、总和）：直接调用对应方法转成数值即可，示例：

# 计算数组总和，自动忽略掩码位置的无效值
rainc_sum = rainc.sum()
data = ("01", "2021030100", rainc_sum)

对应var1字段设为FLOAT或DOUBLE类型即可。

• 将二维数组每个格点单独存储为一行：遍历数组的经纬度维度逐行插入，示例逻辑：

sql = "INSERT INTO gis (id, name, lon_idx, lat_idx, var1) VALUES (%s, %s, %s, %s, %s)"
# 遍历二维数组的两个维度
for lat_i in range(rainc.shape[0]):
    for lon_i in range(rainc.shape[1]):
        # 跳过掩码位置的无效值
        if not rainc.mask[lat_i, lon_i]:
            val = rainc[lat_i, lon_i].item()
            dbcursor.execute(sql, (f"01_{lat_i}_{lon_i}", "2021030100", lon_i, lat_i, val))
con.commit()

• 代码中导入了pyodbc但实际使用的是mysql.connector，没用的依赖可以删除避免冗余。
• 插入操作完成后记得调用con.close()关闭数据库连接，避免连接泄露。

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