Neon PostgreSQL - New Components

components/neon_postgres/actions/delete-rows/delete-rows.mjs

@@ -0,0 +1,75 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  name: "Delete Row(s)",
+  key: "neon_api_keys-delete-rows",
+  description: "Deletes a row or rows from a table. [See the documentation](https://node-postgres.com/features/queries)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    schema: {
+      propDefinition: [
+        neon,
+        "schema",
+      ],
+    },
+    table: {
+      propDefinition: [
+        neon,
+        "table",
+        (c) => ({
+          schema: c.schema,
+        }),
+      ],
+    },
+    column: {
+      propDefinition: [
+        neon,
+        "column",
+        (c) => ({
+          table: c.table,
+          schema: c.schema,
+        }),
+      ],
+      label: "Lookup Column",
+      description: "Find row(s) by searching for a value in this column",
+    },
+    value: {
+      propDefinition: [
+        neon,
+        "value",
+        (c) => ({
+          table: c.table,
+          column: c.column,
+          schema: c.schema,
+        }),
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      table,
+      schema,
+      column,
+      value,
+    } = this;
+
+    try {
+      const rows = await this.neon.deleteRows(
+        schema,
+        table,
+        column,
+        value,
+      );
+      $.export("$summary", `Deleted ${rows.length} rows from ${table}`);
+      return rows;
+    } catch (error) {
+      let errorMsg = "Row not deleted due to an error. ";
+      errorMsg += `${error}`.includes("SSL verification failed")
+        ? "This could be because SSL verification failed. To resolve this, reconnect your account and set SSL Verification Mode: Skip Verification, and try again."
+        : `${error}`;
+      throw new Error(errorMsg);
+    }
+  },
+};

components/neon_postgres/actions/execute-custom-query/execute-custom-query.mjs

@@ -0,0 +1,28 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  key: "neon_api_keys-execute-custom-query",
+  name: "Execute SQL Query",
+  description: "Execute a custom PostgreSQL query. See [our docs](https://pipedream.com/docs/databases/working-with-sql) to learn more about working with SQL in Pipedream.",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    // eslint-disable-next-line pipedream/props-description
+    sql: {
+      type: "sql",
+      auth: {
+        app: "neon",
+      },
+      label: "PostgreSQL Query",
+    },
+  },
+  async run({ $ }) {
+    const args = this.neon.executeQueryAdapter(this.sql);
+    const data = await this.neon.executeQuery(args);
+    $.export("$summary", `Returned ${data.length} ${data.length === 1
+      ? "row"
+      : "rows"}`);
+    return data;
+  },
+};

components/neon_postgres/actions/find-row-custom-query/find-row-custom-query.mjs

@@ -0,0 +1,60 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  name: "Find Row With Custom Query",
+  key: "neon_api_keys-find-row-custom-query",
+  description: "Finds a row in a table via a custom query. [See the documentation](https://node-postgres.com/features/queries)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    query: {
+      propDefinition: [
+        neon,
+        "query",
+      ],
+    },
+    values: {
+      propDefinition: [
+        neon,
+        "values",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      query,
+      values = [],
+    } = this;
+
+    if (!Array.isArray(values)) {
+      throw new Error("No valid values provided. The values property must be an array.");
+    }
+
+    if (this.values) {
+      const numberOfValues = query?.match(/\$/g)?.length || 0;
+      if (values.length !== numberOfValues) {
+        throw new Error("The number of values provided does not match the number of values in the query.");
+      }
+    }
+
+    if (!query.toLowerCase().includes("select")) {
+      throw new Error("Need be a `SELECT` statement query. Read more about [SELECT queries here](https://www.w3schools.com/sql/sql_select.asp)");
+    }
+
+    try {
+      const res = await this.neon.executeQuery({
+        text: query,
+        values,
+      });
+      $.export("$summary", "Successfully executed query");
+      return res;
+    } catch (error) {
+      let errorMsg = "Query not executed due to an error. ";
+      errorMsg += `${error}`.includes("SSL verification failed")
+        ? "This could be because SSL verification failed. To resolve this, reconnect your account and set SSL Verification Mode: Skip Verification, and try again."
+        : `${error}`;
+      throw new Error(errorMsg);
+    }
+  },
+};

components/neon_postgres/actions/find-row/find-row.mjs

