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();
}
}
}