Get Data

src/main/java/com/admatic/GetUserData.java

package com.admatic;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;

import java.util.UUID;

public class GetUserData {
    private static String[] CONTACT_POINTS = {"127.0.0.1"};

    public static void main(String[] args) {
        GetUserData client = new GetUserData();

        try {
            client.connect(CONTACT_POINTS, 9042);
            client.loadData();
        } finally {
            client.close();
        }
    }

    private Cluster cluster;

    private Session session;

    private void connect(String[] contactPoints, int port) {

        cluster = Cluster.builder()
                .addContactPoints(contactPoints).withPort(port)
                .build();

        System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName());

        session = cluster.connect();
    }

    private void loadData() {
        int i = 0;
        long startTime = System.nanoTime();
        ResultSet resultUsername = session.execute("SELECT * FROM admatic.users_by_username");
        for (Row row : resultUsername) {
            i++;
            System.out.printf("%s\t%s\t%d%n",
                    row.getString("username"),
                    row.getString("email"),
                    row.getInt("age"));

        }
        long stopTime = System.nanoTime();

        int j = 0;
        long startTime2 = System.nanoTime();
        ResultSet resultEmail = session.execute("SELECT * FROM admatic.users_by_email");
        for (Row row : resultEmail) {
            j++;
            System.out.printf("%s\t%s\t%d%n",
                    row.getString("username"),
                    row.getString("email"),
                    row.getInt("age"));

        }
        long stopTime2 = System.nanoTime();

        System.out.println(i + ":" + (stopTime - startTime));
        System.out.println(j + ":" + (stopTime2 - startTime2));
    }

    private void close() {
        session.close();
        cluster.close();
    }
}

src/main/java/com/admatic/GetOtherData.java

package com.admatic;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;

public class GetOtherData {
    private static String[] CONTACT_POINTS = {"127.0.0.1"};

    public static void main(String[] args) {
        GetOtherData client = new GetOtherData();

        try {
            client.connect(CONTACT_POINTS, 9042);
            client.loadData();
        } finally {
            client.close();
        }
    }

    private Cluster cluster;

    private Session session;

    private void connect(String[] contactPoints, int port) {

        cluster = Cluster.builder()
                .addContactPoints(contactPoints).withPort(port)
                .build();

        System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName());

        session = cluster.connect();
    }

    private void loadData() {
        int i = 0;
        long startTime = System.nanoTime();
        ResultSet resultUsername = session.execute("SELECT * FROM others.users_by_username");
        for (Row row : resultUsername) {
            i++;
            ResultSet resultSet = session.execute("SELECT * FROM others.users WHERE id=" + row.getUUID("id"));
            for (Row r : resultSet) {
                System.out.printf("%s\t%s\t%d%n",
                        r.getString("username"),
                        r.getString("email"),
                        r.getInt("age"));
            }
        }
        long stopTime = System.nanoTime();

        int j = 0;
        long startTime2 = System.nanoTime();
        ResultSet resultEmail = session.execute("SELECT * FROM others.users_by_email");
        for (Row row : resultEmail) {
            j++;
            ResultSet resultSet = session.execute("SELECT * FROM others.users WHERE id=" + row.getUUID("id"));
            for (Row r : resultSet) {
                System.out.printf("%s\t%s\t%d%n",
                        r.getString("username"),
                        r.getString("email"),
                        r.getInt("age"));
            }
        }
        long stopTime2 = System.nanoTime();

        System.out.println(i + ":" + (stopTime - startTime));
        System.out.println(j + ":" + (stopTime2 - startTime2));
    }

    private void close() {
        session.close();
        cluster.close();
    }
}