W jaki sposób strumienie reaktywne są używane w Slick do wstawiania danych?

Wstawki szeregowe

Najprostszym sposobem byłoby zrobienie wstawek w Sink.foreach .

Zakładając, że użyłeś generowanie kodu schematu i dalej zakładając, że twoja tabela nosi nazwę „NumberTable”

//Tables file was auto-generated by the schema code generation
import Tables.{Numbertable, NumbertableRow} 

val numberTableDB = Database forConfig "NumberTableConfig"

Możemy napisać funkcję, która wykonuje wstawianie

def insertIntoDb(num : Int) = 
  numberTableDB run (Numbertable += NumbertableRow(num))

I tę funkcję można umieścić w zlewie

val insertSink = Sink[Int] foreach insertIntoDb

Source(0 to 100) runWith insertSink

Wstawki w grupach

Możesz jeszcze bardziej rozszerzyć metodologię Sink, grupując N wstawek naraz:

def batchInsertIntoDb(nums : Seq[Int]) = 
  numberTableDB run (Numbertable ++= nums.map(NumbertableRow.apply))

val batchInsertSink = Sink[Seq[Int]] foreach batchInsertIntoDb

Ten zlew wsadowy może być zasilany przez Flow co robi grupowanie wsadowe:

val batchSize = 10

Source(0 to 100).via(Flow[Int].grouped(batchSize))
                .runWith(batchInsertSink)