Skip to content

Commit 840677c

Browse files
author
unknown
committed
mb - updated datafresh procedure to ignore the standard delta runner version table
1 parent eeda010 commit 840677c

2 files changed

Lines changed: 14 additions & 1 deletion

File tree

DataFresh/Resources/PrepareDataFresh.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ AS
6262

6363
-- Delete All data from Changed Tables and Refill
6464
DECLARE ChangedTable_Cursor CURSOR FOR
65-
SELECT [tablename] FROM #ChangedTables WHERE tablename <> 'df_ChangeTracking'
65+
SELECT [tablename] FROM #ChangedTables WHERE tablename not in('df_ChangeTracking', 'dr_DeltaVersion')
6666

6767
OPEN ChangedTable_Cursor
6868
FETCH NEXT FROM ChangedTable_Cursor INTO @TableName

Testing.DataFresh/SqlDataFreshTester.cs

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,19 @@ public void RefreshTheDatabaseSpeedTests()
300300
dataFresh.RefreshTheDatabase();
301301
}
302302

303+
[Test]
304+
public void ShouldNotRefreshDeltaRunnerTable()
305+
{
306+
InitializeTheDatabase();
307+
SqlDataFresh dataFresh = new SqlDataFresh(connectionString);
308+
dataFresh.RemoveDataFreshFromDatabase();
309+
dataFresh.PrepareDatabaseforDataFresh(true);
310+
ExecuteNonQuery("insert into [dr_deltaversion] ([latestdelta], [hash], [filename]) values (99, 'blah-hash', 'whatever file');");
311+
Assert.AreEqual(1, ExecuteScalar("select count(*) from [dr_deltaversion] where [filename] = 'whatever file'"));
312+
dataFresh.RefreshTheDatabase();
313+
Assert.AreEqual(1, ExecuteScalar("select count(*) from [dr_deltaversion] where [filename] = 'whatever file'"));
314+
}
315+
303316
private void InitializeTheDatabase()
304317
{
305318
SqlDeltaRunner deltaRunner = new SqlDeltaRunner(connectionString, new DirectoryInfo(deltaPath).FullName, true);

0 commit comments

Comments
 (0)