下面列出了怎么用com.amazonaws.services.dynamodbv2.model.DeleteTableResult的API类实例代码及写法,或者点击链接到github查看源代码。
@Override
public DynamoDBResponse deleteTable(DeleteTableRequest deleteTableRequest) {
logger.info("deleting JSON table");
String keyspace = keyspaceName;
String table = deleteTableRequest.getTableName();
String statement = String.format("DROP TABLE %s.\"%s\";\n", keyspace, table);
ResultSet result = session().execute(statement);
if (result.wasApplied()) {
logger.info("deleted table " + table);
cassandraManager.refreshSchema();
TableDescription newTableDesc = this.getTableDescription(table, null,null);
DeleteTableResult createResult = (new DeleteTableResult()).withTableDescription(newTableDesc);
return new DynamoDBResponse(createResult, 200);
}
return null;
}
public DeleteTableResult deleteTable(final DeleteTableRequest request) throws BackendException {
controlPlaneRateLimiter.acquire();
final Timer.Context apiTimerContext = getTimerContext(DELETE_TABLE, request.getTableName());
DeleteTableResult result;
try {
result = client.deleteTable(request);
} catch (Exception e) {
throw processDynamoDbApiException(e, DELETE_TABLE, request.getTableName());
} finally {
apiTimerContext.stop();
}
return result;
}
@Test
public void deleteNoSqlTable() {
TableDescription tableDescription = new TableDescription().withTableArn(ARN).withTableStatus(DELETING_STATUS);
DeleteTableResult deleteResult = new DeleteTableResult().withTableDescription(tableDescription);
when(dynamoDb.deleteTable(argThat((ArgumentMatcher<String>) argument -> true))).thenReturn(deleteResult);
NoSqlTableDeleteResponse result = underTest.deleteNoSqlTable(new NoSqlTableDeleteRequest());
assertEquals(ARN, result.getId());
assertEquals(DELETING_STATUS, result.getTableStatus());
assertEquals(ResponseStatus.OK, result.getStatus());
}
@AfterClass
public static void afterClass() {
DeleteTableResult result = amazonDynamoDBClient.deleteTable(stringHashStringRangeTableName);
result = amazonDynamoDBClient.deleteTable(numberHashNumberRangeTableName);
result = amazonDynamoDBClient.deleteTable(numberHashOnlyTableName);
}
@Override
public DeleteTableResult deleteTable(DeleteTableRequest deleteTableRequest) {
throw new UnsupportedOperationException();
}
@Override
public DeleteTableResult deleteTable(String tableName) {
throw new UnsupportedOperationException();
}
DeleteTableResult deleteTable(final String tableName) throws BackendException {
return deleteTable(new DeleteTableRequest().withTableName(tableName));
}
@AfterClass
public static void afterClass() {
DeleteTableResult result = amazonDynamoDBClient.deleteTable(stringHashStringRangeTableName);
result = amazonDynamoDBClient.deleteTable(numberHashNumberRangeTableName);
result = amazonDynamoDBClient.deleteTable(numberHashOnlyTableName);
}
@Override
public DeleteTableResult deleteTable(DeleteTableRequest arg0)
throws AmazonServiceException, AmazonClientException {
throw new UnsupportedOperationException("Use the underlying client instance instead");
}
@Override
public DeleteTableResult deleteTable(String tableName)
throws AmazonServiceException, AmazonClientException {
throw new UnsupportedOperationException("Use the underlying client instance instead");
}
@Override
public DeleteTableResult deleteTable(DeleteTableRequest request) throws AmazonServiceException, AmazonClientException {
return getBackend().deleteTable(request);
}
@Override
public DeleteTableResult deleteTable(String tableName) throws AmazonServiceException, AmazonClientException {
return getBackend().deleteTable(tableName);
}
@Override
public DeleteTableResult deleteTable(DeleteTableRequest arg0)
throws AmazonServiceException, AmazonClientException {
throw new UnsupportedOperationException("Use the underlying client instance instead");
}
@Override
public DeleteTableResult deleteTable(String tableName)
throws AmazonServiceException, AmazonClientException {
throw new UnsupportedOperationException("Use the underlying client instance instead");
}
@Test
public void test_deleteTable() throws Exception {
createTable();
DeleteTableResult deleteResult = dynamoDb.deleteTable(TEST_TABLE_NAME);
String tableName = deleteResult.getTableDescription().getTableName();
assertThat(tableName, equalTo(TEST_TABLE_NAME));
ListTablesResult listResult = listTables();
assertThat(listResult.getTableNames().size(), equalTo(0));
}