feat: batch endpoints for column creation and retrieval

src/lib/PostgresMetaColumns.ts

@@ -2,7 +2,7 @@ import { ident, literal } from 'pg-format'
 import PostgresMetaTables from './PostgresMetaTables'
 import { DEFAULT_SYSTEM_SCHEMAS } from './constants'
 import { columnsSql } from './sql'
-import { PostgresMetaResult, PostgresColumn } from './types'
+import { PostgresMetaResult, PostgresColumn, PostgresColumnCreate } from './types'
 
 export default class PostgresMetaColumns {
   query: (sql: string) => Promise<PostgresMetaResult<any>>
@@ -57,75 +57,148 @@ export default class PostgresMetaColumns {
     schema?: string
   }): Promise<PostgresMetaResult<PostgresColumn>> {
     if (id) {
+      const { data, error } = await this.batchRetrieve({ ids: [id] })
+      if (data) {
+        return { data: data[0], error: null }
+      } else if (error) {
+        return { data: null, error: error }
+      }
+    }
+    if (name && table) {
+      const { data, error } = await this.batchRetrieve({ names: [name], table, schema })
+      if (data) {
+        return { data: data[0], error: null }
+      } else if (error) {
+        return { data: null, error: error }
+      }
+    }
+    return { data: null, error: { message: 'Invalid parameters on column retrieve' } }
+  }
+
+  async batchRetrieve({ ids }: { ids: string[] }): Promise<PostgresMetaResult<PostgresColumn[]>>
+  async batchRetrieve({
+    names,
+    table,
+    schema,
+  }: {
+    names: string[]
+    table: string
+    schema: string
+  }): Promise<PostgresMetaResult<PostgresColumn[]>>
+  async batchRetrieve({
+    ids,
+    names,
+    table,
+    schema = 'public',
+  }: {
+    ids?: string[]
+    names?: string[]
+    table?: string
+    schema?: string
+  }): Promise<PostgresMetaResult<PostgresColumn[]>> {
+    if (ids && ids.length > 0) {
       const regexp = /^(\d+)\.(\d+)$/
-      if (!regexp.test(id)) {
-        return { data: null, error: { message: 'Invalid format for column ID' } }
+
+      const invalidId = ids.find((id) => !regexp.test(id))
+      if (invalidId) {
+        return { data: null, error: { message: `Invalid format for column ID: ${invalidId}` } }
       }
-      const matches = id.match(regexp) as RegExpMatchArray
-      const [tableId, ordinalPos] = matches.slice(1).map(Number)
-      const sql = `${columnsSql} AND c.oid = ${tableId} AND a.attnum = ${ordinalPos};`
+
+      const filteringClauses = ids
+        .map((id) => {
+          const matches = id.match(regexp) as RegExpMatchArray
+          const [tableId, ordinalPos] = matches.slice(1).map(Number)
+          return `(c.oid = ${tableId} AND a.attnum = ${ordinalPos})`
+        })
+        .join(' OR ')
+      const sql = `${columnsSql} AND (${filteringClauses});`
       const { data, error } = await this.query(sql)
       if (error) {
         return { data, error }
-      } else if (data.length === 0) {
-        return { data: null, error: { message: `Cannot find a column with ID ${id}` } }
+      } else if (data.length < ids.length) {
+        return { data: null, error: { message: `Cannot find some of the requested columns.` } }
       } else {
-        return { data: data[0], error }
+        return { data, error }
       }
-    } else if (name && table) {
-      const sql = `${columnsSql} AND a.attname = ${literal(name)} AND c.relname = ${literal(
+    } else if (names && names.length > 0 && table) {
+      const filteringClauses = names.map((name) => `a.attname = ${literal(name)}`).join(' OR ')
+      const sql = `${columnsSql} AND (${filteringClauses}) AND c.relname = ${literal(
         table
       )} AND nc.nspname = ${literal(schema)};`
       const { data, error } = await this.query(sql)
       if (error) {
         return { data, error }
-      } else if (data.length === 0) {
+      } else if (data.length < names.length) {
         return {
           data: null,
-          error: { message: `Cannot find a column named ${name} in table ${schema}.${table}` },
+          error: { message: `Cannot find some of the requested columns.` },
         }
       } else {
-        return { data: data[0], error }
+        return { data, error }
       }
     } else {
       return { data: null, error: { message: 'Invalid parameters on column retrieve' } }
     }
   }
 
-  async create({
-    table_id,
-    name,
-    type,
-    default_value,
-    default_value_format = 'literal',
-    is_identity = false,
-    identity_generation = 'BY DEFAULT',
-    // Can't pick a value as default since regular columns are nullable by default but PK columns aren't
-    is_nullable,
-    is_primary_key = false,
-    is_unique = false,
-    comment,
-    check,
-  }: {
-    table_id: number
-    name: string
-    type: string
-    default_value?: any
-    default_value_format?: 'expression' | 'literal'
-    is_identity?: boolean
-    identity_generation?: 'BY DEFAULT' | 'ALWAYS'
-    is_nullable?: boolean
-    is_primary_key?: boolean
-    is_unique?: boolean
-    comment?: string
-    check?: string
-  }): Promise<PostgresMetaResult<PostgresColumn>> {
+  async create(col: PostgresColumnCreate): Promise<PostgresMetaResult<PostgresColumn>> {
+    const { data, error } = await this.batchCreate([col])
+    if (data) {
+      return { data: data[0], error: null }
+    } else if (error) {
+      return { data: null, error: error }
+    }
+    return { data: null, error: { message: 'Invalid params' } }
+  }
+
+  async batchCreate(cols: PostgresColumnCreate[]): Promise<PostgresMetaResult<PostgresColumn[]>> {
+    if (cols.length < 1) {
+      throw new Error('no columns provided for creation')
+    }
+    if ([...new Set(cols.map((col) => col.table_id))].length > 1) {
+      throw new Error('all columns in a single request must share the same table')
+    }
+    const { table_id } = cols[0]
     const { data, error } = await this.metaTables.retrieve({ id: table_id })
     if (error) {
       return { data: null, error }
     }
     const { name: table, schema } = data!
 
+    const sqlStrings = cols.map((col) => this.generateColumnCreationSql(col, schema, table))
+
+    const sql = `BEGIN;
+${sqlStrings.join('\n')}
+COMMIT;
+`
+    {
+      const { error } = await this.query(sql)
+      if (error) {
+        return { data: null, error }
+      }
+    }
+    const names = cols.map((col) => col.name)
+    return await this.batchRetrieve({ names, table, schema })
+  }
+
+  generateColumnCreationSql(
+    {
+      name,
+      type,
+      default_value,
+      default_value_format = 'literal',
+      is_identity = false,
+      identity_generation = 'BY DEFAULT',
+      // Can't pick a value as default since regular columns are nullable by default but PK columns aren't
+      is_nullable,
+      is_primary_key = false,
+      is_unique = false,
+      comment,
+      check,
+    }: PostgresColumnCreate,
+    schema: string,
+    table: string
+  ) {
     let defaultValueClause = ''
     if (is_identity) {
       if (default_value !== undefined) {
@@ -159,22 +232,14 @@ export default class PostgresMetaColumns {
         : `COMMENT ON COLUMN ${ident(schema)}.${ident(table)}.${ident(name)} IS ${literal(comment)}`
 
     const sql = `
-BEGIN;
   ALTER TABLE ${ident(schema)}.${ident(table)} ADD COLUMN ${ident(name)} ${typeIdent(type)}
     ${defaultValueClause}
     ${isNullableClause}
     ${isPrimaryKeyClause}
     ${isUniqueClause}
     ${checkSql};
-  ${commentSql};
-COMMIT;`
-    {
-      const { error } = await this.query(sql)
-      if (error) {
-        return { data: null, error }
-      }
-    }
-    return await this.retrieve({ name, table, schema })
+  ${commentSql};`
+    return sql
   }
 
   async update(

src/lib/types.ts

@@ -42,6 +42,26 @@ export const postgresColumnSchema = Type.Object({
 })
 export type PostgresColumn = Static<typeof postgresColumnSchema>
 
+export const postgresColumnCreateSchema = Type.Object({
+  table_id: Type.Integer(),
+  name: Type.String(),
+  type: Type.String(),
+  default_value: Type.Optional(Type.Any()),
+  default_value_format: Type.Optional(
+    Type.Union([Type.Literal('expression'), Type.Literal('literal')])
+  ),
+  is_identity: Type.Optional(Type.Boolean()),
+  identity_generation: Type.Optional(
+    Type.Union([Type.Literal('BY DEFAULT'), Type.Literal('ALWAYS')])
+  ),
+  is_nullable: Type.Optional(Type.Boolean()),
+  is_primary_key: Type.Optional(Type.Boolean()),
+  is_unique: Type.Optional(Type.Boolean()),
+  comment: Type.Optional(Type.String()),
+  check: Type.Optional(Type.String()),
+})
+export type PostgresColumnCreate = Static<typeof postgresColumnCreateSchema>
+
 // TODO Rethink config.sql
 export const postgresConfigSchema = Type.Object({
   name: Type.Unknown(),

src/server/routes/columns.ts

@@ -1,5 +1,11 @@
+import { Type } from '@sinclair/typebox'
 import { FastifyInstance } from 'fastify'
 import { PostgresMeta } from '../../lib'
+import {
+  PostgresColumnCreate,
+  postgresColumnSchema,
+  postgresColumnCreateSchema,
+} from '../../lib/types'
 import { DEFAULT_POOL_CONFIG } from '../constants'
 import { extractRequestForLogging } from '../utils'
 
@@ -56,22 +62,49 @@ export default async (fastify: FastifyInstance) => {
 
   fastify.post<{
     Headers: { pg: string }
-    Body: any
-  }>('/', async (request, reply) => {
-    const connectionString = request.headers.pg
+    Body: PostgresColumnCreate | PostgresColumnCreate[]
+  }>(
+    '/',
+    {
+      schema: {
+        headers: Type.Object({
+          pg: Type.String(),
+        }),
+        body: Type.Union([postgresColumnCreateSchema, Type.Array(postgresColumnCreateSchema)]),
+        response: {
+          200: Type.Union([postgresColumnSchema, Type.Array(postgresColumnSchema)]),
+          400: Type.Object({
+            error: Type.String(),
+          }),
+          404: Type.Object({
+            error: Type.String(),
+          }),
+        },
+      },
+    },
+    async (request, reply) => {
+      const connectionString = request.headers.pg
 
-    const pgMeta = new PostgresMeta({ ...DEFAULT_POOL_CONFIG, connectionString })
-    const { data, error } = await pgMeta.columns.create(request.body)
-    await pgMeta.end()
-    if (error) {
-      request.log.error({ error, request: extractRequestForLogging(request) })
-      reply.code(400)
-      if (error.message.startsWith('Cannot find')) reply.code(404)
-      return { error: error.message }
-    }
+      const pgMeta = new PostgresMeta({ ...DEFAULT_POOL_CONFIG, connectionString })
+      if (!Array.isArray(request.body)) {
+        request.body = [request.body]
+      }
 
-    return data
-  })
+      const { data, error } = await pgMeta.columns.batchCreate(request.body)
+      await pgMeta.end()
+      if (error) {
+        request.log.error({ error, request: extractRequestForLogging(request) })
+        reply.code(400)
+        if (error.message.startsWith('Cannot find')) reply.code(404)
+        return { error: error.message }
+      }
+
+      if (Array.isArray(request.body)) {
+        return data
+      }
+      return data[0]
+    }
+  )
 
   fastify.patch<{
     Headers: { pg: string }