diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java index 8efb78187..39a0e4dbf 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java @@ -35,10 +35,10 @@ public class DBCallChainInfoDao { PreparedStatement preparedStatement = null; try { preparedStatement = connection - .prepareStatement("INSERT INTO sw_chain_detail(cid,uid,traceLevelId,viewpoint,create_time)" + .prepareStatement("INSERT INTO sw_chain_detail(treeId,uid,traceLevelId,viewpoint,create_time)" + " VALUES(?,?,?,?,?)"); for (ChainNode chainNode : callChainDetailForMysql.getChainNodes()) { - preparedStatement.setString(1, callChainDetailForMysql.getChainToken()); + preparedStatement.setString(1, callChainDetailForMysql.getTreeToken()); preparedStatement.setString(2, callChainDetailForMysql.getUserId()); preparedStatement.setString(3, chainNode.getTraceLevelId()); preparedStatement.setString(4, chainNode.getViewPoint() + ":" diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java index 69e2e3b21..206d1e372 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java @@ -14,15 +14,17 @@ import java.util.Map; public class CallChainDetailForMysql { private String chainToken; + private String treeToken; private Map chainNodeMap = new HashMap(); private String userId; - public CallChainDetailForMysql(ChainInfo chainInfo) { + public CallChainDetailForMysql(ChainInfo chainInfo, String treeToken) { chainToken = chainInfo.getCID(); for (ChainNode chainNode : chainInfo.getNodes()) { chainNodeMap.put(chainNode.getTraceLevelId(), chainNode); } userId = chainInfo.getUserId(); + this.treeToken = treeToken; } @Override @@ -45,4 +47,8 @@ public class CallChainDetailForMysql { public String getChainToken() { return chainToken; } + + public String getTreeToken() { + return treeToken; + } } diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallTreeMergedChainIdContainer.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallTreeMergedChainIdContainer.java index b2d2af1cb..7ab2c0d87 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallTreeMergedChainIdContainer.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallTreeMergedChainIdContainer.java @@ -42,7 +42,7 @@ public class SpecificTimeCallTreeMergedChainIdContainer { // if (chainInfo.getChainStatus() == ChainInfo.ChainStatus.NORMAL) { - callChainDetailMap.put(chainInfo.getCID(), new CallChainDetailForMysql(chainInfo)); + callChainDetailMap.put(chainInfo.getCID(), new CallChainDetailForMysql(chainInfo,treeToken)); } }else{