SQL Server change tracking
No edit summary
(Adding page to Category:TOC because it contains a TOC.)
 
(9 intermediate revisions by 4 users not shown)
Line 1: Line 1:
=== Background ===
=== Background ===
The MDrivenServer has build in change tracking. It's implemented as a "dirty list" of objects that all clients can ask for. When the client gets this list, it markes all matched objects in memory as "dirty" and discards them. If any of these objects are present in a user interface (that is currently shown), these objects will be immediately reloaded from the MDrivenServer/ SQL Server.
The MDrivenServer has built-in change tracking. It is implemented as a "dirty list" of objects that all clients can ask for. When the client gets this list, it marks all matched objects in memory as "dirty" and discards them. If any of these objects are present in a user interface (that is currently shown), these objects will be immediately reloaded from the MDrivenServer/ SQL Server.  


MDrivenServer's dirty list is not a part of SQL Server and out of the box the MDrivenServer won't find out if some other client or service changes the underlying tables directly in the SQL Server.
MDrivenServer's dirty list is not part of the SQL Server and the MDrivenServer won't find out if some other client or service changes the underlying tables directly in the SQL Server.


The need for external dirty list handling (aka. change tracking) is often needed only when there's legacy system reading and writing to the same SQL database. Because of this, it's usually not a good idea to have it on all tables in the database. You probably only want change tracking on the tables that can be affected by the non-MDriven system.
The need for external dirty list handling (aka. change tracking) is often needed when there's legacy system reading and writing to the same SQL database. Because of this, it's not a good idea to have it on all tables in the database. You probably only want change tracking on the tables that can be affected by the non-MDriven system.  


=== MDriven implementation ===
== MDriven Implementation ==


