#113 use std.experimental.logger

Author: SingingBush

source/mysql/connection.d

@@ -4,6 +4,9 @@ module mysql.connection;
 import std.algorithm;
 import std.conv;
 import std.exception;
+static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+	import std.experimental.logger;
+}
 import std.range;
 import std.socket;
 import std.string;
@@ -438,6 +441,10 @@ package:
 
 	static PlainPhobosSocket defaultOpenSocketPhobos(string host, ushort port)
 	{
+		static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+			sharedLog.tracef("opening phobos socket %s:%s", host, port);
+		}
+
 		auto s = new PlainPhobosSocket();
 		s.connect(new InternetAddress(host, port));
 		return s;
@@ -446,7 +453,11 @@ package:
 	static PlainVibeDSocket defaultOpenSocketVibeD(string host, ushort port)
 	{
 		version(Have_vibe_d_core)
+		{
+			import vibe.core.log : logDebug;
+			logDebug("opening vibe-d socket %s:%s", host, port);
 			return vibe.core.net.connectTCP(host, port);
+		}
 		else
 			assert(0);
 	}

source/mysql/protocol/comms.d

@@ -24,6 +24,10 @@ import std.algorithm;
 import std.conv;
 import std.digest.sha;
 import std.exception;
+static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+	import std.experimental.logger;
+}
+
 import std.range;
 import std.variant;
 
@@ -511,9 +515,19 @@ package(mysql) bool execQueryImpl(Connection conn, ExecQueryImplInfo info, out u
 
 	// Send data
 	if(info.isPrepared)
+	{
+		static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+			sharedLog.tracef("prepared SQL: %s", info.hStmt);
+		}
+
 		ProtocolPrepared.sendCommand(conn, info.hStmt, info.psh, info.inParams, info.psa);
+	}
 	else
 	{
+		static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+			sharedLog.tracef("exec query: %s", info.sql);
+		}
+
 		conn.sendCmd(CommandType.QUERY, info.sql);
 		conn._fieldCount = 0;
 	}
@@ -525,6 +539,11 @@ package(mysql) bool execQueryImpl(Connection conn, ExecQueryImplInfo info, out u
 	{
 		conn.resetPacket();
 		auto okp = OKErrorPacket(packet);
+
+		static if(__traits(compiles, (){ import std.experimental.logger; } )) {
+			sharedLog.errorf("packet error: %s %s", okp.error, okp.message);
+		}
+
 		enforcePacketOK(okp);
 		ra = okp.affected;
 		conn._serverStatus = okp.serverStatus;