ก่อนหน้า ถัดไป

วิธีระบุข้อมูลที่ต้องการดึงจากแหล่งข้อมูล Cassandra

ในโพรซีเดอร์นี้ ให้ใช้อนุประโยค open ต่อไปนี้ในเคียวรี CQL:

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();

นอกจากนี้ให้ใช้อนุประโยค fetch ต่อไปนี้:

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  
*
*
*
*
*
*
เมื่อเสร็จสิ้นการระบุคุณสมบัติคอลัมน์ชุดข้อมูลแล้ว ให้เลือก ตกลง

รูปที่ 2-2 การเพิ่มคอลัมน์เอาต์พุต

รูปที่ 2-2  การเพิ่มคอลัมน์เอาต์พุต
คอลัมน์เอาต์พุตที่ระบุจะปรากฏใน ชุดข้อมูลใหม่ ดังแสดงใน รูปที่ 2-3 ในตัวอย่างนี้ คอลัมน์เอาต์พุตคือ ชื่อ นามสกุล และอายุ

รูปที่ 2-3 การระบุคอลัมน์เอาต์พุตที่ต้องการดึงข้อมูล

รูปที่ 2-3  การระบุคอลัมน์เอาต์พุตที่ต้องการดึงข้อมูล
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();

รูปที่ 2-4 การระบุอนุประโยค open

รูปที่ 2-4  การระบุอนุประโยค open
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;
}

รูปที่ 2-5 การระบุอนุประโยค fetch

รูปที่ 2-5  การระบุอนุประโยค fetch
3  

(c) ลิขสิทธิ์ Actuate Corporation 2013