当通过hibernate在DB中发生任何更新时,lucene索引不会同步

Atu*_*mar 5 lucene hibernate hibernate-search

我正在使用下面的env 在Lucene上进行Hibernate Search的一些POC工作:

  • 休眠的搜索引擎,4.4.2.Final.jar
  • Lucene的核心 - 3.6.2.jar
  • MySQL 5.5
  • @Indexed在域类上使用注释.
  • @Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO)在场上使用.
  • 使用@IndexedEmbedded不同域类的实例集合.

在应用程序启动时进行了显式索引(因为这是在Hibernate Search API中编写的,Hibernate Search将通过Hibernate Core,Hibernate Search Indexing透明地索引每个实体持久化,更新或删除),代码如下:

private static void doIndex() throws InterruptedException {
    Session session = HibernateSearchUtil.getSession();

    FullTextSession fullTextSession = Search.getFullTextSession(session);
    fullTextSession.createIndexer().startAndWait();

    fullTextSession.close();
}
Run Code Online (Sandbox Code Playgroud)

在已经播种的数据库上进行索引和搜索以及通过应用程序中的hibernate核心进行创建和删除操作时,它可以正常工作.

但不是通过Hibernate Core对现有数据进行任何更新操作,因为当通过hibernate搜索进行搜索时,我没有获得更新的数据.

不知道Hibernate Search或lucene是否有问题的原因,意味着索引没有得到更新或者由于没有通过Hibernate Search获得更新结果的其他原因.

用户类:

@Entity
@Table(name = "user")
@Indexed
public class User implements java.io.Serializable {

private static final long serialVersionUID = 5753658991436258019L;
private Integer idUser;

@Field(index = Index.YES, analyze = Analyze.YES, norms = Norms.NO, store = Store.NO)
private String Name;

private Set<UserInfo> userInfos = new HashSet<UserInfo>(0);

public User() {
}

@Id
@GeneratedValue(strategy = IDENTITY)
@Column(name = "iduser", unique = true, nullable = false)
public Integer getIdUser() {
    return idUser;
}

public void setIdUser(Integer idUser) {
    this.idUser = idUser;
}

@Column(name = "name", nullable = false, length = 256)
public String getName() {
    return this.Name;
}

public void setName(String tenantName) {
    this.Name = tenantName;
}

@IndexedEmbedded
@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY, mappedBy = "user")
public Set<UserInfo> getUserInfos() {
    return userInfos;
}

public void setUserInfos(Set<UserInfo> userInfos) {
    this.userInfos = userInfos;
    }
}
Run Code Online (Sandbox Code Playgroud)

UserInfo类:

@Entity
@Table(name = "userInfo")
public class UserInfo implements java.io.Serializable {

private static final long serialVersionUID = 5753658991436258019L;
private Integer iduserInfo;
private User user;
private String address; 

public UserInfo() {
}

@Id
@GeneratedValue(strategy = IDENTITY)
@Column(name = "iduserInfo", unique = true, nullable = false)
public Integer getIduserInfo() {
    return iduserInfo;
}

public void setIduserInfo(Integer iduserInfo) {
    this.iduserInfo = iduserInfo;
}

@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "userId", nullable = false)
public User getUser() {
    return user;
}

public void setUser(User user) {
    this.user = user;
}

@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, norms=Norms.NO)
@Column(name = "address", nullable = false, length = 256)
public String getAddress() {
    return address;
}

public void setAddress(String address) {
    this.address = address;
}
}
Run Code Online (Sandbox Code Playgroud)

小智 0

尝试添加

@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "userId", nullable = false)
@ContainedIn
public User getUser() {
   return user;
}
Run Code Online (Sandbox Code Playgroud)