public class FunctionalEntityStream extends java.lang.Object implements BulkUpdatable
EntityManager em = ... Listoids = new ArrayList<>(); long[] counter = {0}; em.bulkUpdate(BulkUpdatable.as("TargetEntity").onNext(() -> { //onNextで次の1件のBulkUpdateEntityを返却するように実装 if (counter[0] >= 100) { //処理対象が終了した場合は、nullを返却 return null; } GenericEntity ret = new GenericEntity("TargetEntity"); ret.setName("hoge"); counter[0]++; return new BulkUpdateEntity(UpdateMethod.INSERT, ret); }).onUpdated(bue -> { //onUpdatedは、更新処理後のコールバック処理を記述可能(オプション) oids.add(bue.getEntity().getOid()); }).onClose(() -> { //onCloseは、BulkUpdatableのクローズ処理を記述可能(オプション) doSomething... }));
コンストラクタと説明 |
---|
FunctionalEntityStream() |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
close()
BulkUpdatableのクローズ処理を記述。
|
FunctionalEntityStream |
definitionName(java.lang.String definitionName)
Entityの定義名を指定
|
java.lang.String |
getDefinitionName()
バルク更新対象のEntity定義名を返却するように実装。
|
java.util.List<java.lang.String> |
getUpdateProperties()
バルク更新(UPDATEおよびMERGEで更新と判断された場合)の際の更新対象のプロパティを指定する。
|
java.util.Iterator<BulkUpdateEntity> |
iterator() |
FunctionalEntityStream |
onClose(java.lang.Runnable onClose)
BulkUpdatableのクローズ処理を記述。
|
FunctionalEntityStream |
onNext(java.util.function.Supplier<BulkUpdateEntity> onNext)
BulkUpdateEntityを取得するロジックを記述。
|
FunctionalEntityStream |
onUpdated(java.util.function.Consumer<BulkUpdateEntity> onUpdated)
更新処理成功後のコールバック処理を記述可能。
|
void |
updated(BulkUpdateEntity updatedEntity)
バルク更新対象のEntityの更新処理が成功した場合呼び出されるコールバック。
|
FunctionalEntityStream |
updateProperties(java.lang.String... propName)
更新時の更新対象プロパティを指定
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
as
public FunctionalEntityStream onNext(java.util.function.Supplier<BulkUpdateEntity> onNext)
onNext
- public FunctionalEntityStream definitionName(java.lang.String definitionName)
definitionName
- public FunctionalEntityStream updateProperties(java.lang.String... propName)
propName
- public FunctionalEntityStream onClose(java.lang.Runnable onClose)
onClose
- public FunctionalEntityStream onUpdated(java.util.function.Consumer<BulkUpdateEntity> onUpdated)
onUpdated
- public java.util.Iterator<BulkUpdateEntity> iterator()
iterator
インタフェース内 java.lang.Iterable<BulkUpdateEntity>
public java.lang.String getDefinitionName()
BulkUpdatable
getDefinitionName
インタフェース内 BulkUpdatable
public void updated(BulkUpdateEntity updatedEntity)
BulkUpdatable
updated
インタフェース内 BulkUpdatable
public void close()
BulkUpdatable
close
インタフェース内 java.lang.AutoCloseable
close
インタフェース内 BulkUpdatable
public java.util.List<java.lang.String> getUpdateProperties()
BulkUpdatable
getUpdateProperties
インタフェース内 BulkUpdatable