Update

Author: GoodManWEN

cx_Oracle_async/pools.py

@@ -1,7 +1,7 @@
 from .context import AbstractContextManager as BaseManager
 from .connections import AsyncConnectionWrapper , AsyncConnectionWrapper_context
 from ThreadPoolExecutorPlus import ThreadPoolExecutor
-from cx_Oracle import SessionPool
+from cx_Oracle import Connection , SessionPool
 from types import CoroutineType
 import asyncio
 import platform
@@ -52,6 +52,12 @@ def _acquire(self):
     def _unoccupied(self , obj):
         self._occupied.remove(obj)
 
+    async def release(self , conn: Connection):
+        return await self._loop.run_in_executor(self._thread_pool , self._pool.release , conn)
+
+    async def drop(self , conn: Connection):
+        return await self._loop.run_in_executor(self._thread_pool , self._pool.drop , conn)
+
     async def close(self , force = False):
         if force:
             while self._occupied:

tests/test_drop.py

@@ -0,0 +1,29 @@
+import os , sys
+sys.path.append(os.getcwd())
+import pytest
+import asyncio
+import time
+from cx_Oracle_async import *
+import cx_Oracle
+
+async def create_long_query(oracle_pool):
+    async with oracle_pool.acquire() as conn:
+        cursor = await conn.cursor()
+        try:
+            await cursor.execute("BEGIN  DBMS_LOCK.SLEEP(:a); END;",(20,))
+        except Exception as e:
+            assert isinstance(e , cx_Oracle.OperationalError)
+
+@pytest.mark.asyncio
+async def test_force_close():
+    loop = asyncio.get_running_loop()
+    dsn  = makedsn('localhost','1521',sid='xe')
+    INAQ = 0.5
+    oracle_pool = await create_pool(user='system',password='oracle',dsn=dsn,max=4)
+    loop = asyncio.get_running_loop()
+    loop.create_task(create_long_query(oracle_pool))
+    st_time = time.time()
+    await asyncio.sleep(2)
+    await oracle_pool.close(force = True)
+    ed_time = time.time()
+    assert (ed_time - st_time) <= (20 - INAQ)