Créer des clés, de table et de générer des tableaux dynamiquement à l'aide de Printemps de Données Cassandra

À l'aide de Cassandra, je veux créer des clés et des tableaux dynamiquement à l'aide de Printemps de Démarrage de l'application. Je suis à l'aide de Java en fonction de la configuration.

J'ai une entité annotée avec @Table dont le schéma je veux être créé avant l'application démarre depuis qu'il a fixé les champs qui sont connus à l'avance.

Cependant en fonction de l'utilisateur connecté, j'ai aussi envie de créer d'autres tables pour ceux de l'utilisateur de manière dynamique et être capable d'insérer des entrées de ces tables.

Quelqu'un peut-il me guider pour certaines ressources que je peux utiliser ou me diriger dans la bonne direction dans la façon d'aller sur la résolution de ces problèmes. Merci beaucoup pour l'aide!

InformationsquelleAutor Anu | 2016-05-20
  1. 14

    La meilleure chose à faire serait d'ajouter le Printemps De Démarrage Démarreur De Données Cassandra dépendance à votre Printemps de Démarrage application, comme si...

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

    En outre, cela va ajouter de la Printemps de Données Cassandra la dépendance à votre demande.

    Avec Printemps de Données Cassandra, vous pouvez configurer votre application Espace(s) à l'aide de la CassandraClusterFactoryBean (ou plus précisément, la sous-classe... CassandraCqlClusterFactoryBean) par l'appel de la setKeyspaceCreations(:Set) méthode.

    La KeyspaceActionSpecification classe est assez explicite. Vous pouvez même en créer un avec le KeyspaceActionSpecificationFactorybean, l'ajouter à un Set et de passer ensuite que la setKeyspaceCreations(..) méthode sur la CassandraClusterFactoryBean.

    Pour la génération de l'application des Tables, vous essentiellement besoin d'annoter votre domaine d'application, objet(s) (entités) à l'aide de la carte SD Cassandra @Table annotation, et assurez-vous que votre domaine d'objets/entités peuvent être trouvés sur le CLASSPATH de l'application.

    Plus précisément, vous pouvez avoir votre application @Configuration classe prolonger la SD Cassandra AbstractClusterConfiguration classe. Là, vous trouverez la getEntityBasePackages():String[] méthode que vous pouvez remplacer fournir l'ensemble des emplacements contenant votre domaine d'application de l'objet/les classes d'entité, qui SD Cassandra pourront ensuite utiliser pour scan pour @Table domaine d'objets/entités.

    Avec votre application @Table domaine d'objets/entités identifiés correctement, vous définissez la SD Cassandra SchemaAction à CREATE à l'aide de la CassandraSessionFactoryBean méthode, setSchemaAction(:SchemaAction). Cela permettra de créer des Tables dans votre Espace de clé pour tous les objets de domaine/entités trouvées lors de l'analyse, de vous fournir identifié le bon Espace sur votre CassandraSessionFactoryBean de façon appropriée.

    Évidemment, si votre application crée/utilise plusieurs Keyspaces, vous aurez besoin de créer un CassandraSessionFactoryBean pour chaque Espace, avec la entityBasePackages propriété configuration appropriée pour les entités qui appartiennent à un Espace de clé, de sorte que les Tableaux sont créés dans cet Espace.

    Maintenant...

    Pour les "autres" de Tables par l'utilisateur, qui est un peu plus compliqué et délicat.

    Vous pourriez être en mesure de tirer parti de Printemps Profils ici, cependant, les profils sont généralement appliquées uniquement au démarrage. Si un autre utilisateur se connecte à une application en cours d'exécution, vous avez besoin d'un moyen de fournir des @Configuration classes pour le Printemps ApplicationContext au moment de l'exécution.

    Votre Printemps de Démarrage application peut injecter une référence à un AnnotationConfigApplicationContext, puis de l'utiliser sur un événement de connexion par programmation registre supplémentaires @Configuration classes en fonction de l'utilisateur qui s'est connecté à l'application. Vous devez suivre votre register(Class...) appel(s) avec une ApplicationContext.refresh().

    Vous avez également besoin de traiter correctement la situation où les Tables existent déjà.

    Ce n'est pas actuellement pris en charge dans la SD de Cassandra, mais voir DATACASS-219 pour plus de détails.

    Techniquement, il serait beaucoup plus simple de créer toutes les Tables nécessaires par l'application pour tous les utilisateurs au moment de l'exécution et de l'utilisation de Cassandra paramètres de sécurité pour restreindre l'utilisateur individuel d'accès par rôle et des permissions.

    Une autre option pourrait être de créer temporaire Keyspaces et/ou de Tableaux que nécessaire lorsqu'un utilisateur se connecte à l'application, les déposer lorsque l'utilisateur se déconnecte.

    Clairement, il y a beaucoup de choix différents ici, et cela se résume plus à de l'architecture, des compromis et des considérations puis il ne faisabilité technique, donc soyez prudent.

    Espère que cette aide.

    Cheers!

    InformationsquelleAutor John Blum
  2. 8

    Printemps suivant la configuration de la classe crée des clés et des tables si elles n'existent pas.

    @Configuration
