Cursor Based Streaming with Kotlin Sequence

cursor_based_streaming.kt

dataSource.connection.use { connection ->
  connection.prepareStatement(sql, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY).use { statement ->
    statement.fetchSize = fetchSize
    statement.queryTimeout = queryTimeoutSeconds
    statement.executeQuery().use { resultSet ->
      val rows = generateSequence {
        if (resultSet.next()) mapRow(resultSet) else null
      }
      consumer(rows)
    }
  }
}