More tests and fixes

Author: bakwc

mysql_ch_replicator/clickhouse_api.py

@@ -135,7 +135,7 @@ def insert(self, table_name, records, table_structure: TableStructure = None):
                         try:
                             e.timestamp()
                         except (ValueError, AttributeError):
-                            e = 0
+                            e = datetime.datetime(1970, 1, 1)
                 new_record.append(e)
             record = new_record
 

test_mysql_ch_replicator.py

@@ -481,3 +481,13 @@ def test_datetime_exception():
 
     assert_wait(lambda: TEST_TABLE_NAME in ch.get_tables())
     assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 1)
+
+    mysql.execute(
+        f"INSERT INTO {TEST_TABLE_NAME} (name, modified_date) VALUES ('Alex', '0000-00-00 00:00:00');",
+        commit=True,
+    )
+    mysql.execute(
+        f"INSERT INTO {TEST_TABLE_NAME} (name, modified_date) VALUES ('Givi', '2023-01-08 03:11:09');",
+        commit=True,
+    )
+    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 3)