Doobie中模糊隐式解析错误排查求助

核心问题1：函数返回类型不匹配 #

你的函数声明返回Fragment，但实际代码中update.withUniqueGeneratedKeys返回的是ConnectionIO[Int]，后续的flatMap、traverse_操作都是基于ConnectionIO类型，和Fragment完全不兼容。这种类型混乱会导致编译器在查找隐式实例时出现歧义。

核心问题2：隐式实例歧义 #

当编译器为traverse_查找Applicative[G]实例时，doobie的Instances特质中存在多个WeakAsync实例（对应BlobIO、CallableStatementIO等不同IO类型），这些实例都能向上兼容为Applicative，导致编译器无法确定使用哪一个。修正返回类型后，编译器能明确推导需要的是ConnectionIO的Applicative实例，歧义会自动消除。

修复步骤 #

1. 修正函数返回类型：将返回类型从Fragment改为ConnectionIO[Unit]（整个插入操作无返回值，可根据需求调整）。
2. 修复SQL语法错误：
   • 移除INSERT语句列和VALUES列表末尾的多余逗号，避免SQL语法错误。
   • 补充缺失的参数：比如第一个INSERT中id列若为自增则可从列列表移除，第二个INSERT中补充createdAt、updatedAt的对应参数。
3. 修正逻辑错误：当前代码中所有TableB都会插入相同的TableC数据，应从当前遍历的TableB实例中获取对应的TableC列表，而非从顶层的cs对象获取。

修复后的代码示例 #

import doobie.ConnectionIO
import doobie.implicits._
import cats.implicits._

def insertRelations(cs: TableA): ConnectionIO[Unit] = {
  sql"""INSERT INTO my_schema.table_a (
          name,
          dataType,
          longName,
          externalNumber
        ) VALUES (
          ${cs.name},
          ${cs.dataType},
          ${cs.longName},
          ${cs.externalNumber}
        )"""
    .update.withUniqueGeneratedKeys[Int]("id")
    .flatMap { tableAId =>
      cs.tableBSeqs.traverse_ { bElem =>
        sql"""INSERT INTO table_b (
                tableAId,
                externalName,
                readValue,
                isFormatted,
                meanValue,
                createdAt,
                updatedAt
              ) VALUES (
                $tableAId,
                ${bElem.externalName},
                ${bElem.readValue},
                ${bElem.isFormatted},
                ${bElem.meanValue},
                CURRENT_TIMESTAMP,
                CURRENT_TIMESTAMP
              )"""
          .update.withUniqueGeneratedKeys[Long]("id")
          .flatMap { tableBId =>
            bElem.tableCSeqs.traverse_ { cElem =>
              sql"""INSERT INTO table_c (
                      tableBId,
                      col1,
                      col2
                    ) VALUES (
                      $tableBId,
                      ${cElem.col1},
                      ${cElem.col2}
                    )"""
                .update.run
            }
          }
      }
    }
}

额外说明 #

• 确保TableA、TableB、TableC的字段与SQL列一一对应。
• CURRENT_TIMESTAMP为SQL标准时间函数，若使用特定数据库（如MySQL、PostgreSQL），可替换为对应数据库的时间函数（如NOW()）。

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