/
ColumnManagerSupplier.java
73 lines (62 loc) · 3.12 KB
/
ColumnManagerSupplier.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
/*
* Copyright (c) 2022 Contributors to the Eclipse Foundation
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* and Apache License v2.0 which accompanies this distribution.
* The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
* and the Apache License v2.0 is available at http://www.opensource.org/licenses/apache2.0.php.
*
* You may elect to redistribute this code under either of these licenses.
*
* Contributors:
*
* Otavio Santana
*/
package org.eclipse.jnosql.mapping.column.configuration;
import jakarta.data.exceptions.MappingException;
import org.eclipse.jnosql.communication.Settings;
import org.eclipse.jnosql.communication.semistructured.DatabaseConfiguration;
import org.eclipse.jnosql.communication.semistructured.DatabaseManager;
import org.eclipse.jnosql.mapping.Database;
import org.eclipse.jnosql.mapping.DatabaseType;
import org.eclipse.jnosql.mapping.core.config.MicroProfileSettings;
import org.eclipse.jnosql.mapping.reflection.Reflections;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Disposes;
import jakarta.enterprise.inject.Produces;
import jakarta.enterprise.inject.spi.CDI;
import java.util.Optional;
import java.util.function.Supplier;
import java.util.logging.Level;
import java.util.logging.Logger;
import static org.eclipse.jnosql.mapping.core.config.MappingConfigurations.COLUMN_DATABASE;
import static org.eclipse.jnosql.mapping.core.config.MappingConfigurations.COLUMN_PROVIDER;
@ApplicationScoped
class ColumnManagerSupplier implements Supplier<DatabaseManager> {
private static final Logger LOGGER = Logger.getLogger(ColumnManagerSupplier.class.getName());
@Override
@Produces
@Database(DatabaseType.COLUMN)
@ApplicationScoped
public DatabaseManager get() {
Settings settings = MicroProfileSettings.INSTANCE;
DatabaseConfiguration configuration = settings.get(COLUMN_PROVIDER, Class.class)
.filter(DatabaseConfiguration.class::isAssignableFrom)
.map(c -> {
final Reflections reflections = CDI.current().select(Reflections.class).get();
return (DatabaseConfiguration) reflections.newInstance(c);
}).orElseGet(DatabaseConfiguration::getConfiguration);
var managerFactory = configuration.apply(settings);
Optional<String> database = settings.get(COLUMN_DATABASE, String.class);
String db = database.orElseThrow(() -> new MappingException("Please, inform the database filling up the property "
+ COLUMN_DATABASE.get()));
DatabaseManager manager = managerFactory.apply(db);
LOGGER.log(Level.FINEST, "Starting a ColumnManager instance using Eclipse MicroProfile Config," +
" database name: " + db);
return manager;
}
public void close(@Disposes @Database(DatabaseType.COLUMN) DatabaseManager manager) {
LOGGER.log(Level.FINEST, "Closing ColumnManager resource, database name: " + manager.name());
manager.close();
}
}