001
014
015 package com.liferay.portlet.documentlibrary.service.persistence.impl;
016
017 import com.liferay.portal.kernel.dao.orm.QueryPos;
018 import com.liferay.portal.kernel.dao.orm.SQLQuery;
019 import com.liferay.portal.kernel.dao.orm.Session;
020 import com.liferay.portal.kernel.dao.orm.Type;
021 import com.liferay.portal.kernel.exception.SystemException;
022 import com.liferay.portal.service.persistence.impl.BasePersistenceImpl;
023 import com.liferay.portlet.documentlibrary.model.DLFileRank;
024 import com.liferay.portlet.documentlibrary.model.impl.DLFileRankImpl;
025 import com.liferay.portlet.documentlibrary.service.persistence.DLFileRankFinder;
026 import com.liferay.util.dao.orm.CustomSQLUtil;
027
028 import java.util.List;
029
030
033 public class DLFileRankFinderImpl
034 extends BasePersistenceImpl<DLFileRank> implements DLFileRankFinder {
035
036 public static final String FIND_BY_STALE_RANKS =
037 DLFileRankFinder.class.getName() + ".findByStaleRanks";
038
039 public static final String FIND_BY_FOLDER_ID =
040 DLFileRankFinder.class.getName() + ".findByFolderId";
041
042 @Override
043 public List<Object[]> findByStaleRanks(int count) {
044 Session session = null;
045
046 try {
047 session = openSession();
048
049 String sql = CustomSQLUtil.get(FIND_BY_STALE_RANKS);
050
051 SQLQuery q = session.createSynchronizedSQLQuery(sql);
052
053 q.addScalar("groupId", Type.LONG);
054 q.addScalar("userId", Type.LONG);
055
056 QueryPos qPos = QueryPos.getInstance(q);
057
058 qPos.add(count);
059
060 return q.list(true);
061 }
062 catch (Exception e) {
063 throw new SystemException(e);
064 }
065 finally {
066 closeSession(session);
067 }
068 }
069
070 @Override
071 public List<DLFileRank> findByFolderId(long folderId) {
072 Session session = null;
073
074 try {
075 session = openSession();
076
077 String sql = CustomSQLUtil.get(FIND_BY_FOLDER_ID);
078
079 SQLQuery q = session.createSynchronizedSQLQuery(sql);
080
081 q.addEntity("DLFileRank", DLFileRankImpl.class);
082
083 QueryPos qPos = QueryPos.getInstance(q);
084
085 qPos.add(folderId);
086
087 return q.list(true);
088 }
089 catch (Exception e) {
090 throw new SystemException(e);
091 }
092 finally {
093 closeSession(session);
094 }
095 }
096
097 }