001
014
015 package com.liferay.portal.service.base;
016
017 import aQute.bnd.annotation.ProviderType;
018
019 import com.liferay.portal.kernel.bean.BeanReference;
020 import com.liferay.portal.kernel.bean.IdentifiableBean;
021 import com.liferay.portal.kernel.dao.db.DB;
022 import com.liferay.portal.kernel.dao.db.DBFactoryUtil;
023 import com.liferay.portal.kernel.dao.jdbc.SqlUpdate;
024 import com.liferay.portal.kernel.dao.jdbc.SqlUpdateFactoryUtil;
025 import com.liferay.portal.kernel.dao.orm.ActionableDynamicQuery;
026 import com.liferay.portal.kernel.dao.orm.DefaultActionableDynamicQuery;
027 import com.liferay.portal.kernel.dao.orm.DynamicQuery;
028 import com.liferay.portal.kernel.dao.orm.DynamicQueryFactoryUtil;
029 import com.liferay.portal.kernel.dao.orm.Projection;
030 import com.liferay.portal.kernel.exception.PortalException;
031 import com.liferay.portal.kernel.exception.SystemException;
032 import com.liferay.portal.kernel.search.Indexable;
033 import com.liferay.portal.kernel.search.IndexableType;
034 import com.liferay.portal.kernel.util.OrderByComparator;
035 import com.liferay.portal.model.PersistedModel;
036 import com.liferay.portal.model.Shard;
037 import com.liferay.portal.service.BaseLocalServiceImpl;
038 import com.liferay.portal.service.PersistedModelLocalServiceRegistry;
039 import com.liferay.portal.service.ShardLocalService;
040 import com.liferay.portal.service.persistence.ClassNamePersistence;
041 import com.liferay.portal.service.persistence.ShardPersistence;
042 import com.liferay.portal.util.PortalUtil;
043
044 import java.io.Serializable;
045
046 import java.util.List;
047
048 import javax.sql.DataSource;
049
050
062 @ProviderType
063 public abstract class ShardLocalServiceBaseImpl extends BaseLocalServiceImpl
064 implements ShardLocalService, IdentifiableBean {
065
070
071
077 @Indexable(type = IndexableType.REINDEX)
078 @Override
079 public Shard addShard(Shard shard) {
080 shard.setNew(true);
081
082 return shardPersistence.update(shard);
083 }
084
085
091 @Override
092 public Shard createShard(long shardId) {
093 return shardPersistence.create(shardId);
094 }
095
096
103 @Indexable(type = IndexableType.DELETE)
104 @Override
105 public Shard deleteShard(long shardId) throws PortalException {
106 return shardPersistence.remove(shardId);
107 }
108
109
115 @Indexable(type = IndexableType.DELETE)
116 @Override
117 public Shard deleteShard(Shard shard) {
118 return shardPersistence.remove(shard);
119 }
120
121 @Override
122 public DynamicQuery dynamicQuery() {
123 Class<?> clazz = getClass();
124
125 return DynamicQueryFactoryUtil.forClass(Shard.class,
126 clazz.getClassLoader());
127 }
128
129
135 @Override
136 public <T> List<T> dynamicQuery(DynamicQuery dynamicQuery) {
137 return shardPersistence.findWithDynamicQuery(dynamicQuery);
138 }
139
140
152 @Override
153 public <T> List<T> dynamicQuery(DynamicQuery dynamicQuery, int start,
154 int end) {
155 return shardPersistence.findWithDynamicQuery(dynamicQuery, start, end);
156 }
157
158
171 @Override
172 public <T> List<T> dynamicQuery(DynamicQuery dynamicQuery, int start,
173 int end, OrderByComparator<T> orderByComparator) {
174 return shardPersistence.findWithDynamicQuery(dynamicQuery, start, end,
175 orderByComparator);
176 }
177
178
184 @Override
185 public long dynamicQueryCount(DynamicQuery dynamicQuery) {
186 return shardPersistence.countWithDynamicQuery(dynamicQuery);
187 }
188
189
196 @Override
197 public long dynamicQueryCount(DynamicQuery dynamicQuery,
198 Projection projection) {
199 return shardPersistence.countWithDynamicQuery(dynamicQuery, projection);
200 }
201
202 @Override
203 public Shard fetchShard(long shardId) {
204 return shardPersistence.fetchByPrimaryKey(shardId);
205 }
206
207
214 @Override
215 public Shard getShard(long shardId) throws PortalException {
216 return shardPersistence.findByPrimaryKey(shardId);
217 }
218
219 @Override
220 public ActionableDynamicQuery getActionableDynamicQuery() {
221 ActionableDynamicQuery actionableDynamicQuery = new DefaultActionableDynamicQuery();
222
223 actionableDynamicQuery.setBaseLocalService(com.liferay.portal.service.ShardLocalServiceUtil.getService());
224 actionableDynamicQuery.setClass(Shard.class);
225 actionableDynamicQuery.setClassLoader(getClassLoader());
226
227 actionableDynamicQuery.setPrimaryKeyPropertyName("shardId");
228
229 return actionableDynamicQuery;
230 }
231
232 protected void initActionableDynamicQuery(
233 ActionableDynamicQuery actionableDynamicQuery) {
234 actionableDynamicQuery.setBaseLocalService(com.liferay.portal.service.ShardLocalServiceUtil.getService());
235 actionableDynamicQuery.setClass(Shard.class);
236 actionableDynamicQuery.setClassLoader(getClassLoader());
237
238 actionableDynamicQuery.setPrimaryKeyPropertyName("shardId");
239 }
240
241
244 @Override
245 public PersistedModel deletePersistedModel(PersistedModel persistedModel)
246 throws PortalException {
247 return shardLocalService.deleteShard((Shard)persistedModel);
248 }
249
250 @Override
251 public PersistedModel getPersistedModel(Serializable primaryKeyObj)
252 throws PortalException {
253 return shardPersistence.findByPrimaryKey(primaryKeyObj);
254 }
255
256
267 @Override
268 public List<Shard> getShards(int start, int end) {
269 return shardPersistence.findAll(start, end);
270 }
271
272
277 @Override
278 public int getShardsCount() {
279 return shardPersistence.countAll();
280 }
281
282
288 @Indexable(type = IndexableType.REINDEX)
289 @Override
290 public Shard updateShard(Shard shard) {
291 return shardPersistence.update(shard);
292 }
293
294
299 public com.liferay.portal.service.ShardLocalService getShardLocalService() {
300 return shardLocalService;
301 }
302
303
308 public void setShardLocalService(
309 com.liferay.portal.service.ShardLocalService shardLocalService) {
310 this.shardLocalService = shardLocalService;
311 }
312
313
318 public ShardPersistence getShardPersistence() {
319 return shardPersistence;
320 }
321
322
327 public void setShardPersistence(ShardPersistence shardPersistence) {
328 this.shardPersistence = shardPersistence;
329 }
330
331
336 public com.liferay.counter.service.CounterLocalService getCounterLocalService() {
337 return counterLocalService;
338 }
339
340
345 public void setCounterLocalService(
346 com.liferay.counter.service.CounterLocalService counterLocalService) {
347 this.counterLocalService = counterLocalService;
348 }
349
350
355 public com.liferay.portal.service.ClassNameLocalService getClassNameLocalService() {
356 return classNameLocalService;
357 }
358
359
364 public void setClassNameLocalService(
365 com.liferay.portal.service.ClassNameLocalService classNameLocalService) {
366 this.classNameLocalService = classNameLocalService;
367 }
368
369
374 public com.liferay.portal.service.ClassNameService getClassNameService() {
375 return classNameService;
376 }
377
378
383 public void setClassNameService(
384 com.liferay.portal.service.ClassNameService classNameService) {
385 this.classNameService = classNameService;
386 }
387
388
393 public ClassNamePersistence getClassNamePersistence() {
394 return classNamePersistence;
395 }
396
397
402 public void setClassNamePersistence(
403 ClassNamePersistence classNamePersistence) {
404 this.classNamePersistence = classNamePersistence;
405 }
406
407 public void afterPropertiesSet() {
408 persistedModelLocalServiceRegistry.register("com.liferay.portal.model.Shard",
409 shardLocalService);
410 }
411
412 public void destroy() {
413 persistedModelLocalServiceRegistry.unregister(
414 "com.liferay.portal.model.Shard");
415 }
416
417
422 @Override
423 public String getBeanIdentifier() {
424 return _beanIdentifier;
425 }
426
427
432 @Override
433 public void setBeanIdentifier(String beanIdentifier) {
434 _beanIdentifier = beanIdentifier;
435 }
436
437 protected Class<?> getModelClass() {
438 return Shard.class;
439 }
440
441 protected String getModelClassName() {
442 return Shard.class.getName();
443 }
444
445
450 protected void runSQL(String sql) {
451 try {
452 DataSource dataSource = shardPersistence.getDataSource();
453
454 DB db = DBFactoryUtil.getDB();
455
456 sql = db.buildSQL(sql);
457 sql = PortalUtil.transformSQL(sql);
458
459 SqlUpdate sqlUpdate = SqlUpdateFactoryUtil.getSqlUpdate(dataSource,
460 sql, new int[0]);
461
462 sqlUpdate.update();
463 }
464 catch (Exception e) {
465 throw new SystemException(e);
466 }
467 }
468
469 @BeanReference(type = com.liferay.portal.service.ShardLocalService.class)
470 protected com.liferay.portal.service.ShardLocalService shardLocalService;
471 @BeanReference(type = ShardPersistence.class)
472 protected ShardPersistence shardPersistence;
473 @BeanReference(type = com.liferay.counter.service.CounterLocalService.class)
474 protected com.liferay.counter.service.CounterLocalService counterLocalService;
475 @BeanReference(type = com.liferay.portal.service.ClassNameLocalService.class)
476 protected com.liferay.portal.service.ClassNameLocalService classNameLocalService;
477 @BeanReference(type = com.liferay.portal.service.ClassNameService.class)
478 protected com.liferay.portal.service.ClassNameService classNameService;
479 @BeanReference(type = ClassNamePersistence.class)
480 protected ClassNamePersistence classNamePersistence;
481 @BeanReference(type = PersistedModelLocalServiceRegistry.class)
482 protected PersistedModelLocalServiceRegistry persistedModelLocalServiceRegistry;
483 private String _beanIdentifier;
484 }