Skip to content

Commit

Permalink
fix: bytter til localdattime for alle kallene mot db so bruker native…
Browse files Browse the repository at this point in the history 
…sql (#40)
  • Loading branch information
@frode-carlsen
frode-carlsen authored Apr 23, 2020
1 parent ba794b9 commit ec2f1d6
Showing 1 changed file with 33 additions and 25 deletions.
58 changes: 33 additions & 25 deletions task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/TaskManagerRepositoryImpl.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import java.io.IOException;
import java.io.InputStream;
import java.lang.management.ManagementFactory;
import java.sql.Timestamp;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
Expand Down Expand Up @@ -97,16 +96,26 @@ static String getSqlFraFil(String filNavn) {
List<ProsessTaskData> pollNeste(LocalDateTime etterTid) {
final String sqlForPolling = getSqlForPolling();

@SuppressWarnings("unchecked")
List<ProsessTaskEntitet> resultList = entityManager
@SuppressWarnings("resource")
List<ProsessTaskEntitet> resultList = getEntityManagerAsSession()
.createNativeQuery(sqlForPolling, ProsessTaskEntitet.class) // NOSONAR - statisk SQL
.setParameter("neste_kjoering", Timestamp.valueOf(etterTid), TemporalType.TIMESTAMP)
.setParameter("neste_kjoering", etterTid, TemporalType.TIMESTAMP)
.setParameter("skip_ids", Set.of(-1))
.setHint(QueryHints.HINT_CACHE_MODE, "IGNORE")
.getResultList();
return tilProsessTask(resultList);
}

@SuppressWarnings("rawtypes")
private Session getEntityManagerAsSession() {
EntityManager em = entityManager;
// workaround for hibernate issue HHH-11020
if (em instanceof TargetInstanceProxy) {
em = (EntityManager) ((TargetInstanceProxy) em).weld_getTargetInstance();
}
return em.unwrap(Session.class);
}

void frigiVeto(ProsessTaskEntitet blokkerendeTask) {
String updateSql = "update PROSESS_TASK SET "
+ " status='KLAR'"
Expand All @@ -118,10 +127,11 @@ void frigiVeto(ProsessTaskEntitet blokkerendeTask) {

LocalDateTime nesteKjøringEtter = LocalDateTime.now();

int tasks = entityManager
@SuppressWarnings("resource")
int tasks = getEntityManagerAsSession()
.createNativeQuery(updateSql)
.setParameter("id", blokkerendeTask.getId())
.setParameter("neste", nesteKjøringEtter == null ? null : Timestamp.valueOf(nesteKjøringEtter), TemporalType.TIMESTAMP) // NOSONAR
.setParameter("neste", nesteKjøringEtter, TemporalType.TIMESTAMP) // NOSONAR
.executeUpdate();
if (tasks > 0) {
log.info("ProssessTask [{}] FERDIG. Frigitt {} tidligere blokkerte tasks", blokkerendeTask.getId(), tasks);
Expand All @@ -143,11 +153,12 @@ void frigiVeto(ProsessTaskEntitet blokkerendeTask) {

String status = taskStatus.getDbKode();
LocalDateTime now = LocalDateTime.now();
int tasks = entityManager.createNativeQuery(updateSql)
@SuppressWarnings("resource")
int tasks = getEntityManagerAsSession().createNativeQuery(updateSql)
.setParameter("id", prosessTaskId) // NOSONAR
.setParameter("status", status) // NOSONAR
.setParameter("status_ts", now)
.setParameter("neste", nesteKjøringEtter == null ? null : Timestamp.valueOf(nesteKjøringEtter), TemporalType.TIMESTAMP) // NOSONAR
.setParameter("neste", nesteKjøringEtter, TemporalType.TIMESTAMP) // NOSONAR
.setParameter("feilkode", feilkode)// NOSONAR
.setParameter("feiltekst", feiltekst)// NOSONAR
.setParameter("forsoek", feilforsøk)// NOSONAR
Expand All @@ -170,26 +181,27 @@ void oppdaterStatus(Long prosessTaskId, ProsessTaskStatus taskStatus) {

String status = taskStatus.getDbKode();
LocalDateTime now = LocalDateTime.now();
@SuppressWarnings("unused")
int tasks = entityManager.createNativeQuery(updateSql) // NOSONAR
@SuppressWarnings({ "unused", "resource" })
int tasks = getEntityManagerAsSession().createNativeQuery(updateSql) // NOSONAR
.setParameter("id", prosessTaskId)
.setParameter("status", status)
.setParameter("status_ts", Timestamp.valueOf(now), TemporalType.TIMESTAMP)
.setParameter("status_ts", now, TemporalType.TIMESTAMP)
.executeUpdate();

}

/** Markere task under arbeid (kjøres nå). */
@SuppressWarnings("resource")
void oppdaterTaskUnderArbeid(Long prosessTaskId, LocalDateTime now) {
String updateSql = "update PROSESS_TASK set" +
" siste_kjoering_ts = :naa" +
" ,versjon=versjon+1 " +
" WHERE id = :id";

@SuppressWarnings("unused")
int tasks = entityManager.createNativeQuery(updateSql) // NOSONAR
int tasks = getEntityManagerAsSession().createNativeQuery(updateSql) // NOSONAR
.setParameter("id", prosessTaskId)
.setParameter("naa", Timestamp.valueOf(now), TemporalType.TIMESTAMP)
.setParameter("naa", now, TemporalType.TIMESTAMP)
.executeUpdate();

}
Expand Down Expand Up @@ -227,7 +239,7 @@ void oppdaterTaskPlukket(Long prosessTaskId, LocalDateTime nesteKjøring, LocalD
* Poll neste vha. scrolling. Dvs. vi plukker en og en task og håndterer den får vi laster mer fra databasen. Sikrer
* at flere pollere kan opere samtidig og uavhengig av hverandre.
*/
@SuppressWarnings({ "rawtypes", "resource" })
@SuppressWarnings({ "resource" })
List<ProsessTaskEntitet> pollNesteScrollingUpdate(int numberOfTasks, long waitTimeBeforeNextPollingAttemptSecs, Set<Long> skipIds) {
int numberOfTasksStillToGo = numberOfTasks;
List<ProsessTaskEntitet> tasksToRun = new ArrayList<>(numberOfTasks);
Expand All @@ -236,14 +248,8 @@ List<ProsessTaskEntitet> pollNesteScrollingUpdate(int numberOfTasks, long waitTi
// gangen) og definere eksakt spørring.

// Scroller for å kunne oppdatere en og en rad uten å ta lås på neste.
EntityManager em = entityManager;

// workaround for hibernate issue HHH-11020
if (em instanceof TargetInstanceProxy) {
em = (EntityManager) ((TargetInstanceProxy) em).weld_getTargetInstance();
}
var timestamp = LocalDateTime.now();
try (ScrollableResults results = em.unwrap(Session.class)
try (ScrollableResults results = getEntityManagerAsSession()
.createNativeQuery(getSqlForPolling(), ProsessTaskEntitet.class)
.setFlushMode(FlushMode.MANUAL)
// hent kun 1 av gangen for å la andre pollere slippe til
Expand Down Expand Up @@ -295,13 +301,14 @@ List<ProsessTaskData> tilProsessTask(List<ProsessTaskEntitet> resultList) {
+ " FOR UPDATE SKIP LOCKED" //$NON-NLS-1$
;

Query query = entityManager.createNativeQuery(sql, ProsessTaskEntitet.class)
@SuppressWarnings("resource")
Query query = getEntityManagerAsSession().createNativeQuery(sql, ProsessTaskEntitet.class)
.setHint(org.hibernate.annotations.QueryHints.FETCH_SIZE, 1)
.setHint("javax.persistence.cache.storeMode", "REFRESH") //$NON-NLS-1$ //$NON-NLS-2$
.setParameter("id", taskInfo.getId())// NOSONAR
.setParameter("taskType", taskInfo.getTaskType())// NOSONAR
.setParameter("status", ProsessTaskStatus.KLAR.getDbKode())// NOSONAR
.setParameter("sisteTs", Timestamp.valueOf(taskInfo.getTimestampLowWatermark()), TemporalType.TIMESTAMP);
.setParameter("sisteTs", taskInfo.getTimestampLowWatermark(), TemporalType.TIMESTAMP);

return query.getResultList().stream().findFirst();

Expand All @@ -328,8 +335,9 @@ void verifyStartup() {
}

LocalDateTime now = LocalDateTime.now();
var result = (StartupData) entityManager.createNativeQuery(sql, StartupData.class)
.setParameter("inputTid", Timestamp.valueOf(now), TemporalType.TIMESTAMP)
@SuppressWarnings({ "resource", "cast" })
var result = (StartupData) getEntityManagerAsSession().createNativeQuery(sql, StartupData.class)
.setParameter("inputTid", now, TemporalType.TIMESTAMP)
.getSingleResult();

Object hibernateTz = entityManager.getEntityManagerFactory().getProperties().get("hibernate.jdbc.time_zone");
Expand Down

0 comments on commit ec2f1d6

Please sign in to comment.