我对Spring Boot还是个新手,但现在我遇到了一个问题:
// Application.java
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Autowired
private Cluster cluster = null;
@PostConstruct
private void migrateCassandra() {
Database database = new Database(this.cluster, "foo");
MigrationTask migration = new MigrationTask(database, new MigrationRepository());
migration.migrate();
}
}
基本上,我正在尝试引导一个Spring应用程序,之后进行一些Cassandra迁移。
我还为我的用户模型定义了一个存储库:
// UserRepo.java
public interface UserRepo extends CassandraRepository<User> {
}
现在我正在尝试使用以下简单的测试用例来测试我的仓库类:
// UserRepoTest.java
@RunWith(SpringRunner.class)
@AutoConfigureTestDatabase(replace = Replace.NONE)
@DataJpaTest
public class UserRepoTest {
@Autowired
private UserRepo userRepo = null;
@Autowired
private TestEntityManager entityManager = null;
@Test
public void findOne_whenUserExists_thenReturnUser() {
String id = UUID.randomUUID().toString();
User user = new User();
user.setId(id);
this.entityManager.persist(user);
assertEquals(this.userRepo.findOne(user.getId()).getId(), id);
}
@Test
public void findOne_whenUserNotExists_thenReturnNull() {
assertNull(this.userRepo.findOne(UUID.randomUUID().toString()));
}
}
我本来期望测试会通过,但是却收到一个错误,显示“没有找到 'com.datastax.driver.core.Cluster' 类型的合格 bean”。看起来 Spring 没有自动装配 cluster
对象,但是为什么呢?我该如何修复这个问题?万分感谢!
@Autowired private Cluster cluster = null;
- Jens