apm-sniffer/apm-sdk-plugin/clickhouse-0.3.2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/clickhouse/v32/ClickHousePrepareStatementTracing.java [35:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static <T> T of(ConnectionInfo connectionInfo, String methodName, String sql,
            SupplierWithException<T> supplier) throws SQLException {
        final AbstractSpan span = ContextManager.createExitSpan(
                connectionInfo.getDBType() + "/JDBC/Statement/" + methodName, connectionInfo.getDatabasePeer());
        try {
            Tags.DB_TYPE.set(span, connectionInfo.getDBType());
            Tags.DB_INSTANCE.set(span, connectionInfo.getDatabaseName());
            Tags.DB_STATEMENT.set(span, sql);
            span.setComponent(connectionInfo.getComponent());
            SpanLayer.asDB(span);
            return supplier.get();
        } catch (SQLException e) {
            span.log(e);
            throw e;
        } finally {
            ContextManager.stopSpan();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



apm-sniffer/apm-sdk-plugin/clickhouse-0.3.1-plugin/src/main/java/org/apache/skywalking/apm/plugin/jdbc/clickhouse/ClickHouseStatementTracingWrapper.java [33:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static <T> T of(ConnectionInfo connectionInfo, String methodName, String sql,
            SupplierWithException<T> supplier) throws SQLException {
        final AbstractSpan span = ContextManager.createExitSpan(
                connectionInfo.getDBType() + "/JDBC/Statement/" + methodName, connectionInfo.getDatabasePeer());
        try {
            Tags.DB_TYPE.set(span, connectionInfo.getDBType());
            Tags.DB_INSTANCE.set(span, connectionInfo.getDatabaseName());
            Tags.DB_STATEMENT.set(span, sql);
            span.setComponent(connectionInfo.getComponent());
            SpanLayer.asDB(span);
            return supplier.get();
        } catch (SQLException e) {
            span.log(e);
            throw e;
        } finally {
            ContextManager.stopSpan();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -