{"id":207338,"date":"2020-11-25T18:44:57","date_gmt":"2020-11-25T10:44:57","guid":{"rendered":"http:\/\/4563.org\/?p=207338"},"modified":"2020-11-25T18:44:57","modified_gmt":"2020-11-25T10:44:57","slug":"%e6%b1%82%e5%8a%a9-java-%e6%93%8d%e4%bd%9c-mongodb","status":"publish","type":"post","link":"http:\/\/4563.org\/?p=207338","title":{"rendered":"[\u6c42\u52a9] Java \u64cd\u4f5c mongodb"},"content":{"rendered":"
\n
\n
\n

[\u6c42\u52a9] Java \u64cd\u4f5c mongodb <\/h1>\n

<\/p>\n

\n
\u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span> <\/i> 3<\/span> <\/div>\n
<\/div>\n<\/p><\/div>\n<\/p><\/div>\n<\/p><\/div>\n
<\/p>\n

db.chat_message.aggregate([<\/p>\n

{      $match: {          \"sessionId\":{$in: [\"1249264194773536859\"]},           \"channel\": 3,          \"senderType\": 2      }  },  {      $group: {          _id: {              sessionId: \"$sessionId\",              targetId: \"$targetId\"          },          count: { $sum: 1 }      }  },  {      $match: {          tcount: { $gt: 2 }      }  },  {      $group: {          _id: {              targetId: \"$_id.targetId\"          },          count: { $sum: 1}      }  },  {      $group: {          _id: null,          count: {$sum: 1}      }  } <\/code><\/pre>\n
])<\/p>\n
\u7b2c\u4e00\u6b21\u641e mongdb\uff0c\u8fd8\u662f\u8fd9\u79cd\u591a\u91cd\u5206\u7ec4\u7684\uff0c\u8981\u7528 java \u4ee3\u7801\u5b9e\u73b0\uff0c\u7f51\u4e0a\u627e\u4e86\u4e00\u4e9b\u6559\u7a0b\u770b\u4e86\uff0c\u4f46\u662f\u6700\u540e\u8fd8\u662f\u4e0d\u884c\uff0c\u6ca1\u6cd5\u4e86\u539a\u8138\u76ae\u6765\u6c42\u52a9<\/p>\n<\/p><\/div>\n
 \u5927\u4f6c\u6709\u8a71\u8aaa<\/b> (11<\/span>)        <\/div>\n
 <\/div>\n<\/p><\/div>\n<\/p><\/div>\n
    \n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : narmgalaxy <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \/\/ Requires official Java MongoDB Driver 3.6+
    import com.mongodb.Block;
    import com.mongodb.MongoClient;
    import com.mongodb.MongoException;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import java.util.Arrays;
    import java.util.List;
    import org.bson.BsonNull;
    import org.bson.Document;
    import org.bson.conversions.Bson;<\/p>\n
    public class Program {<\/p>\n
     public static void main(String[] args) {<\/p>\n
     try (MongoClient client = new MongoClient(“localhost”, 27017)) {<\/p>\n
     MongoDatabase database = client.getDatabase(“bijiduo”);
     MongoCollection<Document> collection = database.getCollection(“docInfo”);<\/p>\n
     \/\/ Created with Studio 3T, the IDE for MongoDB – https:\/\/studio3t.com\/<\/p>\n
     Block<Document> processBlock = new Block<Document>() {
     @Override
     public void apply(final Document document) {
     System.out.println(document);
     }
     };<\/p>\n
     List<? extends Bson> pipeline = Arrays.asList(
     new Document()
     .append(“$match”, new Document()
     .append(“sessionId”, new Document()
     .append(“$in”, Arrays.asList(
     “1249264194773536859”
     )
     )
     )
     .append(“channel”, 3.0)
     .append(“senderType”, 2.0)
     ), 
     new Document()
     .append(“$group”, new Document()
     .append(“_id”, new Document()
     .append(“sessionId”, “$sessionId”)
     .append(“targetId”, “$targetId”)
     )
     .append(“count”, new Document()
     .append(“$sum”, 1.0)
     )
     ), 
     new Document()
     .append(“$match”, new Document()
     .append(“tcount”, new Document()
      .append(“$gt”, 2.0)
     )
     ), 
     new Document()
     .append(“$group”, new Document()
     .append(“_id”, new Document()
     .append(“targetId”, “$_id.targetId”)
     )
     .append(“count”, new Document()
     .append(“$sum”, 1.0)
     )
     ), 
     new Document()
     .append(“$group”, new Document()
     .append(“_id”, new BsonNull())
     .append(“count”, new Document()
     .append(“$sum”, 1.0)
     )
     )
     );<\/p>\n
     collection.aggregate(pipeline)
     .allowDiskUse(false)
     .forEach(processBlock);<\/p>\n
     } catch (MongoException e) {
     \/\/ handle MongoDB exception
     }
     }<\/p>\n
    }                                                            <\/p><\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : 0x9527 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 tcount: { $gt: 2 } \uff1f                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @0x9527 \u8fd9\u4e2a\u662f\u624b\u6296\uff0c\u5f04\u9519\u4e86\uff0c\u591a\u4e86\u4e2a t                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @narmgalaxy \u611f\u8c22                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @narmgalaxy <\/p>\n
    \u5927\u4f6c \u4f60\u8fd9\u4e2a\u662f\u7528 studio 3T \u751f\u6210\u7684\u5417? \u683c\u5f0f\u597d\u50cf<\/p>\n
    \u4f46\u662f\u6211\u8bb0\u5f97\u8fd9\u4e2a\u662f\u53ea\u80fd\u7528 SQL \u751f\u6210 Java \u4ee3\u7801\u5427? 
    \u548b\u7528 mongo shell \u751f\u6210 java \u4ee3\u7801\u554a?                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : narmgalaxy <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u6211\u8fd9\u4e2a\u662f\u81ea\u52a8\u751f\u6210\u7684\u3002\u7528\u7684 studio 3t.                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : narmgalaxy <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @wushigejiajia01 \u4e0d\u662f\u597d\u50cf\uff0c\u8fd9\u4e2a\u5c31\u662f\u3002                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @narmgalaxy 
    \u597d\u5427 \u6211\u8bf4\u770b\u7740\u683c\u5f0f\u602a\u773c\u719f<\/p>\n
    \u53ef\u662f \u6211\u7528\u7684\u7248\u672c\u597d\u50cf\u53ea\u6709\u4ece SQL \u751f\u6210 Java \u4ee3\u7801, \u6ca1\u6709\u4ece shell \u751f\u6210\u4ee3\u7801\u7684<\/p>\n
    \u4f60\u8fd9\u4e2a\u662f\u548b\u5f04\u7684?
    \u6211\u7684\u7248\u672c\u4e0d\u5bf9\u5417
    \u6211\u7684\u662f 2019.2.1(\u8bd5\u7528\u7248)                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : narmgalaxy <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u6211\u4e5f\u662f\u4e00\u6837\u7684\u7248\u672c\u3002
    \u5728 aggreagate \u91cc\u64cd\u4f5c\uff0c                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : wushigejiajia01 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @narmgalaxy 
    \u54c8\u54c8
    \u6211\u81ea\u5df1\u7814\u7a76\u4e86\u4e0b, \u641e\u51fa\u6765\u4e86
    \u6211\u5c31\u60f3\u7740\u8d76\u7d27\u8fc7\u6765\u56de\u590d\u4f60\u4e00\u4e0b, \u6ca1\u60f3\u5230\u4f60\u8fd9\u4e48\u5feb\u5c31\u56de\u590d\u4e86<\/p>\n
    \u54c8\u54c8 \u611f\u8c22                                                            <\/p><\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : qinxi <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \/\/match1
    final MatchOperation match = Aggregation.match(criteria);
    \/\/group1
    final GroupOperation group1 = Aggregation.group(“sessionId”,”targetId”).count().as(“count”);
    \/\/match2
    final MatchOperation match2 = Aggregation.match(new Criteria(“count”).gt(2));<\/p>\n
    \/\/group2
    Aggregation.group().count().as(“count”);<\/p>\n
     final Aggregation aggregation = Aggregation.newAggregation(match1, group1,match2, group2);<\/p>\n
     final Map uniqueMappedResult = mongoTemplate.aggregate(aggregation, UserTask.class, Map.class).getUniqueMappedResult();                                                            <\/p><\/div>\n<\/p><\/div>\n<\/li>\n
  • \n","protected":false},"excerpt":{"rendered":"
    [\u6c42\u52a9] Java \u64cd\u4f5c mong…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[],"tags":[],"_links":{"self":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/207338"}],"collection":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=207338"}],"version-history":[{"count":0,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/207338\/revisions"}],"wp:attachment":[{"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=207338"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=207338"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=207338"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}