不使用schema.xml将mongo动态数据添加到solr中

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.apache.solr.client.solrj.request.UpdateRequest;
import org.apache.solr.common.SolrInputDocument;
import org.bson.Document;

public class MongoToSolr {
    public static void main(String[] args) {
        // 连接MongoDB
        MongoClient mongoClient = new MongoClient("localhost", 27017);
        MongoDatabase database = mongoClient.getDatabase("mydb");
        MongoCollection<Document> collection = database.getCollection("mycollection");

        // 连接Solr
        String solrUrl = "http://localhost:8983/solr/mycore";
        SolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();

        // 从MongoDB中获取数据
        MongoCursor<Document> cursor = collection.find().iterator();
        while (cursor.hasNext()) {
            Document doc = cursor.next();

            // 创建Solr文档
            SolrInputDocument solrDoc = new SolrInputDocument();
            solrDoc.addField("id", doc.get("_id").toString());
            solrDoc.addField("title", doc.get("title").toString());
            solrDoc.addField("content", doc.get("content").toString());

            // 将Solr文档添加到Solr索引中
            try {
                UpdateRequest updateRequest = new UpdateRequest();
                updateRequest.add(solrDoc);
                updateRequest.setAction(UpdateRequest.ACTION.COMMIT, false, false);
                updateRequest.process(solrClient);
            } catch (SolrServerException | IOException e) {
                e.printStackTrace();
            }
        }

        // 关闭连接
        cursor.close();
        mongoClient.close();
        solrClient.close();
    }
}