public class Java1094Test extends TestCase {

    @Test
    public void testOutputStream() throws Exception {

        String name = "JAVA-1094";
        DB db = new MongoClient().getDB(name);
        db.dropDatabase();
        db.setWriteConcern(WriteConcern.UNACKNOWLEDGED);
        GridFS fs = new GridFS(db);


        GridFSInputFile created = fs.createFile(name);
        created.setId(name);

        OutputStream writeStream = created.getOutputStream();
        writeStream.write("MongoDB".getBytes());
        writeStream.close();

        GridFSDBFile out = fs.findOne(name);
        assertEquals(out.getLength(), 7);

        GridFSInputFile update = fs.createFile(name);
        
        // This will trigger a Duplicate Key error but we don't acknowledge the write.
        update.setId(name);
        OutputStream updatedWriteStream = update.getOutputStream();
        updatedWriteStream.write("MongoDB Rules".getBytes());
        updatedWriteStream.close();

        GridFSDBFile out1 = fs.findOne(name);
        assertEquals(out1.getLength(), 7);
    }

}