类com.amazonaws.services.dynamodbv2.model.DeleteTableResult源码实例Demo

下面列出了怎么用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;
}
 
源代码3 项目: cloudbreak   文件: AwsNoSqlConnectorTest.java
@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);
}
 
源代码5 项目: podyn   文件: PostgresDynamoDB.java
@Override
public DeleteTableResult deleteTable(DeleteTableRequest deleteTableRequest) {
	
	throw new UnsupportedOperationException();
}
 
源代码6 项目: podyn   文件: PostgresDynamoDB.java
@Override
public DeleteTableResult deleteTable(String tableName) {
	
	throw new UnsupportedOperationException();
}
 
DeleteTableResult deleteTable(final String tableName) throws BackendException {
    return deleteTable(new DeleteTableRequest().withTableName(tableName));
}
 
源代码8 项目: nifi   文件: ITAbstractDynamoDBTest.java
@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));
}
 
 类方法
 同包方法