Mercurial > pub > bltoolkit
view UnitTests/Linq/Exceptions/Common.cs @ 0:f990fcb411a9
Копия текущей версии из github
author | cin |
---|---|
date | Thu, 27 Mar 2014 21:46:09 +0400 |
parents | |
children |
line wrap: on
line source
using System; using System.Collections.Generic; using BLToolkit.Common; using BLToolkit.Data; using BLToolkit.Data.Linq; using BLToolkit.Data.Sql; using NUnit.Framework; namespace Data.Exceptions { using Linq; using Linq.Model; [TestFixture] public class Common : TestBase { class MyDbManager : TestDbManager { public MyDbManager() : base("Sql2008") {} protected override SqlQuery ProcessQuery(SqlQuery sqlQuery) { if (sqlQuery.IsInsert && sqlQuery.Insert.Into.Name == "Parent") { var expr = new QueryVisitor().Find(sqlQuery.Insert, e => { if (e.ElementType == QueryElementType.SetExpression) { var se = (SqlQuery.SetExpression)e; return ((SqlField)se.Column).Name == "ParentID"; } return false; }) as SqlQuery.SetExpression; if (expr != null) { var value = ConvertTo<int>.From(((IValueContainer)expr.Expression).Value); if (value == 555) { var tableName = "Parent1"; var dic = new Dictionary<IQueryElement,IQueryElement>(); sqlQuery = new QueryVisitor().Convert(sqlQuery, e => { if (e.ElementType == QueryElementType.SqlTable) { var oldTable = (SqlTable)e; if (oldTable.Name == "Parent") { var newTable = new SqlTable(oldTable) { Name = tableName, PhysicalName = tableName }; foreach (var field in oldTable.Fields.Values) dic.Add(field, newTable.Fields[field.Name]); return newTable; } } IQueryElement ex; return dic.TryGetValue(e, out ex) ? ex : null; }); } } } return sqlQuery; } } [Test, ExpectedException(typeof(DataException), ExpectedMessage = "Invalid object name 'Parent1'.")] public void ReplaceTableTest([IncludeDataContexts("Sql2008", "Sql2012")] string context) { using (var db = new MyDbManager()) { var n = 555; db.Parent.Insert(() => new Parent { ParentID = n, Value1 = n }); db.Parent.Delete(p => p.ParentID == n); } } } }