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

Polish JDBC plugins to make DBType accurate (#396)

This commit is contained in:
pg.yang 2022-11-23 14:36:18 +08:00 committed by GitHub
parent 6cb2b4290f
commit add2bc42ca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
50 changed files with 141 additions and 140 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.github/workflows/plugins-test.3.yaml vendored
View File

@ -121,7 +121,7 @@ jobs:
run: |
mkdir -p skywalking-agent/plugins
curl -O https://skyapm.github.io/ci-assist/jars/ojdbc14-10.2.0.4.0.jar
curl -L -o ./skywalking-agent/plugins/apm-oracle-10.x-plugin-2.0.0.jar https://github.com/SkyAPM/java-plugin-extensions/releases/download/2.3.0/apm-oracle-10.x-plugin-2.3.0.jar
curl -L -o ./skywalking-agent/plugins/apm-oracle-10.x-plugin-2.3.1.jar https://github.com/SkyAPM/java-plugin-extensions/releases/download/2.3.1/apm-oracle-10.x-plugin-2.3.1.jar
./mvnw -q --batch-mode install:install-file -Dfile=ojdbc14-10.2.0.4.0.jar -DgroupId=com.oracle -DartifactId=ojdbc14 -Dversion=10.2.0.4.0 -Dpackaging=jar
- name: Run Plugin Test
uses: ./.github/actions/run

1
CHANGES.md
View File

@ -12,6 +12,7 @@ Release Notes.
* Bump up byte-buddy to 1.12.19
* Upgrade agent test tools
* [Breaking Change] Compatible with 3.x and 4.x RabbitMQ Client, rename `rabbitmq-5.x-plugin` to `rabbitmq-plugin`
* Polish JDBC plugins to make DBType accurate
#### Documentation

2
apm-sniffer/apm-sdk-plugin/clickhouse-0.3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/clickhouse/ClickHouseStatementTracingWrapper.java
View File

@ -35,7 +35,7 @@ public class ClickHouseStatementTracingWrapper {
final AbstractSpan span = ContextManager.createExitSpan(
connectionInfo.getDBType() + "/JDBC/Statement/" + methodName, connectionInfo.getDatabasePeer());
try {
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectionInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectionInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, sql);
span.setComponent(connectionInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/clickhouse-0.3.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/clickhouse/ClickHouseStatementMethodInterceptorTest.java
View File

@ -121,7 +121,7 @@ public class ClickHouseStatementMethodInterceptorTest {
SpanAssert.assertComponent(span, ComponentsDefine.CLICKHOUSE_JDBC_DRIVER);
SpanAssert.assertLayer(span, SpanLayer.DB);
SpanAssert.assertTagSize(span, 3);
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "ClickHouse");
SpanAssert.assertTag(span, 1, "default");
SpanAssert.assertTag(span, 2, SQL);
}

2
apm-sniffer/apm-sdk-plugin/impala-jdbc-2.6.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/impala/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -45,7 +45,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
}
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/impala-jdbc-2.6.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/impala/StatementExecuteMethodsInterceptor.java
View File

@ -40,7 +40,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
if (connectInfo != null) {
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
String sql = allArguments.length > 0 ? (String) allArguments[0] : "";
sql = SqlBodyUtil.limitSqlBodySize(sql);

4
apm-sniffer/apm-sdk-plugin/impala-jdbc-2.6.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/impala/PreparedStatementExecuteMethodsInterceptorTest.java
View File

@ -115,7 +115,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Impala/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Impala");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
SpanAssert.assertTag(span, 3, "[abcd,efgh]");
@ -145,7 +145,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Impala/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Impala");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
SpanAssert.assertTag(span, 3, "[abcd,efgh]");

4
apm-sniffer/apm-sdk-plugin/impala-jdbc-2.6.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/impala/StatementExecuteMethodsInterceptorTest.java
View File

@ -98,7 +98,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Impala/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Impala");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
}
@ -115,7 +115,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Impala/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Impala");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
}

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/main/java/org/apache/skywalking/apm/plugin/jdbc/ConnectionServiceMethodInterceptor.java
View File

