Java操作MongoDB实现增删改查

电玩女神 2021-09-26 01:28 557阅读 0赞

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.util.JSON;

public class TestMongoDB {
public static void main(String[] args) { 

  1.      new TestMongoDB().save();  
  2.      new TestMongoDB().queryAll();  
  3.      new TestMongoDB().queryByName();  
  4.      new TestMongoDB().update();  
  5.      new TestMongoDB().del();  
  6. \}  
  8. // 实例化mongo对象，连接mongodb服务器 包含所有的数据库  
  9. protected static Mongo mongo = new Mongo();  
  11. // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  12. protected static DB db = mongo.getDB("myMongo");  
  14. // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  15. protected static DBCollection dbCollection = db.getCollection("user");  
  17. public void save() \{  
  18.     try \{  
  19.         // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  20.         //DB db = mongo.getDB("myMongo");  
  22.         // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  23.         //DBCollection dbCollection = db.getCollection("user");  
  25.         // 添加操作  
  26.          BasicDBObject document = new BasicDBObject();  
  28.          // 数据  
  29.          document.put("id", 1);  
  30.          document.put("name", "xiaoli");  
  31.          document.put("age", 20);  
  32.          document.put("email", "abcd1990@126.com");  
  33.          document.put("sex", "男");  
  34.          document.put("address", "广东省深圳市南山区");  
  36.          // 保存到集合中  
  37.          dbCollection.insert(document);  
  39.         // 第二种：直接把json存到数据库中  
  40.         String jsonTest = "\{'id':2,'name':'小明'," + "'address':\{'city':'beijing','code':'065000'\}" + "\}";  
  41.         DBObject dbobjct = (DBObject) JSON.parse(jsonTest);  
  42.         dbCollection.insert(dbobjct);  
  44.         // 查询所有  
  45.         DBCursor cursor = dbCollection.find();  
  46.         System.out.println("--------添加数据后：");  
  47.         while (cursor.hasNext()) \{  
  48.             System.out.println(cursor.next());  
  49.         \}  
  50.     \} catch (Exception e) \{  
  51.         e.printStackTrace();  
  52.     \}  
  53. \}  
  55. public void queryAll() \{  
  56.     try \{  
  57.         // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  58.         //DB db = mongo.getDB("myMongo");  
  60.         // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  61.         //DBCollection dbCollection = db.getCollection("user");  
  63.         // 查询所有  
  64.         DBCursor cursor = dbCollection.find();  
  65.         System.out.println("---------查询所有:");  
  66.         while (cursor.hasNext()) \{  
  67.             System.out.println(cursor.next());  
  68.         \}  
  69.     \} catch (Exception e) \{  
  70.         e.printStackTrace();  
  71.     \}  
  72. \}  
  74. public void queryByName() \{  
  75.     try \{  
  76.         // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  77.         //DB db = mongo.getDB("myMongo");  
  79.         // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  80.         //DBCollection dbCollection = db.getCollection("user");  
  82.         BasicDBObject queryObject = new BasicDBObject();  
  83.         queryObject.put("id", 1);  
  85.         // 条件查询  
  86.         DBCursor cursor = dbCollection.find(queryObject);  
  87.         System.out.println("------------根据条件查询：");  
  88.         while (cursor.hasNext()) \{  
  89.             System.out.println(cursor.next());  
  90.         \}  
  91.     \} catch (Exception e) \{  
  92.         e.printStackTrace();  
  93.     \}  
  94. \}  
  96. public void update() \{  
  97.     try \{  
  98.         // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  99.         //DB db = mongo.getDB("myMongo");  
  101.         // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  102.         //DBCollection dbCollection = db.getCollection("user");  
  104.         BasicDBObject basObject = new BasicDBObject();  
  105.         basObject.put("id", 1);  
  106.         basObject.put("name", "xiaoli");  
  107.         basObject.put("age", 20);  
  108.         basObject.put("email", "abcd1990@126.com");  
  109.         basObject.put("sex", "男");  
  110.         basObject.put("address", "广东省深圳市南山区");  
  112.         // 第一种更新  
  113.         dbCollection.update(new BasicDBObject().append("age", 25), basObject);  
  115.         // 第二种更新  
  116.         BasicDBObject newBasicDBObject = new BasicDBObject().append("$set", new BasicDBObject().append("age", 5));  
  117.         dbCollection.update(new BasicDBObject().append("id", 1), newBasicDBObject);  
  119.         // 查询所有  
  120.         DBCursor cursor = dbCollection.find();  
  121.         System.out.println("更新后结果：");  
  122.         while (cursor.hasNext()) \{  
  123.             System.out.println(cursor.next());  
  124.         \}  
  125.     \} catch (Exception e) \{  
  126.         e.printStackTrace();  
  127.     \}  
  128. \}  
  130. public void del() \{  
  131.     try \{  
  132.         // 连接具体的数据库,参数是具体数据库的名称，若服务器中不存在，会自动创建  
  133.         //DB db = mongo.getDB("myMongo");  
  135.         // 操作具体的表,参数是具体表名称，若服务器上不存在，自动创建  
  136.         //DBCollection dbCollection = db.getCollection("user");  
  138.         BasicDBObject basObject = new BasicDBObject();  
  139.         basObject.put("id", 2);  
  140.         basObject.put("name", "小明");  
  142.         // remove一条记录  
  143.         dbCollection.remove(basObject);  
  145.         // remove all  
  146.         dbCollection.drop();  
  148.         // find all  
  149.         DBCursor cursor = dbCollection.find();  
  150.         System.out.println("----------删除后：");  
  151.         while (cursor.hasNext()) \{  
  152.             System.out.println(cursor.next());  
  153.         \}  
  154.     \} catch (Exception e) \{  
  155.         e.printStackTrace();  
  156.     \}  
  157. \}

}

发表评论

表情：
评论列表 （有 0 条评论，557人围观）

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

相关阅读