如何获取MySqlConnector库MySqlBulkCopy批量加载错误的详细信息

一、无需修改源码的临时排查方法 #

• 开启MySQL严格SQL模式：在执行批量写入操作前，先在同一会话执行SET sql_mode = 'STRICT_TRANS_TABLES,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';，该配置会将原本只会触发警告的非法写入操作直接转为错误抛出，你可以直接拿到错误详情。
• 同会话查询警告：批量写入操作执行失败后，不要关闭或归还连接到连接池，立即在同一个连接上执行SHOW WARNINGS;命令，查询结果会直接返回30条警告的完整内容，包含错误码和具体原因。
• 调整连接字符串配置：在连接字符串中添加WarningsAsErrors=True参数，MySqlConnector会自动将所有操作产生的警告转为异常抛出，直接暴露问题原因。

二、修改MySqlConnector源码永久暴露警告的方案 #

• 暴露警告计数：找到MySqlBulkCopy对应的执行结果类，新增公开的WarningCount属性，在批量操作处理返回的ResultSet对象时，将你调试时看到的WarningCount字段值赋值给该属性，对外暴露。
• 新增警告详情获取接口：在MySqlBulkCopy类中新增公开方法GetWarnings()，方法逻辑为在当前批量操作使用的会话连接上执行SHOW WARNINGS查询，将返回的Level、Code、Message三个字段封装为警告对象列表返回，注意要在批量操作执行完成后、连接归还到连接池前调用该逻辑才能拿到正确结果。
• 可选：在MySqlBulkCopy的异常逻辑中加入警告内容拼接，当写入行数为0时，自动查询警告并附加到异常消息中，后续调用时无需额外操作就能直接看到问题原因。

三、常见故障定位方向 #

拿到警告内容后你可以对照以下常见问题排查：

• 字段映射不匹配：检查MySqlBulkCopy的列映射配置是否和第二张表的字段顺序、字段类型完全匹配，是否存在字段名拼写错误、类型不兼容的情况。
• 数据合法性问题：检查写入数据是否违反表约束，比如非空字段传空、数值超出字段长度限制、字符串超出字符长度、唯一索引冲突、外键关联值不存在等。
• 表配置问题：检查第二张表的字符集、存储引擎配置是否和写入数据兼容，是否存在触发器、行级安全规则拦截了写入操作。

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