Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

plain execute function

Browse source
This commit is contained in:
Lex Berezhny 2020-05-18 08:14:30 -04:00
parent 5d6388b366
commit d232eeaf81
3 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbry/db/__init__.py
View file

@ -3,8 +3,3 @@ from .constants import (
TXO_TYPES, SPENDABLE_TYPE_CODES, TXO_TYPES, SPENDABLE_TYPE_CODES,
CLAIM_TYPE_CODES, CLAIM_TYPE_NAMES CLAIM_TYPE_CODES, CLAIM_TYPE_NAMES
) )
from .tables import (
Table, Version, metadata,
AccountAddress, PubkeyAddress,
Block, TX, TXO, TXI, Claim, Tag, Claimtrie
)

3
lbry/db/database.py
View file

@ -106,6 +106,9 @@ class Database:
self.executor, partial(func, *args, **kwargs) 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): async def execute_fetchall(self, sql):
return await self.run_in_executor(q.execute_fetchall, sql) return await self.run_in_executor(q.execute_fetchall, sql)

4
lbry/db/queries.py
View file

@ -365,6 +365,10 @@ def process_claims_and_supports(block_range=None):
rows.save() rows.save()
def execute(sql):
return ctx().execute(text(sql))
def execute_fetchall(sql): def execute_fetchall(sql):
return ctx().fetchall(text(sql)) return ctx().fetchall(text(sql))