2112A-ONE
/
muyu-source
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

资产展示{KLTV}的代码

master
冷调 2024-08-31 18:49:14 +08:00
parent c79777ef32
commit b2ab146577
1 changed files with 0 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java
View File

@ -230,38 +230,6 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
conn.close(); conn.close();
mysqlPool.closeConn(); mysqlPool.closeConn();
} }
// else if (etlDataScore.getType().equals(REDIS)) {
// RedisPool redisPool = new RedisPool(etlDataScore);
// redisPool.init();
// Jedis jedis = redisPool.getConn();
//
// String cursor = ScanParams.SCAN_POINTER_START;
// ScanParams scanParams = new ScanParams().count(100);
//
// HashMap<String, String> map = new HashMap<>();
//
//
// while (true) {
// ScanResult<String> scanResult = jedis.scan(cursor, scanParams);
// List<String> keys = scanResult.getResult();
// for (String key : keys) {
// String value = jedis.get(key);
// if (value != null) {
// map.put(key, value);
// }
// }
// cursor = scanResult.getCursor();
// if (cursor.equals(ScanParams.SCAN_POINTER_START)) {
// break;
// }
// }
// System.out.println(map);
//
// redisPool.replease(jedis);
// redisPool.closeConn();
//
//
// }
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }