diff options
author | Diego <diegolparra@gmail.com> | 2014-11-25 08:51:21 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-12-04 02:27:38 -0300 |
commit | 6e6bb0486bc6ad83103e8ab62f6f928da0918a2c (patch) | |
tree | 92664be748d1a7af7873ef749a32b35d40eb0dba /kamon-jdbc/src/main/scala/kamon/jdbc | |
parent | 4cf69bc1367bbe75623cbab40e653ea08b2e0341 (diff) | |
download | Kamon-6e6bb0486bc6ad83103e8ab62f6f928da0918a2c.tar.gz Kamon-6e6bb0486bc6ad83103e8ab62f6f928da0918a2c.tar.bz2 Kamon-6e6bb0486bc6ad83103e8ab62f6f928da0918a2c.zip |
= kamon-jdbc: minor refactor
Diffstat (limited to 'kamon-jdbc/src/main/scala/kamon/jdbc')
-rw-r--r-- | kamon-jdbc/src/main/scala/kamon/jdbc/instrumentation/StatementInstrumentation.scala | 7 |
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 |