in java/datastax-v4/connection-vpc-endpoint/src/main/java/software/aws/mcs/example/OrderFetcher.java [36:64]
public static void main(String[] args) {
if (args.length != 3) {
System.err.println("Usage: OrderFetcher <region> <endpoint> <customer ID>");
System.exit(1);
}
// Both of these can be speficied in the configuration, but
// are being done programmatically here for flexibility as
// example code.
SigV4AuthProvider provider = new SigV4AuthProvider(args[0]);
List<InetSocketAddress> contactPoints = Collections.singletonList(new InetSocketAddress(args[1], 9142));
try (CqlSession session = CqlSession.builder().addContactPoints(contactPoints).withAuthProvider(provider).withLocalDatacenter(args[0]).build()) {
// Use a prepared query for quoting
PreparedStatement prepared = session.prepare("select * from acme.orders where customer_id = ?");
// We use execute to send a query to Cassandra. This returns a ResultSet, which is essentially a collection
// of Row objects.
ResultSet rs = session.execute(prepared.bind(args[2]));
// Print the header
System.out.printf(TABLE_FORMAT, "Date", "Order Id");
for (Row row : rs) {
System.out.printf(TABLE_FORMAT, row.getInstant("order_timestamp"), row.getUuid("order_id"));
}
}
}