From d232eeaf819458dbedfa53db080d627a2332efa8 Mon Sep 17 00:00:00 2001
From: Lex Berezhny <lex@damoti.com>
Date: Mon, 18 May 2020 08:14:30 -0400
Subject: [PATCH] plain execute function

---
 lbry/db/__init__.py | 5 -----
 lbry/db/database.py | 3 +++
 lbry/db/queries.py  | 4 ++++
 3 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/lbry/db/__init__.py b/lbry/db/__init__.py
index c93a317ee..76a2c2887 100644
--- a/lbry/db/__init__.py
+++ b/lbry/db/__init__.py
@@ -3,8 +3,3 @@ from .constants import (
     TXO_TYPES, SPENDABLE_TYPE_CODES,
     CLAIM_TYPE_CODES, CLAIM_TYPE_NAMES
 )
-from .tables import (
-    Table, Version, metadata,
-    AccountAddress, PubkeyAddress,
-    Block, TX, TXO, TXI, Claim, Tag, Claimtrie
-)
diff --git a/lbry/db/database.py b/lbry/db/database.py
index c27f056bf..ae8e3cf01 100644
--- a/lbry/db/database.py
+++ b/lbry/db/database.py
@@ -106,6 +106,9 @@ class Database:
             self.executor, partial(func, *args, **kwargs)
         )
 
+    async def execute(self, sql):
+        return await self.run_in_executor(q.execute, sql)
+
     async def execute_fetchall(self, sql):
         return await self.run_in_executor(q.execute_fetchall, sql)
 
diff --git a/lbry/db/queries.py b/lbry/db/queries.py
index da44289eb..9bc49fa30 100644
--- a/lbry/db/queries.py
+++ b/lbry/db/queries.py
@@ -365,6 +365,10 @@ def process_claims_and_supports(block_range=None):
     rows.save()
 
 
+def execute(sql):
+    return ctx().execute(text(sql))
+
+
 def execute_fetchall(sql):
     return ctx().fetchall(text(sql))