SQL監控和感嘆詞

從另一個線程，給了我如何監控添加到SQL Server中的信息...SQL監控和感嘆詞

See SQL From EntityFramework with Collection-like Queries

這個效果很好，但我希望把它更進了一步。我希望能夠在事務發生時將註釋添加到日誌中。

我希望能夠寫入註釋到事情中，但是，這將進入SQL日誌記錄。所以，我可以做一個查詢，並調用Debugger.Logger.Write（「某種評論」），所以我知道是什麼。我不太瞭解SQL，所以我想了解什麼是正在運行的，以及在哪裏。

任何幫助，非常感謝。我認爲我將不得不運行另一個SQL查詢來將註釋插入到查詢流中。

我設計，則在調試器類..

public static class Debugger 
{ 
    public static System.IO.TextWriter File 
    { 
     get; 
     set; 
    } 
    public static void Open() 
    { 
     // open a file for storing SQL results from queries 
     File = new System.IO.StreamWriter("results.sql", false); 
    } 

    public static void Write(string text) 
    { 
     File.WriteLine(text); 
    } 

    public static bool Log(SampleDataContext context) 
    { 
     var results = context.Database.Connection.CreateCommand(); 
     results.CommandText = Sql.Review; 
     context.Database.Connection.Open(); 

     System.Data.Common.DbDataReader resultsReader; 
     do 
     { 
      resultsReader = results.ExecuteReader(); 
     } 
     while (resultsReader == null); 

     Console.WriteLine("Discovered a Data Reader"); 

     // Retrieves the schema of the table. 
     var dtSchema = resultsReader.GetSchemaTable(); 

     string strRow; // represents a full row 
     // Reads the rows one by one from the SqlDataReader 
     // transfers them to a string with the given separator character and 
     // writes it to the file. 
     while (resultsReader.Read()) 
     { 
      Console.WriteLine("Reading Data Reader... "); 

      strRow = ""; 
      for (int i = 0; i < resultsReader.FieldCount; i++) 
      { 
       strRow += resultsReader.GetValue(i).ToString(); 
       if (i < resultsReader.FieldCount - 1) 
       { 
        strRow += " "; 
       } 
      } 

      Sql.Text.Lexer lexer = new Sql.Text.Lexer(); 
      lexer.Enscribe(); 

      var matches = lexer.Tokenize(strRow); 
      matches.ForEach(x => 
           { 
            strRow = strRow.Replace(x.Value, Environment.NewLine); 
           }); 

      File.WriteLine(strRow); 
     } 

     File.Close(); 
     context.Database.Connection.Close(); 

     return false; 
    } 

    public static bool SetupLog(SampleDataContext context) 
    { 
     var command = context.Database.Connection.CreateCommand(); 
     command.CommandText = Sql.Record; 

     context.Database.Connection.Open(); 
     command.ExecuteNonQuery(); 
     context.Database.Connection.Close(); 

     return true; 
    } 
}

我基本上都插入下面的SQL到C＃中的資源我的數據上下文（的DbContext）

using(var context = new SampleDataContext(dbModel)) 
{ 
// ... 
      // prepare a logging model. 
      if (Debugger.SetupLog(context)) 
       Console.WriteLine("Logging Enabled..."); 
      // open up the debugger log 
      Debugger.Open(); 
} 

public class SampleDataContext: DbContext, IDisposable 
    { 
     public new void Dispose() 
     { 
      Debugger.Log(this); 

      base.Dispose(); 
     } 
    }

...

這是「Project.SQL.Record」。

IF EXISTS(SELECT * FROM sys.server_event_sessions WHERE name='test_trace') 
    DROP EVENT SESSION [test_trace] ON SERVER; 
CREATE EVENT SESSION [test_trace] 
ON SERVER 
ADD EVENT sqlserver.sp_statement_completed(
    ACTION (package0.callstack, sqlserver.session_id, sqlserver.sql_text) 
    -- WHERE (([sqlserver].[username]='Domain\Username')) 
    ), 
ADD EVENT sqlserver.sql_statement_completed(
    ACTION (package0.callstack, sqlserver.session_id, sqlserver.sql_text) 
    --WHERE (([sqlserver].[username]='Domain\Username')) 
    ) 
ADD TARGET package0.ring_buffer 
WITH (MAX_MEMORY = 4096KB, EVENT_RETENTION_MODE = ALLOW_SINGLE_EVENT_LOSS, 
MAX_DISPATCH_LATENCY = 1 SECONDS, MAX_EVENT_SIZE = 0KB, 
MEMORY_PARTITION_MODE = NONE, TRACK_CAUSALITY = OFF, STARTUP_STATE = OFF) 

ALTER EVENT SESSION [test_trace] ON SERVER STATE = START

然後我又有一個「Project.SQL.Review」。

DECLARE 
    @session_name VARCHAR(200) = 'test_trace' 

SELECT 
    pivoted_data.* 
