Commit f7d6a24f682bd2410a634f979c1e682165f5fd4f
- Diff rendering mode:
- inline
- side by side
hq-server/src/main/java/org/hyperic/hq/appdef/server/session/AgentDAO.java
(14 / 0)
|   | |||
| 51 | 51 | @Repository | |
| 52 | 52 | public class AgentDAO extends HibernateDAO<Agent> { | |
| 53 | 53 | private static final Log log = LogFactory.getLog(AgentDAO.class); | |
| 54 | private static final String LIMIT_A_TO_CURRENT_AGENTS = "a.version >= :serverVersion "; | ||
| 54 | 55 | private static final String LIMIT_A_TO_OLD_AGENTS = "a.version < :serverVersion "; | |
| 55 | 56 | ||
| 56 | 57 | private final ServerConfigManager serverConfigManager; | |
| … | … | ||
| 168 | 168 | query.setParameter("serverVersion", serverConfigManager.getServerMajorVersion()); | |
| 169 | 169 | return ((Number) query.uniqueResult()).longValue(); | |
| 170 | 170 | } | |
| 171 | |||
| 172 | |||
| 173 | public long getNumAutoUpdatingAgents() { | ||
| 174 | final String sql = new StringBuilder(150) | ||
| 175 | .append("select count(a) from Agent a where ") | ||
| 176 | .append(LIMIT_A_TO_CURRENT_AGENTS) | ||
| 177 | .append("and exists (select 1 from Platform p where p.agent.id = a.id)") | ||
| 178 | .toString(); | ||
| 179 | final Query query = getSession().createQuery(sql); | ||
| 180 | query.setParameter("serverVersion", serverConfigManager.getServerMajorVersion()); | ||
| 181 | return ((Number) query.uniqueResult()).longValue(); | ||
| 182 | } | ||
| 183 | |||
| 171 | 184 | ||
| 172 | 185 | /** | |
| 173 | 186 | * |
hq-server/src/main/java/org/hyperic/hq/appdef/server/session/AgentManagerImpl.java
(1 / 1)
|   | |||
| 1594 | 1594 | ||
| 1595 | 1595 | @Transactional(readOnly=true) | |
| 1596 | 1596 | public long getNumAutoUpdatingAgents() { | |
| 1597 | return agentPluginStatusDAO.getNumAutoUpdatingAgents(); | ||
| 1597 | return agentDao.getNumAutoUpdatingAgents(); | ||
| 1598 | 1598 | } | |
| 1599 | 1599 | ||
| 1600 | 1600 | @Transactional(readOnly=true) |
hq-server/src/main/java/org/hyperic/hq/appdef/server/session/AgentPluginStatusDAO.java
(0 / 12)
|   | |||
| 277 | 277 | .list(); | |
| 278 | 278 | } | |
| 279 | 279 | ||
| 280 | Long getNumAutoUpdatingAgents() { | ||
| 281 | String serverMajorVersion = serverConfigManager.getServerMajorVersion(); | ||
| 282 | final String sql = new StringBuilder(150) | ||
| 283 | .append("select count(distinct agent_id) from EAM_AGENT_PLUGIN_STATUS s ") | ||
| 284 | .append(LIMIT_S_TO_CURRENT_AGENTS) | ||
| 285 | .append("and exists (select 1 from EAM_PLATFORM p where p.agent_id = s.agent_id)") | ||
| 286 | .toString(); | ||
| 287 | final SQLQuery query = getSession().createSQLQuery(sql); | ||
| 288 | query.setParameter("serverVersion", serverMajorVersion); | ||
| 289 | return ((Number) query.uniqueResult()).longValue(); | ||
| 290 | } | ||
| 291 | |||
| 292 | 280 | @SuppressWarnings("unchecked") | |
| 293 | 281 | public Collection<Agent> getAutoUpdatingAgents() { | |
| 294 | 282 | String serverMajorVersion = serverConfigManager.getServerMajorVersion(); |
Comments
Add your comment
Please log in to comment



Add a new comment:
Login or create an account to post a comment