diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/AlarmMessageDao.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/AlarmMessageDao.java index a9c0a4c51..a3c8a5b8b 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/AlarmMessageDao.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/dao/AlarmMessageDao.java @@ -131,23 +131,4 @@ public class AlarmMessageDao { } return rules; } - - public static String selectAppCodeByAppId(String appId) throws SQLException { - Connection connection = DBConnectUtil.getConnection(); - try { - PreparedStatement ps = - connection.prepareStatement("SELECT app_code FROM application_info WHERE sts = ? AND application_info.app_id = ?"); - ps.setString(1, "A"); - ps.setString(2, appId); - ResultSet rs = ps.executeQuery(); - rs.next(); - return rs.getString("app_code"); - } catch (SQLException e) { - throw e; - } finally { - if (connection != null) { - connection.close(); - } - } - } } diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java index 59529e7fb..4d53a4a6d 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java @@ -144,15 +144,4 @@ public class AlarmMessageProcessor { } private static Map idCodeMapper = new ConcurrentHashMap(); - - public static String convertAppId2AppCode(String appId) throws SQLException { - String resultCode = idCodeMapper.get(appId); - if (resultCode == null) { - resultCode = AlarmMessageDao.selectAppCodeByAppId(appId); - - idCodeMapper.put(appId, resultCode); - } - - return idCodeMapper.get(appId); - } }