0

私は取得しています

org.hibernate.exception.ConstraintViolationException: Duplicate entry X for key 'PRIMARY'

のせいで

Caused by: com.mysql.jdbc.exceptions.MySQLIntegrityConstraintViolationException: Duplicate entry X for key 'PRIMARY'

私はスレッド化された作業（4つのスレッドで）を行っています。ロジックは次のとおりです。データベースに何かがあるかどうかを（主キーで）確認し、それを取得してオブジェクトを変更するか、そうでない場合は新しいオブジェクトを作成します。問題は、さらに2つのスレッドが同じオブジェクトを使用し、それがデータベースにない場合、両方がそれを作成しようとし、保存すると違反が発生することだと思います。私を困惑させているのは、hashCode メソッドと equals メソッドをオーバーライドしたことです。例外をキャッチしてデータベースにクエリを実行すると、JVM のオブジェクトとデータベースのオブジェクトが等しくなります。例外が発生してはならないということではないですか?

さらに困惑しているのは、データベースにクエリを実行するとnull返されることがあることです。

ロックを作成してから同期しようとしたので、1 つのスレッドが同じ ID のオブジェクトで作業を行っている場合、もう 1 つのスレッドが最初のスレッドを終了させますが、改善されませんでした。

また、次のコードでシナリオを再作成しようとしましたが、問題なく実行されます。

    public static void main(String[] args) throws Exception {
            ThreadPoolExecutor executionPool = new ThreadPoolExecutor(4, 4, 9999, TimeUnit.HOURS, new LinkedBlockingQueue<Runnable>());
            final Dao dao = new Dao();
            TestIdentity t1 = new TestIdentity(1, "aaa", false);
            dao.saveObject(t1);
            TestIdentity t2 = new TestIdentity(1, "aaa", true);
            dao.saveObject(t2);
            dao.saveObject(t1);
            dao.saveObject(t2);
            final Wrapper w1 = new Wrapper(t1);
            final Wrapper w2 = new Wrapper(t2); 
            Runnable runnable1 = new Runnable() {
                public void run() {
                    while(true) {
                        w1.work(dao);
                    }
                }
            };

            Runnable runnable2 = new Runnable() {
                public void run() {
                    while(true) {
                        w2.work(dao);
                    }
                }
            };

            executionPool.submit(runnable1);
            executionPool.submit(runnable2);
        }
private static class Wrapper {
        TestIdentity t;

        public Wrapper(TestIdentity t) {
            this.t = t;
        }
        public void work(Dao dao) {

            TestIdentity t2 = new TestIdentity(t.getId(), t.getField(), t.isBit());

            dao.saveObject(t2);
            t.setBit(true);
            dao.saveObject(t2);
            t.setBit(false);
        }
    }

クラスを使用するもの

@Entity
@Table(name="cycling_scraped.test_identity")
public class TestIdentity {
    int id;
    String field;
    boolean bit;
    public TestIdentity() {
        super();
    }
    public TestIdentity(int id, String field, boolean bit) {
        super();
        this.id = id;
        this.field = field;
        this.bit = bit;
    }
    @Id
    @Column(name="pk_id")
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    @Column(name="field")
    public String getField() {
        return field;
    }
    public void setField(String field) {
        this.field = field;
    }
    @Column(name="bit")
    public boolean isBit() {
        return bit;
    }
    public void setBit(boolean bit) {
        this.bit = bit;
    }
    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + (bit ? 1231 : 1237);
        result = prime * result + ((field == null) ? 0 : field.hashCode());
        result = prime * result + id;
        return result;
    }
    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        TestIdentity other = (TestIdentity) obj;
        if (bit != other.bit)
            return false;
        if (field == null) {
            if (other.field != null)
                return false;
        } else if (!field.equals(other.field))
            return false;
        if (id != other.id)
            return false;
        return true;
    }
    @Override
    public String toString() {
        return "TestIdentity [id=" + id + ", field=" + field + ", bit=" + bit
                + "]";
    }

}

そしてテーブル

CREATE TABLE test_database.test_identity (
    pk_id INT NOT NULL PRIMARY KEY,
    field VARCHAR(100),
    bit BIT
);
4

1 に答える 1

0

コードに同期されたブロック/メソッドが表示されません。

同期アクセスのためにロックされるものはありません。

主キーを指定するか、PKを自動インクリメントフィールドにしないとレコードを追加できないように見えるため、db例外が発生します。それを行った後、ID に @GeneratedValue を追加できます。

于 2012-08-24T13:14:16.500 に答える