private def writeJournalRowsStatements()

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

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

  private def writeJournalRowsStatements(
      journalSerializedRow: JournalPekkoSerializationRow,
      tags: Set[String]): DBIO[Unit] = {
    val journalInsert: DBIO[Long] = newJournalQueries.JournalTable
      .returning(newJournalQueries.JournalTable.map(_.ordering))
      .forceInsert(journalSerializedRow)

    val tagInserts =
      newJournalQueries.TagTable ++= tags.map(tag => TagRow(journalSerializedRow.ordering, tag)).toSeq

    journalInsert.flatMap(_ => tagInserts.asInstanceOf[DBIO[Unit]])
  }