2 files changed, 64 insertions, 0 deletions
diff --git a/test/js/third_party/postgres/package.json b/test/js/third_party/postgres/package.json
new file mode 100644
index 000000000..90809f48f
--- /dev/null
+++ b/test/js/third_party/postgres/package.json
@@ -0,0 +1,8 @@
+{
+  "name": "postgres",
+  "dependencies": {
+    "pg": "8.11.1", 
+    "postgres": "3.3.5",
+    "pg-connection-string": "2.6.1"
+  }
+}
diff --git a/test/js/third_party/postgres/postgres.test.ts b/test/js/third_party/postgres/postgres.test.ts
new file mode 100644
index 000000000..490192ae7
--- /dev/null
+++ b/test/js/third_party/postgres/postgres.test.ts
@@ -0,0 +1,56 @@
+import { test, expect, describe } from "bun:test";
+import { Pool } from "pg";
+import { parse } from "pg-connection-string";
+import postgres from "postgres";
+
+const CONNECTION_STRING = process.env.TLS_POSTGRES_DATABASE_URL;
+
+const it = CONNECTION_STRING ? test : test.skip;
+
+describe("pg", () => {
+  it("should connect using TLS", async () => {
+    const pool = new Pool(parse(CONNECTION_STRING as string));
+    try {
+      const { rows } = await pool.query("SELECT version()", []);
+      const [{ version }] = rows;
+
+      expect(version).toMatch(/PostgreSQL/);
+    } finally {
+      pool.end();
+    }
+  });
+});
+
+describe("postgres", () => {
+  it("should connect using TLS", async () => {
+    const sql = postgres(CONNECTION_STRING as string);
+    try {
+      const [{ version }] = await sql`SELECT version()`;
+      expect(version).toMatch(/PostgreSQL/);
+    } finally {
+      sql.end();
+    }
+  });
+
+  it("should insert, select and delete", async () => {
+    const sql = postgres(CONNECTION_STRING as string);
+    try {
+      await sql`CREATE TABLE IF NOT EXISTS users (
+            user_id serial PRIMARY KEY,
+            username VARCHAR ( 50 ) NOT NULL
+        );`;
+
+      const [{ user_id, username }] = await sql`insert into users (username) values ('bun') returning *`;
+      expect(username).toBe("bun");
+
+      const [{ user_id: user_id2, username: username2 }] = await sql`select * from users where user_id = ${user_id}`;
+      expect(username2).toBe("bun");
+      expect(user_id2).toBe(user_id);
+
+      const [{ username: username3 }] = await sql`delete from users where user_id = ${user_id} returning *`;
+      expect(username3).toBe("bun");
+    } finally {
+      sql.end();
+    }
+  });
+});