MongoDB Java

Instalação

Antes de começar a usar o MongoDB com nossos programas em Java, precisamos ter certeza de que temos informações MongoDB Java Driver JDBC e configurar sua máquina.

Você pode verificar no Java tutorial como instalar o Java em sua máquina. Agora, vamos verificar como configurar o MongoDB JDBC driver.

1. Você precisa baixar o arquivo  mongo.jar. Certifique-se de baixar a ultima versão do mesmo.


2. Você precisa incluir o mongo.jar em seu classpath.

Conecte-se ao banco de dados

Para conectar banco de dados, você precisa especificar o nome do banco de dados, se não existir, então será criado automaticamente pelo MongoDB.

Trechos do código para se conectar ao banco de dados seria a seguinte:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth);
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Agora, vamos compilar e executar acima programa para criar nosso banco de dados de teste. Você pode mudar o seu caminho como por sua exigência. Estamos assumindo versão atual do driver JDBC mongo-2.10.1.jar está disponível no caminho atual

$javac MongoDBJDBC.java
$java -classpath ".:mongo-2.10.1.jar" MongoDBJDBC
Connect to database successfully
Authentication: true

Se você estiver usando uma máquina Windows, você pode compilar e executar o seu código da seguinte forma:

$javac MongoDBJDBC.java
$java -classpath ".;mongo-2.10.1.jar" MongoDBJDBC
Connect to database successfully
Authentication: true

Valor do auth será true, se o nome de usuário e a senha forem válidos para o banco de dados selecionado.

Criar uma coleção (Collection)

Para criar uma coleção,utilizaremos o método createCollection() da classe com.mongodb.DB.

Trechos de código para criar uma coleção:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth);
 DBCollection coll = db.createCollection("mycol");
 System.out.println("Collection created successfully");
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection created successfully

Obtendo/Selecionando uma coleção

Para obter/selecionar uma coleção a partir do banco de dados, utilizaremos o método getCollection() da classe com.mongodb.DBCollection.

Trechos de código para obter/selecionar uma coleção:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth);
 DBCollection coll = db.createCollection("mycol");
 System.out.println("Collection created successfully");
 DBCollection coll = db.getCollection("mycol");
 System.out.println("Collection mycol selected successfully");
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection created successfully
Collection mycol selected successfully

Inseririndo um documento

Para inserir um documento no mongodb, utilizaremos o metodo insert() da classe com.mongodb.DBCollection

Trechos de código para inserir um documentos:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth); 
 DBCollection coll = db.getCollection("mycol");
 System.out.println("Collection mycol selected successfully");
 BasicDBObject doc = new BasicDBObject("title", "MongoDB").
 append("description", "database").
 append("likes", 100).
 append("url", "http://www.tutorialspoint.com/mongodb/").
 append("by", "tutorials point");
 coll.insert(doc);
 System.out.println("Document inserted successfully");
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document inserted successfully

Recuperar todos os documentos

Para selecionar todos os documentos da coleção utilizaremos o método  find() da classe com.mongodb.DBCollection. Este método retorna um cursor, então você precisa repetir este cursor.

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth); 
 DBCollection coll = db.getCollection("mycol");
 System.out.println("Collection mycol selected successfully");
 DBCursor cursor = coll.find();
 int i=1;
 while (cursor.hasNext()) { 
 System.out.println("Inserted Document: "+i); 
 System.out.println(cursor.next()); 
 i++;
 }
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Inserted Document: 1
{
 "_id" : ObjectId(7df78ad8902c),
 "title": "MongoDB",
 "description": "database",
 "likes": 100,
 "url": "http://www.tutorialspoint.com/mongodb/",
 "by": "tutorials point"
}

Atualização de Documentos (Update)

Para atualizar documentos de uma colação utilizaremos o método update() da classe com.mongodb.DBCollection.

Trechos de código para selecionar documentos:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth); 
 DBCollection coll = db.getCollection("mycol");
 System.out.println("Collection mycol selected successfully");
 DBCursor cursor = coll.find();
 while (cursor.hasNext()) { 
 DBObject updateDocument = cursor.next();
 updateDocument.put("likes","200")
 col1.update(updateDocument); 
 }
 System.out.println("Document updated successfully");
 cursor = coll.find();
 int i=1;
 while (cursor.hasNext()) { 
 System.out.println("Updated Document: "+i); 
 System.out.println(cursor.next()); 
 i++;
 }
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document updated successfully
Updated Document: 1
{
 "_id" : ObjectId(7df78ad8902c),
 "title": "MongoDB",
 "description": "database",
 "likes": 100,
 "url": "http://www.tutorialspoint.com/mongodb/",
 "by": "tutorials point"
}

Apagar documentos

Para apagar documentos de uma coleção, você precisa primeiro selecionar os documentos usando o método findOne () e  em seguida, o método remover de classe com.mongodb.DBCollection .

Trechos de código para excluir documentos:

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
 public static void main( String args[] ){
 try{ 
 // To connect to mongodb server
 MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
 // Now connect to your databases
 DB db = mongoClient.getDB( "test" );
 System.out.println("Connect to database successfully");
 boolean auth = db.authenticate(myUserName, myPassword);
 System.out.println("Authentication: "+auth); 
 DBCollection coll = db.getCollection("mycol");
 System.out.println("Collection mycol selected successfully");
 DBObject myDoc = coll.findOne();
 col1.remove(myDoc);
 DBCursor cursor = coll.find();
 int i=1;
 while (cursor.hasNext()) { 
 System.out.println("Inserted Document: "+i); 
 System.out.println(cursor.next()); 
 i++;
 }
 System.out.println("Document deleted successfully");
 }catch(Exception e){
 System.err.println( e.getClass().getName() + ": " + e.getMessage() );
 }
 }
}

Quando o programa é compilado e executado, obteremos o seguinte resultado:

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document deleted successfully