String schemaName = connection.getSchema();
    public void execute(IDatabaseConnection connection, IDataSet dataSet)            throws DatabaseUnitException, SQLException    {        Connection jdbcConnection = connection.getConnection();        Statement statement = jdbcConnection.createStatement();        try        {            IDataSet databaseDataSet = connection.createDataSet();            String schemaName = connection.getSchema();            // INSERT_IDENTITY need to be enabled/disabled inside the            // same transaction            if (jdbcConnection.getAutoCommit() == false)            {                throw new ExclusiveTransactionException();            }            jdbcConnection.setAutoCommit(false);            // Execute decorated operation one table at a time            ITableIterator iterator = dataSet.iterator();            while(iterator.next())            {                ITable table = iterator.getTable();                String tableName = table.getTableMetaData().getTableName();                ITableMetaData metaData =                        databaseDataSet.getTableMetaData(tableName);                // enable identity insert                boolean hasIdentityColumn = hasIdentityColumn(metaData);                if (hasIdentityColumn)                {                    StringBuffer sqlBuffer = new StringBuffer(128);                    sqlBuffer.append("SET IDENTITY_INSERT ");                    sqlBuffer.append(getQualifiedName(connection.getSchema(),                            metaData.getTableName(), connection));                    sqlBuffer.append(" ON");                    statement.execute(sqlBuffer.toString());                }                try                {                    _operation.execute(connection, new DefaultDataSet(table));                }                finally                {                    // disable identity insert                    if (hasIdentityColumn)                    {                        StringBuffer sqlBuffer = new StringBuffer(128);                        sqlBuffer.append("SET IDENTITY_INSERT ");                        sqlBuffer.append(getQualifiedName(connection.getSchema(),                                metaData.getTableName(), connection));                        sqlBuffer.append(" OFF");                        statement.execute(sqlBuffer.toString());                    }                    jdbcConnection.commit();                }            }        }        finally        {            jdbcConnection.setAutoCommit(true);            statement.close();        }    }