Skip to content

Commit 41745b3

Browse files
committed
Fix case when reused db that is not set in thread local.
1 parent fbf2337 commit 41745b3

1 file changed

Lines changed: 14 additions & 11 deletions

File tree

graphdb/src/main/java/com/tinkerpop/blueprints/impls/orient/OrientBaseGraph.java

Lines changed: 14 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,17 @@
11
package com.tinkerpop.blueprints.impls.orient;
22

3+
import java.io.UnsupportedEncodingException;
4+
import java.net.URLDecoder;
5+
import java.net.URLEncoder;
6+
import java.util.ArrayList;
7+
import java.util.Arrays;
8+
import java.util.Collection;
9+
import java.util.HashSet;
10+
import java.util.List;
11+
import java.util.Set;
12+
13+
import org.apache.commons.configuration.Configuration;
14+
315
import com.orientechnologies.common.exception.OException;
416
import com.orientechnologies.common.io.OFileUtils;
517
import com.orientechnologies.common.log.OLogManager;
@@ -37,17 +49,6 @@
3749
import com.tinkerpop.blueprints.util.ExceptionFactory;
3850
import com.tinkerpop.blueprints.util.StringFactory;
3951
import com.tinkerpop.blueprints.util.wrappers.partition.PartitionVertex;
40-
import org.apache.commons.configuration.Configuration;
41-
42-
import java.io.UnsupportedEncodingException;
43-
import java.net.URLDecoder;
44-
import java.net.URLEncoder;
45-
import java.util.ArrayList;
46-
import java.util.Arrays;
47-
import java.util.Collection;
48-
import java.util.HashSet;
49-
import java.util.List;
50-
import java.util.Set;
5152

5253
/**
5354
* A Blueprints implementation of the graph database OrientDB (http://www.orientechnologies.com)
@@ -861,6 +862,8 @@ public void removeEdge(final Edge edge) {
861862
* Underlying database object
862863
*/
863864
public OrientBaseGraph reuse(final ODatabaseDocumentTx iDatabase) {
865+
ODatabaseRecordThreadLocal.INSTANCE.set(iDatabase);
866+
864867
this.url = iDatabase.getURL();
865868
this.username = iDatabase.getUser() != null ? iDatabase.getUser().getName() : null;
866869
synchronized (this) {

0 commit comments

Comments
 (0)