public class MyConstants {
 
  // Nếu tên DB này chưa có trong hệ thống
  // Khi được gọi, nó sẽ được tự động tạo ra
  public static final String DB_NAME ="MyStudyDB";
 
}

// Host: địa chỉ của host, ở đây là cá nhân nên sẽ là localhost
private static final String HOST = "localhost";
// port: Cổng tương ứng
private static final int PORT = 27017;

MongoClient mongoClient = new MongoClient();

MongoClient mongoClient = new MongoClient(new MongoClientURI("MongoDB://"Host":'port'"));
// Sử dụng URI để kết nối nhanh chóng
// Hoặc dễ hiểu hơn
MongoClient mongoClient = new MongoClient(HOST, PORT);

//Tạo chứng chỉ  
MongoCredential credential = MongoCredential.createMongoCRCredential(
              USERNAME, MyConstants.DB_NAME, PASSWORD.toCharArray());
// Tạo client truy cập, tuy nhiên thêm chứng chỉ
      MongoClient mongoClient = new MongoClient(
              new ServerAddress(HOST, PORT), Arrays.asList(credential));

// (Không nhất thiết DB này phải tồn tại sẵn
// nó sẽ được tự động tạo ra nếu chưa tồn tại).
DB db = mongoClient.getDB(MyConstants.DB_NAME);

// Ví dụ lấy ra Collection với tên Department.
// Không nhất thiết Collection này phải tồn tại trong DB.
DBCollection dept = db.getCollection("Department");

package org.o7planning.tutorial.mongodb;
 
import java.net.UnknownHostException;
import java.util.Arrays;
import java.util.List;
 
import com.mongodb.MongoClient;
import com.MongoDB.MongoCredential;
import com.MongoDB.ServerAddress;
 
public class MongoUtils {
 
  private static final String HOST = "localhost";
  private static final int PORT = 27017;
 
  //
  private static final String USERNAME = "mgdb";
  private static final String PASSWORD = "1234";
 
  // Cách kết nối vào MongoDB không bắt buộc bảo mật.
  private static MongoClient getMongoClient_1() throws UnknownHostException {
      MongoClient mongoClient = new MongoClient(HOST, PORT);
      return mongoClient;
  }
 
  // Cách kết nối vào DB MongoDB có bảo mật.
  private static MongoClient getMongoClient_2() throws UnknownHostException {
      MongoCredential credential = MongoCredential.createMongoCRCredential(
              USERNAME, MyConstants.DB_NAME, PASSWORD.toCharArray());
 
      MongoClient mongoClient = new MongoClient(
              new ServerAddress(HOST, PORT), Arrays.asList(credential));
      return mongoClient;
  }
 
  public static MongoClient getMongoClient() throws UnknownHostException {
      // Kết nối vào MongoDB không bắt buộc bảo mật.
      return getMongoClient_1();
      // Bạn có thể thay thế bởi getMongoClient_2()
      // trong trường hợp kết nối vào MongoDB có bảo mật.
  }
 
  private static void ping() throws UnknownHostException {
      MongoClient mongoClient = getMongoClient();
      
      System.out.println("List all DB:");
      
      // Danh sách các DB Names.
      List<String> dbNames = mongoClient.getDatabaseNames();
      for (String dbName : dbNames) {
          System.out.println("+ DB Name: " + dbName);
      }
 
      System.out.println("Done!");
  }
 
  // Test
  public static void main(String[] args) throws UnknownHostException {
      ping();
  }
}

List<Integer> books = Arrays.asList(27464, 747854);
DBObject person = new BasicDBObject("_id", "jo")
                            .append("name", "Jo Bloggs")
                            .append("address", new BasicDBObject("street", "123 Fake St")
                                                         .append("city", "Faketon")
                                                         .append("state", "MA")
                                                         .append("zip", 12345))
                            .append("books", books);

dept.insert(person)

// Một số method của class DBCollection cho việc truy vấn:
public DBCursor find(DBObject ref)
  
public DBCursor find(DBObject ref, DBObject keys)

BasicDBObjectBuilder whereBuilder = BasicDBObjectBuilder.start();
whereBuilder.append("dept_name", "ACCOUNTING");
//
DBObject where  = whereBuilder.get();
        
// Query
DBCursor cursor = dept.find(where);

