получить следующее значение последовательности из базы данных, используя Hibernate

Question

У меня есть объект, который имеет поле NON-ID, которое должно быть установлено из последовательности.В настоящее время я выбираю первое значение последовательности, сохраняю его на стороне клиента и вычисляю из этого значения.

Однако я ищу «лучший» способ сделать это.Я реализовал способ получения следующего значения последовательности:

public Long getNextKey()
{
    Query query = session.createSQLQuery( "select nextval('mySequence')" );
    Long key = ((BigInteger) query.uniqueResult()).longValue();
    return key;
}

Однако этот способ значительно снижает производительность (создание ~ 5000 объектов замедляется в 3 раза - с 5740 до 13648 мс).

Я попытался добавить «поддельную» сущность:

@Entity
@SequenceGenerator(name = "sequence", sequenceName = "mySequence")
public class SequenceFetcher
{
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "sequence")
    private long                      id;

    public long getId() {
        return id;
    }
}

Однако этот подход тоже не сработал (все возвращенные идентификаторы были 0).

Можеткто-то посоветует мне, как эффективно извлечь следующее значение последовательности, используя Hibernate?

Редактировать: После исследования я обнаружил, что вызов Query query = session.createSQLQuery( "select nextval('mySequence')" ); гораздо более неэффективен, чем использование @GeneratedValue- из-за Hibernate каким-то образом удается уменьшить количество выборок при доступе к последовательности, описанной @GeneratedValue.

Например, когда я создаю 70000 сущностей (то есть с 70000 первичных ключей, выбранных из той же последовательности), я получаю все, что мне нужно.

HOWEVER , только Hibernateвыдает 1404 select nextval ('local_key_sequence') команд.ПРИМЕЧАНИЕ. На стороне базы данных значение кэширования равно 1.

. Если я попытаюсь извлечь все данные вручную, мне потребуется 70 000 операций выбора, таким образом огромная разница в производительности.Кто-нибудь знает внутреннее функционирование Hibernate и как его воспроизвести вручную?

Answer 1

Вот что сработало для меня (специфично для Oracle, но использование scalar кажется ключевым)

Long getNext() {
    Query query = 
        session.createSQLQuery("select MYSEQ.nextval as num from dual")
            .addScalar("num", StandardBasicTypes.BIG_INTEGER);

    return ((BigInteger) query.uniqueResult()).longValue();
}

Благодаря постерам здесь: springsource_forum

Answer 2

Вы можете использовать Hibernate Dialect API для независимости базы данных следующим образом

class SequenceValueGetter {
    private SessionFactory sessionFactory;

    // For Hibernate 3
    public Long getId(final String sequenceName) {
        final List<Long> ids = new ArrayList<Long>(1);

        sessionFactory.getCurrentSession().doWork(new Work() {
            public void execute(Connection connection) throws SQLException {
                DialectResolver dialectResolver = new StandardDialectResolver();
                Dialect dialect =  dialectResolver.resolveDialect(connection.getMetaData());
                PreparedStatement preparedStatement = null;
                ResultSet resultSet = null;
                try {
                    preparedStatement = connection.prepareStatement( dialect.getSequenceNextValString(sequenceName));
                    resultSet = preparedStatement.executeQuery();
                    resultSet.next();
                    ids.add(resultSet.getLong(1));
                }catch (SQLException e) {
                    throw e;
                } finally {
                    if(preparedStatement != null) {
                        preparedStatement.close();
                    }
                    if(resultSet != null) {
                        resultSet.close();
                    }
                }
            }
        });
        return ids.get(0);
    }

    // For Hibernate 4
    public Long getID(final String sequenceName) {
        ReturningWork<Long> maxReturningWork = new ReturningWork<Long>() {
            @Override
            public Long execute(Connection connection) throws SQLException {
                DialectResolver dialectResolver = new StandardDialectResolver();
                Dialect dialect =  dialectResolver.resolveDialect(connection.getMetaData());
                PreparedStatement preparedStatement = null;
                ResultSet resultSet = null;
                try {
                    preparedStatement = connection.prepareStatement( dialect.getSequenceNextValString(sequenceName));
                    resultSet = preparedStatement.executeQuery();
                    resultSet.next();
                    return resultSet.getLong(1);
                }catch (SQLException e) {
                    throw e;
                } finally {
                    if(preparedStatement != null) {
                        preparedStatement.close();
                    }
                    if(resultSet != null) {
                        resultSet.close();
                    }
                }

            }
        };
        Long maxRecord = sessionFactory.getCurrentSession().doReturningWork(maxReturningWork);
        return maxRecord;
    }

}

Answer 3

Я нашел решение:

public class DefaultPostgresKeyServer
{
    private Session session;
    private Iterator<BigInteger> iter;
    private long batchSize;

    public DefaultPostgresKeyServer (Session sess, long batchFetchSize)
    {
        this.session=sess;
        batchSize = batchFetchSize;
        iter = Collections.<BigInteger>emptyList().iterator();
    }

