0

休止状態 の Java フレームワークを使用して、 Integerの代わりにAtomicInteger変数を持つオブジェクトを永続化しようとしましたが(オブジェクトを保存した後、スレッド セーフなシナリオでオブジェクトを使用する必要があります)、オブジェクトを保存しようとすると、Java がスローします。

java.lang.ClassCastException: java.util.concurrent.atomic.AtomicInteger cannot be cast to java.lang.Integer

AtomicInteger を整数にマップする方法はありますか? オブジェクトの例があります:

public class Statistics implements java.io.Serializable {
  private AtomicInteger id;
  private AtomicInteger totalErrors;

  public Statistics() {
  }


  public AtomicInteger getTotalErrors() {
    return this.totalErrors;
  }

  public void seTotalErrors(AtomicInteger totalErrors) {
    this.totalErrors= totalErrors;
  }
}

そして、それぞれの POJO xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
   <class name="Statistics" table="statistics" catalog="example" optimistic-lock="version">
      <id name="id" type="java.lang.Integer">
         <column name="id" />
         <generator class="identity" />
      </id>
      <property name="totalErrors" type="java.lang.Integer">
         <column name="total_errors" />
      </property>
   </class>
</hibernate-mapping>

そして休止状態のバージョンがあります:

    <dependency>
        <groupId>org.hibernate</groupId>
        <artifactId>hibernate-core</artifactId>
        <version>5.2.10.Final</version>
    </dependency>
    <dependency>
        <groupId>org.hibernate</groupId>
        <artifactId>hibernate-hikaricp</artifactId>
        <version>5.2.10.Final</version>
    </dependency>
4

2 に答える 2

3

それを行う 1 つの方法は、以下のように Integer から AtomicInteger に変換する JPA 2.1 AttributeConverterを作成することです。

@Converter
public class AtomicIntConverter implements AttributeConverter<AtomicInteger, Integer> {


 @Override
 public Integer convertToDatabaseColumn(AtomicInteger attribute) {
  return attribute.get();
 }

 @Override
 public AtomicInteger convertToEntityAttribute(Integer dbData) {
  return new AtomicInteger(dbData);
 }

}

通常は、次のようにクラス フィールドで JPA@Convertアノテーションを使用できます。@Entity

@Convert(converter = AtomicIntConverter.class)
private AtomicInteger totalErrors;

詳細については、Hibernate 5.2 のドキュメント (こちら) を参照してください。

@Converterただし、休止状態のマッピング ファイルを使用しているため、注釈を使用する代わりに、Converter クラスの FQN をフィールドの型として設定してください。

<property name="totalErrors" type="fully.qualified.name.of.AtomicIntConverter">
     <column name="total_errors" />
 </property>
于 2017-09-12T11:04:35.223 に答える
0

