如何用quill动态查询批量插入?

3zwjbxry  于 2021-06-14  发布在  Cassandra
关注(0)|答案(1)|浏览(466)

我正在尝试使用quill动态查询来执行批插入
在非动态api中,我会使用:

db.run(quote {
liftQuery(myCollection).foreach(data => querySchema[MyDBClass]("table").insert(data))
})

对于动态查询,我也尝试过这样做:

db.run({
liftQuery(myCollection).foreach(data => dynamicQuerySchema[MyDBClass](tableNameVar).insertValue(data))
})

但我得到以下错误:
找不到参数unquote的隐式:dynamicinsert[mydbclass]=>a_
我是否正确使用了api?任何帮助都将不胜感激

hrirmatl

hrirmatl1#

解决方法是:

val dynamicSchema = context.dynamicQuerySchema[MyDBClass](tableNameVar)

context.transaction {
      myCollection.foreach { p =>
        context.run(dynamicSchema.insertValue(p))
      }
    }

Cassandra使用,无需交易

相关问题