連線遠端mongodb資料庫：mongo 192.168.100.177:27017

 

檢視已建立的資料庫：show dbs

 

 

去重查詢

db.addresses.distinct("zip-code")

 

刪除指定條件資料的記錄

db.tianyancha_recruit.remove( { ly : "測試" })

 

模糊查詢

db.tyc_jbxx_Cfjl.find({"gsmc": {$regex:/測試.*/i}}) 

db.IncomeStatementNew_z.find({"value": {$regex: ' ', $options:'i'}}) 

 

修改某個欄位值

db.qcc_cpxxNew_sb.update({"ID":"1"},{$set:{"WZ":""}},false,true);

 

新增一個欄位

db.CompanyInfo.update({}, {$set: {gscmm: ''}}, {multi: 1})

 

刪除一個欄位

db.test.update({},{$unset:{需要刪除的欄位:''}},false,true)

 

修改一個欄位

db.tyc_jbxxNew_s.update({}, {$rename : {"text1" : "jbxx_dh"}}, false, true) 

 

查詢某個欄位為空的記錄

db.foo.find({name:{$in:[null]}})

 

查詢某個欄位不為空的記錄

db.foo.find({name:{$ne:null}})

 

排序

db.getCollection('IncomeStatementNew_z').find({'gsid':'1'}).sort({'nd':-1})

 

同一欄位多條件查詢

db.AssetsAndLiabilities_ths.find({km:{$in:['1','2']}})

 

建立索引

db.tyc_jbxxNew.ensureIndex({"gsmc":1},{"name":"tyc_jbxxNew_name"})

 

查詢大於等於、小於等於

db.getCollection('0700006').find({rq:{$gte:"2017-06-05",$lte:"2017-06-09"}})

 

//檢視當前表建立的索引

db.zq_pj.getIndexes() 

 

//刪除當前表建立的索引

db.zq_pj.dropIndexes(); 

 

查詢date時間段

db.AssetsAndLiabilities_z.find({"rksj":{"$get":new Date("2017-03-11"),"$lt":new Date("2017-03-13")}})

 

查詢一個表的總數

db.judgmentDocumentEetwork.aggregate(

   [

      { $group: { _id: 1, count: { $sum: 1 } } }

   ]

)

 

通過指定條件查詢一個表的總數

db.judgmentDocumentEetwork.aggregate(

   [

      { $match: {"rksj": {$regex:/2017-03-22.*/i}} },

      { $group: { _id: null, count: { $sum: 1 } } }

   ]

)

 

 

刪除重複的記錄

var res=db.tyc_jbxx_Cfjl.find();

var count=res.count()

print(count)

for(var i=0;i<count;i++){

    var resNew=db.tyc_jbxx_Cfjl.find({"gsmc":res[i].gsmc});

    var countNew=resNew.count()

    for(var j=0;j<countNew;j++){

      if(j>0){

      db.tyc_jbxx_Cfjl.remove({"_id":resNew[j]._id});  

      }  

    }

}

 

 

把沒有的資料新增到另一張表裡

var res=db.tyc_jbxxNew.find();

var count=res.count()

print(count)

for(var i=0;i<count;i++){

    var resNew=db.tyc_jbxx.find({"gsmc":res[i].gsmc});

    var countNew=resNew.count()

    if(countNew==0){

        //print(countNew)

        db.tyc_jbxx_Cfjl.insert(res[i])

    }

}

 

 

 

 

//1.新增一個欄位

//db.judgmentDocumentEetwork_s.update({gsid:{$in:[null]}}, {$set: {gsids: ''}}, {multi: 1})

 

//2.新增公司id

var list = db.judgmentDocumentEetwork_s.find({"gsids":""})

var count = list.count()

print(count)

for(var i=0;i<count;i++){

    if(list[i].gsids == ""){

        //print(list[i].gsmc)

        var list_jbxx=db.tyc_jbxxNew.find({"gsmc":list[i].gsmc})

        if(list_jbxx.count()>0){

            db.qcc_cpxxNew_sb.update({"_id":list[i]._id},{$set:{"gsids":list_jbxx[0].gsid}},false,true);

            //print(list_jbxx[0].gsid)

        }

    }

}