PG语法更新与删除

更新接口

PG语法更新提供同步和异步两个接口，只支持单条Query。

• 不支持部分字段更新

• valueMap要求表schema中除pkey、skey外的全部字段，否则更新无效

// 同步更新接口，无返回值
public void updateSync(@NonNull UpdateSessionCtx updateSessionCtx, @NonNull UpdateQuery updateQuery)

// 异步更新接口，返回CompletableFuture
public CompletableFuture updateAsync(@NonNull UpdateSessionCtx updateSessionCtx, @NonNull UpdateQuery updateQuery)

• 其中，UpdateSessionCtx 用来设定和记录单次查询的信息：

• updateSessionCtx.getUpdateConfig() 用于支持一些 query 级别的定制化参数

• updateSessionCtx.getRequestContext() 用于在更新后获得更新中的一些信息

同步更新接口

一个简单的同步更新示例

UpdateSessionCtx updateSessionCtx = new UpdateSessionCtx();
try {
    abfsClient.updateSync(updateSessionCtx, updateQuery);
} catch (Exception e) {
    log.error("update failed", e);
    return;
}

异步更新接口

一个简单的异步更新示例

CompletableFuture future;
UpdateSessionCtx updateSessionCtx = new UpdateSessionCtx();
try {
    future = abfsClient.updateAsync(updateSessionCtx, updateQuery);
} catch (Exception e) {
    log.error("update failed", e);
    return;
}

删除接口

PG语法删除提供同步和异步两个接口，只支持单条Query。

• kv 表只需指定 pkey 即可删除

• kkv 表只指定 pkey，会删除 pkey 下的所有 skey 的内容

• kkv 表指定 pkey + skey, 会删除对应的一条记录

// 同步删除接口，无返回值
public void deleteSync(@NonNull UpdateSessionCtx updateSessionCtx, @NonNull UpdateQuery updateQuery)

// 异步删除接口，返回CompletableFuture
public CompletableFuture deleteAsync(@NonNull UpdateSessionCtx updateSessionCtx, @NonNull UpdateQuery updateQuery)

同步删除接口

一个简单的同步删除示例

UpdateQuery deleteQuery = UpdateQuery.builder()
                .table("your_table_name")
                .pkey("your_pkey")
                .build();
UpdateSessionCtx updateSessionCtx = new UpdateSessionCtx();
try {
    abfsClient.deleteSync(updateSessionCtx, deleteQuery);
} catch (Exception e) {
    log.error("update failed", e);
    return;
}

异步删除接口

一个简单的异步删除示例

CompletableFuture future;
UpdateSessionCtx updateSessionCtx = new UpdateSessionCtx();
try {
    future = abfsClient.deleteSync(updateSessionCtx, deleteQuery);
} catch (Exception e) {
    log.error("update failed", e);
    return;
}