diff options
Diffstat (limited to 'server/src/main/java/org/onap/usecaseui/server/service/impl')
5 files changed, 43 insertions, 47 deletions
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java index d8e1eaef..3e0777e0 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java @@ -21,13 +21,12 @@ import java.util.ArrayList; import java.util.Collections;
import java.util.List;
-import javax.persistence.EntityManagerFactory;
-import javax.transaction.Transactional;
+import jakarta.persistence.EntityManagerFactory;
+import jakarta.transaction.Transactional;
-import org.hibernate.Query;
+import org.hibernate.query.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
-import org.hibernate.Transaction;
import org.onap.usecaseui.server.bean.AlarmsHeader;
import org.onap.usecaseui.server.bean.SortMaster;
import org.onap.usecaseui.server.service.AlarmsHeaderService;
@@ -44,7 +43,7 @@ import org.springframework.stereotype.Service; @Transactional
@org.springframework.context.annotation.Configuration
@EnableAspectJAutoProxy
-public class AlarmsHeaderServiceImpl implements AlarmsHeaderService {
+public class AlarmsHeaderServiceImpl implements AlarmsHeaderService {
private static final Logger logger = LoggerFactory.getLogger(AlarmsHeaderServiceImpl.class);
@@ -115,8 +114,8 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { }
Query query = session.createQuery(count.toString());
if(UuiCommonUtil.isNotNullOrEmpty(alarmsHeader.getStartEpochMicrosec())&&UuiCommonUtil.isNotNullOrEmpty(alarmsHeader.getLastEpochMicroSec())) {
- query.setString("startTime",alarmsHeader.getStartEpochMicrosec());
- query.setString("endTime",alarmsHeader.getLastEpochMicroSec());
+ query.setParameter("startTime",alarmsHeader.getStartEpochMicrosec());
+ query.setParameter("endTime",alarmsHeader.getLastEpochMicroSec());
}
long q=(long)query.uniqueResult();
session.flush();
@@ -159,8 +158,8 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { logger.info("AlarmsHeaderServiceImpl queryAlarmsHeader: alarmsHeader={}", alarmsHeader);
Query query = session.createQuery(hql.toString());
if(UuiCommonUtil.isNotNullOrEmpty(alarmsHeader.getStartEpochMicrosec())&&UuiCommonUtil.isNotNullOrEmpty(alarmsHeader.getLastEpochMicroSec())) {
- query.setString("startTime",alarmsHeader.getStartEpochMicrosec());
- query.setString("endTime",alarmsHeader.getLastEpochMicroSec());
+ query.setParameter("startTime",alarmsHeader.getStartEpochMicrosec());
+ query.setParameter("endTime",alarmsHeader.getLastEpochMicroSec());
}
query.setFirstResult(offset);
query.setMaxResults(pageSize);
@@ -205,13 +204,13 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { //Query q=session.createQuery("update AlarmsHeader set status='"+status+"', updateTime='"+date+"' , startEpochMicrosecCleared='"+startEpochMicrosecCleared+"' ,lastEpochMicroSecCleared='"+lastEpochMicroSecCleared+"' where eventName='"+eventName+"' and reportingEntityName='"+reportingEntityName+"' and specificProblem ='"+specificProblem+"'");
Query q=session.createQuery("update AlarmsHeader set status=:status, startEpochMicrosecCleared=:startEpochMicrosecCleared ,lastEpochMicroSecCleared=:lastEpochMicroSecCleared where eventName=:eventName and reportingEntityName=:reportingEntityName and specificProblem =:specificProblem");
- q.setString("status",status);
+ q.setParameter("status",status);
- q.setString("startEpochMicrosecCleared",startEpochMicrosecCleared);
- q.setString("lastEpochMicroSecCleared",lastEpochMicroSecCleared);
- q.setString("eventName",eventName);
- q.setString("reportingEntityName",reportingEntityName);
- q.setString("specificProblem",specificProblem);
+ q.setParameter("startEpochMicrosecCleared",startEpochMicrosecCleared);
+ q.setParameter("lastEpochMicroSecCleared",lastEpochMicroSecCleared);
+ q.setParameter("eventName",eventName);
+ q.setParameter("reportingEntityName",reportingEntityName);
+ q.setParameter("specificProblem",specificProblem);
q.executeUpdate();
@@ -232,7 +231,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { hql+=" where a.status = :status";
Query query = session.createQuery(hql);
if (!status.equals("0"))
- query.setString("status",status);
+ query.setParameter("status",status);
return query.uniqueResult().toString();
} catch (Exception e) {
logger.error("exception occurred while performing AlarmsHeaderServiceImpl queryStatusCount. Details:" + e.getMessage());
@@ -247,7 +246,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { String string = "from AlarmsHeader a where 1=1 and a.id=:id";
Query q = session.createQuery(string);
- q.setString("id",id);
+ q.setParameter("id",id);
AlarmsHeader alarmsHeader =(AlarmsHeader)q.uniqueResult();
return alarmsHeader;
@@ -263,7 +262,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { try{
StringBuffer hql =new StringBuffer("from SortMaster a where 1=1 and a.sortType=:sortType");
Query query = session.createQuery(hql.toString());
- query.setString("sortType",sortType);
+ query.setParameter("sortType",sortType);
List<SortMaster> list= query.list();
return list;
} catch (Exception e) {
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java index 7bd444a9..f48133ef 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java @@ -18,12 +18,11 @@ package org.onap.usecaseui.server.service.impl; import java.util.ArrayList;
import java.util.List;
-import javax.persistence.EntityManagerFactory;
-import javax.transaction.Transactional;
-import org.hibernate.Query;
+import jakarta.persistence.EntityManagerFactory;
+import jakarta.transaction.Transactional;
+import org.hibernate.query.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
-import org.hibernate.Transaction;
import org.onap.usecaseui.server.bean.AlarmsInformation;
import org.onap.usecaseui.server.bean.maxAndMinTimeBean;
import org.onap.usecaseui.server.service.AlarmsInformationService;
@@ -156,15 +155,15 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { hql += " and (CASE WHEN a.startEpochMicrosec=:zero THEN a.lastEpochMicroSec ELSE a.startEpochMicrosec END) between :startTime and :endTime ";
}
Query query = session.createQuery(hql);
- query.setString("zero",zero);
+ query.setParameter("zero",zero);
if (sourceName != null && !"".equals(sourceName)){
- query.setString("sourceName",sourceName);
+ query.setParameter("sourceName",sourceName);
}
if (UuiCommonUtil.isNotNullOrEmpty(status)){
- query.setString("status",status);
+ query.setParameter("status",status);
}
if (startTime != null && !"".equals(startTime) && endTime != null && !"".equals(endTime)){
- query.setString("startTime", startTime).setString("endTime", endTime);
+ query.setParameter("startTime", startTime).setParameter("endTime", endTime);
}
long num=(long) query.uniqueResult();
return (int)num;
@@ -180,7 +179,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { Session session = getSession();
try {
String sql = "select MAX(startEpochMicrosec),MIN(startEpochMicrosec) FROM alarms_commoneventheader";
- Query query = session.createSQLQuery(sql);
+ Query query = session.createNativeQuery(sql);
list = query.list();
session.flush();
}catch (Exception e){
@@ -198,7 +197,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { try {
String string = "from AlarmsInformation a where 1=1 and a.headerId=:headerId";
Query query = session.createQuery(string);
- query.setString("headerId",headerId);
+ query.setParameter("headerId",headerId);
List<AlarmsInformation> list = query.list();
session.flush();
return list;
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/InitializationServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/InitializationServiceImpl.java index c4af8ddc..68890db5 100644 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/InitializationServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/InitializationServiceImpl.java @@ -15,7 +15,7 @@ */ package org.onap.usecaseui.server.service.impl; -import javax.transaction.Transactional; +import jakarta.transaction.Transactional; import org.onap.usecaseui.server.service.InitializationService; import org.slf4j.Logger; diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java index 9ff3dec2..a403858c 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java @@ -19,13 +19,12 @@ package org.onap.usecaseui.server.service.impl; import java.util.ArrayList;
import java.util.List;
-import javax.persistence.EntityManagerFactory;
-import javax.transaction.Transactional;
+import jakarta.persistence.EntityManagerFactory;
+import jakarta.transaction.Transactional;
-import org.hibernate.Query;
+import org.hibernate.query.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
-import org.hibernate.Transaction;
import org.onap.usecaseui.server.bean.PerformanceHeader;
import org.onap.usecaseui.server.service.PerformanceHeaderService;
import org.onap.usecaseui.server.util.Page;
@@ -102,7 +101,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { }
Query query = session.createQuery(hql.toString());
if(null!=performanceHeder.getStartEpochMicrosec() && null!=performanceHeder.getLastEpochMicroSec()) {
- query.setString("startTime",performanceHeder.getStartEpochMicrosec()).setString("endTime",performanceHeder.getLastEpochMicroSec());
+ query.setParameter("startTime",performanceHeder.getStartEpochMicrosec()).setParameter("endTime",performanceHeder.getLastEpochMicroSec());
}
long q=(long)query.uniqueResult();
session.flush();
@@ -131,7 +130,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { }
Query query = session.createQuery(hql.toString());
if(UuiCommonUtil.isNotNullOrEmpty(performanceHeder.getStartEpochMicrosec())&& UuiCommonUtil.isNotNullOrEmpty(performanceHeder.getLastEpochMicroSec())) {
- query.setString("startTime",performanceHeder.getStartEpochMicrosec()).setString("endTime",performanceHeder.getLastEpochMicroSec());
+ query.setParameter("startTime",performanceHeder.getStartEpochMicrosec()).setParameter("endTime",performanceHeder.getLastEpochMicroSec());
}
query.setFirstResult(offset);
query.setMaxResults(pageSize);
@@ -185,7 +184,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { String string = "from PerformanceHeader a where 1=1 and a.id=:id";
Query q = session.createQuery(string);
- q.setString("id",id);
+ q.setParameter("id",id);
PerformanceHeader performanceHeader =(PerformanceHeader)q.uniqueResult();
session.flush();
return performanceHeader;
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java index 0cc99193..c09bccbc 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java @@ -21,14 +21,13 @@ import java.util.Date; import java.util.List;
-import javax.persistence.EntityManagerFactory;
-import javax.transaction.Transactional;
+import jakarta.persistence.EntityManagerFactory;
+import jakarta.transaction.Transactional;
import com.google.common.base.Throwables;
-import org.hibernate.Query;
+import org.hibernate.query.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
-import org.hibernate.Transaction;
import org.onap.usecaseui.server.bean.PerformanceInformation;
import org.onap.usecaseui.server.service.PerformanceInformationService;
import org.onap.usecaseui.server.util.UuiCommonUtil;
@@ -148,13 +147,13 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation }
Query query = session.createQuery(hql);
if (resourceId != null && !"".equals(resourceId)){
- query.setString("resourceId",resourceId);
+ query.setParameter("resourceId",resourceId);
}
if (name != null && !"".equals(name)){
- query.setString("name",name);
+ query.setParameter("name",name);
}
if (startTime != null && !"".equals(startTime) && endTime != null && !"".equals(endTime)){
- query.setString("startTime", startTime).setString("endTime", endTime);
+ query.setParameter("startTime", startTime).setParameter("endTime", endTime);
}
logger.info("PerformanceInformationServiceImpl queryDateBetween: list={}", query.list());
return query.list();
@@ -170,7 +169,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation try {
String string = "from PerformanceInformation a where 1=1 and a.headerId=:headerId";
Query query = session.createQuery(string);
- query.setString("headerId",headerId);
+ query.setParameter("headerId",headerId);
List<PerformanceInformation> list = query.list();
session.flush();
return list;
@@ -197,13 +196,13 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation }
Query query = session.createQuery(hql);
if (sourceId != null && !"".equals(sourceId)){
- query.setString("resourceId",sourceId);
+ query.setParameter("resourceId",sourceId);
}
if (name != null && !"".equals(name)){
- query.setString("name",name);
+ query.setParameter("name",name);
}
if (startTime != null && !"".equals(startTime) && endTime != null && !"".equals(endTime)){
- query.setString("startTime", startTime).setString("endTime", endTime);
+ query.setParameter("startTime", startTime).setParameter("endTime", endTime);
}
String num=(String) query.uniqueResult();
return UuiCommonUtil.isNotNullOrEmpty(num)?num:0+"";
|