Class EsAbstractBehavior<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>
- java.lang.Object
-
- org.dbflute.bhv.AbstractBehaviorReadable<ENTITY,CB>
-
- org.dbflute.bhv.AbstractBehaviorWritable<ENTITY,CB>
-
- org.codelibs.fess.es.log.allcommon.EsAbstractBehavior<ENTITY,CB>
-
- Type Parameters:
ENTITY- The type of entity.CB- The type of condition-bean.
- All Implemented Interfaces:
org.dbflute.bhv.BehaviorReadable,org.dbflute.bhv.BehaviorWritable
- Direct Known Subclasses:
BsClickLogBhv,BsFavoriteLogBhv,BsSearchLogBhv,BsUserInfoBhv
public abstract class EsAbstractBehavior<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean> extends org.dbflute.bhv.AbstractBehaviorWritable<ENTITY,CB>- Author:
- ESFlute (using FreeGen)
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classEsAbstractBehavior.BulkList<E,B>-
Nested classes/interfaces inherited from class org.dbflute.bhv.AbstractBehaviorReadable
org.dbflute.bhv.AbstractBehaviorReadable.InternalLoadReferrerCallback<LOCAL_ENTITY extends org.dbflute.Entity,PK extends Object,REFERRER_CB extends org.dbflute.cbean.ConditionBean,REFERRER_ENTITY extends org.dbflute.Entity>
-
-
Field Summary
Fields Modifier and Type Field Description protected StringbulkTimeoutprotected StringdeleteTimeoutprotected StringindexTimeoutprotected StringrefreshTimeoutprotected StringscrollForCursorprotected StringscrollForDeleteprotected StringscrollSearchTimeoutprotected StringsearchTimeoutprotected intsizeForCursorprotected intsizeForDelete
-
Constructor Summary
Constructors Constructor Description EsAbstractBehavior()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract StringasEsIndex()protected abstract StringasEsIndexType()protected abstract StringasEsSearchType()protected org.elasticsearch.action.delete.DeleteRequestBuildercreateDeleteRequest(EsAbstractEntity esEntity)protected abstract <RESULT extends ENTITY>
RESULTcreateEntity(Map<String,Object> source, Class<? extends RESULT> entityType)protected org.elasticsearch.action.index.IndexRequestBuildercreateInsertRequest(EsAbstractEntity esEntity)protected <RESULT extends org.dbflute.Entity>
org.dbflute.cbean.result.ListResultBean<RESULT>createListResultBean(org.dbflute.cbean.ConditionBean cb, List<RESULT> selectedList)protected org.dbflute.bhv.writable.UpdateOption<CB>createPlainUpdateOption()protected org.elasticsearch.action.index.IndexRequestBuildercreateUpdateRequest(EsAbstractEntity esEntity)protected int[]delegateBatchDelete(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)protected int[]delegateBatchInsert(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)protected <BUILDER> int[]delegateBatchRequest(List<? extends org.dbflute.Entity> entityList, Function<EsAbstractEntity,BUILDER> call)protected int[]delegateBatchUpdate(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)protected voiddelegateBulkRequest(org.dbflute.cbean.ConditionBean cb, Function<org.elasticsearch.search.SearchHits,Boolean> handler)protected intdelegateDelete(org.dbflute.Entity entity, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)protected intdelegateInsert(org.dbflute.Entity entity, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)protected intdelegateQueryDelete(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)protected <RESULT extends ENTITY>
voiddelegateSelectBulk(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<List<RESULT>> handler, Class<? extends RESULT> entityType)protected intdelegateSelectCountUniquely(org.dbflute.cbean.ConditionBean cb)protected <RESULT extends ENTITY>
voiddelegateSelectCursor(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType)protected <RESULT extends ENTITY>
RESULTdelegateSelectEntity(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)protected <RESULT extends ENTITY>
List<RESULT>delegateSelectList(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)protected intdelegateUpdate(org.dbflute.Entity entity, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)protected voiddeleteScrollContext(String scrollId)protected NumberdoReadNextVal()protected org.elasticsearch.search.SearchHitsgetSearchHits(org.elasticsearch.action.search.SearchResponse response)protected <RESULT extends ENTITY>
voidhelpSelectCursorHandlingByPaging(CB cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType, org.dbflute.cbean.coption.CursorSelectOption option)protected booleanisCompatibleBatchInsertDefaultEveryColumn()org.elasticsearch.action.admin.indices.refresh.RefreshResponserefresh()voidsetBulkTimeout(String bulkTimeout)voidsetDeleteTimeout(String deleteTimeout)voidsetIndexTimeout(String indexTimeout)voidsetRefreshTimeout(String refreshTimeout)voidsetScrollForCursor(String scrollForCursor)voidsetScrollForDelete(String scrollForDelete)voidsetScrollSearchTimeout(String scrollSearchTimeout)voidsetSearchTimeout(String searchTimeout)voidsetSizeForCursor(int sizeForCursor)voidsetSizeForDelete(int sizeForDelete)protected DatetoDate(Object value)protected LocalDateTimetoLocalDateTime(Object value)protected Map<String,Object>toSource(EsAbstractEntity esEntity)protected String[]toStringArray(Object value)-
Methods inherited from class org.dbflute.bhv.AbstractBehaviorWritable
adjustEntityBeforeDelete, adjustEntityBeforeInsert, adjustEntityBeforeQueryDelete, adjustEntityBeforeQueryInsert, adjustEntityBeforeQueryUpdate, adjustEntityBeforeUpdate, adjustEntityListBeforeBatchDelete, adjustEntityListBeforeBatchInsert, adjustEntityListBeforeBatchUpdate, assertDeleteOpCallNotNull, assertDeleteOptionStatus, assertEntityHasOptimisticLockValue, assertEntityHasUpdateDateValue, assertEntityHasVersionNoValue, assertEntityOfDelete, assertEntityOfInsert, assertEntityOfUpdate, assertInsertOpCallNotNull, assertInsertOptionStatus, assertQueryDeleteStatus, assertQueryUpdateStatus, assertUpdateColumnSpecificationNotNull, assertUpdateOpCallNotNull, assertUpdateOptionStatus, checkCountBeforeQueryUpdateIfNeeds, create, createBatchDeleteCommand, createBatchDeleteNonstrictCommand, createBatchInsertCommand, createBatchUpdateCommand, createBatchUpdateNonstrictCommand, createCBForQueryInsert, createCBForSpecifiedUpdate, createCBForVaryingUpdate, createDeleteEntityCommand, createDeleteNonstrictEntityCommand, createDeleteOption, createInsertOption, createOptionalCause, createOptionalDeleteOption, createOptionalUpdateOption, createOrModify, createOrModifyNonstrict, createPlainInsertOption, createQueryDeleteCBCommand, createQueryInsertCBCommand, createQueryUpdateCBCommand, createSpecifiedUpdateOption, createUpdateEntityCommand, createUpdateNonstrictEntityCommand, createUpdateOption, delegateBatchDeleteNonstrict, delegateBatchUpdateNonstrict, delegateDeleteNonstrict, delegateQueryInsert, delegateQueryUpdate, delegateUpdateNonstrict, doBatchDelete, doBatchDeleteNonstrict, doBatchInsert, doBatchUpdate, doBatchUpdateNonstrict, doCreate, doCreateOrModify, doCreateOrModifyNonstrict, doDelete, doDeleteNonstrict, doInsert, doInsertOrUpdate, doInsertOrUpdateNonstrict, doLumpCreate, doLumpModify, doLumpModifyNonstrict, doLumpRemove, doLumpRemoveNonstrict, doModify, doModifyNonstrict, doQueryDelete, doQueryInsert, doQueryUpdate, doRangeCreate, doRangeModify, doRangeRemove, doRemove, doRemoveNonstrict, doUpdate, doUpdateNonstrict, downcast, downcast, downcast, downcast, emptyOpt, filterEntityOfDelete, filterEntityOfInsert, filterEntityOfUpdate, frameworkFilterEntityOfDelete, frameworkFilterEntityOfInsert, frameworkFilterEntityOfUpdate, getCommonColumnAutoSetupper, helpDeleteInternally, helpDeleteNonstrictIgnoreDeletedInternally, helpDeleteNonstrictInternally, helpDetermineInsertOrUpdateDirectInsert, helpInsertOrUpdateInternally, helpInsertOrUpdateNonstrictInternally, helpReloadPrimaryKeyIfUniqueByIfNeeds, helpUpdateInternally, helpUpdateNonstrictInternally, hookBeforeDelete, hookBeforeInsert, hookBeforeUpdate, hookFinallyDelete, hookFinallyInsert, hookFinallyUpdate, injectSequenceToPrimaryKeyIfNeeds, isBatchInsertColumnModifiedPropertiesFragmentedDisallowed, isBatchUpdateColumnModifiedPropertiesFragmentedAllowed, isCompatibleBatchUpdateDefaultEveryColumn, lumpCreate, lumpModify, lumpModifyNonstrict, lumpRemove, lumpRemoveNonstrict, modify, modifyNonstrict, newBatchDeleteCommand, newBatchDeleteNonstrictCommand, newBatchInsertCommand, newBatchUpdateCommand, newBatchUpdateNonstrictCommand, newDeleteEntityCommand, newDeleteNonstrictEntityCommand, newDeleteOption, newInsertOption, newUpdateEntityCommand, newUpdateNonstrictEntityCommand, newUpdateOption, prepareBatchInsertOption, prepareBatchUpdateOption, prepareDeleteOption, prepareEntityDelete, prepareEntityDeleteOption, prepareEntityUpdate, prepareEntityUpdateOption, prepareInsertOption, prepareUpdateOption, rangeCreate, rangeModify, rangeRemove, reflectUniqueDriven, remove, removeNonstrict, setCommonColumnAutoSetupper, setupCommonColumnOfInsertIfNeeds, setupCommonColumnOfUpdateIfNeeds, setupExclusiveControlColumnOfQueryInsert, setupListEntityCommand, throwUpdateDateValueNullException, throwUpdateEntityAlreadyDeletedException, throwUpdateEntityDuplicatedException, throwVersionNoValueNullException
-
Methods inherited from class org.dbflute.bhv.AbstractBehaviorReadable
assertBehaviorCommandInvoker, assertCBCallNotNull, assertCBNotDreamCruise, assertCBNotNull, assertCBStateValid, assertConditionBeanSelectResource, assertEntityListNotNull, assertEntityNotDeleted, assertEntityNotNull, assertEntityNotNullAndHasPrimaryKeyValue, assertListNotNullAndEmpty, assertListNotNullAndHasOnlyOne, assertListNotNullAndNotEmpty, assertObjectNotNull, assertSpecifyDerivedReferrerEntityProperty, assertStringNotNullAndNotTrimmedEmpty, createBhvExThrower, createCB, createCBExThrower, createExceptionMessageBuilder, createHpSLSExecutor, createInsertEntityCommand, createOptionalEntity, createOptionalInsertOption, createPagingHandler, createPagingInvoker, createSelectCountCBCommand, createSelectCursorCBCommand, createSelectEntityCBCommand, createSelectListCBCommand, createSelectNextValCommand, createSelectNextValSubCommand, createSelectScalarCBCommand, createSLSFunction, delegateInsertNoPK, delegateSelectCountPlainly, delegateSelectNextVal, delegateSelectNextValSub, doHelpLoadReferrerInternally, doHelpLoadReferrerInternally, doOutsideSql, doReadCount, doReadEntity, doReadEntityWithDeletedCheck, doReadList, doReadPage, doReadScalar, doScalarSelect, doSelectCountPlainly, doSelectCountUniquely, doSelectCursor, doSelectEntity, doSelectEntityWithDeletedCheck, doSelectList, doSelectPage, downcast, downcast, downcast, facadeScalarSelect, facadeSelectCount, facadeSelectCursor, facadeSelectEntityWithDeletedCheck, facadeSelectList, facadeSelectPage, getBehaviorCommandInvoker, getBehaviorSelector, hasUpdateDateValue, hasVersionNoValue, helpConditionBeanDowncastInternally, helpEntityDowncastInternally, helpExtractListInternally, helpExtractSetInternally, helpLoadReferrerInternally, helpLoadReferrerInternally, helpPulloutInternally, helpSelectCursorCheckingByPagingAllowed, helpSelectCursorCheckingOrderByPK, helpSelectCursorInternally, helpSelectEntityInternally, helpSelectEntityWithDeletedCheckInternally, helpSelectListInternally, helpSelectPageInternally, invoke, isEntityDerivedMappable, isRelationOptional, ln, newConditionBean, newEntity, newInsertEntityCommand, newSelectCountCBCommand, newSelectCursorCBCommand, newSelectEntityCBCommand, newSelectListCBCommand, newSelectNextValCommand, newSelectNextValSubCommand, newSelectScalarCBCommand, newSLSFunction, readCount, readCursor, readEntity, readEntityWithDeletedCheck, readList, readNextVal, readPage, readScalar, readyOutsideSql, setBehaviorCommandInvoker, setBehaviorSelector, throwSelectEntityAlreadyDeletedException, throwSelectEntityConditionNotFoundException, throwSelectEntityDuplicatedException, throwSpecifyDerivedReferrerEntityPropertyNotFoundException, toLoadReferrerMappingKey, toLowerCaseIfString, toRelationOptional, typeOfHandlingConditionBean, typeOfHandlingEntity, typeOfSelectedEntity, warmUpCommand, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xbuildReferrerCorrelatedFixedCondition, xcheckSafetyResultAsOne, xconvertFK2PKImplicitly, xconvertToRelationOptionalEntityIfNeeds, xcreateLoadReferrerCallback, xcreateLoadReferrerCallback, xdoBuildReferrerCorrelatedFixedCondition, xdoHelpExtractSetInternally, xextractPulloutForeignEntity, xextractPulloutReverseWrittenObject, xfindReferrerBehavior, xgetBSFLR, xgetROpFactory, xnewLoadReferrerCompoundKeyMap, xnewLRAryLs, xnewLRLs, xpreparePulloutResultList, xrestoreSafetyResult, xsavePulloutForeignEntity, xsetupEntityCommand, xsetupSelectCommand
-
-
-
-
Field Detail
-
sizeForDelete
protected int sizeForDelete
-
scrollForDelete
protected String scrollForDelete
-
sizeForCursor
protected int sizeForCursor
-
scrollForCursor
protected String scrollForCursor
-
searchTimeout
protected String searchTimeout
-
indexTimeout
protected String indexTimeout
-
scrollSearchTimeout
protected String scrollSearchTimeout
-
bulkTimeout
protected String bulkTimeout
-
deleteTimeout
protected String deleteTimeout
-
refreshTimeout
protected String refreshTimeout
-
-
Method Detail
-
asEsIndex
protected abstract String asEsIndex()
-
asEsIndexType
protected abstract String asEsIndexType()
-
asEsSearchType
protected abstract String asEsSearchType()
-
createEntity
protected abstract <RESULT extends ENTITY> RESULT createEntity(Map<String,Object> source, Class<? extends RESULT> entityType)
-
refresh
public org.elasticsearch.action.admin.indices.refresh.RefreshResponse refresh()
-
delegateSelectCountUniquely
protected int delegateSelectCountUniquely(org.dbflute.cbean.ConditionBean cb)
-
delegateSelectEntity
protected <RESULT extends ENTITY> RESULT delegateSelectEntity(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
-
delegateSelectList
protected <RESULT extends ENTITY> List<RESULT> delegateSelectList(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
-
helpSelectCursorHandlingByPaging
protected <RESULT extends ENTITY> void helpSelectCursorHandlingByPaging(CB cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType, org.dbflute.cbean.coption.CursorSelectOption option)
-
delegateSelectCursor
protected <RESULT extends ENTITY> void delegateSelectCursor(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType)
-
delegateSelectBulk
protected <RESULT extends ENTITY> void delegateSelectBulk(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<List<RESULT>> handler, Class<? extends RESULT> entityType)
-
delegateBulkRequest
protected void delegateBulkRequest(org.dbflute.cbean.ConditionBean cb, Function<org.elasticsearch.search.SearchHits,Boolean> handler)
-
deleteScrollContext
protected void deleteScrollContext(String scrollId)
-
doReadNextVal
protected Number doReadNextVal()
-
createListResultBean
protected <RESULT extends org.dbflute.Entity> org.dbflute.cbean.result.ListResultBean<RESULT> createListResultBean(org.dbflute.cbean.ConditionBean cb, List<RESULT> selectedList)
-
delegateInsert
protected int delegateInsert(org.dbflute.Entity entity, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
-
createInsertRequest
protected org.elasticsearch.action.index.IndexRequestBuilder createInsertRequest(EsAbstractEntity esEntity)
-
delegateUpdate
protected int delegateUpdate(org.dbflute.Entity entity, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
-
createUpdateRequest
protected org.elasticsearch.action.index.IndexRequestBuilder createUpdateRequest(EsAbstractEntity esEntity)
-
toSource
protected Map<String,Object> toSource(EsAbstractEntity esEntity)
-
delegateDelete
protected int delegateDelete(org.dbflute.Entity entity, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
-
createDeleteRequest
protected org.elasticsearch.action.delete.DeleteRequestBuilder createDeleteRequest(EsAbstractEntity esEntity)
-
delegateQueryDelete
protected int delegateQueryDelete(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchInsert
protected int[] delegateBatchInsert(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchUpdate
protected int[] delegateBatchUpdate(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchDelete
protected int[] delegateBatchDelete(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchRequest
protected <BUILDER> int[] delegateBatchRequest(List<? extends org.dbflute.Entity> entityList, Function<EsAbstractEntity,BUILDER> call)
-
createPlainUpdateOption
protected org.dbflute.bhv.writable.UpdateOption<CB> createPlainUpdateOption()
-
isCompatibleBatchInsertDefaultEveryColumn
protected boolean isCompatibleBatchInsertDefaultEveryColumn()
-
setSizeForDelete
public void setSizeForDelete(int sizeForDelete)
-
setScrollForDelete
public void setScrollForDelete(String scrollForDelete)
-
setSizeForCursor
public void setSizeForCursor(int sizeForCursor)
-
setScrollForCursor
public void setScrollForCursor(String scrollForCursor)
-
setSearchTimeout
public void setSearchTimeout(String searchTimeout)
-
setIndexTimeout
public void setIndexTimeout(String indexTimeout)
-
setScrollSearchTimeout
public void setScrollSearchTimeout(String scrollSearchTimeout)
-
setBulkTimeout
public void setBulkTimeout(String bulkTimeout)
-
setDeleteTimeout
public void setDeleteTimeout(String deleteTimeout)
-
setRefreshTimeout
public void setRefreshTimeout(String refreshTimeout)
-
toLocalDateTime
protected LocalDateTime toLocalDateTime(Object value)
-
getSearchHits
protected org.elasticsearch.search.SearchHits getSearchHits(org.elasticsearch.action.search.SearchResponse response)
-
-