aboutsummaryrefslogtreecommitdiff
path: root/id/server/moa-id-commons/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'id/server/moa-id-commons/src/main/java')
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/MOAIDConstants.java3
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/config/persistence/MOAIDConfigurationImpl.java13
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/AbstractConfigProperty.java23
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigProperty.java11
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigPropertyByteValues.java16
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/DatabaseConfigPropertyImpl.java22
-rw-r--r--id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/session/AuthenticatedSessionStore.java11
7 files changed, 67 insertions, 32 deletions
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/MOAIDConstants.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/MOAIDConstants.java
index 98f0616a5..436dcc91d 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/MOAIDConstants.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/MOAIDConstants.java
@@ -134,7 +134,8 @@ public class MOAIDConstants {
static {
List<String> jdbcDriverWorkaround = new ArrayList<String>();
jdbcDriverWorkaround.add("oracle.jdbc.");
- jdbcDriverWorkaround.add("com.microsoft.sqlserver.");
+ jdbcDriverWorkaround.add("com.microsoft.sqlserver.");
+ jdbcDriverWorkaround.add("org.postgresql.");
JDBC_DRIVER_NEEDS_WORKAROUND = Collections.unmodifiableList(jdbcDriverWorkaround);
}
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/config/persistence/MOAIDConfigurationImpl.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/config/persistence/MOAIDConfigurationImpl.java
index 4fd382606..4944813ad 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/config/persistence/MOAIDConfigurationImpl.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/config/persistence/MOAIDConfigurationImpl.java
@@ -1,6 +1,5 @@
package at.gv.egovernment.moa.id.commons.config.persistence;
-import java.sql.SQLSyntaxErrorException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
@@ -17,7 +16,7 @@ import at.gv.egiz.components.configuration.api.Configuration;
import at.gv.egiz.components.configuration.api.ConfigurationException;
import at.gv.egovernment.moa.id.commons.config.MOAIDConfigurationConstants;
import at.gv.egovernment.moa.id.commons.db.dao.config.AbstractConfigProperty;
-import at.gv.egovernment.moa.id.commons.db.dao.config.ConfigProperty;
+//import at.gv.egovernment.moa.id.commons.db.dao.config.ConfigProperty;
import at.gv.egovernment.moa.id.commons.db.dao.config.DatabaseConfigPropertyImpl;
import at.gv.egovernment.moa.id.commons.utils.KeyValueUtils;
import at.gv.egovernment.moa.logging.Logger;
@@ -56,7 +55,7 @@ public class MOAIDConfigurationImpl extends DatabaseConfigPropertyImpl implement
}
- TypedQuery<AbstractConfigProperty> configQuery = em.createQuery("select dbconfig from ConfigProperty dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> configQuery = em.createQuery("select dbconfig from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
configQuery.setParameter("key", preFix + "%");
List<AbstractConfigProperty> configResult = configQuery.getResultList();
@@ -94,7 +93,7 @@ public class MOAIDConfigurationImpl extends DatabaseConfigPropertyImpl implement
}
- TypedQuery<AbstractConfigProperty> configQuery = em.createQuery("select dbconfig from ConfigProperty dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> configQuery = em.createQuery("select dbconfig from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
configQuery.setParameter("key", searchKey.replace("*", "%"));
List<AbstractConfigProperty> configResult = configQuery.getResultList();
@@ -128,7 +127,7 @@ public class MOAIDConfigurationImpl extends DatabaseConfigPropertyImpl implement
+ MOAIDConfigurationConstants.SERVICE_UNIQUEIDENTIFIER;
List<AbstractConfigProperty> oaSearchResult = null;
- TypedQuery<AbstractConfigProperty> oaSearchQuery = em.createQuery("select dbconfig from ConfigProperty dbconfig where dbconfig.key like :key and dbconfig.value = SUBSTRING(:uniqueID, 1, LENGTH(dbconfig.value))", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> oaSearchQuery = em.createQuery("select dbconfig from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key and dbconfig.value = SUBSTRING(:uniqueID, 1, LENGTH(dbconfig.value))", AbstractConfigProperty.class);
oaSearchQuery.setParameter("key", keyId);
oaSearchQuery.setParameter("uniqueID", publicURLPrefix);
oaSearchResult = oaSearchQuery.getResultList();
@@ -159,7 +158,7 @@ public class MOAIDConfigurationImpl extends DatabaseConfigPropertyImpl implement
List<AbstractConfigProperty> oaSearchResult = new ArrayList<AbstractConfigProperty>();
- TypedQuery<AbstractConfigProperty> oaSearchQuery = em.createQuery("select dbconfig from ConfigProperty dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> oaSearchQuery = em.createQuery("select dbconfig from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
oaSearchQuery.setParameter("key", keyId);
List<AbstractConfigProperty> intermResult = oaSearchQuery.getResultList();
if (intermResult != null) {
@@ -224,7 +223,7 @@ public class MOAIDConfigurationImpl extends DatabaseConfigPropertyImpl implement
String oaType = KeyValueUtils.getFirstChildAfterPrefix(oaIdKey, MOAIDConfigurationConstants.PREFIX_MOAID_SERVICES);
String oaKey = KeyValueUtils.getPrefixFromKey(oaIdKey, MOAIDConfigurationConstants.SERVICE_UNIQUEIDENTIFIER);
- TypedQuery<AbstractConfigProperty> oaConfigQuery = em.createQuery("select dbconfig from ConfigProperty dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> oaConfigQuery = em.createQuery("select dbconfig from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key", AbstractConfigProperty.class);
oaConfigQuery.setParameter("key", oaKey + ".%");
List<AbstractConfigProperty> oaConfigResult = oaConfigQuery.getResultList();
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/AbstractConfigProperty.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/AbstractConfigProperty.java
index d50aa9c6e..0d9a1bf8b 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/AbstractConfigProperty.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/AbstractConfigProperty.java
@@ -8,6 +8,9 @@ import javax.persistence.MappedSuperclass;
@MappedSuperclass
public abstract class AbstractConfigProperty implements Serializable{
+
+
+
/**
*
*/
@@ -65,7 +68,7 @@ public abstract class AbstractConfigProperty implements Serializable{
return false;
if (getClass() != obj.getClass())
return false;
- ConfigProperty other = (ConfigProperty) obj;
+ AbstractConfigProperty other = (AbstractConfigProperty) obj;
if (key == null) {
if (other.key != null)
return false;
@@ -76,7 +79,7 @@ public abstract class AbstractConfigProperty implements Serializable{
public String toString() {
StringBuilder builder = new StringBuilder();
- builder.append(getImpplementationName());
+ builder.append(getImplementationName());
builder.append(" [key=");
builder.append(getKey());
builder.append(", value=");
@@ -86,9 +89,21 @@ public abstract class AbstractConfigProperty implements Serializable{
}
/**
- * Get a name for this Entity-Implementation for logging purposes
+ * Get a name for this Entity-Implementation class
*
* @return
*/
- abstract protected String getImpplementationName();
+ protected String getImplementationName() {
+ return getImplementationClass().getSimpleName();
+
+ }
+
+ /**
+ * Get get Class of the implemented Entity
+ *
+ * @return
+ */
+ abstract protected Class<? extends AbstractConfigProperty> getImplementationClass();
+
+
} \ No newline at end of file
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigProperty.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigProperty.java
index 07770fdf3..2cea90e7b 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigProperty.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigProperty.java
@@ -14,8 +14,7 @@ import javax.persistence.Table;
@Entity
public class ConfigProperty extends AbstractConfigProperty{
-
-
+
/**
*
*/
@@ -46,9 +45,13 @@ public class ConfigProperty extends AbstractConfigProperty{
this.value = value;
}
+ /* (non-Javadoc)
+ * @see at.gv.egovernment.moa.id.commons.db.dao.config.AbstractConfigProperty#getImplementationClass()
+ */
@Override
- protected String getImpplementationName() {
- return this.getClass().getName();
+ protected Class<? extends AbstractConfigProperty> getImplementationClass() {
+ return this.getClass();
+
}
}
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigPropertyByteValues.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigPropertyByteValues.java
index 51f7e4da6..c31ca98ed 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigPropertyByteValues.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/ConfigPropertyByteValues.java
@@ -1,11 +1,9 @@
package at.gv.egovernment.moa.id.commons.db.dao.config;
import java.io.UnsupportedEncodingException;
-import java.nio.charset.Charset;
import javax.persistence.Column;
import javax.persistence.Entity;
-import javax.persistence.Lob;
import javax.persistence.Table;
import at.gv.egovernment.moa.logging.Logger;
@@ -27,7 +25,6 @@ public class ConfigPropertyByteValues extends AbstractConfigProperty{
private static final long serialVersionUID = 1L;
- @Lob
@Column(name = "propertyValueBytes")
private byte[] value = null;
@@ -58,7 +55,10 @@ public class ConfigPropertyByteValues extends AbstractConfigProperty{
@Override
public void setValue(String value) {
try {
- this.value = value.getBytes("UTF-8");
+ if (value == null)
+ this.value = null;
+ else
+ this.value = value.getBytes("UTF-8");
} catch (UnsupportedEncodingException e) {
Logger.error("Internal DB write error! Can not read write to configuration DB.", e);
@@ -66,8 +66,12 @@ public class ConfigPropertyByteValues extends AbstractConfigProperty{
}
}
+ /* (non-Javadoc)
+ * @see at.gv.egovernment.moa.id.commons.db.dao.config.AbstractConfigProperty#getImplementationClass()
+ */
@Override
- protected String getImpplementationName() {
- return this.getClass().getName();
+ protected Class<? extends AbstractConfigProperty> getImplementationClass() {
+ return this.getClass();
+
}
}
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/DatabaseConfigPropertyImpl.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/DatabaseConfigPropertyImpl.java
index 213d1a860..c202e231b 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/DatabaseConfigPropertyImpl.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/config/DatabaseConfigPropertyImpl.java
@@ -3,9 +3,9 @@ package at.gv.egovernment.moa.id.commons.db.dao.config;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
-import java.util.Map.Entry;
import java.util.regex.Pattern;
+import javax.annotation.PostConstruct;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;
@@ -36,6 +36,15 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
@Autowired(required=true)
private ApplicationContext appContext;
+
+ static protected String dataBaseEntityName;
+
+ @PostConstruct
+ void postConstructor() {
+ dataBaseEntityName = appContext.getBean(AbstractConfigProperty.class).getImplementationName();
+ log.info("DB-Entity for config: " + dataBaseEntityName);
+
+ }
/**
*
@@ -51,7 +60,7 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
log.error("No EntityManager set!");
throw new ConfigurationException("No EntityManager set!");
}
- TypedQuery<String> query = em.createQuery("select key from ConfigProperty", String.class);
+ TypedQuery<String> query = em.createQuery("select key from " + dataBaseEntityName, String.class);
List<String> result = query.getResultList();
return result;
}
@@ -109,7 +118,7 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
protected void deleteKey(String key) {
log.debug("Deleting entry with key '{}'.", key);
- AbstractConfigProperty el = em.find(AbstractConfigProperty.class, key);
+ AbstractConfigProperty el = em.find(appContext.getBean(AbstractConfigProperty.class).getClass(), key);
if (el != null)
em.remove(el);
@@ -126,7 +135,7 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
throw new ConfigurationException("No EntityManager set!");
}
- TypedQuery<String> query = em.createQuery("select key from ConfigProperty dbconfig where dbconfig.key like :key", String.class);
+ TypedQuery<String> query = em.createQuery("select key from " + dataBaseEntityName + " dbconfig where dbconfig.key like :key", String.class);
query.setParameter("key", searchString.replace("*", "%"));
List<String> result = query.getResultList();
if (result == null)
@@ -146,7 +155,7 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
throw new ConfigurationException("No EntityManager set!");
}
- TypedQuery<AbstractConfigProperty> query = em.createQuery("select * from ConfigProperty dbconfig", AbstractConfigProperty.class);
+ TypedQuery<AbstractConfigProperty> query = em.createQuery("select * from " + dataBaseEntityName + " dbconfig", AbstractConfigProperty.class);
List<AbstractConfigProperty> all = query.getResultList();
searchString = searchString.replace(".", "\\.");
@@ -195,7 +204,8 @@ public class DatabaseConfigPropertyImpl extends AbstractConfigurationImpl {
private AbstractConfigProperty getProperty(String key) {
log.trace("Looking for configuration property for key '{}'.", key);
- AbstractConfigProperty result = em.find(AbstractConfigProperty.class, key);
+
+ AbstractConfigProperty result = em.find(appContext.getBean(AbstractConfigProperty.class).getClass(), key);
if (result != null) {
log.trace("Found configuration property {}.", result);
} else {
diff --git a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/session/AuthenticatedSessionStore.java b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/session/AuthenticatedSessionStore.java
index 7cb921ee7..b13f0ba5b 100644
--- a/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/session/AuthenticatedSessionStore.java
+++ b/id/server/moa-id-commons/src/main/java/at/gv/egovernment/moa/id/commons/db/dao/session/AuthenticatedSessionStore.java
@@ -98,9 +98,12 @@ public class AuthenticatedSessionStore implements Serializable{
@Column(name = "pendingRequestID", nullable=true)
private String pendingRequestID = "";
- @Column(name = "additionalInformationBytes", nullable=true)
+ @Column(name = "additionalInformation", nullable=true)
@Lob
- private byte[] additionalInformation;
+ private String additionalInformation;
+
+ @Column(name = "additionalInformationBytes", nullable=true)
+ private byte[] additionalInformationBytes;
@Column(name = "created", updatable=false, nullable=false)
@Temporal(TemporalType.TIMESTAMP)
@@ -350,14 +353,14 @@ public class AuthenticatedSessionStore implements Serializable{
* @return the additionalInformation
*/
public byte[] getAdditionalInformation() {
- return additionalInformation;
+ return additionalInformationBytes;
}
/**
* @param additionalInformation the additionalInformation to set
*/
public void setAdditionalInformation(byte[] additionalInformation) {
- this.additionalInformation = additionalInformation;
+ this.additionalInformationBytes = additionalInformation;
}