MongoDB中獲取的所有記錄的Java API

Question

我運行一個查詢來獲取所有記錄從MongoDB的特定集合，代碼 -

@WebMethod(operationName = "getAllWorkItem", action = "urn:GetWorkItem") 
@WebResult(name = "workItems") 
public List<WorkItem> getAllWorkItem() { 
    List<WorkItem> workItemList = new ArrayList<WorkItem>(); 

    WorkItem workItem; 
    AttachmentTransactions atr = new AttachmentTransactions(); 
    AuditInfoTransactions autr = new AuditInfoTransactions(); 
    // documentWItem.put("id", workItemId); 
    FindIterable<Document> item = transaction.getWorkItemCollection().find(); 

    for (Document document : item) { 
     workItem = new WorkItem(); 
     @SuppressWarnings("unchecked") 
     ArrayList<String> attchObjArr = (ArrayList<String>) document.get("attachmentId"); 
     workItem.setAttachment(atr.getAttachmentById("", attchObjArr.get(0))); 

     @SuppressWarnings("unchecked") 
     ArrayList<String> auditObjArr = (ArrayList<String>) document.get("auditInfoId"); 
     workItem.setAuditInfo(autr.getAuditInfoById("", auditObjArr.get(0))); 

     workItem.setEtc(document.getDate("etc")); 
     workItem.setExecutionUrl(document.getString("executionUrl")); 
     workItem.setId(document.get("_id").toString()); 
     workItem.setName(document.getString("name")); 
     workItem.setPriority(document.getString("priority")); 
     workItem.setProcessName(document.getString("processName")); 
     workItem.setStatus(document.getString("status")); 
     workItem.setType(document.getString("type")); 
     workItemList.add(workItem); 
    } 

    return workItemList; 
} 

但是我得到的錯誤，我不明白的是它由於超時或我執行API的方式問題？任何幫助或指針，將不勝感激。

Apr 18, 2016 1:31:56 PM org.apache.cxf.phase.PhaseInterceptorChain doDefaultLogging 
WARNING: Interceptor for {http://ws.ss.inct.com/}WorkItemFacadeService# {http://ws.ss.inct.com/}getAllWorkItem has thrown exception, unwinding now 
org.apache.cxf.interceptor.Fault: Could not send Message. 
at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:64) 
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263) 
at org.apache.cxf.interceptor.OutgoingChainInterceptor.handleMessage(OutgoingChainInterceptor.java:81) 
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263) 
at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121) 
at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:240) 
at org.apache.openejb.server.cxf.CxfWsContainer.onMessage(CxfWsContainer.java:89) 
at org.apache.openejb.server.webservices.WsServlet.service(WsServlet.java:98) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:303) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) 
at org.apache.tomee.webservices.CXFJAXRSFilter.doFilter(CXFJAXRSFilter.java:83) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) 
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) 
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:220) 
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:122) 
at org.apache.tomee.catalina.OpenEJBValve.invoke(OpenEJBValve.java:44) 
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:505) 
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:169) 
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103) 
at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:956) 
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:116) 
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:436) 
at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1078) 
at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:625) 
at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:316) 
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) 
at java.lang.Thread.run(Thread.java:745) 
Caused by: org.apache.catalina.connector.ClientAbortException: java.net.SocketException: Broken pipe 
at org.apache.catalina.connector.OutputBuffer.realWriteBytes(OutputBuffer.java:407) 
at org.apache.tomcat.util.buf.ByteChunk.flushBuffer(ByteChunk.java:480) 
at org.apache.catalina.connector.OutputBuffer.doFlush(OutputBuffer.java:356) 
at org.apache.catalina.connector.OutputBuffer.close(OutputBuffer.java:308) 
at org.apache.catalina.connector.CoyoteOutputStream.close(CoyoteOutputStream.java:108) 
at org.apache.cxf.transport.http.AbstractHTTPDestination$WrappedOutputStream.close(AbstractHTTPDestination.java:734) 
at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56) 
at org.apache.cxf.transport.http.AbstractHTTPDestination$BackChannelConduit.close(AbstractHTTPDestination.java:677) 
at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62) 
... 31 more 
Caused by: java.net.SocketException: Broken pipe 
at java.net.SocketOutputStream.socketWrite0(Native Method) 
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109) 
at java.net.SocketOutputStream.write(SocketOutputStream.java:153) 
at org.apache.coyote.http11.InternalOutputBuffer.realWriteBytes(InternalOutputBuffer.java:215) 
at org.apache.tomcat.util.buf.ByteChunk.flushBuffer(ByteChunk.java:480) 
at org.apache.tomcat.util.buf.ByteChunk.append(ByteChunk.java:366) 
at org.apache.coyote.http11.InternalOutputBuffer$OutputStreamOutputBuffer.doWrite(InternalOutputBuffer.java:240) 
at org.apache.coyote.http11.filters.ChunkedOutputFilter.doWrite(ChunkedOutputFilter.java:119) 
at org.apache.coyote.http11.AbstractOutputBuffer.doWrite(AbstractOutputBuffer.java:192) 
at org.apache.coyote.Response.doWrite(Response.java:499) 
at org.apache.catalina.connector.OutputBuffer.realWriteBytes(OutputBuffer.java:402) 
... 39 more 

Answer 1

Another Way to to connect mongo db using java 


    public static void main(String[] args) { 

     Mongo mongo = new Mongo("localhost", 27017); 
     DB db = mongo.getDB("mydb");// db name 


     DBCollection collection = db.getCollection("test"); 
      BasicDBObject query = new BasicDBObject(); 
      BasicDBObject rmfld = new BasicDBObject(); 
     JSONArray jrr=new JSONArray(); 
     JSONObject jobj=new JSONObject(); 
     // query.put("name", "test"); 
      rmfld.put("_id", 0); 

      try{ 
      DBCursor openCur = collection.find(query,rmfld); 

      while (openCur.hasNext()) { 
       jrr.put(openCur.next()); 
      } 
      if(openCur!=null) 
      { 
       openCur.close(); 
      } 
      System.out.println(jrr); 
      } 
      catch (Exception e) { 
       // TODO: handle exception 
      } 

    }