1
22
23 package com.liferay.portlet.expando.service.persistence;
24
25 import com.liferay.portal.SystemException;
26 import com.liferay.portal.kernel.dao.orm.QueryPos;
27 import com.liferay.portal.kernel.dao.orm.QueryUtil;
28 import com.liferay.portal.kernel.dao.orm.SQLQuery;
29 import com.liferay.portal.kernel.dao.orm.Session;
30 import com.liferay.portal.kernel.dao.orm.Type;
31 import com.liferay.portal.service.persistence.impl.BasePersistenceImpl;
32 import com.liferay.portlet.expando.model.ExpandoRow;
33 import com.liferay.portlet.expando.model.impl.ExpandoRowImpl;
34 import com.liferay.util.dao.orm.CustomSQLUtil;
35
36 import java.util.Iterator;
37 import java.util.List;
38
39
45 public class ExpandoRowFinderImpl
46 extends BasePersistenceImpl implements ExpandoRowFinder {
47
48 public static String COUNT_BY_TC_TN =
49 ExpandoRowFinder.class.getName() + ".countByTC_TN";
50
51 public static String FIND_BY_TC_TN =
52 ExpandoRowFinder.class.getName() + ".findByTC_TN";
53
54 public static String FIND_BY_TC_TN_C =
55 ExpandoRowFinder.class.getName() + ".findByTC_TN_C";
56
57 public int countByTC_TN(long classNameId, String tableName)
58 throws SystemException {
59
60 Session session = null;
61
62 try {
63 session = openSession();
64
65 String sql = CustomSQLUtil.get(COUNT_BY_TC_TN);
66
67 SQLQuery q = session.createSQLQuery(sql);
68
69 q.addScalar(COUNT_COLUMN_NAME, Type.LONG);
70
71 QueryPos qPos = QueryPos.getInstance(q);
72
73 qPos.add(classNameId);
74 qPos.add(tableName);
75
76 Iterator<Long> itr = q.list().iterator();
77
78 if (itr.hasNext()) {
79 Long count = itr.next();
80
81 if (count != null) {
82 return count.intValue();
83 }
84 }
85
86 return 0;
87 }
88 catch (Exception e) {
89 throw new SystemException(e);
90 }
91 finally {
92 closeSession(session);
93 }
94 }
95
96 public List<ExpandoRow> findByTC_TN(
97 long classNameId, String tableName, int start, int end)
98 throws SystemException {
99
100 Session session = null;
101
102 try {
103 session = openSession();
104
105 String sql = CustomSQLUtil.get(FIND_BY_TC_TN);
106
107 SQLQuery q = session.createSQLQuery(sql);
108
109 q.addEntity("ExpandoRow", ExpandoRowImpl.class);
110
111 QueryPos qPos = QueryPos.getInstance(q);
112
113 qPos.add(classNameId);
114 qPos.add(tableName);
115
116 return (List<ExpandoRow>)QueryUtil.list(
117 q, getDialect(), start, end);
118 }
119 catch (Exception e) {
120 throw new SystemException(e);
121 }
122 finally {
123 closeSession(session);
124 }
125 }
126
127 public ExpandoRow fetchByTC_TN_C(
128 long classNameId, String tableName, long classPK)
129 throws SystemException {
130
131 Session session = null;
132
133 try {
134 session = openSession();
135
136 String sql = CustomSQLUtil.get(FIND_BY_TC_TN_C);
137
138 SQLQuery q = session.createSQLQuery(sql);
139
140 q.addEntity("ExpandoRow", ExpandoRowImpl.class);
141
142 QueryPos qPos = QueryPos.getInstance(q);
143
144 qPos.add(classNameId);
145 qPos.add(tableName);
146 qPos.add(classPK);
147
148 return (ExpandoRow)q.uniqueResult();
149 }
150 catch (Exception e) {
151 throw new SystemException(e);
152 }
153 finally {
154 closeSession(session);
155 }
156 }
157
158 }