def connection_init(self):
        cursor = self._get_connection().cursor()
        if cursor.execute("SHOW variables WHERE Variable_Name='default_storage_engine';"):
            engine_var = 'default_storage_engine'
        else:
            engine_var = 'storage_engine'
        if self._has_setting('STORAGE_ENGINE') and self._get_setting('STORAGE_ENGINE'):
            cursor.execute("SET %s=%s;" % (engine_var, self._get_setting('STORAGE_ENGINE')))
Begin a transaction.
dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/South-1.0.2/south/db/mysql.py/DatabaseOperations.connection_init--crossover with--dataset/ETHPy150Open jasonrbriggs/stomp.py/stomp/protocol.py/Protocol10.begin