diff UnitTests/Linq/CompileTest.cs @ 0:f990fcb411a9

Копия текущей версии из github
author cin
date Thu, 27 Mar 2014 21:46:09 +0400
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/UnitTests/Linq/CompileTest.cs	Thu Mar 27 21:46:09 2014 +0400
@@ -0,0 +1,191 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using NUnit.Framework;
+
+using BLToolkit.Data.Linq;
+
+namespace Data.Linq
+{
+	using Model;
+
+	[TestFixture]
+	public class CompileTest : TestBase
+	{
+		[Test]
+		public void CompiledTest1()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, string n1, int n2) =>
+				n1 + n2);
+
+			ForEachProvider(db =>
+			{
+				Assert.AreEqual("11", query(db, "1", 1));
+				Assert.AreEqual("22", query(db, "2", 2));
+			});
+		}
+
+		[Test]
+		public void CompiledTest2([DataContexts] string context)
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, int n) =>
+				db.Child.Where(c => c.ParentID == n).Take(n));
+
+			using (var db = GetDataContext(context))
+			{
+				Assert.AreEqual(1, query(db, 1).ToList().Count());
+				Assert.AreEqual(2, query(db, 2).ToList().Count());
+			}
+		}
+
+		[Test]
+		public void CompiledTest3()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, int n) =>
+				db.GetTable<Child>().Where(c => c.ParentID == n).Take(n));
+
+			ForEachProvider(db =>
+			{
+				Assert.AreEqual(1, query(db, 1).ToList().Count());
+				Assert.AreEqual(2, query(db, 2).ToList().Count());
+			});
+		}
+
+		[Test]
+		public void CompiledTest4()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, int[] n) =>
+				db.GetTable<Child>().Where(c => n.Contains(c.ParentID)));
+
+			ForEachProvider(db =>
+				Assert.AreEqual(3, query(db, new[] { 1, 2 }).ToList().Count()));
+		}
+
+		[Test]
+		public void CompiledTest5()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, object[] ps) => 
+				db.Parent.Where(p => p.ParentID == (int)ps[0] && p.Value1 == (int?)ps[1]));
+
+			ForEachProvider(db =>
+			{
+				Assert.AreEqual(1, query(db, new object[] { 1, 1    }).ToList().Count());
+				Assert.AreEqual(1, query(db, new object[] { 2, null }).ToList().Count());
+			});
+		}
+
+		[Test]
+		public void CompiledTable1()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db) =>
+				db.Child);
+
+			ForEachProvider(db => query(db).ToList().Count());
+		}
+
+		[Test]
+		public void CompiledTable2()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db) =>
+				db.GetTable<Child>());
+
+			ForEachProvider(db => query(db).ToList().Count());
+		}
+
+		[Test]
+		public void ConcurentTest1()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, int n) =>
+				db.GetTable<Parent>().Where(p => p.ParentID == n).First().ParentID);
+
+			const int count = 100;
+
+			var threads = new Thread[count];
+			var results = new int   [count, 2];
+
+			for (var i = 0; i < count; i++)
+			{
+				var n = i;
+
+				threads[i] = new Thread(() =>
+				{
+					using (var db = new TestDbManager())
+					{
+						var id = (n % 6) + 1;
+						results[n,0] = id;
+						results[n,1] = query(db, id);
+					}
+				});
+			}
+
+			for (var i = 0; i < count; i++)
+				threads[i].Start();
+
+			for (var i = 0; i < count; i++)
+				threads[i].Join();
+
+			for (var i = 0; i < count; i++)
+				Assert.AreEqual(results[i,0], results[i,1]);
+		}
+
+		[Test]
+		public void ConcurentTest2()
+		{
+			var threads = new Thread[100];
+			var results = new int   [100,2];
+
+			for (var i = 0; i < 100; i++)
+			{
+				var n = i;
+
+				threads[i] = new Thread(() =>
+				{
+					using (var db = new TestDbManager())
+					{
+						var id = (n % 6) + 1;
+						results[n,0] = id;
+						results[n,1] = db.Parent.Where(p => p.ParentID == id).First().ParentID;
+					}
+				});
+			}
+
+			for (var i = 0; i < 100; i++)
+				threads[i].Start();
+
+			for (var i = 0; i < 100; i++)
+				threads[i].Join();
+
+			for (var i = 0; i < 100; i++)
+				Assert.AreEqual(results[i,0], results[i,1]);
+		}
+
+		[Test]
+		public void ParamTest1()
+		{
+			var query = CompiledQuery.Compile<ITestDataContext,int,IEnumerable<Child>>((db, id) =>
+				from c in db.Child
+				where c.ParentID == id
+				select new Child
+				{
+					ParentID = id,
+					ChildID  = c.ChildID
+				});
+
+			ForEachProvider(db => Assert.AreEqual(2, query(db, 2).ToList().Count()));
+		}
+
+		[Test]
+		public void ElementTest1()
+		{
+			var query = CompiledQuery.Compile((ITestDataContext db, int n) =>
+				db.Child.Where(c => c.ParentID == n).First());
+
+			ForEachProvider(db =>
+			{
+				Assert.AreEqual(1, query(db, 1).ParentID);
+				Assert.AreEqual(2, query(db, 2).ParentID);
+			});
+		}
+	}
+}