net.ymate.platform.persistence.mongodb.impl

Class MongoGridFsSession

java.lang.Object

net.ymate.platform.core.persistence.AbstractSession<IMongoConnectionHolder>

net.ymate.platform.persistence.mongodb.impl.MongoGridFsSession

All Implemented Interfaces:

AutoCloseable, ISession<IMongoConnectionHolder>, IDestroyable, IGridFsSession

public class MongoGridFsSession
extends AbstractSession<IMongoConnectionHolder>
implements IGridFsSession

Author:

刘镇 (suninformation@163.com) on 15/11/26 上午11:12

Constructor Summary

Constructors

Constructor and Description
MongoGridFsSession(IMongoConnectionHolder connectionHolder)
MongoGridFsSession(IMongoConnectionHolder connectionHolder, String bucketName)

Method Summary

Modifier and Type	Method and Description
void	close()
void	download(String id, File distFile) 下载文件数据并写入指定的文件
void	download(String id, OutputStream outputStream) 下载文件数据到指定的输出流
boolean	exists(String id) 判断指定id的文件是否存在
IResultSet<GridFSFile>	find() 查询全部记录
IResultSet<GridFSFile>	find(OrderBy orderBy) 查询全部记录
IResultSet<GridFSFile>	find(OrderBy orderBy, Page page) 查询全部记录
IResultSet<GridFSFile>	find(Query query) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(QueryBuilder query) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(QueryBuilder query, OrderBy orderBy) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(QueryBuilder query, OrderBy orderBy, Page page) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(QueryBuilder query, Page page) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(Query query, OrderBy orderBy) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(Query query, OrderBy orderBy, Page page) 根据条件查询符合条件的文件记录
IResultSet<GridFSFile>	find(Query query, Page page) 根据条件查询符合条件的文件记录
GridFSFile	find(String id) 根据id查询文件记录
IResultSet<GridFSFile>	find(String filename, OrderBy orderBy) 查询指定名称的文件记录
IResultSet<GridFSFile>	find(String filename, OrderBy orderBy, Page page) 查询指定名称的文件记录
GridFSFile	findFirst(Query query) 根据条件查询符合条件的第一条记录
GridFSFile	findFirst(QueryBuilder query) 根据条件查询符合条件的第一条记录
String	getBucketName() 获取桶名称
IMongoConnectionHolder	getConnectionHolder() 获取连接对象
GridFSBucket	getGridFsBucket() 获取GridFSBucket对象
GridFSFile	match(String fileHash) 判断指定fileHash值的文件是否存在
void	remove(Collection<String> ids) 批量删除指定id的文件记录
void	remove(String id) 删除指定id的文件记录
void	rename(String id, String newFileName) 文件重命名
String	upload(File file) 上传文件
String	upload(File file, GridFSUploadOptions fsUploadOption) 上传文件
String	upload(String id, File file) 上传文件
String	upload(String id, File file, GridFSUploadOptions fsUploadOption) 上传文件
String	upload(String fileName, InputStream inputStream) 上传文件
String	upload(String fileName, InputStream inputStream, GridFSUploadOptions fsUploadOption) 上传文件
String	upload(String id, String fileName, InputStream inputStream) 上传文件
String	upload(String id, String fileName, InputStream inputStream, GridFSUploadOptions fsUploadOption) 上传文件

Methods inherited from class net.ymate.platform.core.persistence.AbstractSession

getId, getSessionEventListener, setSessionEventListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.ymate.platform.core.persistence.ISession

getId, getSessionEventListener, setSessionEventListener

Constructor Detail

MongoGridFsSession

public MongoGridFsSession(IMongoConnectionHolder connectionHolder)
                   throws Exception

Throws:

Exception

MongoGridFsSession

public MongoGridFsSession(IMongoConnectionHolder connectionHolder,
                          String bucketName)
                   throws Exception

Throws:

Exception

Method Detail

getGridFsBucket

public GridFSBucket getGridFsBucket()

Description copied from interface: IGridFsSession

获取GridFSBucket对象

Specified by:

getGridFsBucket in interface IGridFsSession

Returns:

返回GridFSBucket对象

getConnectionHolder

public IMongoConnectionHolder getConnectionHolder()

Description copied from interface: ISession

获取连接对象

Specified by:

getConnectionHolder in interface ISession<IMongoConnectionHolder>

Returns:

返回连接对象

getBucketName

public String getBucketName()

Description copied from interface: IGridFsSession

获取桶名称

Specified by:

getBucketName in interface IGridFsSession

Returns:

返回桶名称

close

public void close()

Specified by:

close in interface AutoCloseable

upload

public String upload(File file,
                     GridFSUploadOptions fsUploadOption)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

file - 待上传的文件对象

fsUploadOption - 文件上传配置对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String id,
                     File file,
                     GridFSUploadOptions fsUploadOption)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

id - 自定义文件唯一标识

file - 待上传的文件对象

fsUploadOption - 文件上传配置对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(File file)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

file - 待上传的文件对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String id,
                     File file)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

id - 自定义文件唯一标识

file - 待上传的文件对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String fileName,
                     InputStream inputStream,
                     GridFSUploadOptions fsUploadOption)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

