Source code for tkp.db
import logging
from tkp.db.database import Database, sanitize_db_inputs
from tkp.db.orm import DataSet, Image, ExtractedSource
logger = logging.getLogger(__name__)
[docs]def execute(query, parameters={}, commit=False):
"""
A generic wrapper for doing any query to the database
:param query: the query string
:param parameters: The query parameters. These will be converted and escaped.
:param commit: should a commit be performed afterwards, boolean
:returns: a database cursor object
"""
database = Database()
return database.execute(query, parameters=parameters, commit=commit)
def rollback():
database = Database()
return database.rollback()