EJB UserTransaction / Java

ReSQL.ru

Мобильная версия Контакт Правила FAQ Помощь

Гость

Войти | Регистрация | Профиль | Очистить

Новые сообщения | Избранное

Форумы | Пользователи | Статистика | Мод. лог | Поиск

Цитировать

Написать

Автор*:

Ввести пароль для входа

Тема*:

Сообщение

Данное сообщение тематическое

Сообщение содержит картинки или видео 18+

Автор:

ВНИМАНИЕ! На данном подфоруме действуют строгие правила. Удостоверьтесь, что ваше сообщение соответствует им!

Форум или тема закрыты для гостей. Необходима авторизация!

Загрузить последнюю сохраненную версию

Вложение:

Вставить как галерею

Максимальный размер вложений: 4,0 МБ, аудио/видео: 8,0 МБ. Картинки большего размера ужимаются, если возможно.

Введите код, изображенный на картинке. Если код нечитаемый, кликните картинку, чтобы загрузить другой вариант.

Отправляя сообщение, я выражаю свое согласие с правилами форума и принимаю пользовательское соглашение.

Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр

Форумы / Java [игнор отключен] [закрыт для гостей] / EJB UserTransaction

11 сообщений из 11, страница 1 из 1

EJB UserTransaction

#38191691

serega063

Гость

Здравствуйте, помогите разобраться с транзакциями

Есть класс

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.

@Stateless(name = Loader.JNDI_NAME)
@Remote(Loader.class)
@TransactionManagement(value = TransactionManagementType.BEAN)
public class LoaderBean extends AbstractLoaderBean implements Loader {
    @Override
    public List loadReports(UUID uuid, DateTime beginDate, DateTime endDate) {
        UserTransaction utx = null;
        
        try {
            InitialContext ctx = new InitialContext();
            utx = (UserTransaction) ctx.lookup("UserTransaction");
            utx.begin();
            int status = utx.getStatus(); //0
        } catch (NamingException e) {
            e.printStackTrace(); 
        } catch (NotSupportedException e) {
            e.printStackTrace(); 
        } catch (SystemException e) {
            e.printStackTrace(); 
        }


        try {                    
            deleteQuery.executeUpdate(); // ТУТ вылетает ошибка javax.persistence.TransactionRequiredException: Executing an update/delete query
            code = insertQuery.executeUpdate();

            utx.commit();                      
        } catch (Exception e) {
            utx.rollback();
            
        }

    }


}

persistence.xml

Код: xml

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/persistence" xsi:schemalocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
    <persistence-unit name="PersistenceCore" transaction-type="JTA">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <jta-data-source>java:/MSSQLDS</jta-data-source>
       
        <exclude-unlisted-classes>true</exclude-unlisted-classes>
        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.SQLServerDialect"/>
            <property name="hibernate.hbm2ddl.auto" value="update"/>
           


            <property name="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.JBossTransactionManagerLookup"/>
            <property name="hibernate.transaction.auto_close_session" value="true"/>



        </properties>
    </persistence-unit>
</persistence>

...

Рейтинг:

0 / 0

20.03.2013, 16:32:43

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191704

Blazkowicz

Участник

Сообщения: 25 080

Рейтинг: 0 / 0

Где EntityManager? Как создаётся?

...

Рейтинг:

0 / 0

20.03.2013, 16:37:33

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191731

serega063

Гость

Blazkowicz,

А хз где он создается))
так то есть класс

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.

public class AbstractEntityBean {
    public EntityManager getEntityManager() {
        return em;
    }

    public void setEntityManager(EntityManager em) {
        this.em = em;
    }

    @PersistenceContext(unitName = EPConstants.CORE_PERSISTENCE_UNIT)
    protected EntityManager em;
}

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.

    public List loadReports(UUID uuid, DateTime beginDate, DateTime endDate) {
        EntityManager em = getEntityManager(); // ТУТ EntityManager 
        String deleteSQL = "delete from [dbo].[sell]";
        Query deleteQuery = em.createNativeQuery(deleteSQL);


        UserTransaction utx = null;
        
        try {
            InitialContext ctx = new InitialContext();
            utx = (UserTransaction) ctx.lookup("UserTransaction");
            utx.begin();
            int status = utx.getStatus(); //0
        } catch (NamingException e) {
            e.printStackTrace(); 
        } catch (NotSupportedException e) {
            e.printStackTrace(); 
        } catch (SystemException e) {
            e.printStackTrace(); 
        }


        try {                    
            deleteQuery.executeUpdate(); // ТУТ вылетает ошибка javax.persistence.TransactionRequiredException: Executing an update/delete query
            code = insertQuery.executeUpdate();

            utx.commit();                      
        } catch (Exception e) {
            utx.rollback();
            
        }

    }

Чую что нужно скрестить EntityManager с UserTransaction ??

...

Рейтинг:

0 / 0

20.03.2013, 16:47:24

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191740

Blazkowicz

Участник

Сообщения: 25 080

Рейтинг: 0 / 0

serega063Чую что нужно скрестить EntityManager с UserTransaction ??
Я не гуру в EJB, но первое что я бы попробовал - инжектить EntityManagerFactory, вместо EntityManager. Затем создавать EntityManager из Factory после utx.begin();

...

Рейтинг:

0 / 0

20.03.2013, 16:49:47

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191756

serega063

Гость

