dariah / mtas

MtasSolrComponentJoin.java.html 10.2 KB
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 
<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"><html xmlns="http://www.w3.org/1999/xhtml" lang="en"><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8"/><link rel="stylesheet" href="../jacoco-resources/report.css" type="text/css"/><link rel="shortcut icon" href="../jacoco-resources/report.gif" type="image/gif"/><title>MtasSolrComponentJoin.java</title><link rel="stylesheet" href="../jacoco-resources/prettify.css" type="text/css"/><script type="text/javascript" src="../jacoco-resources/prettify.js"></script></head><body onload="window['PR_TAB_WIDTH']=4;prettyPrint()"><div class="breadcrumb" id="breadcrumb"><span class="info"><a href="../jacoco-sessions.html" class="el_session">Sessions</a></span><a href="../index.html" class="el_report">MTAS</a> &gt; <a href="index.source.html" class="el_package">mtas.solr.handler.component.util</a> &gt; <span class="el_source">MtasSolrComponentJoin.java</span></div><h1>MtasSolrComponentJoin.java</h1><pre class="source lang-java linenums">package mtas.solr.handler.component.util;

import java.io.IOException;
import java.util.Arrays;
import java.util.HashSet;
import java.util.Set;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.solr.common.util.NamedList;
import org.apache.solr.common.util.SimpleOrderedMap;
import org.apache.solr.handler.component.ResponseBuilder;
import org.apache.solr.handler.component.SearchComponent;
import org.apache.solr.handler.component.ShardRequest;
import org.apache.solr.handler.component.ShardResponse;

import mtas.codec.util.CodecComponent.ComponentFields;
import mtas.codec.util.CodecComponent.ComponentJoin;
import mtas.solr.handler.component.MtasSolrSearchComponent;

/**
 * The Class MtasSolrComponentJoin.
 */
@SuppressWarnings(&quot;deprecation&quot;)
public class MtasSolrComponentJoin implements MtasSolrComponent&lt;ComponentJoin&gt; {

  /** The Constant log. */
<span class="fc" id="L28">  private static final Log log = LogFactory.getLog(MtasSolrComponentJoin.class);</span>

  /** The Constant PARAM_MTAS_JOIN. */
  public static final String PARAM_MTAS_JOIN = MtasSolrSearchComponent.PARAM_MTAS
      + &quot;.join&quot;;

  /** The Constant NAME_MTAS_JOIN_FIELD. */
  public static final String NAME_MTAS_JOIN_FIELD = &quot;field&quot;;

  /**
   * Instantiates a new mtas solr component join.
   *
   * @param searchComponent the search component
   */
<span class="fc" id="L42">  public MtasSolrComponentJoin(MtasSolrSearchComponent searchComponent) {</span>
<span class="fc" id="L43">  }</span>

  /* (non-Javadoc)
   * @see mtas.solr.handler.component.util.MtasSolrComponent#prepare(org.apache.solr.handler.component.ResponseBuilder, mtas.codec.util.CodecComponent.ComponentFields)
   */
  public void prepare(ResponseBuilder rb, ComponentFields mtasFields)
      throws IOException {
<span class="nc bnc" id="L50" title="All 2 branches missed.">    if (rb.req.getParams().get(PARAM_MTAS_JOIN + &quot;.&quot; + NAME_MTAS_JOIN_FIELD,</span>
        null) != null) {
<span class="nc" id="L52">      Set&lt;String&gt; fields = new HashSet&lt;&gt;(Arrays.asList(rb.req.getParams()</span>
<span class="nc" id="L53">          .get(PARAM_MTAS_JOIN + &quot;.&quot; + NAME_MTAS_JOIN_FIELD).split(&quot;,&quot;)));</span>
<span class="nc" id="L54">      String key = createKeyFromRequest(rb);</span>
<span class="nc" id="L55">      mtasFields.doJoin = true;</span>
<span class="nc" id="L56">      mtasFields.join = new ComponentJoin(fields, key);</span>
<span class="nc" id="L57">      rb.setNeedDocSet(true);</span>
    }

<span class="nc" id="L60">  }</span>

