import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
static Map<String, String[]> toMultiMap(ModifiableSolrParams solrQueryParameter) {
    NamedList<Object> namedList = solrQueryParameter.toNamedList();
    //disabled for MCR-953 and https://issues.apache.org/jira/browse/SOLR-7508
    //Map<String, String[]> parameters = ModifiableSolrParams.toMultiMap(namedList);
    HashMap<String, String[]> parameters = new HashMap<>();
    for (int i = 0; i < namedList.size(); i++) {
        String name = namedList.getName(i);
        Object val = namedList.getVal(i);
        if (val instanceof String[]) {
            MultiMapSolrParams.addParam(name, (String[]) val, parameters);
        } else {
            MultiMapSolrParams.addParam(name, val.toString(), parameters);
        }
    }
    //end of fix
    return parameters;
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
static void addDoc(String doc, String chain) throws Exception {
  Map<String, String[]> params = new HashMap<>();
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { chain });
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(),
      (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
  req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
private void addDoc(String doc) throws Exception {
  Map<String, String[]> params = new HashMap<>();
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { "uniq-fields" });
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(),
      (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
  req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
static void addDoc(String doc, String chain) throws Exception {
  Map<String, String[]> params = new HashMap<String, String[]>();
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { chain });
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(),
      (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<ContentStream>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
  req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
private void addDoc(String doc) throws Exception {
  Map<String, String[]> params = new HashMap<String, String[]>();
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { "uniq-fields" });
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(),
      (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<ContentStream>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
  req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
private void addDoc(String chain, String doc) throws Exception {
  Map<String, String[]> params = new HashMap<>();
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { chain });
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(), (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
protected static SolrParams makeParams(String query, String qtype, int start, int limit, Map args) {
  Map<String,String[]> map = new HashMap<>();
  for (Iterator iter = args.entrySet().iterator(); iter.hasNext();) {
    Map.Entry e = (Map.Entry)iter.next();
    String k = e.getKey().toString();
    Object v = e.getValue();
    if (v instanceof String[]) map.put(k,(String[])v);
    else map.put(k,new String[]{v.toString()});
  }
  if (query!=null) map.put(CommonParams.Q, new String[]{query});
  if (qtype!=null) map.put(CommonParams.QT, new String[]{qtype});
  map.put(CommonParams.START, new String[]{Integer.toString(start)});
  map.put(CommonParams.ROWS, new String[]{Integer.toString(limit)});
  return new MultiMapSolrParams(map);
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
private static void decodeBuffer(final LinkedList<Object> input, final Map<String,String[]> map, CharsetDecoder charsetDecoder) {
  for (final Iterator<Object> it = input.iterator(); it.hasNext(); ) {
    final byte[] keyBytes = (byte[]) it.next();
    it.remove();
    final Long keyPos = (Long) it.next();
    it.remove();
    final byte[] valueBytes = (byte[]) it.next();
    it.remove();
    final Long valuePos = (Long) it.next();
    it.remove();
    MultiMapSolrParams.addParam(decodeChars(keyBytes, keyPos.longValue(), charsetDecoder),
        decodeChars(valueBytes, valuePos.longValue(), charsetDecoder), map);
  }
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
@Override
public SolrParams parseParamsAndFillStreams( 
    final HttpServletRequest req, ArrayList<ContentStream> streams ) throws Exception
{
  if( !ServletFileUpload.isMultipartContent(req) ) {
    throw new SolrException( ErrorCode.BAD_REQUEST, "Not multipart content! "+req.getContentType() );
  }
  
  MultiMapSolrParams params = parseQueryString( req.getQueryString() );
  
  // Create a factory for disk-based file items
  DiskFileItemFactory factory = new DiskFileItemFactory();

  // Set factory constraints
  // TODO - configure factory.setSizeThreshold(yourMaxMemorySize);
  // TODO - configure factory.setRepository(yourTempDirectory);

  // Create a new file upload handler
  ServletFileUpload upload = new ServletFileUpload(factory);
  upload.setSizeMax( ((long) uploadLimitKB) * 1024L );

  // Parse the request
  List items = upload.parseRequest(req);
  Iterator iter = items.iterator();
  while (iter.hasNext()) {
      FileItem item = (FileItem) iter.next();

      // If its a form field, put it in our parameter map
      if (item.isFormField()) {
        MultiMapSolrParams.addParam( 
          item.getFieldName(), 
          item.getString(), params.getMap() );
      }
      // Add the stream
      else { 
        streams.add( new FileItemContentStream( item ) );
      }
  }
  return params;
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
/**
 * Expands aliases into queries for thematic collections.
 * 
 * Operates by taking apart the passed request, scanning it for thematic-collection keywords,
 * and replacing those it finds with the appropriate expanded query.
 * 
 * @author thill
 * @version 2017.11.14
 */

@Override
public void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp)
    throws Exception {
  
  AliasConfig aliasConfig = req.getCore().getAliasConfig();
  HashMap<String, HashMap<String, String>> aliases = aliasConfig.getAliases();
  SolrParams params = req.getParams();
  Iterator<String> pnit = params.getParameterNamesIterator();
  Map<String, String[]> modifiedParams = new HashMap<String, String[]>();
  String paramnames = "";
  while(pnit.hasNext()) {
    
    String pname = pnit.next();
    paramnames += pname + " ";
    String[] pvalues = params.getParams(pname);
    if(!pname.equals("q") && !pname.equals("fq")) {
      
      modifiedParams.put(pname, pvalues);
      
    }
    else {
      String[] modifiedValues = this.modifyValues(aliases, pvalues);
      modifiedParams.put(pname, modifiedValues);
    
    }
    
  }
  MultiMapSolrParams newParams = new MultiMapSolrParams(modifiedParams);
  req.setParams(newParams);
  // a little debugging check
  //String paramCheck = outputParams(newParams);
  // rsp.add("test", paramCheck);
  super.handleRequestBody(req, rsp);
  
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
private void addDoc(String chain, String doc) throws Exception {
  Map<String, String[]> params = new HashMap<String, String[]>();
  params.put(UpdateParams.UPDATE_CHAIN, new String[] { chain });
  MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
  SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(), (SolrParams) mmparams) {
  };

  UpdateRequestHandler handler = new UpdateRequestHandler();
  handler.init(null);
  ArrayList<ContentStream> streams = new ArrayList<ContentStream>(2);
  streams.add(new ContentStreamBase.StringStream(doc));
  req.setContentStreams(streams);
  handler.handleRequestBody(req, new SolrQueryResponse());
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
protected static SolrParams makeParams(String query, String qtype, int start, int limit, Map args) {
  Map<String,String[]> map = new HashMap<String,String[]>();
  for (Iterator iter = args.entrySet().iterator(); iter.hasNext();) {
    Map.Entry e = (Map.Entry)iter.next();
    String k = e.getKey().toString();
    Object v = e.getValue();
    if (v instanceof String[]) map.put(k,(String[])v);
    else map.put(k,new String[]{v.toString()});
  }
  if (query!=null) map.put(CommonParams.Q, new String[]{query});
  if (qtype!=null) map.put(CommonParams.QT, new String[]{qtype});
  map.put(CommonParams.START, new String[]{Integer.toString(start)});
  map.put(CommonParams.ROWS, new String[]{Integer.toString(limit)});
  return new MultiMapSolrParams(map);
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
@Override
public SolrParams parseParamsAndFillStreams( 
    final HttpServletRequest req, ArrayList<ContentStream> streams ) throws Exception
{
  if( !ServletFileUpload.isMultipartContent(req) ) {
    throw new SolrException( SolrException.ErrorCode.BAD_REQUEST, "Not multipart content! "+req.getContentType() );
  }
  
  MultiMapSolrParams params = SolrRequestParsers.parseQueryString( req.getQueryString() );
  
  // Create a factory for disk-based file items
  DiskFileItemFactory factory = new DiskFileItemFactory();

  // Set factory constraints
  // TODO - configure factory.setSizeThreshold(yourMaxMemorySize);
  // TODO - configure factory.setRepository(yourTempDirectory);

  // Create a new file upload handler
  ServletFileUpload upload = new ServletFileUpload(factory);
  upload.setSizeMax( ((long) uploadLimitKB) * 1024L );

  // Parse the request
  List items = upload.parseRequest(req);
  Iterator iter = items.iterator();
  while (iter.hasNext()) {
      FileItem item = (FileItem) iter.next();

      // If its a form field, put it in our parameter map
      if (item.isFormField()) {
        MultiMapSolrParams.addParam( 
          item.getFieldName(), 
          item.getString(), params.getMap() );
      }
      // Add the stream
      else { 
        streams.add( new FileItemContentStream( item ) );
      }
  }
  return params;
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
static void addDoc(String doc, String chain) throws Exception {
	Map<String, String[]> params = new HashMap<>();
	MultiMapSolrParams mmparams = new MultiMapSolrParams(params);
	params.put(UpdateParams.UPDATE_CHAIN, new String[] { chain });
	SolrQueryRequestBase req = new SolrQueryRequestBase(h.getCore(), mmparams) {
	};

	UpdateRequestHandler handler = new UpdateRequestHandler();
	handler.init(null);
	ArrayList<ContentStream> streams = new ArrayList<>(2);
	streams.add(new ContentStreamBase.StringStream(doc));
	req.setContentStreams(streams);
	handler.handleRequestBody(req, new SolrQueryResponse());
	req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
/**
 * Insures that the given param is included in the query with the given value.
 *
 * <ol>
 *   <li>If the param is already included with the given value, the request is returned unchanged.</li>
 *   <li>If the param is not already included, it is added with the given value.</li>
 *   <li>If the param is already included, but with a different value, the value is replaced with the given value.</li>
 *   <li>If the param is already included multiple times, they are replaced with a single param with given value.</li>
 * </ol>
 *
 * The passed-in valueToSet should NOT be URL encoded, as it will be URL encoded by this method.
 *
 * @param query The query portion of a request URL, e.g. "wt=json&indent=on&fl=id,_version_"
 * @param paramToSet The parameter name to insure the presence of in the returned request 
 * @param valueToSet The parameter value to insure in the returned request
 * @return The query with the given param set to the given value 
 */
private static String setParam(String query, String paramToSet, String valueToSet) {
  if (null == valueToSet) {
    valueToSet = "";
  }
  try {
    StringBuilder builder = new StringBuilder();
    if (null == query || query.trim().isEmpty()) {
      // empty query -> return "paramToSet=valueToSet"
      builder.append(paramToSet);
      builder.append('=');
      StrUtils.partialURLEncodeVal(builder, valueToSet);
      return builder.toString();
    }
    MultiMapSolrParams requestParams = SolrRequestParsers.parseQueryString(query);
    String[] values = requestParams.getParams(paramToSet);
    if (null == values) {
      // paramToSet isn't present in the request -> append "&paramToSet=valueToSet"
      builder.append(query);
      builder.append('&');
      builder.append(paramToSet);
      builder.append('=');
      StrUtils.partialURLEncodeVal(builder, valueToSet);
      return builder.toString();
    }
    if (1 == values.length && valueToSet.equals(values[0])) {
      // paramToSet=valueToSet is already in the query - just return the query as-is.
      return query;
    }
    // More than one value for paramToSet on the request, or paramToSet's value is not valueToSet
    // -> rebuild the query
    boolean isFirst = true;
    for (Map.Entry<String,String[]> entry : requestParams.getMap().entrySet()) {
      String key = entry.getKey();
      String[] valarr = entry.getValue();

      if ( ! key.equals(paramToSet)) {
        for (String val : valarr) {
          builder.append(isFirst ? "" : '&');
          isFirst = false;
          builder.append(key);
          builder.append('=');
          StrUtils.partialURLEncodeVal(builder, null == val ? "" : val);
        }
      }
    }
    builder.append(isFirst ? "" : '&');
    builder.append(paramToSet);
    builder.append('=');
    StrUtils.partialURLEncodeVal(builder, valueToSet);
    return builder.toString();
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
public LocalSolrQueryRequest(SolrCore core, Map<String,String[]> args) {
  super(core, new MultiMapSolrParams(args));
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
/**
 * Given a url-encoded query string (UTF-8), map it into solr params
 */
public static MultiMapSolrParams parseQueryString(String queryString) {
  Map<String,String[]> map = new HashMap<>();
  parseQueryString(queryString, map);
  return new MultiMapSolrParams(map);
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
@Test
public void testStreamBody() throws Exception
{
  String body1 = "AMANAPLANPANAMA";
  String body2 = "qwertasdfgzxcvb";
  String body3 = "1234567890";
  
  SolrCore core = h.getCore();
  
  Map<String,String[]> args = new HashMap<>();
  args.put( CommonParams.STREAM_BODY, new String[] {body1} );
  
  // Make sure it got a single stream in and out ok
  List<ContentStream> streams = new ArrayList<>();
  SolrQueryRequest req = parser.buildRequestFrom( core, new MultiMapSolrParams( args ), streams );
  assertEquals( 1, streams.size() );
  assertEquals( body1, IOUtils.toString( streams.get(0).getReader() ) );
  req.close();

  // Now add three and make sure they come out ok
  streams = new ArrayList<>();
  args.put( CommonParams.STREAM_BODY, new String[] {body1,body2,body3} );
  req = parser.buildRequestFrom( core, new MultiMapSolrParams( args ), streams );
  assertEquals( 3, streams.size() );
  ArrayList<String> input  = new ArrayList<>();
  ArrayList<String> output = new ArrayList<>();
  input.add( body1 );
  input.add( body2 );
  input.add( body3 );
  output.add( IOUtils.toString( streams.get(0).getReader() ) );
  output.add( IOUtils.toString( streams.get(1).getReader() ) );
  output.add( IOUtils.toString( streams.get(2).getReader() ) );
  // sort them so the output is consistent
  Collections.sort( input );
  Collections.sort( output );
  assertEquals( input.toString(), output.toString() );
  req.close();

  // set the contentType and make sure tat gets set
  String ctype = "text/xxx";
  streams = new ArrayList<>();
  args.put( CommonParams.STREAM_CONTENTTYPE, new String[] {ctype} );
  req = parser.buildRequestFrom( core, new MultiMapSolrParams( args ), streams );
  for( ContentStream s : streams ) {
    assertEquals( ctype, s.getContentType() );
  }
  req.close();
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
public SolrServletRequest(SolrCore core, HttpServletRequest req)
{
    super(core, new MultiMapSolrParams(Collections.<String, String[]> emptyMap()));
}
 

import org.apache.solr.common.params.MultiMapSolrParams; //导入依赖的package包/类
/**
 * Given a url-encoded query string (UTF-8), map it into solr params
 */
public static MultiMapSolrParams parseQueryString(String queryString) {
  Map<String,String[]> map = new HashMap<String, String[]>();
  parseQueryString(queryString, map);
  return new MultiMapSolrParams(map);
}