Tworzenie funkcja do pobierania danych zmian

The sys.sp_cdc_generate_wrapper_function system procedura przechowywana generates scripts to create wrapper functions for use by Integration Services packages.

Poniżej przedstawiono pierwszych kilka wierszy, definicja procedura przechowywana:

CREATE PROCEDURE sys.sp_cdc_generate_wrapper_function

(

@capture\_instance sysname = null

@closed\_high\_end\_point bit = 1,

@column\_list = null,

@update\_flag\_list = null

)

Wszystkie parametry procedura przechowywana są opcjonalne.Jeśli bez podawania wartości dla każdego z parametrów wywołania procedury przechowywanej, procedura przechowywana tworzy funkcji otoki dla wszystkich wystąpień przechwytywania, do których użytkownik ma dostęp.

Procedura przechowywana generuje zawsze funkcja otoki, aby zwrócić wszystkie zmiany z każdego wystąpienie przechwytywania.Jeśli @supports\_net\_changes została ustawiona podczas tworzenia wystąpienie przechwytywania, procedura przechowywana generuje również funkcja otoki, aby zwrócić obroty netto z każdego wystąpienie przechwytywania stosuje.

Procedura przechowywana zwraca zestaw z dwiema kolumnami wyników:

• Nazwa funkcja otoka wygenerowanych przez procedura przechowywana.Ta procedura przechowywana uzyskuje nazwę funkcja z nazwą wystąpienie przechwytywania.(Nazwa funkcja jest "fn_all_changes_", po których następuje nazwa wystąpienie przechwytywania.Prefiks używany dla funkcja obroty netto, jeśli jest tworzony, jest "fn_net_changes_").

• Instrukcja CREATE funkcja otoki.

Zwykle deweloper użyje instrukcja SQL INSERT... EXEC wywołać sys.sp_cdc_generate_wrapper_function procedura przechowywana, a następnie zapisz skryptów, które tworzy procedura przechowywana na tabela tymczasowa.Każdy skrypt może następnie być indywidualnie zaznaczone i uruchomić w celu utworzenia odpowiedniej funkcja otoki.Jednak programista może również używać jednego zestaw poleceń SQL na wykonywanie wszystkich skryptów CREATE, jak pokazano na następujący przykładowy kod:

create table #wrapper_functions
      (function_name sysname, create_stmt nvarchar(max))
insert into #wrapper_functions
exec sys.sp_cdc_generate_wrapper_function

declare @stmt nvarchar(max)
declare #hfunctions cursor local fast_forward for 
      select create_stmt from #wrapper_functions
open #hfunctions
fetch #hfunctions into @stmt
while (@@fetch_status <> -1)
begin
      exec sp_executesql @stmt
      fetch #hfunctions into @stmt
end
close #hfunctions
deallocate #hfunctions

Systematycznie zaprezentuje osi czasu, zmiana przechwyconych danych, funkcje wygenerowanych otoki oczekiwanych, @end\_time Parametr dla jeden interwał będzie @start\_time Parametr dla kolejnych interwału. Kiedy następuje tej Konwencji, otoka wygenerowanych funkcji można wykonywać następujące zadania:

• Mapowanie datę / czas wartości z wartościami LSN, które będą używane wewnętrznie.

• Upewnij się, że dane nie zostanie utracony lub powtarzane.

Aby podczas badania dla wszystkich wierszy w tabela Zmiana prostsze, otoka wygenerowanych funkcji obsługuje następujące konwencje:

• Jeśli parametr @ start_time ma wartość null, funkcje otoka użyć najniższej wartości LSN w przechwytywaniu wystąpienie jako dolne ograniczenie kwerendy.

• Jeśli parametr @ end_time ma wartość null, funkcje otoka użyć najwyższej wartości LSN w przypadku przechwytywania jako górną granicę kwerendy.

Większość użytkowników powinna mieć możliwość używania otoka funkcje, które sys.sp_cdc_generate_wrapper_function systemowa procedura składowana tworzy bez żadnych modyfikacji.Jednak aby dostosować funkcje otoki, trzeba dostosować skrypty CREATE przed uruchomieniem skryptów.

