From: Nix

main.py

вот мой пример 
   def execute(self, sql, args=None, commit=False):

        
        conn = self.pool.get_connection()
        cursor = conn.cursor(dictionary=True)#,buffered=True)
        if args:
            cursor.execute(sql, args)
        else:
            cursor.execute(sql)
        if commit is True:
            conn.commit()
            self.close(conn, cursor)
            return None
        else:            
            res = cursor.fetchall()
            self.close(conn, cursor)
            return res