fileName - 文件名称

inputStream - 文件输入流对象

fsUploadOption - 文件上传配置对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String id,
                     String fileName,
                     InputStream inputStream,
                     GridFSUploadOptions fsUploadOption)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

id - 自定义文件唯一标识

fileName - 文件名称

inputStream - 文件输入流对象

fsUploadOption - 文件上传配置对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String fileName,
                     InputStream inputStream)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

fileName - 文件名称

inputStream - 文件输入流对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

upload

public String upload(String id,
                     String fileName,
                     InputStream inputStream)
              throws Exception

Description copied from interface: IGridFsSession

上传文件

Specified by:

upload in interface IGridFsSession

Parameters:

id - 自定义文件唯一标识

fileName - 文件名称

inputStream - 文件输入流对象

Returns:

返回上传的文件唯一标识

Throws:

Exception - 可能产生的任何异常

download

public void download(String id,
                     OutputStream outputStream)
              throws Exception

Description copied from interface: IGridFsSession

下载文件数据到指定的输出流

Specified by:

download in interface IGridFsSession

Parameters:

id - 文件唯一标识

outputStream - 目标输出流

Throws:

Exception - 可能产生的任何异常

download

public void download(String id,
                     File distFile)
              throws Exception

Description copied from interface: IGridFsSession

下载文件数据并写入指定的文件

Specified by:

download in interface IGridFsSession

Parameters:

id - 文件唯一标识

distFile - 目标文件

Throws:

Exception - 可能产生的任何异常

exists

public boolean exists(String id)

Description copied from interface: IGridFsSession

判断指定id的文件是否存在

Specified by:

exists in interface IGridFsSession

Parameters:

id - 文件唯一标识

Returns:

返回true表示存在

match

public GridFSFile match(String fileHash)

Description copied from interface: IGridFsSession

判断指定fileHash值的文件是否存在

Specified by:

match in interface IGridFsSession

Parameters:

fileHash - 文件MD5值

Returns:

若存在则返回对应的文件记录对象，否则返回null

findFirst

public GridFSFile findFirst(Query query)

Description copied from interface: IGridFsSession

根据条件查询符合条件的第一条记录

Specified by:

findFirst in interface IGridFsSession

Parameters:

query - 查询条件对象

Returns:

返回文件记录对象

findFirst

public GridFSFile findFirst(QueryBuilder query)

Description copied from interface: IGridFsSession

根据条件查询符合条件的第一条记录

Specified by:

findFirst in interface IGridFsSession

Parameters:

query - 查询条件对象

Returns:

返回文件记录对象

find

public GridFSFile find(String id)

Description copied from interface: IGridFsSession

根据id查询文件记录

Specified by:

find in interface IGridFsSession

Parameters:

id - 文件唯一标识

Returns:

返回文件记录对象

find

public IResultSet<GridFSFile> find()

Description copied from interface: IGridFsSession

查询全部记录

Specified by:

find in interface IGridFsSession

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(OrderBy orderBy)

Description copied from interface: IGridFsSession

查询全部记录

Specified by:

find in interface IGridFsSession

Parameters:

orderBy - 排序对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(OrderBy orderBy,
                                   Page page)

Description copied from interface: IGridFsSession

查询全部记录

Specified by:

find in interface IGridFsSession

Parameters:

orderBy - 排序对象

page - 分页对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(String filename,
                                   OrderBy orderBy)

Description copied from interface: IGridFsSession

查询指定名称的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

filename - 文件名称

orderBy - 排序对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(String filename,
                                   OrderBy orderBy,
                                   Page page)

Description copied from interface: IGridFsSession

查询指定名称的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

filename - 文件名称

orderBy - 排序对象

page - 分页对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(Query query)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(QueryBuilder query)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(Query query,
                                   OrderBy orderBy)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

orderBy - 排序对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(QueryBuilder query,
                                   OrderBy orderBy)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

orderBy - 排序对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(Query query,
                                   OrderBy orderBy,
                                   Page page)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

orderBy - 排序对象

page - 分页对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(QueryBuilder query,
                                   OrderBy orderBy,
                                   Page page)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

orderBy - 排序对象

page - 分页对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(Query query,
                                   Page page)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

page - 分页对象

Returns:

返回查询结果集对象

find

public IResultSet<GridFSFile> find(QueryBuilder query,
                                   Page page)

Description copied from interface: IGridFsSession

根据条件查询符合条件的文件记录

Specified by:

find in interface IGridFsSession

Parameters:

query - 条件对象

page - 分页对象

Returns:

返回查询结果集对象

rename

public void rename(String id,
                   String newFileName)

Description copied from interface: IGridFsSession

文件重命名

Specified by:

rename in interface IGridFsSession

Parameters:

id - 文件唯一标识

newFileName - 新文件名称

remove

public void remove(String id)

Description copied from interface: IGridFsSession

删除指定id的文件记录

Specified by:

remove in interface IGridFsSession

Parameters:

id - 文件唯一标识

remove

public void remove(Collection<String> ids)

Description copied from interface: IGridFsSession

批量删除指定id的文件记录

Specified by:

remove in interface IGridFsSession

Parameters:

ids - 文件唯一标识集合