最後に、より良い解決策 (より標準的な hibernate コンバーターhttps://docs.jboss.org/hibernate/orm/4.2/manual/en-US/html/ch06.htmlであるため) は、hibernate UserType クラスを作成することです。AttributeConverter が機能しないため、理由がわかりません(休止状態のドキュメントにあるため)。

これは私の場合、Hibernate 5.2 で動作します。hibernate UserType を実装する AtomicIntegerType を作成します。

import java.io.Serializable;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Logger;
import org.hibernate.HibernateException;
import org.hibernate.engine.spi.SharedSessionContractImplementor;
import org.hibernate.usertype.UserType;

public class AtomicIntegerType implements UserType {

    private static final Logger logger = Logger.getLogger("AtomicInteger");

    /**
     * Returns the object from the 2 level cache
     */
    @Override
    public Object assemble(final Serializable cached, final Object owner)
            throws HibernateException {
        //would work as the AtomicInteger.class is Serializable, 
        //and stored in cache as it is - see disassemble
        return cached;
    }

    /**
     * Used to create Snapshots of the object
     */
    @Override
    public Object deepCopy(Object value) throws HibernateException {
        //return value; -> if AtomicInteger.class was immutable we could return the object as it is
        final AtomicInteger recievedParam = (AtomicInteger) value;
        final AtomicInteger atomicInteger = new AtomicInteger(recievedParam.get());
        return atomicInteger;
    }

    /**
     * method called when Hibernate puts the data in a second level cache. The
     * data is stored in a serializable form
     */
    @Override
    public Serializable disassemble(final Object value) throws HibernateException {
        //For this purpose the AtomicInteger.class must implement serializable
        return (Serializable) value;
    }

    /**
     * Used while dirty checking - control passed on to the
     * {@link AtomicInteger}
     */
    @Override
    public boolean equals(final Object o1, final Object o2) throws HibernateException {
        boolean isEqual = false;
        if (o1 == o2) {
            isEqual = true;
        }
        if (null == o1 || null == o2) {
            isEqual = false;
        } else {
            isEqual = o1.equals(o2);
        }
        return isEqual;
        //for this to work correctly the equals() 
        //method must be implemented correctly by AtomicInteger class
    }

    @Override
    public int hashCode(final Object value) throws HibernateException {
        return value.hashCode();
        //for this to work correctly the hashCode() 
        //method must be implemented correctly by AtomicInteger class

    }

    /**
     * Helps hibernate apply certain optimizations for immutable objects
     */
    @Override
    public boolean isMutable() {
        return true; //The audit fields can be modified
    }

    /**
     * This method retrieves the property value from the JDBC resultSet
     */
    @Override
    public Object nullSafeGet(ResultSet resultSet, String[] names, SharedSessionContractImplementor ssci, Object owner) throws HibernateException, SQLException {
        //owner here is class from where the call to retrieve data was made.
        //In this case the Test class
        AtomicInteger atomicInteger = null;
        if (!resultSet.wasNull()) {
            atomicInteger = new AtomicInteger(resultSet.getInt(names[0]));            
        }
        return atomicInteger;
    }

    /**
     * The method writes the property value to the JDBC prepared Statement
     *
     */
    @Override
    public void nullSafeSet(final PreparedStatement statement,
            final Object value, final int index, SharedSessionContractImplementor ssci) throws HibernateException,
            SQLException {
        if (null == value) {
            statement.setNull(index, java.sql.Types.INTEGER);
        } else {
            AtomicInteger atomicInteger = (AtomicInteger) value;
            if (null != atomicInteger) {
                statement.setInt(index , atomicInteger.get());
            } else {
                statement.setNull(index, java.sql.Types.INTEGER);
            }

        }
    }

    /**
     * Method used by Hibernate to handle merging of detached object.
     */
    @Override
    public Object replace(final Object original, final Object target,
            final Object owner)
            throws HibernateException {
        //return original; // if immutable use this
        //For mutable types at bare minimum return a deep copy of first argument
        return this.deepCopy(original);

    }

    /**
     * Method tells Hibernate which Java class is mapped to this Hibernate Type
     */
    @SuppressWarnings("rawtypes")
    @Override
    public Class returnedClass() {
        return AtomicInteger.class;
    }

    /**
     * Method tells Hibernate what SQL columns to use for DDL schema generation.
     * using the Hibernate Types leaves Hibernate free to choose actual SQl
     * types based on database dialect. (Alternatively SQL types can also be
     * used directly)
     */
    @Override
    public int[] sqlTypes() {
        //createdBy, createdDate,modifiedBy,modifiedDate
        return new int[]{java.sql.Types.INTEGER};
    }

}

また、休止状態のマッピング ファイルで、次のように Integer を AtomicIntegerType に変更します。

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<!-- Generated 12-sep-2017 13:14:50 by Hibernate Tools 4.3.1 -->
<hibernate-mapping>
   <class name="classs.location.Statistics" table="statistics" catalog="CATALOG" optimistic-lock="version">
      <id name="id" type="java.lang.Integer">
         <column name="id" />
         <generator class="identity" />
      </id>
      <property name="totalErrors" type="class.location.AtomicIntegerType">
         <column name="total_errors" />
      </property>
   </class>
</hibernate-mapping>
于 2017-09-18T11:16:49.760 に答える