expose table oid and column number (#409)

* expose table oid and att num from description

* add types

* rename properties

* add tests

Author: Newbie012

cjs/src/connection.js

@@ -615,12 +615,16 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
     for (let i = 0; i < length; ++i) {
       start = index
       while (x[index++] !== 0);
+      const table = x.readUInt32BE(index)
+      const number = x.readUInt16BE(index + 4)
       const type = x.readUInt32BE(index + 6)
       query.statement.columns[i] = {
         name: transform.column.from
           ? transform.column.from(x.toString('utf8', start, index - 1))
           : x.toString('utf8', start, index - 1),
         parser: parsers[type],
+        table,
+        number,
         type
       }
       index += 18

cjs/tests/index.js

@@ -1891,6 +1891,18 @@ t('Describe a statement', async() => {
   ]
 })
 
+t('Include table oid and column number in column details', async() => {
+    await sql`create table tester (name text, age int)`
+    const r = await sql`select name, age from tester where name like $1 and age > $2`.describe();
+    const [{ oid }] = await sql`select oid from pg_class where relname = 'tester'`;
+
+    return [
+        `table:${oid},number:1|table:${oid},number:2`,
+        `${ r.columns.map(c => `table:${c.table},number:${c.number}`).join('|') }`,
+        await sql`drop table tester`
+    ]
+})
+
 t('Describe a statement without parameters', async() => {
   await sql`create table tester (name text, age int)`
   const r = await sql`select name, age from tester`.describe()
@@ -2182,4 +2194,4 @@ t('Insert array with undefined transform', async() => {
     (await sql`select x from test`)[0].x[0],
     await sql`drop table test`
   ]
-})
+})

deno/src/connection.js

@@ -619,12 +619,16 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
     for (let i = 0; i < length; ++i) {
       start = index
       while (x[index++] !== 0);
+      const table = x.readUInt32BE(index)
+      const number = x.readUInt16BE(index + 4)
       const type = x.readUInt32BE(index + 6)
       query.statement.columns[i] = {
         name: transform.column.from
           ? transform.column.from(x.toString('utf8', start, index - 1))
           : x.toString('utf8', start, index - 1),
         parser: parsers[type],
+        table,
+        number,
         type
       }
       index += 18

deno/tests/index.js

@@ -1893,6 +1893,18 @@ t('Describe a statement', async() => {
   ]
 })
 
+t('Include table oid and column number in column details', async() => {
+    await sql`create table tester (name text, age int)`
+    const r = await sql`select name, age from tester where name like $1 and age > $2`.describe();
+    const [{ oid }] = await sql`select oid from pg_class where relname = 'tester'`;
+
+    return [
+        `table:${oid},number:1|table:${oid},number:2`,
+        `${ r.columns.map(c => `table:${c.table},number:${c.number}`).join('|') }`,
+        await sql`drop table tester`
+    ]
+})
+
 t('Describe a statement without parameters', async() => {
   await sql`create table tester (name text, age int)`
   const r = await sql`select name, age from tester`.describe()
@@ -2185,5 +2197,4 @@ t('Insert array with undefined transform', async() => {
     await sql`drop table test`
   ]
 })
-
 ;window.addEventListener("unload", () => Deno.exit(process.exitCode))

deno/types/index.d.ts

@@ -505,6 +505,8 @@ declare namespace postgres {
   interface Column<T extends string> {
     name: T;
     type: number;
+    table: number;
+    number: number;
     parser?(raw: string): unknown;
   }
 

src/connection.js

@@ -615,12 +615,16 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
     for (let i = 0; i < length; ++i) {
       start = index
       while (x[index++] !== 0);
+      const table = x.readUInt32BE(index)
+      const number = x.readUInt16BE(index + 4)
       const type = x.readUInt32BE(index + 6)
       query.statement.columns[i] = {
         name: transform.column.from
           ? transform.column.from(x.toString('utf8', start, index - 1))
           : x.toString('utf8', start, index - 1),
         parser: parsers[type],
+        table,
+        number,
         type
       }
       index += 18

tests/index.js

@@ -1891,6 +1891,18 @@ t('Describe a statement', async() => {
   ]
 })
 
+t('Include table oid and column number in column details', async() => {
+    await sql`create table tester (name text, age int)`
+    const r = await sql`select name, age from tester where name like $1 and age > $2`.describe();
+    const [{ oid }] = await sql`select oid from pg_class where relname = 'tester'`;
+
+    return [
+        `table:${oid},number:1|table:${oid},number:2`,
+        `${ r.columns.map(c => `table:${c.table},number:${c.number}`).join('|') }`,
+        await sql`drop table tester`
+    ]
+})
+
 t('Describe a statement without parameters', async() => {
   await sql`create table tester (name text, age int)`
   const r = await sql`select name, age from tester`.describe()
@@ -2182,4 +2194,4 @@ t('Insert array with undefined transform', async() => {
     (await sql`select x from test`)[0].x[0],
     await sql`drop table test`
   ]
-})
+})

types/index.d.ts

@@ -497,6 +497,8 @@ declare namespace postgres {
   interface Column<T extends string> {
     name: T;
     type: number;
+    table: number;
+    number: number;
     parser?(raw: string): unknown;
   }