使用Java将JSON文档数组插入到MongoDB时出错

Question

我试图插入包含文档数组但是获得以下异常的json字符串。

MongoDB的服务器版本：3.0.6

蒙戈-Java驱动程序版本：3.1.0

我明白insertOne()方法用于只插入一个文档，但在这里它的文档的数组。我不知道如何在这里使用insertMany()方法。

请指导。

JSON字符串，我想插入：

json = [{"freightCompanyId":201,"name":"USPS","price":8.00},{"freightCompanyId":202,"name":"FedEx","price":10.00},{"freightCompanyId":203,"name":"UPS","price":12.00},{"freightCompanyId":204,"name":"Other","price":15.00}] 

异常日志：

Exception in thread "main" org.bson.BsonInvalidOperationException: readStartDocument can only be called when CurrentBSONType is DOCUMENT, not when CurrentBSONType is ARRAY. 
    at org.bson.AbstractBsonReader.verifyBSONType(AbstractBsonReader.java:655) 
    at org.bson.AbstractBsonReader.checkPreconditions(AbstractBsonReader.java:687) 
    at org.bson.AbstractBsonReader.readStartDocument(AbstractBsonReader.java:421) 
    at org.bson.codecs.DocumentCodec.decode(DocumentCodec.java:138) 
    at org.bson.codecs.DocumentCodec.decode(DocumentCodec.java:45) 
    at org.bson.Document.parse(Document.java:105) 
    at org.bson.Document.parse(Document.java:90) 
    at com.ebayenterprise.ecp.jobs.Main.insert(Main.java:52) 
    at com.ebayenterprise.ecp.jobs.Main.main(Main.java:31) 

Main.java

public class Main { 

    private static final Logger LOG = Logger.getLogger(Main.class); 

    public static void main(String[] args) throws IOException { 
     String json = getAllFreightCompanies(); 
     insert(json); 
    } 

    private static String getAllFreightCompanies() throws IOException { 
     FreightCompanyDao freightCompanyDao = new FreightCompanyDaoImpl(DataSourceFactory.getDataSource(DatabaseType.POSTGRES.name())); 
     List<FreightCompany> freightCompanies = freightCompanyDao.getAllFreightCompanies(); 
     return GenericUtils.toJson(freightCompanies); 
    } 

    private static void insert(String json) { 
     MongoClient mongoClient = new MongoClient("GSI-547576", 27017); 
     MongoDatabase database = mongoClient.getDatabase("test"); 
     MongoCollection<Document> table = database.getCollection("fc"); 
     Document document = Document.parse(json); 
     table.insertOne(document); 
    } 

} 

GenericUtils.java

public final class GenericUtils { 

    private static final Logger LOG = Logger.getLogger(GenericUtils.class); 

    private GenericUtils() { 
    } 

    public static String toJson(List<FreightCompany> freightCompanies) throws IOException { 
     String json = new ObjectMapper().writer().writeValueAsString(freightCompanies); 
     LOG.debug("json = " + json); 
     return json; 
    } 

} 

的pom.xml

<dependency> 
    <groupId>org.mongodb</groupId> 
    <artifactId>mongo-java-driver</artifactId> 
    <version>3.1.0</version> 
    <type>jar</type> 
</dependency> 
<dependency> 
    <groupId>org.codehaus.jackson</groupId> 
    <artifactId>jackson-mapper-asl</artifactId> 
    <version>1.9.13</version> 
</dependency> 

Answer 1

您应该插入一个接一个，或创建一个文件列表，并使用insertMany（）

下面是一个例子：

MongoClient mongoClient = new MongoClient("GSI-547576", 27017); 
MongoDatabase database = mongoClient.getDatabase("test"); 
MongoCollection <Document> table = database.getCollection("fc"); 
FreightCompanyDao freightCompanyDao = new FreightCompanyDaoImpl(DataSourceFactory.getDataSource(DatabaseType.POSTGRES.name())); 
List <FreightCompany> freightCompanies = freightCompanyDao.getAllFreightCompanies(); 

for (FreightCompany company: freighetCompanies) { 
    Document doc = Document.parse(GenericUtils.toJson(company)) 
    collection.insertOne(doc) 
}