2017-03-03 16 views
0

並べ替えられていない一括挿入をしようとしていますが、書き込みエラーが発生していて、同じ単一の挿入が機能しています。ここサーバIPでのバルク書き込み操作エラー:27017。書き込みエラー:[[email protected]]

final DBCollection col = db.getCollection(STUDENT); 
    BulkWriteOperation bulkop = col.initializeUnorderedBulkOperation(); 

    for(){ 
    //putting values in doc 
    DBObject doc = new BasicDBObject(); 
    // 
    bulkop.insert(doc); 
    } 
     bulkop.execute(WriteConcern.FSYNCED); 

はログです:

Bulk write operation error on server IP:27017. Write errors: [[email protected]]. 
com.mongodb.BulkWriteException: Bulk write operation error on server 192.168.50.166:27017. Write errors: [[email protected]]. 
at com.mongodb.BulkWriteHelper.translateBulkWriteException(BulkWriteHelper.java:57) 
at com.mongodb.DBCollection.executeBulkWriteOperation(DBCollection.java:2202) 
at com.mongodb.DBCollection.executeBulkWriteOperation(DBCollection.java:2188) 
at com.mongodb.BulkWriteOperation.execute(BulkWriteOperation.java:121) 

私はモンゴ3.0.4 Javaのドライバを使用しています。上記のMongoDB-のJava 3.0.1およびについては

答えて

0

、あなたはこのロジックを使用することができ、

 MongoClient mongoClient = new MongoClient("localhost",27017); 
     MongoDatabase database = mongoClient.getDatabase("testDB"); 

     MongoCollection<Document> collection = database.getCollection("testColl").withWriteConcern(WriteConcern.FSYNCED); 
     BulkWriteOptions options = new BulkWriteOptions(); 
     options.ordered(false); 

     ArrayList<InsertOneModel<Document>> insertList = new ArrayList<InsertOneModel<Document>>(); 
     for(int i =0; i<1000;i++){ 
      Document document= new Document().append("_id",i).append("testdat", "testvalue");; 

      insertList.add(new InsertOneModel<Document>(document)); 
     } 

     collection.bulkWrite(insertList, options); 
関連する問題