因?yàn)楣拘枨笞罱芯苛讼耺ongodb的查詢,但是因?yàn)閷?duì)于這里面只進(jìn)行了語法的使用,當(dāng)初沒有進(jìn)行內(nèi)部數(shù)據(jù)的查看導(dǎo)致出現(xiàn)一些問題,所以大家在看一門新的知識(shí)的時(shí)候不要只注重語言本身也要注意內(nèi)部的結(jié)構(gòu),,還有看到的東西要立馬去實(shí)踐不要一直盯著看,那樣會(huì)浪費(fèi)時(shí)間,自己也掌握不了多少知識(shí).

現(xiàn)在開始說下mongodb查詢的問題 用的是java語言.

mongodb的一般都是find方法查詢,因?yàn)椴樵円玫胶芏鄠€(gè)查詢條件組合,并且是精確查詢.就把查詢條件組合好之后放到list當(dāng)中然后用and組合一起放到find當(dāng)中查詢.

/**

* searchCond 試講在condList中的條件并列好之后放到find中

*/

BasicDBObject searchCond = new BasicDBObject();

BasicDBList condList = new BasicDBList();

BasicDBObject cond;

DBCollection Conllection;

condList= linkPayReturnContent(map);

if(condList.size()>0){

searchCond.put("$and", condList);

}

/**

*去掉查詢出來的主鍵id

*/

BasicDBObject idDB=new BasicDBObject();

idDB.put("_id", 0);

Conllection=mongoBgTemp.queryDB(“指定查詢的表名”);

DBCursor db=Conllection.find(searchCond,idDB);

db.addOption(Bytes.QUERYOPTION_NOTIMEOUT);

while(db.hasNext()){

resultMap=new HashMap();

DBObject dbObj= db.next();

list.add(dbObj.toMap());

}

db.close();

return list;

public DBCollection queryDB(String collectionName){

DBCollection userCollection = mongoTemplate.getCollection(collectionName);

return userCollection;

}

/**

* searchCond 試講在condList中的條件并列好之后放到find中

*/

BasicDBObject searchCond = new BasicDBObject();

BasicDBList condList = new BasicDBList();

BasicDBObject cond;

DBCollection Conllection;

condList= linkPayReturnContent(map);

if(condList.size()>0){

searchCond.put("$and", condList);

}

/**

*去掉查詢出來的主鍵id

*/

BasicDBObject idDB=new BasicDBObject();

idDB.put("_id", 0);

Conllection=mongoBgTemp.queryDB(“指定查詢的表名”);

DBCursor db=Conllection.find(searchCond,idDB);

db.addOption(Bytes.QUERYOPTION_NOTIMEOUT);

while(db.hasNext()){

resultMap=new HashMap();

DBObject dbObj= db.next();

list.add(dbObj.toMap());

}

db.close();

return list;

public DBCollection queryDB(String collectionName){

DBCollection userCollection = mongoTemplate.getCollection(collectionName);

return userCollection;

}

/***

*因?yàn)橛械牟樵儣l件不是在一個(gè)方法當(dāng)中我就在這里全部組合在一起方便自己去查詢使用以后

*/

BasicDBList condList = new BasicDBList();

/**交易時(shí)間*/

if(map.containsKey("addTimeStart")){

BasicDBObject addTimeStartDB=new BasicDBObject();

String addTimeStart=StringUtils.trimToEmpty(map.get("addTimeStart").toString());

if(addTimeStart !=null && !addTimeStart.equals("")){

addTimeStartDB.put("transtime",new BasicDBObject("$gte",addTimeStart));

condList.add(addTimeStartDB);

}

}

if(map.containsKey("addTimeEnd")){

BasicDBObject addTimeEndDB=new BasicDBObject();

String addTimeEnd=StringUtils.trimToEmpty(map.get("addTimeEnd").toString());

if(addTimeEnd !=null && !addTimeEnd.equals("")){

addTimeEndDB.put("transtime",new BasicDBObject("$lte",addTimeEnd));

condList.add(addTimeEndDB);

}

}

if(map.containsKey("orderNo")){

BasicDBObject orderNoDB=new BasicDBObject();

String orderNo=StringUtils.trimToEmpty(map.get("orderNo").toString());

if(orderNo !=null && !orderNo.equals("")){

orderNoDB.put("order_no", orderNo);

condList.add(orderNoDB);

}

}

if(map.containsKey("cardNo")){

BasicDBObject cardNoDB=new BasicDBObject();

String cardNo=StringUtils.trimToEmpty(map.get("cardNo").toString());

if(cardNo !=null && !cardNo.equals("")){

cardNoDB.put("card_no", cardNo);

condList.add(cardNoDB);

}

}

if(map.containsKey("phone")){

BasicDBObject phoneDB=new BasicDBObject();

String phone=StringUtils.trimToEmpty(map.get("phone").toString());

if(phone !=null && !phone.equals("")){

phoneDB.put("phone", phone);

condList.add(phoneDB);

}

}

if(map.containsKey("totalFee")){

BasicDBObject totalFeeDB=new BasicDBObject();

String totalFee=StringUtils.trimToEmpty(map.get("totalFee").toString());

if(totalFee !=null && !totalFee.equals("")){

totalFeeDB.put("total_fee", totalFee);

condList.add(totalFeeDB);

}

}

if(map.containsKey("totalFee")){

BasicDBObject totalFeeDB=new BasicDBObject();

String totalFee=StringUtils.trimToEmpty(map.get("totalFee").toString());

if(totalFee !=null && !totalFee.equals("")){

totalFeeDB.put("total_fee", totalFee);

condList.add(totalFeeDB);

}

}

if(map.containsKey("memberId")){

BasicDBObject memberIdDB=new BasicDBObject();

String memberId=StringUtils.trimToEmpty(map.get("memberId").toString());

if(memberId !=null && !memberId.equals("")){

memberIdDB.put("member_id", memberId);

condList.add(memberIdDB);

}

}

if(map.containsKey("content")){

//這個(gè)是利用的模糊查詢現(xiàn)在那個(gè)用的是正則表達(dá)式

BasicDBObject contentDB=new BasicDBObject();

String content=StringUtils.trimToEmpty(map.get("content").toString());

if(content !=null && !content.equals("")){

Pattern queryPattern = Pattern.compile(content, Pattern.CASE_INSENSITIVE);

contentDB.put("content",queryPattern );

condList.add(contentDB);

}

}

if(map.containsKey("borrowMoney")){

//在這里也是提醒下自己在查詢的時(shí)候要注意內(nèi)容的區(qū)分,并且注意字段類型

BasicDBObject borrowMoneyDB=new BasicDBObject();

String borrowMoney=StringUtils.trimToEmpty(map.get("borrowMoney").toString());

if(borrowMoney !=null && !borrowMoney.equals("")){

borrowMoneyDB.put("applyamt",ObjectUtils.toString(new BigDecimal (borrowMoney).setScale(2,BigDecimal.ROUND_DOWN)));

condList.add(borrowMoneyDB);

}

}

return condList;

}