Fixed bug in processing metadata that spans multiple packets when using

asyncio.

Author: anthony-tuininga

doc/src/release_notes.rst

@@ -30,6 +30,8 @@ Thin Mode Changes
     single line comment at the end of the statement.
 #)  Fixed bug in determining the list of attributes for PL/SQL collections.
 #)  Fixed bug in calculating the :data:`Connection.thin` attribute.
+#)  Fixed bug in processing metadata that spans multiple packets when using
+    :ref:`asyncio <asyncio>`.
 
 Thick Mode Changes
 ++++++++++++++++++

src/oracledb/impl/thin/messages.pyx

@@ -459,7 +459,7 @@ cdef class MessageWithData(Message):
         # if no fetch variables exist, nothing further to do at this point; the
         # processing that follows will take the metadata returned by the server
         # and use it to create new fetch variables
-        if cursor_impl.fetch_var_impls is None:
+        if statement._fetch_var_impls is None:
             return 0
 
         # if the type handler set on the cursor or connection does not match
@@ -717,7 +717,7 @@ cdef class MessageWithData(Message):
             str message
         buf.skip_ub4()                      # max row size
         buf.read_ub4(&cursor_impl._num_columns)
-        prev_fetch_var_impls = cursor_impl.fetch_var_impls
+        prev_fetch_var_impls = stmt._fetch_var_impls
         cursor_impl._init_fetch_vars(cursor_impl._num_columns)
         if cursor_impl._num_columns > 0:
             buf.skip_ub1()

tests/test_5400_cursor_execute_async.py

@@ -593,6 +593,15 @@ async def test_5434(self):
             await cursor.execute("select user from dual")
             self.assertEqual(await cursor.fetchone(), (expected_value,))
 
+    async def test_5435(self):
+        "5435 - test metadata requiring multiple packets"
+        values = [f"Test value 5435 - {i}" for i in range(1, 301)]
+        columns = ", ".join(f"'{v}'" for v in values)
+        query = f"select {columns} from dual"
+        await self.cursor.execute(query)
+        row = await self.cursor.fetchone()
+        self.assertEqual(row, tuple(values))
+
 
 if __name__ == "__main__":
     test_env.run_test_cases()