Seed table from csv file with Prisma.

seed.ts

import { clinics, PrismaClient } from "@prisma/client";
import * as fs from "fs";
import * as path from "path";
import * as csv from "fast-csv";

const prisma = new PrismaClient();

type ClinicsCsvRow = Omit<clinics, "date_created" | "date_updated">;

async function main() {
  fs.createReadStream(path.resolve(__dirname, "data-clinics_fixed.csv"))
    .pipe(csv.parse({ headers: true }))
    // pipe the parsed input into a csv formatter
    .pipe(csv.format<ClinicsCsvRow, ClinicsCsvRow>({ headers: true }))
    // Using the transform function from the formatting stream
    .transform(async (row, next) => {
      // If clinic data exist update it, otherwise create it
      const res = await prisma.clinics.upsert({
        where: { crm_id: row.crm_id },
        update: {
          ...row,
        },
        create: {
          ...row,
        },
      });

      return next(null, res);
    })
    .pipe(process.stdout)
    .on("end", () => {
      process.exit();
    });
}

main()
  .then(async () => {
    await prisma.$disconnect();
  })
  .catch(async (e) => {
    console.error(e);
    await prisma.$disconnect();
    process.exit(1);
  });