如何在 JPA 中编写动态 sql 查询以从 jsonb 列中查询数据？

Posted 2023-02-27

【中文标题】如何在 JPA 中编写动态 sql 查询以从 jsonb 列中查询数据？

【英文标题】：How to write dynamic sql query in JPA to query data from jsonb column?

【发布时间】：2021-09-23 05:09:06

【问题描述】：

我想写一个动态 JPA 查询来从 jsonb 列查询数据？

例子：

 recordid |id | typename | useridentifier | value | tags                                                                                                                                                                             

     4793 | 8d7af416-3940-4b7e-9dbb-972b5a31c4fb | AF.ConnectionRecord | z6MkiXvHoNWQEs9RWpLy8mibb9BBQxrsAqiWbZmmAxNBQurq | "Id": "8d7af416-3940-4b7e-9dbb-972b5a31c4fb", "Alias": "Name": "did:dtx:z6Mkw87LmKzcDty6ht5L636kzxHH7DjiTVJuuaGbTMpWYwF9", "State": "Connected", "Endpoint": "uri": "http://127.0.0.1:5000/api/sharedagent/endpoint?identifier=HfrJB5kAtMUdbPEdQU8v9rjHHeTs3c4ZDZMfd5rVdiTm-user", "verkey": ["HfrJB5kAtMUdbPEdQU8v9rjHHeTs3c4ZDZMfd5rVdiTm"], "MiscData": "MyOrgDid": "did:dtx:z6MkiXvHoNWQEs9RWpLy8mibb9BBQxrsAqiWbZmmAxNBQurq", "TheirOrgDid": "did:dtx:z6Mkw87LmKzcDty6ht5L636kzxHH7DjiTVJuuaGbTMpWYwF9", "threadId": "f8a815a5-05ab-4198-8613-a57641cab9ca", "CreatedAtUtc": "2021-07-14T05:25:10.7722507", "UpdatedAtUtc": "2021-07-14T05:28:23.752349" | "MyVk": "HJaPNSqrJm1yCLbibt5YidnMd7CZtZq4VuJNT1G5uwBq", "MyDid": "did:dtx:z6MkvkqRxh6HeJWSJqSRHT3PZjLMSgURJT5RBvDJHHE6q9yD", "State": "Connected", "TheirVk": "Ec4by1o9UVW91kEGRij5Cs2bSEHY3p8wLE2JMAGe4fwW", "TheirDid": "did:dtx:z6Mkt4KeZG3ap2zc8F4y7Hgv3xabFoZPThPJ2EwEBSEeytit", "threadId": "f8a815a5-05ab-4198-8613-a57641cab9ca", "connectionKey": "SQd4RocaX5QJi9TJ2bgpLht5zU8r5YjwZM1xgV2Dbwn", "~CreatedAtUtc": "637618371107722507", "~UpdatedAtUtc": "637618373037523490", "MultiPartyInvitation": "False", "autoAcceptConnection": "true"

现在，我的查询是

select * from nonsecretrecords where typename = 'AF.ConnectionRecord' 
AND useridentifier = 'z6MkiXvHoNWQEs9RWpLy8mibb9BBQxrsAqiWbZmmAxNBQurq' 
AND tags ->> 'MyVk' = 'HJaPNSqrJm1yCLbibt5YidnMd7CZtZq4VuJNT1G5uwBq' 
AND tags ->> 'connectionKey' = 'SQd4RocaX5QJi9TJ2bgpLht5zU8r5YjwZM1xgV2Dbwn';

这里的 'tags' 是一个 jsonb 类型的列，所以我的查询就像上面的一样。 这是一个示例查询，我想创建一个动态查询，这样标签中的部分（此处为“MyVk”和“connectionKey”）将是动态的并且可以更改。

如何使用 Spring JPA 做到这一点？

谢谢

嗨@nikolai

你能提供更多的想法。这是我的服务规范：-

public static Specification<NonSecretRecordEntity> findBySpecification(String typename) 
    return (root, query, builder) -> 
        return builder.equal(root.get("typeName"), typename);
    ;

我想根据“标签”列中的值进行查询，但我还没有为该标签列定义一个类，它是使用 ObjectMapper 的通用类。

【问题讨论】：

看看这个：***.com/questions/57351772/…

嗨@NikolaiShevchenko，我已经编辑了这个问题。能否请您查看并提供更多建议

我已添加答案，请查看

【参考方案1】：

您的规范的新版本如下所示：

public static Specification<NonSecretRecordEntity> findBySpecification(
    String typename, 
    String useridentifier, 
    Map<String, String> tags
) 
    return (root, query, builder) -> 
        List<Predicate> predicates = new ArrayList<>();
        predicates.add(builder.equal(root.get("typeName"), typename));
        predicates.add(builder.equal(root.get("useridentifier"), useridentifier));
        tags.forEach((tagName, tagValue) -> 
            predicates.add(builder.equal(
                builder.function("jsonb_extract_path_text", 
                    String.class, 
                    root.get("tags"), 
                    builder.literal(tagName)),
                tagValue
            ));
        );
        return builder.and(predicates.toArray(new Predicate[0]));
    ;

并被这样使用

String typeName = "AF.ConnectionRecord";
String useridentifier = "z6MkiXvHoNWQEs9RWpLy8mibb9BBQxrsAqiWbZmmAxNBQurq";

Map<String, String> tags = new HashMap<>();
tags.put("MyVk", "HJaPNSqrJm1yCLbibt5YidnMd7CZtZq4VuJNT1G5uwBq");
tags.put("connectionKey", "SQd4RocaX5QJi9TJ2bgpLht5zU8r5YjwZM1xgV2Dbwn");

Specification<NonSecretRecordEntity> spec = findBySpecification(typeName, useridentifier, tags);