Skip to content

Commit

Permalink
fixes aliny sync
Browse files Browse the repository at this point in the history
  • Loading branch information
otaviojava committed Feb 10, 2019
1 parent 60ceb5a commit cfe57dd
Showing 1 changed file with 52 additions and 52 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,6 @@
*/
package org.jnosql.diana.dynamodb;

import java.net.URI;

import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider;
Expand All @@ -24,56 +22,58 @@
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
import software.amazon.awssdk.services.dynamodb.DynamoDbClientBuilder;

public class DynamoDBBuilderSync implements DynamoDBBuilder{


private final DynamoDbClientBuilder dynamoDB = DynamoDbClient.builder();

private String awsAccessKey;
private String awsSecretAccess;


@Override
public void endpoint(String endpoint) {
dynamoDB.endpointOverride(URI.create(endpoint));
}

@Override
public void region(String region) {
dynamoDB.region(Region.of(region));
}

@Override
public void profile(String profile) {
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
import java.net.URI;

public class DynamoDBBuilderSync implements DynamoDBBuilder {


private final DynamoDbClientBuilder dynamoDB = DynamoDbClient.builder();

private String awsAccessKey;
private String awsSecretAccess;


@Override
public void endpoint(String endpoint) {
dynamoDB.endpointOverride(URI.create(endpoint));
}

@Override
public void region(String region) {
dynamoDB.region(Region.of(region));
}

@Override
public void profile(String profile) {
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
.profileName(profile)
.build());
}

public DynamoDbClient build() {
boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");
if(accessKey && secretAccess){
AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey,awsSecretAccess);
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
dynamoDB.credentialsProvider(staticCredentialsProvider);
}
return dynamoDB.build();
}

@Override
public void awsAccessKey(String awsAccessKey) {
this.awsAccessKey = awsAccessKey;
}

@Override
public void awsSecretAccess(String awsSecretAccess) {
this.awsSecretAccess = awsSecretAccess;
}

}

public DynamoDbClient build() {

boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");


if (accessKey && secretAccess) {

AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey, awsSecretAccess);
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
dynamoDB.credentialsProvider(staticCredentialsProvider);
}

return dynamoDB.build();
}

@Override
public void awsAccessKey(String awsAccessKey) {
this.awsAccessKey = awsAccessKey;
}

@Override
public void awsSecretAccess(String awsSecretAccess) {
this.awsSecretAccess = awsSecretAccess;
}
}

0 comments on commit cfe57dd

Please sign in to comment.