Commit 1a382398 authored by Grzegorz Pietrusza's avatar Grzegorz Pietrusza

working mongodb stub

parent 3b8692d4
import api.ExampleResource; import api.ExampleResource;
import com.mongodb.*;
import com.mongodb.client.FindIterable; import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoIterable;
import database.MongoDatabaseConnector; import database.MongoDatabaseConnector;
import io.dropwizard.Application; import io.dropwizard.Application;
import io.dropwizard.setup.Environment; import io.dropwizard.setup.Environment;
...@@ -10,27 +14,60 @@ import persistence.MongoRepositories; ...@@ -10,27 +14,60 @@ import persistence.MongoRepositories;
import repositories.Repositories; import repositories.Repositories;
import stub.MongoConfiguration; import stub.MongoConfiguration;
import java.util.Arrays;
/** /**
* Created by gpietrus on 16.02.16. * Created by gpietrus on 16.02.16.
*/ */
public class CTFApplication extends Application<ApplicationConfiguration> public class CTFApplication extends Application<ApplicationConfiguration> {
{
@Override @Override
public void run(ApplicationConfiguration applicationConfiguration, Environment environment) throws Exception public void run(ApplicationConfiguration applicationConfiguration, Environment environment) throws Exception {
{ // environment.jersey().register(ExampleResource.class);
environment.jersey().register(ExampleResource.class); // MongoDatabaseConnector mongoDatabaseConnector = new MongoDatabaseConnector();
MongoDatabaseConnector mongoDatabaseConnector = new MongoDatabaseConnector(); // FindIterable<Document> users = mongoDatabaseConnector.getUsers();
FindIterable<Document> users = mongoDatabaseConnector.getUsers();
} }
public static void main(String[] args) throws Exception public static void main(String[] args) throws Exception {
{
//todo: add mongo-java-driver as maven dep
/*
MongoSession session = MongoConfiguration.createSession(); MongoSession session = MongoConfiguration.createSession();
session.start(); session.start();
Repositories.initialise(new MongoRepositories(session)); Repositories.initialise(new MongoRepositories(session));
Repositories.fruits().add(new Fruit("apple")); Repositories.fruits().add(new Fruit("apple"));
session.stop(); session.stop();
*/
//new CTFApplication().run(args); //new CTFApplication().run(args);
MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("db");
// database.createCollection("users"); //todo:
MongoCollection<Document> usersCollection = database.getCollection("users");
usersCollection.insertOne(new Document()
.append("username", "gpietrus")
.append("age", 1)
);
BasicDBList documents = usersCollection.find().into(new BasicDBList());
/*
MongoIterable<String> strings = database.listCollectionNames();
MongoCollection<Document> collection = database.getCollection("test");
FindIterable<Document> documents = collection.find();
Document doc = new Document("name", "MongoDB")
.append("type", "database")
.append("count", 1)
.append("info", new Document("x", 203).append("y", 102));
collection.insertOne(doc);
*/
} }
} }
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