ArrayList<ServerAddress> servers = new ArrayList<ServerAddress>();
|
servers.add(new ServerAddress("s231", 20050));
|
servers.add(new ServerAddress("s231", 20051));
|
servers.add(new ServerAddress("s231", 20052));
|
|
Mongo m = new Mongo(servers);
|
|
m.setReadPreference(ReadPreference.SECONDARY);
|
final BasicDBObject query = new BasicDBObject();
|
final BasicDBObject fields = new BasicDBObject();
|
|
query.put("_id", new BasicDBObject("$gte", Integer.valueOf(1)));
|
fields.put("_id", Long.valueOf(1));
|
|
final DB db = m.getDB("offerStore");
|
boolean ok = db.authenticate("user", "pw".toCharArray());
|
System.out.println("ok: " + ok);
|
final DBCursor c = db.getCollection("offer").find(query, fields).limit(10);
|
|
while(c.hasNext()) {
|
DBObject offer = c.next();
|
System.out.println(offer);
|
}
|
c.close();
|