private def writeJournalRowsStatements()

in migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigrator.scala [144:153]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  private def writeJournalRowsStatements(
      journalSerializedRow: JournalPekkoSerializationRow,
      tags: Set[String]): DBIO[Unit] = {
    for {
      id <- newJournalQueries.JournalTable
        .returning(newJournalQueries.JournalTable.map(_.ordering)) += journalSerializedRow
      tagInserts = tags.map(tag => TagRow(id, tag))
      _ <- newJournalQueries.TagTable ++= tagInserts
    } yield ()
  }