在带有 Sequelize 的子查询中使用带有绑定参数的 EXISTS

Question

假设我有一个 table 类似汽车的东西，其中有一个 JSONB 对象指定可能的自定义：

+----+-----------------------------------------+
| id | customizations JSONB                    |
+----+-----------------------------------------+
| 1  | {"color": "blue", "lights": "led", ...} |
+----+-----------------------------------------+
| 2  | {"color": "red"}                        |
+----+-----------------------------------------+
| 3  | {}                                      |
+----+-----------------------------------------+

如果我想根据不区分大小写的值或部分值（即 ILIKE）查询某个自定义项，我可以这样做：

SELECT * FROM "Cars" WHERE EXISTS (
  SELECT 1 FROM JSONB_EACH_TEXT("customizations") WHERE "value" ~* 'BLU'
);

此模式在 Postgres 中运行良好，但现在我正在尝试尽我所能将其转换为 Sequelize。这里重要的是搜索词（示例中的'BLU'）作为参数传递。

const cars = await cars.findAll({
  where: // ????  Maybe something like db.fn('EXISTS', ...), but how do I bind the parameter?
});

如何在此处使用 EXISTS 查询，但绑定参数？我知道我 could use db.literal()，但如果我这样做，我必须在将搜索词字符串插入到查询之前自行转义搜索词字符串。（至少有一个合适的方法在 Sequelize 中进行数据转义吗？）

请注意customizations中的JSONB对象可以有多个键，一个键，甚至没有键。

悬赏说明： 使用现代版本的 Postgres 的答案很好，但我还想要 PostgreSQL v10.12 的答案，因为这就是 AWS Aurora Serverless 提供的所有内容.我很乐意为这两个答案分别分配赏金！

Answer 1

如果你这样修改你的条件：

SELECT * FROM "Cars" WHERE (
  SELECT "value" FROM JSONB_EACH_TEXT("customizations")) ~* 'BLU'

那么您可以将 Sequelize.where 与 Sequelize.literal 结合使用：

where: Sequelize.where(
Sequelize.literal('(SELECT "value" FROM JSONB_EACH_TEXT("customizations"))'),
Op.iRegexp,
'BLU'
)

更新此解决方案仅在子查询 returns 1 条记录时有效。

Answer 2

如果在 postgresql 12+ 上，可以使用 json 路径表达式来提取所有值并转换为文本以便正则表达式匹配

原始查询是

SELECT *
FROM cars
WHERE jsonb_path_query_array(customizations, '$.*')::TEXT ~* 'BLU'

在续集中：

where: Sequelize.where(
  Sequelize.literal("jsonb_path_query_array(customizations, '$.*')::TEXT"),
  Op.iRegexp,
  'BLU'
)

在旧版本中，我可能会使用带有绑定参数的原始查询映射回 Car 对象。

How can I use an EXISTS query here, but bind a parameter? I know I could use db.literal(), but if I did that, I'd have to escape the search term string myself before interpolating it into the query. (Is there at least a proper method for doing this data escaping in Sequelize?)

您可以使用 </code> 或 <code>$name 为位置（数组）和命名（对象）参数将参数绑定到原始 sql 查询。

// cars.js
const Sequelize = require('sequelize');

const path = 'postgresql://hal:hal@localhost:5432/hal'

const sequelize = new Sequelize(path);

let Car = sequelize.define('cars', {
        id: { type: Sequelize.INTEGER, primaryKey: true },
        customizations: Sequelize.JSONB
});

let cars = [{ id: 1, customizations: {color: "blue", lights: "led"} },
            { id: 2, customizations: {color: "red"} },
            { id: 3, customizations: {} }]


const search_pat = 'BLU';

const stmt = `
select distinct cars.*
from cars, jsonb_each_text(customizations) kv(kk, vv)
where vv ~* $search_pattern
`;

sequelize
    .sync()
    .then(() => {
        Car.bulkCreate(cars)
    })
    .then(() => {
        sequelize.query(stmt, {
            bind: {search_pattern: search_pat},
            type: sequelize.QueryTypes.SELECT,
            model: Car,
            mapToModel: true
        }).then(cars => {console.log(cars);})
});

执行此脚本 (node cars.js) 会产生以下输出：

Executing (default): CREATE TABLE IF NOT EXISTS "cars" ("id" INTEGER , "customizations" JSONB, "createdAt" TIMESTAMP WITH TIME ZONE NOT NULL, "updatedAt" TIMESTAMP WITH TIME ZONE NOT NULL, PRIMARY KEY ("id"));
Executing (default): SELECT i.relname AS name, ix.indisprimary AS primary, ix.indisunique AS unique, ix.indkey AS indkey, array_agg(a.attnum) as column_indexes, array_agg(a.attname) AS column_names, pg_get_indexdef(ix.indexrelid) AS definition 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 t.relkind = 'r' and t.relname = 'cars' GROUP BY i.relname, ix.indexrelid, ix.indisprimary, ix.indisunique, ix.indkey ORDER BY i.relname;
Executing (default): INSERT INTO "cars" ("id","customizations","createdAt","updatedAt") VALUES (1,'{"color":"blue","lights":"led"}','2021-04-14 04:42:50.446 +00:00','2021-04-14 04:42:50.446 +00:00'),(2,'{"color":"red"}','2021-04-14 04:42:50.446 +00:00','2021-04-14 04:42:50.446 +00:00'),(3,'{}','2021-04-14 04:42:50.446 +00:00','2021-04-14 04:42:50.446 +00:00') RETURNING "id","customizations","createdAt","updatedAt";
Executing (default): select distinct cars.*
from cars, jsonb_each_text(customizations) kv(kk, vv)
where vv ~* 
[
  cars {
    dataValues: {
      id: 1,
      customizations: [Object],
      createdAt: 2021-04-14T04:42:50.446Z,
      updatedAt: 2021-04-14T04:42:50.446Z
    },
    _previousDataValues: {
      id: 1,
      customizations: [Object],
      createdAt: 2021-04-14T04:42:50.446Z,
      updatedAt: 2021-04-14T04:42:50.446Z
    },
    _changed: Set(0) {},
    _options: {
      isNewRecord: false,
      _schema: null,
      _schemaDelimiter: '',
      raw: true,
      attributes: undefined
    },
    isNewRecord: false
  }
]

请注意，我使用了替代方法（在上面的示例中 select 语句可能效率较低）

您可以使用您的原始查询，IMO 是针对目标 postgresql 版本 (10.x) 的最直接查询，即

const stmt = `
SELECT * 
FROM cars 
WHERE EXISTS (
  SELECT 1 
  FROM JSONB_EACH_TEXT(customizations) WHERE "value" ~* $search_pattern
)
`;

在带有 Sequelize 的子查询中使用带有绑定参数的 EXISTS

Using EXISTS with bound parameters in sub-query with Sequelize

postgresql

node.js

sequelize.js

jsonb