Skip to content

Commit cfe57dd

Browse files
committed
fixes aliny sync
1 parent 60ceb5a commit cfe57dd

File tree

1 file changed

+52
-52
lines changed

1 file changed

+52
-52
lines changed

dynamodb-driver/src/main/java/org/jnosql/diana/dynamodb/DynamoDBBuilderSync.java

Lines changed: 52 additions & 52 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,6 @@
1414
*/
1515
package org.jnosql.diana.dynamodb;
1616

17-
import java.net.URI;
18-
1917
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
2018
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
2119
import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider;
@@ -24,56 +22,58 @@
2422
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
2523
import software.amazon.awssdk.services.dynamodb.DynamoDbClientBuilder;
2624

27-
public class DynamoDBBuilderSync implements DynamoDBBuilder{
28-
29-
30-
private final DynamoDbClientBuilder dynamoDB = DynamoDbClient.builder();
31-
32-
private String awsAccessKey;
33-
private String awsSecretAccess;
34-
35-
36-
@Override
37-
public void endpoint(String endpoint) {
38-
dynamoDB.endpointOverride(URI.create(endpoint));
39-
}
40-
41-
@Override
42-
public void region(String region) {
43-
dynamoDB.region(Region.of(region));
44-
}
45-
46-
@Override
47-
public void profile(String profile) {
48-
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
25+
import java.net.URI;
26+
27+
public class DynamoDBBuilderSync implements DynamoDBBuilder {
28+
29+
30+
private final DynamoDbClientBuilder dynamoDB = DynamoDbClient.builder();
31+
32+
private String awsAccessKey;
33+
private String awsSecretAccess;
34+
35+
36+
@Override
37+
public void endpoint(String endpoint) {
38+
dynamoDB.endpointOverride(URI.create(endpoint));
39+
}
40+
41+
@Override
42+
public void region(String region) {
43+
dynamoDB.region(Region.of(region));
44+
}
45+
46+
@Override
47+
public void profile(String profile) {
48+
dynamoDB.credentialsProvider(ProfileCredentialsProvider.builder()
4949
.profileName(profile)
5050
.build());
51-
52-
}
53-
54-
public DynamoDbClient build() {
55-
56-
boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
57-
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");
58-
59-
60-
if(accessKey && secretAccess){
61-
62-
AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey,awsSecretAccess);
63-
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
64-
dynamoDB.credentialsProvider(staticCredentialsProvider);
65-
}
66-
67-
return dynamoDB.build();
68-
}
69-
70-
@Override
71-
public void awsAccessKey(String awsAccessKey) {
72-
this.awsAccessKey = awsAccessKey;
73-
}
74-
75-
@Override
76-
public void awsSecretAccess(String awsSecretAccess) {
77-
this.awsSecretAccess = awsSecretAccess;
78-
}
51+
52+
}
53+
54+
public DynamoDbClient build() {
55+
56+
boolean accessKey = awsAccessKey != null && !awsAccessKey.equals("");
57+
boolean secretAccess = awsSecretAccess != null && !awsSecretAccess.equals("");
58+
59+
60+
if (accessKey && secretAccess) {
61+
62+
AwsBasicCredentials awsBasicCredentials = AwsBasicCredentials.create(awsAccessKey, awsSecretAccess);
63+
AwsCredentialsProvider staticCredentialsProvider = StaticCredentialsProvider.create(awsBasicCredentials);
64+
dynamoDB.credentialsProvider(staticCredentialsProvider);
65+
}
66+
67+
return dynamoDB.build();
68+
}
69+
70+
@Override
71+
public void awsAccessKey(String awsAccessKey) {
72+
this.awsAccessKey = awsAccessKey;
73+
}
74+
75+
@Override
76+
public void awsSecretAccess(String awsSecretAccess) {
77+
this.awsSecretAccess = awsSecretAccess;
78+
}
7979
}

0 commit comments

Comments
 (0)