0

Здравствуйте. Я пишу программу на java с использованием Hibernate. нижеприведенный код, должен обращается 1 раз в несколько секунд к таблице, чтобы проверить, не появились ли там новые данные с колонкой state = 0.

class Dao {
    public List<MyTable> getNewRows() throws Exception {
        Session session = null;
        List<MyTable> result;
        try {
            session = HibernateUtil.getSessionFactory().openSession();
            result = session.createQuery("from MyTable where state = 0 ").list();
        } catch (Exception e) {
            throw e;
        } finally {
            session.close();
        }
        return result;
    }
}

Работать должно так: я выставляю некоторым строкам в таблице сторонней программой state = 0 и метод должен их подхватить, ведь он вызывается в цикле, с задержкой в 3 секунды. Но метод подхватывает только те строки , которым был выставлен статус 0 до запуска программы, если же выставлять статусы во время работы программы, то метод больше ничего не "цепляет", то есть он не видит, что появились новые строки со статусом 0.

Я попробовал вместо Session использовать StatelessSession, и пробовал после HQL запроса дописывать session.setCacheMode(CacheMode.IGNORE), но не помогло.

вот util

public class HibernateUtil {

private static SessionFactory sessionFactory;

public static SessionFactory getSessionFactory() {

    if (sessionFactory == null) {
        // loads configuration and mappings
        Configuration configuration = new Configuration().configure();
        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(configuration.getProperties()).build();
        // builds a session factory from the service registry
        sessionFactory = configuration.buildSessionFactory(serviceRegistry);
    }
    return sessionFactory;

}

}

вот cfg

   <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/db</property>
    <property name="hibernate.connection.username">login</property>
    <property name="hibernate.connection.password">pass</property>

Кроме этих строк в cfg Ничего больше нет.

Помогите разобраться почему так происходит.

8
  • Покажите как выглядит цикл, который это делает? Возможно вы все делаете в одной транзакции для бд. Включите логгирование hql в лог, покажите что там выходит.
    – flybox
    14 июл 2016 в 10:08
  • java.io.InvalidClassException: com.firmname.hibernate.entities.MyTable; local class incompatible: stream classdesc serialVersionUID = -5930977514948150750, local class serialVersionUID = 6205997936559234017 вот что пишет логгер
    – fantastic
    14 июл 2016 в 10:17
  • извиняюсь, то старая запись, 4-ех часовой давности. А нового ничего нет, лог молчит.
    – fantastic
    14 июл 2016 в 10:24
  • в настройках hibernate есть такая функция hibernate.show_sql = false, поставьте ее в true, посмотрите падают ли в лог функции подбора. Заходит ли вообще в цикл раз в 3 секунды?
    – flybox
    14 июл 2016 в 12:32
  • Посмотрите в sessionFactory возможно ли использовать getCurrentSession? sessionFactory самостоятельно отвечает за управлением сессиями.
    – flybox
    14 июл 2016 в 12:35

1 ответ 1

1

Разобрался со своей проблемой.
Если кратко, то помогла замена метода openSession() на getCurrentSession() и commit в конце запроса.

А вот так если все целиком :

В hibernate.cfg.xml добавляем такую строчку.

<property name="hibernate.current_session_context_class">thread</property>

А Dao теперь выглядит так

     class Dao {
        public List<MyTable> getNewRows() throws Exception {                      
           Session session = HibernateUtil.getSessionFactory().getCurrentSession();
           session.getTransaction().begin();
           List<MyTable> result = session.createQuery("from MyTable where state = 0 ").list();
           session.getTransaction().commit();       
           return result;
        }
    }

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.