out.println(dateNowStr);
DBCollection coll = MongoInit.getColl("table_admin");
BasicDBObject doc = new BasicDBObject();
doc.put("id", "12345678");
doc.put("time", dateNowStr);
doc.put("data", "117.13172:029.77659:131.2580");
doc.put("status", "0");
coll.insert(doc);
// 设定write concern，以便操作失败时得到提示
coll.setWriteConcern(WriteConcern.SAFE);
BasicDBObject dsort = new BasicDBObject();
dsort.put("time", -1);
BasicDBObject searchDevice = new BasicDBObject();
searchDevice.put("id", "12345678");
DBCursor cursor = coll.find(searchDevice).sort(dsort);
List list = cursor.toArray();
//ArrayList listSensorData=new ArrayList(list.size());
ObjectMapper mapper = new ObjectMapper();
String jsonfromList = null;
try {
//list转json
jsonfromList = mapper.writeva lueAsString(list);
} catch (JsonProcessingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//System.out.println(jsonfromList);
// for(int i=0;imysql count()函数),不受limit的影响
// while (cursor.hasNext()) {
// System.out.println(cursor.next());
// }
System.out.println("The Search Query has Executed!");
} catch (MongoException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
String dbname="wlwdb";
String dbCollection="table_admin";
String dbCollection1="15257102317";
String dataID="12345678";
MongoUtils tb=new MongoUtils();
tb.testGetDBS();//查询所有数据库
tb.getAllCollections();//查询所有表
//
// tb.findOne(dbCollection);//查找第一条记录
tb.testGpsData();
tb.getAllDocuments(dbCollection);//获取制定表明的所有数据
//tb.dropDatabase(dbname);//删除指定数据库
//tb.delete(dbCollection,dataID);//删除制定表明和设备ID的数据
//tb.dropCollection(dbCollection);// 删除一个表
//tb.createIndex(dbCollection1);//创建索引
//tb.getIndexInfo(dbCollection1);//获得表中所有索引
}
}
#端口设置
DBPort=27017
#URL
DBUrl=localhost
#URL
DBName=wlwdb
|