Class BsonQueryFactory

src/main/java/org/jongo/query/BsonQueryFactory.java:34–312

import static org.jongo.query.BsonSpecialChar.specialChar;

public class BsonQueryFactory implements QueryFactory {

    private static final String DEFAULT_TOKEN = "#";

    /**
     * The marshall operator will be replacing the token during query parsing as following:
     * {"firstname":#} -> {"firstname":{MARSHALL_OPERATOR: 0}}
     * 0 being the index of the parameter to be inserted in place of that placeholder.
     * Previously $marshall but upgrading to mongo driver 4 the new parser does not allow $ prefixed strings
     * if they're not mongo operators.
     * With a UUID prefixed string there should be no risk of collision.
     */
    private static final String MARSHALL_OPERATOR = "8a6e4178-8fba-4d22-af43-840512e3a999-marshall";

    private final String token;
    private final boolean singleCharToken;
    private final Marshaller marshaller;

    private static class BsonQuery implements Query {
        private final DBObject dbo;

        public BsonQuery(DBObject dbo) {
            this.dbo = dbo;
        }

        public DBObject toDBObject() {
            return dbo;
        }

        public org.bson.BsonDocument toBsonDocument() {
            return BsonDocumentWrapper.asBsonDocument(dbo, MongoClient.getDefaultCodecRegistry());
        }
    }

    public BsonQueryFactory(Marshaller marshaller) {
        this(marshaller, DEFAULT_TOKEN);
    }

    public BsonQueryFactory(Marshaller marshaller, String token) {
        this.singleCharToken = token.length() == 1;
        this.token = token;
        this.marshaller = marshaller;
    }

    public Query createQuery(final String query, Object... parameters) {

        if (query == null) {
            return new BsonQuery(null);
        }
        if (parameters == null) {
            parameters = new Object[]{null};
        }

        String quotedQuery = addRequiredQuotesAndParameters(query, parameters);

        final Object[] params = parameters;

        DBObject dbo;