FROM 
( 
SELECT MIN(event_name) AS event_name, 
    MIN(event_timestamp) AS event_timestamp, 
    unique_event_id, 
    CONVERT (BIGINT, MIN (
     CASE 
      WHEN d_name = 'cpu' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [cpu], 
    CONVERT (BIGINT, MIN (
     CASE 
      WHEN d_name = 'duration' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [duration], 
    CONVERT (BIGINT, MIN (
     CASE 
      WHEN d_name = 'object_id' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [object_id], 
    CONVERT (INT, MIN (
     CASE 
      WHEN d_name = 'object_type' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [object_type], 
    CONVERT (DECIMAL(28,0), MIN (
     CASE 
      WHEN d_name = 'reads' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [reads], 
    CONVERT (VARCHAR(MAX), MIN (
     CASE 
      WHEN d_name = 'session_id' 
      AND d_package IS NOT NULL 
      THEN d_value 
     END)) AS [session_id], 
    CONVERT (INT, MIN (
     CASE 
      WHEN d_name = 'source_database_id' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [source_database_id], 
    CAST((SELECT CONVERT (VARCHAR(MAX), MIN (
     CASE 
      WHEN d_name = 'sql_text' 
      AND d_package IS NOT NULL 
      THEN d_value 
     END)) AS [processing-instruction(x)] FOR XML PATH('')) AS XML) AS [sql_text], 
    CONVERT (DECIMAL(28,0), MIN (
     CASE 
      WHEN d_name = 'writes' 
      AND d_package IS NULL 
      THEN d_value 
     END)) AS [writes] 
FROM 
    ( 
     SELECT 
      *, 
      CONVERT(VARCHAR(400), NULL) AS attach_activity_id 
     FROM 
     ( 
      SELECT 
       event.value('(@name)[1]', 'VARCHAR(400)') as event_name, 
       event.value('(@timestamp)[1]', 'DATETIME') as event_timestamp, 
       DENSE_RANK() OVER (ORDER BY event) AS unique_event_id, 
       n.value('(@name)[1]', 'VARCHAR(400)') AS d_name, 
       n.value('(@package)[1]', 'VARCHAR(400)') AS d_package, 
       n.value('((value)[1]/text())[1]', 'VARCHAR(MAX)') AS d_value, 
       n.value('((text)[1]/text())[1]', 'VARCHAR(MAX)') AS d_text 
      FROM 
      ( 
       SELECT 
        ( 
         SELECT 
          CONVERT(xml, target_data) 
         FROM sys.dm_xe_session_targets st 
         JOIN sys.dm_xe_sessions s ON 
          s.address = st.event_session_address 
         WHERE 
          s.name = @session_name 
          AND st.target_name = 'ring_buffer' 
        ) AS [x] 
       FOR XML PATH(''), TYPE 
      ) AS the_xml(x) 
      CROSS APPLY x.nodes('//event') e (event) 
      CROSS APPLY event.nodes('*') AS q (n) 
     ) AS data_data 
    ) AS activity_data 
    GROUP BY 
     unique_event_id 
) AS pivoted_data;

我首先想到的是讓這樣的方法..

public static void WriteSql(SampleDataContext context, string text) 
    { 
     var command = context.Database.Connection.CreateCommand(); 
     command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Comment",System.Data.SqlDbType.VarChar)); 
     command.Parameters["@Comment"].Value = String.Format("--{0}", text); 
     command.CommandText = String.Format("PRINT '{0}'", text.Replace("'", "''")); 
     context.Database.Connection.Open(); 
     command.ExecuteNonQuery(); 
     context.Database.Connection.Close(); 
    }

其應該執行類似查詢的評論，應在審查顯示，對不對？那麼，這沒有用。所以我打開其他想法...

來源

2010-09-13 Ciel

您可能可以使用PRINT聲明。使用參數化查詢與被稱爲@Comment參數，然後執行

PRINT @Comment

如果評論需要從正規的查詢很容易區分，你可以添加一個新的事件

, 
ADD EVENT sqlserver.error_reported(
    ACTION (sqlserver.sql_text) 
    WHERE (([severity]=(1))))

，並使用RAISERROR(@Comment,1,1)代替。

來源

2010-09-14 11:45:02

我編輯了我的代碼的最後一位以反映您的建議，但它顯示的是輸出中的原始SQL「PRINT @Comment」。任何想法，我錯了？ – Ciel 2010-09-14 15:52:04

不，也許嘗試使用'varchar'而不是文本作爲參數。 'text'是一個LOB數據類型，所以可能不適用於打印。如果這不起作用，那麼我想你可以使用'command.CommandText = String.Format（「PRINT'{0}'」，text.Replace（「'」，「''」））;'as它是您創建註釋的代碼，您不必擔心SQL注入。 – 2010-09-15 12:07:24

我已經在WriteSql方法中更新了我的代碼，並且仍然沒有骰子。它不會在Sql Output中顯示任何內容。 – Ciel 2010-09-15 14:43:16

SQL監控和感嘆詞

回答

相關問題