Dan*_*Dan 5 spring hibernate database-schema hibernate-annotations
看来org.hibernate.cfg.Configuration对象可以通过调用validateSchema方法以编程方式执行验证.但是,此方法需要dialect和databaseMetadata对象.我正在使用Spring,我可以从spring上下文中获取AnnotationSessionFactoryBean对象.到目前为止,我有以下代码:
AnnotationSessionFactoryBean factory = null;
factory = (AnnotationSessionFactoryBean) context.getBean("AnnotationSessionFactory");
Configuration configuration = factory.getConfiguration();
//the following line does not work, ConnectionHelper hierarchy is not visible outside the package
ConnectionHelper connectionHelper =
new ManagedConnectionProviderConnectionHelper(factory.getHibernateProperties());
Dialect dialect = Dialect.getDialect(factory.getHibernateProperties());
Connection connection = null;
DatabaseMetadata databaseMetadata = null;
try {
databaseMetadata = new DatabaseMetadata(connection, dialect);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
configuration.validateSchema(dialect, databaseMetadata);
Run Code Online (Sandbox Code Playgroud)
我是在正确的轨道上吗?ConnectionHelper层次结构在包外不可见,因此我无法以这种方式获取连接对象,以构建databaseMetadata.我该如何实现呢?
编辑:我想我已经取得了一些进展.有一个SchemaValidator类.代码现在看起来像这样:
AnnotationSessionFactoryBean factory = context.getBean("&AnnotationSessionFactory");
Configuration configuration = factory.getConfiguration();
SchemaValidator validator = new SchemaValidator(configuration);
validator.validate();
Run Code Online (Sandbox Code Playgroud)
Howerver,现在我收到以下错误:
org.hibernate.HibernateException:找不到配置的本地DataSource - 必须在LocalSessionFactoryBean上设置'dataSource'属性
最后,当使用 Spring 时,事情就没那么简单了。我设法像这样扩展 AnnotationSessionFactoryBean:
public class SchemaValidatingAnnotationSessionFactoryBean extends
AnnotationSessionFactoryBean {
public void validateDatabaseSchema() throws DataAccessException {
logger.info("Validating database schema for Hibernate SessionFactory");
HibernateTemplate hibernateTemplate = new HibernateTemplate(
getSessionFactory());
hibernateTemplate.setFlushMode(HibernateTemplate.FLUSH_NEVER);
hibernateTemplate.execute(new HibernateCallback() {
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
Connection con = session.connection();
Dialect dialect = Dialect.getDialect(getConfiguration()
.getProperties());
DatabaseMetadata metadata = new DatabaseMetadata(con, dialect);
Configuration configuration = getConfiguration();
configuration.validateSchema(dialect, metadata);
return null;
}
});
}
}
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
6751 次 |
最近记录: |