如何使用doobie连接蜂巢

Question

有一个用于hive的jdbc驱动程序，但似乎没有完全正常工作。我使用默认的doobie Transactor连接到它，如下所示

val xa = Transactor.fromDriverManager[IO](
  "org.apache.hive.jdbc.HiveDriver", url, username, pass
)

myQuery.transact(xa).unsafeRunSync

我收到一条错误消息

线程"main“中的错误异常:不支持org.apache.hive.jdbc.HiveConnection.rollback(HiveConnection.java:1327)错误的方法doobie.free.KleisliInterpreter$ConnectionInterpreter$$anonfun$rollback$1.apply(kleisliinterpreter.scala:643)错误在doobie.free.KleisliInterpreter$$anonfun$primitive$1$$anonfun$apply$1.apply(kleisliinterpreter.scala:99)的doobie.free.KleisliInterpreter$ConnectionInterpreter$$anonfun$rollback$1.apply(kleisliinterpreter.scala:643)错误

如何使用Doobie连接蜂巢？

Answer 1

您需要通过一个新的策略来禁用Transactor中的"after“和"oops”。以下是如何

    import doobie.free.connection.unit
    import doobie.util.transactor.Strategy

    val hiveStrategy = Strategy.default.copy(
                        after = unit, oops = unit)

    val xa = Transactor.strategy.set(
               Transactor.fromDriverManager[IO](
                 "org.apache.hive.jdbc.HiveDriver", url, username, pass), 
               hiveStrategy)

    myQuery.transact(xa).unsafeRunSync