Какой лучший способ получить столбец PATCH Postgres JSONB из React -> ExpressJS -> Postgres?

Question

У меня есть большая таблица данных (визуализированная с использованием AG-Grid), и я хочу обновить ее в бэкэнде Postgres, но лучший подход к следующей части заставляет меня преувеличивать, с точки зрения объема работы, и лучший способ действий.

Используя библиотеку fast-json-patch, я могу достаточно легко получить список исправлений JSON в клиенте, а затем что-то примерно так:

import * as jsonpatch from 'fast-json-patch'

postData = jsonpatch.compare(originalData, updatedData)

const request = new Request(url, {
    method: 'PATCH',
    body: JSON.stringify(postData),
    headers: new Headers({
      Accept: 'application/json',
      'Content-Type': 'application/json-patch',
      Authorization: 'Bearer ' + user.token,
    }),
  })

и затем в ExpressJS 'backend' итерируйте набор jsonb_set запросов для обновления Postgres.

В качестве альтернативы, я могу получить запись для обновления из Postgres, затем использовать fast-json-patch для исправления данных JSONB в бэкэнде ExpressJS, а затем обновления записи Postgres в одну go?

Это не то, что я делал раньше, но это то, что я уверен, должно быть довольно распространенным явлением. Какой лучший общий подход?

---

Обновление

Я пытался реализовать второй подход - моя проблема сейчас заключается в блокировке / разблокировке Postgres, когда у меня есть поля JSONB для обновления , Теперь мои проблемы связаны с реализацией блокировки записей и обновлений со стороны express, в частности с попыткой справиться с асинхронной природой работы с бэкэндом pg.

Мне просто интересно, может ли кто-нибудь заметить ( непреднамеренные) ошибки в этой попытке:

const express = require('express')
const bodyParser = require('body-parser')
const SQL = require('sql-template-strings')
const { Client } = require('pg')
const dbConfig = require('../db')
const client = new Client(dbConfig)
const jsonpatch = require('fast-json-patch')

// excerpt for patch records in 'forms' postgres table

const patchFormsRoute = (req, res) => {
  const { id } = req.body
  const jsonFields = [ 'sections', 'descriptions' ]
  const possibleFields = [ 'name','status',...jsonFields ]
  const parts = []
  const params = [id] // stick id in as first param
  let lockInUse = false

  // find which JSONB fields are being PATCHed.
  // incoming JSONB field values are already JSON 
  // arrays of patches to apply for that particular field

  const patchList = Object.keys(req.body)
    .filter(e => jsonFields.indexOf(e) > -1)

  client.connect()

  if (patchList.length > 0) {
    const patchesToApply = pullProps(req.body, jsonFields)
    lockInUse = getLock('forms',id)
    // return record from pg as object with just JSONB field values
    const oldValues = getCurrentValues(patchList, id)
    // returns record with patches applied
    const patchedValues = patchValues( oldValues , patchesToApply )
  }

  possibleFields.forEach(myProp => {
    if (req.body[myProp] != undefined) {
      parts.push(`${myProp} = $${params.length + 1}`)
      if (jsonFields.indexOf(myProp) > -1) {
        params.push(JSON.stringify(patchedValues[myProp]))
      } else {
        params.push(req.body[myProp])
      }
    }
  })

  result = runUpdate(client, 'forms', parts, params)

  if(lockInUse) {
    releaseLock(client, 'forms', id)
  }

  client.end()

  return result
}

// helper functions to try and cope with async nature of pg

function async getLock(client, tableName, id ) {
  await client.query(SQL`SELECT pg_advisory_lock(${tableName}::regclass::integer, ${id});`)
  return true
}

function async releaseLock(client, tableName, id) {
  await client.query(SQL`SELECT pg_advisory_unlock(${tableName}::regclass::integer, ${id});`)
}

function async getCurrentValues(client, fieldList, id) {
  const fl = fieldList.join(', ')
  const currentValues = await client
    .query(SQL`SELECT ${fl} FROM forms WHERE id = ${id}`)
    .then((result) => {return result.rows[0]})
  return currentValues
}

function pullProps(sourceObject, propList) {
  return propList.reduce((result, propName) => {
    if(sourceObject.hasOwnProperty(propName)) result[propName] = sourceObject[propName]
    return result
  }, {})
}

function patchValues(oldValues, patches) {
  const result = {}
  Object.keys(oldValues).forEach(e => {
    result[e] = jsonpatch.apply( oldValues[e], patches[e] );
  })
  return result
}

function async runUpdate(client, tableName, parts, params) {
  const updateQuery = 'UPDATE ' + tableName + ' SET ' + parts.join(', ') + ' WHERE id = $1'
  const result = await client
    .query(updateQuery, params)
    .then(result => {
      res.json(result.rowCount)
    })
  return result
}

Answer 1

Используйте 2-й метод. PostgreSQL не имеет функции редактирования на месте для JSONB. Это всегда будет включать создание полной копии. Вы могли бы также сделать это в клиенте, который, кажется, имеет лучшие инструменты для этого.

Исключением может быть, если патч маленький, а JSONB огромен, а сеть медленная.