de.fraunhofer.igd.klarschiff.dao

Class JobDao

java.lang.Object

de.fraunhofer.igd.klarschiff.dao.JobDao

@Repository
public class JobDao
extends Object

Die DAO-Klasse unterstützt bei der Synchronisation von Jobs in einem Cluster. Hierzu können die laufenden Jobs in der DB registriert werden.

Author:

Stefan Audersch (Fraunhofer IGD)

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SimpleDateFormat	dateFormat
(package private) javax.persistence.EntityManager	em
private static org.apache.log4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
JobDao()

Method Summary

Modifier and Type	Method and Description
Long	getAnzahlAbgeschlosseneJobs() Ermittelt die Anzahl der korrekt abgeschlossen Jobs, die im Cluster ausgeführt wurden.
List<JobRun>	getFehlerhafteJobs() Ermittelt die fehlerhaft ausgeführten Jobs, die im Cluster ausgeführt wurden.
String	registerJobRun(Date datum, String name, String serverIp, String serverName, String serverConnectorPort, int truncateField) Registriert einen Job in der DB.
void	updateJobRun(String id, JobRun.Ergebnis ergebnis, Throwable exception) Aktualisiert das Ergebnis des Jobs in der Datenbank

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final org.apache.log4j.Logger logger

dateFormat

SimpleDateFormat dateFormat

em

javax.persistence.EntityManager em

Constructor Detail

JobDao

public JobDao()

Method Detail

registerJobRun

@Transactional
public String registerJobRun(Date datum,
                                            String name,
                                            String serverIp,
                                            String serverName,
                                            String serverConnectorPort,
                                            int truncateField)

Registriert einen Job in der DB. Die Id des Jobs wird dabei für die Synchronisation der Jobs verwendet. Die Id setzt sich aus einem abgerundetem Datum und dem Namen des Jobs zusammen

Parameters:

datum - Zeit bei der der Job gestartet wurde

name - Name des Jobs

serverIp - IPs des aktuellen Servers

serverName - Rechnername des aktuellen Servers

serverConnectorPort - ConnectionPort auf dem der aktuellen Server läuft

truncateField - Feld bei der Zeit, auf das abgerundet werden soll

Returns:

Id des Job oder null, wenn der Job bereits von einer anderen Serverinstance ausgeführt wird.

updateJobRun

@Transactional
public void updateJobRun(String id,
                                        JobRun.Ergebnis ergebnis,
                                        Throwable exception)

Aktualisiert das Ergebnis des Jobs in der Datenbank

Parameters:

id - Id des Jobs

ergebnis - Ergebnis des Jobs (abgeschlossen, fehlerhaft)

exception -

getAnzahlAbgeschlosseneJobs

public Long getAnzahlAbgeschlosseneJobs()

Ermittelt die Anzahl der korrekt abgeschlossen Jobs, die im Cluster ausgeführt wurden.

Returns:

Anzahl der korrekt ausgeführten Jobs

getFehlerhafteJobs

public List<JobRun> getFehlerhafteJobs()

Ermittelt die fehlerhaft ausgeführten Jobs, die im Cluster ausgeführt wurden.

Returns:

Liste der fehlerhaft ausgeführten Jobs, die im Cluster ausgeführt wurden.