        @SuppressWarnings("unchecked")
        public Long getNextKey()
        {
            if ( ! iter.hasNext() )
            {
                Query query = session.createSQLQuery( "SELECT nextval( 'mySchema.mySequence' ) FROM generate_series( 1, " + batchSize + " )" );

                iter = (Iterator<BigInteger>) query.list().iterator();
            }
            return iter.next().longValue() ;
        }

}

Answer 4

Если вы используете Oracle, рассмотрите возможность указания размера кэша для последовательности. Если вы обычно создаете объекты в пакетах по 5 КБ, вы можете просто установить его на 1000 или 5000. Мы сделали это для последовательности, используемой для суррогатного первичного ключа, и были удивлены, что время выполнения процесса ETL, написанного от руки на Java, упало пополам.

Я не могу вставить отформатированный код в комментарий. Вот последовательность DDL:

create sequence seq_mytable_sid 
minvalue 1 
maxvalue 999999999999999999999999999 
increment by 1 
start with 1 
cache 1000 
order  
nocycle;

Answer 5

Чтобы получить новый идентификатор, все, что вам нужно сделать, это flush менеджер сущностей. См. getNext() метод ниже:

@Entity
@SequenceGenerator(name = "sequence", sequenceName = "mySequence")
public class SequenceFetcher
{
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "sequence")
    private long id;

    public long getId() {
        return id;
    }

    public static long getNext(EntityManager em) {
        SequenceFetcher sf = new SequenceFetcher();
        em.persist(sf);
        em.flush();
        return sf.getId();
    }
}

Answer 6

Интересно, это работает для вас.Когда я попробовал ваше решение, возникла ошибка: «Несоответствие типов: невозможно преобразовать SQLQuery в Query».-> Поэтому мое решение выглядит так:

SQLQuery query = session.createSQLQuery("select nextval('SEQUENCE_NAME')");
Long nextValue = ((BigInteger)query.uniqueResult()).longValue();

С этим решением я не столкнулся с проблемами производительности.

И не забудьте сбросить значение, если вы просто хотелизнать в информационных целях.

    --nextValue;
    query = session.createSQLQuery("select setval('SEQUENCE_NAME'," + nextValue + ")");

Answer 7

POSTGRESQL

String psqlAutoincrementQuery = "SELECT NEXTVAL(CONCAT(:psqlTableName, '_id_seq')) as id";

Long psqlAutoincrement = (Long) YOUR_SESSION_OBJ.createSQLQuery(psqlAutoincrementQuery)
                                                      .addScalar("id", Hibernate.LONG)
                                                      .setParameter("psqlTableName", psqlTableName)
                                                      .uniqueResult();

MYSQL

String mysqlAutoincrementQuery = "SELECT AUTO_INCREMENT as id FROM information_schema.tables WHERE table_name = :mysqlTableName AND table_schema = DATABASE()";

Long mysqlAutoincrement = (Long) YOUR_SESSION_OBJ.createSQLQuery(mysqlAutoincrementQuery)
                                                          .addScalar("id", Hibernate.LONG)
                                                          .setParameter("mysqlTableName", mysqlTableName)                                                              
                                                          .uniqueResult();

Answer 8

Spring 5 имеет несколько встроенных вспомогательных классов для этого: орг / springframework / JDBC / поддержка / инкрементора

Answer 9

Ваша идея с поддельной сущностью SequenceGenerator хороша.

@Id
@GenericGenerator(name = "my_seq", strategy = "sequence", parameters = {
        @org.hibernate.annotations.Parameter(name = "sequence_name", value = "MY_CUSTOM_NAMED_SQN"),
})
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "my_seq")

Важно использовать параметр с именем ключа "sequence_name".Запустите сеанс отладки в спящем классе SequenceStyleGenerator, метод configure (...) в строке final QualifiedName sequenceName = defineSequenceName (params, dialect, jdbcEnvironment);чтобы увидеть больше деталей о том, как имя последовательности вычисляется Hibernate.Там есть некоторые значения по умолчанию, которые вы также можете использовать.

После создания поддельной сущности я создал CrudRepository:

public interface SequenceRepository extends CrudRepository<SequenceGenerator, Long> {}

В Junit я вызываю метод save для SequenceRepository.

SequenceGenerator sequenceObject = new SequenceGenerator ();SequenceGenerator result = sequenceRepository.save (sequenceObject);

Если есть лучший способ сделать это (возможно, поддержка генератора для любого типа поля вместо просто Id), я был бы более чем рад использоватьэто вместо этого "трюка".

Answer 10

Вот как я это делаю:

@Entity
public class ServerInstanceSeq
{
    @Id //mysql bigint(20)
    @SequenceGenerator(name="ServerInstanceIdSeqName", sequenceName="ServerInstanceIdSeq", allocationSize=20)
    @GeneratedValue(strategy=GenerationType.SEQUENCE, generator="ServerInstanceIdSeqName")
    public Long id;

}

ServerInstanceSeq sis = new ServerInstanceSeq();
session.beginTransaction();
session.save(sis);
session.getTransaction().commit();
System.out.println("sis.id after save: "+sis.id);