diff options
author | Eike Stepper | 2013-03-10 07:54:00 +0000 |
---|---|---|
committer | Eike Stepper | 2013-03-11 10:26:17 +0000 |
commit | e281dd0e6474ce8d294459f1a7ae2d118591317b (patch) | |
tree | fa3ce9ac9065ad04e52d01649c0cb8b59f9c2b85 /plugins/org.eclipse.net4j.examples.installer/examples | |
parent | 35f2316585607417e99e5dd5fe93541e1b9089d1 (diff) | |
download | cdo-e281dd0e6474ce8d294459f1a7ae2d118591317b.tar.gz cdo-e281dd0e6474ce8d294459f1a7ae2d118591317b.tar.xz cdo-e281dd0e6474ce8d294459f1a7ae2d118591317b.zip |
[401763] Make CDO Server more robust against data dictionary changes
https://bugs.eclipse.org/bugs/show_bug.cgi?id=401763
Diffstat (limited to 'plugins/org.eclipse.net4j.examples.installer/examples')
-rw-r--r-- | plugins/org.eclipse.net4j.examples.installer/examples/org.eclipse.net4j.jms.server.jdbc/src/org/eclipse/net4j/jms/server/internal/jdbc/JMSSchema.java | 17 |
1 files changed, 6 insertions, 11 deletions
diff --git a/plugins/org.eclipse.net4j.examples.installer/examples/org.eclipse.net4j.jms.server.jdbc/src/org/eclipse/net4j/jms/server/internal/jdbc/JMSSchema.java b/plugins/org.eclipse.net4j.examples.installer/examples/org.eclipse.net4j.jms.server.jdbc/src/org/eclipse/net4j/jms/server/internal/jdbc/JMSSchema.java index c3e9ea82bc..1fd4ae6de6 100644 --- a/plugins/org.eclipse.net4j.examples.installer/examples/org.eclipse.net4j.jms.server.jdbc/src/org/eclipse/net4j/jms/server/internal/jdbc/JMSSchema.java +++ b/plugins/org.eclipse.net4j.examples.installer/examples/org.eclipse.net4j.jms.server.jdbc/src/org/eclipse/net4j/jms/server/internal/jdbc/JMSSchema.java @@ -11,19 +11,19 @@ package org.eclipse.net4j.jms.server.internal.jdbc; import org.eclipse.net4j.db.DBType; +import org.eclipse.net4j.db.DBUtil; import org.eclipse.net4j.db.ddl.IDBField; import org.eclipse.net4j.db.ddl.IDBIndex; +import org.eclipse.net4j.db.ddl.IDBSchema; import org.eclipse.net4j.db.ddl.IDBTable; -import org.eclipse.net4j.spi.db.DBSchema; +import org.eclipse.net4j.spi.db.ddl.InternalDBSchema; /** * @author Eike Stepper */ -public class JMSSchema extends DBSchema +public class JMSSchema { - public static final JMSSchema INSTANCE = new JMSSchema(); - - private static final long serialVersionUID = 1L; + public static final IDBSchema INSTANCE = DBUtil.createSchema("JMS"); /** * DBTable Destinations @@ -63,13 +63,8 @@ public class JMSSchema extends DBSchema + " FROM " + DESTINATIONS + ", " + MESSAGES + " WHERE " + DESTINATIONS_NAME + "=" + MESSAGES_DESTINATION //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$ + " AND " + DESTINATIONS_NAME + "=?"; //$NON-NLS-1$ //$NON-NLS-2$ - private JMSSchema() - { - super("JMS"); //$NON-NLS-1$ - } - static { - INSTANCE.lock(); + ((InternalDBSchema)INSTANCE).lock(); } } |