我试图在我的项目中同时使用cassandra和mysql。一些数据将保存到cassandra中,一些保存到mysql中。我在同一个项目中使用mysql已经有1年了,现在既然我在扩展它,我也想添加cassandradb。
我的cassandra配置文件如下。
@Configuration
@PropertySource(value = {"classpath:META-INF/application.properties"})
@EnableCassandraRepositories(basePackages = {"com.example.repository"})
public class CassandraConfig {
@Autowired
private Environment environment;
private static final Logger LOGGER = LoggerFactory.getLogger(CassandraConfig.class);
@Bean
public CassandraClusterFactoryBean cluster() {
CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
cluster.setContactPoints(environment.getProperty("spring.cassandra.contactpoints"));
cluster.setPort(Integer.parseInt(environment.getProperty("spring.cassandra.port")));
return cluster;
}
@Bean
public CassandraMappingContext mappingContext() {
return new BasicCassandraMappingContext();
}
@Bean
public CassandraConverter converter() {
return new MappingCassandraConverter(mappingContext());
}
@Bean
public CassandraSessionFactoryBean session() throws Exception {
CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
session.setCluster(cluster().getObject());
session.setKeyspaceName(environment.getProperty("spring.cassandra.keyspace"));
session.setConverter(converter());
session.setSchemaAction(SchemaAction.NONE);
return session;
}
@Bean
public CassandraOperations cassandraTemplate() throws Exception {
return new CassandraTemplate(session().getObject());
}
}
我的存储库是 public interface NewRepository extends CassandraRepository<ID>{ }
现在我正在尝试使用reposiroty将一个实体保存到它
repo.save(entity);
其中repo是newrepository的对象。
但它显示invaliddataaccessapiusageexception:未知类型。
我哪里错了。
先谢谢你。
暂无答案!
目前还没有任何答案,快来回答吧!