jackrabbit-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From thom...@apache.org
Subject svn commit: r736273 - /jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java
Date Wed, 21 Jan 2009 09:31:29 GMT
Author: thomasm
Date: Wed Jan 21 01:31:29 2009
New Revision: 736273

URL: http://svn.apache.org/viewvc?rev=736273&view=rev
Log:
JCR-1572 DbDataStore connection does not always reconnect

Modified:
    jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java

Modified: jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java
URL: http://svn.apache.org/viewvc/jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java?rev=736273&r1=736272&r2=736273&view=diff
==============================================================================
--- jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java
(original)
+++ jackrabbit/branches/1.4/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/data/db/DbDataStore.java
Wed Jan 21 01:31:29 2009
@@ -282,7 +282,6 @@
         ConnectionRecoveryManager conn = getConnection();
         String id = null, tempId = null;
         try {
-            conn.setAutoReconnect(false);
             long now;            
             for (int i = 0; i < ConnectionRecoveryManager.TRIALS; i++) {
                 try {
@@ -323,6 +322,7 @@
             } else {
                 throw new DataStoreException("Unsupported stream store algorithm: " + storeStream);
             }
+            // UPDATE DATASTORE SET DATA=? WHERE ID=?
             conn.executeStmt(updateDataSQL, new Object[]{wrapper, tempId});
             now = System.currentTimeMillis();
             long length = in.getPosition();
@@ -356,7 +356,6 @@
             }
             usesIdentifier(identifier);
             DbDataRecord record = new DbDataRecord(this, identifier, length, now);
-            conn.setAutoReconnect(true);
             return record;
         } catch (Exception e) {
             throw convert("Can not insert new record", e);



Mime
View raw message