Получить следующее значение последовательности из базы данных, используя Hibernate
У меня есть объект, который имеет поле 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 первичных ключей, выбранных из той же последовательности), я получаю все, что мне нужно.
ОДНАКО, Hibernate только выдает 1404 select nextval ('local_key_sequence') команды. ПРИМЕЧАНИЕ. На стороне базы данных для кэширования установлено значение 1.
Если я попытаюсь получить все данные вручную, мне понадобится 70000 выборок, таким образом, огромная разница в производительности. Кто-нибудь знает внутреннее функционирование Hibernate и как его воспроизвести вручную?
9 ответов
Я нашел решение:
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() ;
}
}
Вы можете использовать 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;
}
}
Вот что у меня сработало (специфично для 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
Если вы используете 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;
Чтобы получить новый идентификатор, все, что вам нужно сделать, это 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();
}
}
Spring 5 имеет для этого несколько встроенных вспомогательных классов:org / springframework / jdbc / support / incrementer
Вот как я это делаю:
@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);
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();
Интересно, это работает для вас. Когда я попробовал ваше решение, возникла ошибка: "Несоответствие типов: невозможно преобразовать 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 + ")");
Ваша идея с поддельной сущностью 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 я вызываю метод сохранения в SequenceRepository.
SequenceGenerator sequenceObject = new SequenceGenerator (); SequenceGenerator result = sequenceRepository.save (sequenceObject);
Если есть лучший способ сделать это (возможно, поддержка генератора для любого типа поля вместо просто Id), я был бы более чем рад использовать его вместо этого "трюка".