Environment

• Red Hat JBoss Data Virtualization (DV) 6.2
• Custom code to refresh Materialized Views

private Vdb load(String name) throws CacheSyncException {
        assert name != null;

        try {
            Vdb vdb = Vdb.of(name);
            logger.info("Loaded configuration for VDB: {}", name);
            return vdb;
        } catch (Exception e) {
            logger.error("Configuration could not be loaded for VDB: {}", name);
            throw new CacheSyncException(e);
        }
    }

    private void syncCache(Vdb vdb) throws CacheSyncException {
        assert vdb != null;

        try {
            DataSource ds = InitialContext.doLookup(vdb.getName());
            try(Connection connection = ds.getConnection();
                Statement statement = connection.createStatement()) {
                for (View view : vdb.getViews()) {
                    logger.info("Refreshing cache for view: {}", view.fqn(vdb));
                    statement.executeUpdate(sql(vdb, view));
                }
            }
            logger.info("Done refreshing cache for VDB: {}", vdb.getName());
        } catch (NamingException e) {
            logger.error("DataSource could not be found: " + vdb.getJndi(), e);
            throw new CacheSyncException(e);
        } catch (SQLException e) {
            logger.error("Failed to obtain database connection or execute statement: " + vdb.getName(), e);
            throw new CacheSyncException(e);
        }
    }