Revert TIME return datetime.time object. (#37)

Author: long2ice

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## 0.2
 
+### 0.2.5
+
+- Revert `TIME` return `datetime.time` object. (#37)
+
 ### 0.2.4
 
 - Fix `escape_string` for enum type. (#30)

asyncmy/converters.pyx

@@ -313,7 +313,7 @@ cdef dict decoders = {
     YEAR: int,
     TIMESTAMP: convert_datetime,
     DATETIME: convert_datetime,
-    TIME: convert_time,
+    TIME: convert_timedelta,
     DATE: convert_date,
     BLOB: through,
     TINY_BLOB: through,

asyncmy/replication/binlogstream.py

@@ -39,7 +39,7 @@ class ReportSlave:
     def __init__(self, value: Union[str, tuple, dict]):
         self._hostname = ""
         self._username = ""
-        self._password = ""
+        self._password = ""  # nosec: B105
         self._port = 0
         if isinstance(value, (tuple, list)):
             try:

asyncmy/replication/row_events.py

@@ -197,7 +197,7 @@ def _read_column_data(self, cols_bitmap):
                 # are enabled
                 bit_mask = self.packet.read_uint_by_size(column.size)
                 values[name] = (
-                    set(val for idx, val in enumerate(column.set_values) if bit_mask & 2 ** idx)
+                    set(val for idx, val in enumerate(column.set_values) if bit_mask & 2**idx)
                     or None
                 )
 

conftest.py

@@ -1,7 +1,7 @@
 import asyncio
 import os
 
-import pytest
+import pytest_asyncio
 
 import asyncmy
 from asyncmy import connect
@@ -16,7 +16,7 @@
 )
 
 
-@pytest.fixture(scope="session")
+@pytest_asyncio.fixture(scope="session")
 def event_loop():
     policy = asyncio.get_event_loop_policy()
     res = policy.new_event_loop()
@@ -29,14 +29,14 @@ def event_loop():
     res._close()
 
 
-@pytest.fixture(scope="session")
+@pytest_asyncio.fixture(scope="session")
 async def connection():
     conn = await connect(**connection_kwargs)
     yield conn
     await conn.ensure_closed()
 
 
-@pytest.fixture(scope="session", autouse=True)
+@pytest_asyncio.fixture(scope="session", autouse=True)
 async def initialize_tests(connection):
     async with connection.cursor(cursor=DictCursor) as cursor:
         await cursor.execute("create database if not exists test")
@@ -56,13 +56,13 @@ async def initialize_tests(connection):
         )
 
 
-@pytest.fixture(scope="function", autouse=True)
+@pytest_asyncio.fixture(scope="function", autouse=True)
 async def truncate_table(connection):
     async with connection.cursor(cursor=DictCursor) as cursor:
         await cursor.execute("truncate table test.asyncmy")
 
 
-@pytest.fixture(scope="session")
+@pytest_asyncio.fixture(scope="session")
 async def pool():
     pool = await asyncmy.create_pool(**connection_kwargs)
     yield pool