==== Support for change tracking in SQL Server ====
==== Support for Change Tracking in SQL Server ====
Tracking of changes is available from SQL Server 2008 and in Azure SQL. It's available in the '''Express''' editions, so you can use it in the built in Turnkey database.
Tracking of changes is available from SQL Server 2008 and in Azure SQL. It's available in the '''Express''' editions, so you can use it in the built-in Turnkey database.


==== Background about this on MS site ====
==== Background About This on MS Site ====
https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/about-change-tracking-sql-server
https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/about-change-tracking-sql-server


Article with a lot of details: https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/work-with-change-tracking-sql-server
Article with details: https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/work-with-change-tracking-sql-server


==== How we propose you use the MDriven features to do change tracking ====
==== How We Propose You Use the MDriven Features to Do Change Tracking ====
We want to put as little extra load as possible on the SQL Server. We therefore use to different jobs to detect that '''''something changed''''' and then '''''what has changed'''''
We want to put as little extra load as possible on the SQL Server. We, therefore, use different jobs to detect that '''''something changed''''' and then '''''what has changed.'''''
* '''Something changed''': The stored procedure ''CHANGE_TRACKING_CURRENT_VERSION()'' can be used to know if ANY change has occurred. We compare this version value with the value when we last processed change information.
* '''Something changed''': The stored procedure ''CHANGE_TRACKING_CURRENT_VERSION()'' can be used to know if ANY change has occurred. We compare this version value with the value when we last processed change information.


Line 25: Line 25:
It then uses [[OCLOperators SuspectExternalUpdateInvalidate|SuspectExternalUpdateInvalidate]] to "invalidate", make dirty, the changes objects.
It then uses [[OCLOperators SuspectExternalUpdateInvalidate|SuspectExternalUpdateInvalidate]] to "invalidate", make dirty, the changes objects.


==== Support with other database servers ====
==== Support With Other Database Servers ====
The MDriven implementation is not dependent on HOW you find out what has changed. As long as you can find the primary key of changed rows, you can use this functionality.   
The MDriven implementation is not dependent on HOW you find out what has changed. As long as you can find the primary key of changed rows, you can use this functionality.   


=== Applying change tracking ===
=== Applying Change Tracking ===


==== Preparing your SQL-server ====
==== Preparing Your SQL-server ====
The suggested pattern to allow for MDriven Applications to effectively discover changes to data made by others is this.
The suggested pattern to allow for MDriven Applications to effectively discover changes to data made by others is this.
'''''Turn on change tracking on the db and on the tables you want to discover foreign changes to'''''
'''''Turn on change tracking on the DB and on the tables you want to discover foreign changes to.'''''


To turn change tracking '''on''', do like this
To turn change tracking '''on''', do this:
  ALTER DATABASE <database name>
  ALTER DATABASE <database name>
  SET CHANGE_TRACKING = ON   
  SET CHANGE_TRACKING = ON   
  (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON)  
  (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON)  
Turn on change tracking for each table you want to track
Turn on change tracking for each table you want to track:
  ALTER TABLE <nowiki><table name></nowiki>
  ALTER TABLE <nowiki><table name></nowiki>
  ENABLE CHANGE_TRACKING
  ENABLE CHANGE_TRACKING
You do NOT need column track, we track whole rows/objects.
You do NOT need column track, we track whole rows/objects.


==== Model additions ====
==== Model Additions ====
'''''Add attributes in SysSingleton'''''
'''''Add attributes in SysSingleton'''''
* CurrentVersionNumberFromChangeTracking: Int64?
* CurrentVersionNumberFromChangeTracking: Int64?
Line 49: Line 49:
* LastHandledVersionNumberFromChangeTracking: Int64?
* LastHandledVersionNumberFromChangeTracking: Int64?


==== Viewmodel additions ====
==== Viewmodel Additions ====
Read more on [[Serverside actions]]
Read more on [[Serverside actions]].


===== Create a MDrivenServer server side job that asks sql server for the current change track version =====
===== Create an MDrivenServer Server-side Job That Asks the SQL Server for the Current Change Track Version =====
Create a viewmodel '''SS_GetCurrentTrackingVersion''' rooted in SysSingleton
* Create a ViewModel '''SS_GetCurrentTrackingVersion''' rooted in SysSingleton
 
* Add the '''CurrentVersionNumberFromChangeTracking''' attribute to the ViewModel.
Add the '''CurrentVersionNumberFromChangeTracking''' attribute to the viewmodel
* Add an action called '''GetCurrentVersion''' with this EAL.
 
Add action called '''GetCurrentVersion''' with this EAL
  self.CurrentVersionNumberFromChangeTracking := SysSingleton.sqlpassthrough(  
  self.CurrentVersionNumberFromChangeTracking := SysSingleton.sqlpassthrough(  
  '-- Get the current tracking version number
  '-- Get the current tracking version number
Line 63: Line 61:
   SET @CurrentVersionNumberFromChangeTracking = CHANGE_TRACKING_CURRENT_VERSION();
   SET @CurrentVersionNumberFromChangeTracking = CHANGE_TRACKING_CURRENT_VERSION();
   select @CurrentVersionNumberFromChangeTracking', Int64 )->first.Part1
   select @CurrentVersionNumberFromChangeTracking', Int64 )->first.Part1
Add critera for serverside execution to the viewmodel with an PS Ocl like this
Add criteria for serverside execution to the ViewModel with a PS OCL like this:
  SysSingleton.allInstances
  SysSingleton.allInstances
===== Create a MDrivenServer server side job that invalidates changed objects =====
===== Create an MDrivenServer Server-side Job That Invalidates Changed Objects =====
* Create a viewmodel '''SS_InvalidateExternalChanges''' rooted in SysSingleton
* Create a ViewModel '''SS_InvalidateExternalChanges''' rooted in SysSingleton


* Add the '''CurrentVersionNumberFromChangeTracking''' and '''LastHandledVersionNumberFromChangeTracking''' attributes to the viewmodel
* Add the '''CurrentVersionNumberFromChangeTracking''' and '''LastHandledVersionNumberFromChangeTracking''' attributes to the ViewModel


* Add variable vHandleToVersionNumber as Int64
* Add variable vHandleToVersionNumber as Int64


* Add action called '''Invalidate''' with this EAL
* Add an action called '''Invalidate''' with this EAL.
  -- Move to variable avoiding change of version during execution
  -- Move to variable avoiding change of version during execution
  vHandleToVersionNumber := vCurrent_SS_InvalidateExternalChanges.CurrentVersionNumberFromChangeTracking;
  vHandleToVersionNumber := vCurrent_SS_InvalidateExternalChanges.CurrentVersionNumberFromChangeTracking;
Line 82: Line 80:
  -- Update last handled change number
  -- Update last handled change number
  self.LastHandledVersionNumberFromChangeTracking := vHandleToVersionNumber
  self.LastHandledVersionNumberFromChangeTracking := vHandleToVersionNumber
The '''selfVM.SuspectExternalUpdateInvalidate.....''' is the one you need to adapt to your tables that you are tracking.  
The '''selfVM.SuspectExternalUpdateInvalidate.....''' is the one you need to adapt to the tables you are tracking.  


One row for each of the classes/tables you're tracking.
One row for each of the classes/tables you're tracking.
* Add critera for serverside execution to the viewmodel with an PS Ocl like this
* Add criteria for serverside execution to the ViewModel with a PS OCL like this
  SysSingleton.allInstances->select(ss|ss.CurrentVersionNumberFromChangeTracking <> ss.LastHandledVersionNumberFromChangeTracking)
  SysSingleton.allInstances->select(ss|ss.CurrentVersionNumberFromChangeTracking <> ss.LastHandledVersionNumberFromChangeTracking)
This means that the job isn't even invoked is there's nothing to do.
This means that the job isn't even invoked if there's nothing to do.  


=== Recommended interval ===
=== Recommended Interval ===
Interval has to be adjusted depending on need and load on the server.  
Interval has to be adjusted depending on the need and load on the server.  


But it can be quite low, because it's a very fast operation. For example 5 seconds, or what suits your need of discovery.  
It can be quite low because it's a very fast operation - for example, 5 seconds, or what suits your need of discovery.  


The detection takes about 10 ms to run and getting changes for 40 tables (without changes) around 100 ms.
The detection takes about 10 ms to run and gets changes for 40 tables (without changes) around 100 ms.


==== Generating OCL and SQL for change tracked classes ====
=== Generating OCL and SQL for Change Tracked Classes ===
You can use the model debugger to make is easier to keep your change tracking OCL and SQL in sync with your model. '''Note!''' This OCL is for a database with reverse engineered tables, having non-standard table names and primary keys.
You can use the model debugger to make it easier to keep your change-tracking OCL and SQL in sync with your model. '''Note!''' This OCL is for a database with reverse-engineered tables, having non-standard table names and primary keys.


===== Extend your model =====
===== Extend Your Model =====
If you add a tagged value on your classes, for example called '''ChangeTracking.''' See [[TaggedValues]] for more information.
If you add a tagged value to your classes, for example, called '''ChangeTracking.''' See [[TaggedValues]] for more information.
[[File:ChangeTracking tagged value.png|none|thumb|419x419px|ChangeTracking tagged value with icon]]
[[File:ChangeTracking tagged value.png|none|thumb|419x419px|ChangeTracking tagged value with icon]]
[[File:Tagged value editor for ChangeTracking.png|none|thumb|138x138px|Tagged value editor]]
[[File:Tagged value editor for ChangeTracking.png|none|thumb|138x138px|Tagged value editor]]


===== SQL for turning change tracking on =====
===== SQL for Turning Change Tracking On =====
Using this tag called '''ChangeTracking''', you can then use this OCL for generate SQL for turning change tracking '''on''' for each table
Using this tag called '''ChangeTracking''', you can use this OCL to generate SQL for turning change tracking '''on''' for each table.
  Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
  Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
   String.format('ALTER TABLE {2} ENABLE CHANGE_TRACKING  -- For class {0}',
   String.format('ALTER TABLE {2} ENABLE CHANGE_TRACKING  -- For class {0}',
Line 113: Line 111:
   )
   )
  )->orderBy(s|s)
  )->orderBy(s|s)
This will create a list of rows like this
This will create a list of rows like this:
  ALTER TABLE [CV] ENABLE CHANGE_TRACKING  -- For class CV
  ALTER TABLE [CV] ENABLE CHANGE_TRACKING  -- For class CV
Run this SQL on your SQL Server database
Run this SQL on your SQL Server database.


===== OCL for invalidating objects =====
===== OCL for Invalidating Objects =====
  Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
  Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
   String.format('selfVM.SuspectExternalUpdateInvalidate({0}.sqlpassthroughobjects( \'SELECT {1} FROM CHANGETABLE (CHANGES {2}, \' + LastHandledVersionNumberFromChangeTracking.toString + \') AS C\') );',
   String.format('selfVM.SuspectExternalUpdateInvalidate({0}.sqlpassthroughobjects( \'SELECT {1} FROM CHANGETABLE (CHANGES {2}, \' + LastHandledVersionNumberFromChangeTracking.toString + \') AS C\') );',
Line 125: Line 123:
   )
   )
  )->orderBy(s|s)
  )->orderBy(s|s)
This will create a list of rows like this
This will create a list of rows like this:
  selfVM.SuspectExternalUpdateInvalidate(CV.sqlpassthroughobjects( 'SELECT [CV_ID] FROM CHANGETABLE (CHANGES [CV], ' + LastHandledVersionNumberFromChangeTracking.toString + ') AS C') );
  selfVM.SuspectExternalUpdateInvalidate(CV.sqlpassthroughobjects( 'SELECT [CV_ID] FROM CHANGETABLE (CHANGES [CV], ' + LastHandledVersionNumberFromChangeTracking.toString + ') AS C') );
Insert this OCL in the '''SS_InvalidateExternalChanges''' action.
Insert this OCL in the '''SS_InvalidateExternalChanges''' action.  


==== Supporting SQL for SQL Server ====
==== Helpful Queries for SQL Server ====
Here are a couple of helpful queries: [[Change tracking help SQL]]
Here are a couple of helpful queries: [[Change tracking help SQL]]
[[Category:SQL]]
{{Edited|July|12|2024}}
[[Category:TOC]]

Latest revision as of 14:13, 26 March 2024

Background

The MDrivenServer has built-in change tracking. It is implemented as a "dirty list" of objects that all clients can ask for. When the client gets this list, it marks all matched objects in memory as "dirty" and discards them. If any of these objects are present in a user interface (that is currently shown), these objects will be immediately reloaded from the MDrivenServer/ SQL Server.

MDrivenServer's dirty list is not part of the SQL Server and the MDrivenServer won't find out if some other client or service changes the underlying tables directly in the SQL Server.

The need for external dirty list handling (aka. change tracking) is often needed when there's legacy system reading and writing to the same SQL database. Because of this, it's not a good idea to have it on all tables in the database. You probably only want change tracking on the tables that can be affected by the non-MDriven system.

MDriven Implementation

Support for Change Tracking in SQL Server

Tracking of changes is available from SQL Server 2008 and in Azure SQL. It's available in the Express editions, so you can use it in the built-in Turnkey database.

Background About This on MS Site

https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/about-change-tracking-sql-server

Article with details: https://docs.microsoft.com/en-us/sql/relational-databases/track-changes/work-with-change-tracking-sql-server

How We Propose You Use the MDriven Features to Do Change Tracking

We want to put as little extra load as possible on the SQL Server. We, therefore, use different jobs to detect that something changed and then what has changed.

  • Something changed: The stored procedure CHANGE_TRACKING_CURRENT_VERSION() can be used to know if ANY change has occurred. We compare this version value with the value when we last processed change information.
  • What has changed: If there's a change, we iterate change information for all tables we're interested in.

Both of these methods use sqlpassthroughobjects to directly use SQL to return information.

It then uses SuspectExternalUpdateInvalidate to "invalidate", make dirty, the changes objects.

Support With Other Database Servers

The MDriven implementation is not dependent on HOW you find out what has changed. As long as you can find the primary key of changed rows, you can use this functionality.

Applying Change Tracking

Preparing Your SQL-server

The suggested pattern to allow for MDriven Applications to effectively discover changes to data made by others is this. Turn on change tracking on the DB and on the tables you want to discover foreign changes to.

To turn change tracking on, do this:

ALTER DATABASE <database name>
SET CHANGE_TRACKING = ON  
(CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON) 

Turn on change tracking for each table you want to track:

ALTER TABLE <table name>
ENABLE CHANGE_TRACKING

You do NOT need column track, we track whole rows/objects.

Model Additions

Add attributes in SysSingleton

  • CurrentVersionNumberFromChangeTracking: Int64?
  • LastHandledVersionNumberFromChangeTracking: Int64?

Viewmodel Additions

Read more on Serverside actions.

Create an MDrivenServer Server-side Job That Asks the SQL Server for the Current Change Track Version
  • Create a ViewModel SS_GetCurrentTrackingVersion rooted in SysSingleton
  • Add the CurrentVersionNumberFromChangeTracking attribute to the ViewModel.
  • Add an action called GetCurrentVersion with this EAL.
self.CurrentVersionNumberFromChangeTracking := SysSingleton.sqlpassthrough( 
'-- Get the current tracking version number
  DECLARE @CurrentVersionNumberFromChangeTracking bigint;
  SET @CurrentVersionNumberFromChangeTracking = CHANGE_TRACKING_CURRENT_VERSION();
  select @CurrentVersionNumberFromChangeTracking', Int64 )->first.Part1

Add criteria for serverside execution to the ViewModel with a PS OCL like this:

SysSingleton.allInstances
Create an MDrivenServer Server-side Job That Invalidates Changed Objects
  • Create a ViewModel SS_InvalidateExternalChanges rooted in SysSingleton
  • Add the CurrentVersionNumberFromChangeTracking and LastHandledVersionNumberFromChangeTracking attributes to the ViewModel
  • Add variable vHandleToVersionNumber as Int64
  • Add an action called Invalidate with this EAL.
-- Move to variable avoiding change of version during execution
vHandleToVersionNumber := vCurrent_SS_InvalidateExternalChanges.CurrentVersionNumberFromChangeTracking;
-- Invalidate changed objects
selfVM.SuspectExternalUpdateInvalidate(<classname>.sqlpassthroughobjects( 'SELECT <primarykeyattributename> FROM CHANGETABLE (CHANGES <tablename>, ' + LastHandledVersionNumberFromChangeTracking.toString + ') AS C') );
selfVM.SuspectExte....
selfVM.SuspectExte....
selfVM.SuspectExte....
-- Update last handled change number
self.LastHandledVersionNumberFromChangeTracking := vHandleToVersionNumber

The selfVM.SuspectExternalUpdateInvalidate..... is the one you need to adapt to the tables you are tracking.

One row for each of the classes/tables you're tracking.

  • Add criteria for serverside execution to the ViewModel with a PS OCL like this
SysSingleton.allInstances->select(ss|ss.CurrentVersionNumberFromChangeTracking <> ss.LastHandledVersionNumberFromChangeTracking)

This means that the job isn't even invoked if there's nothing to do.

Recommended Interval

Interval has to be adjusted depending on the need and load on the server.

It can be quite low because it's a very fast operation - for example, 5 seconds, or what suits your need of discovery.

The detection takes about 10 ms to run and gets changes for 40 tables (without changes) around 100 ms.

Generating OCL and SQL for Change Tracked Classes

You can use the model debugger to make it easier to keep your change-tracking OCL and SQL in sync with your model. Note! This OCL is for a database with reverse-engineered tables, having non-standard table names and primary keys.

Extend Your Model

If you add a tagged value to your classes, for example, called ChangeTracking. See TaggedValues for more information.

ChangeTracking tagged value with icon
Tagged value editor
SQL for Turning Change Tracking On

Using this tag called ChangeTracking, you can use this OCL to generate SQL for turning change tracking on for each table.

Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
  String.format('ALTER TABLE {2} ENABLE CHANGE_TRACKING  -- For class {0}',
    c.Name,
    c.TaggedValue->select(tv | tv.Tag='Eco.PrimaryKey')->first.Value,
    c.TaggedValue->select(tv | tv.Tag='Eco.TableName')->first.Value
  )
)->orderBy(s|s)

This will create a list of rows like this:

ALTER TABLE [CV] ENABLE CHANGE_TRACKING  -- For class CV

Run this SQL on your SQL Server database.

OCL for Invalidating Objects
Class.allInstances->select(s | s.TaggedValue->select(tv | tv.Tag.toUpper='CHANGETRACKING')->notEmpty)->collect(c |
  String.format('selfVM.SuspectExternalUpdateInvalidate({0}.sqlpassthroughobjects( \'SELECT {1} FROM CHANGETABLE (CHANGES {2}, \' + LastHandledVersionNumberFromChangeTracking.toString + \') AS C\') );',
    c.Name,
    c.TaggedValue->select(tv | tv.Tag='Eco.PrimaryKey')->first.Value,
    c.TaggedValue->select(tv | tv.Tag='Eco.TableName')->first.Value
  )
)->orderBy(s|s)

This will create a list of rows like this:

selfVM.SuspectExternalUpdateInvalidate(CV.sqlpassthroughobjects( 'SELECT [CV_ID] FROM CHANGETABLE (CHANGES [CV], ' + LastHandledVersionNumberFromChangeTracking.toString + ') AS C') );

Insert this OCL in the SS_InvalidateExternalChanges action.

Helpful Queries for SQL Server

Here are a couple of helpful queries: Change tracking help SQL

This page was edited 47 days ago on 03/26/2024. What links here