This project adds support for Pekko streaming to kuzminki-ec. Take a look at the kuzminki-play-demo for an example of usage.
If you are using Akka, you can use version 0.9.3
// available for Scala 2.13 and Scala 3
libraryDependencies += "io.github.karimagnusson" %% "kuzminki-pekko" % "0.9.5"Query as Source.
import kuzminki.pekko.stream._
sql
.select(user)
.cols2(t => (
t.name,
t.email
))
.all
.orderBy(_.name.asc)
.stream
.map(doSmothing)
.runWith(mySink)
// By default the source will fetch 100 rows each time.
// To fetch a different number of rows: .stream(1000)
// To get a stream where the tuple is read into a type.
.streamType[MyType]Query as Sink.
import kuzminki.akka.stream._
val insertUserStm = sql
.insert(user)
.cols2(t => (
t.name,
t.email
))
.cache
Source(someData)
.map(doSmothing)
.runWith(insertUserStm.asSink)
// To insert in batches of 100
Source(someData)
.map(doSmothing)
.grouped(100) // insert 100 in each transaction.
.runWith(insertUserStm.asChunkSink)
// To create a sink that takes a type
insertUserStm.asTypeSink[MyType]