  /* (non-Javadoc)
   * @see mtas.solr.handler.component.util.MtasSolrComponent#modifyRequest(org.apache.solr.handler.component.ResponseBuilder, org.apache.solr.handler.component.SearchComponent, org.apache.solr.handler.component.ShardRequest)
   */
  public void modifyRequest(ResponseBuilder rb, SearchComponent who,
      ShardRequest sreq) {
<span class="nc bnc" id="L67" title="All 2 branches missed.">    if (sreq.params.getBool(MtasSolrSearchComponent.PARAM_MTAS, false)</span>
<span class="nc bnc" id="L68" title="All 2 branches missed.">        &amp;&amp; sreq.params.getBool(PARAM_MTAS_JOIN, false)) {</span>
<span class="nc bnc" id="L69" title="All 2 branches missed.">      if ((sreq.purpose &amp; ShardRequest.PURPOSE_GET_TOP_IDS) != 0) {</span>
        // do nothing
      } else {
        // remove for other requests
<span class="nc" id="L73">        Set&lt;String&gt; keys = MtasSolrResultUtil</span>
<span class="nc" id="L74">            .getIdsFromParameters(rb.req.getParams(), PARAM_MTAS_JOIN);</span>
<span class="nc" id="L75">        sreq.params.remove(PARAM_MTAS_JOIN);</span>
<span class="nc bnc" id="L76" title="All 2 branches missed.">        for (String key : keys) {</span>
<span class="nc" id="L77">          sreq.params.remove(PARAM_MTAS_JOIN + &quot;.&quot; + key);</span>
<span class="nc" id="L78">        }</span>
      }
    }
<span class="nc" id="L81">  }</span>

  /* (non-Javadoc)
   * @see mtas.solr.handler.component.util.MtasSolrComponent#create(mtas.codec.util.CodecComponent.BasicComponent, java.lang.Boolean)
   */
  public SimpleOrderedMap&lt;Object&gt; create(ComponentJoin join, Boolean encode) throws IOException {
<span class="nc" id="L87">    MtasSolrJoinResult data = new MtasSolrJoinResult(join);</span>
<span class="nc" id="L88">    SimpleOrderedMap&lt;Object&gt; mtasJoinResponse = new SimpleOrderedMap&lt;&gt;();</span>
<span class="nc bnc" id="L89" title="All 2 branches missed.">    if (encode) {</span>
<span class="nc" id="L90">      mtasJoinResponse.add(&quot;_encoded_data&quot;, MtasSolrResultUtil.encode(data));</span>
    } else {
<span class="nc" id="L92">      mtasJoinResponse.add(&quot;data&quot;, data.rewrite());</span>
    }
<span class="nc" id="L94">    return mtasJoinResponse;</span>
  }

