Author: mreutegg
Date: Tue Jul 24 11:20:38 2018
New Revision: 1836541
URL: http://svn.apache.org/viewvc?rev=1836541&view=rev
Log:
OAK-7654: Remove usage of deprecated MongoDB Java driver 2.x API
Modified:
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ConcurrentAddNodesClusterIT.java
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/DocumentClusterIT.java
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/OakMongoNSRepositoryStub.java
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/random/RandomOpCompare.java
Modified:
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ConcurrentAddNodesClusterIT.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ConcurrentAddNodesClusterIT.java?rev=1836541&r1=1836540&r2=1836541&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ConcurrentAddNodesClusterIT.java
(original)
+++
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/ConcurrentAddNodesClusterIT.java
Tue Jul 24 11:20:38 2018
@@ -376,7 +376,7 @@ public class ConcurrentAddNodesClusterIT
private static void dropDB() throws Exception {
MongoConnection con = createConnection();
try {
- con.getDB().dropDatabase();
+ con.getDatabase().drop();
} finally {
con.close();
}
Modified:
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/DocumentClusterIT.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/DocumentClusterIT.java?rev=1836541&r1=1836540&r2=1836541&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/DocumentClusterIT.java
(original)
+++
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/DocumentClusterIT.java
Tue Jul 24 11:20:38 2018
@@ -178,7 +178,7 @@ public abstract class DocumentClusterIT
static void dropDB(@NotNull final Class<?> clazz) throws Exception {
MongoConnection con = createConnection(checkNotNull(clazz));
try {
- con.getDB().dropDatabase();
+ con.getDatabase().drop();
} finally {
con.close();
}
@@ -199,8 +199,9 @@ public abstract class DocumentClusterIT
@NotNull final List<DocumentMK> mks,
final int clusterId,
final int asyncDelay) throws Exception {
- DocumentMK.Builder builder = new DocumentMK.Builder();
- builder.setMongoDB(createConnection(checkNotNull(clazz)).getDB());
+ DocumentMK.Builder builder = new DocumentMK.Builder();
+ MongoConnection c = createConnection(checkNotNull(clazz));
+ builder.setMongoDB(c.getMongoClient(), c.getDBName());
if (asyncDelay != NOT_PROVIDED) {
builder.setAsyncDelay(asyncDelay);
}
Modified:
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/OakMongoNSRepositoryStub.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/OakMongoNSRepositoryStub.java?rev=1836541&r1=1836540&r2=1836541&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/OakMongoNSRepositoryStub.java
(original)
+++
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/OakMongoNSRepositoryStub.java
Tue Jul 24 11:20:38 2018
@@ -33,7 +33,7 @@ public class OakMongoNSRepositoryStub ex
static {
MongoConnection c = MongoUtils.getConnection();
if (c != null) {
- MongoUtils.dropCollections(c.getDB());
+ MongoUtils.dropCollections(c.getDatabase());
c.close();
}
}
@@ -55,7 +55,7 @@ public class OakMongoNSRepositoryStub ex
store = new DocumentMK.Builder().
memoryCacheSize(64 * 1024 * 1024).
setPersistentCache("target/persistentCache,time").
- setMongoDB(connection.getDB()).
+ setMongoDB(connection.getMongoClient(),
connection.getDBName()).
getNodeStore();
Jcr jcr = new Jcr(store);
preCreateRepository(jcr);
Modified:
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/random/RandomOpCompare.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/random/RandomOpCompare.java?rev=1836541&r1=1836540&r2=1836541&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/random/RandomOpCompare.java
(original)
+++
jackrabbit/oak/trunk/oak-jcr/src/test/java/org/apache/jackrabbit/oak/jcr/random/RandomOpCompare.java
Tue Jul 24 11:20:38 2018
@@ -140,10 +140,9 @@ public class RandomOpCompare {
} catch (Exception e) {
throw new RuntimeException(e);
}
- DB mongoDB = connection.getDB();
return new DocumentMK.Builder().
memoryCacheSize(0).
- setMongoDB(mongoDB, 16).
+ setMongoDB(connection.getMongoClient(),
connection.getDBName()).
setPersistentCache("target/persistentCache,time").
getNodeStore();
}