Function setDatabase

test/unit/persisters/common/databases.ts:544–578

(db: Database, dump: DumpIn)

  };

  const setDatabase = async (db: Database, dump: DumpIn) => {
    await cmd(db, 'BEGIN');
    await Promise.all(
      Object.entries(dump).map(async ([name, [sql, rows]]) => {
        await cmd(db, sql);
        await Promise.all(
          rows.map(async (row) => {
            Object.entries(row).forEach(([column, value], index) => {
              if (index == 0 || !jsonValues) {
                row[column] = value;
              } else {
                row[column] = JSON.stringify(value);
              }
            });
            await cmd(
              db,
              'INSERT INTO ' +
                escapeId(name) +
                '(' +
                Object.keys(row)
                  .map((cellId) => escapeId(cellId))
                  .join(',') +
                ') VALUES (' +
                Object.keys(row)
                  .map((_, index) => '$' + (index + 1))
                  .join(',') +
                ')',
              Object.values(row),
            );
          }),
        );
      }),
    );
    await cmd(db, 'END');
  };

  return [getDatabase, setDatabase];
};