1
22
23 package com.liferay.portal.service.impl;
24
25 import com.liferay.portal.PortalException;
26 import com.liferay.portal.SystemException;
27 import com.liferay.portal.kernel.util.Validator;
28 import com.liferay.portal.model.Shard;
29 import com.liferay.portal.service.base.ShardLocalServiceBaseImpl;
30 import com.liferay.portal.util.PortalUtil;
31 import com.liferay.portal.util.PropsValues;
32
33
38 public class ShardLocalServiceImpl extends ShardLocalServiceBaseImpl {
39
40 public Shard addShard(String className, long classPK, String name)
41 throws SystemException {
42
43 long classNameId = PortalUtil.getClassNameId(className);
44
45 if (Validator.isNull(name)) {
46 name = PropsValues.SHARD_DEFAULT_NAME;
47 }
48
49 long shardId = counterLocalService.increment();
50
51 Shard shard = shardPersistence.create(shardId);
52
53 shard.setClassNameId(classNameId);
54 shard.setClassPK(classPK);
55 shard.setName(name);
56
57 shardPersistence.update(shard, false);
58
59 return shard;
60 }
61
62 public Shard getShard(String className, long classPK)
63 throws PortalException, SystemException {
64
65 long classNameId = PortalUtil.getClassNameId(className);
66
67 return shardPersistence.findByC_C(classNameId, classPK);
68 }
69
70 }