O arquivo TryDaxTests.java
contém métodos que executam operações de leitura em uma tabela de teste no Amazon DynamoDB. Esses métodos não consideram como os dados serão acessados (usando o cliente do DynamoDB ou o cliente do DAX) e, portanto, não é necessário modificar a lógica da aplicação.
É possível modificar o programa de várias maneiras:
-
Modifique o método
queryTest
para que ele use umKeyConditionExpression
diferente. -
Adicione um
ScanFilter
ao métodoscanTest
, para que apenas alguns dos itens sejam retornados para você.
nota
Para executar o programa, é possível configurar o Maven para usar o cliente do SDK for Java do DAX e o AWS SDK for Java como dependências. Para ter mais informações, consulte Usar o cliente como dependência do Apache Maven.
Ou você pode fazer download e incluir o cliente Java do DAX e o AWS SDK for Java em seu classpath. Consulte Java e DAX para obter um exemplo de configuração da variável CLASSPATH
.
import java.util.Iterator;
import com.amazonaws.services.dynamodbv2.document.DynamoDB;
import com.amazonaws.services.dynamodbv2.document.Item;
import com.amazonaws.services.dynamodbv2.document.ItemCollection;
import com.amazonaws.services.dynamodbv2.document.QueryOutcome;
import com.amazonaws.services.dynamodbv2.document.ScanOutcome;
import com.amazonaws.services.dynamodbv2.document.Table;
import com.amazonaws.services.dynamodbv2.document.spec.QuerySpec;
public class TryDaxTests {
void getItemTest(String tableName, DynamoDB client, int pk, int sk, int iterations) {
long startTime, endTime;
System.out.println("GetItem test - partition key " + pk + " and sort keys 1-" + sk);
Table table = client.getTable(tableName);
for (int i = 0; i < iterations; i++) {
startTime = System.nanoTime();
try {
for (Integer ipk = 1; ipk <= pk; ipk++) {
for (Integer isk = 1; isk <= sk; isk++) {
table.getItem("pk", ipk, "sk", isk);
}
}
} catch (Exception e) {
System.err.println("Unable to get item:");
e.printStackTrace();
}
endTime = System.nanoTime();
printTime(startTime, endTime, pk * sk);
}
}
void queryTest(String tableName, DynamoDB client, int pk, int sk1, int sk2, int iterations) {
long startTime, endTime;
System.out.println("Query test - partition key " + pk + " and sort keys between " + sk1 + " and " + sk2);
Table table = client.getTable(tableName);
HashMap<String, Object> valueMap = new HashMap<String, Object>();
valueMap.put(":pkval", pk);
valueMap.put(":skval1", sk1);
valueMap.put(":skval2", sk2);
QuerySpec spec = new QuerySpec()
.withKeyConditionExpression("pk = :pkval and sk between :skval1 and :skval2")
.withValueMap(valueMap);
for (int i = 0; i < iterations; i++) {
startTime = System.nanoTime();
ItemCollection<QueryOutcome> items = table.query(spec);
try {
Iterator<Item> iter = items.iterator();
while (iter.hasNext()) {
iter.next();
}
} catch (Exception e) {
System.err.println("Unable to query table:");
e.printStackTrace();
}
endTime = System.nanoTime();
printTime(startTime, endTime, iterations);
}
}
void scanTest(String tableName, DynamoDB client, int iterations) {
long startTime, endTime;
System.out.println("Scan test - all items in the table");
Table table = client.getTable(tableName);
for (int i = 0; i < iterations; i++) {
startTime = System.nanoTime();
ItemCollection<ScanOutcome> items = table.scan();
try {
Iterator<Item> iter = items.iterator();
while (iter.hasNext()) {
iter.next();
}
} catch (Exception e) {
System.err.println("Unable to scan table:");
e.printStackTrace();
}
endTime = System.nanoTime();
printTime(startTime, endTime, iterations);
}
}
public void printTime(long startTime, long endTime, int iterations) {
System.out.format("\tTotal time: %.3f ms - ", (endTime - startTime) / (1000000.0));
System.out.format("Avg time: %.3f ms\n", (endTime - startTime) / (iterations * 1000000.0));
}
}