public static int ExecuteNonQuery(string connectionString, CommandType 
 commandType, string commandText, params SqlParameter[] 
  commandParameters)
{
  if( connectionString == null || connectionString.Length 
   == 0 ) throw new ArgumentNullException
    ( "connectionString" );

    // Create & open a SqlConnection, and dispose it after we are done
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
 connection.Open();

 // Call the overloaded method that takes a ready connection 
  instead of the connection string
 return ExecuteNonQuery(connection, commandType, commandText, 
  commandParameters);
    }
}

public static SqlConnection NewSqlConnection(string connectionString, 
 string username)
{
 if( connectionString == null || connectionString.Length == 0 ) 
  throw new ArgumentNullException( "connectionString" );
 SqlConnection connection = new SqlConnection(connectionString);
 connection.Open();
  // Set username for the created connection in CONTEXT_INFO
 SqlCommand command = connection.CreateCommand();
 command.CommandText = string.Format("DECLARE @BinVar varbinary
  (128)" +
  " SET @BinVar = CAST(N'{0}' AS varbinary(128) ) "+
  "SET CONTEXT_INFO @BinVar ", username);
 command.ExecuteNonQuery();
 return connection;
}

public static int ExecuteNonQuery(string connectionString, string username
 , CommandType commandType, string commandText, params SqlParameter
  [] commandParameters)
{
 // Create & open a SqlConnection, and dispose it after we are done
 using (SqlConnection connection = NewSqlConnection
  (connectionString, username))
 {
       // Call the overloaded method that takes a ready connection instead 
 of the connection string
  return ExecuteNonQuery(connection, commandType, 
   commandText, commandParameters);
 }
}

internal sealed class SqlHelper
{
 private string username = string.Empty;
 public SqlHelper(string username) 
 {
  this.username = username;
 }
 public SqlConnection NewSqlConnection(string 
  connectionString)
 {
  if( connectionString == null || 
   connectionString.Length == 0 ) throw new 
    ArgumentNullException
     ( "connectionString" );
  SqlConnection connection = new SqlConnection
   (connectionString);
  connection.Open();
   // Set username for the created connection in 
  CONTEXT_INFO
  SqlCommand command = connection.CreateCommand();
  command.CommandText = string.Format
   ("DECLARE @BinVar varbinary(128)" +
   " SET @BinVar = CAST(N'{0}' AS 
    varbinary(128) ) "+
   "SET CONTEXT_INFO @BinVar ", username); 
  command.ExecuteNonQuery();
  return connection;
 }
}

public int ExecuteNonQuery(string connectionString, CommandType 
 commandType, string commandText, params SqlParameter[] 
  commandParameters)
{
 // Create & open a SqlConnection, and dispose of it after we are 
  done
 using (SqlConnection connection = NewSqlConnection
  (connectionString))
 {
  // Call the overload that takes a connection in place of 
   the connection string
  return ExecuteNonQuery(connection, commandType, 
   commandText, commandParameters);
 }
}

 StartTriggerNameInsert = "tr_i_AUDIT_"
 StartTriggerNameUpdate = "tr_u_AUDIT_"
 StartTriggerNameDelete = "tr_d_AUDIT_"
 
 DatabaseName = "[" & Audit.Database.Name & "]"
 TransactionsTableName = "dbo.AUDIT_LOG_TRANSACTIONS"
 DataTableName = "dbo.AUDIT_LOG_DATA"

DatabaseName = "MyStorageDatabase"

' =============================================================
' =============================================================
' INSERT INSERT INSERT INSERT INSERT INSERT INSERT
' =============================================================
' =============================================================
caption = "Create Insert Trigger " & "[" & objTable.Owner & "].
 [" & StartTriggerNameInsert & objTable.Name & "]" & _
  " for Table " & TableFullName%}
IF OBJECT_ID('{%Audit.Print replace("[" & objTable.Owner & "].[" 
 & StartTriggerNameInsert & objTable.Name & "]", "'", 
  "''") %}','TR') IS NOT NULL
BEGIN
   DROP TRIGGER {%Audit.Print "[" & objTable.Owner & "].[" & 
 StartTriggerNameInsert & objTable.Name & "]" %}
   PRINT '{% Audit.Print "Trigger Dropped: " & StartTriggerNameInsert 
 & Replace(objTable.Name,"'","''")%}'
END
GO
-- {%Audit.Print caption%}
Print '{%Audit.Print Replace(caption, "'", "''")%}'
go
CREATE TRIGGER {%Audit.Print "[" & objTable.Owner & "].[" & 
 StartTriggerNameInsert & objTable.Name & "]" %}
ON {%Audit.Print TableFullName%}
WITH EXECUTE AS '{%Audit.Print Auditor%}'
FOR INSERT
NOT FOR REPLICATION
As

Auditor = "db_auditor"