问题描述
当前我在Spring上使用Hibernate(MySQL)，配置对我来说运行良好，但是一旦我配置了另一个配置mongo-config.xml文件并尝试使用mongodb运行测试用例，它的显示错误从第一个配置创建名称为.... 的bean.
Currently I'm using Hibernate(MySQL) with Spring, the configuration is running fine for me, but once I configured another configuration mongo-config.xml file and trying to run a test case with mongodb it's showing Error creating bean with name .... from first configuration.
下面是我的mongo-config.xml
<context:annotation-config />
<context:component-scan base-package="com.test.mongo" />
<context:property-placeholder location="classpath:mongo-dao.properties" />
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
</bean>
<bean id="mongoDbFactory" class="org.springframework.data.mongodb.core.MongoFactoryBean">
<property name="driverClassName" value="${spring.datasource.driverClassName}" />
<property name="host" value="${spring.data.mongodb.host}" />
<property name="port" value="${spring.data.mongodb.port}" />
<property name="databaseName" value="${spring.data.mongodb.database}" />
，而我的第一个休眠配置看起来像
<context:component-scan base-package="com.hb.dao" />
<tx:annotation-driven transaction-manager="transactionManager" />
<bean id="dataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="${db.jdbc.driverClassName}" />
<property name="url" value="${db.jdbc.url}" />
<property name="username" value="${db.jdbc.username}" />
<property name="password" value="${db.jdbc.password}" />
</bean>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="packagesToScan">
<list>
<value>com.hb..dao.domain.entity</value>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">${hibernate.dialect}</prop>
<prop key="hibernate.show_sql">${hibernate.show_sql:false}</prop>
<prop key="hibernate.format_sql">${hibernate.format_sql:false}</prop>
</props>
</property>
</bean>
<bean id="transactionManager"
class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
并且堆栈跟踪为
java.lang.IllegalStateException: Failed to load ApplicationContext
at org.springframework.test.context.CacheAwareContextLoaderDelegate.loadContext(CacheAwareContextLoaderDelegate.java:99)
at org.springframework.test.context.DefaultTestContext.getApplicationContext(DefaultTestContext.java:101)
at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.injectDependencies(DependencyInjectionTestExecutionListener.java:109)
at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.prepareTestInstance(DependencyInjectionTestExecutionListener.java:75)
at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:331)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:213)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:290)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
原因:org.springframework.beans.factory.BeanCreationException:创建名称为'accessProfileDaoImpl'的bean时出错:自动连接依赖项的注入失败；嵌套的异常是org.springframework.beans.factory.BeanCreationException:无法自动连线字段:私有org.hibernate.SessionFactory com.soe.dao.AbstractDao.sessionFactory;嵌套的异常是org.springframework.beans.factory.NoSuchBeanDefinitionException:没有找到类型为[org.hibernate.SessionFactory]的合格bean作为依赖项:预计至少有1个bean可以作为此依赖项的自动装配候选. >依赖注释:
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'accessProfileDaoImpl': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private org.hibernate.SessionFactory com.soe.dao.AbstractDao.sessionFactory; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type [org.hibernate.SessionFactory] found for dependency: expected at least 1 bean which qualifies as autowire candidate for this dependency.Dependency annotations:
这是我的考试班级-
public class MongoQuestionsTest extends BaseDaoMongoTest{
private static final Logger logger = LogManager.getLogger(MongoQuestionsTest.class);
@Autowired
private MongoTestDao mongoTestDaoImpl;
@Test
public void saveQuestions(){
MongoQuestions mongoQuestions = new MongoQuestions();
mongoQuestions.setUsername("Hi");
mongoQuestions.setPassword("Hello");
mongoTestDaoImpl.save(mongoQuestions);
logger.debug("Mongo User Set with id " + mongoQuestions.getId());
}
and **BaseDaoMongoTest**---
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"classpath:/mongo-config-test.xml"})
public class BaseDaoMongoTest {
}
在MongoTestDaoImpl类中，我只是自动连接MongoTemplate并调用了save()方法.
And in MongoTestDaoImpl class I just Auto-wired MongoTemplate and calling save() method that's it.
推荐答案
我不确定这是否是最佳解决方案.但是，它对我有用.如果您有两个使用Jpa模块的关系数据库，那么我建议您创建entity和transaction管理器bean来读取每个数据源配置.有关上述用例，请参见下面的链接.
I'm not sure whether this is the best solution. But, it worked for me.If you have two relational databases using Jpa module, then I would suggest you to create entity and transaction manager beans to read each datasource config. Refer the below link for the above use case.
由于您希望将SQL和NoSQL组合使用，因此我将为MySQL数据库创建entity和transcation管理器bean，因为它与Jpa配合得很好.并保留Mongo的配置(直接从application.properties读取的配置).
As you wish to have a combination of SQL and NoSQL, I would create entity and transcation manager beans for MySQL database as it works well with Jpa. And leave as-is configuration for Mongo(configs read directly from application.properties).
MySQLConfiguration数据源配置类:
MySQLConfiguration datasource config class :
@Configuration
@PropertySource("classpath:persistence-multiple-db.properties")
@EnableJpaRepositories(basePackages = "com.springdata.dao.mysql", entityManagerFactoryRef = "mysqlEntityManager", transactionManagerRef = "mysqlTransactionManager")
public class MySQLConfiguration {
@Autowired
private Environment env;
@Bean
@Primary
public LocalContainerEntityManagerFactoryBean mysqlEntityManager() {
LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
em.setDataSource(myMySQLDataSource());
em.setPackagesToScan(new String[] { "com.springdata.models" });
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
em.setJpaVendorAdapter(vendorAdapter);
HashMap<String, Object> properties = new HashMap<String, Object>();
properties.put("hibernate.dialect", env.getProperty("hibernate.dialect"));
em.setJpaPropertyMap(properties);
return em;
}
@Bean
@Primary
public DataSource myMySQLDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(env.getProperty("spring.mysql.jdbc.driverClassName"));
dataSource.setUrl(env.getProperty("spring.mysql.jdbc.url"));
dataSource.setUsername(env.getProperty("spring.mysql.user"));
dataSource.setPassword(env.getProperty("spring.mysql.pass"));
return dataSource;
}
@Bean
@Primary
public PlatformTransactionManager mysqlTransactionManager() {
JpaTransactionManager transactionManager = new JpaTransactionManager();
transactionManager.setEntityManagerFactory(mysqlEntityManager().getObject());
return transactionManager;
}
以上数据源配置参数是从类路径中的classpath:persistence-multiple-db.properties文件读取的.
Above datasource config params are read from classpath:persistence-multiple-db.properties file in the classpath.
# mysql jdbc connections
spring.mysql.jdbc.driverClassName=com.mysql.jdbc.Driver
spring.mysql.jdbc.url=jdbc:mysql://localhost:3306/test?autoReconnect=true&useSSL=false
spring.mysql.user=root
spring.mysql.pass=password1
# hibernate.X
hibernate.dialect=org.hibernate.dialect.MySQL5Dialect
上面的配置应该足以处理MySQL数据源.要在项目中进行mongo配置，请在application.properties中添加以下几行.
The above configuration, should be suffice to deal MySQL datasource. To have mongo configuration in your project, add the below lines to application.properties.
# mongo configuration
spring.data.mongodb.uri=mongodb://localhost
spring.data.mongodb.database=test
Springboot将自动创建必要的mongo数据源bean，并使它们随时可供Spring容器使用.
Springboot will automatically create the necessary mongo datasource beans and keeps them readily available for spring container to use.
现在，为MySQL和Mongo数据源创建存储库接口.
Now, create repository interfaces for both MySQL and Mongo datasources.
MyMongoRepository界面:
MyMongoRepository interface:
@Transactional
public interface MyMongoRepository extends MongoRepository<Users, String>{
}
MySQLRepository界面:
MySQLRepository interface:
@Transactional
public interface MySQLRepository extends JpaRepository<Users, String>{
}
Users pojo类:
Users pojo class :
@Entity
@Table(name = "users")
@Document(collection="users")
@Data
public class Users {
@Id
@javax.persistence.Id
private String id;
private String name;
private Integer age;
}
已在下面添加了注释，以启用mongorepositoreis并将组件扫描到springboot主类.
Have added below annotations to enable mongorepositoreis and for component scan to springboot main class.
@SpringBootApplication
@ComponentScan(basePackages = { "com.springdata" })
@EnableMongoRepositories(basePackages={"com.springdata.dao.mongo"})
public class SpringbootmysqlmongoApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootmysqlmongoApplication.class, args);
}
}
最后，要测试一些代码.
Finally, some code to test.
MyRepositoryImpl类:
MyRepositoryImpl class:
@Service
public class MyRepositoryImpl {
@Autowired
private MyMongoRepository myMongoRepository;
@Autowired
private MySQLRepository mySQLRepository;
@PostConstruct
public void extractUsers(){
myMongoRepository.findAll().forEach((user) -> System.out.println("user name from mongo is : "+user.getName()));
mySQLRepository.findAll().forEach((user) -> System.out.println("User name from mysql is : "+user.getName()));
}
}
已在mysql test数据库中创建了users表，并在mongo test数据库中创建了users集合.
Have created users table in mysql test database and users collection in mongo test database.
最后，已将我的代码上传到git存储库.
Lastly, have uploaded my code to git repository.
https://github.com/harshavmb/springbootmysqlmongo
这篇关于如何在同一个项目中连接两个数据库MySQL和MongoDB?是否有可能?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！