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 java.lang.Object,REFERRER_CB extends org.dbflute.cbean.ConditionBean,REFERRER_ENTITY extends org.dbflute.Entity>
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.StringbulkTimeoutprotected java.lang.StringdeleteTimeoutprotected java.lang.StringindexTimeoutprotected java.lang.StringrefreshTimeoutprotected java.lang.StringscrollForCursorprotected java.lang.StringscrollForDeleteprotected java.lang.StringscrollSearchTimeoutprotected java.lang.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 java.lang.StringasEsIndex()protected abstract java.lang.StringasEsIndexType()protected abstract java.lang.StringasEsSearchType()protected org.elasticsearch.action.delete.DeleteRequestBuildercreateDeleteRequest(EsAbstractEntity esEntity)protected abstract <RESULT extends ENTITY>
RESULTcreateEntity(java.util.Map<java.lang.String,java.lang.Object> source, java.lang.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, java.util.List<RESULT> selectedList)protected org.dbflute.bhv.writable.UpdateOption<CB>createPlainUpdateOption()protected org.elasticsearch.action.index.IndexRequestBuildercreateUpdateRequest(EsAbstractEntity esEntity)protected int[]delegateBatchDelete(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)protected int[]delegateBatchInsert(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)protected <BUILDER> int[]delegateBatchRequest(java.util.List<? extends org.dbflute.Entity> entityList, java.util.function.Function<EsAbstractEntity,BUILDER> call)protected int[]delegateBatchUpdate(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)protected voiddelegateBulkRequest(org.dbflute.cbean.ConditionBean cb, java.util.function.Function<org.elasticsearch.search.SearchHits,java.lang.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<java.util.List<RESULT>> handler, java.lang.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, java.lang.Class<? extends RESULT> entityType)protected <RESULT extends ENTITY>
RESULTdelegateSelectEntity(org.dbflute.cbean.ConditionBean cb, java.lang.Class<? extends RESULT> entityType)protected <RESULT extends ENTITY>
java.util.List<RESULT>delegateSelectList(org.dbflute.cbean.ConditionBean cb, java.lang.Class<? extends RESULT> entityType)protected intdelegateUpdate(org.dbflute.Entity entity, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)protected voiddeleteScrollContext(java.lang.String scrollId)protected java.lang.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, java.lang.Class<? extends RESULT> entityType, org.dbflute.cbean.coption.CursorSelectOption option)protected booleanisCompatibleBatchInsertDefaultEveryColumn()org.elasticsearch.action.admin.indices.refresh.RefreshResponserefresh()voidsetBulkTimeout(java.lang.String bulkTimeout)voidsetDeleteTimeout(java.lang.String deleteTimeout)voidsetIndexTimeout(java.lang.String indexTimeout)voidsetRefreshTimeout(java.lang.String refreshTimeout)voidsetScrollForCursor(java.lang.String scrollForCursor)voidsetScrollForDelete(java.lang.String scrollForDelete)voidsetScrollSearchTimeout(java.lang.String scrollSearchTimeout)voidsetSearchTimeout(java.lang.String searchTimeout)voidsetSizeForCursor(int sizeForCursor)voidsetSizeForDelete(int sizeForDelete)protected java.util.DatetoDate(java.lang.Object value)protected java.time.LocalDateTimetoLocalDateTime(java.lang.Object value)protected java.util.Map<java.lang.String,java.lang.Object>toSource(EsAbstractEntity esEntity)protected java.lang.String[]toStringArray(java.lang.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 java.lang.String scrollForDelete
-
sizeForCursor
protected int sizeForCursor
-
scrollForCursor
protected java.lang.String scrollForCursor
-
searchTimeout
protected java.lang.String searchTimeout
-
indexTimeout
protected java.lang.String indexTimeout
-
scrollSearchTimeout
protected java.lang.String scrollSearchTimeout
-
bulkTimeout
protected java.lang.String bulkTimeout
-
deleteTimeout
protected java.lang.String deleteTimeout
-
refreshTimeout
protected java.lang.String refreshTimeout
-
-
Method Detail
-
asEsIndex
protected abstract java.lang.String asEsIndex()
-
asEsIndexType
protected abstract java.lang.String asEsIndexType()
-
asEsSearchType
protected abstract java.lang.String asEsSearchType()
-
createEntity
protected abstract <RESULT extends ENTITY> RESULT createEntity(java.util.Map<java.lang.String,java.lang.Object> source, java.lang.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, java.lang.Class<? extends RESULT> entityType)
-
delegateSelectList
protected <RESULT extends ENTITY> java.util.List<RESULT> delegateSelectList(org.dbflute.cbean.ConditionBean cb, java.lang.Class<? extends RESULT> entityType)
-
helpSelectCursorHandlingByPaging
protected <RESULT extends ENTITY> void helpSelectCursorHandlingByPaging(CB cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, java.lang.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, java.lang.Class<? extends RESULT> entityType)
-
delegateSelectBulk
protected <RESULT extends ENTITY> void delegateSelectBulk(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<java.util.List<RESULT>> handler, java.lang.Class<? extends RESULT> entityType)
-
delegateBulkRequest
protected void delegateBulkRequest(org.dbflute.cbean.ConditionBean cb, java.util.function.Function<org.elasticsearch.search.SearchHits,java.lang.Boolean> handler)
-
deleteScrollContext
protected void deleteScrollContext(java.lang.String scrollId)
-
doReadNextVal
protected java.lang.Number doReadNextVal()
-
createListResultBean
protected <RESULT extends org.dbflute.Entity> org.dbflute.cbean.result.ListResultBean<RESULT> createListResultBean(org.dbflute.cbean.ConditionBean cb, java.util.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 java.util.Map<java.lang.String,java.lang.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(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchUpdate
protected int[] delegateBatchUpdate(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchDelete
protected int[] delegateBatchDelete(java.util.List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
-
delegateBatchRequest
protected <BUILDER> int[] delegateBatchRequest(java.util.List<? extends org.dbflute.Entity> entityList, java.util.function.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(java.lang.String scrollForDelete)
-
setSizeForCursor
public void setSizeForCursor(int sizeForCursor)
-
setScrollForCursor
public void setScrollForCursor(java.lang.String scrollForCursor)
-
setSearchTimeout
public void setSearchTimeout(java.lang.String searchTimeout)
-
setIndexTimeout
public void setIndexTimeout(java.lang.String indexTimeout)
-
setScrollSearchTimeout
public void setScrollSearchTimeout(java.lang.String scrollSearchTimeout)
-
setBulkTimeout
public void setBulkTimeout(java.lang.String bulkTimeout)
-
setDeleteTimeout
public void setDeleteTimeout(java.lang.String deleteTimeout)
-
setRefreshTimeout
public void setRefreshTimeout(java.lang.String refreshTimeout)
-
toStringArray
protected java.lang.String[] toStringArray(java.lang.Object value)
-
toLocalDateTime
protected java.time.LocalDateTime toLocalDateTime(java.lang.Object value)
-
toDate
protected java.util.Date toDate(java.lang.Object value)
-
getSearchHits
protected org.elasticsearch.search.SearchHits getSearchHits(org.elasticsearch.action.search.SearchResponse response)
-
-