I have working application using Spring and Hibernate for data access. Lately, I needed to add Hibernate Search. I've wrote service interface, class and bean for search. It always returns empty result. The empty result is normal, since there is not index yet, so I wrote simple utility, that should build initial index. There are just three indexed tables, with less then 20 records in it, but the utility starts to work and doesn't finish, even if it works 20 hours.
I suspect, that there is deadlock because of misconfiguration. I use Spring 3.0.1, hibernate 3.5 and hibernate search 3.2.0.
Can somebody help me with this issue?
Code:
public static void main(String[] args) {
ApplicationContext ctx =
new ClassPathXmlApplicationContext( "applicationContext.xml" );
SessionFactory sessions =
(SessionFactory)ctx.getBean( "sessionFactory" );
Session session = sessions.openSession();
FullTextSession fullTextSession = Search.getFullTextSession( session );
boolean result = false;
System.out.println( "Starting to build Lucene index for Hibernate Search" );
try {
fullTextSession.createIndexer( Company.class
).batchSizeToLoadObjects( 20
).threadsForSubsequentFetching( 8
).threadsToLoadObjects( 4
).cacheMode( CacheMode.NORMAL
).startAndWait();
} catch( Exception e) {
result = false;
}
System.out.println(
result ? "Success" : "Error" +
" building Lucene index for Hibernate Search."
);
//session.close();
//fullTextSession.close();
fullTextSession.getSessionFactory().close();
}
Java code:
Code:
@Entity
@Table(name = "groups", catalog = "onboard")
@Indexed
public class Groups extends HashCodeValidator implements BaseEntity {
/** Serial Version UID. */
private static final long serialVersionUID = -559024055L;
/** Field mapping. */
private Company company;
private String name;
private Set<Role> roles = new HashSet<Role>();
public Groups() {}
public Groups(Long id) { setId( id ); }
public Groups(Long id, String name) { setId( id ); this.name = name; }
@Transient
public Class<?> getClassType() { return Groups.class; }
@Id @GeneratedValue(strategy = GenerationType.AUTO)
@Column( name = "id", nullable = false )
public Long getId() { return super.getId(); }
public void setId(final Long id) { super.setId(id); }
@Column( nullable = false, length = 50 )
@Field(index=Index.TOKENIZED, store=Store.NO)
public String getName() { return this.name; }
public void setName(final String name) { this.name = name; }
@ManyToOne( cascade = { CascadeType.PERSIST, CascadeType.MERGE }, fetch = FetchType.EAGER)
@org.hibernate.annotations.Cascade({org.hibernate.annotations.CascadeType.SAVE_UPDATE})
@JoinColumn(name = "company_id", nullable = true )
@IndexedEmbedded
public Company getCompany() { return this.company; }
public void setCompany(final Company company) { this.company = company; }
@ManyToMany(fetch = FetchType.EAGER, cascade = { CascadeType.ALL })
@JoinTable(name = "group_role", joinColumns = @JoinColumn(name = "group_id"), inverseJoinColumns = @JoinColumn(name = "role_id"))
@IndexedEmbedded
public Set<Role> getRoles() { return this.roles; }
public void setRoles(final Set<Role> roles) {
this.roles = roles;
}
}
@Entity
@Table(name = "role", catalog = "onboard")
@Indexed
public class Role
extends HashCodeValidator implements BaseEntity, Comparable<Role> {
/** Serial Version UID. */
private static final long serialVersionUID = -559024050L;
/** Field mapping. */
private String name;
private Set<View> views = new HashSet<View>();
private Set<ObjectPermission> objectPermissions;
private Set<ObjectEntryPermission> objectEntryPermissions;
public Role() {}
public Role(Long id) { setId(id); }
@Transient
public Class<?> getClassType() { return Role.class; }
@Id @GeneratedValue(strategy = GenerationType.AUTO)
@Column(name = "id", nullable = false)
public Long getId() { return super.getId(); }
public void setId(final Long id) { super.setId(id); }
@Column(length = 45)
@Field(index=Index.TOKENIZED, store=Store.NO)
public String getName() { return this.name; }
public void setName(final String name) { this.name = name; }
@ManyToMany(fetch = FetchType.EAGER, cascade = { CascadeType.ALL })
@JoinTable(name = "view_role", joinColumns = @JoinColumn(name = "role_id"), inverseJoinColumns = @JoinColumn(name = "view_id"))
public Set<View> getViews() { return views; };
public void setViews(Set<View> views) { this.views = views; }
@Override
public int compareTo(Role other) { return name.compareTo(other.getName()); }
...
}
@Entity
@Table(name = "company", catalog = "onboard")
//@Cache(usage = CacheConcurrencyStrategy.READ_WRITE)
@Indexed
public class Company extends HashCodeValidator implements BaseEntity, AuditLog {
/** Serial Version UID. */
private static final long serialVersionUID = -559024059L;
/** Field mapping. */
private String name;
private String displayedName;
private Set<User> users = new HashSet<User>();
private Set<Groups> groupss = new HashSet<Groups>();
private CompanyType type;
private PrefixTimezone timeZone;
public Company() {}
public Company(Long id) { setId( id ); }
@Transient
public Class<?> getClassType() { return Company.class; }
@Id @GeneratedValue(strategy = GenerationType.AUTO)
@Column(name = "id", nullable = false)
public Long getId() { return super.getId(); }
public void setId(final Long id) { super.setId(id); }
@Column(length = 45)
@Field(index=Index.TOKENIZED, store=Store.NO)
public String getName() { return this.name; }
public void setName(String name) { this.name = name; }
@ManyToOne(fetch = FetchType.EAGER)
@JoinColumn(name = "type_id")
public CompanyType getType() { return type; };
public void setType(CompanyType companyType) { this.type = companyType; };
@ManyToOne(fetch = FetchType.EAGER)
@JoinColumn(name = "time_zone_id")
public PrefixTimezone getTimeZone() { return timeZone; }
public void setTimeZone(PrefixTimezone timeZone) { this.timeZone = timeZone; }
/**
* Return the value associated with the column: user.
* @return A Set<User> object (this.user)
*/
@OneToMany(fetch = FetchType.EAGER, cascade = { CascadeType.ALL }, mappedBy = "company")
@org.hibernate.annotations.Cascade( { org.hibernate.annotations.CascadeType.SAVE_UPDATE })
@Column(nullable = false)
public Set<User> getUsers() { return this.users; }
public void addUser(User user) {
user.setCompany(this);
this.users.add(user);
}
public void setUsers(final Set<User> user) { this.users = user; }
public void setDisplayedName(String displayedName) {
this.displayedName = displayedName;
}
@Column(name = "displayed_name")
@Field(index=Index.TOKENIZED, store=Store.NO)
public String getDisplayedName() {
return displayedName;
}
@OneToMany(fetch = FetchType.EAGER, cascade = { CascadeType.PERSIST, CascadeType.MERGE }, mappedBy = "company")
@org.hibernate.annotations.Cascade( { org.hibernate.annotations.CascadeType.SAVE_UPDATE })
@Column(nullable = false)
public Set<Groups> getGroupss() { return this.groupss; }
public void addGroups(Groups groups) {
groups.setCompany(this);
this.groupss.add(groups);
}
public void setGroupss(final Set<Groups> groups) {
this.groupss = groups;
}
}
applicationContext.xml:
Code:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
<!--
You may need to change jdbc.properties properties to adjust parameters
to appropriate values for your application.
-->
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:/jdbc.properties" />
</bean>
<bean id="dataSource"
class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost:3306/onboard?autoReconnect=true" />
<property name="username" value="root" />
<property name="password" value="root" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager" />
<!-- Hibernate SessionFactory -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="schemaUpdate" value="false"/>
<property name="namingStrategy" ref="namingStrategy"/>
<property name="hibernateProperties">
<props>
<prop key="hbm2ddl.auto">validate</prop>
<prop key="show_sql">false</prop>
<prop key="connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</prop>
<prop key="hibernate.max_fetch_depth">1</prop>
<prop key="hibernate.default_batch_fetch_size">4</prop>
<prop key="hibernate.jdbc.fetch_size">5</prop>
<prop key="hibernate.jdbc.batch_size">5</prop>
<prop key="hibernate.cache.use_query_cache">true</prop>
<prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop>
<prop key="hibernate.cache.use_second_level_cache">true</prop>
<prop key="hibernate.search.default.directory_provider">org.hibernate.search.store.FSDirectoryProvider</prop>
<prop key="hibernate.search.default.indexBase">C:\\Lucene</prop>
<prop key="hibernate.search.default.exclusive_index_use">true</prop>
</props>
</property>
<property name="configurationClass">
<value>org.hibernate.cfg.AnnotationConfiguration</value>
</property>
<property name="configLocation">
<value>classpath:hibernate.cfg.xml</value>
</property>
</bean>
<bean id="namingStrategy" class="org.hibernate.cfg.ImprovedNamingStrategy"/>
<!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA) -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
....
</beans>
mappings(hibernate.cfg.xml):
Code:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<mapping class="com.sintecmedia.model.AuditTrail" />
<mapping class="com.sintecmedia.model.PrefixTimezone" />
<mapping class="com.sintecmedia.model.Company" />
<mapping class="com.sintecmedia.model.CompanyType" />
<mapping class="com.sintecmedia.model.Role" />
<mapping class="com.sintecmedia.model.User" />
<mapping class="com.sintecmedia.model.Groups" />
<mapping class="com.sintecmedia.model.View" />
<mapping class="com.sintecmedia.model.Object" />
<mapping class="com.sintecmedia.model.ObjectEntry" />
<mapping class="com.sintecmedia.model.ObjectPermission" />
<mapping class="com.sintecmedia.model.ObjectEntryPermission" />
<listener type="pre-delete"
class="com.sintecmedia.daoimpl.HibernateAuditLogListener" />
<listener type="pre-update"
class="com.sintecmedia.daoimpl.HibernateAuditLogListener" />
<listener type="pre-insert"
class="com.sintecmedia.daoimpl.HibernateAuditLogListener" />
<listener type="pre-load"
class="com.sintecmedia.daoimpl.HibernateAuditLogListener" />
</session-factory>
</hibernate-configuration>
Login
FAQ
Search
