public void init()

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


    public void init() throws SQLException {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;

        try {
            conn = dataSource.getConnection();

            ps = conn.prepareStatement(SQL);
            ps.setString(1, name);
            rs = ps.executeQuery();

            while (rs.next()) {
                String tableName = rs.getString(1);
                String colName = rs.getString(2);
                String dataType = rs.getString(3);
                String colType = rs.getString(4);
                String charset = rs.getString(5);

                ColumnParser columnParser = ColumnParser.getColumnParser(dataType, colType, charset);

                if (!tableMap.containsKey(tableName)) {
                    addTable(tableName);
                }
                Table table = tableMap.get(tableName);
                table.addCol(colName);
                table.addParser(columnParser);
            }

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

    }