mongodb java索引_java – 使用MongoDb创建一个索引

深碍√TFBOYSˉ_ 2022-11-02 11:35 283阅读 0赞

我是MongoDB的初学者,我正在尝试一些东西.

我想要存储URL并避免重复的URL我创建一个唯一的索引url.

像那样

collection.createIndex(new BasicDBObject("url", type).append("unique", true));

但是每次启动我的程序时,索引都是再次创建的不是吗？

因为,现在我的程序只插入一个url“http://site.com”,如果我重新启动我的程序这个url是插入再次,如果没有索引.

每次创建索引是处理索引的错误方式？

以下是我的代码示例

mongo.getCollection().ensureIndex(new BasicDBObject("url", 1).append("unique", "true"));

mongo.getCollection().insert(new BasicDBObject("url", "http://site.com").append("crawled", 0));

并输出：

\{ "\_id" : \{ "$oid" : "50d627cf44ae5d6b5e9cf106"\} , "url" : "http://site.com" , "crawled" : 0\}

\{ "\_id" : \{ "$oid" : "50d627cf44ae5d6b5e9cf107"\} , "url" : "http://site.com" , "crawled" : 0\}

谢谢

编辑：

这是我的MongoDB类MongoDB

import java.net.UnknownHostException;

import java.util.List;

import java.util.Set;

import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.DBObject;

import com.mongodb.MongoClient;

public class Mongo \{

private MongoClient mongoClient;

private DB db;

private DBCollection collection;

private String db\_name;

public Mongo(String db)\{

try \{

mongoClient = new MongoClient( "localhost" , 27017 );

this.db = mongoClient.getDB(db);

this.db\_name = db;

\} catch (UnknownHostException e) \{

e.printStackTrace();

public void drop()\{

mongoClient.dropDatabase(db\_name);

public void listCollections()\{

Set colls = db.getCollectionNames();

for (String s : colls) \{

System.out.println(s);

public void listIndex()\{

List list = collection.getIndexInfo();

for (DBObject o : list) \{

System.out.println("\\t" + o);

public void setCollection(String col)\{

this.collection = db.getCollection(col);

public void insert(BasicDBObject doc)\{

this.collection.insert(doc);

public DBCollection getCollection()\{

return collection;

public void createIndex(String on, int type)\{

collection.ensureIndex(new BasicDBObject(on, type).append("unique", true));

这是我的课程,处理我的程序

public class Explorer \{

private final static boolean DEBUG = false;

private final static boolean RESET = false;

private Mongo mongo;

private String host;

public Explorer(String url)\{

mongo = new Mongo("explorer");

mongo.setCollection("page");

if (RESET)\{

mongo.drop();

System.out.println("Set RESET to FALSE and restart the program.");

System.exit(1);

if (DEBUG) \{

mongo.listCollections();

this.host = url.toLowerCase();

BasicDBObject doc = new BasicDBObject("url", "http://site.com").append("crawled", 0);

mongo.getCollection().ensureIndex(new BasicDBObject("url", 1).append("unique", true));

mongo.getCollection().insert(new BasicDBObject("url", "http://site.com").append("crawled", 0));

process();

private void process()\{

BasicDBObject query = new BasicDBObject("crawled", 0);

DBCursor cursor = mongo.getCollection().find(query);

try \{

while(cursor.hasNext()) \{

System.out.println(cursor.next());

\} finally \{

cursor.close();

mongodb java索引_java – 使用MongoDb创建一个索引

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 mongodb java索引_java – 使用MongoDb创建一个索引

相关 mongodb创建索引

相关 mongodb 索引

相关学习MongoDB 七： MongoDB索引（索引基本操作）（一）

相关 MongoDB 索引创建

相关 MongoDB索引创建

相关 mongodb索引

相关 MongoDB 索引

相关 MongoDB索引

相关 MongoDB创建索引语法