MongoDB 3.X JAVA基本操作
import java.util.ArrayList;import java.util.Iterator;
import java.util.List;
import org.bson.Document;
import com.mongodb.Block;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;
import com.mongodb.client.model.BulkWriteOptions;
import com.mongodb.client.model.DeleteOneModel;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.InsertOneModel;
import com.mongodb.client.model.Projections;
import com.mongodb.client.model.ReplaceOneModel;
import com.mongodb.client.model.Sorts;
import com.mongodb.client.model.UpdateOneModel;
import com.mongodb.client.model.WriteModel;
import static com.mongodb.client.model.Filters.gt; /***/
import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.lt;
public>
@SuppressWarnings("resource")
public static void main(String[] args) {
try {
/** 直接登录 */
// To directly connect to a single MongoDB server.
// (this will not auto-discover the primary even if it's a member of a replica set)
/*
MongoClient mongoClient = new MongoClient("192.168.253.10", 27017);
MongoDatabase mongoDatabase = mongoClient.getDatabase("dsp");
System.out.println("Connect to database successfully!");
*/
/** 使用URI连接信息连接 */
/*
MongoClientURI connectionString = new MongoClientURI("mongodb://192.168.253.10:27017,192.168.253.20:27018,192.168.253.30:27019");
MongoClient mongoClient = new MongoClient(connectionString);
*/
/** Replica Set 认证登录 */
// to connect to a replica set, with auto-discovery of the primary, supply a seed list of members
// 数据库URI（两个参数分别为：服务器地址、端口）
ServerAddress serverAddress = new ServerAddress("192.168.253.10", 27017);
List<ServerAddress> addressList = new ArrayList<ServerAddress>();
addressList.add(serverAddress);
// 认证信息（三个参数分别为：用户名、数据库名称、密码）
MongoCredential credential = MongoCredential.createScramSha1Credential("dsp", "dsp", "shi".toCharArray());
List<MongoCredential> credentialList = new ArrayList<MongoCredential>();
credentialList.add(credential);
// 根据URI和认证信息获取数据库连接
MongoClient mongoClient = new MongoClient(addressList, credentialList);
/** 切换数据库 */
MongoDatabase mongoDatabase = mongoClient.getDatabase("dsp");
/** 切换到需要操作的集合 */
MongoCollection collection = mongoDatabase.getCollection("col");
/** 插入文档 */
// 创建文档 org.bson.Document对象，参数为K:V格式
// 创建文档集合List<Document>
// 将文档集合插入数据库集合中collection.insertMany(List<Document>)，插入单个文档可以用collection.insertOne(Document)
/*
List<Document> docList = new ArrayList<Document>();
for (int>
Document doc = new Document("title", "MongoDB" +>
append("desc", "数据库" +>
append("likes", 100 +>
append("by", "dsp" +>
docList.add(doc);
}
collection.insertMany(docList);
*/
/** 更新文档 */
/*
UpdateResult updateResult = collection.updateMany(and(gt("likes", 90), lt("likes", 110)), new Document("$set", new Document("likes", 30)));
updateResult.getMatchedCount();
updateResult.getUpsertedId();
updateResult.getModifiedCount();
*/
/** 删除文档 */
/*
DeleteResult deleteResult = collection.deleteMany(Filters.eq("likes", 30));
System.out.println("本次删除 " + deleteResult.getDeletedCount() + " 条记录！");
*/
/** 检索文档 */
/*
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
try {
while (mongoCursor.hasNext()) {
System.out.println(mongoCursor.next().toJson());
}
} finally {
mongoCursor.close();
}
*/
// 查询过滤器
/*
Document myDoc = (Document) collection.find(eq("likes", 10)).first();
System.out.println(myDoc.toJson());
*/
/** 使用范围查询获取一个较大的子集 */
Block<Document> printBlock = new Block<Document>() {
@Override
public void apply(Document doc) {
System.out.println(doc.toJson());
}
};
// 过滤 likes > 10
// collection.find(gt("likes", 10)).forEach(printBlock);
// 过滤 10 <= likes <= 100
// collection.find(and(Filters.gte("likes", 10), Filters.lte("likes", 100))).forEach(printBlock);
/** 排序 */
// collection.find(Filters.exists("likes")).sort(Sorts.descending("likes")).limit(2).forEach(printBlock);
/** Projection */
// Document myDoc = (Document) collection.find().projection(Projections.excludeId()).first();
// System.out.println(myDoc.toJson());
/** ordered bulk writes */
List<WriteModel<Document>> writes = new ArrayList<WriteModel<Document>>();
writes.add(new InsertOneModel<Document>(new Document("_id", 13)));
writes.add(new InsertOneModel<Document>(new Document("_id", 14)));
writes.add(new InsertOneModel<Document>(new Document("_id", 15)));
writes.add(new UpdateOneModel<Document>(new Document("_id", 10), new Document("$set", new Document("x", 101010))));
writes.add(new DeleteOneModel<Document>(new Document("_id", 11)));
writes.add(new ReplaceOneModel<Document>(new Document("_id", 12), new Document("_id", 12).append("x", 121212)));
// bulkWrite默认BulkWriteOptions
// collection.bulkWrite(writes);
// collection.find().forEach(printBlock);
//
// collection.bulkWrite(writes, new BulkWriteOptions().ordered(false));
// collection.find().forEach(printBlock);
/** drop集合 */
// collection.drop();
/** drop数据库 */
// mongoDatabase.drop();
} catch (Exception e) {
System.err.println(e.getClass().getName() + " : " + e.getMessage());
} finally {
// 防止意外，关闭数据库连接
// mongoClient.close();
}
}
}
页:
[1]