fixing mongodb where clause

Author: PicoCreator

src/main/java/picoded/dstack/mongodb/MongoDBStack.java

@@ -59,7 +59,7 @@ public static String getFullConnectionURL(GenericConvertMap<String, Object> conf
 		int port = config.getInt("port", 27017);
 		String opts = config.getString("opt_str", "w=majority&retryWrites=true&retryReads=true"
 			+ "&maxPoolSize=10&compressors=zstd");
-			// "&readPreference=nearest&readConcernLevel=linearizable"
+			// "&readPreference=master&readConcernLevel=majority"
 
 		// Lets do a logging, for missing read concern if its not configured
 		if( opts.indexOf("readConcernLevel") < 0 ) {
@@ -76,6 +76,7 @@ public static String getFullConnectionURL(GenericConvertMap<String, Object> conf
 			//
 			LOGGER.warning("MongoDB is configured without readConcernLevel, "+
 			"this is alright for a single node, but `readConcernLevel=linearizable`"+
+			"or `readPreference=master&readConcernLevel=majority`"+
 			"is highly recommended for replica clusters to ensure read after write consistency.");
 		}
 

src/main/java/picoded/dstack/mongodb/MongoDB_DataObjectMap.java

@@ -1,6 +1,7 @@
 package picoded.dstack.mongodb;
 
 // Java imports
+import java.util.regex.Pattern;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -293,13 +294,12 @@ public Set<String> keySet() {
 		HashSet<String> ret = new HashSet<String>();
 
 		// Lets fetch everything ... D=
-		FindIterable<Document> search = collection.find();
-		search = search.projection(Projections.include("_oid"));
+		DistinctIterable<String> search = collection.distinct("_oid", String.class);
 
 		// Lets iterate the search
-		try (MongoCursor<Document> cursor = search.iterator()) {
+		try (MongoCursor<String> cursor = search.iterator()) {
 			while (cursor.hasNext()) {
-				ret.add(cursor.next().getString("_oid"));
+				ret.add(cursor.next());
 			}
 		}
 
@@ -362,13 +362,14 @@ static protected Bson queryObjToBsonFilter(Query inQuery) {
 			if (type == QueryType.LIKE) {
 				// Because the LIKE operator does not natively exists,
 				// we will generates its REGEX equivalent
-				
 				String val = GenericConvert.toString(inQuery.defaultArgumentValue());
-				val = val.replaceAll("*", "\\*");
+
+				// val = val.replaceAll("*", "*");
+				val = val.replaceAll("*", Pattern.quote("*"));
 				val = val.replaceAll("%", ".*");
-				val = val.replaceAll("_", ".+");
+				val = val.replaceAll("_", "[.]");
 
-				return Filters.regex(inQuery.fieldName(), val);
+				return Filters.regex(inQuery.fieldName(), "^"+val+"$");
 			}
 		}