mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
ALF-7260: schema comparator
* replace path/push/pop mechanism as it doesn't work well at reporting where differences/validation errors occur. * add getParent() to DbObject - so that a path-style identifier can be deduced for a DbObject when needed * add DbProperty to specify a specific DbObject's property and value -- acts as a schema location pointer * refactored Result code (need difference result and validation error result) git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@31527 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
@@ -20,7 +20,7 @@ package org.alfresco.util.schemacomp;
|
||||
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertNull;
|
||||
import static org.junit.Assert.assertSame;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
|
||||
import java.util.Arrays;
|
||||
@@ -28,10 +28,8 @@ import java.util.Collection;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
||||
import org.alfresco.util.schemacomp.Result.Strength;
|
||||
import org.alfresco.util.schemacomp.Result.Where;
|
||||
import org.alfresco.util.schemacomp.Difference.Where;
|
||||
import org.alfresco.util.schemacomp.model.Column;
|
||||
import org.alfresco.util.schemacomp.model.DbObject;
|
||||
import org.alfresco.util.schemacomp.model.ForeignKey;
|
||||
import org.alfresco.util.schemacomp.model.Index;
|
||||
import org.alfresco.util.schemacomp.model.PrimaryKey;
|
||||
@@ -68,18 +66,18 @@ public class SchemaComparatorTest
|
||||
public void canPerformDiff()
|
||||
{
|
||||
// Left hand side's database objects.
|
||||
left.add(new Table("tbl_no_diff", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)", "name VARCHAR2(150)"),
|
||||
left.add(new Table(left, "tbl_no_diff", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)", "name VARCHAR2(150)"),
|
||||
pk("pk_tbl_no_diff", "id"), fkeys(fk("fk_tbl_no_diff", "nodeRef", "node", "nodeRef")),
|
||||
indexes("idx_node id nodeRef")));
|
||||
left.add(table("table_in_left"));
|
||||
left.add(new Table("tbl_has_diff_pk", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)"),
|
||||
left.add(new Table(left, "tbl_has_diff_pk", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)"),
|
||||
pk("pk_is_diff", "id"), fkeys(), indexes()));
|
||||
|
||||
// Right hand side's database objects.
|
||||
right.add(new Table("tbl_no_diff", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)", "name VARCHAR2(150)"),
|
||||
right.add(new Table(right, "tbl_no_diff", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)", "name VARCHAR2(150)"),
|
||||
pk("pk_tbl_no_diff", "id"), fkeys(fk("fk_tbl_no_diff", "nodeRef", "node", "nodeRef")),
|
||||
indexes("idx_node id nodeRef")));
|
||||
right.add(new Table("tbl_has_diff_pk", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)"),
|
||||
right.add(new Table(right, "tbl_has_diff_pk", columns("id NUMBER(10)", "nodeRef VARCHAR2(200)"),
|
||||
pk("pk_is_diff", "nodeRef"), fkeys(), indexes()));
|
||||
right.add(table("table_in_right"));
|
||||
|
||||
@@ -87,53 +85,57 @@ public class SchemaComparatorTest
|
||||
comparator = new SchemaComparator(left, right, dialect);
|
||||
comparator.validateAndCompare();
|
||||
|
||||
// See stdout for diagnostics dump...
|
||||
dumpDiffs(comparator.getDifferences(), false);
|
||||
dumpValidation(comparator.getValidationResults());
|
||||
|
||||
Iterator<Result> it = comparator.getDifferences().iterator();
|
||||
|
||||
assertHasDifference("left_schema", "left_schema", "right_schema", it.next()); // schema names
|
||||
assertNoDifference("left_schema.tbl_no_diff", "tbl_no_diff", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.id", "id", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.id", "NUMBER(10)", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.id", Boolean.FALSE, it.next()); // nullable
|
||||
assertNoDifference("left_schema.tbl_no_diff.nodeRef", "nodeRef", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.nodeRef", "VARCHAR2(200)", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.nodeRef", Boolean.FALSE, it.next()); // nullable
|
||||
assertNoDifference("left_schema.tbl_no_diff.name", "name", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.name", "VARCHAR2(150)", it.next());
|
||||
assertNoDifference("left_schema.tbl_no_diff.name", Boolean.FALSE, it.next()); // nullable
|
||||
assertNoDifference("left_schema.tbl_no_diff.pk_tbl_no_diff", "pk_tbl_no_diff", it.next()); // name field
|
||||
assertNoDifference("left_schema.tbl_no_diff.pk_tbl_no_diff", "id", it.next()); // first (& only) column of list
|
||||
assertNoDifference("left_schema.tbl_no_diff.fk_tbl_no_diff", "fk_tbl_no_diff", it.next()); // name field
|
||||
assertNoDifference("left_schema.tbl_no_diff.fk_tbl_no_diff", "nodeRef", it.next()); // localColumn
|
||||
assertNoDifference("left_schema.tbl_no_diff.fk_tbl_no_diff", "node", it.next()); // targetTable
|
||||
assertNoDifference("left_schema.tbl_no_diff.fk_tbl_no_diff", "nodeRef", it.next()); // targetColumn
|
||||
assertNoDifference("left_schema.tbl_no_diff.idx_node", "idx_node", it.next()); // index name
|
||||
assertNoDifference("left_schema.tbl_no_diff.idx_node", "id", it.next()); // first indexed column
|
||||
assertNoDifference("left_schema.tbl_no_diff.idx_node", "nodeRef", it.next()); // second indexed column
|
||||
// TODO: why are diffs for table not flattened out as for index?
|
||||
assertOnlyInOne("left_schema", Where.ONLY_IN_LEFT, table("table_in_left"), it.next());
|
||||
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk", "tbl_has_diff_pk", it.next());
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.id", "id", it.next());
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.id", "NUMBER(10)", it.next());
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.id", Boolean.FALSE, it.next()); // nullable
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.nodeRef", "nodeRef", it.next());
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.nodeRef", "VARCHAR2(200)", it.next());
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.nodeRef", Boolean.FALSE, it.next()); // nullable
|
||||
assertNoDifference("left_schema.tbl_has_diff_pk.pk_is_diff", "pk_is_diff", it.next()); // name field
|
||||
|
||||
// TODO: surely this should be a diff rather than a ONLY_IN_LEFT plus ONLY_IN_RIGHT?
|
||||
// assertHasDifference("left_schema.tbl_has_diff_pk.pk_is_diff", "id", "nodeRef", it.next()); // first (& only) column of list
|
||||
assertOnlyInOne("left_schema.tbl_has_diff_pk.pk_is_diff", Where.ONLY_IN_LEFT, "id", it.next()); // first (& only) column of list
|
||||
Results differences = comparator.getDifferences();
|
||||
assertEquals(5, differences.size());
|
||||
|
||||
// This belong to the pk_is_diff above.
|
||||
assertOnlyInOne("left_schema.tbl_has_diff_pk.pk_is_diff", Where.ONLY_IN_RIGHT, "nodeRef", it.next()); // first (& only) column of list
|
||||
Iterator<Difference> it = differences.iterator();
|
||||
|
||||
// Items that are ONLY_IN_RIGHT always come at the end
|
||||
assertEquals("Should be table with correct name", "tbl_has_diff_pk", ((DbObject) it.next().getRight()).getName());
|
||||
assertOnlyInOne("left_schema", Where.ONLY_IN_RIGHT, table("table_in_right"), it.next());
|
||||
// Schema names are different ("left_schema" vs "right_schema")
|
||||
Difference diff = it.next();
|
||||
assertEquals(Where.IN_BOTH_BUT_DIFFERENCE, diff.getWhere());
|
||||
assertEquals("left_schema.name", diff.getLeft().getPath());
|
||||
assertEquals("right_schema.name", diff.getRight().getPath());
|
||||
assertSame(left, diff.getLeft().getDbObject());
|
||||
assertSame(right, diff.getRight().getDbObject());
|
||||
assertEquals("name", diff.getLeft().getPropertyName());
|
||||
assertEquals("left_schema", diff.getLeft().getPropertyValue());
|
||||
assertEquals("name", diff.getRight().getPropertyName());
|
||||
assertEquals("right_schema", diff.getRight().getPropertyValue());
|
||||
|
||||
// Table table_in_left only appears in the left schema
|
||||
diff = it.next();
|
||||
assertEquals(Where.ONLY_IN_LEFT, diff.getWhere());
|
||||
assertEquals("left_schema.table_in_left", diff.getLeft().getPath());
|
||||
assertEquals(null, diff.getRight());
|
||||
assertEquals(null, diff.getLeft().getPropertyName());
|
||||
assertEquals(null, diff.getLeft().getPropertyValue());
|
||||
|
||||
// Table tbl_has_diff_pk has PK of "id" in left and "nodeRef" in right
|
||||
diff = it.next();
|
||||
assertEquals(Where.ONLY_IN_LEFT, diff.getWhere());
|
||||
assertEquals("left_schema.tbl_has_diff_pk.pk_is_diff.columnNames[0]", diff.getLeft().getPath());
|
||||
assertEquals("right_schema.tbl_has_diff_pk.pk_is_diff.columnNames", diff.getRight().getPath());
|
||||
assertEquals("columnNames[0]", diff.getLeft().getPropertyName());
|
||||
assertEquals("id", diff.getLeft().getPropertyValue());
|
||||
assertEquals("columnNames", diff.getRight().getPropertyName());
|
||||
assertEquals(Arrays.asList("nodeRef"), diff.getRight().getPropertyValue());
|
||||
|
||||
// Table tbl_has_diff_pk has PK of "id" in left and "nodeRef" in right
|
||||
diff = it.next();
|
||||
assertEquals(Where.ONLY_IN_RIGHT, diff.getWhere());
|
||||
assertEquals("left_schema.tbl_has_diff_pk.pk_is_diff.columnNames", diff.getLeft().getPath());
|
||||
assertEquals("right_schema.tbl_has_diff_pk.pk_is_diff.columnNames[0]", diff.getRight().getPath());
|
||||
assertEquals("columnNames", diff.getLeft().getPropertyName());
|
||||
assertEquals(Arrays.asList("id"), diff.getLeft().getPropertyValue());
|
||||
assertEquals("columnNames[0]", diff.getRight().getPropertyName());
|
||||
assertEquals("nodeRef", diff.getRight().getPropertyValue());
|
||||
|
||||
// Table table_in_right does not exist in the left schema
|
||||
}
|
||||
|
||||
|
||||
@@ -145,111 +147,11 @@ public class SchemaComparatorTest
|
||||
System.out.println(r);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Test
|
||||
public void canReportWarnings()
|
||||
{
|
||||
// Left hand side's database objects.
|
||||
left.add(new Table("tbl_example", columns("id NUMBER(10)"), pk("pk_tbl_example", "id"), fkeys(),
|
||||
indexes("idx_specified_name id")));
|
||||
|
||||
// Right hand side's database objects.
|
||||
right.add(new Table("tbl_example", columns("id NUMBER(10)"), pk("pk_tbl_example", "id"), fkeys(),
|
||||
indexes("sys_random_idx_name id")));
|
||||
|
||||
|
||||
comparator = new SchemaComparator(left, right, dialect);
|
||||
comparator.validateAndCompare();
|
||||
|
||||
dumpDiffs(comparator.getDifferences(), true);
|
||||
dumpValidation(comparator.getValidationResults());
|
||||
|
||||
Iterator<Result> it = comparator.getDifferences().iterator();
|
||||
assertHasDifference("left_schema", "left_schema", "right_schema", it.next());
|
||||
assertNoDifference("left_schema.tbl_example", "tbl_example", it.next());
|
||||
assertNoDifference("left_schema.tbl_example.id", "id", it.next());
|
||||
assertNoDifference("left_schema.tbl_example.id", "NUMBER(10)", it.next());
|
||||
assertNoDifference("left_schema.tbl_example.id", Boolean.FALSE, it.next());
|
||||
assertNoDifference("left_schema.tbl_example.pk_tbl_example", "pk_tbl_example", it.next());
|
||||
assertNoDifference("left_schema.tbl_example.pk_tbl_example", "id", it.next());
|
||||
|
||||
assertHasWarning(
|
||||
"left_schema.tbl_example.idx_specified_name",
|
||||
"idx_specified_name",
|
||||
"sys_random_idx_name",
|
||||
it.next());
|
||||
}
|
||||
|
||||
/**
|
||||
* Assert that the result shows the value to have different values in the left and right items.
|
||||
*/
|
||||
private void assertHasDifference(String path, Object leftValue, Object rightValue,
|
||||
Result result, Strength strength)
|
||||
{
|
||||
assertEquals(strength, result.getStrength());
|
||||
assertEquals(Where.IN_BOTH_BUT_DIFFERENCE, result.getWhere());
|
||||
assertEquals(path, result.getPath());
|
||||
assertEquals(leftValue, result.getLeft());
|
||||
assertEquals(rightValue, result.getRight());
|
||||
}
|
||||
|
||||
/**
|
||||
* @see #assertHasDifference(String, Object, Object, Result, Strength)
|
||||
*/
|
||||
private void assertHasDifference(String path, Object leftValue, Object rightValue, Result result)
|
||||
{
|
||||
assertHasDifference(path, leftValue, rightValue, result, Strength.ERROR);
|
||||
}
|
||||
|
||||
/**
|
||||
* @see #assertHasDifference(String, Object, Object, Result, Strength)
|
||||
*/
|
||||
private void assertHasWarning(String path, Object leftValue, Object rightValue, Result result)
|
||||
{
|
||||
assertHasDifference(path, leftValue, rightValue, result, Strength.WARN);
|
||||
}
|
||||
|
||||
/**
|
||||
* Assert that the result shows the value to be present only in either the left or right items.
|
||||
*/
|
||||
private void assertOnlyInOne(String path, Where which, Object value, Result result)
|
||||
{
|
||||
assertEquals(which, result.getWhere());
|
||||
assertEquals(path, result.getPath());
|
||||
|
||||
if (which == Where.ONLY_IN_LEFT)
|
||||
{
|
||||
assertEquals(value, result.getLeft());
|
||||
assertNull(result.getRight());
|
||||
}
|
||||
else if (which == Where.ONLY_IN_RIGHT)
|
||||
{
|
||||
assertNull(result.getLeft());
|
||||
assertEquals(value, result.getRight());
|
||||
}
|
||||
else
|
||||
{
|
||||
throw new IllegalArgumentException("The 'which' argument should be ONLY_IN_LEFT or ONLY_IN_RIGHT.");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Assert that the result shows no differences between the left and right items.
|
||||
*/
|
||||
private void assertNoDifference(String path, Object value, Result result)
|
||||
{
|
||||
assertEquals(Where.IN_BOTH_NO_DIFFERENCE, result.getWhere());
|
||||
assertEquals(path, result.getPath());
|
||||
assertEquals(value, result.getLeft());
|
||||
assertEquals(value, result.getRight());
|
||||
}
|
||||
|
||||
|
||||
private void dumpDiffs(Differences differences, boolean showNonDifferences)
|
||||
private void dumpDiffs(Results differences, boolean showNonDifferences)
|
||||
{
|
||||
System.out.println("Differences (" + differences.size() + ")");
|
||||
for (Result d : differences)
|
||||
for (Difference d : differences)
|
||||
{
|
||||
if (d.getWhere() != Where.IN_BOTH_NO_DIFFERENCE || showNonDifferences)
|
||||
{
|
||||
@@ -260,7 +162,7 @@ public class SchemaComparatorTest
|
||||
|
||||
private Table table(String name)
|
||||
{
|
||||
return new Table(name, columns("id NUMBER(10)"), pk("pk_" + name, "id"), fkeys(), indexes());
|
||||
return new Table(null, name, columns("id NUMBER(10)"), pk("pk_" + name, "id"), fkeys(), indexes());
|
||||
}
|
||||
|
||||
private Collection<Column> columns(String... colDefs)
|
||||
@@ -271,7 +173,7 @@ public class SchemaComparatorTest
|
||||
for (int i = 0; i < colDefs.length; i++)
|
||||
{
|
||||
String[] parts = colDefs[i].split(" ");
|
||||
columns[i] = new Column(parts[0], parts[1], false);
|
||||
columns[i] = new Column(null, parts[0], parts[1], false);
|
||||
}
|
||||
return Arrays.asList(columns);
|
||||
}
|
||||
@@ -279,7 +181,7 @@ public class SchemaComparatorTest
|
||||
private PrimaryKey pk(String name, String... columnNames)
|
||||
{
|
||||
assertTrue("No columns specified", columnNames.length > 0);
|
||||
PrimaryKey pk = new PrimaryKey(name, Arrays.asList(columnNames));
|
||||
PrimaryKey pk = new PrimaryKey(null, name, Arrays.asList(columnNames));
|
||||
return pk;
|
||||
}
|
||||
|
||||
@@ -290,7 +192,7 @@ public class SchemaComparatorTest
|
||||
|
||||
private ForeignKey fk(String fkName, String localColumn, String targetTable, String targetColumn)
|
||||
{
|
||||
return new ForeignKey(fkName, localColumn, targetTable, targetColumn);
|
||||
return new ForeignKey(null, fkName, localColumn, targetTable, targetColumn);
|
||||
}
|
||||
|
||||
private Collection<Index> indexes(String... indexDefs)
|
||||
@@ -301,7 +203,7 @@ public class SchemaComparatorTest
|
||||
String[] parts = indexDefs[i].split(" ");
|
||||
String name = parts[0];
|
||||
String[] columns = (String[]) ArrayUtils.subarray(parts, 1, parts.length);
|
||||
indexes[i] = new Index(name, Arrays.asList(columns));
|
||||
indexes[i] = new Index(null, name, Arrays.asList(columns));
|
||||
}
|
||||
return Arrays.asList(indexes);
|
||||
}
|
||||
|
Reference in New Issue
Block a user