Loading skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWCallableStatementTest.java +13 −13 Original line number Diff line number Diff line Loading @@ -463,7 +463,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -484,7 +484,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -503,7 +503,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -521,7 +521,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -539,7 +539,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -560,7 +560,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -581,7 +581,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = ?"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = ?"); } }); } Loading @@ -602,7 +602,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -622,7 +622,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -642,7 +642,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -662,7 +662,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -687,7 +687,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeBatch", ""); } }); } Loading Loading @@ -736,7 +736,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWConnectionTest.java +15 −15 Original line number Diff line number Diff line Loading @@ -66,7 +66,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); } }); } Loading @@ -81,7 +81,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); } }); } Loading @@ -98,7 +98,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -115,7 +115,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); Loading @@ -131,7 +131,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); } Loading @@ -147,7 +147,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); } Loading @@ -162,7 +162,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); } }); } Loading @@ -176,7 +176,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); } }); } Loading @@ -192,7 +192,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -208,7 +208,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); } }); } Loading @@ -222,7 +222,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); } }); } Loading @@ -238,7 +238,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -255,7 +255,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); } }); } Loading @@ -269,7 +269,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); } }); } Loading @@ -285,7 +285,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWStatementTest.java +11 −11 Original line number Diff line number Diff line Loading @@ -123,7 +123,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "SELECT * FROM test"); } }); } Loading @@ -139,7 +139,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "SELECT * FROM test"); } }); } Loading @@ -155,7 +155,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -171,7 +171,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -189,7 +189,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -205,7 +205,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -221,7 +221,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -237,7 +237,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -253,7 +253,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -275,7 +275,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/Statement/executeBatch", ""); } }); } Loading @@ -294,7 +294,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1 WHERE b = 2"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1 WHERE b = 2"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SwPreparedStatementTest.java +13 −13 Original line number Diff line number Diff line Loading @@ -293,7 +293,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -314,7 +314,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -333,7 +333,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -351,7 +351,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -369,7 +369,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -390,7 +390,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -411,7 +411,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = ?"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = ?"); } }); } Loading @@ -432,7 +432,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -452,7 +452,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -472,7 +472,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -492,7 +492,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -517,7 +517,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeBatch", ""); } }); } Loading Loading @@ -568,7 +568,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading Loading
skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWCallableStatementTest.java +13 −13 Original line number Diff line number Diff line Loading @@ -463,7 +463,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -484,7 +484,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -503,7 +503,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -521,7 +521,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -539,7 +539,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -560,7 +560,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -581,7 +581,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = ?"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = ?"); } }); } Loading @@ -602,7 +602,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -622,7 +622,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -642,7 +642,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -662,7 +662,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -687,7 +687,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeBatch", ""); } }); } Loading Loading @@ -736,7 +736,7 @@ public class SWCallableStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/CallableStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertDBSpan(span, "Mysql/JDBI/CallableStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading
skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWConnectionTest.java +15 −15 Original line number Diff line number Diff line Loading @@ -66,7 +66,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); } }); } Loading @@ -81,7 +81,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); } }); } Loading @@ -98,7 +98,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/commit"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/commit"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -115,7 +115,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); Loading @@ -131,7 +131,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); } Loading @@ -147,7 +147,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback"); } }); } Loading @@ -162,7 +162,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); } }); } Loading @@ -176,7 +176,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); } }); } Loading @@ -192,7 +192,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/rollback to savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/rollback to savepoint"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -208,7 +208,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); } }); } Loading @@ -222,7 +222,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); } }); } Loading @@ -238,7 +238,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/close"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/close"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading @@ -255,7 +255,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); } }); } Loading @@ -269,7 +269,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); } }); } Loading @@ -285,7 +285,7 @@ public class SWConnectionTest extends AbstractStatementTest { @Override public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); assertDBSpan(traceSegment.getSpans().get(0), "JDBC/Connection/releaseSavepoint savepoint"); assertDBSpan(traceSegment.getSpans().get(0), "Mysql/JDBI/Connection/releaseSavepoint savepoint"); assertDBSpanLog(traceSegment.getSpans().get(0).getLogs().get(0)); } }); Loading
skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SWStatementTest.java +11 −11 Original line number Diff line number Diff line Loading @@ -123,7 +123,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "SELECT * FROM test"); } }); } Loading @@ -139,7 +139,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "SELECT * FROM test"); } }); } Loading @@ -155,7 +155,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/Statement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -171,7 +171,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -189,7 +189,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -205,7 +205,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -221,7 +221,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -237,7 +237,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -253,7 +253,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -275,7 +275,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/Statement/executeBatch", ""); } }); } Loading @@ -294,7 +294,7 @@ public class SWStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/Statement/execute", "UPDATE test SET a = 1 WHERE b = 2"); assertDBSpan(span, "Mysql/JDBI/Statement/execute", "UPDATE test SET a = 1 WHERE b = 2"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading
skywalking-sniffer/skywalking-sdk-plugin/jdbc-plugin/src/test/java/com/a/eye/skywalking/plugin/jdbc/SwPreparedStatementTest.java +13 −13 Original line number Diff line number Diff line Loading @@ -293,7 +293,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -314,7 +314,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test"); } }); } Loading @@ -333,7 +333,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -351,7 +351,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -369,7 +369,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "INSERT INTO test VALUES(1)"); } }); } Loading @@ -390,7 +390,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/execute", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/execute", "UPDATE test SET a = 1"); } }); } Loading @@ -411,7 +411,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = ?"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = ?"); } }); } Loading @@ -432,7 +432,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -452,7 +452,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -472,7 +472,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -492,7 +492,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeUpdate", "UPDATE test SET a = 1"); } }); } Loading @@ -517,7 +517,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeBatch", ""); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeBatch", ""); } }); } Loading Loading @@ -568,7 +568,7 @@ public class SwPreparedStatementTest extends AbstractStatementTest { public void call(TraceSegment traceSegment) { assertThat(traceSegment.getSpans().size(), is(1)); Span span = traceSegment.getSpans().get(0); assertDBSpan(span, "JDBC/PreparedStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertDBSpan(span, "Mysql/JDBI/PreparedStatement/executeQuery", "SELECT * FROM test WHERE a = ? or b = ? or c=? or d = ? or e=?"); assertThat(span.getLogs().size(), is(1)); assertDBSpanLog(span.getLogs().get(0)); } Loading