def journalRowByPersistenceIds()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/ReadJournalQueries.scala [28:32]

• 5 lines of code
• 3 McCabe index (conditional complexity)

  def journalRowByPersistenceIds(persistenceIds: Iterable[String]) =
    for {
      query <- JournalTable.map(_.persistenceId)
      if query.inSetBind(persistenceIds)
    } yield query