Seamless Media Storage: Integrating Azure Blob Storage and MongoDB With Spring Boot

1
spring.data.mongodb.uri=mongodb+srv://<username>:<password>@<cluster>.mongodb.net/
2
spring.data.mongodb.database=userPosts
3
server.port=8080

1
azure.blob-storage.connection-string=<connection.string>
2
spring.cloud.azure.storage.blob.container-name=<container.name>

1
@Document("imageMetadata")
2
public class ImageMetadata {
3
	
4
	@Id
5
	private String id;
6
	private String caption;
7
	private String imageUrl;
8
	
9
	// getters and setters
10
}

1
package com.example.azureblob.repositories;
2
3
import com.example.azureblob.models.ImageMetadata;
4
import org.springframework.data.mongodb.repository.MongoRepository;
5
6
public interface ImageMetadataRepository extends MongoRepository<ImageMetadata, String> {
7
}

1
@Service
2
public class ImageMetadataService {
3
4
    @Autowired
5
    private ImageMetadataRepository imageMetadataRepository;
6
    
7
    @Value("${spring.cloud.azure.storage.blob.container-name}")
8
    private String containerName;
9
    
10
    @Value("${azure.blob-storage.connection-string}")
11
    private String connectionString;
12
13
    private BlobServiceClient blobServiceClient;
14
15
    @PostConstruct
16
    public void init() {
17
        blobServiceClient = new BlobServiceClientBuilder().connectionString(connectionString).buildClient();
18
    }
19
20
    public ImageMetadata save(ImageMetadata metadata) {
21
        return imageMetadataRepository.save(metadata);
22
    }
23
24
    public List<ImageMetadata> findAll() {
25
        return imageMetadataRepository.findAll();
26
    }
27
28
    public Optional<ImageMetadata> findById(String id) {
29
        return imageMetadataRepository.findById(id);
30
    }
31
    
32
    public String uploadImageWithCaption(MultipartFile imageFile, String caption) throws IOException {
33
        String blobFileName = imageFile.getOriginalFilename();
34
        BlobClient blobClient = blobServiceClient.getBlobContainerClient(containerName).getBlobClient(blobFileName);
35
36
        blobClient.upload(imageFile.getInputStream(), imageFile.getSize(), true);
37
38
        String imageUrl = blobClient.getBlobUrl();
39
        
40
        ImageMetadata metadata = new ImageMetadata();
41
        metadata.setCaption(caption);
42
        metadata.setImageUrl(imageUrl);
43
        
44
        imageMetadataRepository.save(metadata);
45
46
        return "Image and metadata uploaded successfully!";
47
    }
48
}

1
@RestController
2
@RequestMapping("/image-metadata")
3
public class ImageMetadataController {
4
	
5
	@Autowired
6
	private ImageMetadataService imageMetadataService;
7
	
8
	@PostMapping("/upload")
9
	public String uploadImageWithCaption(@RequestParam("image") MultipartFile imageFile, @RequestParam("caption") String caption) throws IOException {
10
		return imageMetadataService.uploadImageWithCaption(imageFile, caption);
11
	}
12
	
13
	@GetMapping("/")
14
	public List<ImageMetadata> getAllImageMetadata() {
15
		return imageMetadataService.findAll();
16
	}
17
	
18
	@GetMapping("/{id}")
19
	public ImageMetadata getImageMetadataById(@PathVariable String id) {
20
		return imageMetadataService.findById(id).orElse(null);
21
	}
22
}

1
curl -F "image=mongodb-is-webscale.png" -F "caption=MongoDB is Webscale" http://localhost:8080/blob/upload