DBCollection 是表示数据集合的抽象类,它的实现可以简单地分为两类:
一类是抽象方法,由子类(DBApiLayer.MyCollection)实现;
另一类委托给类型为 "DB" 的属性 _db,_db 实际上是 DBApiLayer 类的实例(DBApiLayer 继承抽象类 DB);
因此,DBCollection 类是实现细节与 DBApiLayer 关系密切。
DBApiLyer 的实现细节我们将在后续文章中进行详细的描述,本文主要探讨两者之间的联系。
由子类实现的方法
以下方法是由子类实现的,这些将在介绍 DBApiLayer 时再进行详细说明:
// 插入记录
public abstract WriteResult insert(DBObject[] arr , WriteConcern concern )
// 更新记录
public abstract WriteResult update( DBObject q , DBObject o , boolean upsert , boolean multi , WriteConcern concern )
// 保存数据之前附加额外属性
protected abstract void doapply( DBObject o )
// 删除记录
public abstract WriteResult remove( DBObject o , WriteConcern concern )
// 查询记录
abstract Iterator<DBObject> __find( DBObject ref , DBObject fields , int numToSkip , int batchSize , int limit, int options )
// 创建索引
public abstract void createIndex( DBObject keys , DBObject options )
此外,以下方法是在这些方法的基础上,在进行包装和组合得到的:
public final void ensureIndex( final DBObject keys , final DBObject optionsIN )
public final DBObject findOne( DBObject o, DBObject fields )
public final Object apply( DBObject jo , boolean ensureID )
ensurceIndex 方法用于创建索引,调用了抽象方法 createdIndex ,在此之前,先检查数据库是否为只读,以及是否重复创建索引。
具体实现如下:
public final void ensureIndex( final DBObject keys , final DBObject optionsIN )
throws MongoException {
// 检查是否为只读
if ( checkReadOnly( false ) ) return;
// 设置参数
final DBObject options = defaultOptions( keys );
for ( String k : optionsIN.keySet() )
options.put( k , optionsIN.get( k ) );
// 取得参数中的索引名称
final String name = options.get( "name" ).toString();
// 如果索引已经创建,则返回,避免重复创建
if ( _createdIndexes.contains( name ) )
return;
// 创建索引,并添加到 createdIndexes
createIndex( keys , options );
_createdIndexes.add( name );
}
findOne 方法用于查询一个对象,第一个参数是表示查询条件的 DBObject,第二个参数表示返回结果包含的字段。
调用了抽象方法 _find,并取第一条。
具体实现如下:
public final DBObject findOne( DBObject o, DBObject fields ) {
// 调用 _find 方法
Iterator<DBObject> i = __find( o , fields , 0 , -1 , 0, getOptions() );
// 读取第一条记录
if ( i == null || ! i.hasNext() )
return null;
return i.next();
}
apply 方法用于在保存对象之前,为对象添加额外的属性。
除了调用抽象方法 doapply,还可以根据 ensureId 的值,生成 id。
具体实现如下:
public final Object apply( DBObject jo , boolean ensureID ){
// 根据 ensureId 的值,确定是否生成 id
Object id = jo.get( "_id" );
if ( ensureID && id == null ){
id = ObjectId.get();
jo.put( "_id" , id );
}
// 调用抽象方法 doapply,为对象附加额外属性。
doapply( jo );
return id;
}
委托给 _db 的方法
// 查询并修改对象
public DBObject findAndModify(DBObject query, DBObject fields, DBObject sort,
boolean remove, DBObject update, boolean returnNew, boolean upsert)
// 删除索引
public void dropIndexes( String name )
// 删除该数据集
public void drop()
// 统计数量
public long getCount(DBObject query, DBObject fields, long limit, long skip )
// 重命名该集合
public DBCollection rename( String newName, boolean dropTarget )
// 执行 Group 操作
public DBObject group( GroupCommand cmd )
// 查询对象并去除重复
public List distinct( String key , DBObject query )
// 执行 Map Reduce 操作
public MapReduceOutput mapReduce( MapReduceCommand command )
// 获取索引信息
public List<DBObject> getIndexInfo()
// 获取子数据集
public DBCollection getCollection( String n )
以 findAndModify 为例。
findAndModify 方法用于查询并修改对象,实际调用的是 _db.command( cmd ) 方法;
在调用 _db 的方法之前,先对 cmd 进行组装,添加查询条件、查询字段、排序条件等;
然后调用 _db.command( cmd ),返回结果或抛出异常。
具体实现如下:
public DBObject findAndModify(DBObject query, DBObject fields, DBObject sort,
boolean remove, DBObject update, boolean returnNew, boolean upsert) {
// 创建 cmd 对象
BasicDBObject cmd = new BasicDBObject( "findandmodify", _name);
// 添加查询条件
if (query != null && !query.keySet().isEmpty())
cmd.append( "query", query );
// 添加查询字段
if (fields != null && !fields.keySet().isEmpty())
cmd.append( "fields", fields );
// 添加排序字段
if (sort != null && !sort.keySet().isEmpty())
cmd.append( "sort", sort );
// 是否执行删除
if (remove)
cmd.append( "remove", remove );
else {
// 添加更新的字段
if (update != null && !update.keySet().isEmpty()) {
// if 1st key doesnt start with $, then object will be inserted as is, need to check it
String key = update.keySet().iterator().next();
if (key.charAt(0) != '$')
_checkObject(update, false, false);
cmd.append( "update", update );
}
// 是否返回新创建的对象
if (returnNew)
cmd.append( "new", returnNew );
// 被查询的对象不存在时是否创建一个
if (upsert)
cmd.append( "upsert", upsert );
}
// 删除操作与更新操作不能混合,抛异常
if (remove && !(update == null || update.keySet().isEmpty() || returnNew))
throw new MongoException("FindAndModify: Remove cannot be mixed with the Update, or returnNew params!");
// 执行 _db.command( cmd )
CommandResult res = this._db.command( cmd );
// 返回结果或抛异常
if (res.ok() || res.getErrorMessage().equals( "No matching object found" ))
return (DBObject) res.get( "value" );
res.throwOnError();
return null;
}
分享到:
相关推荐
mongodb c#驱动 最新驱动mongodb.driver.dll 版本2.12.0-beta1,包内有MongoDB.Bson.dll 、mongodb.driver.core.dll 等文件
标签:mongodb、driver、core、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
mongodb-java-driver-4.4.0.jar
标签:mongodb、driver、sync、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...
MongoDB Java Driver 简单操作
标签:mongodb、driver、sync、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
标签:mongodb、driver、core、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...
亲测可用,解压包含三个jar包,引用时sources和doc包根据需要添加。 mongo-java-driver-3.5.0.jar; mongo-java-driver-3.5.0-javadoc.jar; mongo-java-driver-3.5.0-sources.jar;
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 api mongoDB java 驱动 所有类的api
mongodb-driver-core-3.5.0.jar,链接驱动
NULL 博文链接:https://xxing22657-yahoo-com-cn.iteye.com/blog/1233940
df = spark.read.format(com.mongodb.spark.sql.DefaultSource).load() File /home/cisco/spark-2.2.0-bin-hadoop2.7/python/lib/pyspark.zip/pyspark/sql/readwriter.py, line 165, in load
mongodb java Driver,具体使用请看我的博客:http://blog.csdn.net/lablenet
mongodb-driver-3.4.0-rc1.jar mongodb-driver-3.4.0-rc1.jar mongodb-driver-3.4.0-rc1.jar mongodb-driver-3.4.0-rc1.jar
软件介绍: mongodb 的java驱动,资源内包含三个不同版本,分别是:javadoc版sources版和mongo-java-driver-3.4.2.jar编译过的版本。有需要的同学可直接拿去使用。
java用来链接Mongo数据库所需要的jar mongodb-driver-3.6.0.jar bson-3.6.0.jar mongodb-driver-core-3.6.0.jar
mongo-java-driver-3.12.7 最新版本,java连接MongoDB最新驱动,有需要的可以自行下载
mongodb-driver-java3.12.14.jar
mongodb driver java 源码 2.5.3 版本