updates

Author: michelle0927

components/neon_postgres/neon_postgres.app.mjs

@@ -1,4 +1,5 @@
 import postgresql from "@pipedream/postgresql";
+import format from "pg-format";
 
 export default {
   type: "app",
@@ -26,5 +27,30 @@ export default {
         ssl: this._getSslConfig(),
       };
     },
+    upsertRow({
+      schema, table, columns, values, conflictTarget = "id", errorMsg,
+    } = {}) {
+      const placeholders = this.getPlaceholders({
+        values,
+      });
+
+      const updates = columns
+        .filter((column) => column !== conflictTarget)
+        .map((column) => `${column}=EXCLUDED.${column}`);
+
+      const query = `
+        INSERT INTO ${schema}.${table} (${columns})
+          VALUES (${placeholders})
+          ON CONFLICT (${conflictTarget})
+          DO UPDATE SET ${updates}
+          RETURNING *
+      `;
+
+      return this.executeQuery({
+        text: format(query, schema, table),
+        values,
+        errorMsg,
+      });
+    },
   },
 };

components/neon_postgres/package.json

@@ -14,6 +14,7 @@
   },
   "dependencies": {
     "@pipedream/platform": "^3.0.3",
-    "@pipedream/postgresql": "^2.2.3"
+    "@pipedream/postgresql": "^2.2.3",
+    "pg-format": "^1.0.4"
   }
 }

components/neon_postgres/sources/new-row-custom-query/new-row-custom-query.mjs

@@ -56,7 +56,7 @@ export default {
       }
 
       const numberOfValues = this.query?.match(/\$/g)?.length || 0;
-      if (this.values.length !== numberOfValues) {
+      if (this.values && this.values.length !== numberOfValues) {
         throw new Error("The number of values provided does not match the number of values in the query.");
       }
 

components/postgresql/sources/new-row-custom-query/new-row-custom-query.mjs

@@ -56,7 +56,7 @@ export default {
       }
 
       const numberOfValues = this.query?.match(/\$/g)?.length || 0;
-      if (this.values.length !== numberOfValues) {
+      if (this.values && this.values.length !== numberOfValues) {
         throw new Error("The number of values provided does not match the number of values in the query.");
       }