Adding records to my Movie table

add-records.swift

// I have one table: Movie. To add records, after the Movie migration I’m doing:
let worker = MultiThreadedEventLoopGroup(numberOfThreads: 1)
let conn = sqliteDatabase.newConnection(on: worker)
let _ = conn.map { connection in
  // Open the CSV file
  for line in lines {
    // Parse the line to get the title, etc.
    let movie = Movie(id: id, title: title)
    dispatchGroup.enter()
    let future = movie.save(on: connection)
    future.whenFailure { (error) in
        dispatchGroup.leave()
    }
    future.whenSuccess { _ in
        dispatchGroup.leave()
    }
    // ...etc.
  }
  
  dispatchGroup.notify(queue: .global()) {
    worker.shutdownGracefully { error in
      // etc.
    }
  }
}

To figure out when migrations are finished, I’m doing:

extension Movie: Migration {
    static func prepare(on connection: SQLiteConnection) -> EventLoopFuture<Void> {
        let future = Database.create(Movie.self, on: connection) { creator in
            creator.field(for: \.id, isIdentifier: true)
            creator.field(for: \.title)
            creator.field(for: \.format)
            creator.field(for: \.posterURLString)
        }
        future.whenComplete {
            MovieDatabase.shared.populateFromCSV()
        }
        return future
    }
}