Для примера создадим такую процедура, в которой есть и commit и rollback операции
create or replace procedure a2(
in a smallint,
out b smallint
)
LANGUAGE plpgsql
AS $$
BEGIN
b:=1;
if (a=1) then
commit;
return;
end if;
if (a=2) then
rollback;
b:=2;
else
b:=3;
end if;
END; $$;
Если выполнить эту процедуру через, средства разработки для баз данных(DataGrip), то она будет выполняться без ошибок.
CALL a2(1::smallint,null::smallint);
CALL a2(2::smallint,null::smallint);
CALL a2(3::smallint,null::smallint);
Но если выполнять туже самую процедуру в Python через psycopg2 или asyncpg, происходят разного рода ошибки. Без ошибок выполняются процедуры в которых нет операции commit и rollback, но мне нужен такой функционал.
ps_connection = psycopg2.connect(
user="postgres",
password="denis",
host="127.0.0.1",
port="5432",
database="testing_xab2"
)
cursor = ps_connection.cursor()
cursor.callproc('a2', [72, 10])
result = cursor.fetchall()
print()
""" Ошибка
psycopg2.errors.UndefinedFunction: function a2(integer, integer) does not exist
LINE 1: SELECT * FROM a2(72,10)
^
HINT: No function matches the given name and argument types. You might need to add explicit type casts.
"""
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession, AsyncConnection, AsyncEngine
from sqlalchemy import text
import asyncio
async def main(url, raw_sql):
engine = create_async_engine(url, encoding='utf8')
async with engine.begin() as conn:
cursor = await conn.execute(text(raw_sql))
result = cursor.fetchall()
print(result)
asyncio.run(main(
'postgresql+asyncpg://postgres:denis@localhost:5432/testing_xab2'
, 'CALL a2(2::smallint,null::smallint);'
)
)
""" Ошибка
sqlalchemy.exc.DBAPIError: (sqlalchemy.dialects.postgresql.asyncpg.Error) <class 'asyncpg.exceptions.InvalidTransactionTerminationError'>: invalid transaction termination
[SQL:
CALL a2(2::smallint,null::smallint);
]
(Background on this error at: https://sqlalche.me/e/14/dbapi)
"""