0

我的公司正在使用 SQL Server 2008。我正面临一个存在事务问题的审计表。

我有一个存储过程。

create proc MySP
as begin
    insert into MY_TABLE values('Value1');

    begin transaction TX_MY_SP
    -- write to audit table permanently
    insert into AUDIT_TABLE values('Value1 is inserted.'); 
    commit transaction TX_MY_SP
end

我有一块 VB.net 代码

Using tx = New TransactionScope()
    Using conn = New SqlConnection(MY_CONN_STR)
        Using cmd = New SqlCommand("MySP", conn)
            conn.Open()
            cmd.ExecuteNonQuery()
            Throw New ApplicationException("Always throw exception.")
        End Using
    End Using
    tx.Complete()
End Using

但是，没有记录插入 AUDIT_TABLE。我在 MSDN http://msdn.microsoft.com/en-us/library/ms189336.aspx中找到了原因

我的问题是如何使用存储过程插入记录 AUDIT_TABLE。

谢谢！

4

3 回答 3

1

基本上，您可以做的是拥有一个异步审计/日志系统。因此，您的审计将在不同的线程上运行，并且您的主事务范围是否失败并不重要。

  1. 使用企业库+MSMQ
  2. 构建您自己的轻量级异步日志系统（使用同步队列）
于 2012-01-04T06:16:23.947 回答
0

回滚事务中的任何操作也会回滚。不这样做会破坏事务的原子性。鉴于您正在审核的活动正在回滚，您很可能实际上希望无论如何都回滚审核。

尽管如此，当需要记录当前事务范围之外的操作时，还是有一些合理的情况，例如某些调试情况。有已知的变通方法，例如对用户可配置的事件类使用事件通知，然后使用以使事件通知激活过程运行并记录审计。因为探查器事件是在事务范围之外生成的，所以审计记录不会回滚。sp_trace_generateevent

:setvar dbname testdb
:on error exit

set nocount on;
use master;

if exists (
    select * from sys.server_event_notifications
    where name = N'audit')
begin
    drop event notification audit on server;
end 
go

if db_id('$(dbname)') is not null
begin
    alter database [$(dbname)] set single_user with rollback immediate;
    drop database [$(dbname)];
end
go

create database [$(dbname)];
go

alter authorization on database::[$(dbname)] to [sa];
go

use [$(dbname)];
go

create queue audit;
create service audit on queue audit (
    [http://schemas.microsoft.com/SQL/Notifications/PostEventNotification]);
go  

create table audit_table (
    Time datetime not null,
    TextData nvarchar(256) not null);
go

create procedure usp_audit
as
begin
declare @h uniqueidentifier, @mt sysname, @mb varbinary(max), @mx xml;
begin transaction;
receive top(1) @h = conversation_handle,
    @mt = message_type_name,
    @mb = message_body
from audit;
if (@mt = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification')
begin
    select @mx = cast(@mb as xml);
    insert into audit_table (Time, TextData)
    values (
        @mx.value(N'(/EVENT_INSTANCE/PostTime)[1]', N'datetime'),
        @mx.value(N'(/EVENT_INSTANCE/TextData)[1]', N'nvarchar(256)'));
end
else if (@mt = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
    or @mt = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog')
begin
    end conversation @h;
end 
commit
end 
go

alter queue audit
    with activation (
        status = on,
        procedure_name = usp_audit,
        max_queue_readers = 1,
        execute as owner);
go      

create event notification audit
on server for USERCONFIGURABLE_0
to service N'audit', N'current database';
go

begin transaction;
exec sp_trace_generateevent 82, N'this was inserted from a rolled back';
rollback
go

waitfor delay '00:00:05';
select * from audit_table;
go
于 2011-03-04T05:37:40.663 回答
0

使用 时，如果您不希望事务回滚TransactionScope，则需要在超出其范围之前调用该方法：Complete

Using tx = New TransactionScope()
    Using conn = New SqlConnection(MY_CONN_STR)
        Using cmd = New SqlCommand("MySP", conn)
            conn.Open()
            cmd.ExecuteNonQuery()
            'Throw New ApplicationException("Always throw exception.")
        End Using
    End Using

    tx.Complete() ' <---- Here

End Using
于 2011-03-03T23:05:47.237 回答