Skip to content
This repository was archived by the owner on Dec 24, 2022. It is now read-only.

Commit 51c4537

Browse files
mythzmythz
committed
Update OrmLiteUpdateTestsAsync.cs
1 parent 30377c1 commit 51c4537

File tree

1 file changed

+131
-158
lines changed

1 file changed

+131
-158
lines changed

‎tests/ServiceStack.OrmLite.Tests/Async/OrmLiteUpdateTestsAsync.cs‎

Lines changed: 131 additions & 158 deletions
Original file line numberDiff line numberDiff line change
@@ -12,22 +12,23 @@ namespace ServiceStack.OrmLite.Tests.Async
1212
[TestFixtureOrmLite]
1313
public class OrmLiteUpdateTestsAsync : OrmLiteProvidersTestBase
1414
{
15-
public OrmLiteUpdateTestsAsync(DialectContext context) : base(context) {}
15+
public OrmLiteUpdateTestsAsync(DialectContext context) : base(context)
16+
{
17+
OrmLiteUtils.PrintSql();
18+
}
1619

1720
[Test]
1821
public async Task Can_filter_update_method1_to_insert_date()
1922
{
20-
using (var db = OpenDbConnection())
21-
{
22-
await CreateAndInitializeAsync(db, 2);
23-
24-
await ResetUpdateDateAsync(db);
25-
await db.UpdateAsync(
26-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider),
27-
new DefaultValuesUpdate {Id = 1, DefaultInt = 45 }, new DefaultValuesUpdate {Id = 2, DefaultInt = 72 });
28-
await VerifyUpdateDateAsync(db);
29-
await VerifyUpdateDateAsync(db, 2);
30-
}
23+
using var db = await OpenDbConnectionAsync();
24+
await CreateAndInitializeAsync(db, 2);
25+
26+
await ResetUpdateDateAsync(db);
27+
await db.UpdateAsync(
28+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider),
29+
new DefaultValuesUpdate {Id = 1, DefaultInt = 45 }, new DefaultValuesUpdate {Id = 2, DefaultInt = 72 });
30+
await VerifyUpdateDateAsync(db);
31+
await VerifyUpdateDateAsync(db, 2);
3132
}
3233

