[V5] Close Database in foreach

[AGDholo]

I'm working with big data in a command line program by updateOrCreateMany.

But Postgres itself doesn't support more than 34464 parameters for a bound statement.

So I need to chunk it and insert DB.

Here is my code:

import Database from '@ioc:Adonis/Lucid/Database';
import Game from 'App/Models/Game';
import { chunk, forEach } from "lodash";

    const chunkApps = chunk(apps, 10)
    forEach(chunkApps, async (value: any[], key: number) => {
      await Game.updateOrCreateMany('appid', value)
      await Database.manager.closeAll() // line 32
    })

But the console throw some errors:

 at \commands\SpiderGames.ts:32:7
(node:16624) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). To terminate the node process on unhandled promise rejection, use the CLI flag `--unhandled-rejections=strict` (see https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode). (rejection id: 30917)
(node:16624) UnhandledPromiseRejectionWarning: Error: aborted
    at PendingOperation.abort (\node_modules\tarn\dist\PendingOperation.js:25:21)
    at i\node_modules\tarn\dist\Pool.js:203:25
    at Array.map (<anonymous>)
    at \node_modules\tarn\dist\Pool.js:202:53
    at processTicksAndRejections (internal/process/task_queues.js:93:5)
    at Connection.disconnect (\node_modules\@adonisjs\lucid\build\src\Connection\index.js:297:17)
    at ConnectionManager.close (\node_modules\@adonisjs\lucid\build\src\Connection\Manager.js:186:13)
    at async Promise.all (index 2)
    at ConnectionManager.closeAll (\node_modules\@adonisjs\lucid\build\src\Connection\Manager.js:197:9)

AND:

(node:16624) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). To terminate the node process on unhandled promise rejection, use the CLI flag `--unhandled-rejections=strict` (see https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode). (rejection id: 30918)
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit
(node:16624) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 end listeners added to [Connection]. Use emitter.setMaxListeners() to increase limit

[AGDholo]

I looked up the principle of foreach and used for in instead, and now the problem is solved.

There is my code:

    const chunkApps: any[] = chunk(apps, 1000)
    for (const iterator of chunkApps) {
      await Game.updateOrCreateMany('appid', iterator)
    }

    await Database.manager.closeAll()