Tag: MongoDB

// This code is just for my reference
 public static void main(String[] args) {
        Logger mongoLogger = Logger.getLogger( "org.mongodb.driver" );
        mongoLogger.setLevel(Level.SEVERE);

        MongoClient mongoClient = MongoClients.create();
        MongoDatabase database = mongoClient.getDatabase("testdb");

        GridFSBucket gridFSFilesBucket = GridFSBuckets.create(database);
        ObjectId fileId = new ObjectId();
        try {

            InputStream streamToUploadFrom = new FileInputStream(new File("d:\\200mb.mkv"));

//            GridFSUploadOptions options = new GridFSUploadOptions()
//                    .chunkSizeBytes(1000)
//                    .metadata(new Document("type", "presentation"));

            fileId = gridFSFilesBucket.uploadFromStream("myfile", streamToUploadFrom);

            System.out.println("ObjectID" + fileId);
        } catch(FileNotFoundException ex) {
            System.out.println("Error" + ex.getMessage());
        }


        try {
            FileOutputStream streamToDownloadTo = new FileOutputStream("d:/out.mkv");
            gridFSFilesBucket.downloadToStream(fileId , streamToDownloadTo);
            streamToDownloadTo.close();
            System.out.println("Finished!");
        } catch (IOException e) {
            // handle exception
        }
    }