Commit 5caf6928 authored by santiagoperaza93's avatar santiagoperaza93

conexcion a mongo con singleton

parent e0457eff
......@@ -7,6 +7,7 @@ import static com.mongodb.client.model.Updates.set;
import java.util.ArrayList;
import java.util.List;
import javax.ejb.EJB;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;
......@@ -14,7 +15,6 @@ import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
......@@ -29,11 +29,17 @@ import excepciones.CategoriaNoExiste;
import excepciones.CategoriaYaExiste;
import logica.EstadoCategoria;
import logica.EstadoPregunta;
import logica.MongoClientProvider;
@Stateless
@LocalBean
public class CategoriaEJB implements CategoriaEJBLocal {
MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
@EJB
MongoClientProvider mongoClientProvider;
MongoClient mongoClientNube = mongoClientProvider.getMongoClient();
//MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
// MongoClient mongoClientNube = MongoClients.create(
// "mongodb+srv://proyecto:proyecto.20@tecno-trivia-vtpeu.mongodb.net/proyectoBDMongo?retryWrites=true&w=majority");
......
......@@ -3,18 +3,15 @@ package beans;
import java.util.ArrayList;
import java.util.List;
import javax.ejb.EJB;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;
import org.bson.Document;
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
......@@ -24,6 +21,7 @@ import datatypes.DtNotificacion;
import excepciones.NotificacionNoExiste;
import excepciones.NotificacionNoPendiente;
import logica.EstadoNotificacion;
import logica.MongoClientProvider;
/**
* Session Bean implementation class NotificacionEJB
......@@ -32,7 +30,11 @@ import logica.EstadoNotificacion;
@LocalBean
public class NotificacionEJB implements NotificacionEJBLocal {
MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
@EJB
MongoClientProvider mongoClientProvider;
MongoClient mongoClientNube = mongoClientProvider.getMongoClient();
//MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
// MongoClient mongoClientNube = MongoClients.create(
// "mongodb+srv://proyecto:proyecto.20@tecno-trivia-vtpeu.mongodb.net/proyectoBDMongo?retryWrites=true&w=majority");
......
......@@ -17,11 +17,8 @@ import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.BasicDBObject;
import com.mongodb.client.FindIterable;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
......@@ -38,6 +35,7 @@ import excepciones.PartidaNoExiste;
import logica.EstadoPartida;
import logica.EstadoPregunta;
import logica.ModoDeJuego;
import logica.MongoClientProvider;
import logica.TipoPregunta;
/**
......@@ -50,7 +48,12 @@ public class PartidaEJB implements PartidaEJBLocal {
@EJB
PreguntasEJB preguntas;
MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
@EJB
MongoClientProvider mongoClientProvider;
MongoClient mongoClientNube = mongoClientProvider.getMongoClient();
// MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
// MongoClient mongoClientNube = MongoClients.create(
// "mongodb+srv://proyecto:proyecto.20@tecno-trivia-vtpeu.mongodb.net/proyectoBDMongo?retryWrites=true&w=majority");
MongoDatabase db;
......
......@@ -15,12 +15,8 @@ import javax.ejb.Stateless;
import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
......@@ -31,6 +27,7 @@ import datatypes.DtPregunta;
import datatypes.DtRespuesta;
import logica.EstadoCategoria;
import logica.EstadoPregunta;
import logica.MongoClientProvider;
import logica.TipoPregunta;
@Stateless
......@@ -40,7 +37,11 @@ public class PreguntasEJB implements PreguntasEJBLocal{
@EJB
private CategoriaEJB categorias;
MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
@EJB
MongoClientProvider mongoClientProvider;
MongoClient mongoClientNube = mongoClientProvider.getMongoClient();
//MongoClient mongoClientNube = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
// MongoClient mongoClientNube = MongoClients.create(
// "mongodb+srv://proyecto:proyecto.20@tecno-trivia-vtpeu.mongodb.net/proyectoBDMongo?retryWrites=true&w=majority");
......
package logica;
import javax.annotation.PostConstruct;
import javax.ejb.ConcurrencyManagement;
import javax.ejb.ConcurrencyManagementType;
import javax.ejb.Lock;
import javax.ejb.LockType;
import javax.ejb.Singleton;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
@Singleton
@ConcurrencyManagement(ConcurrencyManagementType.CONTAINER)
public class MongoClientProvider {
private MongoClient mongoClient = null;
@Lock(LockType.READ)
public MongoClient getMongoClient(){
return mongoClient;
}
@PostConstruct
public void init() {
mongoClient = new MongoClient(new MongoClientURI("mongodb://proyecto:proyecto.20@mongodb/proyectoBDMongo"));
}
}
\ No newline at end of file
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment