Skip to content

Commit 12b78ef

Browse files
committed
fixes factory
1 parent 6132b69 commit 12b78ef

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

couchbase-driver/src/main/java/org/jnosql/diana/couchbase/key/DefaultCouchbaseBucketManagerFactory.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,14 @@ public <K, V> Map<K, V> getMap(String bucketName, Class<K> keyValue, Class<V> va
7272
throw new UnsupportedOperationException("Couchbase Map does not support a not String key instead of: "
7373
+ keyValue);
7474
}
75+
if (JsonValueCheck.checkType(valueValue)) {
76+
return (Map<K, V>)
77+
new com.couchbase.client.java.datastructures.collections.
78+
CouchbaseMap<V>(bucketName + ":map", getBucket(bucketName));
79+
} else {
80+
return new CouchbaseMap<>(getBucket(bucketName), bucketName, keyValue, valueValue);
81+
}
7582

76-
return new CouchbaseMap<>(getBucket(bucketName), bucketName, keyValue, valueValue);
7783
}
7884

7985
@Override

couchbase-driver/src/test/java/org/jnosql/diana/couchbase/key/DefaultCouchbaseBucketManagerFactoryTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,6 @@ public void shouldReturnMap() {
8080
assertTrue(factory.getMap("jnosql", String.class, User.class) instanceof CouchbaseMap);
8181
assertTrue(factory.getMap("jnosql", "jnosql", String.class, String.class) instanceof
8282
com.couchbase.client.java.datastructures.collections.CouchbaseMap);
83-
assertTrue(factory.getMap("jnosql", "jnosql", String.class, User.class) instanceof CouchbaseArrayList);
83+
assertTrue(factory.getMap("jnosql", "jnosql", String.class, User.class) instanceof CouchbaseMap);
8484
}
8585
}

0 commit comments

Comments
 (0)