support REAL column types

Ben Osheroff · Ben Osheroff · commit cff03ba9dbcc · 2015-06-18T14:57:06.000-07:00
these are sql-syntax aliases for 'double' types
diff --git a/src/main/java/com/zendesk/maxwell/schema/columndef/ColumnDef.java b/src/main/java/com/zendesk/maxwell/schema/columndef/ColumnDef.java
@@ -55,6 +55,9 @@ public static ColumnDef build(String tableName, String name, String encoding, St
 		case "mediumblob":
 		case "longblob":
 			return new StringColumnDef(tableName, name, type, pos, "binary");
+		case "real":
+			type = "double";
+			// fall through
 		case "float":
 		case "double":
 			return new FloatColumnDef(tableName, name, type, pos);
diff --git a/src/test/java/com/zendesk/maxwell/schema/ddl/DDLIntegrationTest.java b/src/test/java/com/zendesk/maxwell/schema/ddl/DDLIntegrationTest.java
@@ -163,4 +163,13 @@ public void testBooleans() throws Exception {
 
 		testIntegration(sql);
 	}
+
+	@Test
+	public void testReals() throws Exception {
+		String sql[] = {
+			"create TABLE `test_reals` ( r1 REAL, b2 REAL (2,2) )"
+		};
+
+		testIntegration(sql);
+	}
 }

Original file line number	Diff line number	Diff line change
`@@ -163,4 +163,13 @@ public void testBooleans() throws Exception {`
`163`	`163`
`164`	`164`	`testIntegration(sql);`
`165`	`165`	`}`
	`166`	`+`
	`167`	`+ @Test`
	`168`	`+ public void testReals() throws Exception {`
	`169`	`+ String sql[] = {`
	`170`	+ "create TABLE `test_reals` ( r1 REAL, b2 REAL (2,2) )"
	`171`	`+ };`
	`172`	`+`
	`173`	`+ testIntegration(sql);`
	`174`	`+ }`
`166`	`175`	`}`