package com.tompig.ljc;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Set;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
public class DBUtil {
String collectionsName = "user_info";
String dbName = "ljc";
DBCollection coll = null;
Mongo m = null;
public DBUtil() {
try {
coll = getDBCollection(collectionsName);
} catch (Exception e) {
e.printStackTrace();
}
}
public DBCollection getDBCollection(String collectionName) {
DBCollection coll = null;
try {
m = new Mongo("localhost", 27017);
DB db = m.getDB(dbName);
// if (db.authenticate("ljc", "007".toCharArray())) {
// System.out.println("success");
// }
coll = db.getCollection(collectionName);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
return coll;
}
// mongo db 删除数据库
public void dropDatabase() {
try {
m.dropDatabase(dbName);
} catch (MongoException e) {
e.printStackTrace();
}
}
// mongo db查询所有表名
public void getAllCollections() {
DB db = m.getDB("mydb");
Set<String> colls = db.getCollectionNames();
for (String s : colls) {
System.out.println(s);
}
}
// mongo db 查询索引
public void getAllIndex() {
List<DBObject> list = coll.getIndexInfo();
for (DBObject o : list) {
System.out.println(o);
}
}
// mongo db 插入 insert
public void insert(int i) {
BasicDBObject doc = new BasicDBObject();
doc.put("name", "liu" + i);
doc.put("age", 20 + i);
doc.put("sex", "boy");
doc.put("time", new Date());
coll.insert(doc);
}
public void batchInsert() {
List datas = new ArrayList();
for (int i = 0; i < 100; i++) {
BasicDBObject bo = new BasicDBObject();
bo.put("name", "liu");
bo.append("age", i);
datas.add(bo);
}
coll.insert(datas);
}
// 查询单个
public void findOne() {
BasicDBObject obj = (BasicDBObject) coll.findOne();
System.out.println(obj);
}
// mongo db 修改
public void update() {
BasicDBObject query = new BasicDBObject();
query.put("name", "liu");
DBObject stuFound = coll.findOne(query);
stuFound.put("name", stuFound.get("name") + "update_1");
coll.update(query, stuFound);
}
// 查询所有
public void queryAll() {
BasicDBObject obj = new BasicDBObject();
obj.put("sex", "boy");
DBCursor cursor = coll.find(obj);
while (cursor.hasNext()) {
String name = (String) cursor.next().get("name");
System.out.println(name);
}
cursor.close();
}
// 条件删除
public void delete(String name) {
BasicDBObject query = new BasicDBObject();
query.put("name", name);
// 找到并且删除,并返回删除的对象
DBObject removeObj = coll.findAndRemove(query);
System.out.println(removeObj);
}
// 条件查询
public void findByName(String name) {
BasicDBObject obj = new BasicDBObject();
obj.put("name", name);
DBCursor cursor = coll.find(obj);
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
}
//条件查询2
public void argsFind(){
BasicDBObject condition = new BasicDBObject();
//condition.put("age", new BasicDBObject("$gt", 20).append("$lte", 30));
condition.put("age", new BasicDBObject("$gt", 50));
coll.find(condition);
//比较符
//"$gt": 大于
//"$gte":大于等于
//"$lt": 小于
//"$lte":小于等于
//"$in": 包含
//以下条件查询20<age<=30
}
// 分页查询
public void pageQuery() {
DBCursor cursor = coll.find().skip(0).limit(10);
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
}
}
分享到:
相关推荐
java操作mongo的小例子
Mongo DB数据库日常常用操作命令大全集合,适用于初学MONGO DB的人员掌握基本命令
详细介绍 Web项目Mongo数据库连接 内加驱动包 超值下载
Java操作mongo包含lib,增删改查及gridFS操作
完全面向对象的mongo封装,maven工程源码,可直接install导出jar包引用,支持基本的增删改查和分页等,使用反射对javaBean实体进行映射,所有方法参数只需要传javaBean就行了,支持带密码连接,即拿即用,无需修改。
该rar包中包括MOngoDB数据库操作基本的增删改查,以及在CMD命令行中怎么配置MOngodb和增删改查,还有就是连接mongoDB的jar包和详细的操作文档,本来想上传NOde.js来着,可是只能上传60兆,只能放弃了,不过这些已经...
Mongo数据库 java驱动
mongo 数据库
mongo db 0801
实现将mongo数据库注册成系统服务同时设置自动启动命令。
Java使用POI将Mongo数据库数据导出到Excel文件;包含java 测试文件和各种jar包 ,bson-3.4.2.jar ,mongodb-driver-3.4.2.jar,mongodb-driver-core-3.4.2.jar,poi-3.9-20121203.jar
没下载积分了,传个文档挣下积分,Mongo数据库和Nginx容器的部署。
metersphere连接mongo数据库所需驱动包
Mongo数据库的安装,MongoDB学习笔记(一) MongoDB介绍及安装.docx
mongoVUE mongo数据连接工具,自身实验感觉还不错,共享一下。
Mongo DB 服务安装,版本4.4,本地数据存储,非关型数据库服务安装。
MongoVUE mongo 数据库 工具
Camo - 基于Class的ES6 ODM用于类似于Mongo的数据库
本例实现了将Mongo数据库中的集合转换成MySQL中的单条记录,使用java语言实现