cassandra - 如何使用 quill 动态查询批量插入?
问题描述
我正在尝试使用 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?任何帮助,将不胜感激
解决方案
解决方法是:
val dynamicSchema = context.dynamicQuerySchema[MyDBClass](tableNameVar)
context.transaction {
myCollection.foreach { p =>
context.run(dynamicSchema.insertValue(p))
}
}
对于没有事务的 cassandra 使用
推荐阅读
- javascript - jQuery DataTables - 调用多个插件?(日期范围/范围搜索)
- python - 马修特征值
- prisma - Prisma - 如何使用多个模型中的字段定义复合唯一约束?
- java - springdoc-openapi、swagger UI 中的 XML 示例
- sql - SQL 查找多个条件的最后一个值
- r - 添加时间间隔的无暴露时段(间隙)的行
- c++ - 调用 movetothread() 后如何停止 Qthread?
- javascript - 一个组件的导出功能并在另一个组件中使用
- javascript - Angular:由于不允许的 MIME 类型(“text/html”),浏览器有时无法加载 es2015 文件
- powershell - 如何使用带有通配符的 Powershell 运行 EXE 来查找文件?