github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#9506] org.jooq.Migration implementation

Browse Source 
- MigrationImpl.toString() implementation for debugging
This commit is contained in:
Lukas Eder 2019-12-16 14:41:10 +01:00
parent c33cd0bd8d
commit 0bef99c814
1 changed files with 35 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
jOOQ/src/main/java/org/jooq/impl/MigrationImpl.java
View File

@ -39,6 +39,8 @@ package org.jooq.impl;
import static java.lang.Boolean.FALSE;
import static org.jooq.impl.DSL.createSchemaIfNotExists;
import static org.jooq.impl.DSL.dropSchemaIfExists;
import static org.jooq.impl.DSL.dropTableIfExists;
import java.sql.Timestamp;
import java.util.Arrays;
@ -141,12 +143,26 @@ final class MigrationImpl extends AbstractScope implements Migration {
Version currentVersion = currentVersion();
Meta currentMeta = currentVersion.meta();
List<Schema> expectedSchemas = to().meta().getSchemas();
// TODO Add a settings governing what schemas we're including in the migration
// The current implementation will default to migrating all schemas that are
// touched by the to() version
Meta existingMeta = dsl().meta();
for (Schema schema : existingMeta.getSchemas()) {
for (Schema schema : existingMeta.getSchemas())
currentMeta = currentMeta.apply(createSchemaIfNotExists(schema));
// TODO Why is this qualification necessary?
existingMeta = existingMeta.apply(dropTableIfExists(schema.getQualifiedName().append(CHANGELOG.getUnqualifiedName())).cascade());
System.out.println(existingMeta.migrateTo(currentMeta));
if (!expectedSchemas.contains(schema))
existingMeta = existingMeta.apply(dropSchemaIfExists(schema).cascade());
else
currentMeta = currentMeta.apply(createSchemaIfNotExists(schema));
}
Queries diff = currentMeta.migrateTo(existingMeta);
if (diff.queries().length > 0)
throw new DataMigrationValidationException("Non-empty difference between actual schema and migration from schema: " + diff);
}
private static final MigrationResult MIGRATION_RESULT = new MigrationResult() {};
@ -215,6 +231,11 @@ final class MigrationImpl extends AbstractScope implements Migration {
// TODO: Make batching an option: queries().executeBatch();
for (Query query : queries().queries()) {
// TODO: Properly configure the schema creation
if (query.toString().startsWith("create schema") || query.toString().startsWith("drop schema"))
continue;
ctx.query(query);
listener.queryStart(ctx);
query.execute();
@ -302,6 +323,17 @@ final class MigrationImpl extends AbstractScope implements Migration {
}
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("-- Migration\n-- From: ").append(from().id()).append("\n")
.append("-- To : ").append(to().id()).append("\n")
.append(queries());
return sb.toString();
}
// -------------------------------------------------------------------------
// XXX: Generated code
// -------------------------------------------------------------------------