  /* (non-Javadoc)
   * @see mtas.solr.handler.component.util.MtasSolrComponent#finishStage(org.apache.solr.handler.component.ResponseBuilder)
   */
  @SuppressWarnings(&quot;unchecked&quot;)
  public void finishStage(ResponseBuilder rb) {
<span class="nc bnc" id="L102" title="All 4 branches missed.">    if (rb.req.getParams().getBool(MtasSolrSearchComponent.PARAM_MTAS, false)</span>
        &amp;&amp; rb.stage == MtasSolrSearchComponent.STAGE_JOIN) {
<span class="nc bnc" id="L104" title="All 2 branches missed.">      for (ShardRequest sreq : rb.finished) {</span>
<span class="nc bnc" id="L105" title="All 2 branches missed.">        if (sreq.params.getBool(MtasSolrSearchComponent.PARAM_MTAS, false)</span>
<span class="nc bnc" id="L106" title="All 2 branches missed.">            &amp;&amp; sreq.params.getBool(PARAM_MTAS_JOIN, false)) {</span>
<span class="nc bnc" id="L107" title="All 2 branches missed.">          for (ShardResponse shardResponse : sreq.responses) {</span>
<span class="nc" id="L108">            NamedList&lt;Object&gt; response = shardResponse.getSolrResponse()</span>
<span class="nc" id="L109">                .getResponse();</span>
            try {
<span class="nc" id="L111">              Object data = response.findRecursive(&quot;mtas&quot;, &quot;join&quot;);</span>
<span class="nc bnc" id="L112" title="All 4 branches missed.">              if (data != null &amp;&amp; data instanceof String) {</span>
<span class="nc" id="L113">                NamedList&lt;Object&gt; mtasResponse = (NamedList&lt;Object&gt;) response</span>
<span class="nc" id="L114">                    .get(&quot;mtas&quot;);</span>
<span class="nc" id="L115">                mtasResponse.remove(&quot;join&quot;);</span>
<span class="nc" id="L116">                mtasResponse.add(&quot;join&quot;,</span>
<span class="nc" id="L117">                    MtasSolrResultUtil.decode((String) data));</span>
              }
<span class="nc" id="L119">            } catch (ClassCastException e) {</span>
<span class="nc" id="L120">              log.debug(e);</span>
              // shouldn't happen
<span class="nc" id="L122">            }</span>
<span class="nc" id="L123">          }</span>
        }
<span class="nc" id="L125">      }</span>
    }
<span class="nc" id="L127">  }</span>

  /* (non-Javadoc)
   * @see mtas.solr.handler.component.util.MtasSolrComponent#distributedProcess(org.apache.solr.handler.component.ResponseBuilder, mtas.codec.util.CodecComponent.ComponentFields)
   */
  @SuppressWarnings(&quot;unchecked&quot;)
  public void distributedProcess(ResponseBuilder rb, ComponentFields mtasFields)
      throws IOException {
    // rewrite
<span class="nc" id="L136">    NamedList&lt;Object&gt; mtasResponse = null;</span>
    try {
<span class="nc" id="L138">      mtasResponse = (NamedList&lt;Object&gt;) rb.rsp.getValues().get(&quot;mtas&quot;);</span>
<span class="nc" id="L139">    } catch (ClassCastException e) {</span>
<span class="nc" id="L140">      log.debug(e);</span>
<span class="nc" id="L141">      mtasResponse = null;</span>
<span class="nc" id="L142">    }</span>
<span class="nc bnc" id="L143" title="All 2 branches missed.">    if (mtasResponse != null) {</span>
      MtasSolrJoinResult mtasSolrJoinResult;
      try {
<span class="nc" id="L146">        mtasSolrJoinResult = (MtasSolrJoinResult) mtasResponse.get(&quot;join&quot;);</span>
<span class="nc bnc" id="L147" title="All 2 branches missed.">        if (mtasSolrJoinResult != null) {</span>
<span class="nc" id="L148">          mtasResponse.removeAll(&quot;join&quot;);</span>
<span class="nc" id="L149">          mtasResponse.add(&quot;join&quot;, mtasSolrJoinResult.rewrite());</span>
        }
<span class="nc" id="L151">      } catch (ClassCastException e) {</span>
<span class="nc" id="L152">        log.debug(e);</span>
<span class="nc" id="L153">        mtasResponse.remove(&quot;join&quot;);</span>
<span class="nc" id="L154">      }</span>
    }
<span class="nc" id="L156">  }</span>

  /**
   * Creates the key from request.
   *
   * @param rb the rb
   * @return the string
   */
  private String createKeyFromRequest(ResponseBuilder rb) {
<span class="nc" id="L165">    return rb.req.getParams().toQueryString();</span>
  }


  


}
</pre><div class="footer"><span class="right">Created with <a href="http://www.jacoco.org/jacoco">JaCoCo</a> 0.7.9.201702052155</span></div></body></html>