Skip to content

Commit

Permalink
Implemented notification ctl migration and small refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
Kirill380 committed Aug 15, 2016
1 parent 67964c3 commit 80cdc77
Show file tree
Hide file tree
Showing 8 changed files with 26 additions and 5 deletions.
Expand Up @@ -42,7 +42,7 @@ public AbstractCTLMigration(Connection connection) {
}

public void beforeTransform() throws SQLException {
// delete relation between <feature>_schems to schems
// delete relation between <table_prefix>_schems to schems
dd.dropUnnamedFK(getPrefixTableName() + "_schems", "schems");
}

Expand Down
Expand Up @@ -18,11 +18,11 @@

import java.sql.Connection;

public class CtlLogMigration extends AbstractCTLMigration {
public class CTLLogMigration extends AbstractCTLMigration {

public static final String LOG_SCHEMA_PREFIX_TABLE_NAME = "log";

public CtlLogMigration(Connection connection) {
public CTLLogMigration(Connection connection) {
super(connection);
}

Expand Down
@@ -0,0 +1,19 @@
package org.kaaproject.data_migration;

import java.sql.Connection;

/**
* Created by user223225 on 15.08.16.
*/
public class CTLNotificationMigration extends AbstractCTLMigration {


public CTLNotificationMigration(Connection connection) {
super(connection);
}

@Override
protected String getPrefixTableName() {
return "notification";
}
}
Expand Up @@ -47,7 +47,8 @@ public static void main(String[] args) {
List<AbstractCTLMigration> migrationList = new ArrayList<>();
migrationList.add(new CTLConfigurationMigration(conn));
migrationList.add(new CTLEventsMigration(conn));
migrationList.add(new CtlLogMigration(conn));
migrationList.add(new CTLNotificationMigration(conn));
migrationList.add(new CTLLogMigration(conn));

CTLAggregation aggregation = new CTLAggregation(conn);
BaseSchemaRecordsCreation recordsCreation = new BaseSchemaRecordsCreation(conn);
Expand Down

Large diffs are not rendered by default.

Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.

Large diffs are not rendered by default.

Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.

0 comments on commit 80cdc77

Please sign in to comment.