如何在一个项目中同时使用cassandra和mysql?

hec6srdp  于 2021-06-15  发布在  Cassandra
关注(0)|答案(0)|浏览(272)

我试图在我的项目中同时使用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:未知类型。
我哪里错了。
先谢谢你。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题