Come utilizzare le query cql per ottenere diversi tipi di dati da cassandra con java client hector

Question

Sono nuovo a cassandra e hector quindi sto provando a eseguire query cql ma il problema è che non tutte le colonne sono di tipo stringa, quindi come dow eseguo la query "select * from users"?

mia famiglia colonna assomiglia a questo:

UPDATE COLUMN FAMILY users 
WITH comparator = UTF8Type 
AND key_validation_class=UTF8Type 
AND column_metadata = [ 
{column_name: full_name, validation_class: UTF8Type} 
{column_name: email, validation_class: UTF8Type} 
{column_name: state, validation_class: UTF8Type, index_type: KEYS} 
{column_name: gender, validation_class: UTF8Type} 
{column_name: birth_year, validation_class: LongType, index_type: KEYS} 
{column_name: education, validation_class: UTF8Type} 
]; 

Io uso il seguente codice per eseguire la query:

CqlQuery<String, String, String> cqlQuery = new CqlQuery<String, String, String>(Keyspace,stringSerializer,stringSerializer,stringSerializer); 

    cqlQuery.setQuery("select * from users"); 

    QueryResult<CqlRows<String, String, String>> result = cqlQuery.execute(); 


    if (result != null && result.get() != null) { 
     List<Row<String, String, String>> list = result.get().getList(); 
     for (Row row : list) { 
      System.out.println("."); 
      List columns = row.getColumnSlice().getColumns(); 
      for (Iterator iterator = columns.iterator(); iterator.hasNext();) { 
       HColumn column = (HColumn) iterator.next(); 
       System.out.print(column.getName() + ":" + column.getValue() 
         + "\t"); 
      } 
      System.out.println(""); 
     } 
    } 

Ma a causa della colonna 'birth_year' con classe di convalida tempo posso' t ottenere il valore. ottengo il seguente risultato supponendo che ci sia solo un record:

KEY:Carl birth_year: 'strange chars?' full_name:Carl Smith gender:M eduction:electrician state:LA 

Se cambio la mia domanda a questo:

CqlQuery<String, String, Long> cqlQuery = new CqlQuery<String, String, Long> 
TutorialBase.tutorialKeyspace, stringSerializer, stringSerializer, longSerializer); 

    cqlQuery.setQuery("select birth_year from users"); 

Than funziona.

Quindi, come posso farlo con una sola query e se ho più tipi di dati come booleani e float nelle righe di una famiglia di colonne?

Answer 1

Si specifica il tipo di valore come Stringa in CqlRows, quindi ogni valore dovrebbe essere una stringa. Perché si vuole mescolare tipi di valore, si dovrebbe tenere i metadati della colonna, ma anche specificare la classe di validazione di default come BytesType nello schema e quindi utilizzare ByteBuffer come tipo in CqlRows:

QueryResult<CqlRows<String, String, ByteBuffer>> result = cqlQuery.execute(); 

Poi, durante l'elaborazione i valori, si dovrà convertire il tipo appropriato, e invece di iterazione attraverso le colonne, probabilmente otterrete la colonna specifica per nome:

ColumnSlice<String, ByteBuffer> slice = row.getColumnSlice(); 
HColumn<String,ByteBuffer> col = slice.getColumnByName("birth_year"); 
System.out.println(" birth_year: " + col.getValue().getLong()); 

Naturalmente, le stringhe devono essere gestite in modo diverso, utilizzando Java .nio.charset.Charset:

Charset.defaultCharset().decode(col.getValue()).toString() 

È possibile determinare i tipi dai meta-dati Colonna, ma l'ho fatto solo tramite l'API di Thrift (vedere ColumnDef), quindi non sono sicuro di come farlo tramite l'API Hector. Ma HColumn fornisce un metodo getValueSerializer(), quindi potrebbe essere un inizio.