diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/svc/DomainListRefreshService.java b/code/services-core/executor-service/src/main/java/nu/marginalia/svc/DomainListRefreshService.java
index 2543f963..fe600fc0 100644
--- a/code/services-core/executor-service/src/main/java/nu/marginalia/svc/DomainListRefreshService.java
+++ b/code/services-core/executor-service/src/main/java/nu/marginalia/svc/DomainListRefreshService.java
@@ -51,13 +51,12 @@ public class DomainListRefreshService {
 
             // Case 1: The domains are in the table, but have no affinity defined
             for (var domain : domainsAll) {
-                update.setString(1, domain.toLowerCase());
-                update.setInt(2, nodeId);
+                update.setInt(1, nodeId);
+                update.setString(2, domain.toLowerCase());
                 update.addBatch();
             }
             update.executeBatch();
 
-
             // Case 2: The domains are missing form the table
             for (var domain : domainsAll) {
                 var parsed = new EdgeDomain(domain);
@@ -69,6 +68,10 @@ public class DomainListRefreshService {
             insert.executeBatch();
 
             cleanCrawlQueue(conn);
+
+            if (!conn.getAutoCommit()) {
+                conn.commit();
+            }
         }
         catch (Exception ex) {
             logger.warn("Failed to insert domains", ex);