-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmongo.java
82 lines (67 loc) · 2.61 KB
/
mongo.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package mongoproject;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.model.Updates;
import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
public class MongoAdmin {
private static MongoClient mongoclient;
public static void main(String[] args) {
MongoClient client = conectar();
MongoDatabase db = basetest(client);
listaProdutos(db);
inserir(db, "Novo", "Teste", "100.0", "Nada");
listaProdutos(db);
alterar(db, "Novo", "150");
listaProdutos(db);
remover(db, "Novo");
listaProdutos(db);
}
public static void alterar(MongoDatabase db, String nome, String valor) {
MongoCollection<Document> colection = db.getCollection("produtos");
Bson updates = Updates.combine(Updates.set("valor", valor));
Document busca = new Document("nome", nome);
colection.updateOne(busca, updates);
}
public static void remover(MongoDatabase db, String nome) {
MongoCollection<Document> colection = db.getCollection("produtos");
Document busca = new Document("nome", nome);
colection.deleteOne(busca);
}
public static void inserir(MongoDatabase db, String nome, String descricao, String valor, String estado) {
MongoCollection<Document> colection = db.getCollection("produtos");
Document produto = new Document("nome", nome).append("descricao", descricao).append("valor", valor).append("estado", estado);
colection.insertOne(produto);
}
public static MongoClient conectar() {
System.out.println("Conectando com o Mongo");
MongoClient client = MongoClients.create("mongodb://localhost");
return client;
}
public static MongoDatabase basetest(MongoClient client) {
System.out.println("Conectando a base test");
MongoDatabase db = client.getDatabase("test");
return db;
}
public static void listaColecao(MongoDatabase db) {
System.out.println("Lista as colecoes da base");
Iterable<Document> collections = db.listCollections();
for (Document col: collections) {
System.out.println(col.get("name"));
}
}
public static void listaProdutos(MongoDatabase db) {
MongoCollection<Document> colection = db.getCollection("produtos");
System.out.println("Imprimindo Produtos");
Iterable<Document> produtos = colection.find();
for (Document produto: produtos) {
String nome = produto.getString("nome");
String descricao = produto.getString("descricao");
String valor = produto.getString("valor");
String estado = produto.getString("estado");
System.out.println(nome + " -- " + descricao + " -- " + valor + " -- " + estado);
}
}
}