GridFSFile 类表示 GridFS 中的文件的信息,它是一个抽象类,分别被 GridFSDBFile (表示从数据库中读取的文件) 和 GridFSInputFile(表示将要保存到数据库中的文件 ) 继承。
GridFSFile 类包含下列属性(相应地有一系列的 get 方法)
Object _id; // 文件的唯一标识
String _filename; // 文件的名称
String _contentType; // 文件内容类型
long _length; // 文件长度
long _chunkSize; // 文件分块大小
Date _uploadDate; // 更新时间
List<String> _aliases; // 别名
DBObject _extradata = new BasicDBObject(); //额外信息
String _md5; // md5 值
此外它还提供保存文件信息的 save 方法:
// 保存文件
public void save(){
if ( _fs == null )
throw new MongoException( "need _fs" );
_fs._filesCollection.save( this );
}
GridFSDBFile (从数据库中读取的文件)
【将文件写入输出流】
GridFSDBFile 的 writeTo 方法可以将文件写入输出流,以达到读取文件数据的目的。
// 将文件写入输出流
public long writeTo( OutputStream out )
throws IOException {
final int nc = numChunks();
// 遍历文件块,一次写入到输出流中
for ( int i=0; i<nc; i++ ){
out.write( getChunk( i ) );
}
return _length;
}
// 获取特定的文件块
byte[] getChunk( int i ){
if ( _fs == null )
throw new RuntimeException( "no gridfs!" );
// 调用 GridFS 的 _chunkCollection 的 findOne 方法
// _chunkCollection 中存放了文件数据
// 查询时指定了参数 files_id (文件的唯一标识) 和 n (序号)
DBObject chunk = _fs._chunkCollection.findOne( BasicDBObjectBuilder.start( "files_id" , _id ).add( "n" , i ).get() );
if ( chunk == null )
throw new MongoException( "can't find a chunk! file id: " + _id + " chunk: " + i );
// 获取文件块数据
return (byte[])chunk.get( "data" );
}
【获取输入流】
另一种读取数据的方式是直接获取输入流。
// 获取输入流,用于读取数据
public InputStream getInputStream(){
return new MyInputStream();
}
GridFSFile.MyInputStream 的 read 方法实现如下:
// 读取数据
// b 存放数据的字节数组
// off 偏移量
// len 长度
public int read(byte[] b, int off, int len){
// 偏移量超过文件大小
if ( _data == null || _offset >= _data.length ){
// 已经读完
if ( _nextChunk >= _numChunks )
return -1;
// 读取一块数据,以备使用
_data = getChunk( _nextChunk );
_offset = 0;
_nextChunk++;
}
// r:将要读取的数据的长度
int r = Math.min( len , _data.length - _offset );
// 将 _data 中指定偏移量和长度的数据复制到 b 中
System.arraycopy( _data , _offset , b , off , r );
// 增加偏移量
// 在 MyInputStream 内部记录当前的数据块读取到哪里了
// 下次再从这里开始读取
_offset += r;
// 返回读取的长度
return r;
}
【删除操作】
GridFSDBFile 还提供从 GridFS 中删除文件的方法,实际上相当于调用 GridFS 的 remove 方法。
// 从 GridFS 的 _filesCollection 和 _chunkCollection 中删除文件
// 与 GridFS.remove 方法的实现相似, 实际上相当于调用 _fs.remove(_id)
void remove(){
_fs._filesCollection.remove( new BasicDBObject( "_id" , _id ) );
_fs._chunkCollection.remove( new BasicDBObject( "files_id" , _id ) );
}
GridFSInputFile 准备写入数据库的文件
GridFSInputFile 可以获得输出流,从而写入需要保存的数据,写入完毕后通过 close 方法提交修改。
// 获取输出流
public OutputStream getOutputStream() {
if ( _outputStream == null ) {
_outputStream = new MyOutputStream();
}
return _outputStream;
}
GridFSInputFile.MyOutputStream 的 write 方法的实现如下:
public void write( byte[] b , int off , int len ) throws IOException {
int offset = off;
int length = len;
int toCopy = 0;
while ( length > 0 ) {
// 计算每次需要写入的长度
toCopy = length;
if ( toCopy > _chunkSize - _currentBufferPosition ) {
toCopy = (int) _chunkSize - _currentBufferPosition;
}
// 复制数据
System.arraycopy( b, offset, _buffer, _currentBufferPosition, toCopy );
// 修改偏移量
_currentBufferPosition += toCopy;
offset += toCopy;
length -= toCopy;
// 已经到达文件块的结尾,写入数据库
if ( _currentBufferPosition == _chunkSize ) {
_dumpBuffer( false );
}
}
}
// 将缓冲区中的数据写入数据库中
// writePartial 为 true 表示不写入整块的数据,这通常用于写入文件数据的结尾部分。
private void _dumpBuffer( boolean writePartial ) {
if ( ( _currentBufferPosition < _chunkSize ) && !writePartial ) {
// 文件块不完整,返回
return;
}
if (_currentBufferPosition == 0) {
// 块为空,返回
return;
}
// 复制数据
byte[] writeBuffer = _buffer;
if ( _currentBufferPosition != _chunkSize ) {
writeBuffer = new byte[_currentBufferPosition];
System.arraycopy( _buffer, 0, writeBuffer, 0, _currentBufferPosition );
}
// 保存文件数据到数据库
DBObject chunk = BasicDBObjectBuilder.start()
.add( "files_id", _id )
.add( "n", _currentChunkNumber )
.add( "data", writeBuffer ).get();
_fs._chunkCollection.save( chunk );
// 改变偏移量等收尾工作
_currentChunkNumber++;
_totalBytes += writeBuffer.length;
_messageDigester.update( writeBuffer );
_currentBufferPosition = 0;
}
需要特别注意的是以下语句:
// 保存文件数据到数据库
DBObject chunk = BasicDBObjectBuilder.start()
.add( "files_id", _id )
.add( "n", _currentChunkNumber )
.add( "data", writeBuffer ).get();
_fs._chunkCollection.save( chunk );
借助 DBCollection.save 保存了数据。构造的 DBObject 包含三个属性:files_id (文件标识)、n(文件块序号)和 data(文件数据)
分享到:
相关推荐
本篇文章将聚焦于MongoDB Java Driver的源码分析,首先从Package概述的角度进行深入探讨。 MongoDB Java Driver的源码主要分为以下几个核心包: 1. **com.mongodb**: 这是最顶层的包,包含了驱动的核心组件。`...
### MongoDB Java Driver 简单操作详解 #### 一、简介 MongoDB 是一款非常流行的文档型数据库系统,因其灵活性和高性能而被广泛应用于多种场景之中。为了方便开发者使用 Java 进行开发,MongoDB 提供了官方的 Java ...
标签:mongodb、driver、sync、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
12. **安全性**:MongoDB支持身份验证和权限控制,Java驱动API可以进行用户认证,并在连接时指定角色和数据库。 总的来说,MongoDB Java驱动API是一个功能丰富的工具,它提供了对MongoDB所有特性的全面支持,使得...
标签:mongodb、driver、core、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
标签:mongodb、driver、sync、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
java和mongodb连接,需要mongodb-driver,您还必须下载其依赖项: bson和 mongodb-driver-core》》3个包: mongodb-driver-3.8.2.jar; bson-3.8.2.jar; mongodb-driver-core-3.8.2.jar
MongoDB Java Driver 2.11是用于与MongoDB数据库进行交互的Java开发库,它提供了丰富的API,使得Java开发者可以方便地在应用程序中存取和管理MongoDB的数据。MongoDB是一款高性能、分布式、文档型的NoSQL数据库,它...
MongoDB Java驱动是Java开发者与MongoDB数据库交互的重要工具,它允许Java应用程序通过标准的Java API来执行查询、插入、更新和删除等操作。在Java中使用MongoDB,首先需要安装并配置对应的驱动版本,以确保与正在...
6. **聚合框架**:MongoDB的聚合框架允许对数据进行处理和分析。Java驱动程序通过`Aggregation`接口提供支持,允许你构建复杂的管道操作,如`$match`、`$group`、`$sort`等。 7. **异步操作**:对于高并发应用,...
mongodb-java-driver-4.4.0.jar
- `mongo-java-driver-3.4.2.jar`:这是核心的MongoDB Java驱动程序库,包含了所有必要的类和方法,用于在Java应用中连接、查询和操作MongoDB数据库。 - `mongo-java-driver-3.4.2-sources.jar`:这个文件包含驱动...
MongoDB Java Driver是Java开发者用来与MongoDB数据库交互的官方驱动程序。这个源码依赖库包含了一组Java类和接口,使得开发人员能够方便地在应用程序中执行CRUD(创建、读取、更新、删除)操作以及其他高级功能,如...
总的来说,"mongodb-async-driver-2.0.1.jar"这个包是Java开发者与MongoDB数据库交互的强大工具,它通过异步I/O和事件驱动的编程模型,提高了应用的并发能力和响应速度。通过这个驱动,开发者可以充分利用MongoDB的...
`mongodb-driver-3.5.0.jar`是完整版的MongoDB Java驱动,它扩展了`mongodb-driver-core`,提供了更高级别的操作接口,如`MongoClient`和`MongoDatabase`,方便开发者进行数据库操作。这个驱动程序使开发者能够方便...
这里提到的"Java连接mongoDB需要的jar包(3.9.1)"是指Java开发者用于连接MongoDB数据库的一组关键库文件,包括`bson-3.9.1.jar`、`mongodb-driver-3.9.1.jar`和`mongodb-driver-core-3.9.1.jar`。这些JAR文件是...
MongoDB Java驱动程序是Java开发者用来与MongoDB数据库进行交互的官方库。源码分析将帮助我们深入理解其内部工作原理,优化应用性能,并有可能自定义功能以满足特定需求。以下是对MongoDB Java驱动2.5.3版本源码的...
标签:mongodb、driver、core、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
mongo-java-driver-3.4.3.jar 是 MongoDB 官方为 Java 开发者提供的 Java 驱动程序的一个特定版本(3.4.3)。这个 JAR 文件包含了与 MongoDB 数据库进行交互所需的类和接口,允许 Java 应用程序连接到 MongoDB 实例...
MongoDB Java驱动是Java开发者与MongoDB数据库交互的主要工具,它是MongoDB官方提供的一款开源库,使得在Java应用程序中执行CRUD(创建、读取、更新、删除)操作变得简单。MongoDB Java驱动源码程序提供了深入理解其...