2
2
using CoreEx . Json ;
3
3
using NTangle . Test ;
4
4
using NUnit . Framework ;
5
+ using NUnit . Framework . Legacy ;
5
6
using SqlServerDemo . Publisher . Data ;
6
7
using System ;
7
8
using System . Threading . Tasks ;
@@ -58,20 +59,20 @@ public async Task LogicalDelete()
58
59
UnitTest . WriteResult ( cdcr , imp ) ;
59
60
60
61
// Assert/verify the results.
61
- Assert . NotNull ( cdcr ) ;
62
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
63
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
64
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
65
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
66
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
67
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
68
- Assert . IsNull ( cdcr . Exception ) ;
69
- Assert . AreEqual ( 2 , cdcr . ExecuteStatus ? . InitialCount ) ;
70
- Assert . AreEqual ( 2 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
71
- Assert . AreEqual ( 2 , cdcr . ExecuteStatus ? . PublishCount ) ;
62
+ ClassicAssert . NotNull ( cdcr ) ;
63
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
64
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
65
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
66
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
67
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
68
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
69
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
70
+ ClassicAssert . AreEqual ( 2 , cdcr . ExecuteStatus ? . InitialCount ) ;
71
+ ClassicAssert . AreEqual ( 2 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
72
+ ClassicAssert . AreEqual ( 2 , cdcr . ExecuteStatus ? . PublishCount ) ;
72
73
73
74
var events = imp . GetEvents ( ) ;
74
- Assert . AreEqual ( 2 , events . Length ) ;
75
+ ClassicAssert . AreEqual ( 2 , events . Length ) ;
75
76
76
77
UnitTest . AssertEvent ( "CustomerTest-LogicalDelete-1.txt" , events [ 0 ] ) ;
77
78
UnitTest . AssertEvent ( "CustomerTest-LogicalDelete-2.txt" , events [ 1 ] , "value.rowVersion" ) ;
@@ -96,20 +97,20 @@ public async Task ExcludeRowVersionFromETag()
96
97
UnitTest . WriteResult ( cdcr , imp ) ;
97
98
98
99
// Assert/verify the results.
99
- Assert . NotNull ( cdcr ) ;
100
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
101
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
102
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
103
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
104
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
105
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
106
- Assert . IsNull ( cdcr . Exception ) ;
107
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
108
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
109
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . PublishCount ) ;
100
+ ClassicAssert . NotNull ( cdcr ) ;
101
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
102
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
103
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
104
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
105
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
106
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
107
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
108
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
109
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
110
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . PublishCount ) ;
110
111
111
112
var events = imp . GetEvents ( ) ;
112
- Assert . AreEqual ( 1 , events . Length ) ;
113
+ ClassicAssert . AreEqual ( 1 , events . Length ) ;
113
114
114
115
// Update excluded property; should not pick up even though RowVersion column would have been updated as version (ETag) excludes.
115
116
script = "UPDATE [Legacy].[Cust] SET [internal-secret] = 'shhh' WHERE [CustId] = 1" ;
@@ -123,18 +124,18 @@ public async Task ExcludeRowVersionFromETag()
123
124
UnitTest . WriteResult ( cdcr , imp ) ;
124
125
125
126
// Assert/verify the results.
126
- Assert . NotNull ( cdcr ) ;
127
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
128
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
129
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
130
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
131
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
132
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
133
- Assert . IsNull ( cdcr . Exception ) ;
134
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
135
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
136
- Assert . AreEqual ( 0 , cdcr . ExecuteStatus ? . PublishCount ) ;
137
- Assert . AreEqual ( 0 , imp . GetEvents ( ) . Length ) ;
127
+ ClassicAssert . NotNull ( cdcr ) ;
128
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
129
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
130
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
131
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
132
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
133
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
134
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
135
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
136
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
137
+ ClassicAssert . AreEqual ( 0 , cdcr . ExecuteStatus ? . PublishCount ) ;
138
+ ClassicAssert . AreEqual ( 0 , imp . GetEvents ( ) . Length ) ;
138
139
}
139
140
140
141
[ Test ]
@@ -162,56 +163,56 @@ public async Task MaxQuerySize()
162
163
UnitTest . WriteResult ( cdcr , imp ) ;
163
164
164
165
// Assert/verify the results.
165
- Assert . NotNull ( cdcr ) ;
166
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
167
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
168
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
169
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
170
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
171
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
172
- Assert . IsNull ( cdcr . Exception ) ;
173
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . InitialCount ) ;
174
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
175
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . PublishCount ) ;
176
- Assert . AreEqual ( 3 , imp . GetEvents ( ) . Length ) ;
166
+ ClassicAssert . NotNull ( cdcr ) ;
167
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
168
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
169
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
170
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
171
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
172
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
173
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
174
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . InitialCount ) ;
175
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
176
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . PublishCount ) ;
177
+ ClassicAssert . AreEqual ( 3 , imp . GetEvents ( ) . Length ) ;
177
178
178
179
// Next Execute should pick up the next 3.
179
180
imp . Reset ( ) ;
180
181
cdcr = await cdc . ExecuteAsync ( ) . ConfigureAwait ( false ) ;
181
182
UnitTest . WriteResult ( cdcr , imp ) ;
182
183
183
184
// Assert/verify the results.
184
- Assert . NotNull ( cdcr ) ;
185
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
186
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
187
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
188
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
189
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
190
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
191
- Assert . IsNull ( cdcr . Exception ) ;
192
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . InitialCount ) ;
193
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
194
- Assert . AreEqual ( 3 , cdcr . ExecuteStatus ? . PublishCount ) ;
195
- Assert . AreEqual ( 3 , imp . GetEvents ( ) . Length ) ;
185
+ ClassicAssert . NotNull ( cdcr ) ;
186
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
187
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
188
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
189
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
190
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
191
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
192
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
193
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . InitialCount ) ;
194
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
195
+ ClassicAssert . AreEqual ( 3 , cdcr . ExecuteStatus ? . PublishCount ) ;
196
+ ClassicAssert . AreEqual ( 3 , imp . GetEvents ( ) . Length ) ;
196
197
197
198
// Next Execute should pick up the last 1.
198
199
imp . Reset ( ) ;
199
200
cdcr = await cdc . ExecuteAsync ( ) . ConfigureAwait ( false ) ;
200
201
UnitTest . WriteResult ( cdcr , imp ) ;
201
202
202
203
// Assert/verify the results.
203
- Assert . NotNull ( cdcr ) ;
204
- Assert . IsTrue ( cdcr . IsSuccessful ) ;
205
- Assert . IsNotNull ( cdcr . BatchTracker ) ;
206
- Assert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
207
- Assert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
208
- Assert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
209
- Assert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
210
- Assert . IsNull ( cdcr . Exception ) ;
211
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
212
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
213
- Assert . AreEqual ( 1 , cdcr . ExecuteStatus ? . PublishCount ) ;
214
- Assert . AreEqual ( 1 , imp . GetEvents ( ) . Length ) ;
204
+ ClassicAssert . NotNull ( cdcr ) ;
205
+ ClassicAssert . IsTrue ( cdcr . IsSuccessful ) ;
206
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker ) ;
207
+ ClassicAssert . IsTrue ( cdcr . BatchTracker . IsComplete ) ;
208
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CompletedDate ) ;
209
+ ClassicAssert . IsNotNull ( cdcr . BatchTracker . CorrelationId ) ;
210
+ ClassicAssert . IsFalse ( cdcr . BatchTracker . HasDataLoss ) ;
211
+ ClassicAssert . IsNull ( cdcr . Exception ) ;
212
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . InitialCount ) ;
213
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . ConsolidatedCount ) ;
214
+ ClassicAssert . AreEqual ( 1 , cdcr . ExecuteStatus ? . PublishCount ) ;
215
+ ClassicAssert . AreEqual ( 1 , imp . GetEvents ( ) . Length ) ;
215
216
}
216
217
}
217
218
}
0 commit comments