public static void main()

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"));
            }
        }

    }