aboutsummaryrefslogtreecommitdiff
path: root/kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala')
-rw-r--r--kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala7
1 files changed, 4 insertions, 3 deletions
diff --git a/kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala b/kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala
index f0a83007..600a79b9 100644
--- a/kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala
+++ b/kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala
@@ -17,6 +17,7 @@ package kamon.jdbc.instrumentation
import java.sql.SQLException
import java.util.concurrent.TimeUnit.{ NANOSECONDS ⇒ nanos }
+
import akka.actor.ActorSystem
import kamon.Kamon
import kamon.jdbc.Jdbc
@@ -59,8 +60,8 @@ class StatementInstrumentation {
log.debug(s"Unable to parse sql [$sql]")
pjp.proceed()
}
- } getOrElse pjp.proceed()
- }
+ }
+ } getOrElse pjp.proceed()
@AfterThrowing(pointcut = "onExecuteStatement(sql) || onExecutePreparedStatement(sql) || onExecutePreparedCall(sql)", throwing = "ex")
def onError(sql: String, ex: SQLException): Unit = {
@@ -94,7 +95,7 @@ class StatementInstrumentation {
}
object StatementInstrumentation {
- val log = LoggerFactory.getLogger("StatementInstrumentation")
+ val log = LoggerFactory.getLogger(classOf[StatementInstrumentation])
val SelectStatement = "(?i)^\\s*select.*?\\sfrom[\\s\\[]+([^\\]\\s,)(;]*).*".r
val InsertStatement = "(?i)^\\s*insert(?:\\s+ignore)?\\s+into\\s+([^\\s(,;]*).*".r