# Path: rhizi/neo4j_util.py
# class Neo4JException(Exception):
#     def __init__(self, error_set):
#         self.error_set = error_set
# 
#     def __str__(self):
#         return 'neo4j error set: ' + str(self.error_set)


import sys
import logging
from .neo4j_util import Neo4JException
from . import neo4j_util as db_util
        from org.rhizi.db.neo4j.util import EmbeddedNeo4j
#
#    This program is free software: you can redistribute it and/or modify
#    it under the terms of the GNU Affero General Public License as published
#    by the Free Software Foundation, either version 3 of the License, or
#    (at your option) any later version.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU Affero General Public License for more details.
#
#    You should have received a copy of the GNU Affero General Public License
#    along with this program.  If not, see <http://www.gnu.org/licenses/>.





log = logging.getLogger('rhizi')


python2 = sys.version_info[0] == 2


class DB_Driver_Base():

    def log_committed_queries(self, statement_set):
        indent_prefix = '  '
        for sp_dict in statement_set['statements']:
            if None != sp_dict['parameters']:

# Path: rhizi/neo4j_util.py
# class Neo4JException(Exception):
#     def __init__(self, error_set):
#         self.error_set = error_set
# 
#     def __str__(self):
#         return 'neo4j error set: ' + str(self.error_set)


# Path: rhizi/db_driver.py
import sys
import logging
from .neo4j_util import Neo4JException
from . import neo4j_util as db_util
        from org.rhizi.db.neo4j.util import EmbeddedNeo4j

#
#    This program is free software: you can redistribute it and/or modify
#    it under the terms of the GNU Affero General Public License as published
#    by the Free Software Foundation, either version 3 of the License, or
#    (at your option) any later version.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU Affero General Public License for more details.
#
#    You should have received a copy of the GNU Affero General Public License
#    along with this program.  If not, see <http://www.gnu.org/licenses/>.





log = logging.getLogger('rhizi')


python2 = sys.version_info[0] == 2


class DB_Driver_Base():

    def log_committed_queries(self, statement_set):
        indent_prefix = '  '
        for sp_dict in statement_set['statements']:
            if None != sp_dict['parameters']:

                msg = indent_prefix + 'q: {0}\n\tp: {1}'.format(sp_dict['statement'].encode('utf-8'),