Vorheriges Nächstes

Vorgehensweise beim Angeben der aus einer Cassandra-Datenquelle abzurufenden Daten

Verwenden Sie in dieser Prozedur die folgende Klausel für Öffnen in einer CQL-Abfrage:

importPackage(Packages.java.util);
importPackage(Packages.me.prettyprint.cassandra.serializers);
importPackage(Packages.me.prettyprint.cassandra.service);
importPackage(Packages.me.prettyprint.hector.api);
importPackage(Packages.me.prettyprint.hector.api.beans);
importPackage(Packages.me.prettyprint.hector.api.factory);
importPackage(Packages.me.prettyprint.hector.api.query);
importPackage(Packages.me.prettyprint.cassandra.model);
var cluster = HFactory.getOrCreateCluster("Test Cluster",new CassandraHostConfigurator("192.168.218.246:9160"));
var keyspace = HFactory.createKeyspace("users", cluster);
var cqlQuery = new CqlQuery(keyspace, StringSerializer.get(), StringSerializer.get(), StringSerializer.get());
cqlQuery.setQuery("select * from User");
var resultCQL = cqlQuery.execute();
rowsIterator = resultCQL.get().iterator();

Verwenden Sie darüber hinaus die folgende Klause für Abrufen:

if (rowsIterator.hasNext()) {
var myrow = rowsIterator.next();
var cols = myrow.getColumnSlice().getColumns();
for( ii=0; ii < cols.size(); ii++ ){
row[cols.get(ii).getName()] = cols.get(ii).getValue();
}
return true;
}else{
return false;
}
1  
2  
1  
2  
3  
3  
*
*
*
*
*
*
Wenn Sie alle Eigenschaften der Datensatzspalte angegeben haben, wählen Sie OK aus.

Abbildung 2-2: Ausgabespalte hinzufügen

Abbildung 2-2  Ausgabespalte hinzufügen
Die angegebenen Ausgabespalten werden unter 'Neuer Datensatz' angezeigt (siehe Abbildung 2-3). In diesem Beispiel handelt es sich bei den Ausgabespalten um 'first' (Vorname), 'last' (Nachname) und 'age' (Alter).

Abbildung 2-3: Abzurufende Ausgabespalten angeben

Abbildung 2-3  Abzurufende Ausgabespalten angeben
4  
5  
1  
importPackage(Packages.java.util);
importPackage(Packages.me.prettyprint.cassandra.serializers);
importPackage(Packages.me.prettyprint.cassandra.service);
importPackage(Packages.me.prettyprint.hector.api);
importPackage(Packages.me.prettyprint.hector.api.beans);
importPackage(Packages.me.prettyprint.hector.api.factory);
importPackage(Packages.me.prettyprint.hector.api.query);
importPackage(Packages.me.prettyprint.cassandra.model);
var cluster = HFactory.getOrCreateCluster("Test Cluster",new CassandraHostConfigurator("192.168.218.246:9160"));
var keyspace = HFactory.createKeyspace("users", cluster);
var cqlQuery = new CqlQuery(keyspace, StringSerializer.get(), StringSerializer.get(), StringSerializer.get());
cqlQuery.setQuery("select * from User");
var resultCQL = cqlQuery.execute();
rowsIterator = resultCQL.get().iterator();

Abbildung 2-4: Klausel für 'Öffnen' angeben

Abbildung 2-4  Klausel für 'Öffnen' angeben
2  
if (rowsIterator.hasNext()) {
var myrow = rowsIterator.next();
var cols = myrow.getColumnSlice().getColumns();
for( ii=0; ii < cols.size(); ii++ ){
row[cols.get(ii).getName()] = cols.get(ii).getValue();
}
return true;
}else{
return false;
}

Abbildung 2-5: Klausel für 'Abrufen' angeben

Abbildung 2-5  Klausel für 'Abrufen' angeben
3  

(c) Copyright Actuate Corporation 2013