如何让MariaDB.Error始终返回executemany插入时的错误行/列信息？

默认情况下，MariaDB的executemany()在处理批量INSERT时，外键约束错误不会自动返回具体的行号和列信息——这是因为批量操作是把所有数据打包发送到数据库，数据库抛出约束错误时，不会逐个追踪到具体的出错行，自然驱动也没法从mariadb.Error中拿到这些细节（和数据类型错误不同，类型错误是驱动在预处理数据时就能检测到，所以能直接定位行/列）。

没有直接配置mariadb.Error让它自动补充行/列信息的办法，不过可以通过两种业务层方案实现需求：

• 逐行执行并捕获错误：放弃executemany()，改用循环逐个调用execute()，每次执行时记录当前行号，遇到外键错误时手动拼接行号和目标列信息。示例代码：

  import mariadb
  
  # 假设已建立数据库连接和cursor
  rows_to_insert = [(1, "a", 100), (2, "b", 999), (3, "c", 200)]  # 其中999为无效外键值
  fk_column_name = "parent_id"  # 你的外键列名
  
  for row_idx, row_data in enumerate(rows_to_insert, start=1):
      try:
          cursor.execute(
              "INSERT INTO your_table (col1, col2, parent_id) VALUES (%s, %s, %s)",
              row_data
          )
      except mariadb.Error as e:
          err_msg = str(e)
          if "foreign key constraint fails" in err_msg:
              detailed_err = f"{err_msg} at row {row_idx}, column '{fk_column_name}'"
              print(detailed_err)
          else:
              print(err_msg)
  

  缺点是批量插入的效率会降低，适合数据量不大的场景。

• 插入前预检查外键合法性：先从父表获取所有有效的外键值，再遍历待插入数据，提前筛选出外键无效的行并标记。示例代码：

  # 先获取所有合法的外键值
  cursor.execute("SELECT id FROM parent_table")
  valid_fk_ids = {row[0] for row in cursor.fetchall()}
  
  rows_to_insert = [(1, "a", 100), (2, "b", 999), (3, "c", 200)]
  fk_column_idx = 2  # 外键在row_data中的索引（从0开始计数）
  fk_column_name = "parent_id"
  
  # 提前检查并收集错误信息
  error_rows = []
  for row_idx, row_data in enumerate(rows_to_insert, start=1):
      current_fk = row_data[fk_column_idx]
      if current_fk not in valid_fk_ids:
          error_rows.append(
              f"Cannot add or update a child row: a foreign key constraint fails at row {row_idx}, column '{fk_column_name}' (invalid value: {current_fk})"
          )
  
  if error_rows:
      print("\n".join(error_rows))
  else:
      # 预检查通过后执行批量插入
      try:
          cursor.executemany(
              "INSERT INTO your_table (col1, col2, parent_id) VALUES (%s, %s, %s)",
              rows_to_insert
          )
      except mariadb.Error as e:
          print(str(e))
  

  这种方式保留了executemany()的执行效率，同时能提前定位错误行，适合数据量较大的场景。

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