Intégrer le ressort avec cassandra en utilisant Hector

Question

Je travaille sur une application Spring et j'ai besoin de parler à Cassandra en utilisant Hector. Besoin d'aide quant à la façon d'aborder. Je veux utiliser JPA et utiliser les fonctions d'injection de dépendance du printemps aussi.

Les points d'aide!

Answer 1

Kundera, je pourrais l'intégrer au printemps très facilement et Oui comme Hardik Bhalani a suggéré les familles de colonnes ont été conçus avec soin pour atteindre l'efficacité maximale

Answer 2

réponse à votre 1er problème: vous devez définir et normaliser votre modèle de données afin de réduire la traversée entre plusieurs familles de colonnes. Par exemple Si vous stockez un identifiant d'utilisateur dans une liste d'objets CF, vous devez insérer l'objet JSON de l'utilisateur avec les détails d'utilisation au lieu de cet identifiant, de manière à éviter la traversée vers l'usermaster CF.

Answer 3

J'ai réussi à faire assez facilement en utilisant ce documentation, mais cela vous laisse SimpleCassandraDao (que vous pouvez injecter à votre DAO) - ce qui est assez limité.

Ce que je ne créais la connexion pragmatiquement:

@PostConstruct 
public void connect() { 
if (Boolean.parseBoolean(isActive)) { 
    CassandraHostConfigurator cassandraHostConfigurator = new CassandraHostConfigurator(this.socket); 
    cluster = HFactory.getOrCreateCluster(clusterName, cassandraHostConfigurator); 
    ConfigurableConsistencyLevel consistencyLevelPolicy = new ConfigurableConsistencyLevel(); 
    consistencyLevelPolicy.setDefaultReadConsistencyLevel(getConsistencyLevelPolicy()); 
    keyspace = HFactory.createKeyspace(keyspaceName, cluster, consistencyLevelPolicy); 
    if (isConnected()) 
    fireConnectionEvent(true); 
    else { 
    LOG.error("Could not connect to socket " + this.socket + ". Connection to Cassandra DB is down!!!"); 
    } 
} else { 
    LOG.info("Cassandra connection is not active hence could not connect to socket " + this.socket 
     + ". Please activate the connection before trying to connect"); 
} 
} 

Cette méthode est une partie d'un grain de printemps (annoté avec le composant d'annotation), donc une fois que l'application est déployée le pool de connexion est créée . Comme vous le voyez, je déclenche un événement de connexion (en utilisant le support Spring Application-Event). L'événement contient le nouvel espace de touches créé puis capturé par mon Dao. De cette façon, mon Dao peut initialiser les requêtes requises. par exemple:

StringSerializer stringSerializer = StringSerializer.get(); 
SliceQuery<String, String, String> query = HFactory.createSliceQuery(this.keyspace, stringSerializer, stringSerializer, stringSerializer) 
     .setColumnFamily(columnFamily).setRange(null, null, false, 4).setKey(rowKey); 

    ColumnSlice<String, String> columnsSlice = query.execute().get(); 
    List<HColumn<String, String>> columns = columnsSlice.getColumns(); 

J'espère que cela aide.

Answer 4

Vous pouvez essayer d'utiliser Playorm qui 1. prend en charge les jointures de type sql pour deux familles de colonnes 2. Fournit également un support d'indexation sur les colonnes.