kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1. 将Mysql表中的cid改成treeId

This commit is contained in:
ascrutae 2016-04-06 17:56:14 +08:00
parent 646c260599
commit d7719b6617
3 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/DBCallChainInfoDao.java
View File

@ -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() + ":"

8
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/entity/CallChainDetailForMysql.java
View File

@ -14,15 +14,17 @@ import java.util.Map;
public class CallChainDetailForMysql {
private String chainToken;
private String treeToken;
private Map<String, ChainNode> chainNodeMap = new HashMap<String, ChainNode>();
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;
}
}

2
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/chainbuild/po/SpecificTimeCallTreeMergedChainIdContainer.java
View File

@ -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{