0

我正在尝试INSERT INTO ... SELECT ...用 HQL 编写查询。但是，我插入的类包含<component>映射中的项目。例如，我的类定义可能是：

public class X
{
    public virtual string A { get; set; }
    public virtual string B { get; set; }
    public virtual Y C { get; set; }
}
public class Y
{
    public virtual string C1 { get; set; }
    public virtual string C2 { get; set; }
}

和一个可能的映射：

<class name="X">
    <id type="int"><generator class="identity"/></id>
    <property name="A" />
    <property name="B" />
        <component name="C">
            <property name="C1" column="C1" />
            <property name="C2" column="C2" />
        </component>
    </component>
</class>

如何在 HQL 中为此类编写插入查询？我试过：

session.CreateQuery("INSERT INTO X(A, B, C1, C2) SELECT A, B, 'foo', 'bar' FROM X data")
       .ExecuteUpdate();

这给出了错误：

NHibernate.QueryException : could not resolve property: C1 of: X
[INSERT INTO X(A, B, C1, C2) SELECT A, B, "foo", "bar" FROM X data]

我也试过：

session.CreateQuery("INSERT INTO X(A, B, C) SELECT A, B, :C FROM X data")
       .SetParameter("C", new Y() { C1 = "foo", C2 = "bar" });
       .ExecuteUpdate();

这给出了错误：

NHibernate.HibernateException : Could not determine a type for class: Y

我也试过：

session.CreateQuery("INSERT INTO X(A, B, C.C1, C.C2) SELECT A, B, 'foo', 'bar' FROM X data")
       .ExecuteUpdate();

这给出了错误：

NHibernate.Hql.Ast.ANTLR.QuerySyntaxException : Exception of type 'Antlr.Runtime.MismatchedTreeNodeException' was thrown. near line 1, column 21 
[INSERT INTO X(A, B, C.C1, C.C2) SELECT A, B, "foo", "bar" FROM X data]

还有其他建议吗？

4

3 回答 3

2

HQL 是关于检索实体，而不是关于检索记录或插入记录。

在使用 NHibernate 时，您不应该考虑记录和记录集，而应该考虑实体。所以，如果你想使用 NHibernate 在数据库中插入一些东西，你必须创建一个实体的实例，并使用 NHibernate 的 ISession 将该实体保存到数据库中。

于 2012-08-24T09:07:06.033 回答
1

所以答案是

session.CreateSQLQuery("INSERT INTO X(A, B, C1, C2) SELECT A, B, 'foo', 'bar' FROM X data")
       .ExecuteUpdate();
于 2012-08-24T10:19:49.973 回答
1

正如 Frederik Gheysels 已经回答的那样，您应该通过 NHibernate 会话对象创建和保存新实体。如果您要插入很多实体，我建议您使用无状态会话对象来加快速度。

using (IStatelessSession statelessSession = sessionFactory.OpenStatelessSession())
using (ITransaction transaction = statelessSession.BeginTransaction())
{
    foreach (var entity in entities)
        statelessSession.Insert(entity);

    transaction.Commit();
}

这可能不是一个可衡量的改进，具体取决于您插入的数据量。在我当前的项目中，我可以使用无状态会话在不到一秒的时间内批量插入大约 16000 个实体。

于 2012-08-24T12:36:37.807 回答