4

我正在开发一个有两个数据库的应用程序。

我有一个对象，我们称之为它permit，它有一个从表中引用 id 的 id 列表，让我们tasks在另一个数据库中调用它。

我正在尝试运行以下查询：

var listOfUsedIds = select taskid from Permit_Task;
Select * from task where id not in (listOfUsedIds)

当我运行此代码时，我收到错误：

传入的表格数据流 (TDS) 远程过程调用 (RPC) 协议流不正确。
此 RPC 请求中提供的参数过多。最大值为 2100。

我不能运行子选择或任何东西，因为 NHibernate 不会让我在两个数据库上这样做。

谁能帮我解决这个问题？

4

2 回答 2

1 
using (var tx = session.BeginTransaction())
{
    session.CreateSQLQuery("CREATE TEMP TABLE usedIds (id INT)").ExecuteUpdate();

    for (int index = 0; index < ids.Length; index++)
    {
        // TODO: batch this
        session.CreateSQLQuery("INSERT INTO usedIds VALUES (:p" + index + ")")
            .SetParameter("p" + index, id)
            .ExecuteUpdate();
    }

    session.CreateSQLQuery("CREATE INDEX usedIds_idx ON usedIds (id)").ExecuteUpdate();


    Batch batch;
    while((batch.List = session.CreateSQLQuery("SELECT id FROM tasks t WHERE 1 = (SELECT COUNT(*) FROM usedIds u WHERE u.id = t.id) LIMIT 10 OFFSET " + batch.Number).List<int>()).Count > 0)

    {
        var tasks = session.QueryOver<Task>()
            .Where(t => t.Id.IsIn(batch))
            .List();
        // Do something with the tasks
    }
    tx.Commit();
}

或者

public TaskMap()
{

    Map(x => x.IsUsedCount).Formula("SELECT (SELECT COUNT(*) FROM usedIds u WHERE u.Id = Id)").LazyLoad();
}

var tasks = session.QueryOver<Task>()
    .Where(t => t.IsUsedCount == 0)
    .List();
于 2011-09-15T11:40:53.403 回答
0

只需将它们listOfUsedIds分成更小的块（例如，每个 200 个 id），为每个块运行查询，然后.Concat()得到结果。

于 2011-09-15T15:34:39.737 回答