#NEWLINE# def query( self , statement , * args , **kwargs ) : #NEWLINE# #INDENT# statement = self . prepare ( statement , kwargs . pop ( 'escape' , False ) ) #NEWLINE# try : #NEWLINE# #INDENT# return self . connection . execute ( statement , * self , ** kwargs ) #NEWLINE# #UNINDENT# except exc . SQLAlchemyError as e : #NEWLINE# #INDENT# raise DBError ( str ( e ) )