diff --git a/openjpa-slice/src/main/java/org/apache/openjpa/slice/jdbc/DistributedConnection.java b/openjpa-slice/src/main/java/org/apache/openjpa/slice/jdbc/DistributedConnection.java index 51de6962a..5334eb08b 100644 --- a/openjpa-slice/src/main/java/org/apache/openjpa/slice/jdbc/DistributedConnection.java +++ b/openjpa-slice/src/main/java/org/apache/openjpa/slice/jdbc/DistributedConnection.java @@ -164,9 +164,9 @@ public class DistributedConnection implements Connection { public PreparedStatement prepareStatement(String arg0) throws SQLException { // TODO: Big hack - if (arg0.startsWith( - "SELECT SEQUENCE_VALUE FROM OPENJPA_SEQUENCE_TABLE")) + if (arg0.indexOf("OPENJPA_SEQUENCE_TABLE") != -1) { return master.prepareStatement(arg0); + } DistributedPreparedStatement ret = new DistributedPreparedStatement(this); for (Connection c : real) { ret.add(c.prepareStatement(arg0));