Tests.cs 41.6 KB
Newer Older
S
Sam Saffron 已提交
1 2 3
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
M
mgravell 已提交
4
using System.Linq;
5
using Dapper;
6 7
using System.Data.SqlServerCe;
using System.IO;
S
Sam Saffron 已提交
8 9
using System.Data;
using System.Collections;
S
Sam Saffron 已提交
10
using System.Reflection;
S
Sam Saffron 已提交
11 12 13 14

namespace SqlMapper
{

S
Sam Saffron 已提交
15 16
    class Tests
    {
S
Sam Saffron 已提交
17 18
        SqlConnection connection = Program.GetOpenConnection();

S
Sam Saffron 已提交
19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36

        public void TestNullableGuidSupport()
        {
            var guid = connection.Query<Guid?>("select null").First();
            guid.IsNull();

            guid = Guid.NewGuid();
            var guid2 = connection.Query<Guid?>("select @guid", new { guid }).First();
            guid.IsEqualTo(guid2);
        }

        public void TestNonNullableGuidSupport()
        {
            var guid = Guid.NewGuid();
            var guid2 = connection.Query<Guid?>("select @guid", new { guid }).First();
            Assert.IsTrue(guid == guid2);
        }

S
Sam Saffron 已提交
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58
        struct Car
        {
            public enum TrapEnum : int
            {
                A = 1,
                B = 2
            }
            public string Name;
            public int Age { get; set; }
            public TrapEnum Trap { get; set; }
        
        }

        public void TestStructs()
        {
            var car = connection.Query<Car>("select 'Ford' Name, 21 Age, 2 Trap").First();

            car.Age.IsEqualTo(21);
            car.Name.IsEqualTo("Ford");
            ((int)car.Trap).IsEqualTo(2);
        }

S
Sam Saffron 已提交
59 60
        public void SelectListInt()
        {
61
            connection.Query<int>("select 1 union all select 2 union all select 3")
62
              .IsSequenceEqualTo(new[] { 1, 2, 3 });
S
Sam Saffron 已提交
63
        }
M
mgravell 已提交
64 65
        public void SelectBinary()
        {
M
marc.gravell@gmail.com 已提交
66
            connection.Query<byte[]>("select cast(1 as varbinary(4))").First().SequenceEqual(new byte[] { 1 });
M
mgravell 已提交
67
        }
S
Sam Saffron 已提交
68 69
        public void PassInIntArray()
        {
70
            connection.Query<int>("select * from (select 1 as Id union all select 2 union all select 3) as X where Id in @Ids", new { Ids = new int[] { 1, 2, 3 }.AsEnumerable() })
71
             .IsSequenceEqualTo(new[] { 1, 2, 3 });
S
Sam Saffron 已提交
72
        }
S
Sam Saffron 已提交
73

74 75 76 77 78 79
        public void PassInEmptyIntArray()
        {
            connection.Query<int>("select * from (select 1 as Id union all select 2 union all select 3) as X where Id in @Ids", new { Ids = new int[0] })
             .IsSequenceEqualTo(new int[0]);
        }

S
Sam Saffron 已提交
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95
        public void TestSchemaChanged()
        {
            connection.Execute("create table #dog(Age int, Name nvarchar(max)) insert #dog values(1, 'Alf')");
            var d = connection.Query<Dog>("select * from #dog").Single();
            d.Name.IsEqualTo("Alf");
            d.Age.IsEqualTo(1);
            connection.Execute("alter table #dog drop column Name");
            d = connection.Query<Dog>("select * from #dog").Single();
            d.Name.IsNull();
            d.Age.IsEqualTo(1);
            connection.Execute("drop table #dog");
        }

        public void TestSchemaChangedMultiMap()
        {
            connection.Execute("create table #dog(Age int, Name nvarchar(max)) insert #dog values(1, 'Alf')");
M
marc.gravell@gmail.com 已提交
96
            var tuple = connection.Query<Dog, Dog, Tuple<Dog, Dog>>("select * from #dog d1 join #dog d2 on 1=1", (d1, d2) => Tuple.Create(d1, d2), splitOn: "Age").Single();
S
Sam Saffron 已提交
97 98 99 100 101 102 103

            tuple.Item1.Name.IsEqualTo("Alf");
            tuple.Item1.Age.IsEqualTo(1);
            tuple.Item2.Name.IsEqualTo("Alf");
            tuple.Item2.Age.IsEqualTo(1);

            connection.Execute("alter table #dog drop column Name");
M
marc.gravell@gmail.com 已提交
104
            tuple = connection.Query<Dog, Dog, Tuple<Dog, Dog>>("select * from #dog d1 join #dog d2 on 1=1", (d1, d2) => Tuple.Create(d1, d2), splitOn: "Age").Single();
S
Sam Saffron 已提交
105 106 107 108 109

            tuple.Item1.Name.IsNull();
            tuple.Item1.Age.IsEqualTo(1);
            tuple.Item2.Name.IsNull();
            tuple.Item2.Age.IsEqualTo(1);
M
marc.gravell@gmail.com 已提交
110

S
Sam Saffron 已提交
111 112 113
            connection.Execute("drop table #dog");
        }

114 115
        public void TestReadMultipleIntegersWithSplitOnAny()
        {
116
            connection.Query<int, int, int, Tuple<int, int, int>>(
117
                "select 1,2,3 union all select 4,5,6", Tuple.Create, splitOn: "*")
118
             .IsSequenceEqualTo(new[] { Tuple.Create(1, 2, 3), Tuple.Create(4, 5, 6) });
119
        }
S
Sam Saffron 已提交
120 121 122

        public void TestDoubleParam()
        {
123
            connection.Query<double>("select @d", new { d = 0.1d }).First()
124
                .IsEqualTo(0.1d);
S
Sam Saffron 已提交
125 126 127 128
        }

        public void TestBoolParam()
        {
129
            connection.Query<bool>("select @b", new { b = false }).First()
S
Sam Saffron 已提交
130
                .IsFalse();
S
Sam Saffron 已提交
131 132 133 134
        }

