com.mongodb.client.gridfs

Class GridFSUploadStreamImpl

java.lang.Object

java.io.OutputStream

com.mongodb.client.gridfs.GridFSUploadStream

com.mongodb.client.gridfs.GridFSUploadStreamImpl

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

final class GridFSUploadStreamImpl
extends GridFSUploadStream

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buffer
private int	bufferOffset
private int	chunkIndex
private MongoCollection<Document>	chunksCollection
private int	chunkSizeBytes
private boolean	closed
private java.lang.Object	closeLock
private BsonValue	fileId
private java.lang.String	filename
private MongoCollection<GridFSFile>	filesCollection
private long	lengthInBytes
private java.security.MessageDigest	md5
private Document	metadata

Constructor Summary

Constructors

Constructor and Description
GridFSUploadStreamImpl(MongoCollection<GridFSFile> filesCollection, MongoCollection<Document> chunksCollection, BsonValue fileId, java.lang.String filename, int chunkSizeBytes, Document metadata)

Method Summary

Modifier and Type	Method and Description
void	abort() Aborts the upload and deletes any data.
private void	checkClosed()
void	close()
private Binary	getData()
ObjectId	getFileId() Deprecated.
BsonValue	getId() Gets the BsonValue for the file to be uploaded
ObjectId	getObjectId() Gets the ObjectId for the file to be uploaded or throws an error if an alternative BsonType has been used for the id.
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)
private void	writeChunk()

Methods inherited from class com.mongodb.client.gridfs.GridFSUploadStream

flush

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

filesCollection

private final MongoCollection<GridFSFile> filesCollection

chunksCollection

private final MongoCollection<Document> chunksCollection

fileId

private final BsonValue fileId

filename

private final java.lang.String filename

chunkSizeBytes

private final int chunkSizeBytes

metadata

private final Document metadata

md5

private final java.security.MessageDigest md5

buffer

private byte[] buffer

lengthInBytes

private long lengthInBytes

bufferOffset

private int bufferOffset

chunkIndex

private int chunkIndex

closeLock

private final java.lang.Object closeLock

closed

private boolean closed

Constructor Detail

GridFSUploadStreamImpl

GridFSUploadStreamImpl(MongoCollection<GridFSFile> filesCollection,
                       MongoCollection<Document> chunksCollection,
                       BsonValue fileId,
                       java.lang.String filename,
                       int chunkSizeBytes,
                       Document metadata)

Method Detail

getFileId

@Deprecated
public ObjectId getFileId()

Deprecated.

Description copied from class: GridFSUploadStream

Gets the ObjectId for the file to be uploaded Throws a MongoGridFSException if the file id is not an ObjectId.

Specified by:

getFileId in class GridFSUploadStream

Returns:

the ObjectId for the file to be uploaded

getObjectId

public ObjectId getObjectId()

Description copied from class: GridFSUploadStream

Gets the ObjectId for the file to be uploaded or throws an error if an alternative BsonType has been used for the id. Throws a MongoGridFSException if the file id is not an ObjectId.

Specified by:

getObjectId in class GridFSUploadStream

Returns:

the ObjectId for the file to be uploaded

getId

public BsonValue getId()

Description copied from class: GridFSUploadStream

Gets the BsonValue for the file to be uploaded

Specified by:

getId in class GridFSUploadStream

Returns:

the BsonValue for the file to be uploaded

abort

public void abort()

Description copied from class: GridFSUploadStream

Aborts the upload and deletes any data.

Specified by:

abort in class GridFSUploadStream

write

public void write(int b)

Specified by:

write in class GridFSUploadStream

write

public void write(byte[] b)

Specified by:

write in class GridFSUploadStream

write

public void write(byte[] b,
                  int off,
                  int len)

Specified by:

write in class GridFSUploadStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class GridFSUploadStream

writeChunk

private void writeChunk()

getData

private Binary getData()

checkClosed

private void checkClosed()