From f1e4e386b680b0adf0475bfcaf0219a610a7f844 Mon Sep 17 00:00:00 2001 From: andrei Date: Tue, 31 May 2022 15:31:48 +0300 Subject: [PATCH] Added run() method to TarantoolDBConnection Class. --- planetmint/backend/tarantool/connection.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/planetmint/backend/tarantool/connection.py b/planetmint/backend/tarantool/connection.py index 11f22c9..34b769d 100644 --- a/planetmint/backend/tarantool/connection.py +++ b/planetmint/backend/tarantool/connection.py @@ -54,6 +54,16 @@ class TarantoolDBConnection(Connection): def space(self, space_name: str): return self.query().space(space_name) + def run(self, query): + try: + return query.run(self.db_connect) + except tarantool.error.NetworkError: + return None + except tarantool.error.OperationalError as op_error: + raise op_error + except tarantool.error.SchemaError as schema_error: + raise schema_error + def get_connection(self): return self.db_connect