使用SQL Server的Java JPA / Hibernate – 如何检测db中的列何时未被实体模型映射？

我有一个使用JPA / Hibernate映射实体的Spring webapp,这可以很好地完成所有正常任务,例如： CRUD操作.我还能够检测到模型中的某个字段何时不存在于数据库中(hibernate会抛出“无效的列名”).我的问题是,当数据库中...

我有一个使用JPA / Hibernate映射实体的Spring webapp,这可以很好地完成所有正常任务,例如： CRUD操作.

我还能够检测到模型中的某个字段何时不存在于数据库中(hibernate会抛出“无效的列名”).

我的问题是,当数据库中有新的列没有被模型表示时,我现在需要检测并警告用户.

这样做的原因是应用程序应始终允许用户设置/查看数据库中存在的所有字段,而不是透明地忽略没有通知的可用字段.

是否有一种直接的方式来使用JPA / Hibernate

>如果数据库中有新的未映射列,则抛出错误,或者
>手动检查所有列是否已计入？

如果没有简单的方法,我想我可以查询information_schema,但我想尽可能避免这种情况.

提前致谢！

解决方法:

如果您正在搜索类似的内容,则没有这样的hbm2ddl.auto选项.例如,update只会检查映射列并忽略其他列 – 至少它不会删除它们.

所以你必须努力工作并手工检查：

SessionFactoryImplementor sessionFactory = (SessionFactoryImplementor) ((Session) this.em.getDelegate()).getSessionFactory();

// Find all mapped tables with all mapped columns
final Map<String, Set<String>> tableColumns = new HashMap<>();

for (ClassMetadata metadata : sessionFactory.getAllClassMetadata().values()) {
  AbstractEntityPersister persister = (AbstractEntityPersister) metadata;
  Set<String> columns = new HashSet<>();
  tableColumns.put(persister.getTableName(), columns);
  for (String propertyName : persister.getPropertyNames()) {
    for (String propertyColumnName : persister.getPropertyColumnNames(propertyName)) {
      columns.add(propertyColumnName);
    }
  }
}

for (CollectionMetadata metadata : sessionFactory.getAllCollectionMetadata().values()) {
  AbstractCollectionPersister persister = (AbstractCollectionPersister) metadata;
  // ... extract key, index and element columns from persister, similar to AbstractEntityPersister
}

// Compare columns with existing metadata
sessionFactory.getCurrentSession().doWork(new Work() {
  public void execute(Connection connection) throws SQLException {
    for (Map.Entry<String, Set<String>> entry : tableColumns.entrySet()) {
      String tableName = entry.getKey();
      ResultSet rs = connection.getMetaData().getColumns(null, null, tableName, null);
      try {
        while (rs.next()) {
          String columnName = resultSet.getString("COLUMN_NAME");
          if (!entry.getValue().remove(columnName)) {
            log.error("Column not mapped: {}.{}", tableName, columnName));
          }
        }
        if (!entry.getValue().isEmpty()) {
          log.error("Columns not defined: {}.{}", tableName, entry.getValue()));
        }
      } finally {
        rs.close();
      }
    }
  }
});