Merge pull request DbUp#89 from gfody/master

fixes DbUp#88

src/DbUp/Builder/StandardExtensions.cs

@@ -68,7 +68,19 @@ public static UpgradeEngineBuilder LogScriptOutput(this UpgradeEngineBuilder bui
     public static UpgradeEngineBuilder LogToTrace(this UpgradeEngineBuilder builder)
     {
         return LogTo(builder, new TraceUpgradeLog());
-    }
+    }
+
+	/// <summary>
+	/// Logs to SqlContext.Pipe, for use with "context connection=true".
+	/// </summary>
+	/// <param name="builder">The builder.</param>
+	/// <returns>
+	/// The same builder
+	/// </returns>
+	public static UpgradeEngineBuilder LogToSqlContext(this UpgradeEngineBuilder builder)
+	{
+		return LogTo(builder, new SqlContextUpgradeLog());
+	}
 
     /// <summary>
     /// Uses a custom journal for recording which scripts were executed.

src/DbUp/DbUp.csproj

@@ -60,6 +60,7 @@
     <Compile Include="Builder\UpgradeEngineBuilder.cs" />
     <Compile Include="DeployChanges.cs" />
     <Compile Include="Engine\DelegateDisposable.cs" />
+    <Compile Include="Engine\Output\SqlContextUpgradeLog.cs" />
     <Compile Include="Engine\Transactions\DatabaseConnectionManager.cs" />
     <Compile Include="Engine\IScript.cs" />
     <Compile Include="Engine\Transactions\SingleTrasactionStrategy.cs" />

src/DbUp/Engine/Output/SqlContextUpgradeLog.cs

@@ -0,0 +1,22 @@
+using Microsoft.SqlServer.Server;
+
+namespace DbUp.Engine.Output
+{
+	internal class SqlContextUpgradeLog : IUpgradeLog
+	{
+		public void WriteInformation(string format, params object[] args)
+		{
+			SqlContext.Pipe.Send("INFO:  " + string.Format(format, args));
+		}
+
+		public void WriteError(string format, params object[] args)
+		{
+			SqlContext.Pipe.Send("ERROR: " + string.Format(format, args));
+		}
+
+		public void WriteWarning(string format, params object[] args)
+		{
+			SqlContext.Pipe.Send("WARN:  " + string.Format(format, args));
+		}
+	}
+}

src/DbUp/Support/SqlServer/SqlScriptExecutor.cs

@@ -150,7 +150,7 @@ public virtual void Execute(SqlScript script, IDictionary<string, string> variab
             }
         }
 
-        private virtual void Log(IDataReader reader)
+        public virtual void Log(IDataReader reader)
         {
             do
             {