more test case for DATA_TOO_MANY_UNMATCHED_ROWS

Author: guyplusplus

src/test/java/com/geckotechnology/mySqlDataCompare/AppTest.java

@@ -84,7 +84,7 @@ public void testCompareSchemaAndData() throws Exception
 		assertEquals(schemaDifferences.size(), 27);
 
 		ArrayList<Table> tablesReadyToBeDataAnalyzed = mySQLSchemaComparer.getMasterTablesReadyToBeDataAnalyzed();
-		assertEquals(tablesReadyToBeDataAnalyzed.size(), 5);
+		assertEquals(tablesReadyToBeDataAnalyzed.size(), 6);
 		MySQLTableDataComparer tableDataComparer = new MySQLTableDataComparer(masterSchemaReader, slaveSchemaReader);
 		for(Table table:tablesReadyToBeDataAnalyzed)
 			tableDataComparer.compareTable(table);
@@ -100,11 +100,12 @@ public void testCompareSchemaAndData() throws Exception
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "tab3", DifferenceType.DATA_ROW_MISSING_IN_SLAVE_TABLE, "(uid,sometext2)=(4,d2)")) >= 0);
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "tab3", DifferenceType.DATA_ROW_EXCESS_IN_SLAVE_TABLE, "(uid,sometext2)=(4,d3)")) >= 0);
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "tab3", DifferenceType.DATA_ROW_EXCESS_IN_SLAVE_TABLE, "(uid,sometext2)=(6,e2)")) >= 0);
-
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "bigtable", DifferenceType.DATA_ROW_EXCESS_IN_SLAVE_TABLE, "(uid)=(300000001)")) >= 0);
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "bigtable", DifferenceType.DATA_ROW_DIFFERENT_MD5, "(uid)=(500000001)")) >= 0);
 		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "bigtable", DifferenceType.DATA_ROW_MISSING_IN_SLAVE_TABLE, "(uid)=(700000001)")) >= 0);
-		assertEquals(dataDifferences.size(), 14);
+		assertTrue(dataDifferences.indexOf(new SchemaDifference(Criticality.ERROR, "bigdiff", DifferenceType.DATA_TOO_MANY_UNMATCHED_ROWS, "max rows:100")) >= 0);
+
+		assertEquals(dataDifferences.size(), 15);
         assertTrue(tableDataComparer.getMasterTotalRetrievedRows() > 900000);
         assertTrue(tableDataComparer.getSlaveTotalRetrievedRows() > 900000);
     }

src/test/resources/test_schemas.sql

@@ -294,6 +294,28 @@ INSERT INTO schema_B.bigtable ( uid, rndint ) VALUES ( 500000001, 4567);
 INSERT INTO schema_A.bigtable ( uid, rndint ) VALUES ( 700000001, 1234);
 INSERT INTO schema_B.bigtable ( uid, rndint ) VALUES ( 300000001, 4567);
 
+#######
+# Big diff Table with 1,000 rows
+
+create table schema_A.bigdiff(
+   uid INT,
+   rndint INT,
+   PRIMARY KEY ( uid )
+);
+
+INSERT IGNORE INTO schema_A.bigdiff ( uid, rndint )
+SELECT 2 * round(rand() * 1073741823), 2 * round(rand() * 1073741823) 
+FROM 
+(select 0 as i union select 1 union select 2 union select 3 union select 4 union select 5 union select 6 union select 7 union select 8 union select 9) as t1,
+(select 0 as i union select 1 union select 2 union select 3 union select 4 union select 5 union select 6 union select 7 union select 8 union select 9) as t2,
+(select 0 as i union select 1 union select 2 union select 3 union select 4 union select 5 union select 6 union select 7 union select 8 union select 9) as t3;
+
+create table schema_B.bigdiff(
+   uid INT,
+   rndint INT,
+   PRIMARY KEY ( uid )
+);
+
 #######
 # View to make sure it has no impact