Add cursor -> select example

packages/pg/performance-test.js

@@ -0,0 +1,48 @@
+// Runs a select statement on 10000 rows, compare performance between node pg and pg-browser
+var time_pg
+var time_ws
+
+// with pg-browser
+var { Client, Pool } = require("./lib/index.js")
+var start = new Date().getTime();
+
+var client = new Client({
+    database: 'postgres',
+    user: 'bitdotio-2',
+    password: 'password',
+    port: '5901',
+})
+
+client.connect(() => {
+    client.query("SELECT * FROM generate_series(1,10000)", () => {
+        var elapsed = new Date().getTime() - start;
+        time_ws = elapsed
+        console.log("Ws time: %d", time_ws)
+        client.end(() => {
+            // with regular pg
+            var { Client, Pool } = require('pg')
+            var start = new Date().getTime();
+
+            client = new Client({
+                database: 'postgres',
+                user: 'bitdotio-2',
+                password: 'password',
+                port: '5433',
+            })
+
+            client.connect(() => {
+                client.query("SELECT * FROM generate_series(1,10000)", () => {
+                    var elapsed = new Date().getTime() - start;
+                    time_pg = elapsed
+                    console.log("Vanilla pg time: %d", time_pg)
+                    client.end()
+                })
+            })
+        })
+    })
+})
+
+
+
+
+

packages/pg/select-example.js

@@ -0,0 +1,26 @@
+const { Client } = require('pg')
+const Cursor = require('pg-cursor')
+
+const client = new Client({
+    database: 'postgres',
+    user: 'bitdotio-2',
+    password: 'password',
+    port: '5433',
+})
+
+client.connect()
+
+const cursor = client.query(new Cursor("SELECT * FROM generate_series(1,100)"))
+// read partially from cursor
+cursor.read(1, () => {
+    console.log("Cursor read")
+    // send query from client, which will not execute since there is a PortalSuspended
+    client.query("SELECT 1", () => {
+        console.log("SELECT 1")
+        cursor.read(100, () => {
+            console.log("Cursor read again")
+        })
+    })
+    // if calling client.connection.query() or cursor.connection.query()
+    // instead, the portal will receive a commandComplete and then close
+})