Cómo ejecutar múltiples comandos mongodb desde un código java. Necesito que los comandos mongodb se ejecuten en segundo plano cuando ejecuto el programa Java. Este programa genera una excepción "Excepción en el subproceso "principal" java.io.IOException: No se puede ejecutar el programa "db.createCollection("emplear")": error=2, No existe tal archivo o directorio en java.lang.ProcessBuilder.start( ProcessBuilder.java:1029) . . .".
import java.io.BufferedReader; import java.io.InputStreamReader; public class try1 { public static void main(String[] args) throws Exception{ String command ="mongo"; String command1="db.createCollection(\"employ\")"; Process proc = Runtime.getRuntime().exec(command); Process proc1 = Runtime.getRuntime().exec(command1); BufferedReader reader = new BufferedReader(new InputStreamReader(proc.getInputStream())); String line = ""; while((line = reader.readLine()) != null) { System.out.print(line + "\n"); } proc.waitFor(); BufferedReader reader1 = new BufferedReader(new InputStreamReader(proc.getInputStream())); String line1 = ""; while((line1 = reader1.readLine()) != null) { System.out.print(line1 + "\n"); } proc1.waitFor(); } }Necesito ejecutar un conjunto de comandos mongo db desde el programa java. El programa funciona con otros comandos de terminal como "ls" (solo comando único). Pero hay un problema si damos comando1 y comando como "ls". Solo se ejecuta un comando ls. Si intenta con un solo comando mongo db, diga, el comando "mongo" no se ejecuta por completo (el programa no termina). ¿Es por "proc.waitFor()".
tengo el codigo La función db.eval() sirve para mi propósito. Funciona perfectamente. :) "consulta" es la cadena que almacena la consulta mongodb.
public void qexecute() { try{String query="db.products.insert( { item: "card", qty: 15 } )"; MongoClient mongo = new MongoClient("localhost",27017); DB db = mongo.getDB("test"); DBCollection collection = db.getCollection(tablename); db.eval(query); } catch(UnknownHostException e){ System.out.println(e); } catch (MongoException.DuplicateKey e) { System.out.println("Exception Caught" + e); } }Recomiendo encarecidamente utilizar Mongo Spring Data. Usted puede hacer eso:
import com.mongodb.MongoClient; import com.mongodb.MongoException; import com.mongodb.WriteConcern; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.BasicDBObject; import com.mongodb.DBObject; import com.mongodb.DBCursor; import com.mongodb.ServerAddress; import java.util.Arrays; public class MongoDBCollection { public static void main(String args[]) { try { //Connect to Database MongoClient mongoClient = new MongoClient("localhost",27017); DB db = mongoClient.getDB("myDB"); System.out.println("Your connection to DB is ready for Use::"+db); //Create Collection DBCollection linked = db.createCollection("employ",new BasicDBObject()); System.out.println("Collection employ created successfully"); } catch(Exception e) { System.out.println(e.getClass().getName() + ": " + e.getMessage()); } } }