How to batch insert with quill dynamic queries?

Question

I'm trying to use Quill dynamic queries to perform batch insert

In non-dynamic api I would've used:

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

I've tried doing the same for dynamic query:

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

But I get the following error:

No implicits found for parameter unquote: DynamicInsert[MyDBClass] => A_

Am I using the API correctly? any help would be appreciated

score 1 · Accepted Answer · answered Sep 01 '19 at 18:29

1

The work-around is:

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

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

For cassandra use without transaction

answered Sep 01 '19 at 18:29

Andrzej Jozwik

14,331
3
59
68

Thank you, much appreciated – mich8bsp Sep 02 '19 at 20:36
For cassandra its really doing batching ? seems like it just inserting it one by one – oron Oct 16 '19 at 08:21
Cassandra does not support transactions. `context.transaction` is ignored. – Andrzej Jozwik Oct 16 '19 at 08:53
@AndrzejJozwik Do you know how to do this with Cassandra? Or is it just not possible? – Noah Apr 15 '20 at 14:11
@Noah Try without `context.transaction` – Andrzej Jozwik Apr 16 '20 at 08:48

How to batch insert with quill dynamic queries?

1 Answers1