Fix Timestamp conversion to return UTC instead of local timezone (julien-duponchelle#443)

* fix: capitalize sql statements

* fix: fix timestamp into utc timezone

Author: soulee-dev

pymysqlreplication/event.py

@@ -39,7 +39,7 @@ def _read_table_id(self):
 
     def dump(self):
         print("=== %s ===" % (self.__class__.__name__))
-        print("Date: %s" % (datetime.datetime.fromtimestamp(self.timestamp)
+        print("Date: %s" % (datetime.datetime.utcfromtimestamp(self.timestamp)
                             .isoformat()))
         print("Log position: %d" % self.packet.log_pos)
         print("Event size: %d" % (self.event_size))

pymysqlreplication/row_event.py

@@ -174,7 +174,7 @@ def _read_column_data(self,  cols_bitmap):
             elif column.type == FIELD_TYPE.DATE:
                 values[name] = self.__read_date()
             elif column.type == FIELD_TYPE.TIMESTAMP:
-                values[name] = datetime.datetime.fromtimestamp(
+                values[name] = datetime.datetime.utcfromtimestamp(
                     self.packet.read_uint32())
 
             # For new date format:
@@ -184,7 +184,7 @@ def _read_column_data(self,  cols_bitmap):
                 values[name] = self.__read_time2(column)
             elif column.type == FIELD_TYPE.TIMESTAMP2:
                 values[name] = self.__add_fsp_to_time(
-                    datetime.datetime.fromtimestamp(
+                    datetime.datetime.utcfromtimestamp(
                         self.packet.read_int_be_by_size(4)), column)
             elif column.type == FIELD_TYPE.LONGLONG:
                 if unsigned: