Доступ к базе данных h2 для проверки данных из отдельных потоков - PullRequest
0 голосов
/ 14 февраля 2019

Моя Интеграция Сценарий тестирования:

  1. создать строку в базе данных H2
  2. sleep(50000ms) (тем временем другой поток вызывается благодаря конфигурации пружиныи этот поток должен найти строку, созданную в пункте 1. и обновить эту строку)
  3. ожидать, что строка из пункта 1. была обновлена ​​потоком, упомянутым в пункте 2.

Этот сценарийтестирует оба - конфигурацию и реализацию.И это то, чего я хочу достичь.

Я использую базу данных H2 во всех своих тестах, поэтому решил использовать ее и здесь.При отладке тестового сценария я обнаружил, что новый поток, вызванный во время sleep - подключается к БД, но не находит созданную строку.Я просмотрел документацию H2 и начал использовать:

java -cp ~/.m2/repository/com/h2database/h2/1.4.194/h2-1.4.194.jar org.h2.tools.Server -tcp -web -browser -tcpAllowOthers -tcpPort 9092 -webPort 8082

и строку подключения:

DB_URL=jdbc:h2:tcp://localhost:9092/~/test2

и конфигурацию:

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
      destroy-method="close" p:driverClassName="org.h2.Driver"
      p:url="${DB_URL}"
      p:username="${OPENSHIFT_MYSQL_DB_USERNAME}" p:password="${OPENSHIFT_MYSQL_DB_PASSWORD}"/>

<util:properties id="hibernateProperties">
    <prop key="hibernate.dialect">org.hibernate.dialect.H2Dialect</prop>
    <prop key="hibernate.hbm2ddl.auto">validate</prop>
    <prop key="hibernate.show_sql">false</prop>
</util:properties>

<bean id="sessionFactory"
      class="org.springframework.orm.hibernate5.LocalSessionFactoryBean"
      p:dataSource-ref="dataSource" p:packagesToScan="com.fridayweekend.lottery.model"
      p:hibernateProperties-ref="hibernateProperties"/>

<bean id="transactionManager"
      class="org.springframework.orm.hibernate5.HibernateTransactionManager"
      p:sessionFactory-ref="sessionFactory"/>

ПРИМЕЧАНИЕ: я уженемного поиграл с ddl-auto - я попытался создать схему при первом запуске, а затем только проверить ее (чтобы предотвратить повторное создание), но это не помогло.

Я могу проверить базу данных через H2 Web Console.Я вижу, что схема создана (на основе моей Java-аннотированной модели), но данных там нет (даже во время sleep или во время точки останова отладки).

С другой стороны - когда я добавляю данные (с 1-й точки сценария) вручную - я могу отладить, что второй поток их увидит и правильно их обновит, тогда тест пройден успешно.Данные, созданные во втором потоке, сохраняются, и я вижу их даже после завершения набора тестов.

Что делать, чтобы данные, созданные в основном (@ Test-annotated), были видны второму потоку?

PS.Я думаю, что это не имеет отношения, но «второй» поток вызывается так:

    <util:properties id="javaMailProperties">
    <prop key="mail.imap.socketFactory.class">javax.net.ssl.SSLSocketFactory</prop>
    <prop key="mail.imap.socketFactory.fallback">false</prop>
    <prop key="mail.store.protocol">${imap.protocol}</prop>
    <prop key="mail.debug">${imap.debug}</prop>
</util:properties>
<mail:inbound-channel-adapter id="imapAdapter"
                              store-uri="${imap.uri}"
                              channel="recieveEmailChannel"
                              should-delete-messages="false"
                              should-mark-messages-as-read="true"
                              auto-startup="true"
                              java-mail-properties="javaMailProperties">
    <int:poller fixed-delay="${imap.poolerSecondsDelay}" time-unit="SECONDS"/>
</mail:inbound-channel-adapter>
<int:channel id="recieveEmailChannel">
    <int:interceptors>
        <int:wire-tap channel="logger"/>
    </int:interceptors>
</int:channel>
<int:logging-channel-adapter id="logger" level="DEBUG"/>
<int:service-activator input-channel="recieveEmailChannel" ref="emailReceiverService" method="receive"/>

, так что в основном - он вызывает метод receive из emailReceiverService bean.Конечно, я гарантировал, что метод вызывается (отправив электронное письмо в почтовый ящик), но, как я уже сказал, я не думаю, что способ создания второго потока является релевантным.По сути, он вызывается конфигурацией Spring (конфигурация Spring передается методу тестирования через

@ContextConfiguration(locations = { "classpath:spring/test-lottery-context.xml", "classpath:spring/test-sms-context.xml" })
@Transactional
public class QueueServiceImplIntegrationTest extends AbstractTransactionalTestNGSpringContextTests {

).

1 Ответ

0 голосов
/ 15 февраля 2019

Я нашел коренную проблему там: Транзакции !

Мой тест расширял AbstractTransactionalTestNGSpringContextTests, поэтому область транзакции была целым @Test аннотированным методом.Я изменил свой тест, чтобы расширить просто AbstractTestNGSpringContextTests - и затем область транзакций была сужена до определенного метода Service (я говорю о обычном шаблоне MVC), вызываемого из аннотированного метода @Test.Это решило мою проблему.

Ура!

...