8

短いバージョンは次のとおりです。Spring Data Rest PATCH メソッドを使用して、Postgres フィールドに含まれる JSON オブジェクトにパッチを適用する方法は?jsonb

ここに長いバージョンがあります。次のエンティティを検討してください。

@Entity
@Table(name = "examples")
public class Example {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private long id;

    private String jsonobject;

    @JsonRawValue
    public String getJsonobject() {
        return jsonobject == null ? null : jsonobject;
    }

    public void setJsonobject(JsonNode jsonobject) {
        this.jsonobject = jsonobject == null ? null : jsonobject.toString();
    }
}

jsonobjectPostgres タイプjsonbです。これらのゲッター/セッターは、ここで言及されている Spring Data Rest のためにシリアル化/逆シリアル化する方法です。また、これらの回答に記載されているように、フィールドに独自のタイプを与えようとしました。

私たちの目標は、Spring Data Rest を使用して、このフィールドに含まれる JSON オブジェクトにパッチを適用することです。

例えば：

GET /examples/1
{
    "id": 1,
    "jsonobject": {
         "foo": {"bar": "Hello"},
         "baz": 2
    }
}

PATCH /examples/1
{
    "jsonobject": {
        "foo": {"bar": "Welcome"}
    }
}

期待される出力:

GET /examples/1
{
    "id": 1,
    "jsonobject": {
         "foo": {"bar": "Welcome"},
         "baz": 2
    }
}

現在の出力:

GET /examples/1
{
    "id": 1,
    "jsonobject": {
         "foo": {"bar": "Welcome"}
    }
}

Spring Data Rest は、リクエストされたネストされたプロパティにのみパッチを適用するために JSON オブジェクトのプロパティを掘り下げようとするのではなく、Example リソースにパッチを適用し、リクエストされた各属性の値をオーバーライドします。

これは、Spring Data Rest のapplication/merge-patch+jsonおよびapplication/json-patch+jsonメディア タイプのサポートが役立つと考えたときです。各メディア タイプの出力は次のとおりです。

application/merge-patch+json:

PATCH /examples/1
{
    "jsonobject": {
        "foo": {"bar": "Welcome"}
    }
}

出力：

GET /examples/1
{
    "id": 1,
    "jsonobject": {
         "foo": {"bar": "Welcome"}
    }
}

application/json-patch+json:

PATCH /examples/1
[
    { "op": "replace", "path": "/jsonobject/foo/bar", "value": "Welcome" }
]

出力：

{
    "cause": {
        "cause": null,
        "message": "EL1008E:(pos 8): Property or field 'foo' cannot be found on object of type 'java.lang.String' - maybe not public?"
    },
    "message": "Could not read an object of type class com.example.Example from the request!; nested exception is org.springframework.expression.spel.SpelEvaluationException: EL1008E:(pos 8): Property or field 'foo' cannot be found on object of type 'java.lang.String' - maybe not public?"
}

これは同じ考えに帰着します。エンティティ属性のみが検索され、完全にオーバーライドされるか、見つからないかのいずれかです。

問題は次のとおりです。Spring Data Rest がjsonbフィールドを処理していることを認識し、エンティティ属性を検索するだけでなく、JSON のネストされたプロパティを検索する方法はありますか?

注意:@Embeddable/@Embedded注釈は、ネストされたプロパティ名を知っていることを意味するため、回避される可能性が最も高く、jsonbフィールドへの関心が低下します。

読んでくれてありがとう。

4

2 に答える 2

2

Hibernate 5 が JPA 実装として使用されていることを前提としています

の代わりjsonobjectに、フィールドを特定のクラス タイプ (必要なフィールドを含む) にしStringます。

次に、タイプのカスタム Hibernate ユーザー タイプを追加できjsonbます。

@Entity
@Table(name = "examples")
public class Example {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private long id;

    @Basic
    @Type(type = "com.package.JsonObjectType")
    private JsonObject jsonobject;
}

カスタム型の実装は非常に冗長ですが、基本的には Jackson を使用ObjectMapperしてオブジェクトStringを JDBC ステートメントに渡します (ResultSet から取得する場合はその逆)。

public class JsonObjectType implements UserType {

    private ObjectMapper mapper = new ObjectMapper();

    @Override
    public int[] sqlTypes() {
        return new int[]{Types.JAVA_OBJECT};
    }

    @Override
    public Class<JsonObject> returnedClass() {
        return JsonObject.class;
    }

    @Override
    public Object nullSafeGet(ResultSet rs, String[] names, SharedSessionContractImplementor session, Object owner) throws HibernateException, SQLException {
        final String cellContent = rs.getString(names[0]);
        if (cellContent == null) {
            return null;
        }
        try {
            return mapper.readValue(cellContent.getBytes("UTF-8"), returnedClass());
        } catch (final Exception ex) {
            throw new HibernateException("Failed to convert String to Invoice: " + ex.getMessage(), ex);
        }
    }

