rzg4zHfe

1package routines;
2
3import java.sql.Blob;
4import com.amazonaws.auth.BasicAWSCredentials;
5import com.amazonaws.services.s3.AmazonS3;
6import com.amazonaws.services.s3.AmazonS3Client;
7import com.amazonaws.services.s3.model.ObjectMetadata;
8import com.amazonaws.services.s3.model.PutObjectRequest;
9
10public class BlobToS3Helper {
11
12	public static void put(Object input, String keyName, String bucketName, String accessKey, String secretKey) {
13		if (input instanceof Blob) {
14			Blob blob = (Blob) input;
15
16			try {
17				BasicAWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
18				AmazonS3 s3client = new AmazonS3Client(credentials);
19				ObjectMetadata metadata = new ObjectMetadata();
20				metadata.setContentLength(blob.length());
21				s3client.putObject(new PutObjectRequest(bucketName, keyName, blob.getBinaryStream(), metadata));
22			} catch (Exception e) {
23				e.printStackTrace();
24			}
25		}
26	}
27}