feat(csv-to-pg): add conflictDoNothing option for ON CONFLICT DO NOTHING

packages/csv-to-pg/__tests__/csv2pg.test.ts

@@ -15,6 +15,78 @@ const testCase = resolve(__dirname + '/../__fixtures__/test-case.csv');
 it('noop', () => {
   expect(true).toBe(true);
 });
+
+describe('conflictDoNothing', () => {
+  it('InsertOne with conflictDoNothing generates ON CONFLICT DO NOTHING AST', () => {
+    const config = {
+      schema: 'my-schema',
+      table: 'my-table',
+      fields: {
+        name: 'text'
+      }
+    };
+    const types = parseTypes(config);
+    const stmt = InsertOne({
+      schema: config.schema,
+      table: config.table,
+      types,
+      record: { name: 'test' },
+      conflictDoNothing: true
+    });
+
+    // Verify the AST contains the ON CONFLICT DO NOTHING clause
+    expect(stmt.RawStmt.stmt.InsertStmt.onConflictClause).toEqual({
+      action: 'ONCONFLICT_NOTHING'
+    });
+  });
+
+  it('InsertMany with conflictDoNothing generates ON CONFLICT DO NOTHING AST', () => {
+    const config = {
+      schema: 'my-schema',
+      table: 'my-table',
+      fields: {
+        name: 'text'
+      }
+    };
+    const types = parseTypes(config);
+    const stmt = InsertMany({
+      schema: config.schema,
+      table: config.table,
+      types,
+      records: [
+        { name: 'test1' },
+        { name: 'test2' }
+      ],
+      conflictDoNothing: true
+    });
+
+    // Verify the AST contains the ON CONFLICT DO NOTHING clause
+    expect(stmt.RawStmt.stmt.InsertStmt.onConflictClause).toEqual({
+      action: 'ONCONFLICT_NOTHING'
+    });
+  });
+
+  it('InsertOne without conflictDoNothing has no conflict clause', () => {
+    const config = {
+      schema: 'my-schema',
+      table: 'my-table',
+      fields: {
+        name: 'text'
+      }
+    };
+    const types = parseTypes(config);
+    const stmt = InsertOne({
+      schema: config.schema,
+      table: config.table,
+      types,
+      record: { name: 'test' }
+    });
+
+    // Verify no conflict clause when conflictDoNothing is not set
+    expect(stmt.RawStmt.stmt.InsertStmt.onConflictClause).toBeUndefined();
+  });
+});
+
 xdescribe('Insert Many', () => {
   it('Insert Many', async () => {
     const config = {

packages/csv-to-pg/src/parser.ts

@@ -8,6 +8,7 @@ interface ParserConfig {
   table: string;
   singleStmts?: boolean;
   conflict?: string[];
+  conflictDoNothing?: boolean;
   headers?: string[];
   delimeter?: string;
   json?: boolean;
@@ -30,7 +31,7 @@ export class Parser {
 
   async parse(data?: Record<string, unknown>[]): Promise<string | void> {
     const config = this.config;
-    const { schema, table, singleStmts, conflict, headers, delimeter } = config;
+    const { schema, table, singleStmts, conflict, conflictDoNothing, headers, delimeter } = config;
 
     const opts: CsvOptions = {};
     if (headers) opts.headers = headers;
@@ -67,7 +68,8 @@ export class Parser {
           table,
           types,
           record,
-          conflict
+          conflict,
+          conflictDoNothing
         })
       );
       return deparse(stmts);
@@ -77,7 +79,8 @@ export class Parser {
         table,
         types,
         records,
-        conflict
+        conflict,
+        conflictDoNothing
       });
       return deparse([stmt]);
     }

packages/csv-to-pg/src/utils.ts

@@ -130,7 +130,18 @@ const indexElem = (name: string): Node => ({
 
 import type { OnConflictClause } from '@pgsql/types';
 
-const makeConflictClause = (conflictElems: string[] | undefined, fields: string[]): OnConflictClause | undefined => {
+const makeConflictClause = (
+  conflictElems: string[] | undefined,
+  fields: string[],
+  conflictDoNothing?: boolean
+): OnConflictClause | undefined => {
+  // If conflictDoNothing is true, generate ON CONFLICT DO NOTHING without specifying columns
+  // This catches any unique constraint violation
+  if (conflictDoNothing) {
+    return {
+      action: 'ONCONFLICT_NOTHING'
+    };
+  }
   if (!conflictElems || !conflictElems.length) return undefined;
   const setElems = fields.filter((el) => !conflictElems.includes(el));
   if (setElems.length) {
@@ -157,14 +168,16 @@ interface InsertOneParams {
   types: TypesMap;
   record: Record<string, unknown>;
   conflict?: string[];
+  conflictDoNothing?: boolean;
 }
 
 export const InsertOne = ({
   schema = 'public',
   table,
   types,
   record,
-  conflict
+  conflict,
+  conflictDoNothing
 }: InsertOneParams): Node => ({
   RawStmt: {
     stmt: {
@@ -189,7 +202,7 @@ export const InsertOne = ({
             limitOption: 'LIMIT_OPTION_DEFAULT'
           }
         },
-        onConflictClause: makeConflictClause(conflict, Object.keys(types)),
+        onConflictClause: makeConflictClause(conflict, Object.keys(types), conflictDoNothing),
         override: 'OVERRIDING_NOT_SET'
       }
     },
@@ -203,14 +216,16 @@ interface InsertManyParams {
   types: TypesMap;
   records: Record<string, unknown>[];
   conflict?: string[];
+  conflictDoNothing?: boolean;
 }
 
 export const InsertMany = ({
   schema = 'public',
   table,
   types,
   records,
-  conflict
+  conflict,
+  conflictDoNothing
 }: InsertManyParams): Node => ({
   RawStmt: {
     stmt: {
@@ -233,7 +248,7 @@ export const InsertMany = ({
             limitOption: 'LIMIT_OPTION_DEFAULT'
           }
         },
-        onConflictClause: makeConflictClause(conflict, Object.keys(types)),
+        onConflictClause: makeConflictClause(conflict, Object.keys(types), conflictDoNothing),
         override: 'OVERRIDING_NOT_SET'
       }
     },

pgpm/core/src/export/export-meta.ts

@@ -7,6 +7,7 @@ type FieldType = 'uuid' | 'uuid[]' | 'text' | 'text[]' | 'boolean' | 'image' | '
 interface TableConfig {
   schema: string;
   table: string;
+  conflictDoNothing?: boolean;
   fields: Record<string, FieldType>;
 }
 
@@ -57,6 +58,10 @@ const config: Record<string, TableConfig> = {
   field: {
     schema: 'metaschema_public',
     table: 'field',
+    // Use ON CONFLICT DO NOTHING to handle the unique constraint (databases_field_uniq_names_idx)
+    // which normalizes UUID field names by stripping suffixes like _id, _uuid, etc.
+    // This causes collisions when tables have both 'foo' (text) and 'foo_id' (uuid) columns.
+    conflictDoNothing: true,
     fields: {
       id: 'uuid',
       database_id: 'uuid',