private void getUsersWithin24Hours(String id, Map < String, Object > payload) throws JSONException { JSONObject json = new JSONObject(String.valueOf(payload.get("data"))); Query query = new Query(); query.addCriteria(Criteria.where("user_id").is(id).and("timezone").in(json.get("timezone")).and("gender").in(json.get("gender")).and("locale").in(json.get("language")).and("time").gt(getDate())); mongoTemplate.getCollection("user_log").distinct("user_id", query.getQueryObject()); }Iba a hacer una consulta y obtener el resultado de mongodb y tuve éxito con el comando de terminal mongo:
db.getCollection('user_log').find({"user_id" : "1", "timezone" : {$in: [5,6]}, "gender" : {$in : ["male", "female"]}, "locale" : {$in : ["en_US"]}, "time" : {$gt : new ISODate("2017-01-26T16:57:52.354Z")}})pero desde Java cuando lo estaba intentando, me dio el siguiente error.
org.bson.codecs.configuration.CodecConfigurationException: no se puede encontrar un códec para la clase org.json.JSONArray
¿Cuál es la forma ideal de hacer esto?
Sugerencia: en realidad, creo que en mi código se produjo un error en esta parte json.get ("zona horaria"). porque contiene una matriz. Cuando estoy usando matrices de cadenas de código duro, este código funciona
Aquí hay un ejemplo de MongoDB del curso de MongoDB University con una base de datos MongoDB llamada "students" con una colección llamada "grades":
pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.mongodb</groupId> <artifactId>test</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <name>test</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver</artifactId> <version>3.2.2</version> </dependency> </dependencies> </project>com/mongo/Main.java
package com.mongo; import com.mongodb.MongoClient; import com.mongodb.client.*; import org.bson.Document; import org.bson.conversions.Bson; import javax.print.Doc; public class Main { public static void main(String[] args) { MongoClient client = new MongoClient(); MongoDatabase database = client.getDatabase("students"); final MongoCollection<Document> collection = database.getCollection("grades"); Bson sort = new Document("student_id", 1).append("score", 1); MongoCursor<Document> cursor = collection.find().sort(sort).iterator(); try { Integer student_id = -1; while (cursor.hasNext()) { Document document = cursor.next(); // Doing more stuff } } finally { cursor.close(); } } }No tiene que usar JSONObject/JSONArray para la conversión.
Reemplace con la línea de abajo si payload.get("data") es Map
BasicDBObject json = new BasicDBObject(payload.get("data")); Reemplace con la línea a continuación si payload.get("data") contiene una cadena json.
BasicDBObject json =(BasicDBObject) JSON.parse(payload.get("data"));