JSON 对象到 Postgres 存储过程参数

Question

有一个单页应用程序可以发送带有 JSON 负载的 POST HTTP 请求：

{"product": { "name": "product A", "quantity": 100 }}

有一个包含表和存储过程的 Postgres 数据库：

create table product {
  product_id serial primary key,
  name text,
  quantity numeric,
  description text
}

create function insert_product (product product) returns product as $$
  -- This function accepts a product type as an argument

是否有任何语言的解决方案可以位于服务器上、处理 HTTP 请求、调用存储过程并自动将 JSON 对象转换为适当的 Postgres 行类型？

在伪 Express.js 中

app.post('/product', (req, res) =>
  db.query('select insert_product($1)', [convertToPostgresPlease(req.body.product)])

我不考虑的解决方案：

• 解构 JSON 对象并用茶匙为 Postgres 提供每个键 或在存储过程中处理 JSON（SP 应接受行类型）
• 从 Postgres 架构复制信息（解决方案必须使用 Postgres 自省功能）
• 手动连接'(' + product.name + ',' + ...

我知道存储过程通常不受欢迎，但对于小型项目，我真的认为它们很棒。 SQL 是用于处理数据的出色 DSL，而 Postgres 足够先进，可以处理任何与数据相关的任务。

无论如何，将 JSON HTTP 请求与适当的 SQL RDBMS 连接起来最简单的方法是什么？

找到解决方案（几乎）：

• postgraphql（有效，但太神奇了）
• Chicken Scheme（list-unparser，还没试过）

Answer 1

正如 Abelisto 在 cmets 中提到的，您可以使用 json_populate_record/jsonb_populate_record 将数据库函数中的 JSON/JSONB 参数转换为特定的表行。另一种选择是直接使用 json 变量，使用 -> 和 ->> 运算符来检索其内容。这样做的缺点是每个表的维护都有相当多的编码。

您还可以从 RESTful 接口（例如 https://github.com/QBisConsult/psql-api）中受益。

对于大量基于 JSON 的解决方案来说，另一个选项是简化大量小表的操作，这些小表每个都不会超过几百条记录。会有性能损失，但对于几行来说，它可能可以忽略不计。

以下示例说明了 PostgreSQL 中 JSON 数据类型的强大功能以及支持 JSON 运算符的 GIN 索引。对于需要最高性能的数据，您仍然可以使用普通表和专用函数。

例子：

CREATE TABLE public.jtables (
  table_id serial NOT NULL PRIMARY KEY,
  table_name text NOT NULL UNIQUE,
  fields jsonb
);

INSERT INTO public.jtables VALUES (default, 'product', '{"id": "number", "name": "string", "quantity": "number", "description": "string"}'::jsonb);

CREATE TABLE public.jdata (
  table_id int NOT NULL REFERENCES jtables,
  data jsonb NOT NULL
);

CREATE UNIQUE INDEX ON public.jdata USING BTREE (table_id, (data->>'id'));
CREATE INDEX ON public.jdata USING GIN (data);

您可以创建函数以通用 JSON 方式操作数据，例如：

CREATE FUNCTION public.jdata_insert(_table text, _data jsonb) RETURNS text AS
$BODY$
  INSERT INTO public.jdata 
  SELECT table_id, $2
  FROM public.jtables
  WHERE table_name = $1
  RETURNING (data)->>'id';
$BODY$ LANGUAGE sql;

CREATE FUNCTION public.jdata_update(_table text, _id text, _data jsonb) RETURNS text AS
$BODY$
  UPDATE public.jdata d SET data = jsonb_strip_nulls(d.data || $3)
  FROM public.jtables t
  WHERE d.table_id = t.table_id AND t.table_name = $1 AND (d.data->>'id') = $2
  RETURNING (d.data)->>'id';
$BODY$ LANGUAGE sql;

然后可以使用这些通用函数插入行：

SELECT public.jdata_insert('product', '{"id": 1, "name": "Product 1", "quantity": 10, "description": "no description"}'::jsonb);
SELECT public.jdata_insert('product', '{"id": 2, "name": "Product 2", "quantity": 5}'::jsonb);
SELECT public.jdata_update('product', '1', '{"description": "test product"}'::jsonb);

并且可以利用现有索引以多种方式查询他们的数据：

SELECT * FROM public.jdata WHERE table_id = 1 AND (data->>'id') = '1';
SELECT * FROM public.jdata WHERE table_id = 1 AND data @> '{"quantity": 5}'::jsonb;
SELECT * FROM public.jdata WHERE table_id = 1 AND data ? 'description';

视图可以使查询更容易：

CREATE VIEW public.vjdata AS
SELECT d.table_id, t.table_name, (d.data->>'id') AS id, d.data
FROM jtables t
JOIN jdata d USING (table_id);

CREATE OR REPLACE FUNCTION public.vjdata_upsert() RETURNS trigger AS $$
BEGIN
  IF TG_OP = 'INSERT' THEN
    PERFORM public.jdata_insert(NEW.table_name, NEW.data);
  ELSE
    PERFORM public.jdata_update(NEW.table_name, NEW.id, NEW.data);
  END IF;
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER vjdata_upsert_trigger INSTEAD OF INSERT OR UPDATE
  ON public.vjdata FOR EACH ROW EXECUTE PROCEDURE public.vjdata_upsert();

UPDATE public.vjdata SET
  data = data || jsonb_build_object('quantity', (data->>'quantity')::int + 2)
WHERE table_name = 'product' AND id = '2'

SELECT * FROM public.vjdata WHERE table_name = 'product' AND id = '2';

Answer 2

查看PostgREST? BTW，我不知道为什么有人会对存储过程皱眉。与数据库交互的正确方法是通过视图和函数/过程。用纯代码编写 SQL 是过去 15 年才发生的事情，实际上仅仅是因为方便和失去了 SQL 技能。对大多数人来说，集合操作比程序处理更难。