我需要您为这个问题提供建议,在Spring Boot应用程序中,我从数据库中加载了一些属性,例如(定时周期,电子邮件数据),我需要在应用程序上下文中导出这些属性,以便使用加载的数据。我该怎么办?
对于那些需要在应用程序启动之前从数据库中加载属性的人,并通过项目中的@Value使这些道具可访问,只需添加此处理器即可。
public class ReadDbPropertiesPostProcessor implements EnvironmentPostProcessor { /** * Name of the custom property source added by this post processor class */ private static final String PROPERTY_SOURCE_NAME = "databaseProperties"; private String[] KEYS = { "excel.threads", "cronDelay", "cronDelayEmail", "spring.mail.username", "spring.mail.password", "spring.mail.host", "spring.mail.port", "spring.mail.properties.mail.transport.protocol", "spring.mail.properties.mail.smtp.auth", "spring.mail.properties.mail.smtp.starttls.enabled", "spring.mail.properties.mail.debug", "spring.mail.properties.mail.smtp.starttls.required", "spring.mail.properties.mail.socketFactory.port", "spring.mail.properties.mail.socketFactory.class", "spring.mail.properties.mail.socketFactory.fallback", "white.executor.threads", "white.search.threads", "lot.sync.threads", "lot.async.threads", "lot.soap.threads", "excel.async.threads", "kpi.threads", "upload.threads" }; /** * Adds Spring Environment custom logic. This custom logic fetch properties from database and setting highest precedence */ @Override public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) { Map<String, Object> propertySource = new HashMap<>(); try { // Build manually datasource to ServiceConfig DataSource ds = DataSourceBuilder .create() .username(environment.getProperty("spring.datasource.username")) .password(environment.getProperty("spring.mail.password")) .url(environment.getProperty("spring.datasource.url")) .driverClassName("com.mysql.jdbc.Driver") .build(); // Fetch all properties Connection connection = ds.getConnection(); JTrace.genLog(LogSeverity.informational, "cargando configuracion de la base de datos"); PreparedStatement preparedStatement = connection.prepareStatement("SELECT value FROM config WHERE id = ?"); for (int i = 0; i < KEYS.length; i++) { String key = KEYS[i]; preparedStatement.setString(1, key); ResultSet rs = preparedStatement.executeQuery(); // Populate all properties into the property source while (rs.next()) { propertySource.put(key, rs.getString("value")); } rs.close(); preparedStatement.clearParameters(); } preparedStatement.close(); connection.close(); // Create a custom property source with the highest precedence and add it to Spring Environment environment.getPropertySources().addFirst(new MapPropertySource(PROPERTY_SOURCE_NAME, propertySource)); } catch (Throwable e) { throw new RuntimeException(e); } }
在 application.properties中, 必须存在数据源数据才能连接到数据库。
然后在 META-INF 文件夹中创建一个名为 spring.factories 的文件, 并 在其中放置以下行:
org.springframework.boot.env.EnvironmentPostProcessor=test.config.ReadDbPropertiesPostProcessor
就是这样,可以在任何地方访问经过检索的属性。