public static DBObject getWhereClause() {
 
      BasicDBObjectBuilder whereBuilder = BasicDBObjectBuilder.start();
      
      // Sử dụng append và add là giống nhau.
      whereBuilder.push("dept_name").add("$regex", ".*A.*") ;
      whereBuilder.pop();
      whereBuilder.append("description", null);
      //
      DBObject where = whereBuilder.get();
      System.out.println("Where " + where.toString());
      return where;
  }

public static DBObject getWhereClause() {
 
    BasicDBObjectBuilder whereBuilder = BasicDBObjectBuilder.start();
 
    // Biểu thức chính quy mô tả một chuỗi.
    // Bắt đầu bởi ký tự bất kỳ xuất hiện 0 hoặc nhiều lần
    // Tiếp theo là ký tự S.
    // Và tiếp theo là ký tự xuất hiện 0 hoặc nhiều lần.
    String regex = ".*S.*";
    Pattern pattern = Pattern.compile(regex);
 
    whereBuilder.append("dept_name", pattern);
    whereBuilder.append("description", null);
    //
    DBObject where = whereBuilder.get();
    System.out.println("Where: " + where.toString());
    return where;
  }

// Viết điều kiện where sử dụng QueryBuilder.
// Sử dụng QueryBuilder luôn luôn dễ dàng hơn.
// dept_name in ('ACCOUNTING', 'RESEARCH') or location  = 'BOSTON'.
// { "$or" : [ { "dept_name" : { "$in" : [ "ACCOUNTING" , "RESEARCH"]}} , {"location" : "BOSTON"}]}
  protected static DBObject getWhereClause() {
      List<String> list = new ArrayList<String>();
      list.add("ACCOUNTING");
      list.add("RESEARCH");
      //
      QueryBuilder qb1 = new QueryBuilder();
      qb1.put("dept_name").in(list);
      DBObject q1 = qb1.get();
      //
      QueryBuilder qb2 = new QueryBuilder();
      qb2.put("location").("BOSTON");
      DBObject q2 = qb2.get();
 
       //
      QueryBuilder queryBuilder = QueryBuilder.start();
      queryBuilder.or(q1, q2);
 
      DBObject query = queryBuilder.get();
      return query;
  }
 

List<String> list = new ArrayList<String>();
       list.add("ACCOUNTING");
       list.add("RESEARCH");
       //
       QueryBuilder queryBuilder = QueryBuilder.start();
       queryBuilder.or(QueryBuilder.start().put("dept_name").in(list).get(),
               QueryBuilder.start().put("location").is("BOSTON").get());
 
       DBObject query = queryBuilder.get();
       System.out.println("Query = " + query);
       return query;

      DBObject whereClause = new BasicDBObject("city_no", "WAS");
 
      DBObject values = new BasicDBObject();
      values.put("population", 1200000);
      values.put("description", "Pop 2014");
      values.put("note", "Document replaced!");
 
      // Thực hiện việc update.
      WriteResult result = city.update(whereClause, values);
      int effectedCount = result.getN();
      System.out.println("result: " + values.toString());
      System.out.println("Effected Count: " + effectedCount);

      DBCollection city = db.getCollection("City");
 
      // Tìm các City có city_no = "CHI".
      DBObject whereClause = new BasicDBObject("city_no", "CHI");
 
      DBObject values = new BasicDBObject();
      values.put("population", 3400000);
      values.put("description", "Pop 2014");
      values.put("note", "Document update with $set");
      
      DBObject valuesWithSet = new BasicDBObject();
      valuesWithSet.put("$set", values);
 
      // Thực hiện việc update.
      WriteResult result = city.update(whereClause, valuesWithSet);
      
      int effectedCount = result.getN();
      System.out.println("Effected Count: " + effectedCount);
      System.out.println("Done!");

    DBCollection city = db.getCollection("City");
 
     // Tìm các City có city_no = "NYO".
     DBObject whereClause = new BasicDBObject("city_no", "NYO");
 
     DBObject values = new BasicDBObject();
     values.put("population", 10000);
    
    
     DBObject valuesWithInc = new BasicDBObject();
     valuesWithInc.put("$inc", values);
 
     // Thực hiện việc update.
     WriteResult result = city.update(whereClause, valuesWithInc);
    
     int effectedCount = result.getN();
     System.out.println("Effected Count: " + effectedCount);