Merge pull request julien-duponchelle#352 from dongwook-chan/negative-timedelta

Correct timedelta value for negative MySQL TIME datatype

Author: julien-duponchelle

pymysqlreplication/row_event.py

@@ -285,11 +285,11 @@ def __read_time2(self, column):
  data = ~data + 1
 
  t = datetime.timedelta(
- hours=sign*self.__read_binary_slice(data, 2, 10, 24),
+ hours=self.__read_binary_slice(data, 2, 10, 24),
  minutes=self.__read_binary_slice(data, 12, 6, 24),
  seconds=self.__read_binary_slice(data, 18, 6, 24),
  microseconds=self.__read_fsp(column)
- )
+ ) * sign
  return t
 
  def __read_date(self):

pymysqlreplication/tests/test_data_type.py

@@ -291,7 +291,7 @@ def test_time(self):
  microseconds=(((838*60) + 59)*60 + 59)*1000000
  ))
  self.assertEqual(event.rows[0]["values"]["test2"], datetime.timedelta(
- microseconds=(((-838*60) + 59)*60 + 59)*1000000
+ microseconds=-(((838*60) + 59)*60 + 59)*1000000
  ))
 
  def test_time2(self):
@@ -306,7 +306,7 @@ def test_time2(self):
  microseconds=(((838*60) + 59)*60 + 59)*1000000 + 0
  ))
  self.assertEqual(event.rows[0]["values"]["test2"], datetime.timedelta(
- microseconds=(((-838*60) + 59)*60 + 59)*1000000 + 0
+ microseconds=-(((838*60) + 59)*60 + 59)*1000000 + 0
  ))
 
  def test_zero_time(self):