Java JPA/Hibernate with SQL Server-如何检测数据库中的列何时未按实体模型映射？

Question

我有一个使用JPA/Hibernate映射实体的Spring webapp，它可以很好地执行所有正常任务，例如CRUD操作。

我还能够检测模型中的字段何时不在数据库中（hibernate抛出“无效列名”）。

我的问题是，当数据库中有未由模型表示的新列时，我现在需要检测并提醒用户。

这样做的原因是应用程序应始终使用户能够设置/查看数据库中存在的所有字段，而不是在没有通知的情况下透明地忽略可用字段。

有没有一种简单的方法可以使用JPA/Hibernate

1. 如果数据库中有新的未映射列，则引发错误，或
2. 是否手动检查所有列是否已记帐

如果没有简单的方法，我想我可以查询informathtml" target="_blank">ion\u模式，但如果可能的话，我希望避免这种情况。

提前感谢！

Answer 1

你可以这样做（没有查询元数据，我想是不可能的），你可以在每个“x”时间内将其作为作业运行。

public void printMetadata() {
    Set<String> dbColumns = new HashSet<>();
    Set<String> entityProperties = null;
    sessionFactory.getCurrentSession().doWork(new Work() {
        @Override
        public void execute(Connection connection) throws SQLException {
        //**Post** is EntityClass with `@Table` & `@Entity` annotated.               
        ResultSet resultSet =  connection.getMetaData().getColumns(null, null,
                    Post.class.getDeclaredAnnotation(Table.class).name(), null);
            while (resultSet.next()) {
                dbColumns.add(resultSet.getString("COLUMN_NAME"));
            }
        }
    });

    ClassMetadata classMetadata = sessionFactory.getClassMetadata(Post.class);
    entityProperties = new HashSet<>(Arrays.asList(classMetadata.getPropertyNames()));

    if (entityProperties.size() != dbColumns.size()) {
        //Throw Error.
        //Else, you can compare ColumnName with Property using some pattern.
    }
}

Answer 2

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

因此，您必须付出艰苦的努力，并手动检查：

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();
      }
    }
  }
});