MongoDB using Node.js - Part 2

var MongoClient = require('mongodb').MongoClient;

// Connect to the db
MongoClient.connect("mongodb://username:yourpassword@serveraddress:yourport/database", function(err, db) {

    if(err) { return console.dir(err); }

    var collection = db.collection('nodejs');

    var doc1 = {'_id':'doc1', 'city':'taipei', 'num' :25};
    var doc2 = {'_id':'doc2', 'city':'kaohsiung', 'num' :35};

    //insert
    collection.insert(doc1, {w:1}, function(err, result){});

    collection.insert(doc2, {w:1}, function(err, result) {
        console.log('insert');
        collection.update({city:'taipei'}, {$set:{num:55}}, {w:1}, function(err, result) {});
        
        collection.find().toArray(function(err, items) {});

        collection.find({city:'taipei'}).toArray(function(err, docs){
            console.log("retrieved records:");
            console.log(docs);
        });
    });
        
    var cursor = collection.find({city:'taipei'}).toArray(function(err, docs) {
          console.log("Printing docs from Array");
          docs.forEach(function(doc) {
                console.log("Doc from Array ");
                console.dir(doc);
                console.log(doc.city);
          });
    });
    //update
    collection.update({city:'taipei'}, {$inc:{num:25}}, {w:1}, function(err, result) {
        if(err)
        {
            console.log('fail update');
            return console.dir(err);
        }
        console.log('Successfully update');
    });
    //remove
    collection.remove({city:'kaohsiung'}, {w:1}, function(err, result) {});
});

MongoDB using Node.js - Part 1

// Retrieve
var MongoClient = require('mongodb').MongoClient;

// Connect to the db
MongoClient.connect("mongodb://yourusername:yourpassword@yourserveraddress:yourport/yourdatabase", function(err, db) {
  if(err) { return console.dir(err); }

  db.createCollection('nodejs', function(err, collection) {});
    
  var collection = db.collection('nodejs');
  var doc1 = {'hello':'doc1'};
  var doc2 = {'hello':'doc2'};
  var lotsOfDocs = [{'hello':'doc3'}, {'hello':'doc4'}];

  collection.insert(doc2, {w:1}, function(err, result) {});

  collection.insert(lotsOfDocs, {w:1}, function(err, result) {});

});

MongoDB using Java Part 3 - select

package mongodb;

import java.util.ArrayList;
import java.util.List;
import java.net.UnknownHostException;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoCredential;
import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;

public class MongodbSelect {

 public static void main(String[] args) {
  // TODO Auto-generated method stub
  try
  {
   // 認證
   MongoCredential journaldevAuth = MongoCredential.createMongoCRCredential("your username", "your database", "your password".toCharArray());
   List auths = new ArrayList();
   auths.add(journaldevAuth);

   //連線
   ServerAddress serverAddress = new ServerAddress("your server", your port);
   MongoClient mongo = new MongoClient(serverAddress,auths);

   //選擇連線database
   DB db = mongo.getDB("your database");

   //選擇collection (table)
   DBCollection site = db.getCollection("site");

   //iterate the table
   System.out.println();
   System.out.println("iterate the table");
   DBCursor cursor = site.find();
   try {
    while(cursor.hasNext()) {
     System.out.println(cursor.next());
    }
   } finally {
    cursor.close();
   }

   //query -->  city==Taipei
   System.out.println();
   System.out.println("query -->  city==Taipei");
   BasicDBObject query = new BasicDBObject("city", "taipei");

   cursor = site.find(query);

   try {
    while(cursor.hasNext()) {
     System.out.println(cursor.next());
    }
   } finally {
    cursor.close();
   }

   //query --> num>=50 && city==Taipei
   System.out.println();
   System.out.println("query --> num>=50 && city==Taipei");
   query = new BasicDBObject("num", new BasicDBObject("$gte", 50))
   .append("city", "taipei");

   cursor = site.find(query);

   try {
    while(cursor.hasNext()) {
     System.out.println(cursor.next());
    }
   } finally {
    cursor.close();
   }
   
   //query num > 20 && num<=30
   //only display columns city , address
   System.out.println();
   System.out.println("query num > 20 && num<=30");
   System.out.println("only display columns city , address");
   query = new BasicDBObject("num", new BasicDBObject("$gt", 20).append("$lte", 30));
   cursor = site.find(query, new BasicDBObject("city",true).append("address", true));

   try {
       while (cursor.hasNext()) {
           System.out.println(cursor.next());
       }
   } finally {
       cursor.close();
   }
   
   //iterate the table and sort by num
   System.out.println();
   System.out.println("iterate the table and sort by num");
      cursor = site.find().sort(new BasicDBObject("num",1));
   try {
    while(cursor.hasNext()) {
     System.out.println(cursor.next());
    }
   } finally {
    cursor.close();
   }
  }
  catch(UnknownHostException ex)
  {

  }
 }

}

MongoDB using Java part 2 - delete

package mongodb;

import java.util.ArrayList;
import java.util.List;
import java.net.UnknownHostException;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.MongoCredential;
import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;

public class MongodbDelete {

 public static void main(String[] args) {
  // TODO Auto-generated method stub
  try
  {
   // 認證
   MongoCredential journaldevAuth = MongoCredential.createMongoCRCredential("your username", "your database", "your password".toCharArray());
   List auths = new ArrayList();
   auths.add(journaldevAuth);

   //連線
   ServerAddress serverAddress = new ServerAddress("your address", your port);
   MongoClient mongo = new MongoClient(serverAddress,auths);

   //選擇連線database
   DB db = mongo.getDB("your database");

   //選擇collection (table)
   DBCollection site = db.getCollection("site");

   BasicDBObject searchQuery = new BasicDBObject();
   searchQuery.put("city", "Taipei");
   site.remove(searchQuery);
  }
  catch(UnknownHostException ex)
  {

  }
 }

}

MongoDB using Java part 1 - update

package mongodb;

import java.util.ArrayList;
import java.util.List;
import java.net.UnknownHostException;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.MongoCredential;
import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;

public class MongdbUpdate {

 public static void main(String[] args) {
  // TODO Auto-generated method stub
  try
  {
   // 認證
   MongoCredential journaldevAuth = MongoCredential.createMongoCRCredential("username", "database", "password".toCharArray());
   List auths = new ArrayList();
   auths.add(journaldevAuth);

   //連線
   ServerAddress serverAddress = new ServerAddress("your server address", your port);
   MongoClient mongo = new MongoClient(serverAddress,auths);

   //選擇連線database
   DB db = mongo.getDB("database");

   //選擇collection (table)
   DBCollection site = db.getCollection("site");
   
   // $set
   BasicDBObject query = new BasicDBObject();
   query.put("city", "taipei");
   BasicDBObject newDocument = new BasicDBObject();
   newDocument.put("num", 125);
   
   BasicDBObject updateObj = new BasicDBObject();
   updateObj.put("$set", newDocument);
   
   site.update(query, updateObj, true, true);
   
   // $inc
   updateObj.clear();
   updateObj.put("$inc", newDocument);
   site.update(query, updateObj, true, true);
  }
  catch(UnknownHostException ex)
  {

  }
 }

}