diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/CallableStatementImpl.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/CallableStatementImpl.scala
index a3ae52bf0..0d63e525e 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/CallableStatementImpl.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/CallableStatementImpl.scala
@@ -211,9 +211,9 @@ case class CallableStatementImpl[F[_]: Temporal: Exchange: Tracer](
                 case q if q.startsWith("INSERT") =>
                   sendQuery(sql.split("VALUES").head + " VALUES" + args.mkString(","))
                     .flatMap {
-                      case _: OKPacket => ev.pure(Array.fill(args.length)(Statement.SUCCESS_NO_INFO.toLong))
+                      case _: OKPacket      => ev.pure(Array.fill(args.length)(Statement.SUCCESS_NO_INFO.toLong))
                       case error: ERRPacket => ev.raiseError(error.toException("Failed to execute query", sql))
-                      case _: EOFPacket => ev.raiseError(new SQLException("Unexpected EOF packet"))
+                      case _: EOFPacket     => ev.raiseError(new SQLException("Unexpected EOF packet"))
                     }
                 case q if q.startsWith("update") || q.startsWith("delete") || q.startsWith("CALL") =>
                   protocol.resetSequenceId *>
@@ -249,7 +249,7 @@ case class CallableStatementImpl[F[_]: Temporal: Exchange: Tracer](
                   ev.raiseError(
                     new SQLException("The batch query must be an INSERT, UPDATE, or DELETE, CALL statement.")
                   )
-            )
+          )
         }
       } <* params.set(ListMap.empty) <* batchedArgs.set(Vector.empty)
 
diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ClientPreparedStatement.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ClientPreparedStatement.scala
index 3a6dc26c4..db7bec8c0 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ClientPreparedStatement.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ClientPreparedStatement.scala
@@ -173,7 +173,7 @@ case class ClientPreparedStatement[F[_]: Temporal: Exchange: Tracer](
                     Attribute("execute", "batch"),
                     Attribute("size", args.length.toLong),
                     Attribute("sql", args.toArray.toSeq)
-                  )) *
+                  ))*
                 ) *> (
                   if args.isEmpty then ev.pure(Array.empty)
                   else
@@ -188,11 +188,11 @@ case class ClientPreparedStatement[F[_]: Temporal: Exchange: Tracer](
                       protocol
                         .receive(GenericResponsePackets.decoder(protocol.initialPacket.capabilityFlags))
                         .flatMap {
-                          case _: OKPacket => ev.pure(Array.fill(args.length)(Statement.SUCCESS_NO_INFO.toLong))
+                          case _: OKPacket      => ev.pure(Array.fill(args.length)(Statement.SUCCESS_NO_INFO.toLong))
                           case error: ERRPacket => ev.raiseError(error.toException("Failed to execute query", sql))
-                          case _: EOFPacket => ev.raiseError(new SQLException("Unexpected EOF packet"))
+                          case _: EOFPacket     => ev.raiseError(new SQLException("Unexpected EOF packet"))
                         }
-                  )
+                )
               }
           } <* params.set(ListMap.empty) <* batchedArgs.set(Vector.empty)
         case q if q.startsWith("update") || q.startsWith("delete") =>
@@ -235,7 +235,7 @@ case class ClientPreparedStatement[F[_]: Temporal: Exchange: Tracer](
                             yield result
                           }
                           .map(_.toArray)
-                    )
+                  )
                 }
             } <*
             protocol.resetSequenceId <*
@@ -246,7 +246,7 @@ case class ClientPreparedStatement[F[_]: Temporal: Exchange: Tracer](
           ev.raiseError(
             new IllegalArgumentException("The batch query must be an INSERT, UPDATE, or DELETE statement.")
           )
-      )
+    )
 
   override def getGeneratedKeys(): F[ResultSet[F]] =
     autoGeneratedKeys.get.flatMap {
diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ServerPreparedStatement.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ServerPreparedStatement.scala
index fb447c9bf..8cf15aae1 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ServerPreparedStatement.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/ServerPreparedStatement.scala
@@ -177,7 +177,7 @@ case class ServerPreparedStatement[F[_]: Temporal: Exchange: Tracer](
                           case error: ERRPacket => ev.raiseError(error.toException("Failed to execute query", sql))
                           case _: EOFPacket     => ev.raiseError(new SQLException("Unexpected EOF packet"))
                         }
-                  )
+                )
               }
           } <* params.set(ListMap.empty) <* batchedArgs.set(Vector.empty)
         case q if q.startsWith("update") || q.startsWith("delete") =>
@@ -220,7 +220,7 @@ case class ServerPreparedStatement[F[_]: Temporal: Exchange: Tracer](
                             yield result
                           }
                           .map(_.toArray)
-                    )
+                  )
                 }
             } <*
             protocol.resetSequenceId <*
@@ -231,7 +231,7 @@ case class ServerPreparedStatement[F[_]: Temporal: Exchange: Tracer](
           ev.raiseError(
             new IllegalArgumentException("The batch query must be an INSERT, UPDATE, or DELETE statement.")
           )
-      )
+    )
 
   override def getGeneratedKeys(): F[ResultSet[F]] =
     autoGeneratedKeys.get.flatMap {
diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/StatementImpl.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/StatementImpl.scala
index 95a622ddc..e5223635e 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/StatementImpl.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/net/protocol/StatementImpl.scala
@@ -169,11 +169,11 @@ private[ldbc] case class StatementImpl[F[_]: Temporal: Exchange: Tracer](
                     yield result
                   }
                   .map(_.toArray)
-            )
+          )
         }
       } <* protocol.resetSequenceId <* protocol.comSetOption(
-      EnumMySQLSetOption.MYSQL_OPTION_MULTI_STATEMENTS_OFF
-    ) <* clearBatch()
+        EnumMySQLSetOption.MYSQL_OPTION_MULTI_STATEMENTS_OFF
+      ) <* clearBatch()
 
   override def getGeneratedKeys(): F[ResultSet[F]] =
     autoGeneratedKeys.get.flatMap {