luticate2-api/Test/Utils/EfCrubDataAccess/LuEfCreateDataAccessTest.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using Luticate2.Utils.Dbo;
using Microsoft.AspNetCore.Mvc.Controllers;
using Test.Utils.DataAccess;
using Test.Utils.Dbo.PkBigSerial;
using Test.Utils.Dbo.PkGuid;
using Xunit;

namespace Test.Utils.EfCrubDataAccess
{
    public class LuEfCreateDataAccessTest
    {
        [Fact]
        public void TestAddMultiple1()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(dbos, enumerable => enumerable);
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, PkBigSerialDbo>(dbo, serialDbo)))
                {
                    Assert.NotNull(dbo.Key);
                    Assert.NotNull(dbo.Value);

                    Assert.NotEqual(0, dbo.Value.Id);
                    Assert.Equal(dbo.Key.SomeText, dbo.Value.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, dbo.Value.SomeInt);

                    var get = service.GetSingleById(dbo.Value.Id);
                    Assert.Equal(LuStatus.Success, get.Status);
                    Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
                    Assert.Equal(dbo.Value.Id, get.Data.Id);
                }
            });
        }

        [Fact]
        public void TestAddMultiple2()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.Id));
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, long>(dbo, serialDbo)))
                {
                    Assert.NotNull(dbo.Key);
                    Assert.NotNull(dbo.Value);

                    Assert.NotEqual(0, dbo.Value);

                    var get = service.GetSingleById(dbo.Value);
                    Assert.Equal(LuStatus.Success, get.Status);
                    Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
                    Assert.Equal(dbo.Value, get.Data.Id);
                }
            });
        }

        [Fact]
        public void TestAddMultiple3()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.CreatedAt));
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in res.Data)
                {
                    Assert.NotEqual(default(DateTime), dbo);
                }
            });
        }

        [Fact]
        public void TestAddMultiple4()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "42"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.CreatedAt));
                Assert.Equal(LuStatus.DbError, res.Status);
            });
        }


        [Fact]
        public void TestAddSingle1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                }, dbo => dbo);
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);
                Assert.Equal("42", res.Data.SomeText);
                Assert.Equal(42, res.Data.SomeInt);

                var get = service.GetSingleById(res.Data.Id);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data.Id, get.Data.Id);
            });
        }

        [Fact]
        public void TestAddSingle2()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                }, dbo => dbo.Id);
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data);

                var get = service.GetSingleById(res.Data);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data, get.Data.Id);
            });
        }

        [Fact]
        public void TestAddSingle3()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.Add(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                }, dbo => dbo.CreatedAt);
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(default(DateTime), res.Data);
            });
        }

        [Fact]
        public void TestAddGuidMultiple1()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkGuidAddDbo>
                {
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(dbos);
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkGuidAddDbo, string>(dbo, serialDbo)))
                {
                    Assert.NotNull(dbo.Key);
                    Assert.NotNull(dbo.Value);

                    Assert.NotEqual(new Guid().ToString(), dbo.Value);

                    var get = service.GetSingleById(dbo.Value);
                    Assert.Equal(LuStatus.Success, get.Status);
                    Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
                    Assert.Equal(dbo.Value, get.Data.Id);
                }
            });
        }


        [Fact]
        public void TestAddGuidSingle1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(new PkGuidAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(new Guid().ToString(), res.Data);

                var get = service.GetSingleById(res.Data);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data, get.Data.Id);
            });
        }

        [Fact]
        public void TestAddIdMultiple1()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddId(dbos);
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, long>(dbo, serialDbo)))
                {
                    Assert.NotNull(dbo.Key);
                    Assert.NotNull(dbo.Value);

                    Assert.NotEqual(0, dbo.Value);

                    var get = service.GetSingleById(dbo.Value);
                    Assert.Equal(LuStatus.Success, get.Status);
                    Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
                    Assert.Equal(dbo.Value, get.Data.Id);
                }
            });
        }


        [Fact]
        public void TestAddIdSingle1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddId(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data);

                var get = service.GetSingleById(res.Data);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data, get.Data.Id);
            });
        }

        [Fact]
        public void TestAddDboMultiple1()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkBigSerialAddDbo>
                {
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkBigSerialAddDbo
                    {
                        SomeInt = 21,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(dbos);
                Assert.Equal(LuStatus.Success, res.Status);
                foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, PkBigSerialDbo>(dbo, serialDbo)))
                {
                    Assert.NotNull(dbo.Key);
                    Assert.NotNull(dbo.Value);

                    Assert.NotEqual(0, dbo.Value.Id);

                    var get = service.GetSingleById(dbo.Value.Id);
                    Assert.Equal(LuStatus.Success, get.Status);
                    Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
                    Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
                    Assert.Equal(dbo.Value.Id, get.Data.Id);
                }
            });
        }


        [Fact]
        public void TestAddDboSingle1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);

                var get = service.GetSingleById(res.Data.Id);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data.Id, get.Data.Id);
            });
        }


        [Fact]
        public void TestGetSingle1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);

                var get = service.GetSingle(bigserial => bigserial.some_int == 42);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data.Id, get.Data.Id);
            });
        }

        [Fact]
        public void TestGetSingle2()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);

                var get = service.GetSingle(bigserial => bigserial.some_int == 24);
                Assert.Equal(LuStatus.NotFound, get.Status);
            });
        }


        [Fact]
        public void TestGetSingleByKeys1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);

                var get = service.GetSingleByKeys(new KeyValuePair<string, object>("some_text", "42"));
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data.Id, get.Data.Id);
            });
        }

        [Fact]
        public void TestGetSingleByKeys2()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddDbo(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data.Id);

                var get = service.GetSingleByKeys(new KeyValuePair<string, object>("some_text", "24"));
                Assert.Equal(LuStatus.NotFound, get.Status);
            });
        }

        [Fact]
        public void TestGetSingleById1()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddId(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data);

                var get = service.GetSingleById(res.Data);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data, get.Data.Id);
            });
        }

        [Fact]
        public void TestGetSingleById2()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkBigSerialDataAccess(context);
                var res = service.AddId(new PkBigSerialAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(0, res.Data);

                var get = service.GetSingle(bigserial => bigserial.some_int == 24);
                Assert.Equal(LuStatus.NotFound, get.Status);
            });
        }

        [Fact]
        public void TestGetSingleById3()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(new PkGuidAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(new Guid().ToString(), res.Data);

                var get = service.GetSingleById(res.Data);
                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal("42", get.Data.SomeText);
                Assert.Equal(42, get.Data.SomeInt);
                Assert.Equal(res.Data, get.Data.Id);
            });
        }

        [Fact]
        public void TestGetSingleById4()
        {
            Tests.TestRealDb(context =>
            {
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(new PkGuidAddDbo
                {
                    SomeInt = 42,
                    SomeText = "42"
                });
                Assert.Equal(LuStatus.Success, res.Status);
                Assert.NotEqual(new Guid().ToString(), res.Data);

                var get = service.GetSingle(bigserial => bigserial.some_int == 24);
                Assert.Equal(LuStatus.NotFound, get.Status);
            });
        }

        [Fact]
        public void TestGetMultiple1()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkGuidAddDbo>
                {
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "442"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 24,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(dbos);
                Assert.Equal(LuStatus.Success, res.Status);

                var get = service.GetMultiple(table => table.OrderBy(guid => guid.some_int),
                    guid => guid.some_int == 42, 0, int.MaxValue, set => set.OrderBy(guid => guid.some_text));

                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal(2, get.Data.Count);
                Assert.Equal(2, get.Data.Data.Count);

                var dbo = get.Data.Data[0];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("42", dbo.SomeText);

                dbo = get.Data.Data[1];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("442", dbo.SomeText);
            });
        }

        [Fact]
        public void TestGetMultiple2()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkGuidAddDbo>
                {
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "442"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 24,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(dbos);
                Assert.Equal(LuStatus.Success, res.Status);

                var get = service.GetMultiple(guid => guid.some_int, guid => guid.some_int == 42, 0, int.MaxValue,
                    guid => guid.some_text);

                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal(2, get.Data.Count);
                Assert.Equal(2, get.Data.Data.Count);

                var dbo = get.Data.Data[0];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("42", dbo.SomeText);

                dbo = get.Data.Data[1];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("442", dbo.SomeText);
            });
        }

        [Fact]
        public void TestGetMultiple3()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkGuidAddDbo>
                {
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "442"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 24,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(dbos);
                Assert.Equal(LuStatus.Success, res.Status);

                var get = service.GetMultiple(table => table.OrderBy(guid => guid.some_int), 0, int.MaxValue,
                    set => set.OrderBy(guid => guid.some_text));

                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal(3, get.Data.Count);
                Assert.Equal(3, get.Data.Data.Count);

                var dbo = get.Data.Data[0];
                Assert.Equal(24, dbo.SomeInt);
                Assert.Equal("24", dbo.SomeText);

                dbo = get.Data.Data[1];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("42", dbo.SomeText);

                dbo = get.Data.Data[2];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("442", dbo.SomeText);
            });
        }

        [Fact]
        public void TestGetMultiple4()
        {
            Tests.TestRealDb(context =>
            {
                var dbos = new List<PkGuidAddDbo>
                {
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "442"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 42,
                        SomeText = "42"
                    },
                    new PkGuidAddDbo
                    {
                        SomeInt = 24,
                        SomeText = "24"
                    }
                };
                var service = new LuUtilsPkGuidDataAccess(context);
                var res = service.AddGuid(dbos);
                Assert.Equal(LuStatus.Success, res.Status);

                var get = service.GetMultiple(guid => guid.some_int, 0, int.MaxValue, guid => guid.some_text);

                Assert.Equal(LuStatus.Success, get.Status);
                Assert.Equal(3, get.Data.Count);
                Assert.Equal(3, get.Data.Data.Count);

                var dbo = get.Data.Data[0];
                Assert.Equal(24, dbo.SomeInt);
                Assert.Equal("24", dbo.SomeText);

                dbo = get.Data.Data[1];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("42", dbo.SomeText);

                dbo = get.Data.Data[2];
                Assert.Equal(42, dbo.SomeInt);
                Assert.Equal("442", dbo.SomeText);
            });
        }
    }
}