aboutsummaryrefslogtreecommitdiff
path: root/other/java
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2023-02-16 21:30:55 -0800
committerchrislu <chris.lu@gmail.com>2023-02-16 21:30:55 -0800
commita9aa2d581fcb246d01bad603cd1164d992ad2cfc (patch)
treedfe2076377ba8804347df39734967df1916af6f1 /other/java
parent79af6b41d450d10f3eaa6c6de40d838610e73e9d (diff)
downloadseaweedfs-a9aa2d581fcb246d01bad603cd1164d992ad2cfc.tar.xz
seaweedfs-a9aa2d581fcb246d01bad603cd1164d992ad2cfc.zip
add some more example
Diffstat (limited to 'other/java')
-rw-r--r--other/java/s3copier/pom.xml4
-rw-r--r--other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java15
2 files changed, 19 insertions, 0 deletions
diff --git a/other/java/s3copier/pom.xml b/other/java/s3copier/pom.xml
index c3ff30932..0050c70da 100644
--- a/other/java/s3copier/pom.xml
+++ b/other/java/s3copier/pom.xml
@@ -5,6 +5,10 @@
<artifactId>copier</artifactId>
<packaging>jar</packaging>
<version>1.0-SNAPSHOT</version>
+ <properties>
+ <maven.compiler.source>18</maven.compiler.source>
+ <maven.compiler.target>18</maven.compiler.target>
+ </properties>
<name>copier</name>
<url>http://maven.apache.org</url>
diff --git a/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java b/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java
index b86df95a0..06e623886 100644
--- a/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java
+++ b/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java
@@ -10,6 +10,8 @@ import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+import com.amazonaws.services.s3.model.CreateBucketRequest;
+import com.amazonaws.services.s3.model.GetBucketLocationRequest;
import com.amazonaws.services.s3.transfer.TransferManager;
import com.amazonaws.services.s3.transfer.TransferManagerBuilder;
import com.amazonaws.services.s3.transfer.Upload;
@@ -42,6 +44,19 @@ public class HighLevelMultipartUpload {
.withS3Client(s3Client)
.build();
+
+ if (!s3Client.doesBucketExistV2(bucketName)) {
+ // Because the CreateBucketRequest object doesn't specify a region, the
+ // bucket is created in the region specified in the client.
+ s3Client.createBucket(new CreateBucketRequest(bucketName));
+
+ // Verify that the bucket was created by retrieving it and checking its location.
+ String bucketLocation = s3Client.getBucketLocation(new GetBucketLocationRequest(bucketName));
+ System.out.println("Bucket location: " + bucketLocation);
+ } else {
+ System.out.println("Bucket already exists");
+ }
+
// TransferManager processes all transfers asynchronously,
// so this call returns immediately.
Upload upload = tm.upload(bucketName, keyName, file);