public void load()

in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Schema.java [51:90]

• 31 lines of code
• 7 McCabe index (conditional complexity)

    public void load() throws SQLException {

        dbMap = new HashMap<>();

        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;

        try {
            conn = dataSource.getConnection();

            ps = conn.prepareStatement(SQL);
            rs = ps.executeQuery();

            while (rs.next()) {
                String dbName = rs.getString(1);
                if (!IGNORED_DATABASES.contains(dbName)) {
                    Database database = new Database(dbName, dataSource);
                    dbMap.put(dbName, database);
                }
            }

        } finally {

            if (conn != null) {
                conn.close();
            }
            if (ps != null) {
                ps.close();
            }
            if (rs != null) {
                rs.close();
            }
        }

        for (Database db : dbMap.values()) {
            db.init();
        }

    }