3334
private async Task<DefaultValuesUpdate> CreateAndInitializeAsync(IDbConnection db, int count = 1)
@@ -73,236 +74,208 @@ private async Task VerifyUpdateDateAsync(IDbConnection db, int id = 1)
7374
[Test]
7475
public async Task Can_filter_update_method2_to_insert_date()
7576
{
76-
using (var db = OpenDbConnection())
77-
{
78-
await CreateAndInitializeAsync(db);
77+
using var db = await OpenDbConnectionAsync();
78+
await CreateAndInitializeAsync(db);
7979

80-
await ResetUpdateDateAsync(db);
81-
await db.UpdateAsync(new DefaultValuesUpdate { Id = 1, DefaultInt = 2342 }, p => p.Id == 1,
82-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
83-
await VerifyUpdateDateAsync(db);
84-
}
80+
await ResetUpdateDateAsync(db);
81+
await db.UpdateAsync(new DefaultValuesUpdate { Id = 1, DefaultInt = 2342 }, p => p.Id == 1,
82+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
83+
await VerifyUpdateDateAsync(db);
8584
}
8685

8786
[Test]
8887
public async Task Can_filter_update_method3_to_insert_date()
8988
{
90-
using (var db = OpenDbConnection())
91-
{
92-
await CreateAndInitializeAsync(db);
93-
94-
await ResetUpdateDateAsync(db);
95-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
96-
row.DefaultInt = 3245;
97-
row.DefaultDouble = 978.423;
98-
await db.UpdateAsync(row, cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
99-
await VerifyUpdateDateAsync(db);
100-
}
89+
using var db = await OpenDbConnectionAsync();
90+
await CreateAndInitializeAsync(db);
91+
92+
await ResetUpdateDateAsync(db);
93+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
94+
row.DefaultInt = 3245;
95+
row.DefaultDouble = 978.423;
96+
await db.UpdateAsync(row, cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
97+
await VerifyUpdateDateAsync(db);
10198
}
10299

103100
[Test]
104101
public async Task Can_filter_update_method4_to_insert_date()
105102
{
106-
using (var db = OpenDbConnection())
107-
{
108-
await CreateAndInitializeAsync(db);
103+
using var db = await OpenDbConnectionAsync();
104+
await CreateAndInitializeAsync(db);
109105

110-
await ResetUpdateDateAsync(db);
111-
await db.UpdateAsync<DefaultValuesUpdate>(new { DefaultInt = 765 }, p => p.Id == 1,
112-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
113-
await VerifyUpdateDateAsync(db);
114-
}
106+
await ResetUpdateDateAsync(db);
107+
await db.UpdateAsync<DefaultValuesUpdate>(new { DefaultInt = 765 }, p => p.Id == 1,
108+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
109+
await VerifyUpdateDateAsync(db);
115110
}
116111

117112
[Test]
118113
public async Task Can_filter_updateAll_to_insert_date()
119114
{
120-
using (var db = OpenDbConnection())
121-
{
122-
await CreateAndInitializeAsync(db, 2);
123-
124-
await ResetUpdateDateAsync(db);
125-
db.UpdateAll(new[] { new DefaultValuesUpdate { Id = 1, DefaultInt = 45 }, new DefaultValuesUpdate { Id = 2, DefaultInt = 72 } },
126-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
127-
await VerifyUpdateDateAsync(db);
128-
await VerifyUpdateDateAsync(db, 2);
129-
}
115+
using var db = await OpenDbConnectionAsync();
116+
await CreateAndInitializeAsync(db, 2);
117+
118+
await ResetUpdateDateAsync(db);
119+
db.UpdateAll(new[] { new DefaultValuesUpdate { Id = 1, DefaultInt = 45 }, new DefaultValuesUpdate { Id = 2, DefaultInt = 72 } },
120+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
121+
await VerifyUpdateDateAsync(db);
122+
await VerifyUpdateDateAsync(db, 2);
130123
}
131124

132125
[Test]
133126
public async Task Can_filter_updateOnly_method1_to_insert_date()
134127
{
135-
using (var db = OpenDbConnection())
136-
{
137-
await CreateAndInitializeAsync(db);
128+
using var db = await OpenDbConnectionAsync();
129+
await CreateAndInitializeAsync(db);
138130

139-
await ResetUpdateDateAsync(db);
140-
db.UpdateOnly(() => new DefaultValuesUpdate { DefaultInt = 345 }, p => p.Id == 1,
141-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
142-
await VerifyUpdateDateAsync(db);
143-
}
131+
await ResetUpdateDateAsync(db);
132+
db.UpdateOnly(() => new DefaultValuesUpdate { DefaultInt = 345 }, p => p.Id == 1,
133+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
134+
await VerifyUpdateDateAsync(db);
144135
}
145136

146137
[Test]
147138
public async Task Can_filter_updateOnly_method2_to_insert_date()
148139
{
149-
using (var db = OpenDbConnection())
150-
{
151-
await CreateAndInitializeAsync(db);
140+
using var db = await OpenDbConnectionAsync();
141+
await CreateAndInitializeAsync(db);
152142

153-
await ResetUpdateDateAsync(db);
154-
await db.UpdateOnlyAsync(() => new DefaultValuesUpdate { DefaultInt = 345 }, db.From<DefaultValuesUpdate>().Where(p => p.Id == 1),
155-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
156-
await VerifyUpdateDateAsync(db);
157-
}
143+
await ResetUpdateDateAsync(db);
144+
await db.UpdateOnlyAsync(() => new DefaultValuesUpdate { DefaultInt = 345 }, db.From<DefaultValuesUpdate>().Where(p => p.Id == 1),
145+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
146+
await VerifyUpdateDateAsync(db);
158147
}
159148

160149
[Test]
161150
public async Task Can_filter_MySql_updateOnly_method2_to_insert_date()
162151
{
163-
using (var db = OpenDbConnection())
164-
{
165-
await CreateAndInitializeAsync(db);
152+
using var db = await OpenDbConnectionAsync();
153+
await CreateAndInitializeAsync(db);
166154

167-
await ResetUpdateDateAsync(db);
168-
await db.UpdateOnlyAsync(() => new DefaultValuesUpdate { DefaultInt = 345 }, db.From<DefaultValuesUpdate>().Where(p => p.Id == 1),
169-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
170-
await VerifyUpdateDateAsync(db);
171-
}
155+
await ResetUpdateDateAsync(db);
156+
await db.UpdateOnlyAsync(() => new DefaultValuesUpdate { DefaultInt = 345 }, db.From<DefaultValuesUpdate>().Where(p => p.Id == 1),
157+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
158+
await VerifyUpdateDateAsync(db);
172159
}
173160

174161
[Test]
175162
public async Task Can_filter_updateOnly_method3_to_insert_date()
176163
{
177-
using (var db = OpenDbConnection())
178-
{
179-
await CreateAndInitializeAsync(db);
180-
181-
await ResetUpdateDateAsync(db);
182-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
183-
row.DefaultDouble = 978.423;
184-
await db.UpdateOnlyAsync(row, db.From<DefaultValuesUpdate>().Update(p => p.DefaultDouble),
185-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
186-
await VerifyUpdateDateAsync(db);
187-
}
164+
using var db = await OpenDbConnectionAsync();
165+
await CreateAndInitializeAsync(db);
166+
167+
await ResetUpdateDateAsync(db);
168+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
169+
row.DefaultDouble = 978.423;
170+
await db.UpdateOnlyAsync(row, db.From<DefaultValuesUpdate>().Update(p => p.DefaultDouble),
171+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
172+
await VerifyUpdateDateAsync(db);
188173
}
189174

190175
[Test]
191176
public async Task Can_filter_updateOnly_method4_to_insert_date()
192177
{
193-
using (var db = OpenDbConnection())
194-
{
195-
await CreateAndInitializeAsync(db);
196-
197-
await ResetUpdateDateAsync(db);
198-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
199-
row.DefaultDouble = 978.423;
200-
await db.UpdateOnlyAsync(row, p => p.DefaultDouble, p => p.Id == 1,
201-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
202-
await VerifyUpdateDateAsync(db);
203-
}
178+
using var db = await OpenDbConnectionAsync();
179+
await CreateAndInitializeAsync(db);
180+
181+
await ResetUpdateDateAsync(db);
182+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
183+
row.DefaultDouble = 978.423;
184+
await db.UpdateOnlyAsync(row, p => p.DefaultDouble, p => p.Id == 1,
185+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
186+
await VerifyUpdateDateAsync(db);
204187
}
205188

206189
[Test]
207190
public async Task Can_filter_updateOnly_method5_to_insert_date()
208191
{
209-
using (var db = OpenDbConnection())
210-
{
211-
await CreateAndInitializeAsync(db);
212-
213-
await ResetUpdateDateAsync(db);
214-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
215-
row.DefaultDouble = 978.423;
216-
await db.UpdateOnlyAsync(row, new[] { nameof(DefaultValuesUpdate.DefaultDouble) }, p => p.Id == 1,
217-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
218-
await VerifyUpdateDateAsync(db);
219-
}
192+
using var db = await OpenDbConnectionAsync();
193+
await CreateAndInitializeAsync(db);
194+
195+
await ResetUpdateDateAsync(db);
196+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
197+
row.DefaultDouble = 978.423;
198+
await db.UpdateOnlyAsync(row, new[] { nameof(DefaultValuesUpdate.DefaultDouble) }, p => p.Id == 1,
199+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
200+
await VerifyUpdateDateAsync(db);
220201
}
221202

222203
[Test]
223204
public async Task Can_filter_updateAdd_expression_to_insert_date()
224205
{
225-
using (var db = OpenDbConnection())
226-
{
227-
await CreateAndInitializeAsync(db);
206+
using var db = await OpenDbConnectionAsync();
207+
await CreateAndInitializeAsync(db);
228208

229-
await ResetUpdateDateAsync(db);
209+
await ResetUpdateDateAsync(db);
230210

231-
var count = await db.UpdateAddAsync(() => new DefaultValuesUpdate { DefaultInt = 5, DefaultDouble = 7.2 }, p => p.Id == 1,
232-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
211+
var count = await db.UpdateAddAsync(() => new DefaultValuesUpdate { DefaultInt = 5, DefaultDouble = 7.2 }, p => p.Id == 1,
212+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
233213

234-
Assert.That(count, Is.EqualTo(1));
235-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
236-
Assert.That(row.DefaultInt, Is.EqualTo(6));
237-
Assert.That(row.DefaultDouble, Is.EqualTo(8.3).Within(0.1));
238-
await VerifyUpdateDateAsync(db);
239-
}
214+
Assert.That(count, Is.EqualTo(1));
215+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
216+
Assert.That(row.DefaultInt, Is.EqualTo(6));
217+
Assert.That(row.DefaultDouble, Is.EqualTo(8.3).Within(0.1));
218+
await VerifyUpdateDateAsync(db);
240219
}
241220

242221
[Test]
243222
public async Task Can_filter_updateAdd_SqlExpression_to_insert_date()
244223
{
245-
using (var db = OpenDbConnection())
246-
{
247-
await CreateAndInitializeAsync(db);
224+
using var db = await OpenDbConnectionAsync();
225+
await CreateAndInitializeAsync(db);
248226

249-
await ResetUpdateDateAsync(db);
227+
await ResetUpdateDateAsync(db);
250228

251-
var where = db.From<DefaultValuesUpdate>().Where(p => p.Id == 1);
252-
var count = await db.UpdateAddAsync(() => new DefaultValuesUpdate { DefaultInt = 5, DefaultDouble = 7.2 }, where,
253-
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
229+
var where = db.From<DefaultValuesUpdate>().Where(p => p.Id == 1);
230+
var count = await db.UpdateAddAsync(() => new DefaultValuesUpdate { DefaultInt = 5, DefaultDouble = 7.2 }, @where,
231+
cmd => cmd.SetUpdateDate<DefaultValuesUpdate>(nameof(DefaultValuesUpdate.UpdatedDateUtc), DialectProvider));
254232

255-
Assert.That(count, Is.EqualTo(1));
256-
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
257-
Assert.That(row.DefaultInt, Is.EqualTo(6));
258-
Assert.That(row.DefaultDouble, Is.EqualTo(8.3).Within(0.1));
259-
await VerifyUpdateDateAsync(db);
260-
}
233+
Assert.That(count, Is.EqualTo(1));
234+
var row = await db.SingleByIdAsync<DefaultValuesUpdate>(1);
235+
Assert.That(row.DefaultInt, Is.EqualTo(6));
236+
Assert.That(row.DefaultDouble, Is.EqualTo(8.3).Within(0.1));
237+
await VerifyUpdateDateAsync(db);
261238
}
262239

263240
[Test]
264241
public async Task Can_updated_with_ExecuteSql_and_db_params_Async()
265242
{
266-
using (var db = OpenDbConnection())
267-
{
268-
db.DropAndCreateTable<PocoUpdateAsync>();
243+
using var db = await OpenDbConnectionAsync();
244+
db.DropAndCreateTable<PocoUpdateAsync>();
269245

270-
db.Insert(new PocoUpdateAsync { Id = 1, Name = "A" });
271-
db.Insert(new PocoUpdateAsync { Id = 2, Name = "B" });
246+
db.Insert(new PocoUpdateAsync { Id = 1, Name = "A" });
247+
db.Insert(new PocoUpdateAsync { Id = 2, Name = "B" });
272248

273-
var result = await db.ExecuteSqlAsync($"UPDATE {DialectProvider.GetQuotedTableName("PocoUpdateAsync")} SET name = @name WHERE id = @id", new { id = 2, name = "UPDATED" });
274-
Assert.That(result, Is.EqualTo(1));
249+
var result = await db.ExecuteSqlAsync($"UPDATE {DialectProvider.GetQuotedTableName("PocoUpdateAsync")} SET name = @name WHERE id = @id", new { id = 2, name = "UPDATED" });
250+
Assert.That(result, Is.EqualTo(1));
275251

276-
var row = await db.SingleByIdAsync<PocoUpdateAsync>(2);
277-
Assert.That(row.Name, Is.EqualTo("UPDATED"));
278-
}
252+
var row = await db.SingleByIdAsync<PocoUpdateAsync>(2);
253+
Assert.That(row.Name, Is.EqualTo("UPDATED"));
279254
}
280255

281256
[Test]
282257
public async Task Does_UpdateAdd_using_AssignmentExpression_async()
283258
{
284-
using (var db = OpenDbConnection())
285-
{
286-
db.DropAndCreateTable<Person>();
287-
await db.InsertAllAsync(Person.Rockstars);
259+
using var db = await OpenDbConnectionAsync();
260+
db.DropAndCreateTable<Person>();
261+
await db.InsertAllAsync(Person.Rockstars);
288262

289-
var count = await db.UpdateAddAsync(() => new Person { FirstName = "JJ", Age = 1 }, where: p => p.LastName == "Hendrix");
290-
Assert.That(count, Is.EqualTo(1));
263+
var count = await db.UpdateAddAsync(() => new Person { FirstName = "JJ", Age = 1 }, @where: p => p.LastName == "Hendrix");
264+
Assert.That(count, Is.EqualTo(1));
291265

292-
var hendrix = Person.Rockstars.First(x => x.LastName == "Hendrix");
293-
var kurt = Person.Rockstars.First(x => x.LastName == "Cobain");
266+
var hendrix = Person.Rockstars.First(x => x.LastName == "Hendrix");
267+
var kurt = Person.Rockstars.First(x => x.LastName == "Cobain");
294268

295-
var row = await db.SingleAsync<Person>(p => p.LastName == "Hendrix");
296-
Assert.That(row.FirstName, Is.EqualTo("JJ"));
297-
Assert.That(row.Age, Is.EqualTo(hendrix.Age + 1));
269+
var row = await db.SingleAsync<Person>(p => p.LastName == "Hendrix");
270+
Assert.That(row.FirstName, Is.EqualTo("JJ"));
271+
Assert.That(row.Age, Is.EqualTo(hendrix.Age + 1));
298272

299-
count = await db.UpdateAddAsync(() => new Person { FirstName = "KC", Age = hendrix.Age + 1 }, where: p => p.LastName == "Cobain");
300-
Assert.That(count, Is.EqualTo(1));
273+
count = await db.UpdateAddAsync(() => new Person { FirstName = "KC", Age = hendrix.Age + 1 }, @where: p => p.LastName == "Cobain");
274+
Assert.That(count, Is.EqualTo(1));
301275

302-
row = await db.SingleAsync<Person>(p => p.LastName == "Cobain");
303-
Assert.That(row.FirstName, Is.EqualTo("KC"));
304-
Assert.That(row.Age, Is.EqualTo(kurt.Age + hendrix.Age + 1));
305-
}
276+
row = await db.SingleAsync<Person>(p => p.LastName == "Cobain");
277+
Assert.That(row.FirstName, Is.EqualTo("KC"));
278+
Assert.That(row.Age, Is.EqualTo(kurt.Age + hendrix.Age + 1));
306279
}
307280

308281
public class PocoUpdateAsync

0 commit comments

Comments
 (0)