        public void TestStrings()
        {
135
            connection.Query<string>(@"select 'a' a union select 'b'")
136
                .IsSequenceEqualTo(new[] { "a", "b" });
S
Sam Saffron 已提交
137 138
        }

139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159
        enum EnumParam : short
        {
            None, A, B
        }
        class EnumParamObject
        {
            public EnumParam A { get; set; }
            public EnumParam? B { get; set; }
            public EnumParam? C { get; set; }
        }
        public void TestEnumParams()
        {
            EnumParam a = EnumParam.A;
            EnumParam? b = EnumParam.B, c = null;
            var obj = connection.Query<EnumParamObject>("select @a as A, @b as B, @c as C",
                new { a, b, c }).Single();
            obj.A.IsEqualTo(EnumParam.A);
            obj.B.IsEqualTo(EnumParam.B);
            obj.C.IsEqualTo(null);
        }

S
Sam Saffron 已提交
160 161 162 163 164 165 166 167 168 169
        public class Dog
        {
            public int? Age { get; set; }
            public Guid Id { get; set; }
            public string Name { get; set; }
            public float? Weight { get; set; }

            public int IgnoredProperty { get { return 1; } }
        }

170 171 172
        public void TestExtraFields()
        {
            var guid = Guid.NewGuid();
173
            var dog = connection.Query<Dog>("select '' as Extra, 1 as Age, 0.1 as Name1 , Id = @id", new { Id = guid });
174 175 176 177 178 179 180 181 182 183 184 185

            dog.Count()
               .IsEqualTo(1);

            dog.First().Age
                .IsEqualTo(1);

            dog.First().Id
                .IsEqualTo(guid);
        }


186
        public void TestStrongType()
S
Sam Saffron 已提交
187
        {
188
            var guid = Guid.NewGuid();
189
            var dog = connection.Query<Dog>("select Age = @Age, Id = @Id", new { Age = (int?)null, Id = guid });
190

S
Sam Saffron 已提交
191
            dog.Count()
192
                .IsEqualTo(1);
S
Sam Saffron 已提交
193 194 195

            dog.First().Age
                .IsNull();
196 197

            dog.First().Id
198
                .IsEqualTo(guid);
S
Sam Saffron 已提交
199 200
        }

S
Sam Saffron 已提交
201 202
        public void TestSimpleNull()
        {
203
            connection.Query<DateTime?>("select null").First().IsNull();
S
Sam Saffron 已提交
204
        }
205

S
Sam Saffron 已提交
206 207
        public void TestExpando()
        {
208
            var rows = connection.Query("select 1 A, 2 B union all select 3, 4").ToList();
209

S
Sam Saffron 已提交
210
            ((int)rows[0].A)
211
                .IsEqualTo(1);
S
Sam Saffron 已提交
212 213

            ((int)rows[0].B)
214
                .IsEqualTo(2);
S
Sam Saffron 已提交
215 216

            ((int)rows[1].A)
217
                .IsEqualTo(3);
S
Sam Saffron 已提交
218 219

            ((int)rows[1].B)
220
                .IsEqualTo(4);
S
Sam Saffron 已提交
221
        }
S
Sam Saffron 已提交
222 223

