import org.apache.solr.client.solrj.request.schema.SchemaRequest; //导入依赖的package包/类
public void addField(String name, String type, boolean multivalue)  throws IOException, SolrServerException {
    String mappedType = dataTypeMapping.get(type);
    if(mappedType == null) {
        mappedType = type;
    }

    Map<String, Object> fieldAttributes = new HashMap();
    fieldAttributes.put("name", name);
    fieldAttributes.put("type", mappedType);
    fieldAttributes.put("stored", true);
    fieldAttributes.put("indexed", true);
    fieldAttributes.put("multiValued", multivalue);
    fieldAttributes.put("required", false);

    SchemaRequest.AddField schemaRequest = new SchemaRequest.AddField(fieldAttributes);
    SchemaResponse.UpdateResponse response =  schemaRequest.process(solrClient);
}
 

import org.apache.solr.client.solrj.request.schema.SchemaRequest; //导入依赖的package包/类
public List<String> getAllFields() throws IOException, SolrServerException {
    List<String> allFields = new ArrayList<String>();
    SchemaRequest.Fields listFields = new SchemaRequest.Fields();
    SchemaResponse.FieldsResponse fieldsResponse = listFields.process(solrClient);
    List<Map<String,Object>> solrFields = fieldsResponse.getFields();
    for(Map<String,Object> field : solrFields) {
        allFields.add((String) field.get("name"));
    }
    return allFields;
}
 

import org.apache.solr.client.solrj.request.schema.SchemaRequest; //导入依赖的package包/类
@Override
public boolean start() throws IOException {
  if (source.replica != null) {
    solrClient =
        source.spec.getConnectionConfiguration().createClient(source.replica.baseUrl());
  } else {
    solrClient = source.spec.getConnectionConfiguration().createClient();
  }
  SchemaRequest.UniqueKey uniqueKeyRequest = new SchemaRequest.UniqueKey();
  try {
    String collection = source.spec.getCollection();
    SchemaResponse.UniqueKeyResponse uniqueKeyResponse =
        (SchemaResponse.UniqueKeyResponse) solrClient.process(collection, uniqueKeyRequest);
    uniqueKey = uniqueKeyResponse.getUniqueKey();
  } catch (SolrServerException e) {
    throw new IOException("Can not get unique key from solr", e);
  }
  return advance();
}
 

import org.apache.solr.client.solrj.request.schema.SchemaRequest; //导入依赖的package包/类
public void deleteField(String name) throws IOException, SolrServerException {
    if(fieldBlackList.contains(name)) {
        return;
    }
    SchemaRequest.DeleteField deleteFieldRequest = new SchemaRequest.DeleteField(name);
    SchemaResponse.UpdateResponse deleteFieldResponse = deleteFieldRequest.process(solrClient);


}
 

import org.apache.solr.client.solrj.request.schema.SchemaRequest; //导入依赖的package包/类
/**
 * Get unique key field from the remote Solr server.
 * 
 * @param cached
 *            If false, the value will be retrieved from Solr. If true, the
 *            value may be retrieved from a local cache.
 * @return Unique key field name.
 * @throws SophieException
 *             If the unique key field cannot be fetched.
 */
public static String getRemoteUniqueField(boolean cached) throws SophieException {
    // If cache is empty, or if client method explicitely wants uncached
    // value, then warm the cache.
    if (!cached || !StringUtils.isNoneEmpty(cachedUniqueField)) {
        SchemaRequest.UniqueKey request = new SchemaRequest.UniqueKey();
        try {
            cachedUniqueField = request.process(Sophie.client).getUniqueKey();
        } catch (SolrServerException | IOException | SolrException e) {
            throw new SophieException("Unable to fetch name of unique field", e);
        }
    }
    // Return cache.
    return cachedUniqueField;
}