using System;
using System.Collections;
using System.Collections.Generic;
using System.Diagnostics.CodeAnalysis;
using System.IO;
using System.Linq;
using System.Reflection;
using NewLife.Data;
using NewLife.IO;
using NewLife.Security;
using Xunit;

namespace XUnitTest.IO
{
    public class CsvDbTests
    {
        private CsvDb<PageParameter> GetDb(String name)
        {
            var file = $"data/{name}.csv".GetFullPath();
            if (File.Exists(file)) File.Delete(file);

            var db = new CsvDb<PageParameter>((x, y) => x.PageIndex == y.PageIndex)
            {
                FileName = file
            };
            return db;
        }

        private PageParameter GetModel()
        {
            var model = new PageParameter
            {
                PageIndex = Rand.Next(),
                PageSize = Rand.Next(),

                Sort = Rand.NextString(14),
                Desc = Rand.Next(2) == 1,

                TotalCount = Rand.Next(),
            };

            return model;
        }

        private String[] GetHeaders()
        {
            var pis = typeof(PageParameter).GetProperties(BindingFlags.Public | BindingFlags.Instance);
            return pis.Select(e => e.Name).ToArray();
        }

        private Object[] GetValue(PageParameter model)
        {
            var pis = typeof(PageParameter).GetProperties(BindingFlags.Public | BindingFlags.Instance);
            //return pis.Select(e => e.GetValue(model, null)).ToArray();
            var arr = new Object[pis.Length];
            for (var i = 0; i < pis.Length; i++)
            {
                arr[i] = pis[i].GetValue(model, null);
                if (pis[i].PropertyType == typeof(Boolean)) arr[i] = (Boolean)arr[i] ? "1" : "0";
            }
            return arr;
        }

        [Fact]
        public void InsertTest()
        {
            var db = GetDb("Insert");

            var model = GetModel();
            db.Add(model);

            // 把文件读出来
            var lines = File.ReadAllLines(db.FileName.GetFullPath());
            Assert.Equal(2, lines.Length);

            Assert.Equal(GetHeaders().Join(","), lines[0]);
            Assert.Equal(GetValue(model).Join(","), lines[1]);
        }

        [Fact]
        public void InsertsTest()
        {
            var db = GetDb("Inserts");

            var list = new List<PageParameter>();
            var count = Rand.Next(2, 100);
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 把文件读出来
            var lines = File.ReadAllLines(db.FileName.GetFullPath());
            Assert.Equal(list.Count + 1, lines.Length);

            Assert.Equal(GetHeaders().Join(","), lines[0]);
            for (var i = 0; i < list.Count; i++)
            {
                Assert.Equal(GetValue(list[i]).Join(","), lines[i + 1]);
            }
        }

        [Fact]
        public void GetAllTest()
        {
            var db = GetDb("GetAll");

            var list = new List<PageParameter>();
            var count = Rand.Next(2, 100);
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 把文件读出来
            var list2 = db.FindAll();
            Assert.Equal(list.Count, list2.Count);

            for (var i = 0; i < list.Count; i++)
            {
                Assert.Equal(GetValue(list[i]).Join(","), GetValue(list2[i]).Join(","));
            }

            // 高级查找
            var list3 = db.FindAll(e => e.PageIndex >= 100 && e.PageIndex < 1000);
            var list4 = list.Where(e => e.PageIndex >= 100 && e.PageIndex < 1000).ToList();
            Assert.Equal(list4.Select(e => e.PageIndex), list3.Select(e => e.PageIndex));
        }

        [Fact]
        public void GetCountTest()
        {
            var db = GetDb("GetCount");

            var list = new List<PageParameter>();
            var count = Rand.Next(2, 100);
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 把文件读出来
            var lines = File.ReadAllLines(db.FileName.GetFullPath());
            Assert.Equal(list.Count + 1, lines.Length);
            Assert.Equal(list.Count, db.FindCount());
        }

        [Fact]
        public void LargeInsertsTest()
        {
            var db = GetDb("LargeInserts");

            var list = new List<PageParameter>();
            var count = 100_000;
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 把文件读出来
            var lines = File.ReadAllLines(db.FileName.GetFullPath());
            Assert.Equal(list.Count + 1, lines.Length);

            Assert.Equal(GetHeaders().Join(","), lines[0]);
            for (var i = 0; i < list.Count; i++)
            {
                Assert.Equal(GetValue(list[i]).Join(","), lines[i + 1]);
            }
        }

        [Fact]
        public void InsertTwoTimesTest()
        {
            var db = GetDb("InsertTwoTimes");

            // 第一次插入
            var list = new List<PageParameter>();
            {
                var count = Rand.Next(2, 100);
                for (var i = 0; i < count; i++)
                {
                    list.Add(GetModel());
                }

                db.Add(list);
            }

            // 第二次插入
            {
                var list2 = new List<PageParameter>();
                var count = Rand.Next(2, 100);
                for (var i = 0; i < count; i++)
                {
                    list2.Add(GetModel());
                }

                db.Add(list2);

                list.AddRange(list2);
            }

            // 把文件读出来
            var lines = File.ReadAllLines(db.FileName.GetFullPath());
            Assert.Equal(list.Count + 1, lines.Length);

            Assert.Equal(GetHeaders().Join(","), lines[0]);
            for (var i = 0; i < list.Count; i++)
            {
                Assert.Equal(GetValue(list[i]).Join(","), lines[i + 1]);
            }
        }

        [Fact]
        public void DeletesTest()
        {
            var db = GetDb("Deletes");

            var list = new List<PageParameter>();
            var count = Rand.Next(2, 100);
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 随机删除一个
            var idx = Rand.Next(list.Count);
            var rs = db.Remove(list[idx]);
            Assert.Equal(1, rs);

            list.RemoveAt(idx);
            Assert.Equal(list.Count, db.FindCount());

            // 随机抽几个，删除
            var list2 = new List<PageParameter>();
            for (var i = 0; i < list.Count; i++)
            {
                if (Rand.Next(2) == 1) list2.Add(list[i]);
            }

            var rs2 = db.Remove(list2);
            Assert.Equal(list2.Count, rs2);
            Assert.Equal(list.Count - list2.Count, db.FindCount());
        }

        [Fact]
        public void UpdateTest()
        {
            var db = GetDb("Update");

            var list = new List<PageParameter>();
            var count = Rand.Next(2, 100);
            for (var i = 0; i < count; i++)
            {
                list.Add(GetModel());
            }

            db.Add(list);

            // 随机改一个
            var idx = Rand.Next(list.Count);
            var model = db.Find(list[idx]);
            Assert.NotNull(model);

            model.TotalCount = Rand.Next();
            var rs = db.Update(model);
            Assert.True(rs);

            var model2 = db.Find(list[idx]);
            Assert.NotNull(model2);
            Assert.Equal(model.TotalCount, model2.TotalCount);
        }
    }
}