Gdy pakiet wywołuje funkcji otoki, pakiet, musisz podać wartości parametrów trzy.Te trzy parametry są jak trzy parametry, że zmiana danych przechwytywać funkcji.Te trzy parametry są następujące:

• Data początkowa / czas wartości i datę końcową / czas wartość dla przedziału czasu.Funkcje otoką za pomocą wartości data/godziny jako punkty końcowe interwału kwerendy, zmiana danych przechwytywania dwie wartości LSN użycia funkcji jako punkty końcowe.

• Filtr wiersza.W przypadku zmiany danych i funkcji otoki przechwytywania funkcji, @row\_filter\_option parametr jest taka sama. Aby uzyskać więcej informacji zobacz cdc.fn_cdc_get_all_changes_<capture_instance> (Transact-SQL) i cdc.fn_cdc_get_net_changes_<capture_instance> (Transact-SQL).

Zestaw wyników zwróconych przez includesthe funkcji otoki, następujących danych:

• Zmienić wszystkie żądane kolumny danych.

• Kolumna o nazwie __CDC_OPERATION korzystającej z pole jednej lub dwóch znaków do identyfikowania operacji, który jest skojarzony z wierszem.Prawidłowe wartości dla tego pole są następujące: ‘ I ’ do wstawiania, ‘ D ’ o usunięcie, ‘ UO ’ dla aktualizacji stare wartości i ‘ UN ’ wartości nowych aktualizacji.

• Aktualizacja flag, gdy zażąda ich) są wyświetlane jako kolumny bit po kodzie operacji i w kolejności określonej w @update\_flag\_list parametr. Te kolumna noszą nazwy za pomocą dołączania ‘ _uflag ’ do nazwy skojarzonej kolumnie.

Jeśli pakiet wywołuje funkcję otoka tej kwerendy dla wszystkich zmian, funkcja otoka zwraca także kolumny, __CDC_STARTLSN i __CDC_SEQVAL.Te dwie kolumny stają się kolumny pierwszego i drugiego, zestaw wyników.Funkcja otoka również sortuje zestaw wyników na podstawie tych dwóch kolumn.

CREATE function CDCSample.uf_Customer (
     @start_time datetime
    ,@end_time datetime
)
returns @Customer table (
     CustomerID int
    ,TerritoryID int
    ,CustomerType nchar(1)
    ,rowguid uniqueidentifier
    ,ModifiedDate datetime
    ,CDC_OPERATION varchar(1)
) as
begin
    declare @from_lsn binary(10), @to_lsn binary(10)

    if (@start_time is null)
        select @from_lsn = sys.fn_cdc_get_min_lsn('Customer')
    else
        select @from_lsn = sys.fn_cdc_increment_lsn(sys.fn_cdc_map_time_to_lsn('largest less than or equal',@start_time))

    if (@end_time is null)
        select @to_lsn = sys.fn_cdc_get_max_lsn()
    else
        select @to_lsn = sys.fn_cdc_map_time_to_lsn('largest less than or equal',@end_time)

    if (@from_lsn = sys.fn_cdc_increment_lsn(@to_lsn))
        return

    -- Query for change data
    insert into @Customer
    select 
        CustomerID,    
        TerritoryID, 
        CustomerType, 
        rowguid, 
        ModifiedDate, 
        case __$operation
                when 1 then 'D'
                when 2 then 'I'
                when 4 then 'U'
                else null
         end as CDC_OPERATION
    from 
        cdc.fn_cdc_get_net_changes_Customer(@from_lsn, @to_lsn, 'all')

    return
end 
go

Mimo że utworzyć użytkownika funkcja zwracająca tabelę pokazano tylko starsze zastosowań Operacja $ __ kolumnieCDC.fn_cdc_get_net_changes_<capture_instance> funkcja zwraca cztery kolumna metadane dla każdego wiersza zmiany. Chcąc użyć tych wartości w sieci przepływ danych, można przywrócić je jako dodatkowe kolumny z funkcja otoka wycenione tabela.

Aby uzyskać więcej informacji zobaczcdc.fn_cdc_get_net_changes_<capture_instance> (Transact-SQL).