class MySqlConnectionFactory implements DbUnitConnectionFactory {

    @Override
    public IDatabaseConnection createConnection(final Connection connection, final String schema) throws DatabaseUnitException {
        return new MySqlConnection(connection, schema);
    }

}