-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Glaucio Jannotti
committed
Jun 18, 2024
1 parent
c0215f3
commit 7f86700
Showing
15 changed files
with
338 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
129 changes: 129 additions & 0 deletions
129
...e-client/src/main/java/com/truzzt/extension/logginghouse/client/flyway/FlywayService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,129 @@ | ||
| /* | ||
| * Copyright (c) 2023 sovity GmbH | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Apache License, Version 2.0 which is available at | ||
| * https://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * Contributors: | ||
| * sovity GmbH - initial implementation | ||
| * | ||
| */ | ||
|
|
||
| package com.truzzt.extension.logginghouse.client.flyway; | ||
|
|
||
| import com.truzzt.extension.logginghouse.client.flyway.connection.DatasourceProperties; | ||
| import com.truzzt.extension.logginghouse.client.flyway.connection.DriverManagerConnectionFactory; | ||
| import org.eclipse.edc.spi.monitor.Monitor; | ||
| import org.eclipse.edc.spi.persistence.EdcPersistenceException; | ||
| import org.eclipse.edc.sql.datasource.ConnectionFactoryDataSource; | ||
| import org.flywaydb.core.Flyway; | ||
| import org.flywaydb.core.api.FlywayException; | ||
| import org.flywaydb.core.api.MigrationVersion; | ||
| import org.flywaydb.core.api.output.MigrateResult; | ||
| import org.flywaydb.core.api.output.RepairResult; | ||
|
|
||
| import java.util.List; | ||
| import javax.sql.DataSource; | ||
|
|
||
| public class FlywayService { | ||
|
|
||
| private static final String MIGRATION_LOCATION_BASE = "classpath:migration"; | ||
| private static final String MIGRATION_TABLE_NAME = "flyway_schema_history_logginghouse"; | ||
|
|
||
| private final Monitor monitor; | ||
| private final boolean tryRepairOnFailedMigration; | ||
| private final boolean cleanEnabled; | ||
| private final boolean clean; | ||
|
|
||
| public FlywayService(Monitor monitor, boolean tryRepairOnFailedMigration, boolean cleanEnabled, boolean clean) { | ||
| this.monitor = monitor; | ||
| this.tryRepairOnFailedMigration = tryRepairOnFailedMigration; | ||
| this.cleanEnabled = cleanEnabled; | ||
| this.clean = clean; | ||
| } | ||
|
|
||
| public void cleanDatabase(DatasourceProperties datasourceProperties) { | ||
| if (clean) { | ||
| monitor.info("Running flyway clean."); | ||
| var flyway = setupFlyway(datasourceProperties); | ||
| flyway.clean(); | ||
| } | ||
| } | ||
|
|
||
| public void migrateDatabase(DatasourceProperties datasourceProperties) { | ||
| var flyway = setupFlyway(datasourceProperties); | ||
| flyway.info().getInfoResult().migrations.stream() | ||
| .map(migration -> "Found migration: %s".formatted(migration.filepath)) | ||
| .forEach(monitor::info); | ||
|
|
||
| try { | ||
| var migrateResult = flyway.migrate(); | ||
| handleFlywayMigrationResult(migrateResult); | ||
| } catch (FlywayException e) { | ||
| if (tryRepairOnFailedMigration) { | ||
| repairAndRetryMigration(flyway); | ||
| } else { | ||
| throw new EdcPersistenceException("Flyway migration failed", e); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private void repairAndRetryMigration(Flyway flyway) { | ||
| try { | ||
| var repairResult = flyway.repair(); | ||
| handleFlywayRepairResult(repairResult); | ||
| var migrateResult = flyway.migrate(); | ||
| handleFlywayMigrationResult(migrateResult); | ||
| } catch (FlywayException e) { | ||
| throw new EdcPersistenceException("Flyway migration failed", e); | ||
| } | ||
| } | ||
|
|
||
| private void handleFlywayRepairResult(RepairResult repairResult) { | ||
| if (!repairResult.repairActions.isEmpty()) { | ||
| var repairActions = String.join(", ", repairResult.repairActions); | ||
| monitor.info("Repair actions: %s".formatted(repairActions)); | ||
| } | ||
|
|
||
| if (!repairResult.warnings.isEmpty()) { | ||
| var warnings = String.join(", ", repairResult.warnings); | ||
| throw new EdcPersistenceException("Repairing failed: %s".formatted(warnings)); | ||
| } | ||
| } | ||
|
|
||
| private Flyway setupFlyway(DatasourceProperties datasourceProperties) { | ||
| var dataSource = getDataSource(datasourceProperties); | ||
| var migrationLocations = List.of(MIGRATION_LOCATION_BASE); | ||
| return Flyway.configure() | ||
| .baselineVersion(MigrationVersion.fromVersion("0.0.0")) | ||
| .baselineOnMigrate(true) | ||
| .failOnMissingLocations(true) | ||
| .dataSource(dataSource) | ||
| .table(MIGRATION_TABLE_NAME) | ||
| .locations(migrationLocations.toArray(new String[0])) | ||
| .cleanDisabled(!cleanEnabled) | ||
| .load(); | ||
| } | ||
|
|
||
| private DataSource getDataSource(DatasourceProperties datasourceProperties) { | ||
| var connectionFactory = new DriverManagerConnectionFactory(datasourceProperties); | ||
| return new ConnectionFactoryDataSource(connectionFactory); | ||
| } | ||
|
|
||
| private void handleFlywayMigrationResult(MigrateResult migrateResult) { | ||
| if (migrateResult.migrationsExecuted > 0) { | ||
| monitor.info(String.format( | ||
| "Successfully migrated database from version %s to version %s", | ||
| migrateResult.initialSchemaVersion, | ||
| migrateResult.targetSchemaVersion)); | ||
| } else { | ||
| monitor.info(String.format( | ||
| "No migration necessary. Current version is %s", | ||
| migrateResult.initialSchemaVersion)); | ||
| } | ||
| } | ||
|
|
||
| } |
72 changes: 72 additions & 0 deletions
72
...java/com/truzzt/extension/logginghouse/client/flyway/connection/DatasourceProperties.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,72 @@ | ||
| /* | ||
| * Copyright (c) 2023 sovity GmbH | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Apache License, Version 2.0 which is available at | ||
| * https://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * Contributors: | ||
| * sovity GmbH - initial implementation | ||
| * | ||
| */ | ||
|
|
||
| package com.truzzt.extension.logginghouse.client.flyway.connection; | ||
|
|
||
| import org.eclipse.edc.spi.EdcException; | ||
| import org.eclipse.edc.spi.system.configuration.Config; | ||
|
|
||
| import static org.eclipse.edc.transaction.datasource.spi.DataSourceRegistry.DEFAULT_DATASOURCE; | ||
|
|
||
| public class DatasourceProperties { | ||
| private static final String LOGGING_HOUSE_DATASOURCE = "logginghouse"; | ||
|
|
||
| private static final String DATASOURCE_SETTING_NAME = "edc.datasource.%s.name"; | ||
| private static final String DATASOURCE_SETTING_JDBC_URL = "edc.datasource.%s.url"; | ||
| private static final String DATASOURCE_SETTING_USER = "edc.datasource.%s.user"; | ||
| private static final String DATASOURCE_SETTING_PASSWORD = "edc.datasource.%s.password"; | ||
|
|
||
| private final String name; | ||
| private final String jdbcUrl; | ||
| private final String user; | ||
| private final String password; | ||
|
|
||
| public DatasourceProperties(Config config) { | ||
| name = getSetting(config, String.format(DATASOURCE_SETTING_NAME, LOGGING_HOUSE_DATASOURCE), | ||
| String.format(DATASOURCE_SETTING_NAME, DEFAULT_DATASOURCE)); | ||
|
|
||
| jdbcUrl = getSetting(config, String.format(DATASOURCE_SETTING_JDBC_URL, LOGGING_HOUSE_DATASOURCE), | ||
| String.format(DATASOURCE_SETTING_JDBC_URL, DEFAULT_DATASOURCE)); | ||
|
|
||
| user = getSetting(config, String.format(DATASOURCE_SETTING_USER, LOGGING_HOUSE_DATASOURCE), | ||
| String.format(DATASOURCE_SETTING_USER, DEFAULT_DATASOURCE)); | ||
|
|
||
| password = getSetting(config, String.format(DATASOURCE_SETTING_PASSWORD, LOGGING_HOUSE_DATASOURCE), | ||
| String.format(DATASOURCE_SETTING_PASSWORD, DEFAULT_DATASOURCE)); | ||
| } | ||
|
|
||
| private String getSetting(Config config, String setting, String defaultSetting) { | ||
| try { | ||
| return config.getString(setting); | ||
| } catch (EdcException e) { | ||
| return config.getString(defaultSetting); | ||
| } | ||
| } | ||
|
|
||
| public String getName() { | ||
| return name; | ||
| } | ||
|
|
||
| public String getJdbcUrl() { | ||
| return jdbcUrl; | ||
| } | ||
|
|
||
| public String getUser() { | ||
| return user; | ||
| } | ||
|
|
||
| public String getPassword() { | ||
| return password; | ||
| } | ||
| } |
47 changes: 47 additions & 0 deletions
47
...ruzzt/extension/logginghouse/client/flyway/connection/DriverManagerConnectionFactory.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| /* | ||
| * Copyright (c) 2023 sovity GmbH | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Apache License, Version 2.0 which is available at | ||
| * https://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * Contributors: | ||
| * sovity GmbH - initial implementation | ||
| * | ||
| */ | ||
|
|
||
| package com.truzzt.extension.logginghouse.client.flyway.connection; | ||
|
|
||
| import org.eclipse.edc.spi.persistence.EdcPersistenceException; | ||
| import org.eclipse.edc.sql.ConnectionFactory; | ||
|
|
||
| import java.sql.Connection; | ||
| import java.sql.DriverManager; | ||
| import java.sql.SQLException; | ||
| import java.util.Properties; | ||
|
|
||
| public class DriverManagerConnectionFactory implements ConnectionFactory { | ||
|
|
||
| private static final String CONNECTION_PROPERTY_USER = "user"; | ||
| private static final String CONNECTION_PROPERTY_PASSWORD = "password"; | ||
|
|
||
| private final DatasourceProperties datasourceProperties; | ||
|
|
||
| public DriverManagerConnectionFactory(DatasourceProperties datasourceProperties) { | ||
| this.datasourceProperties = datasourceProperties; | ||
| } | ||
|
|
||
| @Override | ||
| public Connection create() { | ||
| try { | ||
| var properties = new Properties(); | ||
| properties.setProperty(CONNECTION_PROPERTY_USER, datasourceProperties.getUser()); | ||
| properties.setProperty(CONNECTION_PROPERTY_PASSWORD, datasourceProperties.getPassword()); | ||
| return DriverManager.getConnection(datasourceProperties.getJdbcUrl(), properties); | ||
| } catch (SQLException e) { | ||
| throw new EdcPersistenceException(e); | ||
| } | ||
| } | ||
| } |
40 changes: 40 additions & 0 deletions
40
...a/com/truzzt/extension/logginghouse/client/flyway/migration/DatabaseMigrationManager.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,40 @@ | ||
| /* | ||
| * Copyright (c) 2023 sovity GmbH | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Apache License, Version 2.0 which is available at | ||
| * https://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * Contributors: | ||
| * sovity GmbH - initial implementation | ||
| * | ||
| */ | ||
|
|
||
| package com.truzzt.extension.logginghouse.client.flyway.migration; | ||
|
|
||
| import com.truzzt.extension.logginghouse.client.flyway.FlywayService; | ||
| import com.truzzt.extension.logginghouse.client.flyway.connection.DatasourceProperties; | ||
| import org.eclipse.edc.spi.monitor.Monitor; | ||
| import org.eclipse.edc.spi.system.configuration.Config; | ||
|
|
||
| public class DatabaseMigrationManager { | ||
| private final Config config; | ||
| private final Monitor monitor; | ||
| private final FlywayService flywayService; | ||
|
|
||
| public DatabaseMigrationManager(Config config, Monitor monitor, FlywayService flywayService) { | ||
| this.config = config; | ||
| this.monitor = monitor; | ||
| this.flywayService = flywayService; | ||
| } | ||
|
|
||
| public void migrate() { | ||
| var datasourceProperties = new DatasourceProperties(config); | ||
| monitor.info("Using datasource %s to apply flyway migrations".formatted(datasourceProperties.getName())); | ||
|
|
||
| flywayService.cleanDatabase(datasourceProperties); | ||
| flywayService.migrateDatabase(datasourceProperties); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.