@@ -0,0 +1,77 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  name: "Find Row",
+  key: "neon_api_keys-find-row",
+  description: "Finds a row in a table via a lookup column. [See the documentation](https://node-postgres.com/features/queries)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    schema: {
+      propDefinition: [
+        neon,
+        "schema",
+      ],
+    },
+    table: {
+      propDefinition: [
+        neon,
+        "table",
+        (c) => ({
+          schema: c.schema,
+        }),
+      ],
+    },
+    column: {
+      propDefinition: [
+        neon,
+        "column",
+        (c) => ({
+          table: c.table,
+          schema: c.schema,
+        }),
+      ],
+      label: "Lookup Column",
+      description: "Find row by searching for a value in this column. Returns first row found",
+    },
+    value: {
+      propDefinition: [
+        neon,
+        "value",
+        (c) => ({
+          table: c.table,
+          column: c.column,
+          schema: c.schema,
+        }),
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      schema,
+      table,
+      column,
+      value,
+    } = this;
+    try {
+      const res = await this.neon.findRowByValue(
+        schema,
+        table,
+        column,
+        value,
+      );
+      const summary = res
+        ? "Row found"
+        : "Row not found";
+      $.export("$summary", summary);
+      return res;
+    } catch (error) {
+      let errorMsg = "Row not retrieved due to an error. ";
+      errorMsg += `${error}`.includes("SSL verification failed")
+        ? "This could be because SSL verification failed. To resolve this, reconnect your account and set SSL Verification Mode: Skip Verification, and try again."
+        : `${error}`;
+      throw new Error(errorMsg);
+    }
+  },
+};

components/neon_postgres/actions/insert-row/insert-row.mjs

@@ -0,0 +1,58 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  name: "Insert Row",
+  key: "neon_api_keys-insert-row",
+  description: "Adds a new row. [See the documentation](https://node-postgres.com/features/queries)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    schema: {
+      propDefinition: [
+        neon,
+        "schema",
+      ],
+    },
+    table: {
+      propDefinition: [
+        neon,
+        "table",
+        (c) => ({
+          schema: c.schema,
+        }),
+      ],
+    },
+    rowValues: {
+      propDefinition: [
+        neon,
+        "rowValues",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      schema,
+      table,
+      rowValues,
+    } = this;
+    const columns = Object.keys(rowValues);
+    const values = Object.values(rowValues);
+    try {
+      const res = await this.neon.insertRow(
+        schema,
+        table,
+        columns,
+        values,
+      );
+      $.export("$summary", "New row inserted");
+      return res;
+    } catch (error) {
+      let errorMsg = "New row not inserted due to an error. ";
+      errorMsg += `${error}`.includes("SSL verification failed")
+        ? "This could be because SSL verification failed. To resolve this, reconnect your account and set SSL Verification Mode: Skip Verification, and try again."
+        : `${error}`;
+      throw new Error(errorMsg);
+    }
+  },
+};

components/neon_postgres/actions/update-row/update-row.mjs

@@ -0,0 +1,85 @@
+import neon from "../../neon_postgres.app.mjs";
+
+export default {
+  name: "Update Row",
+  key: "neon_api_keys-update-row",
+  description: "Updates an existing row. [See the documentation](https://node-postgres.com/features/queries)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    neon,
+    schema: {
+      propDefinition: [
+        neon,
+        "schema",
+      ],
+    },
+    table: {
+      propDefinition: [
+        neon,
+        "table",
+        (c) => ({
+          schema: c.schema,
+        }),
+      ],
+    },
+    column: {
+      propDefinition: [
+        neon,
+        "column",
+        (c) => ({
+          table: c.table,
+          schema: c.schema,
+        }),
+      ],
+      label: "Lookup Column",
+      description: "Find row to update by searching for a value in this column. Returns first row found",
+    },
+    value: {
+      propDefinition: [
+        neon,
+        "value",
+        (c) => ({
+          table: c.table,
+          column: c.column,
+          schema: c.schema,
+        }),
+      ],
+    },
+    rowValues: {
+      propDefinition: [
+        neon,
+        "rowValues",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      schema,
+      table,
+      column,
+      value,
+      rowValues,
+    } = this;
+    try {
+      const res = await this.neon.updateRow(
+        schema,
+        table,
+        column,
+        value,
+        rowValues,
+      );
+      const summary = res
+        ? "Row updated"
+        : "Row not found";
+      $.export("$summary", summary);
+      return res;
+    } catch (error) {
+      let errorMsg = "Row not updated due to an error. ";
+      errorMsg += `${error}`.includes("SSL verification failed")
+        ? "This could be because SSL verification failed. To resolve this, reconnect your account and set SSL Verification Mode: Skip Verification, and try again."
+        : `${error}`;
+      throw new Error(errorMsg);
+    }
+  },
+};