        public void TestStringList()
S
Sam Saffron 已提交
224
        {
225 226
            connection.Query<string>("select * from (select 'a' as x union all select 'b' union all select 'c') as T where x in @strings", new { strings = new[] { "a", "b", "c" } })
                .IsSequenceEqualTo(new[] { "a", "b", "c" });
S
Sam Saffron 已提交
227

228 229
            connection.Query<string>("select * from (select 'a' as x union all select 'b' union all select 'c') as T where x in @strings", new { strings = new string[0] })
                   .IsSequenceEqualTo(new string[0]);
S
Sam Saffron 已提交
230 231
        }

S
Sam Saffron 已提交
232 233
        public void TestExecuteCommand()
        {
234
            connection.Execute(@"
S
Sam Saffron 已提交
235 236 237 238 239 240
    set nocount on 
    create table #t(i int) 
    set nocount off 
    insert #t 
    select @a a union all select @b 
    set nocount on 
241
    drop table #t", new { a = 1, b = 2 }).IsEqualTo(2);
S
Sam Saffron 已提交
242
        }
243 244 245
        public void TestExecuteCommandWithHybridParameters()
        {
            var p = new DynamicParameters(new { a = 1, b = 2 });
246
            p.Add("c", dbType: DbType.Int32, direction: ParameterDirection.Output);
247 248 249
            connection.Execute(@"set @c = @a + @b", p);
            p.Get<int>("@c").IsEqualTo(3);
        }
250 251 252 253 254 255 256 257
        public void TestExecuteMultipleCommand()
        {
            connection.Execute("create table #t(i int)");
            int tally = connection.Execute(@"insert #t (i) values(@a)", new[] { new { a = 1 }, new { a = 2 }, new { a = 3 }, new { a = 4 } });
            int sum = connection.Query<int>("select sum(i) from #t drop table #t").First();
            tally.IsEqualTo(4);
            sum.IsEqualTo(10);
        }
S
Sam Saffron 已提交
258

259 260
        class Student
        {
M
marc.gravell@gmail.com 已提交
261
            public string Name { get; set; }
262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277
            public int Age { get; set; }
        }

        public void TestExecuteMultipleCommandStrongType()
        {
            connection.Execute("create table #t(Name nvarchar(max), Age int)");
            int tally = connection.Execute(@"insert #t (Name,Age) values(@Name, @Age)", new List<Student> 
            {
                new Student{Age = 1, Name = "sam"},
                new Student{Age = 2, Name = "bob"}
            });
            int sum = connection.Query<int>("select sum(Age) from #t drop table #t").First();
            tally.IsEqualTo(2);
            sum.IsEqualTo(3);
        }

278 279 280 281 282 283 284 285 286
        public void TestExecuteMultipleCommandObjectArray()
        {
            connection.Execute("create table #t(i int)");
            int tally = connection.Execute(@"insert #t (i) values(@a)", new object[] { new { a = 1 }, new { a = 2 }, new { a = 3 }, new { a = 4 } });
            int sum = connection.Query<int>("select sum(i) from #t drop table #t").First();
            tally.IsEqualTo(4);
            sum.IsEqualTo(10);
        }

S
Sam Saffron 已提交
287
        public void TestMassiveStrings()
288
        {
S
Sam Saffron 已提交
289
            var str = new string('X', 20000);
290
            connection.Query<string>("select @a", new { a = str }).First()
291
                .IsEqualTo(str);
S
Sam Saffron 已提交
292 293
        }

294 295 296 297 298 299 300 301 302 303 304
        class TestObj
        {
            public int _internal;
            internal int Internal { set { _internal = value; } }

            public int _priv;
            internal int Priv { set { _priv = value; } }
        }

        public void TestSetInternal()
        {
305
            connection.Query<TestObj>("select 10 as [Internal]").First()._internal.IsEqualTo(10);
306 307 308 309
        }

        public void TestSetPrivate()
        {
310
            connection.Query<TestObj>("select 10 as [Priv]").First()._priv.IsEqualTo(10);
311 312
        }

313 314
        public void TestEnumeration()
        {
S
Sam Saffron 已提交
315 316 317 318
            var en = connection.Query<int>("select 1 as one union all select 2 as one", buffered: false);
            var i = en.GetEnumerator();
            i.MoveNext();

319 320 321
            bool gotException = false;
            try
            {
S
Sam Saffron 已提交
322
                var x = connection.Query<int>("select 1 as one", buffered: false).First();
323 324 325 326 327 328
            }
            catch (Exception)
            {
                gotException = true;
            }

S
Sam Saffron 已提交
329 330
            while (i.MoveNext())
            { }
331 332

            // should not exception, since enumertated
333
            en = connection.Query<int>("select 1 as one", buffered: false);
334 335 336 337 338 339

            gotException.IsTrue();
        }

        public void TestEnumerationDynamic()
        {
S
Sam Saffron 已提交
340 341 342 343
            var en = connection.Query("select 1 as one union all select 2 as one", buffered: false);
            var i = en.GetEnumerator();
            i.MoveNext();

344 345 346
            bool gotException = false;
            try
            {
S
Sam Saffron 已提交
347
                var x = connection.Query("select 1 as one", buffered: false).First();
348 349 350 351 352 353
            }
            catch (Exception)
            {
                gotException = true;
            }

S
Sam Saffron 已提交
354 355
            while (i.MoveNext())
            { }
356 357

            // should not exception, since enumertated
S
Sam Saffron 已提交
358
            en = connection.Query("select 1 as one", buffered: false);
359 360 361

            gotException.IsTrue();
        }
362

M
mgravell 已提交
363 364 365
        public void TestNakedBigInt()
        {
            long foo = 12345;
M
marc.gravell@gmail.com 已提交
366
            var result = connection.Query<long>("select @foo", new { foo }).Single();
M
mgravell 已提交
367 368 369 370 371 372 373 374 375
            foo.IsEqualTo(result);
        }

        public void TestBigIntMember()
        {
            long foo = 12345;
            var result = connection.Query<WithBigInt>(@"
declare @bar table(Value bigint)
insert @bar values (@foo)
M
marc.gravell@gmail.com 已提交
376
select * from @bar", new { foo }).Single();
M
mgravell 已提交
377 378 379 380 381 382
            result.Value.IsEqualTo(foo);
        }
        class WithBigInt
        {
            public long Value { get; set; }
        }
S
Sam Saffron 已提交
383

384
        class User
S
Sam Saffron 已提交
385 386 387 388
        {
            public int Id { get; set; }
            public string Name { get; set; }
        }
389
        class Post
S
Sam Saffron 已提交
390 391 392 393
        {
            public int Id { get; set; }
            public User Owner { get; set; }
            public string Content { get; set; }
394
            public Comment Comment { get; set; }
S
Sam Saffron 已提交
395 396 397
        }
        public void TestMultiMap()
        {
S
Sam Saffron 已提交
398 399 400
            var createSql = @"
                create table #Users (Id int, Name varchar(20))
                create table #Posts (Id int, OwnerId int, Content varchar(20))
S
Sam Saffron 已提交
401

S
style  
Sam Saffron 已提交
402
                insert #Users values(99, 'Sam')
S
Sam Saffron 已提交
403 404
                insert #Users values(2, 'I am')

S
style  
Sam Saffron 已提交
405 406
                insert #Posts values(1, 99, 'Sams Post1')
                insert #Posts values(2, 99, 'Sams Post2')
S
Sam Saffron 已提交
407 408 409 410
                insert #Posts values(3, null, 'no ones post')
";
            connection.Execute(createSql);

411
            var sql =
S
style  
Sam Saffron 已提交
412 413 414 415
@"select * from #Posts p 
left join #Users u on u.Id = p.OwnerId 
Order by p.Id";

416
            var data = connection.Query<Post, User, Post>(sql, (post, user) => { post.Owner = user; return post; }).ToList();
S
style  
Sam Saffron 已提交
417
            var p = data.First();
418

S
style  
Sam Saffron 已提交
419 420 421 422
            p.Content.IsEqualTo("Sams Post1");
            p.Id.IsEqualTo(1);
            p.Owner.Name.IsEqualTo("Sam");
            p.Owner.Id.IsEqualTo(99);
423 424 425 426 427 428 429

            data[2].Owner.IsNull();

            connection.Execute("drop table #Users drop table #Posts");
        }


430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469

        public void TestMultiMapGridReader()
        {
            var createSql = @"
                create table #Users (Id int, Name varchar(20))
                create table #Posts (Id int, OwnerId int, Content varchar(20))

                insert #Users values(99, 'Sam')
                insert #Users values(2, 'I am')

                insert #Posts values(1, 99, 'Sams Post1')
                insert #Posts values(2, 99, 'Sams Post2')
                insert #Posts values(3, null, 'no ones post')
";
            connection.Execute(createSql);

            var sql =
@"select p.*, u.Id, u.Name + '0' Name from #Posts p 
left join #Users u on u.Id = p.OwnerId 
Order by p.Id

select p.*, u.Id, u.Name + '1' Name from #Posts p 
left join #Users u on u.Id = p.OwnerId 
Order by p.Id
";

            var grid = connection.QueryMultiple(sql);

            for (int i = 0; i < 2; i++)
            {
                var data = grid.Read<Post, User, Post>((post, user) => { post.Owner = user; return post; }).ToList();
                var p = data.First();

                p.Content.IsEqualTo("Sams Post1");
                p.Id.IsEqualTo(1);
                p.Owner.Name.IsEqualTo("Sam" + i);
                p.Owner.Id.IsEqualTo(99);

                data[2].Owner.IsNull();
            }
M
marc.gravell@gmail.com 已提交
470

471 472 473 474
            connection.Execute("drop table #Users drop table #Posts");

        }

475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494
        public void TestMultiMapDynamic()
        {
            var createSql = @"
                create table #Users (Id int, Name varchar(20))
                create table #Posts (Id int, OwnerId int, Content varchar(20))

                insert #Users values(99, 'Sam')
                insert #Users values(2, 'I am')

                insert #Posts values(1, 99, 'Sams Post1')
                insert #Posts values(2, 99, 'Sams Post2')
                insert #Posts values(3, null, 'no ones post')
";
            connection.Execute(createSql);

            var sql =
@"select * from #Posts p 
left join #Users u on u.Id = p.OwnerId 
Order by p.Id";

495
            var data = connection.Query<dynamic, dynamic, dynamic>(sql, (post, user) => { post.Owner = user; return post; }).ToList();
496 497 498 499 500 501 502 503 504 505 506
            var p = data.First();

            // hairy extension method support for dynamics
            ((string)p.Content).IsEqualTo("Sams Post1");
            ((int)p.Id).IsEqualTo(1);
            ((string)p.Owner.Name).IsEqualTo("Sam");
            ((int)p.Owner.Id).IsEqualTo(99);

            ((object)data[2].Owner).IsNull();

            connection.Execute("drop table #Users drop table #Posts");
S
Sam Saffron 已提交
507
        }
508

M
mgravell 已提交
509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533
        class Product
        {
            public int Id { get; set; }
            public string Name { get; set; }
            public Category Category { get; set; }
        }
        class Category
        {
            public int Id { get; set; }
            public string Name { get; set; }
        }
        public void TestMultiMapWithSplit() // http://stackoverflow.com/q/6056778/23354
        {
            var sql = @"select 1 as id, 'abc' as name, 2 as id, 'def' as name";
            var product = connection.Query<Product, Category, Product>(sql, (prod, cat) =>
            {
                prod.Category = cat;
                return prod;
            }).First();
            // assertions
            product.Id.IsEqualTo(1);
            product.Name.IsEqualTo("abc");
            product.Category.Id.IsEqualTo(2);
            product.Category.Name.IsEqualTo("def");
        }
M
mgravell 已提交
534 535 536 537 538
        public void TestFieldsAndPrivates()
        {
            var data = connection.Query<TestFieldCaseAndPrivatesEntity>(
                @"select a=1,b=2,c=3,d=4,f='5'").Single();

539

M
mgravell 已提交
540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563
            data.a.IsEqualTo(1);
            data.GetB().IsEqualTo(2);
            data.c.IsEqualTo(3);
            data.GetD().IsEqualTo(4);
            data.e.IsEqualTo(5);


        }

        private class TestFieldCaseAndPrivatesEntity
        {
            public int a { get; set; }
            private int b { get; set; }
            public int GetB() { return b; }
            public int c = 0;
            private int d = 0;
            public int GetD() { return d; }
            public int e { get; set; }
            private string f
            {
                get { return e.ToString(); }
                set { e = int.Parse(value); }
            }
        }
M
mgravell 已提交
564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579

        public void TestMultiReaderBasic()
        {
            var sql = @"select 1 as Id union all select 2 as Id     select 'abc' as name   select 1 as Id union all select 2 as Id";
            int i, j;
            string s;
            using (var multi = connection.QueryMultiple(sql))
            {
                i = multi.Read<int>().First();
                s = multi.Read<string>().Single();
                j = multi.Read<int>().Sum();
            }
            Assert.IsEqualTo(i, 1);
            Assert.IsEqualTo(s, "abc");
            Assert.IsEqualTo(j, 3);
        }
S
Sam Saffron 已提交
580 581
        public void TestMultiMappingVariations()
        {
S
Sam Saffron 已提交
582
            var sql = @"select 1 as Id, 'a' as Content, 2 as Id, 'b' as Content, 3 as Id, 'c' as Content, 4 as Id, 'd' as Content, 5 as Id, 'e' as Content";
583 584

            var order = connection.Query<dynamic, dynamic, dynamic, dynamic>(sql, (o, owner, creator) => { o.Owner = owner; o.Creator = creator; return o; }).First();
S
Sam Saffron 已提交
585 586 587 588 589 590 591 592

            Assert.IsEqualTo(order.Id, 1);
            Assert.IsEqualTo(order.Content, "a");
            Assert.IsEqualTo(order.Owner.Id, 2);
            Assert.IsEqualTo(order.Owner.Content, "b");
            Assert.IsEqualTo(order.Creator.Id, 3);
            Assert.IsEqualTo(order.Creator.Content, "c");

593 594 595 596 597 598 599
            order = connection.Query<dynamic, dynamic, dynamic, dynamic, dynamic>(sql, (o, owner, creator, address) =>
            {
                o.Owner = owner;
                o.Creator = creator;
                o.Owner.Address = address;
                return o;
            }).First();
S
Sam Saffron 已提交
600 601 602 603 604 605 606 607 608 609

            Assert.IsEqualTo(order.Id, 1);
            Assert.IsEqualTo(order.Content, "a");
            Assert.IsEqualTo(order.Owner.Id, 2);
            Assert.IsEqualTo(order.Owner.Content, "b");
            Assert.IsEqualTo(order.Creator.Id, 3);
            Assert.IsEqualTo(order.Creator.Content, "c");
            Assert.IsEqualTo(order.Owner.Address.Id, 4);
            Assert.IsEqualTo(order.Owner.Address.Content, "d");

610
            order = connection.Query<dynamic, dynamic, dynamic, dynamic, dynamic, dynamic>(sql, (a, b, c, d, e) => { a.B = b; a.C = c; a.C.D = d; a.E = e; return a; }).First();
S
Sam Saffron 已提交
611 612 613 614 615 616 617 618 619 620 621

            Assert.IsEqualTo(order.Id, 1);
            Assert.IsEqualTo(order.Content, "a");
            Assert.IsEqualTo(order.B.Id, 2);
            Assert.IsEqualTo(order.B.Content, "b");
            Assert.IsEqualTo(order.C.Id, 3);
            Assert.IsEqualTo(order.C.Content, "c");
            Assert.IsEqualTo(order.C.D.Id, 4);
            Assert.IsEqualTo(order.C.D.Content, "d");
            Assert.IsEqualTo(order.E.Id, 5);
            Assert.IsEqualTo(order.E.Content, "e");
S
Sam Saffron 已提交
622 623 624

        }

625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646
        class InheritanceTest1
        {
            public string Base1 { get; set; }
            public string Base2 { get; private set; }
        }

        class InheritanceTest2 : InheritanceTest1
        {
            public string Derived1 { get; set; }
            public string Derived2 { get; private set; }
        }

        public void TestInheritance()
        {
            // Test that inheritance works.
            var list = connection.Query<InheritanceTest2>("select 'One' as Derived1, 'Two' as Derived2, 'Three' as Base1, 'Four' as Base2");
            list.First().Derived1.IsEqualTo("One");
            list.First().Derived2.IsEqualTo("Two");
            list.First().Base1.IsEqualTo("Three");
            list.First().Base2.IsEqualTo("Four");
        }

647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670

        public class PostCE
        {
            public int ID { get; set; }
            public string Title { get; set; }
            public string Body { get; set; }

            public AuthorCE Author { get; set; }
        }

        public class AuthorCE
        {
            public int ID { get; set; }
            public string Name { get; set; }
        }

        public void MultiRSSqlCE()
        {
            if (File.Exists("Test.sdf"))
                File.Delete("Test.sdf");

            var cnnStr = "Data Source = Test.sdf;";
            var engine = new SqlCeEngine(cnnStr);
            engine.CreateDatabase();
671

672 673 674 675 676 677 678 679 680 681 682
            using (var cnn = new SqlCeConnection(cnnStr))
            {
                cnn.Open();

                cnn.Execute("create table Posts (ID int, Title nvarchar(50), Body nvarchar(50), AuthorID int)");
                cnn.Execute("create table Authors (ID int, Name nvarchar(50))");

                cnn.Execute("insert Posts values (1,'title','body',1)");
                cnn.Execute("insert Posts values(2,'title2','body2',null)");
                cnn.Execute("insert Authors values(1,'sam')");

683
                var data = cnn.Query<PostCE, AuthorCE, PostCE>(@"select * from Posts p left join Authors a on a.ID = p.AuthorID", (post, author) => { post.Author = author; return post; }).ToList();
684
                var firstPost = data.First();
S
Sam Saffron 已提交
685 686 687
                firstPost.Title.IsEqualTo("title");
                firstPost.Author.Name.IsEqualTo("sam");
                data[1].Author.IsNull();
688 689 690
                cnn.Close();
            }
        }
S
Sam Saffron 已提交
691 692

        enum TestEnum : byte
693 694
        {
            Bla = 1
S
Sam Saffron 已提交
695 696 697 698 699
        }
        class TestEnumClass
        {
            public TestEnum? EnumEnum { get; set; }
        }
M
mgravell 已提交
700 701 702 703
        class TestEnumClassNoNull
        {
            public TestEnum EnumEnum { get; set; }
        }
S
Sam Saffron 已提交
704
        public void TestEnumWeirdness()
S
Sam Saffron 已提交
705
        {
M
mgravell 已提交
706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721
            connection.Query<TestEnumClass>("select null as [EnumEnum]").First().EnumEnum.IsEqualTo(null);
            connection.Query<TestEnumClass>("select cast(1 as tinyint) as [EnumEnum]").First().EnumEnum.IsEqualTo(TestEnum.Bla);
        }
        void Foo()
        {
            string s = "Bla";
            var obj = new TestEnumClassNoNull();
            obj.EnumEnum = (TestEnum)Enum.Parse(typeof(TestEnum), s, true);
        }
        public void TestEnumStrings()
        {
            connection.Query<TestEnumClassNoNull>("select 'BLA' as [EnumEnum]").First().EnumEnum.IsEqualTo(TestEnum.Bla);
            connection.Query<TestEnumClassNoNull>("select 'bla' as [EnumEnum]").First().EnumEnum.IsEqualTo(TestEnum.Bla);

            connection.Query<TestEnumClass>("select 'BLA' as [EnumEnum]").First().EnumEnum.IsEqualTo(TestEnum.Bla);
            connection.Query<TestEnumClass>("select 'bla' as [EnumEnum]").First().EnumEnum.IsEqualTo(TestEnum.Bla);
S
Sam Saffron 已提交
722 723
        }

S
Sam Saffron 已提交
724 725 726
        public void TestSupportForParamDictionary()
        {
            var p = new DynamicParameters();
727 728 729
            p.Add("name", "bob");
            p.Add("age", dbType: DbType.Int32, direction: ParameterDirection.Output);

S
Sam Saffron 已提交
730 731
            connection.Query<string>("set @age = 11 select @name", p).First().IsEqualTo("bob");

732
            p.Get<int>("age").IsEqualTo(11);
S
Sam Saffron 已提交
733 734
        }

S
Sam Saffron 已提交
735 736 737 738

        public void TestProcSupport()
        {
            var p = new DynamicParameters();
739 740 741
            p.Add("a", 11);
            p.Add("b", dbType: DbType.Int32, direction: ParameterDirection.Output);
            p.Add("c", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue);
S
Sam Saffron 已提交
742 743 744 745 746 747 748 749 750 751 752 753

            connection.Execute(@"create proc #TestProc 
	@a int,
	@b int output
as 
begin
	set @b = 999
	select 1111
	return @a
end");
            connection.Query<int>("#TestProc", p, commandType: CommandType.StoredProcedure).First().IsEqualTo(1111);

754 755
            p.Get<int>("c").IsEqualTo(11);
            p.Get<int>("b").IsEqualTo(999);
S
Sam Saffron 已提交
756 757 758

        }

M
mgravell 已提交
759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778
        public void TestDbString()
        {
            var obj = connection.Query("select datalength(@a) as a, datalength(@b) as b, datalength(@c) as c, datalength(@d) as d, datalength(@e) as e, datalength(@f) as f",
                new
                {
                    a = new DbString { Value = "abcde", IsFixedLength = true, Length = 10, IsAnsi = true },
                    b = new DbString { Value = "abcde", IsFixedLength = true, Length = 10, IsAnsi = false },
                    c = new DbString { Value = "abcde", IsFixedLength = false, Length = 10, IsAnsi = true },
                    d = new DbString { Value = "abcde", IsFixedLength = false, Length = 10, IsAnsi = false },
                    e = new DbString { Value = "abcde", IsAnsi = true },
                    f = new DbString { Value = "abcde", IsAnsi = false },
                }).First();
            ((int)obj.a).IsEqualTo(10);
            ((int)obj.b).IsEqualTo(20);
            ((int)obj.c).IsEqualTo(5);
            ((int)obj.d).IsEqualTo(10);
            ((int)obj.e).IsEqualTo(5);
            ((int)obj.f).IsEqualTo(10);
        }

S
Sam Saffron 已提交
779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799
        class Person
        {
            public int PersonId { get; set; }
            public string Name { get; set; }
        }

        class Address
        {
            public int AddressId { get; set; }
            public string Name { get; set; }
            public int PersonId { get; set; }
        }

        class Extra
        {
            public int Id { get; set; }
            public string Name { get; set; }
        }

        public void TestFlexibleMultiMapping()
        {
800
            var sql =
S
Sam Saffron 已提交
801 802 803 804 805
@"select 
    1 as PersonId, 'bob' as Name, 
    2 as AddressId, 'abc street' as Name, 1 as PersonId,
    3 as Id, 'fred' as Name
    ";
806 807
            var personWithAddress = connection.Query<Person, Address, Extra, Tuple<Person, Address, Extra>>
                (sql, (p, a, e) => Tuple.Create(p, a, e), splitOn: "AddressId,Id").First();
S
Sam Saffron 已提交
808 809 810 811 812 813 814 815 816 817 818

            personWithAddress.Item1.PersonId.IsEqualTo(1);
            personWithAddress.Item1.Name.IsEqualTo("bob");
            personWithAddress.Item2.AddressId.IsEqualTo(2);
            personWithAddress.Item2.Name.IsEqualTo("abc street");
            personWithAddress.Item2.PersonId.IsEqualTo(1);
            personWithAddress.Item3.Id.IsEqualTo(3);
            personWithAddress.Item3.Name.IsEqualTo("fred");

        }

819 820 821 822 823 824 825 826

        public void TestFastExpandoSupportsIDictionary()
        {
            var row = connection.Query("select 1 A, 'two' B").First() as IDictionary<string, object>;
            row["A"].IsEqualTo(1);
            row["B"].IsEqualTo("two");
        }

S
Sam Saffron 已提交
827 828 829 830

        class PrivateDan
        {
            public int Shadow { get; set; }
831 832 833
            private string ShadowInDB
            {
                set
S
Sam Saffron 已提交
834
                {
835
                    Shadow = value == "one" ? 1 : 0;
S
Sam Saffron 已提交
836 837 838 839 840 841 842
                }
            }
        }
        public void TestDapperSetsPrivates()
        {
            connection.Query<PrivateDan>("select 'one' ShadowInDB").First().Shadow.IsEqualTo(1);
        }
843 844 845 846 847 848 849 850 851 852


        class IntDynamicParam : Dapper.SqlMapper.IDynamicParameters
        {
            IEnumerable<int> numbers;
            public IntDynamicParam(IEnumerable<int> numbers)
            {
                this.numbers = numbers;
            }

853
            public void AddParameters(IDbCommand command, Dapper.SqlMapper.Identity identity)
854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871
            {
                var sqlCommand = (SqlCommand)command;
                sqlCommand.CommandType = CommandType.StoredProcedure;

                List<Microsoft.SqlServer.Server.SqlDataRecord> number_list = new List<Microsoft.SqlServer.Server.SqlDataRecord>();

                // Create an SqlMetaData object that describes our table type.
                Microsoft.SqlServer.Server.SqlMetaData[] tvp_definition = { new Microsoft.SqlServer.Server.SqlMetaData("n", SqlDbType.Int) };

                foreach (int n in numbers)
                {
                    // Create a new record, using the metadata array above.
                    Microsoft.SqlServer.Server.SqlDataRecord rec = new Microsoft.SqlServer.Server.SqlDataRecord(tvp_definition);
                    rec.SetInt32(0, n);    // Set the value.
                    number_list.Add(rec);      // Add it to the list.
                }

                // Add the table parameter.
872
                var p = sqlCommand.Parameters.Add("ints", SqlDbType.Structured);
873 874 875
                p.Direction = ParameterDirection.Input;
                p.TypeName = "int_list_type";
                p.Value = number_list;
876

877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906
            }
        }

        // SQL Server specific test to demonstrate TVP 
        public void TestTVP()
        {
            try
            {
                connection.Execute("CREATE TYPE int_list_type AS TABLE (n int NOT NULL PRIMARY KEY)");
                connection.Execute("CREATE PROC get_ints @ints int_list_type READONLY AS select * from @ints");

                var nums = connection.Query<int>("get_ints", new IntDynamicParam(new int[] { 1, 2, 3 })).ToList();
                nums[0].IsEqualTo(1);
                nums[1].IsEqualTo(2);
                nums[2].IsEqualTo(3);
                nums.Count.IsEqualTo(3);

            }
            finally
            {
                try
                {
                    connection.Execute("DROP PROC get_ints");
                }
                finally
                {
                    connection.Execute("DROP TYPE int_list_type");
                }
            }
        }
907

M
mgravell 已提交
908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931
        class Parent
        {
            public int Id { get; set; }
            public readonly List<Child> Children = new List<Child>();
        }
        class Child
        {
            public int Id { get; set; }
        }
        public void ParentChildIdentityAssociations()
        {
            var lookup = new Dictionary<int, Parent>();
            var parents = connection.Query<Parent, Child, Parent>(@"select 1 as [Id], 1 as [Id] union all select 1,2 union all select 2,3 union all select 1,4 union all select 3,5",
                (parent, child) =>
                {
                    Parent found;
                    if (!lookup.TryGetValue(parent.Id, out found))
                    {
                        lookup.Add(parent.Id, found = parent);
                    }
                    found.Children.Add(child);
                    return found;
                }).Distinct().ToDictionary(p => p.Id);
            parents.Count().IsEqualTo(3);
932
            parents[1].Children.Select(c => c.Id).SequenceEqual(new[] { 1, 2, 4 }).IsTrue();
M
mgravell 已提交
933 934 935 936
            parents[2].Children.Select(c => c.Id).SequenceEqual(new[] { 3 }).IsTrue();
            parents[3].Children.Select(c => c.Id).SequenceEqual(new[] { 5 }).IsTrue();
        }

937

S
Sam Saffron 已提交
938 939
        /* TODO:
         * 
S
Sam Saffron 已提交
940 941 942 943 944 945 946 947
        public void TestMagicParam()
        {
            // magic params allow you to pass in single params without using an anon class
            // this test fails for now, but I would like to support a single param by parsing the sql with regex and remapping. 

            var first = connection.Query("select @a as a", 1).First();
            Assert.IsEqualTo(first.a, 1);
        }
S
Sam Saffron 已提交
948
         * */
S
Sam Saffron 已提交
949

950 951 952 953 954 955 956 957
        class WithBizarreData
        {
            public GenericUriParser Foo { get; set; }
            public int Bar { get; set; }
        }
        public void TestUnexpectedDataMessage()
        {
            string msg = null;
M
marc.gravell@gmail.com 已提交
958 959
            try
            {
960 961
                connection.Query<int>("select count(1) where 1 = @Foo", new WithBizarreData { Foo = new GenericUriParser(GenericUriParserOptions.Default), Bar = 23 }).First();

M
marc.gravell@gmail.com 已提交
962 963
            }
            catch (Exception ex)
964 965 966 967 968 969 970 971 972 973 974
            {
                msg = ex.Message;
            }
            msg.IsEqualTo("The member Foo of type System.GenericUriParser cannot be used as a parameter value");
        }
        public void TestUnexpectedButFilteredDataMessage()
        {
            int i = connection.Query<int>("select @Bar", new WithBizarreData { Foo = new GenericUriParser(GenericUriParserOptions.Default), Bar = 23 }).Single();

            i.IsEqualTo(23);
        }
M
mgravell 已提交
975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013

        class WithCharValue
        {
            public char Value { get; set; }
            public char? ValueNullable { get; set; }
        }
        public void TestCharInputAndOutput()
        {
            const char test = '〠';
            char c = connection.Query<char>("select @c", new { c = test }).Single();

            c.IsEqualTo(test);

            var obj = connection.Query<WithCharValue>("select @Value as Value", new WithCharValue { Value = c }).Single();

            obj.Value.IsEqualTo(test);
        }
        public void TestNullableCharInputAndOutputNonNull()
        {
            char? test = '〠';
            char? c = connection.Query<char?>("select @c", new { c = test }).Single();

            c.IsEqualTo(test);

            var obj = connection.Query<WithCharValue>("select @ValueNullable as ValueNullable", new WithCharValue { ValueNullable = c }).Single();

            obj.ValueNullable.IsEqualTo(test);
        }
        public void TestNullableCharInputAndOutputNull()
        {
            char? test = null;
            char? c = connection.Query<char?>("select @c", new { c = test }).Single();

            c.IsEqualTo(test);

            var obj = connection.Query<WithCharValue>("select @ValueNullable as ValueNullable", new WithCharValue { ValueNullable = c }).Single();

            obj.ValueNullable.IsEqualTo(test);
        }
1014 1015 1016 1017 1018 1019 1020
        public void TestInvalidSplitCausesNiceError()
        {
            try
            {
                connection.Query<User, User, User>("select 1 A, 2 B, 3 C", (x, y) => x);
            }
            catch (ArgumentException)
M
marc.gravell@gmail.com 已提交
1021
            {
1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033
                // expecting an app exception due to multi mapping being bodged 
            }

            try
            {
                connection.Query<dynamic, dynamic, dynamic>("select 1 A, 2 B, 3 C", (x, y) => x);
            }
            catch (ArgumentException)
            {
                // expecting an app exception due to multi mapping being bodged 
            }
        }
1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080



        class Comment
        {
            public int Id { get; set; }
            public string CommentData { get; set; }
        }


        public void TestMultiMapThreeTypesWithGridReader()
        {
            var createSql = @"
                create table #Users (Id int, Name varchar(20))
                create table #Posts (Id int, OwnerId int, Content varchar(20))
                create table #Comments (Id int, PostId int, CommentData varchar(20))

                insert #Users values(99, 'Sam')
                insert #Users values(2, 'I am')

                insert #Posts values(1, 99, 'Sams Post1')
                insert #Posts values(2, 99, 'Sams Post2')
                insert #Posts values(3, null, 'no ones post')

                insert #Comments values(1, 1, 'Comment 1')";
            connection.Execute(createSql);

            var sql = @"SELECT p.* FROM #Posts p

select p.*, u.Id, u.Name + '0' Name, c.Id, c.CommentData from #Posts p 
left join #Users u on u.Id = p.OwnerId 
left join #Comments c on c.postId = p.Id
where p.Id = 1
Order by p.Id";

            var grid = connection.QueryMultiple(sql);

            var post1 = grid.Read<Post>().ToList();

            var post2 = grid.Read<Post, User, Comment, Post>((post, user, comment) => { post.Owner = user; post.Comment = comment; return post; }).SingleOrDefault();

            post2.Comment.Id.IsEqualTo(1);
            post2.Owner.Id.IsEqualTo(99);


            connection.Execute("drop table #Users drop table #Posts drop table #Comments");
        }
1081 1082 1083 1084 1085 1086

        public void TestDynamicParamNullSupport()
        {
            var p = new DynamicParameters();

            p.Add("@b", dbType: DbType.Int32, direction: ParameterDirection.Output);
M
marc.gravell@gmail.com 已提交
1087
            connection.Execute("select @b = null", p);
1088 1089 1090

            p.Get<int?>("@b").IsNull();
        }
M
marc.gravell@gmail.com 已提交
1091 1092
        class Foo1
        {
M
mgravell 已提交
1093 1094
            public int Id;
            public int BarId { get; set; }
M
marc.gravell@gmail.com 已提交
1095
        }
M
mgravell 已提交
1096 1097
        class Bar1
        {
M
marc.gravell@gmail.com 已提交
1098 1099
            public int BarId;
            public string Name { get; set; }
M
mgravell 已提交
1100 1101 1102 1103
        }
        public void TestMultiMapperIsNotConfusedWithUnorderedCols()
        {
            var result = connection.Query<Foo1, Bar1, Tuple<Foo1, Bar1>>("select 1 as Id, 2 as BarId, 3 as BarId, 'a' as Name", (f, b) => Tuple.Create(f, b), splitOn: "BarId").First();
1104

M
mgravell 已提交
1105 1106 1107 1108 1109 1110
            result.Item1.Id.IsEqualTo(1);
            result.Item1.BarId.IsEqualTo(2);
            result.Item2.BarId.IsEqualTo(3);
            result.Item2.Name.IsEqualTo("a");
        }
        public void TestLinqBinaryToClass()
1111
        {
M
mgravell 已提交
1112 1113
            byte[] orig = new byte[20];
            new Random(123456).NextBytes(orig);
M
mgravell 已提交
1114 1115 1116 1117 1118
            var input = new System.Data.Linq.Binary(orig);

            var output = connection.Query<WithBinary>("select @input as [Value]", new { input }).First().Value;

            output.ToArray().IsSequenceEqualTo(orig);
1119 1120
        }

M
mgravell 已提交
1121
        public void TestLinqBinaryRaw()
1122
        {
M
mgravell 已提交
1123 1124
            byte[] orig = new byte[20];
            new Random(123456).NextBytes(orig);
M
mgravell 已提交
1125 1126 1127 1128 1129
            var input = new System.Data.Linq.Binary(orig);

            var output = connection.Query<System.Data.Linq.Binary>("select @input as [Value]", new { input }).First();

            output.ToArray().IsSequenceEqualTo(orig);
1130 1131
        }

M
mgravell 已提交
1132
        class WithBinary
1133
        {
M
mgravell 已提交
1134
            public System.Data.Linq.Binary Value { get; set; }
1135
        }
1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148


        class WithPrivateConstructor
        {
            public int Foo { get; set; }
            private WithPrivateConstructor() { }
        }

        public void TestWithNonPublicConstructor()
        {
            var output = connection.Query<WithPrivateConstructor>("select 1 as Foo").First();
            output.Foo.IsEqualTo(1);
        }
1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166

        public void TestAppendingAnonClasses()
        {
            DynamicParameters p = new DynamicParameters();
            p.AddDynamicParams(new { A = 1, B = 2 });
            p.AddDynamicParams(new { C = 3, D = 4 });

            var result = connection.Query("select @A a,@B b,@C c,@D d", p).Single();

            ((int)result.a).IsEqualTo(1);
            ((int)result.b).IsEqualTo(2);
            ((int)result.c).IsEqualTo(3);
            ((int)result.d).IsEqualTo(4);
        }

        public void TestAppendingAList()
        {
            DynamicParameters p = new DynamicParameters();
M
marc.gravell@gmail.com 已提交
1167
            var list = new int[] { 1, 2, 3 };
1168 1169 1170 1171 1172 1173 1174 1175
            p.AddDynamicParams(new { list });

            var result = connection.Query<int>("select * from (select 1 A union all select 2 union all select 3) X where A in @list", p).ToList();

            result[0].IsEqualTo(1);
            result[1].IsEqualTo(2);
            result[2].IsEqualTo(3);
        }
S
Sam Saffron 已提交
1176

M
marc.gravell@gmail.com 已提交
1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194
        public void TestUniqueIdentifier()
        {
            var guid = Guid.NewGuid();
            var result = connection.Query<Guid>("declare @foo uniqueidentifier set @foo = @guid select @foo", new { guid }).Single();
            result.IsEqualTo(guid);
        }
        public void TestNullableUniqueIdentifierNonNull()
        {
            Guid? guid = Guid.NewGuid();
            var result = connection.Query<Guid?>("declare @foo uniqueidentifier set @foo = @guid select @foo", new { guid }).Single();
            result.IsEqualTo(guid);
        }
        public void TestNullableUniqueIdentifierNull()
        {
            Guid? guid = null;
            var result = connection.Query<Guid?>("declare @foo uniqueidentifier set @foo = @guid select @foo", new { guid }).Single();
            result.IsEqualTo(guid);
        }
S
Sam Saffron 已提交
1195 1196
    }
}