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))