Skip to content

Commit 663911b

Browse files
committed
feat: Create a database logger
1 parent 9060bfc commit 663911b

1 file changed

Lines changed: 25 additions & 2 deletions

File tree

file_service/src/main/scala/db/transactor.scala

Lines changed: 25 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,34 @@ import cats.effect.unsafe.implicits.global
1010
import doobie._
1111
import doobie.implicits._
1212
import doobie.util.transactor.Transactor
13+
import doobie.util.log.{
14+
LogHandler,
15+
LogEvent,
16+
Success,
17+
ProcessingFailure,
18+
ExecFailure
19+
}
20+
1321
import utils.config
1422

23+
val handler: LogHandler[IO] = new LogHandler[IO] {
24+
def run(event: LogEvent) = event match {
25+
case Success(sql, args, _, _, processing_time) =>
26+
IO.println(
27+
s"Executed: $sql | args: $args | Procesing Time: ${processing_time.toMillis} ms"
28+
)
29+
case ProcessingFailure(sql, args, _, _, processing_time, failure) =>
30+
IO.println(
31+
s"Processing failure: $sql | args: $args | Processing Time: ${processing_time.toMillis} ms",
32+
failure
33+
)
34+
case ExecFailure(sql, args, _, _, failure) =>
35+
IO.println(s"Execution failure: $sql | args: $args", failure)
36+
}
37+
}
38+
1539
val transactor: Transactor[IO] = Transactor.fromDriverManager[IO](
1640
driver = "org.sqlite.JDBC",
17-
// url = config.DB_URL,
1841
url = config.DB_URL,
19-
logHandler = None
42+
logHandler = Some(handler)
2043
)

0 commit comments

Comments
 (0)