|
| 1 | +/* |
| 2 | + * Copyright The OpenTelemetry Authors |
| 3 | + * SPDX-License-Identifier: Apache-2.0 |
| 4 | + */ |
| 5 | + |
1 | 6 | package io.opentelemetry.instrumentation.spring.autoconfigure.internal.instrumentation.jdbc; |
2 | 7 |
|
3 | 8 | import com.google.errorprone.annotations.CanIgnoreReturnValue; |
4 | 9 | import io.opentelemetry.api.OpenTelemetry; |
5 | 10 | import io.opentelemetry.instrumentation.jdbc.datasource.JdbcTelemetry; |
6 | 11 | import io.opentelemetry.instrumentation.spring.autoconfigure.internal.properties.InstrumentationConfigUtil; |
7 | 12 | import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties; |
8 | | - |
9 | 13 | import javax.annotation.Nonnull; |
10 | 14 | import javax.annotation.Nullable; |
11 | 15 | import javax.sql.DataSource; |
12 | | - |
13 | 16 | import org.aopalliance.intercept.MethodInterceptor; |
14 | 17 | import org.aopalliance.intercept.MethodInvocation; |
15 | 18 | import org.springframework.aop.framework.ProxyFactory; |
@@ -53,22 +56,24 @@ public Object postProcessAfterInitialization(Object bean, String beanName) { |
53 | 56 | && !isRoutingDatasource(bean) |
54 | 57 | && !ScopedProxyUtils.isScopedTarget(beanName)) { |
55 | 58 | DataSource dataSource = (DataSource) bean; |
56 | | - DataSource wrapped = JdbcTelemetry.builder(openTelemetryProvider.getObject()) |
57 | | - .setStatementSanitizationEnabled( |
58 | | - InstrumentationConfigUtil.isStatementSanitizationEnabled( |
59 | | - configPropertiesProvider.getObject(), |
60 | | - "otel.instrumentation.jdbc.statement-sanitizer.enabled")) |
61 | | - .setCaptureQueryParameters( |
62 | | - configPropertiesProvider |
63 | | - .getObject() |
64 | | - .getBoolean( |
65 | | - "otel.instrumentation.jdbc.experimental.capture-query-parameters", false)) |
66 | | - .setTransactionInstrumenterEnabled( |
67 | | - configPropertiesProvider |
68 | | - .getObject() |
69 | | - .getBoolean("otel.instrumentation.jdbc.experimental.transaction.enabled", false)) |
70 | | - .build() |
71 | | - .wrap(dataSource); |
| 59 | + DataSource wrapped = |
| 60 | + JdbcTelemetry.builder(openTelemetryProvider.getObject()) |
| 61 | + .setStatementSanitizationEnabled( |
| 62 | + InstrumentationConfigUtil.isStatementSanitizationEnabled( |
| 63 | + configPropertiesProvider.getObject(), |
| 64 | + "otel.instrumentation.jdbc.statement-sanitizer.enabled")) |
| 65 | + .setCaptureQueryParameters( |
| 66 | + configPropertiesProvider |
| 67 | + .getObject() |
| 68 | + .getBoolean( |
| 69 | + "otel.instrumentation.jdbc.experimental.capture-query-parameters", false)) |
| 70 | + .setTransactionInstrumenterEnabled( |
| 71 | + configPropertiesProvider |
| 72 | + .getObject() |
| 73 | + .getBoolean( |
| 74 | + "otel.instrumentation.jdbc.experimental.transaction.enabled", false)) |
| 75 | + .build() |
| 76 | + .wrap(dataSource); |
72 | 77 |
|
73 | 78 | ProxyFactory proxyFactory = new ProxyFactory(DataSource.class); |
74 | 79 | proxyFactory.setTarget(bean); |
|
0 commit comments