IllegalTransactionStateException Обнаружено предварительно привязанное соединение JDBC при настройке нескольких источников данных

У меня есть весенний пакетный проект, в котором я читаю данные из источника данных, обрабатываю данные и записываю в другой первичный источник данных. Я расширяю CrudRepository для операций dao.

Я пытаюсь настроить несколько источников данных для моего приложения загрузки springbatch + spring. Ниже представлена ​​структура пакета:

myproject
   ---com
   ---batch
        ---config
                 ---firstDsConfig.java
                 ---secondDsConfig.java
        ---firstrepository
                 ---firstCrudRepository.java
        ---secondRepository
                 ---SecondCrudRepository.java
        ---firstEntity
                 ---firstDBEntity.java
        ---secondEntity
                 ---secondDBEntity.java
        ----main
                 ---MyMainClass.java

Код для firstDsConfig.java:

@Configuration
@EnableJpaRepositories(
        entityManagerFactoryRef = "firstEntityManagerFactory",
        transactionManagerRef = "firstTransactionManager",
        basePackages = "com.batch.firstrepository"
)
@EnableTransactionManagement
public class FirstDbConfig {

    @Primary
    @Bean(name = "firstEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean firstEntityManagerFactory(final EntityManagerFactoryBuilder builder,
                                                                            final @Qualifier("firstDs") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("com.batch.firstEntity")
                .persistenceUnit("abc")
                .build();
    }


    @Primary
    @Bean(name = "firstTransactionManager")
    public PlatformTransactionManager firstTransactionManager(@Qualifier("firstEntityManagerFactory")
                                                              EntityManagerFactory firstEntityManagerFactory) {
        return new JpaTransactionManager(firstEntityManagerFactory);
    }


    @Primary
    @Bean(name = "firstDs")
    @ConfigurationProperties(prefix = "spring.datasource.first")
    public DataSource firstDataSource() {
        return DataSourceBuilder.create().build();
    }
}

Код для secondDsConfig:

@Configuration
@EnableJpaRepositories(
        entityManagerFactoryRef = "secondEntityManagerFactory",
        transactionManagerRef = "secondTransactionManager",
        basePackages = "com.batch.secondrepository"
)
@EnableTransactionManagement
public class FirstDbConfig {

    @Primary
    @Bean(name = "secondEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean secondEntityManagerFactory(final EntityManagerFactoryBuilder builder,
                                                                            final @Qualifier("secondDs") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("com.batch.secondEntity")
                .persistenceUnit("xyz")
                .build();
    }


    @Primary
    @Bean(name = "secondTransactionManager")
    public PlatformTransactionManager secondTransactionManager(@Qualifier("secondEntityManagerFactory")
                                                              EntityManagerFactory firstEntityManagerFactory) {
        return new JpaTransactionManager(secondEntityManagerFactory);
    }


    @Primary
    @Bean(name = "secondDs")
    @ConfigurationProperties(prefix = "spring.datasource.second")
    public DataSource secondDataSource() {
        return DataSourceBuilder.create().build();
    }
}

Вот мой основной класс

@EnableScheduling
@EnableBatchProcessing
@SpringBootApplication(scanBasePackages = { "com.batch" })
public class MyMainClass {

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    private JobRepository jobRepository;

    @Autowired
    @Qualifier(firstDs)
    private DataSource dataSource;

    @Autowired
    @Qualifier("myJob")
    private Job job;

    public static void main(String[] args) throws Exception {
        SpringApplication.run(MyMainClass.class, args);
    }

    @EventListener(ApplicationReadyEvent.class)
    private void start() throws Exception {

        jobLauncher.run(job, new JobParameters());
    }


    @Bean(name = "jobService")
    public JobService jobService() throws Exception {
        SimpleJobServiceFactoryBean factoryBean = new SimpleJobServiceFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setJobRepository(jobRepository);
        factoryBean.setJobLocator(new MapJobRegistry());
        factoryBean.setJobLauncher(jobLauncher);
        factoryBean.afterPropertiesSet();
        return factoryBean.getObject();
    }
}

Вот репо сырой нефти:

Первое творожное репо

public interface FirstCrudRepository extends CrudRepository<FirstDbEntity, Integer> {

    List<FirstDbEntity> findByOId(String oId);

}

Второе репо творожное

public interface SecondCrudRepository extends CrudRepository<SecondDbEntity, Integer> {

    List<SecondDbEntity> findByPid(String pid);

}

Когда я запускаю свое приложение, я вижу следующую ошибку при сохранении записи с помощью FirstCrudRepository:

 org.springframework.transaction.IllegalTransactionStateException: Pre-bound JDBC Connection found! JpaTransactionManager does not support running within DataSourceTransactionManager if told to manage the DataSource itself. It is recommended to use a single JpaTransactionManager for all transactions on a single DataSource, no matter whether JPA or JDBC access.

Примечание: я могу успешно получить данные из SecondCrudRepository

являются ли bean-компоненты firstDs и secondDs ссылками на один и тот же источник данных или на другой источник данных?

greengreyblue 04.11.2018 08:40

они разные, обратитесь к аннотации @ ConfigurationProperties к определенным bean-компонентам.

Manas Saxena 04.11.2018 08:51

Я думаю, вам нужно аннотировать @Transactional и указать диспетчер транзакций в классах репозитория.

greengreyblue 04.11.2018 09:15
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
2
3
4 870
2

Ответы 2

Я подозреваю, что есть 2 разных менеджера транзакций, которые могут вызвать проблемы. Добавьте аннотацию с помощью @Transactional и укажите диспетчер транзакций.

Источник:

Spring - можно ли использовать несколько менеджеров транзакций в одном приложении?

По умолчанию, если вы предоставляете DataSource, Spring Batch будет использовать DataSourceTransactionManager, который ничего не знает о вашей конфигурации JPA. Вам нужно указать Spring Batch использовать ваш JpaTransactionManager. Это объясняется в:

спасибо, теперь он работает, я расширил один из классов конфигурации с помощью DefaultBatchConfigurer в моем коде, указанном в вопросе

Manas Saxena 09.11.2018 10:54

Другие вопросы по теме