Вот мое решение
Субъекты:
public class TaskTest : Entity<TaskTest>
{
public virtual string Name { get; set; }
public virtual IList<TagTest> Tags { get; set; }
public TaskTest()
{
Tags = new List<TagTest>();
}
}
public class TagTest : Entity<TagTest>
{
public virtual string Name { get; set; }
}
Не принимайте во внимание сущность <>.Это универсально, поскольку мы реализовали интерфейс IEquatable
Следующие сопоставления:
public class TaskTestMap : EntityMap<TaskTest>
{
public TaskTestMap()
{
Map(x => x.Name).Not.Nullable().Length(512);
HasManyToMany(x => x.Tags).Table("TaskTag").Cascade.All();
}
}
public class TagTastMap : EntityMap<TagTest>
{
public TagTastMap()
{
Map(x => x.Name).Not.Nullable();
}
}
Я установил каскад только для сохранения задач при сохранении задач.
Репозиторий с моимКритерии:
public IList<TaskTest> GetTaskByTagIds(IList<long> tagIds)
{
DetachedCriteria exists = DetachedCriteria.For<TaskTest>("t")
.CreateAlias("t.Tags", "tags")
.Add(Restrictions.EqProperty("t.Id", "task.Id"))
.Add(Restrictions.In("tags.Id", tagIds.ToArray()))
.SetProjection(Projections.GroupProperty("t.Id"))
.Add(Restrictions.Eq(Projections.Count("t.Id"), tagIds.Count));
ICriteria criteria = GetSession().CreateCriteria<TaskTest>("task")
.Add(Subqueries.Exists(exists));
return criteria.List<TaskTest>();
}
И юнит-тест, который проходит на моей стороне:
[Test]
public void TestTaskTest()
{
//Insert data;
var task1 = new TaskTest {Name = "task1"};
var task2 = new TaskTest {Name = "task2"};
var task3 = new TaskTest {Name = "task3"};
var tag1 = new TagTest {Name = "tag1"};
var tag2 = new TagTest {Name = "tag1"};
var tag3 = new TagTest {Name = "tag1"};
task1.Tags.Add(tag1);
task1.Tags.Add(tag2);
task2.Tags.Add(tag1);
task2.Tags.Add(tag3);
task3.Tags.Add(tag3);
_repository.AddToSession(task1);
_repository.AddToSession(task2);
_repository.AddToSession(task3);
FlushAndClearSession();
//We will try to get all task which a taged with tag1 and tag2. The result should be task1
var tagsId = new List<long> {tag1.Id, tag2.Id};
var result = _repository.GetTaskByTagIds(tagsId);
Assert.That(result, Is.Not.Null);
Assert.That(result, Is.Not.Empty);
Assert.That(result.Count, Is.EqualTo(1));
Assert.That(result[0].Name, Is.EqualTo("task1"));
}
и оператор sql:
exec sp_executesql N'SELECT this_.Id as Id50_0_, this_.Version as Version50_0_, this_.Name as Name50_0_
FROM [TaskTests] this_
WHERE exists (
SELECT this_0_.Id as y0_
FROM [TaskTests] this_0_
inner join TaskTag tags3_ on this_0_.Id=tags3_.TaskTestId
inner join [TagTests] tags1_ on tags3_.TagTestId=tags1_.Id
WHERE this_0_.Id = this_.Id and tags1_.Id in (@p0, @p1)
GROUP BY this_0_.Id
HAVING count(this_0_.Id) = @p2)',
N'@p0 bigint,@p1 bigint,@p2 int',
@p0=9000,@p1=9001,@p2=2
С уважением, / Ион