@ -41,7 +41,7 @@ public class ConnectionServiceMethodInterceptor implements InstanceMethodsAround
if (connectInfo != null) {
AbstractSpan span = ContextManager.createExitSpan(connectInfo.getDBType() + "/JDBC/Connection/" + method.getName(), connectInfo
.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, "");
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/main/java/org/apache/skywalking/apm/plugin/jdbc/trace/CallableStatementTracing.java
View File

@ -35,7 +35,7 @@ public class CallableStatementTracing {
AbstractSpan span = ContextManager.createExitSpan(connectInfo.getDBType() + "/JDBC/CallableStatement/" + method, connectInfo
.getDatabasePeer());
try {
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
SpanLayer.asDB(span);
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, sql);

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/main/java/org/apache/skywalking/apm/plugin/jdbc/trace/PreparedStatementTracing.java
View File

@ -35,7 +35,7 @@ public class PreparedStatementTracing {
final AbstractSpan span = ContextManager.createExitSpan(connectInfo.getDBType() + "/JDBC/PreparedStatement/" + method, connectInfo
.getDatabasePeer());
try {
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, sql);
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/main/java/org/apache/skywalking/apm/plugin/jdbc/trace/StatementTracing.java
View File

@ -34,7 +34,7 @@ public class StatementTracing {
try {
AbstractSpan span = ContextManager.createExitSpan(connectInfo.getDBType() + "/JDBC/Statement/" + method, connectInfo
.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, sql);
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/test/java/org/apache/skywalking/apm/plugin/jdbc/AbstractStatementTest.java
View File

@ -53,7 +53,7 @@ public abstract class AbstractStatementTest {
assertThat(span.getOperationName(), is(exceptOperationName));
assertThat(SpanHelper.getComponentId(span), is(33));
List<TagValuePair> tags = SpanHelper.getTags(span);
assertThat(tags.get(0).getValue(), is("sql"));
assertThat(tags.get(0).getValue(), is("Mysql"));
assertThat(tags.get(1).getValue(), is("test"));
assertThat(SpanHelper.getLayer(span), CoreMatchers.is(SpanLayer.DB));
}

2
apm-sniffer/apm-sdk-plugin/jdbc-commons/src/test/java/org/apache/skywalking/apm/plugin/jdbc/ConnectionTracing.java
View File

@ -32,7 +32,7 @@ public class ConnectionTracing {
AbstractSpan span = ContextManager.createExitSpan(connectInfo.getDBType() + "/JDBC/Connection/" + method, connectInfo
.getDatabasePeer());
try {
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, sql);
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/kylin-jdbc-2.6.x-3.x-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/kylin/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -45,7 +45,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
}
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/kylin-jdbc-2.6.x-3.x-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/kylin/StatementExecuteMethodsInterceptor.java
View File

@ -39,7 +39,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
if (connectInfo != null) {
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
String sql = allArguments.length > 0 ? (String) allArguments[0] : "";
sql = SqlBodyUtil.limitSqlBodySize(sql);

4
apm-sniffer/apm-sdk-plugin/kylin-jdbc-2.6.x-3.x-4.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/kylin/PreparedStatementExecuteMethodsInterceptorTest.java
View File

@ -114,7 +114,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("kylin/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "kylin");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
SpanAssert.assertTag(span, 3, "[abcd,efgh]");
@ -144,7 +144,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("kylin/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "kylin");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
SpanAssert.assertTag(span, 3, "[abcd,efgh]");

4
apm-sniffer/apm-sdk-plugin/kylin-jdbc-2.6.x-3.x-4.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/kylin/StatementExecuteMethodsInterceptorTest.java
View File

@ -97,7 +97,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("kylin/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "kylin");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
}
@ -114,7 +114,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("kylin/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "kylin");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
}

2
apm-sniffer/apm-sdk-plugin/mariadb-2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/mariadb/v2/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -45,7 +45,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
}
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/mariadb-2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/mariadb/v2/StatementExecuteMethodsInterceptor.java
View File

@ -40,7 +40,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
if (connectInfo != null) {
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
String sql = allArguments.length > 0 ? (String) allArguments[0] : "";
sql = SqlBodyUtil.limitSqlBodySize(sql);

4
apm-sniffer/apm-sdk-plugin/mariadb-2.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/mariadb/v2/PreparedStatementExecuteMethodsInterceptorTest.java
View File

@ -114,7 +114,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Mariadb/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Mariadb");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
SpanAssert.assertTag(span, 3, "[abcd,efgh]");
@ -144,7 +144,7 @@ public class PreparedStatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Mariadb/JDBC/PreparedStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Mariadb");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
SpanAssert.assertTag(span, 3, "[abcd,efgh]");

4
apm-sniffer/apm-sdk-plugin/mariadb-2.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/jdbc/mariadb/v2/StatementExecuteMethodsInterceptorTest.java
View File

@ -98,7 +98,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Mariadb/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Mariadb");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
}
@ -115,7 +115,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("Mariadb/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "Mariadb");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "Select * f...");
}

8
apm-sniffer/apm-sdk-plugin/mssql-commons/src/main/java/org/apache/skywalking/apm/plugin/mssql/commons/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -46,7 +46,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
AbstractSpan span = ContextManager.createExitSpan(
buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());
@ -86,8 +86,8 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
private String getParameterString(Object[] parameters, int maxIndex) {
return new PreparedStatementParameterBuilder()
.setParameters(parameters)
.setMaxIndex(maxIndex)
.build();
.setParameters(parameters)
.setMaxIndex(maxIndex)
.build();
}
}

2
apm-sniffer/apm-sdk-plugin/mssql-commons/src/main/java/org/apache/skywalking/apm/plugin/mssql/commons/StatementExecuteMethodsInterceptor.java
View File

@ -41,7 +41,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
AbstractSpan span = ContextManager.createExitSpan(
buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
String sql = "";

2
apm-sniffer/apm-sdk-plugin/mysql-common/src/main/java/org/apache/skywalking/apm/plugin/jdbc/mysql/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -51,7 +51,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
AbstractSpan span = ContextManager.createExitSpan(
buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/mysql-common/src/main/java/org/apache/skywalking/apm/plugin/jdbc/mysql/StatementExecuteMethodsInterceptor.java
View File

@ -48,7 +48,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject
.getStatementName()), connectInfo.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
/**

4
apm-sniffer/apm-sdk-plugin/mysql-common/src/test/java/org/apache/skywalking/apm/plugin/jdbc/mysql/StatementExecuteMethodsInterceptorTest.java
View File

@ -98,7 +98,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("H2/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "H2");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, SQL);
}
@ -116,7 +116,7 @@ public class StatementExecuteMethodsInterceptorTest {
AbstractTracingSpan span = SegmentHelper.getSpans(segment).get(0);
SpanAssert.assertLayer(span, SpanLayer.DB);
assertThat(span.getOperationName(), is("H2/JDBC/CallableStatement/"));
SpanAssert.assertTag(span, 0, "sql");
SpanAssert.assertTag(span, 0, "H2");
SpanAssert.assertTag(span, 1, "test");
SpanAssert.assertTag(span, 2, "SELECT * F...");
}

2
apm-sniffer/apm-sdk-plugin/postgresql-8.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/postgresql/PreparedStatementExecuteMethodsInterceptor.java
View File

@ -47,7 +47,7 @@ public class PreparedStatementExecuteMethodsInterceptor implements InstanceMetho
AbstractSpan span = ContextManager.createExitSpan(
buildOperationName(connectInfo, method.getName(), cacheObject.getStatementName()), connectInfo
.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
Tags.DB_STATEMENT.set(span, SqlBodyUtil.limitSqlBodySize(cacheObject.getSql()));
span.setComponent(connectInfo.getComponent());

2
apm-sniffer/apm-sdk-plugin/postgresql-8.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/postgresql/StatementExecuteMethodsInterceptor.java
View File

@ -41,7 +41,7 @@ public class StatementExecuteMethodsInterceptor implements InstanceMethodsAround
ConnectionInfo connectInfo = cacheObject.getConnectionInfo();
AbstractSpan span = ContextManager.createExitSpan(buildOperationName(connectInfo, method.getName(), cacheObject.getStatementName()), connectInfo
.getDatabasePeer());
Tags.DB_TYPE.set(span, "sql");
Tags.DB_TYPE.set(span, connectInfo.getDBType());
Tags.DB_INSTANCE.set(span, connectInfo.getDatabaseName());
String sql = (String) allArguments[0];
sql = SqlBodyUtil.limitSqlBodySize(sql);

16
test/plugin/scenarios/clickhouse-0.3.x-scenario/config/expectedData.yaml
View File

@ -50,7 +50,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: 'select timezone(), version()'}
- {key: http.status_code, value: '200'}
@ -67,7 +67,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: SELECT * FROM clusters}
- {key: http.status_code, value: '200'}
@ -84,7 +84,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: SELECT 1}
- {key: http.status_code, value: '200'}
@ -101,7 +101,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: ''}
- operationName: ClickHouse/JDBC/Statement/executeQuery
@ -117,7 +117,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: 'select timezone(), version()'}
- {key: http.status_code, value: '200'}
@ -134,7 +134,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: SELECT * FROM clusters}
- {key: http.status_code, value: '200'}
@ -151,7 +151,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: SELECT 1}
- {key: http.status_code, value: '200'}
@ -168,7 +168,7 @@ segmentItems:
peer: not null
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: ClickHouse}
- {key: db.instance, value: system}
- {key: db.statement, value: ''}
- operationName: GET:/clickhouse-scenario/case/clickhouse-scenario

12
test/plugin/scenarios/dbcp-2.x-scenario/config/expectedData.yaml
View File

@ -28,7 +28,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: ''}
- operationName: DBCP/Connection/getConnection
@ -52,7 +52,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: "CREATE TABLE test_DBCP(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -88,7 +88,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: 'INSERT INTO test_DBCP(id, value) VALUES(1,1)'
@ -123,7 +123,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: 'SELECT id, value FROM test_DBCP WHERE id=1'
@ -158,7 +158,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: "DELETE FROM test_DBCP WHERE id=1"
@ -193,7 +193,7 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: "DROP table test_DBCP"

10
test/plugin/scenarios/druid-1.x-scenario/config/expectedData.yaml
View File

@ -40,7 +40,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'CREATE TABLE test_DRUID(id VARCHAR(1) PRIMARY
KEY, value VARCHAR(1) NOT NULL)'}
@ -75,7 +75,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'INSERT INTO test_DRUID(id, value) VALUES(1,1)'}
- operationName: Druid/Connection/close
@ -109,7 +109,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'SELECT id, value FROM test_DRUID WHERE id=1'}
- operationName: Druid/Connection/close
@ -143,7 +143,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'DELETE FROM test_DRUID WHERE id=1'}
- operationName: Druid/Connection/close
@ -177,7 +177,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'DROP table test_DRUID'}
- operationName: Druid/Connection/close

8
test/plugin/scenarios/h2-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: test}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -47,7 +47,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: test}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
skipAnalysis: 'false'
@ -62,7 +62,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: test}
- {key: db.statement, value: DROP table test_007}
skipAnalysis: 'false'
@ -77,7 +77,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: test}
- {key: db.statement, value: ''}
skipAnalysis: 'false'

10
test/plugin/scenarios/hikaricp-scenario/config/expectedData.yaml
View File

@ -40,7 +40,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'CREATE TABLE test_Hikari(id VARCHAR(1) PRIMARY
KEY, value VARCHAR(1) NOT NULL)'}
@ -75,7 +75,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'INSERT INTO test_Hikari(id, value) VALUES(1,1)'}
- operationName: HikariCP/Connection/close
@ -109,7 +109,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'SELECT id, value FROM test_Hikari WHERE id=1'}
- operationName: HikariCP/Connection/close
@ -143,7 +143,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'DELETE FROM test_Hikari WHERE id=1'}
- operationName: HikariCP/Connection/close
@ -177,7 +177,7 @@ segmentItems:
spanType: Exit
peer: mysql-server:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'DROP table test_Hikari'}
- operationName: HikariCP/Connection/close

10
test/plugin/scenarios/impala-jdbc-2.6.x-scenario/config/expectedData.yaml
View File

@ -31,7 +31,7 @@ segmentItems:
peer: impala-server:21050
skipAnalysis: 'false'
tags:
- { key: db.type, value: sql }
- {key: db.type, value: Impala}
- { key: db.instance, value: '' }
- key: db.statement
value: "CREATE TABLE IF NOT EXISTS default.impala_test (test_id BIGINT, test_name STRING);"
@ -47,7 +47,7 @@ segmentItems:
peer: impala-server:21050
skipAnalysis: 'false'
tags:
- { key: db.type, value: sql }
- {key: db.type, value: Impala}
- { key: db.instance, value: '' }
- key: db.statement
value: "INSERT INTO impala_test VALUES (123, 'test');"
@ -63,7 +63,7 @@ segmentItems:
peer: impala-server:21050
skipAnalysis: 'false'
tags:
- { key: db.type, value: sql }
- {key: db.type, value: Impala}
- { key: db.instance, value: '' }
- key: db.statement
value: "SELECT COUNT(*) FROM impala_test;"
@ -79,7 +79,7 @@ segmentItems:
peer: impala-server:21050
skipAnalysis: 'false'
tags:
- { key: db.type, value: sql }
- {key: db.type, value: Impala}
- { key: db.instance, value: '' }
- key: db.statement
value: 'SELECT COUNT(*) FROM impala_test WHERE test_id = ?;'
@ -96,7 +96,7 @@ segmentItems:
peer: impala-server:21050
skipAnalysis: 'false'
tags:
- { key: db.type, value: sql }
- {key: db.type, value: Impala}
- { key: db.instance, value: '' }
- { key: db.statement, value: '' }
- operationName: HEAD:/impala-jdbc-2.6.x-scenario/case/healthCheck

8
test/plugin/scenarios/kotlin-coroutine-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo}
- {key: db.statement, value: 'SELECT * FROM PERSON WHERE ID = ?'}
skipAnalysis: 'false'
@ -45,7 +45,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo}
- {key: db.statement, value: ''}
skipAnalysis: 'false'
@ -76,7 +76,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo}
- {key: db.statement, value: 'SELECT * FROM PERSON WHERE ID = ?'}
skipAnalysis: 'false'
@ -91,7 +91,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo}
- {key: db.statement, value: ''}
skipAnalysis: 'false'

6
test/plugin/scenarios/kylin-jdbc-2.6.x-3.x-4.x-scenario/config/expectedData.yaml
View File

@ -31,7 +31,7 @@ segmentItems:
peer: kylin-server:7070
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: kylin}
- {key: db.instance, value: learn_kylin}
- key: db.statement
value: "select * from KYLIN_ACCOUNT LIMIT 1"
@ -47,7 +47,7 @@ segmentItems:
peer: kylin-server:7070
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: kylin}
- {key: db.instance, value: learn_kylin}
- {key: db.statement, value: "select * from KYLIN_ACCOUNT"}
- operationName: kylin/JDBC/Connection/close
@ -62,7 +62,7 @@ segmentItems:
peer: kylin-server:7070
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: kylin}
- {key: db.instance, value: learn_kylin}
- {key: db.statement, value: ''}
- operationName: HEAD:/kylin-jdbc-2.6.x-3.x-4.x-scenario/case/healthCheck

10
test/plugin/scenarios/mariadb-scenario/config/expectedData.yaml
View File

@ -31,7 +31,7 @@ segmentItems:
peer: mariadb-server:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mariadb}
- {key: db.instance, value: test}
- key: db.statement
value: "CREATE TABLE test_table(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(10)\
@ -48,7 +48,7 @@ segmentItems:
peer: mariadb-server:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mariadb}
- {key: db.instance, value: test}
- {key: db.statement, value: "INSERT INTO test_table(id, value) VALUES(?,?)"}
- operationName: Mariadb/JDBC/PreparedStatement/execute
@ -63,7 +63,7 @@ segmentItems:
peer: mariadb-server:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mariadb}
- {key: db.instance, value: test}
- {key: db.statement, value: "SELECT id, value FROM test_table WHERE id = ?"}
- operationName: Mariadb/JDBC/Statement/execute
@ -78,7 +78,7 @@ segmentItems:
peer: mariadb-server:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mariadb}
- {key: db.instance, value: test}
- {key: db.statement, value: "DROP table test_table"}
- operationName: Mariadb/JDBC/Connection/close
@ -93,7 +93,7 @@ segmentItems:
peer: mariadb-server:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mariadb}
- {key: db.instance, value: test}
- {key: db.statement, value: ''}
- operationName: GET:/mariadb-scenario/case/mariadb-scenario

10
test/plugin/scenarios/mssql-jdbc-scenario/config/expectedData.yaml
View File

@ -23,7 +23,7 @@ segmentItems:
parentSpanId: 0
spanId: 1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -41,7 +41,7 @@ segmentItems:
parentSpanId: 0
spanId: 2
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
- {key: db.sql.parameters, value: '[1,1]'}
@ -58,7 +58,7 @@ segmentItems:
parentSpanId: 0
spanId: 3
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: 'SELECT id, value FROM test_007 WHERE id=?'}
- {key: db.sql.parameters, value: '[1]'}
@ -75,7 +75,7 @@ segmentItems:
parentSpanId: 0
spanId: 4
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: DROP table test_007}
logs: []
@ -91,7 +91,7 @@ segmentItems:
parentSpanId: 0
spanId: 5
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: ''}
logs: []

8
test/plugin/scenarios/mssql-jtds-scenario/config/expectedData.yaml
View File

@ -23,7 +23,7 @@ segmentItems:
parentSpanId: 0
spanId: 1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -41,7 +41,7 @@ segmentItems:
parentSpanId: 0
spanId: 2
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
logs: []
@ -57,7 +57,7 @@ segmentItems:
parentSpanId: 0
spanId: 3
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: DROP table test_007}
logs: []
@ -73,7 +73,7 @@ segmentItems:
parentSpanId: 0
spanId: 4
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mssql}
- {key: db.instance, value: tempdb}
- {key: db.statement, value: ''}
logs: []

8
test/plugin/scenarios/mybatis-3.x-scenario/config/expectedData.yaml
View File

@ -31,7 +31,7 @@ segmentItems:
peer: mysql:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: 'insert into test.table_demo (name) values (?)'}
- operationName: org.apache.ibatis.session.defaults.DefaultSqlSession.insert(java.lang.String,java.lang.Object)
@ -59,7 +59,7 @@ segmentItems:
peer: mysql:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: ''}
- operationName: Mysql/JDBC/PreparedStatement/execute
@ -74,7 +74,7 @@ segmentItems:
peer: mysql:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: 'insert into test.table_demo (name) values (?)'}
- operationName: org.apache.ibatis.session.defaults.DefaultSqlSession.insert(java.lang.String,java.lang.Object)
@ -102,7 +102,7 @@ segmentItems:
peer: mysql:3306
skipAnalysis: 'false'
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: ''}
- operationName: GET:/case/mybatis-case

16
test/plugin/scenarios/mysql-scenario/config/expectedData.yaml
View File

@ -23,7 +23,7 @@ segmentItems:
parentSpanId: 0
spanId: 1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -41,7 +41,7 @@ segmentItems:
parentSpanId: 0
spanId: 2
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
logs: []
@ -57,7 +57,7 @@ segmentItems:
parentSpanId: 0
spanId: 3
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: DROP table test_007}
logs: []
@ -73,7 +73,7 @@ segmentItems:
parentSpanId: 0
spanId: 4
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: "create procedure testProcedure(IN id varchar(10)) \n begin \n select id; \n end"}
logs: []
@ -97,14 +97,14 @@ segmentItems:
peer: mysql-server:3306
skipAnalysis: false
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: SHOW CREATE PROCEDURE `test`.`testProcedure`}
- operationName: Mysql/JDBC/CallableStatement/execute
parentSpanId: 0
spanId: 6
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: "call testProcedure( ? )"}
logs: []
@ -120,7 +120,7 @@ segmentItems:
parentSpanId: 0
spanId: 7
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: "drop procedure testProcedure"}
logs: []
@ -136,7 +136,7 @@ segmentItems:
parentSpanId: 0
spanId: 8
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: test}
- {key: db.statement, value: ''}
logs: []

10
test/plugin/scenarios/oracle-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: oracle-server:1521
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Oracle}
- {key: db.instance, value: xe}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -47,7 +47,7 @@ segmentItems:
spanType: Exit
peer: oracle-server:1521
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Oracle}
- {key: db.instance, value: xe}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
skipAnalysis: 'false'
@ -62,7 +62,7 @@ segmentItems:
spanType: Exit
peer: oracle-server:1521
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Oracle}
- {key: db.instance, value: xe}
- {key: db.statement, value: 'SELECT id, value FROM test_007 WHERE id=?'}
skipAnalysis: 'false'
@ -77,7 +77,7 @@ segmentItems:
spanType: Exit
peer: oracle-server:1521
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Oracle}
- {key: db.instance, value: xe}
- {key: db.statement, value: DROP table test_007}
skipAnalysis: 'false'
@ -86,7 +86,7 @@ segmentItems:
spanId: 5
spanLayer: Database
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Oracle}
- {key: db.instance, value: xe}
- {key: db.statement, value: ''}
startTime: nq 0

8
test/plugin/scenarios/postgresql-above9.4.1207-scenario/config/expectedData.yaml
View File

@ -23,7 +23,7 @@ segmentItems:
parentSpanId: 0
spanId: 1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -40,7 +40,7 @@ segmentItems:
parentSpanId: 0
spanId: 2
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
- {key: db.sql.parameters, value: '[1,1]'}
@ -56,7 +56,7 @@ segmentItems:
parentSpanId: 0
spanId: 3
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: DROP table test_007}
startTime: nq 0
@ -71,7 +71,7 @@ segmentItems:
parentSpanId: 0
spanId: 4
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: ''}
startTime: nq 0

8
test/plugin/scenarios/postgresql-scenario/config/expectedData.yaml
View File

@ -23,7 +23,7 @@ segmentItems:
parentSpanId: 0
spanId: 1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- key: db.statement
value: "CREATE TABLE test_007(\nid VARCHAR(1) PRIMARY KEY, \nvalue VARCHAR(1)\
@ -40,7 +40,7 @@ segmentItems:
parentSpanId: 0
spanId: 2
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: 'INSERT INTO test_007(id, value) VALUES(?,?)'}
startTime: nq 0
@ -55,7 +55,7 @@ segmentItems:
parentSpanId: 0
spanId: 3
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: DROP table test_007}
startTime: nq 0
@ -70,7 +70,7 @@ segmentItems:
parentSpanId: 0
spanId: 4
tags:
- {key: db.type, value: sql}
- {key: db.type, value: PostgreSQL}
- {key: db.instance, value: postgres}
- {key: db.statement, value: ''}
startTime: nq 0

8
test/plugin/scenarios/shardingsphere-3.x-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -62,7 +62,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -94,7 +94,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'
@ -139,7 +139,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'

8
test/plugin/scenarios/shardingsphere-4.0.x-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -62,7 +62,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -94,7 +94,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'
@ -139,7 +139,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'

8
test/plugin/scenarios/shardingsphere-4.x-scenario/config/expectedData.yaml
View File

@ -30,7 +30,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -62,7 +62,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_1}
skipAnalysis: 'false'
@ -94,7 +94,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_1}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'
@ -139,7 +139,7 @@ segmentItems:
spanType: Exit
peer: localhost:-1
tags:
- {key: db.type, value: sql}
- {key: db.type, value: H2}
- {key: db.instance, value: demo_ds_0}
- {key: db.statement, value: SELECT * FROM t_order_0}
skipAnalysis: 'false'

10
test/plugin/scenarios/shardingsphere-5.0.0-scenario/config/expectedData.yaml
View File

@ -32,7 +32,7 @@ segmentItems:
peer: localhost:-1
skipAnalysis: false
tags:
- { key: db.type, value: sql}
- { key: db.type, value: H2}
- { key: db.instance, value: not null}
- { key: db.statement, value: not null}
- segmentId: not null
@ -50,7 +50,7 @@ segmentItems:
peer: localhost:-1
skipAnalysis: false
tags:
- { key: db.type, value: sql }
- {key: db.type, value: H2}
- { key: db.instance, value: not null }
- { key: db.statement, value: not null }
- operationName: /ShardingSphere/executeSQL/
@ -85,7 +85,7 @@ segmentItems:
peer: localhost:-1
skipAnalysis: false
tags:
- { key: db.type, value: sql }
- {key: db.type, value: H2}
- { key: db.instance, value: not null }
- { key: db.statement, value: '' }
- segmentId: not null
@ -103,7 +103,7 @@ segmentItems:
peer: localhost:-1
skipAnalysis: false
tags:
- { key: db.type, value: sql }
- {key: db.type, value: H2}
- { key: db.instance, value: not null }
- { key: db.statement, value: not null }
- operationName: /ShardingSphere/executeSQL/
@ -172,7 +172,7 @@ segmentItems:
peer: localhost:-1
skipAnalysis: false
tags:
- { key: db.type, value: sql }
- {key: db.type, value: H2}
- { key: db.instance, value: not null }
- { key: db.statement, value: not null }
- operationName: /ShardingSphere/executeSQL/

10
test/plugin/scenarios/spring-tx-scenario/config/expectedData.yaml
View File

@ -45,7 +45,7 @@ segmentItems:
spanType: Exit
peer: mysql:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: 'insert into `test`.`table_demo`(name) values(?)'}
skipAnalysis: 'false'
@ -60,7 +60,7 @@ segmentItems:
spanType: Exit
peer: mysql:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: 'insert into `test`.`table_demo`(name) values(?)'}
skipAnalysis: 'false'
@ -75,7 +75,7 @@ segmentItems:
spanType: Exit
peer: mysql:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: ''}
skipAnalysis: 'false'
@ -90,7 +90,7 @@ segmentItems:
spanType: Exit
peer: mysql:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: select @@session.tx_read_only}
skipAnalysis: 'false'
@ -105,7 +105,7 @@ segmentItems:
spanType: Exit
peer: mysql:3306
tags:
- {key: db.type, value: sql}
- {key: db.type, value: Mysql}
- {key: db.instance, value: ''}
- {key: db.statement, value: ''}
skipAnalysis: 'false'