Class DatastoreImpl

core/src/main/java/dev/morphia/DatastoreImpl.java:97–1107

A generic (type-safe) wrapper around mongodb collections @morphia.internal @hidden

 * @hidden
 */
@MorphiaInternal
@SuppressWarnings({ "unchecked", "rawtypes", "removal" })
public class DatastoreImpl implements AdvancedDatastore {
    private static final Logger LOG = LoggerFactory.getLogger(Datastore.class);

    private static final MongoDriverInformation DRIVER_INFO = buildDriverInfo();

    private static MongoDriverInformation buildDriverInfo() {
        MongoDriverInformation.Builder builder = MongoDriverInformation.builder().driverName("Morphia");
        String version = DatastoreImpl.class.getPackage().getImplementationVersion();
        if (version != null) {
            builder.driverVersion(version);
        }
        return builder.build();
    }

    private static void appendMongoClientMetadata(MongoClient mongoClient) {
        try {
            mongoClient.appendMetadata(DRIVER_INFO);
        } catch (Throwable e) {
            // appendMetadata is only available in driver 5.6+
        }
    }

    private final MongoClient mongoClient;
    private final Mapper mapper;
    private final QueryFactory queryFactory;
    private final CodecRegistry codecRegistry;
    public List<MorphiaCodecProvider> morphiaCodecProviders = new ArrayList<>();
    private ClassLoader classLoader;
    private MongoDatabase database;
    private DatastoreOperations operations;

    public DatastoreImpl(MongoClient client, MorphiaConfig config) {
        this(client, config, Thread.currentThread().getContextClassLoader());
    }

    public DatastoreImpl(MongoClient client, MorphiaConfig config, ClassLoader classLoader) {
        this.classLoader = classLoader;
        this.mongoClient = client;
        appendMongoClientMetadata(client);
        this.database = mongoClient.getDatabase(config.database());
        this.mapper = new Mapper(config, classLoader);
        this.queryFactory = mapper.getConfig().queryFactory();
        importModels();

        codecRegistry = buildRegistry();

        this.database = database.withCodecRegistry(this.codecRegistry);
        operations = new CollectionOperations();

        config.packages().forEach(packageName -> {
            Sofia.logMappingPackage(packageName);
            mapper.map(packageName);
        });
        if (config.applyCaps()) {
            applyCaps();
        }