View Javadoc
1   /*
2    * Copyright 2012-2021 CodeLibs Project and the Others.
3    *
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    *     http://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
13   * either express or implied. See the License for the specific language
14   * governing permissions and limitations under the License.
15   */
16  package org.codelibs.fess.es.config.bsbhv;
17  
18  import java.util.List;
19  import java.util.Map;
20  
21  import org.codelibs.fesen.action.bulk.BulkRequestBuilder;
22  import org.codelibs.fesen.action.delete.DeleteRequestBuilder;
23  import org.codelibs.fesen.action.index.IndexRequestBuilder;
24  import org.codelibs.fess.es.config.allcommon.EsAbstractBehavior;
25  import org.codelibs.fess.es.config.allcommon.EsAbstractEntity.RequestOptionCall;
26  import org.codelibs.fess.es.config.bsentity.dbmeta.ThumbnailQueueDbm;
27  import org.codelibs.fess.es.config.cbean.ThumbnailQueueCB;
28  import org.codelibs.fess.es.config.exentity.ThumbnailQueue;
29  import org.dbflute.Entity;
30  import org.dbflute.bhv.readable.CBCall;
31  import org.dbflute.bhv.readable.EntityRowHandler;
32  import org.dbflute.cbean.ConditionBean;
33  import org.dbflute.cbean.result.ListResultBean;
34  import org.dbflute.cbean.result.PagingResultBean;
35  import org.dbflute.exception.IllegalBehaviorStateException;
36  import org.dbflute.optional.OptionalEntity;
37  import org.dbflute.util.DfTypeUtil;
38  
39  /**
40   * @author ESFlute (using FreeGen)
41   */
42  public abstract class BsThumbnailQueueBhv extends EsAbstractBehavior<ThumbnailQueue, ThumbnailQueueCB> {
43  
44      // ===================================================================================
45      //                                                                    Control Override
46      //                                                                    ================
47      @Override
48      public String asTableDbName() {
49          return asEsIndexType();
50      }
51  
52      @Override
53      protected String asEsIndex() {
54          return ".fess_config.thumbnail_queue";
55      }
56  
57      @Override
58      public String asEsIndexType() {
59          return "thumbnail_queue";
60      }
61  
62      @Override
63      public String asEsSearchType() {
64          return "thumbnail_queue";
65      }
66  
67      @Override
68      public ThumbnailQueueDbm asDBMeta() {
69          return ThumbnailQueueDbm.getInstance();
70      }
71  
72      @Override
73      protected <RESULT extends ThumbnailQueue> RESULT createEntity(Map<String, Object> source, Class<? extends RESULT> entityType) {
74          try {
75              final RESULT result = entityType.newInstance();
76              result.setCreatedBy(DfTypeUtil.toString(source.get("createdBy")));
77              result.setCreatedTime(DfTypeUtil.toLong(source.get("createdTime")));
78              result.setGenerator(DfTypeUtil.toString(source.get("generator")));
79              result.setPath(DfTypeUtil.toString(source.get("path")));
80              result.setTarget(DfTypeUtil.toString(source.get("target")));
81              result.setThumbnailId(DfTypeUtil.toString(source.get("thumbnail_id")));
82              return updateEntity(source, result);
83          } catch (InstantiationException | IllegalAccessException e) {
84              final String msg = "Cannot create a new instance: " + entityType.getName();
85              throw new IllegalBehaviorStateException(msg, e);
86          }
87      }
88  
89      protected <RESULT extends ThumbnailQueue> RESULT updateEntity(Map<String, Object> source, RESULT result) {
90          return result;
91      }
92  
93      // ===================================================================================
94      //                                                                              Select
95      //                                                                              ======
96      public int selectCount(CBCall<ThumbnailQueueCB> cbLambda) {
97          return facadeSelectCount(createCB(cbLambda));
98      }
99  
100     public OptionalEntity<ThumbnailQueue> selectEntity(CBCall<ThumbnailQueueCB> cbLambda) {
101         return facadeSelectEntity(createCB(cbLambda));
102     }
103 
104     protected OptionalEntity<ThumbnailQueue> facadeSelectEntity(ThumbnailQueueCB cb) {
105         return doSelectOptionalEntity(cb, typeOfSelectedEntity());
106     }
107 
108     protected <ENTITY extends ThumbnailQueue> OptionalEntity<ENTITY> doSelectOptionalEntity(ThumbnailQueueCB cb,
109             Class<? extends ENTITY> tp) {
110         return createOptionalEntity(doSelectEntity(cb, tp), cb);
111     }
112 
113     @Override
114     public ThumbnailQueueCB newConditionBean() {
115         return new ThumbnailQueueCB();
116     }
117 
118     @Override
119     protected Entity doReadEntity(ConditionBean cb) {
120         return facadeSelectEntity(downcast(cb)).orElse(null);
121     }
122 
123     public ThumbnailQueue selectEntityWithDeletedCheck(CBCall<ThumbnailQueueCB> cbLambda) {
124         return facadeSelectEntityWithDeletedCheck(createCB(cbLambda));
125     }
126 
127     public OptionalEntity<ThumbnailQueue> selectByPK(String id) {
128         return facadeSelectByPK(id);
129     }
130 
131     protected OptionalEntity<ThumbnailQueue> facadeSelectByPK(String id) {
132         return doSelectOptionalByPK(id, typeOfSelectedEntity());
133     }
134 
135     protected <ENTITY extends ThumbnailQueue> ENTITY doSelectByPK(String id, Class<? extends ENTITY> tp) {
136         return doSelectEntity(xprepareCBAsPK(id), tp);
137     }
138 
139     protected ThumbnailQueueCB xprepareCBAsPK(String id) {
140         assertObjectNotNull("id", id);
141         return newConditionBean().acceptPK(id);
142     }
143 
144     protected <ENTITY extends ThumbnailQueue> OptionalEntity<ENTITY> doSelectOptionalByPK(String id, Class<? extends ENTITY> tp) {
145         return createOptionalEntity(doSelectByPK(id, tp), id);
146     }
147 
148     @Override
149     protected Class<? extends ThumbnailQueue> typeOfSelectedEntity() {
150         return ThumbnailQueue.class;
151     }
152 
153     @Override
154     protected Class<ThumbnailQueue> typeOfHandlingEntity() {
155         return ThumbnailQueue.class;
156     }
157 
158     @Override
159     protected Class<ThumbnailQueueCB> typeOfHandlingConditionBean() {
160         return ThumbnailQueueCB.class;
161     }
162 
163     public ListResultBean<ThumbnailQueue> selectList(CBCall<ThumbnailQueueCB> cbLambda) {
164         return facadeSelectList(createCB(cbLambda));
165     }
166 
167     public PagingResultBean<ThumbnailQueue> selectPage(CBCall<ThumbnailQueueCB> cbLambda) {
168         // #pending same?
169         return (PagingResultBean<ThumbnailQueue>) facadeSelectList(createCB(cbLambda));
170     }
171 
172     public void selectCursor(CBCall<ThumbnailQueueCB> cbLambda, EntityRowHandler<ThumbnailQueue> entityLambda) {
173         facadeSelectCursor(createCB(cbLambda), entityLambda);
174     }
175 
176     public void selectBulk(CBCall<ThumbnailQueueCB> cbLambda, EntityRowHandler<List<ThumbnailQueue>> entityLambda) {
177         delegateSelectBulk(createCB(cbLambda), entityLambda, typeOfSelectedEntity());
178     }
179 
180     // ===================================================================================
181     //                                                                              Update
182     //                                                                              ======
183     public void insert(ThumbnailQueue entity) {
184         doInsert(entity, null);
185     }
186 
187     public void insert(ThumbnailQueue entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
188         entity.asDocMeta().indexOption(opLambda);
189         doInsert(entity, null);
190     }
191 
192     public void update(ThumbnailQueue entity) {
193         doUpdate(entity, null);
194     }
195 
196     public void update(ThumbnailQueue entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
197         entity.asDocMeta().indexOption(opLambda);
198         doUpdate(entity, null);
199     }
200 
201     public void insertOrUpdate(ThumbnailQueue entity) {
202         doInsertOrUpdate(entity, null, null);
203     }
204 
205     public void insertOrUpdate(ThumbnailQueue entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
206         entity.asDocMeta().indexOption(opLambda);
207         doInsertOrUpdate(entity, null, null);
208     }
209 
210     public void delete(ThumbnailQueue entity) {
211         doDelete(entity, null);
212     }
213 
214     public void delete(ThumbnailQueue entity, RequestOptionCall<DeleteRequestBuilder> opLambda) {
215         entity.asDocMeta().deleteOption(opLambda);
216         doDelete(entity, null);
217     }
218 
219     public int queryDelete(CBCall<ThumbnailQueueCB> cbLambda) {
220         return doQueryDelete(createCB(cbLambda), null);
221     }
222 
223     public int[] batchInsert(List<ThumbnailQueue> list) {
224         return batchInsert(list, null, null);
225     }
226 
227     public int[] batchInsert(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call) {
228         return batchInsert(list, call, null);
229     }
230 
231     public int[] batchInsert(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call,
232             RequestOptionCall<IndexRequestBuilder> entityCall) {
233         return doBatchInsert(new BulkList<>(list, call, entityCall), null);
234     }
235 
236     public int[] batchUpdate(List<ThumbnailQueue> list) {
237         return batchUpdate(list, null, null);
238     }
239 
240     public int[] batchUpdate(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call) {
241         return batchUpdate(list, call, null);
242     }
243 
244     public int[] batchUpdate(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call,
245             RequestOptionCall<IndexRequestBuilder> entityCall) {
246         return doBatchUpdate(new BulkList<>(list, call, entityCall), null);
247     }
248 
249     public int[] batchDelete(List<ThumbnailQueue> list) {
250         return batchDelete(list, null, null);
251     }
252 
253     public int[] batchDelete(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call) {
254         return batchDelete(list, call, null);
255     }
256 
257     public int[] batchDelete(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call,
258             RequestOptionCall<IndexRequestBuilder> entityCall) {
259         return doBatchDelete(new BulkList<>(list, call, entityCall), null);
260     }
261 
262     // #pending create, modify, remove
263 }