fix(table): run batch unique check inside import transaction

`checkBatchUniqueConstraintsDb` queried the global `db` connection, so
inside a single import transaction (one tx wrapping all batches) the
constraint lookup couldn't see uncommitted rows from prior batches —
duplicates that crossed `CSV_MAX_BATCH_SIZE` boundaries slipped through.

Accept an optional executor and pass `trx` from `batchInsertRowsWithTx`
so the lookup observes the in-flight transaction state.

Author: waleedlatif1

apps/sim/lib/table/service.ts

@@ -849,7 +849,12 @@ export async function batchInsertRowsWithTx(
 
   const uniqueColumns = getUniqueColumns(table.schema)
   if (uniqueColumns.length > 0) {
-    const uniqueResult = await checkBatchUniqueConstraintsDb(data.tableId, data.rows, table.schema)
+    const uniqueResult = await checkBatchUniqueConstraintsDb(
+      data.tableId,
+      data.rows,
+      table.schema,
+      trx
+    )
     if (!uniqueResult.valid) {
       const errorMessages = uniqueResult.errors
         .map((e) => `Row ${e.row + 1}: ${e.errors.join(', ')}`)

apps/sim/lib/table/validation.ts

@@ -379,14 +379,26 @@ export async function checkUniqueConstraintsDb(
   return { valid: errors.length === 0, errors }
 }
 
+/**
+ * Minimal executor surface needed by unique-constraint checks. Both `db` and a
+ * drizzle transaction (`trx`) satisfy this, letting callers run the lookup
+ * inside an open transaction so it observes uncommitted prior-batch inserts.
+ */
+type UniqueCheckExecutor = Pick<typeof db, 'select'>
+
 /**
  * Checks unique constraints for a batch of rows using targeted database queries.
  * Validates both against existing database rows and within the batch itself.
+ *
+ * Pass a transaction as `executor` when running inside an open tx so the lookup
+ * sees rows inserted by earlier batches in the same transaction; otherwise the
+ * default `db` connection only observes committed state.
  */
 export async function checkBatchUniqueConstraintsDb(
   tableId: string,
   rows: RowData[],
-  schema: TableSchema
+  schema: TableSchema,
+  executor: UniqueCheckExecutor = db
 ): Promise<{ valid: boolean; errors: Array<{ row: number; errors: string[] }> }> {
   const uniqueColumns = getUniqueColumns(schema)
   const rowErrors: Array<{ row: number; errors: string[] }> = []
@@ -458,7 +470,7 @@ export async function checkBatchUniqueConstraintsDb(
       return sql`(${userTableRows.data}->${sql.raw(`'${columnName}'`)})::jsonb = ${normalizedValue}::jsonb`
     })
 
-    const conflictingRows = await db
+    const conflictingRows = await executor
       .select({
         id: userTableRows.id,
         data: userTableRows.data,