Blazkowicz,
попробывал em.joinTransaction();
результат тот же

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.

 try {
            InitialContext ctx = new InitialContext();
            utx = (UserTransaction) ctx.lookup("UserTransaction");
            utx.begin();
            em.joinTransaction();
            int status = utx.getStatus(); //0
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (NotSupportedException e) {
            e.printStackTrace();
        } catch (SystemException e) {
            e.printStackTrace();
        }

...

Рейтинг:

0 / 0

20.03.2013, 16:55:26

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191817

забыл ник

Участник

Сообщения: 3 596

Рейтинг: 0 / 0

serega063Blazkowicz,
попробывал em.joinTransaction();
результат тот же

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.

 try {
            InitialContext ctx = new InitialContext();
            utx = (UserTransaction) ctx.lookup("UserTransaction");
            utx.begin();
            em.joinTransaction();
            int status = utx.getStatus(); //0
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (NotSupportedException e) {
            e.printStackTrace();
        } catch (SystemException e) {
            e.printStackTrace();
        }

Так какие эксепшены срутся? У тебя при обработке исключений просто принт стек трейс, а выполнение кода продолджается. Если был эксепшн - естсевенно транзакция не создалась

...

Рейтинг:

0 / 0

20.03.2013, 17:22:47

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191838

serega063

Гость

забыл ник,
Вот модернизированный код

Код: xml

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.

@Stateless(name = Loader.JNDI_NAME)
@Remote(Loader.class)
@TransactionManagement(value = TransactionManagementType.BEAN)
public class LoaderBean extends AbstractLoaderBean implements Loader {
    @Override
    public List loadReports(UUID uuid, DateTime beginDate, DateTime endDate) {
       
        EntityManager em = getEntityManager();

        String deleteSQL = "delete from [dbo].[sell]";
        UserTransaction utx = null;
        
        Query deleteQuery = em.createNativeQuery(deleteSQL);

        try {
            InitialContext ctx = new InitialContext();
            utx = (UserTransaction) ctx.lookup("UserTransaction");
            utx.begin();
            em.joinTransaction();
            int status = utx.getStatus(); //0
        } catch (NamingException e) {
            e.printStackTrace();
            return null;
        } catch (NotSupportedException e) {
            e.printStackTrace();
            return null;
        } catch (SystemException e) {
            e.printStackTrace();
            return null;
        }



        try {                    
            deleteQuery.executeUpdate(); // ТУТ вылетает ошибка javax.persistence.TransactionRequiredException: Executing an update/delete query
            code = insertQuery.executeUpdate();

            utx.commit();                      
        } catch (Exception e) {
            utx.rollback();
            
        }

    }


}

...

Рейтинг:

0 / 0

20.03.2013, 17:32:10

| Ответить | Цитировать | Написать

EJB UserTransaction

#38191854

serega063

Гость

Ошибку возбуждает вот эта хня. Т.е. заходит в

Код: java

1.
2.
3.
4.

if ( ! em.isTransactionInProgress() ) {
				em.throwPersistenceException( new TransactionRequiredException( "Executing an update/delete query" ) );
				return 0;
			}

em.isTransactionInProgress() == false

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.

package org.hibernate.ejb;

public class QueryImpl implements Query, HibernateQuery {
public int executeUpdate() {
		try {
			if ( ! em.isTransactionInProgress() ) {
				em.throwPersistenceException( new TransactionRequiredException( "Executing an update/delete query" ) );
				return 0;
			}
			return query.executeUpdate();
		}
		catch (QueryExecutionRequestException he) {
			throw new IllegalStateException(he);
		}
		catch( TypeMismatchException e ) {
			throw new IllegalArgumentException(e);
		}
		catch (HibernateException he) {
			em.throwPersistenceException( he );
			return 0;
		}
	}
}

...

Рейтинг:

0 / 0

20.03.2013, 17:40:03

| Ответить | Цитировать | Написать

EJB UserTransaction

#38192226

WGA

Гость

serega063,

Не заморачивайтесь с TransactionManagementType.BEAN. Достаточно вынести всю логику, которая должна выполняться в своей транзакции в отдельный бин и пометить его с TransactionAttribute.REQUIRES_NEW.

...

Рейтинг:

0 / 0

20.03.2013, 21:32:21

| Ответить | Цитировать | Написать

EJB UserTransaction

#38192532

serega063

Гость

WGAserega063,

Не заморачивайтесь с TransactionManagementType.BEAN. Достаточно вынести всю логику, которая должна выполняться в своей транзакции в отдельный бин и пометить его с TransactionAttribute.REQUIRES_NEW.

Спасибо, а можно примерчик, если не долго и не далеко

...

Рейтинг:

0 / 0

21.03.2013, 08:41:43

| Ответить | Цитировать | Написать

EJB UserTransaction

#38192732

WGA

Гость

serega063Спасибо, а можно примерчик, если не долго и не далекоДа пожалуйста.

Листинг

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.

@Stateless
public class Bean1 {

    @PersistenceContext
    private EntityManager em;
    @EJB
    private Bean2 bean2;

    public void method() {
        em.persist(new Response("request" + Bean2.getCounter()));
        bean2.method();
        throw new RuntimeException();
    }
}

Код: java

1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.

@Stateless
public class Bean2 {

    private static int counter = 0;

    @PersistenceContext
    private EntityManager em;

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void method() {
        em.persist(new Request("request" + counter));
    }

    public static int getCounter() {
        return ++counter;
    }
}

Исходники тестового проекта прилагаются. Запуск приложения из браузера по контекстному пути /test-app/test. Увидите 500-ю ошибку. В БД появятся записи в таблице request, в response - нет, поскольку RuntimeException откатывает активную транзакцию. Это доказывает, что методы бинов выполняются в различных Persistence Context и, соответственно, в разных транзакциях.

...

Рейтинг:

0 / 0

21.03.2013, 10:59:06

| Ответить | Цитировать | Написать

11 сообщений из 11, страница 1 из 1

Форумы / Java [игнор отключен] [закрыт для гостей] / EJB UserTransaction

Читали тему (0):

Читали форум (0):

Пользователи онлайн (0):

start [/forum/topic.php?fid=59&msg=38191756&tid=2129738]:	0ms
get settings:	16ms
get forum list:	26ms
check forum access:	6ms
check topic access:	6ms
track hit:	55ms
get topic data:	20ms
get forum data:	5ms
get page messages:	86ms
get tp. blocked users:	2ms
others:	348ms

total:	570ms

	Необходимые cookie
	Cookie для сбора статистики
	Cookie для маркетинга и рекламы