    @Override
    public void nullSafeSet(PreparedStatement st, Object value, int index, SharedSessionContractImplementor session) throws HibernateException, SQLException {
        if (value == null) {
            st.setNull(index, Types.OTHER);
            return;
        }
        try {
            final StringWriter w = new StringWriter();
            mapper.writeValue(w, value);
            w.flush();
            st.setObject(index, w.toString(), Types.OTHER);
        } catch (final Exception ex) {
            throw new HibernateException("Failed to convert Invoice to String: " + ex.getMessage(), ex);
        }
    }

    @Override
    public Object deepCopy(final Object value) throws HibernateException {
        try {
            // use serialization to create a deep copy
            ByteArrayOutputStream bos = new ByteArrayOutputStream();
            ObjectOutputStream oos = new ObjectOutputStream(bos);
            oos.writeObject(value);
            oos.flush();
            oos.close();
            bos.close();

            ByteArrayInputStream bais = new ByteArrayInputStream(bos.toByteArray());
            return new ObjectInputStream(bais).readObject();
        } catch (ClassNotFoundException | IOException ex) {
            throw new HibernateException(ex);
        }
    }

    @Override
    public boolean isMutable() {
        return true;
    }

    @Override
    public Serializable disassemble(final Object value) throws HibernateException {
        return (Serializable) this.deepCopy(value);
    }

    @Override
    public Object assemble(final Serializable cached, final Object owner) throws HibernateException {
        return this.deepCopy(cached);
    }

    @Override
    public Object replace(final Object original, final Object target, final Object owner) throws HibernateException {
        return this.deepCopy(original);
    }

    @Override
    public boolean equals(final Object obj1, final Object obj2) throws HibernateException {
        if (obj1 == null) {
            return obj2 == null;
        }
        return obj1.equals(obj2);
    }

    @Override
    public int hashCode(final Object obj) throws HibernateException {
        return obj.hashCode();
    }
}

jsonb最後に、Java オブジェクトをPostgre タイプとして格納するように hibernate に指示する必要があります。これは、カスタム方言クラスを作成する (および構成する) ことを意味します。

public class MyPostgreSQL94Dialect extends PostgreSQL94Dialect {

    public MyPostgreSQL94Dialect() {
        this.registerColumnType(Types.JAVA_OBJECT, "jsonb");
    }
}

これで問題なく、Spring Data Rest パッチ メカニズムが機能するはずです。

PS

Hibernate 4 を使用して、本質的に同じことを行うこのgithub リポジトリに大きく影響された回答をしてください。それを見てください。

于 2016-11-09T23:36:53.020 に答える
2

まあ、あなたの EntityManager は、あなたの jsonObject フィールド内に何らかの構造があることを知りません。これは純粋な文字列です。独自の回避策を実装する必要があります。作業を開始する方法の一例はこちらですhttps://github.com/bazar-nazar/pgjson ただし、このようなアプローチでは、データベースからオブジェクトを読み取るたびに、シリアル化/逆シリアル化のラウンドトリップをもう一度行う必要があります。

ただし、postgresql を使用している場合は、そのすべての機能を使用できます (注: これにより、アプリケーションが postgresql と緊密に結合され、データベースの置き換えが難しくなります)。

簡単な例のように、カスタム jdbc クエリを実装することをお勧めします。

public static class JsonPatchRequest {
    String path;
    String operation;
    String value;
}


@Inject
private JdbcTemplate jdbcTemplate;

@PatchMapping(value = "/example/{id}") 
public void doPatch(@PathVariable("id") Long id, @RequestBody JsonPatchRequest patchRequest) {
    // this line should transform your request path from  "/jsonobject/foo/bar"  to "{foo,bar}" string
    String postgresqlpath = "{" + patchRequest.path.replaceFirst("/jsonobject/", "").replaceAll("/", ",") + "}";

    switch(patchRequest.operation) {
        case "replace" :
            jdbcTemplate.execute("UPDATE example SET jsonobject = jsonb_set(jsonobject, ?, jsonb ?) WHERE id = ?", new PreparedStatementCallback<Void>() {
                @Override
                public Void doInPreparedStatement(PreparedStatement ps) throws SQLException, DataAccessException {
                    ps.setString(1, postgresqlpath);

                    // this one transforms pure value, to string-escaped value (manual workaround)   so  'value' should become '"value"'
                    ps.setString(2, "\"".concat(patchRequest.value).concat("\""));

                    ps.setLong(3, id);

                    ps.execute();
                    return null;
                }
            });
            break;
        case "delete" :
            jdbcTemplate.execute("UPDATE example SET jsonobject = jsonobject #- ? WHERE id = ? ", new PreparedStatementCallback<Void>() {
                @Override
                public Void doInPreparedStatement(PreparedStatement ps) throws SQLException, DataAccessException {
                    ps.setString(1, postgresqlpath);
                    ps.setLong(2, id);
                    ps.execute();
                    return null;
                }
            });
            break;
    }
}

また、注意: 最初のアプローチでは、事前定義された型の jsonobjet フィールドを作成する必要があるため、純粋な正規化されたエンティティに置き換えることができるため、あまり関係ありません。2 番目のアプローチでは、json 内に何らかの構造を持たせる必要はありません。

これがあなたを助けることを願っています。

于 2016-11-09T21:11:35.550 に答える