1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.codelibs.fess.es.log.cbean.bs;
17
18 import java.util.ArrayList;
19 import java.util.List;
20 import java.util.Map;
21
22 import org.codelibs.fesen.action.search.SearchRequestBuilder;
23 import org.codelibs.fesen.index.query.QueryBuilder;
24 import org.codelibs.fess.es.log.allcommon.EsAbstractConditionBean;
25 import org.codelibs.fess.es.log.bsentity.dbmeta.SearchLogDbm;
26 import org.codelibs.fess.es.log.cbean.SearchLogCB;
27 import org.codelibs.fess.es.log.cbean.ca.SearchLogCA;
28 import org.codelibs.fess.es.log.cbean.ca.bs.BsSearchLogCA;
29 import org.codelibs.fess.es.log.cbean.cq.SearchLogCQ;
30 import org.codelibs.fess.es.log.cbean.cq.bs.BsSearchLogCQ;
31 import org.dbflute.cbean.ConditionQuery;
32
33
34
35
36 public class BsSearchLogCB extends EsAbstractConditionBean {
37
38
39
40
41 protected BsSearchLogCQ _conditionQuery;
42 protected BsSearchLogCA _conditionAggregation;
43 protected HpSpecification _specification;
44
45
46
47
48 @Override
49 public SearchLogDbm asDBMeta() {
50 return SearchLogDbm.getInstance();
51 }
52
53 @Override
54 public String asTableDbName() {
55 return "search_log";
56 }
57
58 @Override
59 public boolean hasSpecifiedColumn() {
60 return _specification != null;
61 }
62
63 @Override
64 public ConditionQuery localCQ() {
65 return doGetConditionQuery();
66 }
67
68
69
70
71 public SearchLogCB acceptPK(String id) {
72 assertObjectNotNull("id", id);
73 BsSearchLogCB cb = this;
74 cb.query().docMeta().setId_Equal(id);
75 return (SearchLogCB) this;
76 }
77
78 @Override
79 public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
80 acceptPK((String) primaryKeyMap.get("_id"));
81 }
82
83
84
85
86
87 @Override
88 public SearchRequestBuilder build(SearchRequestBuilder builder) {
89 if (_conditionQuery != null) {
90 QueryBuilder queryBuilder = _conditionQuery.getQuery();
91 if (queryBuilder != null) {
92 builder.setQuery(queryBuilder);
93 }
94 _conditionQuery.getFieldSortBuilderList().forEach(sort -> {
95 builder.addSort(sort);
96 });
97 }
98
99 if (_conditionAggregation != null) {
100 _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation);
101 }
102
103 if (_specification != null) {
104 builder.setFetchSource(_specification.columnList.toArray(new String[_specification.columnList.size()]), null);
105 }
106
107 return builder;
108 }
109
110
111
112
113 public BsSearchLogCQ query() {
114 assertQueryPurpose();
115 return doGetConditionQuery();
116 }
117
118 protected BsSearchLogCQ doGetConditionQuery() {
119 if (_conditionQuery == null) {
120 _conditionQuery = createLocalCQ();
121 }
122 return _conditionQuery;
123 }
124
125 protected BsSearchLogCQ createLocalCQ() {
126 return new SearchLogCQ();
127 }
128
129
130
131
132 public BsSearchLogCA aggregation() {
133 assertAggregationPurpose();
134 return doGetConditionAggregation();
135 }
136
137 protected BsSearchLogCA doGetConditionAggregation() {
138 if (_conditionAggregation == null) {
139 _conditionAggregation = createLocalCA();
140 }
141 return _conditionAggregation;
142 }
143
144 protected BsSearchLogCA createLocalCA() {
145 return new SearchLogCA();
146 }
147
148
149
150
151 public HpSpecification specify() {
152 assertSpecifyPurpose();
153 if (_specification == null) {
154 _specification = new HpSpecification();
155 }
156 return _specification;
157 }
158
159 protected void assertQueryPurpose() {
160 }
161
162 protected void assertAggregationPurpose() {
163 }
164
165 protected void assertSpecifyPurpose() {
166 }
167
168 public static class HpSpecification {
169 protected List<String> columnList = new ArrayList<>();
170
171 private void doColumn(String name) {
172 columnList.add(name);
173 }
174
175 public void columnId() {
176 doColumn("_id");
177 }
178
179 public void columnAccessType() {
180 doColumn("accessType");
181 }
182
183 public void columnClientIp() {
184 doColumn("clientIp");
185 }
186
187 public void columnHitCount() {
188 doColumn("hitCount");
189 }
190
191 public void columnHitCountRelation() {
192 doColumn("hitCountRelation");
193 }
194
195 public void columnLanguages() {
196 doColumn("languages");
197 }
198
199 public void columnQueryId() {
200 doColumn("queryId");
201 }
202
203 public void columnQueryOffset() {
204 doColumn("queryOffset");
205 }
206
207 public void columnQueryPageSize() {
208 doColumn("queryPageSize");
209 }
210
211 public void columnQueryTime() {
212 doColumn("queryTime");
213 }
214
215 public void columnReferer() {
216 doColumn("referer");
217 }
218
219 public void columnRequestedAt() {
220 doColumn("requestedAt");
221 }
222
223 public void columnResponseTime() {
224 doColumn("responseTime");
225 }
226
227 public void columnRoles() {
228 doColumn("roles");
229 }
230
231 public void columnSearchWord() {
232 doColumn("searchWord");
233 }
234
235 public void columnUser() {
236 doColumn("user");
237 }
238
239 public void columnUserAgent() {
240 doColumn("userAgent");
241 }
242
243 public void columnUserInfoId() {
244 doColumn("userInfoId");
245 }
246
247 public void columnUserSessionId() {
248 doColumn("userSessionId");
249 }
250
251 public void columnVirtualHost() {
252 doColumn("virtualHost");
253 }
254 }
255 }