3

JPA2メタデータを使用して、データベースから行を挿入/削除する順序を把握しようとしているため、制約は問題になりません(後でJavaコードで使用されます)。これは、JPA を使用したバックアップ/復元アプローチの一部です。

これが私のアプローチです:

  1. 関係/制約の量によってテーブルをグループ化します (1 対多と 1 対 1 のみが考慮されます)
  2. インスタンスがゼロのテーブル (#1 による) では、問題なくレコードを追加/削除できます
  3. 1 つのインスタンスを持つテーブルは、関連するテーブルが既に「準備完了」である限り、問題なくレコードを追加/削除できます。

Ready by Ready とは、関連するすべてのテーブル レコードにデータが入力されているため、外部キーが挿入に有効であるか、このテーブル内のレコードを参照するテーブルが他にないことを意味します。

ある種の再帰的アプローチになると確信していますが、行き詰まりました。どんな助けも大歓迎です。

これまでのコードは次のとおりです。

/**
 * Get the execution order from the EntityManager meta data model.
 *
 * This will fail if the EntityManager is not JP2 compliant
 * @param em EntityManager to get the metadata from
 * @return ArrayList containing the order to process tables
 */
protected static ArrayList<String> getProcessingOrder(EntityManager em) {
    ArrayList<String> tables = new ArrayList<String>();
    //This holds the amount of relationships and the tables with that same amount
    HashMap<Integer, ArrayList<String>> tableStats = new HashMap<Integer, ArrayList<String>>();
    //This holds the table and the tables referenced by it
    HashMap<String, ArrayList<String>> references = new HashMap<String, ArrayList<String>>();
    for (EntityType et : em.getMetamodel().getEntities()) {
        Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER, et.getName());
        int amount = 0;
        Iterator<SingularAttribute> sIterator = et.getSingularAttributes().iterator();
        while (sIterator.hasNext()) {
            SingularAttribute next = sIterator.next();
            switch (next.getPersistentAttributeType()) {
                case BASIC:
                case ELEMENT_COLLECTION:
                case EMBEDDED:
                case ONE_TO_MANY:
                case ONE_TO_ONE:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER,
                            "Ignoring: {0}", next.getName());
                    break;
                case MANY_TO_MANY:
                case MANY_TO_ONE:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.INFO,
                            "{3} has a {2} relationship: {0} with: {1}",
                            new Object[]{next.getName(), next.getBindableJavaType(),
                                next.getPersistentAttributeType().name(), et.getName()});
                    if (!references.containsKey(et.getName())) {
                        references.put(et.getName(), new ArrayList<String>());
                    }
                    references.get(et.getName()).add(next.getBindableJavaType().getSimpleName());
                    amount++;
                    break;
                default:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.SEVERE,
                            "Unexpected value: {0}", next.getName());
                    break;
            }
        }
        Iterator<PluralAttribute> pIterator = et.getPluralAttributes().iterator();
        while (pIterator.hasNext()) {
            PluralAttribute next = pIterator.next();
            switch (next.getPersistentAttributeType()) {
                case BASIC:
                case ELEMENT_COLLECTION:
                case EMBEDDED:
                case ONE_TO_MANY:
                case MANY_TO_MANY:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER,
                            "Ignoring: {0}", next.getName());
                    break;
                case MANY_TO_ONE:
                case ONE_TO_ONE:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.INFO,
                            "{3} has a {2} relationship: {0} with: {1}",
                            new Object[]{next.getName(), next.getBindableJavaType(),
                                next.getPersistentAttributeType().name(), et.getName()});
                    if (!references.containsKey(et.getName())) {
                        references.put(et.getName(), new ArrayList<String>());
                    }
                    references.get(et.getName()).add(next.getBindableJavaType().getSimpleName());
                    amount++;
                    break;
                default:
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.SEVERE,
                            "Unexpected value: {0}", next.getName());
                    break;
            }
        }
        if (!tableStats.containsKey(amount)) {
            tableStats.put(amount, new ArrayList<String>());
        }
        tableStats.get(amount).add(et.getName());
    }
    Iterator<String> iterator = references.keySet().iterator();
    while (iterator.hasNext()) {
        String next = iterator.next();
        Iterator<String> iterator1 = references.get(next).iterator();
        StringBuilder refs = new StringBuilder();
        while (iterator1.hasNext()) {
            refs.append(iterator1.next()).append("\n");
        }
        Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER, "References for {0}:\n{1}", new Object[]{next, refs.toString()});
    }
    //Need to sort entities with relationships even further
    ArrayList<String> temp = new ArrayList<String>();
    for (Entry<Integer, ArrayList<String>> e : tableStats.entrySet()) {
        if (e.getKey() > 0) {
            Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.INFO, "Tables with {0} references", e.getKey());
            for (String t : e.getValue()) {
                //Check the relationships of the tables
                //Here's where I need help
                boolean ready = true;
                for (String ref : references.get(t)) {
                    if (!temp.contains(ref)) {
                        Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.INFO,
                                "{0} is not ready. Referenced table {1} is not ready yet", new Object[]{t, ref});
                        ready = false;
                    }
                }
                if (ready) {
                    Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.INFO, "{0} is ready.", t);
                    temp.add(t);
                }
            }
            //-------------------------------------------------------
        } else {
            temp.addAll(e.getValue());
        }
    }
    for (Entry<Integer, ArrayList<String>> e : tableStats.entrySet()) {
        Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER,
                "Amount of relationships: {0}", e.getKey());
        StringBuilder list = new StringBuilder();
        for (String t : e.getValue()) {
            list.append(t).append("\n");
        }
        Logger.getLogger(XincoBackupManager.class.getSimpleName()).log(Level.FINER, list.toString());
    }
    tables.addAll(temp);
    return tables;
}
4

1 に答える 1

1

JDBC のデータベース メタデータを使用して、この問題に取り組みます。

ここでは、 java.sql.DatabaseMetadataの次のメソッドを使用します。

// to get the tables
getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types) 

// to get the reference to the table
public ResultSet getExportedKeys(String catalog,
                                 String schema,
                                 String table)
                          throws SQLException

私はいくつかのアプリケーションでこのアプローチを使用しましたが、非常にうまく機能します。

このアプローチは JPA メタモデルの使用法には従いませんが、問題を考えると、JDBC メタデータ レベルで操作する方が適切だと思います。

このような外部キー依存関係グラフを介して処理するのが難しい循環依存関係が存在する可能性があるため、代わりに次のことができます。

削除用

  • 制約を無効にする
  • コンテンツを削除する
  • 制約を有効にする

追加用

  • 制約を無効にする
  • コンテンツを追加
  • 制約を有効にする
于 2010-07-21T12:28:11.923 に答える