mongoDB Java常见用法。

妖狐艹你老母 2022-08-06 06:27 267阅读 0赞

package com.zjh.mongoDB;  
  
import java.io.File;  
import java.io.IOException;  
import java.net.InetSocketAddress;  
import java.net.Socket;  
import java.net.UnknownHostException;  
import java.util.ArrayList;  
import java.util.Arrays;  
import java.util.Date;  
import java.util.Iterator;  
import java.util.List;  
  
import org.bson.types.ObjectId;  
  
import net.sf.json.JSONObject;  
  
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.ServerAddress;  
import com.mongodb.gridfs.GridFS;  
import com.mongodb.gridfs.GridFSDBFile;  
import com.mongodb.gridfs.GridFSFile;  
  
public class MongoDBTest \{  
  
    private static final String ip = "10.37.238.223";  
  
    private static final int port = 27017;  
  
  
    public static void main(String args\[\]) throws IOException \{  
        // MongoDBTest mongoDBTest = new MongoDBTest() ;  
        // ArrayList<ServerAddress> sa = new ArrayList<ServerAddress>();  
        //  
        // sa.add(new ServerAddress("10.37.238.223", 27017));  
        //  
        // MongoCredential credential = MongoCredential  
        // .createMongoCRCredential("zjh", "admin",  
        // "zjh".toCharArray());  
        Mongo mongo = new Mongo(ip, port);  
//        DB db = mongo.getDB("test");  
//        // 添加用户  
//        db.addUser("zjh", "zjh".toCharArray());  
//        // 校验用户是否存在  
//        boolean auth = db.authenticate("zjh", "zjh".toCharArray());  
//        if (auth == true) \{  
            // 创建数据集合  
            // DBCollection collection = db.createCollection("userInfo", null);  
            // System.out.println(collection.toString());  
  
            // System.out.println(db.getCollection("userInfo").getCount());  
            //  
            // 获取集合中所有的对象  
            // DBCursor cursor = db.getCollection("userInfo").find();  
            // DBCollection dbCollection = db.getCollection("userInfo");  
            // List<DBObject> dbObjects = new ArrayList<DBObject>();  
            // for(int i = 0;i < 10 ; i++)\{  
            // BasicDBObject object = new BasicDBObject();  
            // object.append("name", "lll" + i).append("age", 0+i).append("sex", i%2==1?true:false);  
            // dbObjects.add(object);  
            // \}  
            // dbCollection.insert(dbObjects);  
            // Iterator<DBObject> iterator = cursor.iterator();  
            // while(iterator.hasNext())\{  
            //  
            // DBObject dbObject = iterator.next();  
            // dbObject.put("age", 20);  
  
            // System.out.println(dbObject.get("sex"));  
            // // db.getCollection("userInfo").update(q, o)  
            //  
            // \}  
            // BasicDBObject dbObject = new BasicDBObject();  
            // dbObject.append("name", "boye");  
            // dbObject.append("age", 18);  
            // dbObject.append("sex", false);  
            // 直接保存一个对象  
            // db.getCollection("userInfo").save(dbObject);  
            // 单独保存一个对象  
            // db.getCollection("userInfo").insert(dbObject);  
            // 获取所有表名  
            // List<String> dbs = mongo.getDatabaseNames();  
            // System.out.println(dbs.size());  
            // for(String db1:dbs)\{  
            //  
            // System.out.println(db1);  
            // \}  
  
//            BasicDBObject q = new BasicDBObject();  
//            q.put("age", 4);  
//            DBObject object = db.getCollection("userInfo").findOne(q);  
//            System.out.println(object.get("name"));  
//            BasicDBObject o = new BasicDBObject();  
//            o.putAll(object);  
//            o.append("name", "zjh");  
            db.getCollection("userInfo").update(q, o);  
//            db.getCollection("userInfo").update(q, o);  
//            DBObject object1 = db.getCollection("userInfo").findOne(q);  
//            System.out.println(object1.get("name"));  
              
//            BasicDBObject q = new BasicDBObject();  
//            BasicDBObject o = new BasicDBObject();  
//              
//            q.put("age", 11);  
//            o.put("$set", q);  
//            BasicDBObject t = new BasicDBObject();  
//            t.put("name", "zjh");  
//          db.getCollection("userInfo").update(t, o,false,true);  
//          BasicDBObject s = new BasicDBObject();  
//          s.put("name", "boye");  
//          db.getCollection("userInfo").remove(s);  
   
          DB db = mongo.getDB("mongoDBFile");  
//          db.addUser("zjh", "1234".toCharArray());  
          if(db.authenticate("zjh", "1234".toCharArray()))\{  
//上传                
              GridFS myFS = new GridFS(db,"file");  
              GridFSFile file = myFS.createFile(new File("C:/Users/zjh/Desktop/商品图片/格瓦拉.jpg"));                
              file.save();  
//查看                
//              DBCursor cursor = myFS.getFileList();    
//              while(cursor.hasNext())\{    
//               DBObject object =cursor.next();  
//获取                
//               ObjectId id = new ObjectId(object.get("\_id").toString());  
//                  GridFSDBFile fsf =myFS.findOne(id);  
//                  fsf.writeTo(new File("C:/Users/zjh/Desktop/" + object.get("filename")));  
//删除文件     
//myFS.remove(id);  
//              \}       
             
                
                
          \}  
  
    \}      
      
\}