aboutsummaryrefslogtreecommitdiff
path: root/pdf-as-web-db/src/main/java
diff options
context:
space:
mode:
authorAndreas Fitzek <andreas.fitzek@iaik.tugraz.at>2015-02-24 11:40:13 +0100
committerAndreas Fitzek <andreas.fitzek@iaik.tugraz.at>2015-02-24 11:40:13 +0100
commit6da9a2200b04652c00ec5d012f260c8afa311202 (patch)
treef3b633cd7ac0ab670ce894ae26a17a80cbc0f624 /pdf-as-web-db/src/main/java
parent6bf2c6651e2bbca2cb7b5680fa7eb2fea356abf7 (diff)
downloadpdf-as-4-6da9a2200b04652c00ec5d012f260c8afa311202.tar.gz
pdf-as-4-6da9a2200b04652c00ec5d012f260c8afa311202.tar.bz2
pdf-as-4-6da9a2200b04652c00ec5d012f260c8afa311202.zip
Database store to hold StatisticEvent
Diffstat (limited to 'pdf-as-web-db/src/main/java')
-rw-r--r--pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/DBRequestStore.java102
-rw-r--r--pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/Request.java3
-rw-r--r--pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/StatisticRequest.java51
3 files changed, 125 insertions, 31 deletions
diff --git a/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/DBRequestStore.java b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/DBRequestStore.java
index df006f02..1499b8ba 100644
--- a/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/DBRequestStore.java
+++ b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/DBRequestStore.java
@@ -16,78 +16,84 @@ import org.slf4j.LoggerFactory;
import at.gv.egiz.pdfas.api.ws.PDFASSignRequest;
import at.gv.egiz.pdfas.web.config.WebConfiguration;
+import at.gv.egiz.pdfas.web.stats.StatisticEvent;
import at.gv.egiz.pdfas.web.store.IRequestStore;
import at.gv.egiz.pdfas.web.store.db.Request;
+import at.gv.egiz.pdfas.web.store.db.StatisticRequest;
public class DBRequestStore implements IRequestStore {
private static final Logger logger = LoggerFactory
.getLogger(DBRequestStore.class);
-
+
private SessionFactory sessions;
private ServiceRegistry serviceRegistry;
-
+
public DBRequestStore() {
Configuration cfg = new Configuration();
cfg.addAnnotatedClass(Request.class);
cfg.setProperties(WebConfiguration.getHibernateProps());
-
+
serviceRegistry = new StandardServiceRegistryBuilder().applySettings(
cfg.getProperties()).build();
-
+
sessions = cfg.buildSessionFactory(serviceRegistry);
}
-
+
private void cleanOldRequests() {
int seconds = WebConfiguration.getDBTimeout();
Calendar calendar = Calendar.getInstance();
- calendar.add(Calendar.SECOND, (-1)* seconds);
+ calendar.add(Calendar.SECOND, (-1) * seconds);
Date date = calendar.getTime();
- SimpleDateFormat dt = new SimpleDateFormat("yyyy-mm-dd hh:mm:ss");
+ SimpleDateFormat dt = new SimpleDateFormat("yyyy-mm-dd hh:mm:ss");
logger.info("Clearing Entries before: " + dt.format(date));
Session session = null;
Transaction tx = null;
try {
session = sessions.openSession();
tx = session.beginTransaction();
- Query query = session.createQuery("delete from Request as req" +
- " where req.created < :date");
+ Query query = session.createQuery("delete from Request as req"
+ + " where req.created < :date");
query.setCalendar("date", calendar);
query.executeUpdate();
- } catch(Throwable e) {
+ } catch (Throwable e) {
logger.error("Failed to save Request", e);
tx.rollback();
} finally {
- if(session != null) {
+ if (session != null) {
session.close();
}
}
}
-
+
public void cleanOldRequestException() {
int seconds = WebConfiguration.getDBTimeout();
Calendar calendar = Calendar.getInstance();
- calendar.add(Calendar.SECOND, (-1)* seconds);
+ calendar.add(Calendar.SECOND, (-1) * seconds);
Date date = calendar.getTime();
- SimpleDateFormat dt = new SimpleDateFormat("yyyy-mm-dd hh:mm:ss");
+ SimpleDateFormat dt = new SimpleDateFormat("yyyy-mm-dd hh:mm:ss");
logger.info("Clearing Entries before: " + dt.format(date));
Session session = null;
- Transaction tx = null;
try {
session = sessions.openSession();
- tx = session.beginTransaction();
- Query query = session.createQuery("delete from Request as req" +
- " where req.created < :date");
+ Query query = session.createQuery("delete from Request as req"
+ + " where req.created < :date");
query.setCalendar("date", calendar);
query.executeUpdate();
+
+ Query queryStat = session.createQuery("delete from StatisticRequest as req"
+ + " where req.created < :date");
+ queryStat.setCalendar("date", calendar);
+ queryStat.executeUpdate();
} finally {
- if(session != null) {
+ if (session != null) {
session.close();
}
}
}
-
- public String createNewStoreEntry(PDFASSignRequest request) {
+
+ public String createNewStoreEntry(PDFASSignRequest request,
+ StatisticEvent event) {
// Clean Old Requests
this.cleanOldRequests();
Session session = null;
@@ -99,15 +105,20 @@ public class DBRequestStore implements IRequestStore {
dbRequest.setSignRequest(request);
dbRequest.setCreated(Calendar.getInstance().getTime());
session.save(dbRequest);
-
+
+ StatisticRequest statisticRequest = new StatisticRequest();
+ statisticRequest.setStatisticEvent(event);
+ statisticRequest.setCreated(Calendar.getInstance().getTime());
+ session.save(statisticRequest);
+
tx.commit();
return dbRequest.getId();
- } catch(Throwable e) {
+ } catch (Throwable e) {
logger.error("Failed to save Request", e);
tx.rollback();
return null;
} finally {
- if(session != null) {
+ if (session != null) {
session.close();
}
}
@@ -116,30 +127,59 @@ public class DBRequestStore implements IRequestStore {
public PDFASSignRequest fetchStoreEntry(String id) {
// Clean Old Requests
this.cleanOldRequests();
-
+
Session session = null;
Transaction tx = null;
try {
session = sessions.openSession();
tx = session.beginTransaction();
Request dbRequest = (Request) session.get(Request.class, id);
-
+
PDFASSignRequest request = dbRequest.getSignRequest();
-
+
session.delete(dbRequest);
-
+
tx.commit();
return request;
- } catch(Throwable e) {
+ } catch (Throwable e) {
logger.error("Failed to fetch Request", e);
tx.rollback();
return null;
} finally {
- if(session != null) {
+ if (session != null) {
session.close();
}
}
-
+
}
+ @Override
+ public StatisticEvent fetchStatisticEntry(String id) {
+ // Clean Old Requests
+ this.cleanOldRequests();
+
+ Session session = null;
+ Transaction tx = null;
+ try {
+ session = sessions.openSession();
+ tx = session.beginTransaction();
+ StatisticRequest dbRequest = (StatisticRequest) session.get(
+ StatisticRequest.class, id);
+
+ StatisticEvent request = dbRequest.getStatisticEvent();
+
+ session.delete(dbRequest);
+
+ tx.commit();
+ return request;
+ } catch (Throwable e) {
+ logger.error("Failed to fetch Request", e);
+ tx.rollback();
+ return null;
+ } finally {
+ if (session != null) {
+ session.close();
+ }
+ }
+ }
}
diff --git a/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/Request.java b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/Request.java
index d7377166..54870365 100644
--- a/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/Request.java
+++ b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/Request.java
@@ -11,6 +11,7 @@ import javax.persistence.Table;
import org.hibernate.annotations.GenericGenerator;
import at.gv.egiz.pdfas.api.ws.PDFASSignRequest;
+import at.gv.egiz.pdfas.web.stats.StatisticEvent;
@Entity
@Table(name = "requests")
@@ -49,4 +50,6 @@ public class Request {
public void setSignRequest(PDFASSignRequest signRequest) {
this.signRequest = signRequest;
}
+
+
}
diff --git a/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/StatisticRequest.java b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/StatisticRequest.java
new file mode 100644
index 00000000..23b2425b
--- /dev/null
+++ b/pdf-as-web-db/src/main/java/at/gv/egiz/pdfas/web/store/db/StatisticRequest.java
@@ -0,0 +1,51 @@
+package at.gv.egiz.pdfas.web.store.db;
+
+import java.util.Date;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+import org.hibernate.annotations.GenericGenerator;
+
+import at.gv.egiz.pdfas.web.stats.StatisticEvent;
+
+@Entity
+@Table(name = "statisticRequest")
+public class StatisticRequest {
+ private String uuid;
+ private Date created;
+ private StatisticEvent statisticEvent;
+
+ @Id
+ @GeneratedValue(generator = "uuid")
+ @GenericGenerator(name = "uuid", strategy = "uuid2")
+ @Column(name = "id", unique = true)
+ public String getId() {
+ return this.uuid;
+ }
+
+ public void setId(String uuid) {
+ this.uuid = uuid;
+ }
+
+ @Column(name = "created", nullable = false)
+ public Date getCreated() {
+ return this.created;
+ }
+
+ public void setCreated(Date created) {
+ this.created = created;
+ }
+
+ @Column(name = "statisticEvent", nullable = false, length = 52428800)
+ public StatisticEvent getStatisticEvent() {
+ return this.statisticEvent;
+ }
+
+ public void setStatisticEvent(StatisticEvent statisticEvent) {
+ this.statisticEvent = statisticEvent;
+ }
+}