public class CassandraConfig extends AbstractCassandraConfiguration {
private static final String KEYSPACE = "my_keyspace";
private static final String USERNAME = "cassandra";
private static final String PASSWORD = "cassandra";
private static final String NODES = "127.0.0.1"; //comma seperated nodes
@Bean
@Override
public CassandraCqlClusterFactoryBean cluster() {
CassandraCqlClusterFactoryBean bean = new CassandraCqlClusterFactoryBean();
bean.setKeyspaceCreations(getKeyspaceCreations());
bean.setContactPoints(NODES);
bean.setUsername(USERNAME);
bean.setPassword(PASSWORD);
return bean;
}
@Override
public SchemaAction getSchemaAction() {
return SchemaAction.CREATE_IF_NOT_EXISTS;
}
@Override
protected String getKeyspaceName() {
return KEYSPACE;
}
@Override
public String[] getEntityBasePackages() {
return new String[]{"com.panda"};
}
protected List<CreateKeyspaceSpecification> getKeyspaceCreations() {
List<CreateKeyspaceSpecification> createKeyspaceSpecifications = new ArrayList<>();
createKeyspaceSpecifications.add(getKeySpaceSpecification());
return createKeyspaceSpecifications;
}
//Below method creates "my_keyspace" if it doesnt exist.
private CreateKeyspaceSpecification getKeySpaceSpecification() {
CreateKeyspaceSpecification pandaCoopKeyspace = new CreateKeyspaceSpecification();
DataCenterReplication dcr = new DataCenterReplication("dc1", 3L);
pandaCoopKeyspace.name(KEYSPACE);
pandaCoopKeyspace.ifNotExists(true).createKeyspace().withNetworkReplication(dcr);
return pandaCoopKeyspace;
}
}
    • J'ai suivi ce code mais je ne suis pas en mesure de créer des Clés et des tableaux sur le démarrage de l'application. Est-il quelque chose d'autre, je suis absent ? Merci de me guider.
    • Dès que nous avons de développer la capacité de lire dans les pensées, et de comprendre le problème que vous n'avez pas le décrire, nous serons en mesure de vous aider.
    InformationsquelleAutor Enes Altınkaya
  3. 1

    À l'aide de @Enes Altınkaya réponse: 

    @Value("${cassandra.keyspace}")
private String keySpace;
@Override
protected List<CreateKeyspaceSpecification> getKeyspaceCreations() {
return Arrays.asList(
CreateKeyspaceSpecification.createKeyspace()
.name(keySpace)
.ifNotExists()
.withNetworkReplication(new DataCenterReplication("dc1", 3L)));
}

    À définir votre varaibles utiliser un application.properties ou application.yml fichier:

    cassandra:
keyspace: yout_keyspace_name

    À l'aide de fichiers de configuration au lieu de chaînes codées en dur, vous pouvez publier votre code sur par exemple GitHub sans publier vos mots de passe et entrypoints (.gitignore fichiers) qui peut être un risque pour la sécurité.

    InformationsquelleAutor NotMyFaultSir
  4. 0

    Suivantes cassandra configuration permettra de créer un espace de clé lorsqu'il n'existe pas et également exécuter le script de démarrage spécifié

    @Configuration
@PropertySource(value = {"classpath:cassandra.properties"})
@EnableCassandraRepositories
public class CassandraConfig extends AbstractCassandraConfiguration {
@Value("${cassandra.keyspace}")
private String cassandraKeyspace;
@Override
protected List<CreateKeyspaceSpecification> getKeyspaceCreations() {
return Collections.singletonList(CreateKeyspaceSpecification.createKeyspace(cassandraKeyspace)
.ifNotExists()
.with(KeyspaceOption.DURABLE_WRITES, true)
.withSimpleReplication());
}
@Override
protected List<String> getStartupScripts() {
return Collections.singletonList("CREATE TABLE IF NOT EXISTS "+cassandraKeyspace+".test(id UUID PRIMARY KEY, greeting text, occurrence timestamp) WITH default_time_to_live = 600;");
}
}
    InformationsquelleAutor Viswanath
  5. 0

    Cette réponse est inspiré par Viswanath de réponse.

    Mon cassandra.yml se présente comme suit:

    
spring:
data:
cassandra:
cluster-name: Test Cluster
keyspace-name: keyspace
port: 9042
contact-points:
- 127.0.0.1
 

    
@Configuration
@PropertySource(value = { "classpath:cassandra.yml" })
@ConfigurationProperties("spring.data.cassandra")
@EnableCassandraRepositories(basePackages = "info.vishrantgupta.repository")
public class CassandraConfig extends AbstractCassandraConfiguration {
@Value("${keyspacename}")
protected String keyspaceName;
@Override
protected String getKeyspaceName() {
return this.keyspaceName;
}
@Override
protected List getKeyspaceCreations() {
return Collections.singletonList(CreateKeyspaceSpecification
.createKeyspace(keyspaceName).ifNotExists()
.with(KeyspaceOption.DURABLE_WRITES, true)
.withSimpleReplication());
}
@Override
protected List getStartupScripts() {
return Collections.singletonList("CREATE KEYSPACE IF NOT EXISTS "
+ keyspaceName + " WITH replication = {"
+ " 'class': 'SimpleStrategy', "
+ " 'replication_factor': '3' " + "};");
}
}

    Vous pourriez avoir à personnaliser @ConfigurationProperties("spring.data.cassandra"), si votre configuration commence avec cassandra dans cassandra.yml fichier, puis utilisez @ConfigurationProperties("cassandra")

    InformationsquelleAutor Vishrant
  6. 0

    Pour le tableau de la création, vous pouvez l'utiliser dans l'application.fichier de propriétés

    spring.data.cassandra.schema-action=CREATE_IF_NOT_EXISTS
    InformationsquelleAutor abbas