使用spring数据Cassandra动态创建键空间、表和生成表

Question

使用Cassandra，我想使用spring boot应用程序动态地创建键空间和表。我正在使用基于Java的配置。

我有一个用@table注释的实体，我想在应用程序启动之前创建它的模式，因为它有预先已知的固定字段。

但是，根据登录的用户，我还希望为这些用户动态创建额外的表，并能够将条目插入到这些表中。

有没有人可以指导我一些我可以利用的资源，或者指出我如何解决这些问题的正确方向。非常感谢你的帮助！

Answer 1

最简单的做法是将spring boot Starter Data Cassandra依赖项添加到您的spring boot应用程序中，如下所示...

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-cassandra</artifactId>
  <version>1.3.5.RELEASE</version>
</dependency>

此外，这将向您的应用程序添加spring数据Cassandra依赖项。

使用spring数据Cassandra，您可以通过调用setKeyspaceCreations（：set）方法，使用CassandracLusterFactoryBean（或者更准确地说，子类...CassandracQLClusterFactoryBean)配置应用程序的密钥空间。

KeyspaceActionSpecification类非常简单。您甚至可以使用KeyspaceActionSpecificationFactoryBean创建一个KeyspaceActionSpecificationFactoryBean，将其添加到Set中，然后将其传递给CassandracLusterFactoryBean上的SetKeySpaceCreations(..)方法。

为了生成应用程序的表，您基本上只需要使用SD Cassandra@Table注释来注释应用程序的域对象（实体），并确保可以在应用程序的类路径上找到域对象/实体。

具体地说，您可以让应用程序@configuration类扩展SD Cassandra AbstractClusterConfiguration类。在这里，您可以找到getEntityBasePackages():String[]方法，您可以重写该方法，以提供包含应用程序域对象/实体类的包位置，然后SD Cassandra将使用该包来扫描@table域对象/实体。

正确标识应用程序@table域对象/实体后，使用CassandrasessionFactoryBean方法setSchemaAction（：SchemaAction）将SD Cassandra SchemaAction设置为create。如果您在CassandrasessionFactoryBean上正确标识了正确的键空间，这将在您的键空间中为扫描期间找到的所有域对象/实体创建表。

显然，如果应用程序创建/使用多个键空间，则需要为每个键空间创建单独的CassandrasessionFactoryBean，并为属于特定键空间的实体适当设置EntityBasePackages配置属性，以便在该键空间中创建相关联的表。

现在...

对于每个用户的“附加”表来说，这是相当复杂和棘手的。

您可能可以在这里利用spring配置文件，然而，配置文件通常只应用于启动。如果不同的用户登录到一个已经运行的应用程序中，您需要一种方法在运行时向springApplicationContext提供额外的@configuration类。

您的spring boot应用程序可以注入对AnnotationConfigApplicationContext的引用，然后在登录事件中使用它，根据登录到应用程序的用户以编程方式注册其他@configuration类。您需要使用ApplicationContext.Refresh()跟随Register（class...）调用。

您还需要适当地处理表已经存在的情况。

SD Cassandra目前不支持这一点，但请参阅DATACASS-219了解更多详细信息。

从技术上讲，在运行时为所有用户创建应用程序所需的所有可能的表，并使用Cassandra的安全设置来根据角色和分配的权限限制单个用户的访问，会简单得多。

另一种选择可能是在用户登录应用程序时根据需要创建临时键空间和/或表，在用户注销时删除它们。

显然，这里有很多不同的选择，它更多地归结为架构决策、权衡和考虑，然后才是技术可行性，所以要小心。

希望这有帮助。

干杯！