narmgalaxy 最近的时间轴更新
narmgalaxy

narmgalaxy

V2EX 第 318860 号会员,加入于 2018-05-27 15:52:36 +08:00
今日活跃度排名 3573
narmgalaxy 最近回复了
@juded 不太懂什么意思
1 天前
回复了 wushigejiajia01 创建的主题 Java [求助] Java 操作 mongodb
我也是一样的版本。
在 aggreagate 里操作,
1 天前
回复了 wushigejiajia01 创建的主题 Java [求助] Java 操作 mongodb
@wushigejiajia01 不是好像,这个就是。
1 天前
回复了 wushigejiajia01 创建的主题 Java [求助] Java 操作 mongodb
我这个是自动生成的。用的 studio 3t.
2 天前
回复了 wushigejiajia01 创建的主题 Java [求助] Java 操作 mongodb
// 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;

public class Program {

public static void main(String[] args) {

try (MongoClient client = new MongoClient("localhost", 27017)) {

MongoDatabase database = client.getDatabase("bijiduo");
MongoCollection<Document> collection = database.getCollection("docInfo");

// Created with Studio 3T, the IDE for MongoDB - https://studio3t.com/

Block<Document> processBlock = new Block<Document>() {
@Override
public void apply(final Document document) {
System.out.println(document);
}
};

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)
)
)
);

collection.aggregate(pipeline)
.allowDiskUse(false)
.forEach(processBlock);

} catch (MongoException e) {
// handle MongoDB exception
}
}

}
7 天前
回复了 aa69489437 创建的主题 奇思妙想 有合作开发的小伙伴么,一起来哈。
我能提供前端,后端,go,java,python 都可以写
。android,用 flutter 的的话 ios 也行
7 天前
回复了 wuvvu 创建的主题 程序员 仿做一个疫情地图,需要搜索什么关键字
antv
bitvise+1
嗨呀,又来了来了
关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   1221 人在线   最高记录 5268   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 8ms · UTC 19:06 · PVG 03:06 · LAX 11:06 · JFK 14:06
♥ Do have faith in what you're doing.