Merge pull request #129 from hc/wrong_date

Don't fail on incomplete dates (with 00 as day or month)

Author: julien-duponchelle

pymysqlreplication/row_event.py

@@ -252,11 +252,10 @@ def __read_date(self):
             return None
 
         year = (time & ((1 << 15) - 1) << 9) >> 9
-        if year == 0:
-            return None
-
         month = (time & ((1 << 4) - 1) << 5) >> 5
         day = (time & ((1 << 5) - 1))
+        if year == 0 or month == 0 or day == 0:
+            return None
 
         date = datetime.date(
             year=year,

pymysqlreplication/tests/test_data_type.py

@@ -248,6 +248,20 @@ def test_zero_date(self):
         self.assertEqual(event.rows[0]["values"]["test"], None)
         self.assertEqual(event.rows[0]["values"]["test2"], None)
 
+    def test_zero_month(self):
+        create_query = "CREATE TABLE test (id INTEGER, test DATE, test2 DATE);"
+        insert_query = "INSERT INTO test (id, test2) VALUES(1, '2015-00-21')"
+        event = self.create_and_insert_value(create_query, insert_query)
+        self.assertEqual(event.rows[0]["values"]["test"], None)
+        self.assertEqual(event.rows[0]["values"]["test2"], None)
+
+    def test_zero_day(self):
+        create_query = "CREATE TABLE test (id INTEGER, test DATE, test2 DATE);"
+        insert_query = "INSERT INTO test (id, test2) VALUES(1, '2015-05-00')"
+        event = self.create_and_insert_value(create_query, insert_query)
+        self.assertEqual(event.rows[0]["values"]["test"], None)
+        self.assertEqual(event.rows[0]["values"]["test2"], None)
+
     def test_time(self):
         create_query = "CREATE TABLE test (test TIME);"
         insert_query = "INSERT INTO test VALUES('12:33:18')"