import org.noggit.CharArr; //导入依赖的package包/类
protected static String printClusterStateInfo(String collection) throws Exception {
  cloudSolrClient.getZkStateReader().updateClusterState();
  String cs = null;
  ClusterState clusterState = cloudSolrClient.getZkStateReader().getClusterState();
  if (collection != null) {
    cs = clusterState.getCollection(collection).toString();
  } else {
    Map<String, DocCollection> map = new HashMap<String, DocCollection>();
    for (String coll : clusterState.getCollections())
      map.put(coll, clusterState.getCollection(coll));
    CharArr out = new CharArr();
    new JSONWriter(out, 2).write(map);
    cs = out.toString();
  }
  return cs;
}
 

import org.noggit.CharArr; //导入依赖的package包/类
/** Creates a JSON add command from a SolrInputDocument list.  Doesn't currently handle boosts. */
public static String jsonAdd(SolrInputDocument... docs) {
  CharArr out = new CharArr();
  try {
    out.append('[');
    boolean firstField = true;
    for (SolrInputDocument doc : docs) {
      if (firstField) firstField=false;
      else out.append(',');
      out.append(json(doc));
    }
    out.append(']');
  } catch (IOException e) {
    // should never happen
  }
  return out.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
/** Creates a JSON delete command from an id list */
public static String jsonDelId(Object... ids) {
  CharArr out = new CharArr();
  try {
    out.append('{');
    boolean first = true;
    for (Object id : ids) {
      if (first) first=false;
      else out.append(',');
      out.append("\"delete\":{\"id\":");
      out.append(JSONUtil.toJSON(id));
      out.append('}');
    }
    out.append('}');
  } catch (IOException e) {
    // should never happen
  }
  return out.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
/** Creates a JSON deleteByQuery command */
public static String jsonDelQ(String... queries) {
  CharArr out = new CharArr();
  try {
    out.append('{');
    boolean first = true;
    for (Object q : queries) {
      if (first) first=false;
      else out.append(',');
      out.append("\"delete\":{\"query\":");
      out.append(JSONUtil.toJSON(q));
      out.append('}');
    }
    out.append('}');
  } catch (IOException e) {
    // should never happen
  }
  return out.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
protected String printClusterStateInfo(String collection) throws Exception {
  cloudClient.getZkStateReader().updateClusterState(true);
  String cs = null;
  ClusterState clusterState = cloudClient.getZkStateReader().getClusterState();
  if (collection != null) {
    cs = clusterState.getCollection(collection).toString();
  } else {
    Map<String,DocCollection> map = new HashMap<String,DocCollection>();
    for (String coll : clusterState.getCollections())
      map.put(coll, clusterState.getCollection(coll));
    CharArr out = new CharArr();
    new JSONWriter(out, 2).write(map);
    cs = out.toString();
  }
  return cs;
}
 

import org.noggit.CharArr; //导入依赖的package包/类
void writeError(int code, String msg) throws IOException {
  response.setStatus(code);

  CharArr chars = new CharArr();
  JSONWriter w = new JSONWriter(chars, 2);
  w.startObject();
  w.indent();
  w.writeString("status");
  w.writeNameSeparator();
  w.write(code);
  w.writeValueSeparator();
  w.indent();
  w.writeString("error");
  w.writeNameSeparator();
  w.writeString(msg);
  w.endObject();

  out.write(chars.toString());
}
 

import org.noggit.CharArr; //导入依赖的package包/类
protected static String printClusterStateInfo(String collection) throws Exception {
  cloudSolrClient.getZkStateReader().forceUpdateCollection(collection);
  String cs;
  ClusterState clusterState = cloudSolrClient.getZkStateReader().getClusterState();
  if (collection != null) {
    cs = clusterState.getCollection(collection).toString();
  } else {
    Map<String, DocCollection> map = clusterState.getCollectionsMap();
    CharArr out = new CharArr();
    new JSONWriter(out, 2).write(map);
    cs = out.toString();
  }
  return cs;
}
 

import org.noggit.CharArr; //导入依赖的package包/类
@Override
public String toJsonString() {
    CharArr charArr = new CharArr();
    JSONWriter jsonWriter = new JSONWriter(charArr, 2);

    jsonWriter.startObject();
    jsonWriter.indent();

    this.streamToJson(jsonWriter);

    jsonWriter.indent();
    jsonWriter.endObject();

    return charArr.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public static Object fromJSON(byte[] utf8) {
  // convert directly from bytes to chars
  // and parse directly from that instead of going through
  // intermediate strings or readers
  CharArr chars = new CharArr();
  ByteUtils.UTF8toUTF16(utf8, 0, utf8.length, chars);
  JSONParser parser = new JSONParser(chars.getArray(), chars.getStart(), chars.length());
  try {
    return ObjectBuilder.getVal(parser);
  } catch (IOException e) {
    throw new RuntimeException(e); // should never happen w/o using real IO
  }
}
 

import org.noggit.CharArr; //导入依赖的package包/类
/** Convert UTF8 bytes into UTF16 characters. */
public static void UTF8toUTF16(byte[] utf8, int offset, int len, CharArr out) {
  // TODO: do in chunks if the input is large
  out.reserve(len);
  int n = UTF8toUTF16(utf8, offset, len, out.getArray(), out.getEnd());
  out.setEnd(out.getEnd() + n);
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public static String toJSON(Doc doc) {
  CharArr out = new CharArr();
  try {
    out.append("{\"add\":{\"doc\":{");
    boolean firstField = true;
    for (Fld fld : doc.fields) {
      if (firstField) firstField=false;
      else out.append(',');
      JSONUtil.writeString(fld.ftype.fname, 0, fld.ftype.fname.length(), out);
      out.append(':');
      if (fld.vals.size() > 1) {
        out.append('[');
      }
      boolean firstVal = true;
      for (Comparable val : fld.vals) {
        if (firstVal) firstVal=false;
        else out.append(',');
        out.append(JSONUtil.toJSON(val));
      }
      if (fld.vals.size() > 1) {
        out.append(']');
      }
    }
    out.append("}}}");
  } catch (IOException e) {
    // should never happen
  }
  return out.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
@Override
public int runTool(CommandLine cli) throws Exception {
  String solrUrl = cli.getOptionValue("solr", DEFAULT_SOLR_URL);
  if (!solrUrl.endsWith("/"))
    solrUrl += "/";
  
  int exitCode = 0;
  String systemInfoUrl = solrUrl+"admin/info/system";
  HttpClient httpClient = getHttpClient();
  try {        
    // hit Solr to get system info
    Map<String,Object> systemInfo = getJson(httpClient, systemInfoUrl, 2);
    
    // convert raw JSON into user-friendly output
    Map<String,Object> status = 
        reportStatus(solrUrl, systemInfo, httpClient);
    
    // pretty-print the status to stdout
    CharArr arr = new CharArr();
    new JSONWriter(arr, 2).write(status);
    System.out.println(arr.toString());
    
  } catch (Exception exc) {
    if (checkCommunicationError(exc)) {
      // this is not actually an error from the tool as it's ok if Solr is not online.
      System.err.println("Solr at "+solrUrl+" not online.");
    } else {
      System.err.print("Failed to get system information from "+solrUrl+" due to: ");
      exc.printStackTrace(System.err);          
      exitCode = 1;
    }
  } finally {
    closeHttpClient(httpClient);        
  }
        
  return exitCode;
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public void log(
  String userName,
  String impersonator,
  String ipAddress,
  String operation,
  String operationParams,
  long eventTime,
  int allowed,
  String collectionName) {

  if (!isLogEnabled()) {
    return;
  }
  CharArr chars = new CharArr(512);
  JSONWriter writer = new JSONWriter(chars, -1);
  writer.startObject();
  writeField("solrVersion", SOLR_VERSION, writer);
  writer.writeValueSeparator();
  writeField("eventTime", eventTime, writer);
  writer.writeValueSeparator();
  writeField("allowed", allowed, writer);
  writer.writeValueSeparator();
  writeField("collectionName", collectionName, writer);
  writer.writeValueSeparator();
  writeField("operation", operation, writer);
  writer.writeValueSeparator();
  writeField("operationParams", operationParams, writer);
  writer.writeValueSeparator();
  writeField("ipAddress", ipAddress, writer);
  writer.writeValueSeparator();
  writeField("username", userName, writer);
  writer.writeValueSeparator();
  writeField("impersonator", impersonator, writer);
  writer.endObject();
  logger.info("{}", chars);
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public static byte[] toJSON(Object o) {
  CharArr out = new CharArr();
  new JSONWriter(out, 2).write(o); // indentation by default
  return toUTF8(out);
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public static byte[] toUTF8(CharArr out) {
  byte[] arr = new byte[out.size() << 2]; // is 4x the real worst-case upper-bound?
  int nBytes = ByteUtils.UTF16toUTF8(out, 0, out.size(), arr, 0);
  return Arrays.copyOf(arr, nBytes);
}
 

import org.noggit.CharArr; //导入依赖的package包/类
/** Creates JSON from a SolrInputDocument.  Doesn't currently handle boosts.
 *  @see #json(SolrInputDocument,CharArr)
 */
public static String json(SolrInputDocument doc) {
  CharArr out = new CharArr();
  json(doc, out);
  return out.toString();
}
 

import org.noggit.CharArr; //导入依赖的package包/类
void print(String path) throws IOException {
  if (zkClient == null) {
    return;
  }

  // normalize path
  if (path == null) {
    path = "/";
  } else {
    path = path.trim();
    if (path.length() == 0) {
      path = "/";
    }
  }

  if (path.endsWith("/") && path.length() > 1) {
    path = path.substring(0, path.length() - 1);
  }

  int idx = path.lastIndexOf('/');
  String parent = idx >= 0 ? path.substring(0, idx) : path;
  if (parent.length() == 0) {
    parent = "/";
  }

  CharArr chars = new CharArr();
  JSONWriter json = new JSONWriter(chars, 2);
  json.startObject();

  if (detail) {
    if (!printZnode(json, path)) {
      return;
    }
    json.writeValueSeparator();
  }

  json.writeString("tree");
  json.writeNameSeparator();
  json.startArray();
  if (!printTree(json, path)) {
    return; // there was an error
  }
  json.endArray();
  json.endObject();
  out.write(chars.toString());
}
 

import org.noggit.CharArr; //导入依赖的package包/类
public String toString() {      
  CharArr arr = new CharArr();
  new JSONWriter(arr, 2).write(asMap());
  return arr.toString();             
}