cdc.fn_cdc_get_net_changes_<capture_instance> (Transact-SQL)
Retourne une ligne de modification nette pour chaque ligne source modifiée dans la plage spécifiée de numéros séquentiels dans le journal. Autrement dit, lorsqu'une ligne source subit plusieurs modifications pendant la plage de numéros séquentiels dans le journal, une seule ligne qui reflète le contenu final de la ligne est retournée par la fonction. Par exemple, si une transaction insère une ligne dans la table source et qu'une transaction suivante dans la plage de numéros séquentiels dans le journal met à jour une ou plusieurs colonnes de cette ligne, la fonction retourne une seule ligne qui inclut les valeurs de colonne mises à jour.
Cette fonction d'énumération est créée lorsqu'une table source est activée pour la capture des données modifiées et que le suivi net est spécifié. Pour activer le suivi net, la table source doit avoir une clé primaire ou un index unique. Le nom de fonction est dérivé et utilise le format cdc.fn_cdc_get_net_changes_capture_instance, où capture_instance est la valeur spécifiée pour l'instance de capture lorsque la table source a été activée pour la capture de données modifiées. Pour plus d'informations, consultez sys.sp_cdc_enable_table (Transact-SQL).
Conventions de la syntaxe Transact-SQL
Syntaxe
cdc.fn_cdc_get_net_changes_capture_instance ( from_lsn , to_lsn , '<row_filter_option>' )
<row_filter_option> ::=
{ all
| all with mask
| all with merge
}
Arguments
from_lsn
Numéro séquentiel dans le journal qui représente le point de terminaison inférieur de la plage de numéros séquentiels dans le journal à inclure dans le jeu de résultats. from_lsn est de type binary(10).Seules les lignes de la table de modifications cdc.[capture_instance]_CT avec une valeur dans __$start_lsn supérieure ou égale à from_lsn sont incluses dans le jeu de résultats.
to_lsn
Numéro séquentiel dans le journal qui représente le point de terminaison supérieur de la plage de numéros séquentiels dans le journal à inclure dans le jeu de résultats. to_lsn est de type binary(10).Seules les lignes de la table de modifications cdc.[capture_instance]_CT avec une valeur dans __$start_lsn inférieure ou égale à from_lsn ou égale à to_lsn sont incluses dans le jeu de résultats.
<row_filter_option> ::= { all | all with mask | all with merge }
Option qui régit le contenu des colonnes de métadonnées aussi bien que les lignes retournées dans le jeu de résultats. Il peut s'agir de l'une des options suivantes :all
Retourne le numéro séquentiel dans le journal de la modification finale apportée à la ligne et de l'opération permettant d'appliquer la ligne aux colonnes de métadonnées __$start_lsn et __$operation. La colonne __$update_mask a toujours la valeur NULL.all with mask
Retourne le numéro séquentiel dans le journal de la modification finale apportée à la ligne et de l'opération permettant d'appliquer la ligne aux colonnes de métadonnées __$start_lsn et __$operation. De plus, lorsqu'une opération de mise à jour retourne (__$operation = 4), les colonnes capturées modifiées dans la mise à jour sont marquées dans la valeur retournée dans __$update_mask.all with merge
Retourne le numéro séquentiel dans le journal de la modification finale apportée à la ligne dans les colonnes de métadonnées __$start_lsn. La colonne __$operation affichera l'une des deux valeurs suivantes : 1 pour la suppression et 5 pour indiquer que l'opération permettant d'appliquer la modification est une insertion ou une mise à jour. La colonne __$update_mask a toujours la valeur NULL.Dans la mesure où la logique permettant de déterminer l'opération précise pour une modification donnée augmente la complexité de la requête, cette option est conçue pour améliorer le performances des requêtes lorsqu'il suffit d'indiquer que l'opération nécessaire pour appliquer la donnée modifiée est une insertion ou une mise à jour, mais il n'est pas utile de différencier explicitement les deux. Cette option est très intéressante dans les environnements cibles où une opération de fusion est disponible directement, tel qu'un environnement SQL Server 2012.
Table retournée
Nom de la colonne |
Type de données |
Description |
---|---|---|
__$start_lsn |
binary(10) |
Numéro séquentiel dans le journal associé à la transaction de validation de la modification. Toutes les modifications validées dans la même transaction partagent le même numéro séquentiel dans le journal de validation. Par exemple, si une opération de mise à jour sur la table source modifie deux colonnes sur deux lignes, la table de modifications contiendra quatre lignes, chacune avec la même valeur __$start_lsn. |
__$operation |
int |
Identifie l'opération du langage de manipulation de données permettant d'appliquer la ligne de données de modification à la source de données cible. Si la valeur du paramètre row_filter_option est all ou all with mask, la valeur dans cette colonne peut être l'une des suivantes : 1 = suppression 2 = insertion 4 = mise à jour Si la valeur du paramètre row_filter_option est all with merge,, la valeur dans cette colonne peut être l'une des suivantes : 1 = suppression |
__$update_mask |
varbinary(128) |
Masque de bits avec un bit correspondant à chaque colonne capturée identifiée pour l'instance de capture. Tous les bits définis de cette valeur ont la valeur 1 quand __$operation = 1 ou 2. Quand __$operation = 3 ou 4, seuls les bits qui correspondent aux colonnes qui ont changé ont la valeur 1. |
<captured source table columns> |
variable |
Les colonnes restantes retournées par la fonction sont les colonnes de la table source qui ont été identifiées comme colonnes capturées lorsque l'instance de capture a été créée. Si aucune colonne n'a été spécifiée dans la liste des colonnes capturées, toutes les colonnes de la table source sont retournées. |
Autorisations
Requiert l'appartenance au rôle serveur fixe sysadmin ou au rôle de base de données fixe db_owner. Pour tous les autres utilisateurs, requiert l'autorisation SELECT sur toutes les colonnes capturées dans la table source et, si un rôle de régulation pour l'instance de capture a été défini, l'appartenance à ce rôle de base de données. Lorsque l'appelant n'a pas l'autorisation de consulter les données sources, la fonction retourne l'erreur 208 (nom d'objet non valide).
Notes
Si la plage spécifiée de numéro séquentiel dans le journal ne se situe pas dans la chronologie de suivi des modifications pour l'instance de capture, la fonction retourne l'erreur 208 (nom d'objet non valide).
Exemples
L'exemple suivant utilise la fonction cdc.fn_cdc_get_net_changes_HR_Department pour signaler les modifications nettes apportées à la table source HumanResources.Department pendant un intervalle de temps spécifique.
En premier lieu, la fonction GETDATE est utilisée pour marquer le début de l'intervalle de temps. Après avoir appliqué à la table source plusieurs instructions DML, la fonction GETDATE est rappelée pour identifier la fin de l'intervalle de temps. La fonction sys.fn_cdc_map_time_to_lsn est alors utilisée pour mapper l'intervalle de temps à une plage de requêtes de capture des données modifiées liées par les valeurs LSN. Enfin, la fonction cdc.fn_cdc_get_net_changes_HR_Department est interrogée pour obtenir les modifications nettes apportées à la table source pendant l'intervalle de temps. Remarquez que la ligne qui est insérée, puis supprimée n'apparaît pas dans le jeu de résultats retourné par la fonction. En effet, une ligne qui est d'abord ajoutée, puis supprimée dans une fenêtre de requête ne produit aucune modification nette dans la table source pendant l'intervalle. Avant d'exécuter cet exemple, vous devez d'abord exécuter l'exemple B dans sys.sp_cdc_enable_table (Transact-SQL).
USE AdventureWorks2012;
GO
DECLARE @begin_time datetime, @end_time datetime, @from_lsn binary(10), @to_lsn binary(10);
-- Obtain the beginning of the time interval.
SET @begin_time = GETDATE() -1;
-- DML statements to produce changes in the HumanResources.Department table.
INSERT INTO HumanResources.Department (Name, GroupName)
VALUES (N'MyDept', N'MyNewGroup');
UPDATE HumanResources.Department
SET GroupName = N'Resource Control'
WHERE GroupName = N'Inventory Management';
DELETE FROM HumanResources.Department
WHERE Name = N'MyDept';
-- Obtain the end of the time interval.
SET @end_time = GETDATE();
-- Map the time interval to a change data capture query range.
SET @from_lsn = sys.fn_cdc_map_time_to_lsn('smallest greater than or equal', @begin_time);
SET @to_lsn = sys.fn_cdc_map_time_to_lsn('largest less than or equal', @end_time);
-- Return the net changes occurring within the query window.
SELECT * FROM cdc.fn_cdc_get_net_changes_HR_Department(@from_lsn, @to_lsn, 'all');
Voir aussi
Référence
cdc.fn_cdc_get_all_changes_<capture_instance> (Transact-SQL)
sys.fn_cdc_map_time_to_lsn (Transact-SQL)
sys.sp_cdc_enable_table (Transact-SQL)
sys.sp_cdc_help_change_data_capture (Transact-SQL)