int getAllCount(AlarmsInformation alarmsInformation, int currentPage, int pageSize);
- Page<AlarmsInformation> queryAlarmsInformation(AlarmsInformation alarmsInformation, int currentPage, int pageSize);
-
List<AlarmsInformation> queryId(String[] id);
int queryDateBetween(String sourceId, String startTime, String endTime,String level);
String updatePerformanceInformation(PerformanceInformation performanceInformation);
- int getAllCount(PerformanceInformation performanceInformation, int currentPage, int pageSize);
-
- Page<PerformanceInformation> queryPerformanceInformation(PerformanceInformation performanceInformation, int currentPage, int pageSize);
-
List<PerformanceInformation> queryId(String[] id);
List<PerformanceInformation> queryDateBetween(String eventId, Date startDate, Date endDate);
}\r
}\r
\r
- @SuppressWarnings("unchecked")\r
- @Override\r
- public Page<AlarmsInformation> queryAlarmsInformation(AlarmsInformation alarmsInformation, int currentPage,\r
- int pageSize) {\r
- Page<AlarmsInformation> page = new Page<AlarmsInformation>();\r
- int allRow =this.getAllCount(alarmsInformation,currentPage,pageSize);\r
- int offset = page.countOffset(currentPage, pageSize);\r
- \r
- try(Session session = getSession()){\r
- StringBuffer hql =new StringBuffer("from AlarmsInformation a where 1=1");\r
- if (null == alarmsInformation) {\r
- //logger.error("AlarmsInformationServiceImpl queryAlarmsInformation alarmsInformation is null!");\r
- }else {\r
- if(null!=alarmsInformation.getName()) {\r
- String ver=alarmsInformation.getName();\r
- hql.append(" and a.name like '%"+ver+"%'");\r
- }\r
- if(null!=alarmsInformation.getValue()) {\r
- String ver=alarmsInformation.getValue();\r
- hql.append(" and a.value like '%"+ver+"%'");\r
- }\r
- if(null!=alarmsInformation.getSourceId()) {\r
- String ver=alarmsInformation.getSourceId();\r
- hql.append(" and a.sourceId = '"+ver+"'");\r
- }\r
- if(null!=alarmsInformation.getStartEpochMicroSec() || alarmsInformation.getLastEpochMicroSec()!= null) {\r
- hql.append(" and a.startEpochMicrosec between :startTime and :endTime");\r
- }\r
- }\r
- Query query = session.createQuery(hql.toString());\r
- if(null!=alarmsInformation.getStartEpochMicroSec() || alarmsInformation.getLastEpochMicroSec()!= null) {\r
- query.setString("startTime",alarmsInformation.getStartEpochMicroSec());\r
- query.setString("endTime",alarmsInformation.getLastEpochMicroSec());\r
- }\r
- query.setFirstResult(offset);\r
- query.setMaxResults(pageSize);\r
- List<AlarmsInformation> list= query.list();\r
- page.setPageNo(currentPage);\r
- page.setPageSize(pageSize);\r
- page.setTotalRecords(allRow);\r
- page.setList(list);\r
- session.flush();\r
- return page;\r
- } catch (Exception e) {\r
- logger.error("exception occurred while performing AlarmsInformationServiceImpl queryAlarmsInformation. Details:" + e.getMessage());\r
- return null;\r
- }\r
- }\r
-\r
@SuppressWarnings("unchecked")\r
@Override\r
public List<AlarmsInformation> queryId(String[] id) {\r
}\r
}\r
\r
- public int getAllCount(PerformanceInformation performanceInformation, int currentPage, int pageSize) {\r
- try(Session session = getSession()){\r
- StringBuffer hql = new StringBuffer("select count(*) from PerformanceInformation a where 1=1");\r
- if (null == performanceInformation) {\r
- }else {\r
- if(null!=performanceInformation.getName()) {\r
- String ver=performanceInformation.getName();\r
- hql.append(" and a.name like '%"+ver+"%'");\r
- }\r
- if(null!=performanceInformation.getValue()) {\r
- String ver=performanceInformation.getValue();\r
- hql.append(" and a.value like '%"+ver+"%'");\r
- }\r
- if(null!=performanceInformation.getSourceId()) {\r
- String ver=performanceInformation.getSourceId();\r
- hql.append(" and a.sourceId = '"+ver+"'");\r
- }\r
- if(null!=performanceInformation.getStartEpochMicrosec() || performanceInformation.getLastEpochMicroSec()!= null) {\r
- hql.append(" and a.startEpochMicrosec between :startTime and :endTime");\r
- }\r
- }\r
- Query query = session.createQuery(hql.toString());\r
- if(null!=performanceInformation.getStartEpochMicrosec() || performanceInformation.getLastEpochMicroSec()!= null) {\r
- query.setString("startTime",performanceInformation.getStartEpochMicrosec());\r
- query.setString("endTime",performanceInformation.getLastEpochMicroSec());\r
- }\r
- long q=(long) query.uniqueResult();\r
- session.flush();\r
- return (int)q;\r
- } catch (Exception e) {\r
- logger.error("exception occurred while performing PerformanceInformationServiceImpl getAllCount. Details:" + e.getMessage());\r
- return 0;\r
- }\r
- }\r
-\r
- @SuppressWarnings("unchecked")\r
- @Override\r
- public Page<PerformanceInformation> queryPerformanceInformation(PerformanceInformation performanceInformation,\r
- int currentPage, int pageSize) {\r
- Page<PerformanceInformation> page = new Page<PerformanceInformation>();\r
- int allRow =this.getAllCount(performanceInformation,currentPage,pageSize);\r
- int offset = page.countOffset(currentPage, pageSize);\r
-\r
- try(Session session = getSession()){\r
- StringBuffer hql =new StringBuffer("from PerformanceInformation a where 1=1 ");\r
- if (null == performanceInformation) {\r
- }else {\r
- if(null!=performanceInformation.getName()) {\r
- String ver=performanceInformation.getName();\r
- hql.append(" and a.name like '%"+ver+"%'");\r
- }\r
- if(null!=performanceInformation.getValue()) {\r
- String ver=performanceInformation.getValue();\r
- hql.append(" and a.value like '%"+ver+"%'");\r
- }\r
- if(null!=performanceInformation.getSourceId()) {\r
- String ver=performanceInformation.getSourceId();\r
- hql.append(" and a.sourceId = '"+ver+"'");\r
- }\r
- if(null!=performanceInformation.getStartEpochMicrosec() || performanceInformation.getLastEpochMicroSec()!= null) {\r
- hql.append(" and a.startEpochMicrosec between :startTime and :endTime");\r
- }\r
- }\r
- Query query = session.createQuery(hql.toString());\r
- if(null!=performanceInformation.getStartEpochMicrosec() || performanceInformation.getLastEpochMicroSec()!= null) {\r
- query.setString("startTime",performanceInformation.getStartEpochMicrosec());\r
- query.setString("endTime",performanceInformation.getLastEpochMicroSec());\r
- }\r
- query.setFirstResult(offset);\r
- query.setMaxResults(pageSize);\r
- List<PerformanceInformation> list= query.list();\r
-\r
- page.setPageNo(currentPage);\r
- page.setPageSize(pageSize);\r
- page.setTotalRecords(allRow);\r
- page.setList(list);\r
- session.flush();\r
- return page;\r
- } catch (Exception e) {\r
- logger.error("exception occurred while performing PerformanceInformationServiceImpl queryPerformanceInformation. Details:" + e.getMessage());\r
- return null;\r
- }\r
- }\r
-\r
@SuppressWarnings("unchecked")\r
@Override\r
public List<PerformanceInformation> queryId(String[] id) {\r
}
}
- @Test
- public void testQueryAlarmsInformation() throws Exception {
- try {
- AlarmsInformation ai = new AlarmsInformation();
- ai.setName("");
- ai.setValue("");
- ai.setSourceId("");
- ai.setStartEpochMicroSec("");;
- ai.setLastEpochMicroSec("");;
- alarmsInformationServiceImpl.queryAlarmsInformation(ai, 1, 1);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
@Test
public void testQueryId() throws Exception {
try {
}
}
- @Test
- public void testGetAllCount() throws Exception {
- new MockUp<Query>() {
- @Mock
- public Object uniqueResult() {
- return "1";
- }
- };
- try {
- PerformanceInformation pi = new PerformanceInformation();
- pi.setName("");
- pi.setValue("");
- pi.setSourceId("");
- pi.setStartEpochMicrosec("");;
- pi.setLastEpochMicroSec("");;
- performanceInformationServiceImpl.getAllCount(pi, 1, 1);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- @Test
- public void testQueryPerformanceInformation() throws Exception {
- try {
- PerformanceInformation pi = new PerformanceInformation();
- pi.setName("");
- pi.setValue("");
- pi.setSourceId("");
- pi.setStartEpochMicrosec("");;
- pi.setLastEpochMicroSec("");;
- performanceInformationServiceImpl.queryPerformanceInformation(pi, 1, 1);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
@Test
public void testQueryId() throws Exception {
try {