add uniqueColumnGroups

lib/DboBuilder/DboBuilderTypes.ts

@@ -34,7 +34,7 @@ export type TableSchemaColumn = ColumnInfo & {
   privileges: Partial<Record<"INSERT" | "REFERENCES" | "SELECT" | "UPDATE", true>>;
 }
 
-export type TableSchema = {
+export type TableSchema = Pick<TableInfo, "uniqueColumnGroups"> & {
   schema: string;
   name: string;
   escaped_identifier: string;

lib/DboBuilder/ViewHandler/getInfo.ts

@@ -15,6 +15,7 @@ export async function getInfo(this: ViewHandler, lang?: string, param2?: any, pa
   const fileTableName = this.dboBuilder.prostgles?.opts?.fileTable?.tableName;
 
   await this._log({ command: "getInfo", localParams, data: { lang }, duration: 0 });
+  const allowedFieldsToSelect = this.parseFieldFilter(tableRules?.select?.fields);
   return {
     oid: this.tableOrViewInfo.oid,
     comment: this.tableOrViewInfo.comment,
@@ -27,6 +28,10 @@ export async function getInfo(this: ViewHandler, lang?: string, param2?: any, pa
     fileTableName,
     dynamicRules: {
       update: Boolean(tableRules?.update?.dynamicFields?.length)
-    }
+    },
+    /**
+     * Only show column groups that are fully allowed to be selected by the user
+     */
+    uniqueColumnGroups: this.tableOrViewInfo.uniqueColumnGroups?.filter(g => !localParams || g.every(c => allowedFieldsToSelect.includes(c))),
   }
 }

lib/DboBuilder/getTablesForSchemaPostgresSQL.ts

@@ -1,5 +1,5 @@
 import { SQLResult, asName } from "prostgles-types";
-import { omitKeys, tryCatch } from "prostgles-types/dist/util";
+import { omitKeys, tryCatch, tryCatchV2 } from "prostgles-types/dist/util";
 import { DboBuilder } from "../DboBuilder/DboBuilder";
 import { DBorTx } from "../Prostgles";
 import { clone } from "../utils";
@@ -167,6 +167,43 @@ export async function getTablesForSchemaPostgresSQL(
     if(getFkeys.error !== undefined){
       throw getFkeys.error;
     }
+
+    const uniqueColsReq = await tryCatchV2(async () => {
+      const res = await t.any(`
+        select
+            t.relname as table_name,
+            (SELECT pnm.nspname FROM pg_catalog.pg_namespace pnm WHERE pnm.oid =  i.relnamespace) as table_schema,
+            i.relname as index_name,
+            array_agg(a.attname)::_TEXT as column_names
+        from
+            pg_class t,
+            pg_class i,
+            pg_index ix,
+            pg_attribute a
+        where
+            t.oid = ix.indrelid
+            and i.oid = ix.indexrelid
+            and a.attrelid = t.oid
+            and a.attnum = ANY(ix.indkey)
+            and t.relkind = 'r'
+            and ix.indisunique
+        group by 1,2,3
+        order by
+            t.relname,
+            i.relname;
+      `) as {
+          table_name: string;
+          table_schema: string;
+          index_name: string;
+          column_names: string[]; 
+        }[];
+
+        return res;
+    });
+
+    if(uniqueColsReq.error){
+      throw uniqueColsReq.error;
+    }
 
     const badFkey = getFkeys.fkeys!.find(r => r.fcols.includes(null as any));
     if(badFkey){
@@ -386,6 +423,8 @@ export async function getTablesForSchemaPostgresSQL(
 
         });
         table.isHyperTable = getHyperTablesReq.hyperTables?.includes(table.name);
+
+        table.uniqueColumnGroups = uniqueColsReq.data?.filter(r => r.table_name === table.name && r.table_schema === table.schema).map(r => r.column_names);
 
         return table;
       }));

package.json

@@ -1,6 +1,6 @@
 {
   "name": "prostgles-server",
-  "version": "4.2.170",
+  "version": "4.2.171",
   "description": "",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -54,7 +54,7 @@
     "pg": "^8.11.5",
     "pg-cursor": "^2.11.0",
     "pg-promise": "^11.9.1",
-    "prostgles-types": "^4.0.109"
+    "prostgles-types": "^4.0.112"
   },
   "devDependencies": {
     "@types/express": "^4.17.21",

tests/client/package.json

@@ -13,7 +13,7 @@
   "license": "ISC",
   "dependencies": {
     "@types/node": "^20.9.2",
-    "prostgles-client": "^4.0.158",
+    "prostgles-client": "^4.0.162",
     "prostgles-types": "^4.0.51",
     "socket.io-client": "^4.7.5"
   },

tests/isomorphicQueries.spec.ts

@@ -71,6 +71,31 @@ export const isomorphicQueries = async (db: DBOFullyTyped | DBHandlerClient, log
       }
     });
 
+    await test("Table info", async () => {
+      const { 
+        /** Excluded because their value may vary */
+        oid, isFileTable, 
+        ...tableInfo 
+      } = (await db.items.getInfo?.()) ?? {};
+      assert.deepStrictEqual(tableInfo, {
+        "comment": null,
+        "info": {
+          "label": "items"
+        },
+        "isView": false,
+        "hasFiles": false,
+        "fileTableName": "files",
+        "dynamicRules": {
+          "update": false
+        },
+        "uniqueColumnGroups": [
+          [
+            "id"
+          ]
+        ]
+      });
+    });
+
     await test("Prepare data", async () => {
       if(!db.sql) throw "db.sql missing";
       const res = await db.items.insert!([{ name: "a" }, { name: "a" }, { name: "b" }], { returning: "*" });