Test suite improvements.

Author: anthony-tuininga

tests/test_1100_connection.py

@@ -699,6 +699,9 @@ def test_1135(self):
         (instance_name,) = cursor.fetchone()
         self.assertEqual(conn.instance_name.upper(), instance_name)
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (18, 1), "not supported on this client"
+    )
     def test_1136(self):
         "1136 - test deprecated attributes"
         conn = test_env.get_connection()
@@ -757,7 +760,7 @@ def test_1140(self):
             "select sys_context('userenv', 'service_name') from dual"
         )
         (service_name,) = cursor.fetchone()
-        self.assertEqual(conn.service_name, service_name)
+        self.assertEqual(conn.service_name.upper(), service_name.upper())
 
     def test_1141(self):
         "1141 - test transaction_in_progress"

tests/test_2200_number_var.py

@@ -27,6 +27,7 @@
 """
 
 import decimal
+import unittest
 
 import oracledb
 import test_env
@@ -73,6 +74,9 @@ def setUp(self):
             self.raw_data.append(data_tuple)
             self.data_by_key[i] = data_tuple
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (12, 1), "not supported on this client"
+    )
     def test_2200(self):
         "2200 - test binding in a boolean"
         result = self.cursor.callfunc(

tests/test_2400_pool.py

@@ -167,6 +167,9 @@ def __verify_create_arg(self, arg_name, arg_value, sql):
             self.assertEqual(fetched_value, arg_value)
         pool.close()
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (19, 1), "not supported on this client"
+    )
     def test_2400(self):
         "2400 - test getting default pool parameters"
         pool = test_env.get_pool()
@@ -231,6 +234,9 @@ def test_2401(self):
         self.assertEqual(user, test_env.get_proxy_user().upper())
         conn.close()
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (19, 1), "not supported on this client"
+    )
     def test_2402(self):
         "2402 - test setting pool attributes"
         pool = test_env.get_pool()
@@ -670,6 +676,9 @@ def test_2421(self):
         with self.assertRaisesFullCode("DPY-1002"):
             pool.acquire()
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (19, 1), "not supported on this client"
+    )
     def test_2422(self):
         "2422 - using the pool beyond max limit raises an error"
         pool = test_env.get_pool(
@@ -857,7 +866,7 @@ def test_2437(self):
         test_env.get_server_version() < (12, 2), "not supported on this server"
     )
     @unittest.skipIf(
-        test_env.get_client_version() < (12, 2), "not supported on this client"
+        test_env.get_client_version() < (19, 1), "not supported on this client"
     )
     def test_2438(self):
         "2438 - ensure that timed wait times out with appropriate exception"
@@ -867,6 +876,9 @@ def test_2438(self):
         with self.assertRaisesFullCode("DPY-4005"):
             pool.acquire()
 
+    @unittest.skipIf(
+        test_env.get_client_version() < (18, 1), "not supported on this client"
+    )
     def test_2439(self):
         "2439 - ensure call timeout is reset on connections returned by pool"
         pool = test_env.get_pool(ping_timeout=1000, ping_interval=0)

tests/test_2500_string_var.py

@@ -424,6 +424,9 @@ def test_2527(self):
             self.cursor.fetchall(), [(1, short_string), (2, long_string)]
         )
 
+    @unittest.skipIf(
+        test_env.get_server_version() < (12, 2), "not supported on this server"
+    )
     def test_2528(self):
         "2528 - test issue 50 - avoid error ORA-24816"
         cursor = self.conn.cursor()

tests/test_8100_dataframe_async.py

@@ -508,6 +508,34 @@ async def test_8119(self):
             fetched_data = self.__get_data_from_df(fetched_df)
             self.assertEqual(fetched_data, data)
 
+    async def test_8120(self):
+        "8120 - fetch clob"
+        data = [("test_8023",)]
+        self.__check_interop()
+        ora_df = await self.conn.fetch_df_all(
+            "select to_clob('test_8023') from dual"
+        )
+        fetched_tab = pyarrow.Table.from_arrays(
+            ora_df.column_arrays(), names=ora_df.column_names()
+        )
+        fetched_df = fetched_tab.to_pandas()
+        fetched_data = self.__get_data_from_df(fetched_df)
+        self.assertEqual(fetched_data, data)
+
+    async def test_8121(self):
+        "8121 - fetch blob"
+        data = [(b"test_8024",)]
+        self.__check_interop()
+        ora_df = await self.conn.fetch_df_all(
+            "select to_blob(utl_raw.cast_to_raw('test_8024')) from dual"
+        )
+        fetched_tab = pyarrow.Table.from_arrays(
+            ora_df.column_arrays(), names=ora_df.column_names()
+        )
+        fetched_df = fetched_tab.to_pandas()
+        fetched_data = self.__get_data_from_df(fetched_df)
+        self.assertEqual(fetched_data, data)
+
 
 if __name__ == "__main__":
     test_env.run_test_cases()