Handle duplicate records

Animechan-API · Dec 25, 2024 · d1193cb · d1193cb
1 parent b675fd3
commit d1193cb
Showing 1 changed file with 22 additions and 13 deletions.
diff --git a/server/scripts/populate-altname.ts b/server/scripts/populate-altname.ts
@@ -1,3 +1,4 @@
+import { PrismaClientKnownRequestError } from "@prisma/client/runtime/library";
 import type { Options } from "csv-parse";
 import { parse } from "csv-parse";
 import fs from "node:fs";
@@ -18,19 +19,27 @@ fs.createReadStream(filePath)
 	.on("data", async (row) => {
 		if (!row.malId || row.malId === "") return;
 
-		const updatedRecord = await prisma.anime.update({
-			where: {
-				id: Number.parseInt(row.id),
-			},
-			data: {
-				name: row.name,
-				altName: row.altName,
-				malId: Number.parseInt(row.malId),
-				episodeCount: Number.parseInt(row.episodeCount),
-			},
-		});
-		if (updatedRecord) {
-			console.log(`Updated ${updatedRecord.id}`);
+		try {
+			const updatedRecord = await prisma.anime.update({
+				where: {
+					id: Number.parseInt(row.id),
+				},
+				data: {
+					name: row.name,
+					altName: row.altName,
+					malId: Number.parseInt(row.malId),
+					episodeCount: Number.parseInt(row.episodeCount),
+				},
+			});
+			if (updatedRecord) {
+				console.log(`Updated ${updatedRecord.id}`);
+			}
+		} catch (error) {
+			if (error instanceof PrismaClientKnownRequestError) {
+				if (error.code === "P2002") {
+					console.log("Duplicate Record: ", row.id);
+				}
+			}
 		}
 	})
 	.on("error", (err) => {