Also print outbound MySQL messages

Author: mauricio

CHANGELOG.md

@@ -1,5 +1,15 @@
 # Changelog
 
+## 0.2.11 - 2014-01-11
+
+* Driver logs prepared statement data for PostgreSQL calls when logging is set to debug - #77;
+* MySQL and PostgreSQL drivers log network bytes read/written when logging is set to trace;
+* PostgreSQL now correctly sends JSON to JSON fields without requiring a cast - #75;
+* LocalDateTime is not printed (driver fails silently) - #74;
+* Support for ENUM types on PostgreSQL - #75;
+* Allow configuring the execution context used by PostgreSQL connections - #72
+* Naming executors so we can see the threads created - #71
+
 ## 0.2.10 - 2013-12-18
 
 * Removed application_name from PostgreSQL default connection values - #70

mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/codec/MySQLFrameDecoder.scala

@@ -77,7 +77,7 @@ class MySQLFrameDecoder(charset: Charset, connectionId : String) extends ByteToM
  val slice = buffer.readSlice(size)
 
  if ( log.isTraceEnabled ) {
- log.trace(s"Message received is $messageType - " +
+ log.trace(s"Reading message is $messageType - " +
  s"(count=$messagesCount,size=$size,isInQuery=$isInQuery,processingColumns=$processingColumns,processingParams=$processingParams,processedColumns=$processedColumns,processedParams=$processedParams)" +
  s"\n${BufferDumper.dumpAsHex(buffer)}}")
  }

mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/codec/MySQLOneToOneEncoder.scala

@@ -21,7 +21,7 @@ import com.github.mauricio.async.db.mysql.binary.BinaryRowEncoder
 import com.github.mauricio.async.db.mysql.encoder._
 import com.github.mauricio.async.db.mysql.message.client.ClientMessage
 import com.github.mauricio.async.db.mysql.util.CharsetMapper
-import com.github.mauricio.async.db.util.{ByteBufferUtils, Log}
+import com.github.mauricio.async.db.util.{BufferDumper, ByteBufferUtils, Log}
 import java.nio.charset.Charset
 import scala.annotation.switch
 import io.netty.channel.ChannelHandlerContext
@@ -69,14 +69,16 @@ class MySQLOneToOneEncoder(charset: Charset, charsetMapper: CharsetMapper) exten
  case _ => throw new EncoderNotAvailableException(message)
  }
 
- //log.debug("Writing message {}", message)
-
  val result = encoder.encode(message)
 
  ByteBufferUtils.writePacketLength(result, sequence)
 
  sequence += 1
 
+ if ( log.isTraceEnabled ) {
+ log.trace(s"Writing message ${message.getClass.getName} - \n${BufferDumper.dumpAsHex(result)}")
+ }
+
  out.add(result)
  }
  }

postgresql-async/src/main/scala/com/github/mauricio/async/db/postgresql/codec/MessageEncoder.scala

@@ -63,7 +63,7 @@ class MessageEncoder(charset: Charset, encoderRegistry: ColumnEncoderRegistry) e
  }
 
  if (log.isTraceEnabled) {
- log.trace(s"Message being sent ${msg.getClass.getName}\n${BufferDumper.dumpAsHex(buffer)}")
+ log.trace(s"Sending message ${msg.getClass.getName}\n${BufferDumper.dumpAsHex(buffer)}")
  }
 
  out.add(buffer)