import com.volcengine.tos.TOSV2;
import com.volcengine.tos.TOSV2ClientBuilder;
import com.volcengine.tos.TosClientException;
import com.volcengine.tos.TosServerException;
import com.volcengine.tos.model.object.*;
public class AbortMultipartUploadWithPrefixExample {
public static void main(String[] args) {
String endpoint = "your endpoint";
String region = "your region";
String accessKey = System.getenv("TOS_ACCESS_KEY");
String secretKey = System.getenv("TOS_SECRET_KEY");
String bucketName = "bucket-example";
String prefix = "example_dir/";
TOSV2 tos = new TOSV2ClientBuilder().build(region, endpoint, accessKey, secretKey);
boolean isTruncated = true;
String keyMarker = null;
String uploadIdMarker = null;
ListMultipartUploadsV2Input input = new ListMultipartUploadsV2Input().setBucket(bucketName)
.setKeyMarker(keyMarker).setUploadIDMarker(uploadIdMarker).setPrefix(prefix);
ListMultipartUploadsV2Output output = tos.listMultipartUploads(input);
System.out.printf("listMultipartUploads succeed, is truncated? %b, next uploadIDMarker is %s, " +
"next keyMarker is %s.\n", output.isTruncated(), output.getNextUploadIdMarker(), output.getNextKeyMarker());
if (output.getUploads() != null) {
for (int i = 0; i < output.getUploads().size(); i++) {
ListedUpload upload = output.getUploads().get(i);
AbortMultipartUploadInput abort = new AbortMultipartUploadInput().setBucket(bucketName)
.setKey(upload.getKey()).setUploadID(upload.getUploadID());
tos.abortMultipartUpload(abort);
System.out.println("Aborted upload is " + upload);
isTruncated = output.isTruncated();
keyMarker = output.getNextKeyMarker();
uploadIdMarker = output.getNextUploadIdMarker();
} catch (TosClientException e) {
System.out.println("abortMultipartUpload failed");
System.out.println("Message: " + e.getMessage());
if (e.getCause() != null) {
e.getCause().printStackTrace();
} catch (TosServerException e) {
System.out.println("abortMultipartUpload failed");
System.out.println("StatusCode: " + e.getStatusCode());
System.out.println("Code: " + e.getCode());
System.out.println("Message: " + e.getMessage());
System.out.println("RequestID: " + e.getRequestID());
System.out.println("abortMultipartUpload failed");
System.out.println("unexpected exception, message: " + t.getMessage());