From d7719b661716067fdad80421c1deabb23f048b09 Mon Sep 17 00:00:00 2001 From: ascrutae Date: Wed, 6 Apr 2016 17:56:14 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E5=B0=86Mysql=E8=A1=A8=E4=B8=AD=E7=9A=84c?= =?UTF-8?q?id=E6=94=B9=E6=88=90treeId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../analysis/chainbuild/DBCallChainInfoDao.java | 4 ++-- .../chainbuild/entity/CallChainDetailForMysql.java | 8 +++++++- .../po/SpecificTimeCallTreeMergedChainIdContainer.java | 2 +- 3 files changed, 10 insertions(+), 4 deletions(-) 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{