Fix cache clear/evict to use collections part 2.

Closes #1369.

Author: mikereiche

src/main/java/org/springframework/data/couchbase/cache/DefaultCouchbaseCacheWriter.java

@@ -105,7 +105,7 @@ public boolean remove(final String collectionName, final String key) {
 	@Override
 	public long clear(final String collectionName, final String pattern) {
 		QueryResult result = clientFactory.getScope().query(
-				"DELETE FROM `" + collectionName + "` where meta().id LIKE $pattern",
+				"DELETE FROM `" + getCollection(collectionName).name() + "` where meta().id LIKE $pattern",
 				queryOptions().scanConsistency(REQUEST_PLUS).metrics(true).parameters(JsonObject.create().put("pattern", pattern + "%")));
 		return result.metaData().metrics().map(QueryMetrics::mutationCount).orElse(0L);
 	}

src/test/java/org/springframework/data/couchbase/cache/CouchbaseCacheIntegrationTests.java

@@ -57,7 +57,6 @@ public void beforeEach() {
 		super.beforeEach();
 		cache = CouchbaseCacheManager.create(couchbaseTemplate.getCouchbaseClientFactory()).createCouchbaseCache("myCache",
 				CouchbaseCacheConfiguration.defaultCacheConfig());
-		clear(cache);
 		ApplicationContext ac = new AnnotationConfigApplicationContext(Config.class);
 		cacheManager = ac.getBean(CouchbaseCacheManager.class);
 		userRepository = ac.getBean(UserRepository.class);
@@ -66,17 +65,11 @@ public void beforeEach() {
 	@AfterEach
 	@Override
 	public void afterEach() {
-		clear(cache);
+		cache.clear();
 		super.afterEach();
 	}
 
-	private void clear(CouchbaseCache c) {
-		couchbaseTemplate.getCouchbaseClientFactory().getCluster().query("SELECT count(*) from `" + bucketName() + "`",
-				QueryOptions.queryOptions().scanConsistency(REQUEST_PLUS));
-		c.clear();
-		couchbaseTemplate.getCouchbaseClientFactory().getCluster().query("SELECT count(*) from `" + bucketName() + "`",
-				QueryOptions.queryOptions().scanConsistency(REQUEST_PLUS));
-	}
+
 
 	@Test
 	void cachePutGet() {
@@ -109,17 +102,19 @@ void cacheEvict() {
 		cache.put(user1.getId(), user1); // put user1
 		cache.put(user2.getId(), user2); // put user2
 		cache.evict(user1.getId()); // evict user1
+		assertNull(cache.get(user1.getId())); // get user1 -> not present
 		assertEquals(user2, cache.get(user2.getId()).get()); // get user2 -> present
 	}
 
 	@Test
-	void cacheHitMiss() {
+	void cacheClear() {
 		CacheUser user1 = new CacheUser(UUID.randomUUID().toString(), "first1", "last1");
 		CacheUser user2 = new CacheUser(UUID.randomUUID().toString(), "first2", "last2");
-		assertNull(cache.get(user2.getId())); // get user2 -> cacheMiss
-		cache.put(user1.getId(), null); // cache a null
-		assertNotNull(cache.get(user1.getId())); // cacheHit null
-		assertNull(cache.get(user1.getId()).get()); // fetch cached null
+		cache.put(user1.getId(), user1); // put user1
+		cache.put(user2.getId(), user2); // put user2
+		cache.clear();
+		assertNull(cache.get(user1.getId())); // get user1 -> not present
+		assertNull(cache.get(user2.getId())); // get user2 -> not present
 	}
 
 	@Test