import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Connect.
 * @return Region
 */
private static Region connect() {
    final String key = Manifests.read("Rehttp-DynamoKey");
    final Credentials creds = new Credentials.Simple(
        key, Manifests.read("Rehttp-DynamoSecret")
    );
    final Region region;
    if (key.startsWith("AAAAA")) {
        final int port = Integer.parseInt(
            System.getProperty("dynamo.port")
        );
        region = new Region.Simple(new Credentials.Direct(creds, port));
        Logger.warn(Entrance.class, "Test DynamoDB at port #%d", port);
    } else {
        region = new Region.Prefixed(
            new ReRegion(new Region.Simple(creds)),
            "rehttp-"
        );
    }
    Logger.info(Entrance.class, "DynamoDB connected as %s", key);
    return region;
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Connect.
 * @return Region
 */
private static Region connect() {
    final String key = Manifests.read("ThreeCopies-DynamoKey");
    final Credentials creds = new Credentials.Simple(
        key, Manifests.read("ThreeCopies-DynamoSecret")
    );
    final Region region;
    if (key.startsWith("AAAAA")) {
        final int port = Integer.parseInt(
            System.getProperty("dynamo.port")
        );
        region = new Region.Simple(new Credentials.Direct(creds, port));
        Logger.warn(Dynamo.class, "Test DynamoDB at port #%d", port);
    } else {
        region = new Region.Prefixed(
            new ReRegion(new Region.Simple(creds)),
            "tc-"
        );
    }
    Logger.info(Dynamo.class, "DynamoDB connected as %s", key);
    return region;
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Connect.
 * @return Region
 */
private static Region connect() {
    final String key = Manifests.read("Jare-DynamoKey");
    final Credentials creds = new Credentials.Simple(
        key, Manifests.read("Jare-DynamoSecret")
    );
    final Region region;
    if (key.startsWith("AAAAA")) {
        final int port = Integer.parseInt(
            System.getProperty("dynamo.port")
        );
        region = new Region.Simple(new Credentials.Direct(creds, port));
        Logger.warn(Dynamo.class, "test DynamoDB at port #%d", port);
    } else {
        region = new Region.Prefixed(
            new ReRegion(new Region.Simple(creds)),
            "jare-"
        );
    }
    Logger.info(Dynamo.class, "DynamoDB connected as %s", key);
    return region;
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Dynamo DB region.
 * @return Region
 */
private static Region dynamo() {
    final String key = Manifests.read("Thindeck-DynamoKey");
    Credentials creds = new Credentials.Simple(
        key, Manifests.read("Thindeck-DynamoSecret")
    );
    if (key.startsWith("AAAAA")) {
        final String port = System.getProperty("dynamo.port");
        if (port == null) {
            throw new IllegalStateException(
                "dynamo.port system property is not set, check pom.xml"
            );
        }
        creds = new Credentials.Direct(
            creds,
            Integer.parseInt(port)
        );
    }
    return new Region.Prefixed(
        new ReRegion(new Region.Simple(creds)), "td-"
    );
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Dynamo DB region.
 * @return Region
 */
private Region dynamo() {
    final String key = Manifests.read("Bib-DynamoKey");
    Credentials creds = new Credentials.Simple(
        key,
        Manifests.read("Bib-DynamoSecret")
    );
    if (key.startsWith("AAAAA")) {
        final int port = Integer.parseInt(
            System.getProperty("dynamo.port")
        );
        creds = new Credentials.Direct(creds, port);
        Logger.warn(this, "test DynamoDB at port #%d", port);
    }
    return new Region.Prefixed(
        new ReRegion(new Region.Simple(creds)), "bib-"
    );
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * DynamoDB region for tests.
 * @return Region
 */
public Region region() {
    final String key = Manifests.read("Bib-DynamoKey");
    MatcherAssert.assertThat(key.startsWith("AAAA"), Matchers.is(true));
    return new Region.Prefixed(
        new ReRegion(
            new Region.Simple(
                new Credentials.Direct(
                    new Credentials.Simple(
                        key,
                        Manifests.read("Bib-DynamoSecret")
                    ),
                    Integer.parseInt(System.getProperty("dynamo.port"))
                )
            )
        ),
        "bib-"
    );
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Connect.
 * @return Region
 */
private static Region connect() {
    final String key = Manifests.read("Wring-DynamoKey");
    final Credentials creds = new Credentials.Simple(
        key,
        Manifests.read("Wring-DynamoSecret")
    );
    final Region region;
    if (key.startsWith("AAAAA")) {
        final String property = System.getProperty("dynamo.port");
        if (property == null) {
            throw new IllegalStateException(
                "You're not supposed to run this test outside of Maven"
            );
        }
        final int port = Integer.parseInt(property);
        region = new Region.Simple(new Credentials.Direct(creds, port));
        Logger.warn(Dynamo.class, "test DynamoDB at port #%d", port);
    } else {
        region = new Region.Prefixed(
            new ReRegion(new Region.Simple(creds)),
            "wring-"
        );
    }
    Logger.info(Dynamo.class, "DynamoDB connected as %s", key);
    return region;
}
 

import com.jcabi.dynamo.retry.ReRegion; //导入依赖的package包/类
/**
 * Get region with a table.
 * @param table Table name
 * @return Region
 * @throws Exception If fails
 */
public Region get(final String table) throws Exception {
    final Region region = new Region.Simple(
        new Credentials.Direct(Credentials.TEST, this.prt)
    );
    final MadeTable mocker = new MadeTable(
        region,
        new CreateTableRequest()
            .withTableName(table)
            .withProvisionedThroughput(
                new ProvisionedThroughput()
                    .withReadCapacityUnits(1L)
                    .withWriteCapacityUnits(1L)
            )
            .withAttributeDefinitions(
                new AttributeDefinition()
                    .withAttributeName(this.ahash)
                    .withAttributeType(ScalarAttributeType.S),
                new AttributeDefinition()
                    .withAttributeName(this.arange)
                    .withAttributeType(ScalarAttributeType.N)
            )
            .withKeySchema(
                new KeySchemaElement()
                    .withAttributeName(this.ahash)
                    .withKeyType(KeyType.HASH),
                new KeySchemaElement()
                    .withAttributeName(this.arange)
                    .withKeyType(KeyType.RANGE)
            )
    );
    mocker.create();
    mocker.createIfAbsent();
    return new ReRegion(region);
}