@@ -24,6 +24,7 @@ function Client(config) {
 this.flags = Client.defaultFlags;
 this.maxPacketSize = 0x01000000;
 this.charsetNumber = 8;
+this.debug = false;
 
 this._queue = [];
 this._connection = null;
@@ -113,6 +114,10 @@ Client..query = function(sql, params, cb) {
 };
 
 Client..write = function(packet) {
+if (this.debug) {
+console.log('-> %s', packet.buffer.inspect());
+}
+
 this._connection.write(packet.buffer);
 };
 
@@ -180,6 +185,10 @@ Client.._dequeue = function() {
 };
 
 Client.._handlePacket = function(packet) {
+if (this.debug) {
+this._debugPacket(packet);
+}
+
 if (packet.type == Parser.GREETING_PACKET) {
 this._sendAuth(packet);
 return;
@@ -260,6 +269,21 @@ Client._packetToUserObject = function(packet) {
 delete packet.errorNumber;
 };
 
+Client.._debugPacket = function(packet) {
+var packetName = null;
+for (var key in Parser) {
+if (!key.match(/_PACKET$/)) {
+continue;
+}
+
+if (Parser[key] == packet.type) {
+packetName = key;
+break;
+}
+}
+console.log('<- %s: %j', packetName, packet);
+};
+
 // Client Flags
 Client.LONG_PASSWORD = 1;
 Client.FOUND_ROWS = 2;

@@ -28,6 +28,8 @@ test(function constructor() {
 assert.strictEqual(client.password, null);
 assert.strictEqual(client.database, null);
 
+assert.strictEqual(client.debug, false);
+
 assert.strictEqual(client.flags, Client.defaultFlags);
 assert.strictEqual(client.maxPacketSize, 0x01000000);
 assert.strictEqual(client.charsetNumber, 8);

@@ -10,7 +10,7 @@ client.connect();
 client.query('SELECT 1 as field_a, 2 as field_b', function(err, results) {
 if (err) throw err;
 
-console.log(results);
 assert.equal(results[0].field_a, 1);
 assert.equal(results[0].field_b, 2);
+client.end();
 });