Package org.apache.solr.client.solrj.request

Examples of org.apache.solr.client.solrj.request.DirectXmlRequest

146
147
148
149
150
151
152
153
154
155
156
                if (!bodyAsString.startsWith("<add")) {
                    bodyAsString = "<add>" + bodyAsString + "</add>";
                }

                DirectXmlRequest xmlRequest = new DirectXmlRequest(getRequestHandler(), bodyAsString);

                solrServer.request(xmlRequest);               
            } else {
                throw new SolrException(SolrException.ErrorCode.BAD_REQUEST, "unable to find data in Exchange to update Solr");
            }
View Full Code Here
336
337
338
339
340
341
342
343
344
345
      xml.append( "<id>" );
      XML.escapeCharData( (String)d.getField( "id" ).getFirstValue(), xml );
      xml.append( "</id>" );
    }
    xml.append( "</delete>" );
    DirectXmlRequest up = new DirectXmlRequest( "/update", xml.toString() );
    server.request( up );
    server.commit();
    assertNumFound( "*:*", 0 ); // make sure it got out
  }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
                if (!bodyAsString.startsWith("<add")) {
                    bodyAsString = "<add>" + bodyAsString + "</add>";
                }

                DirectXmlRequest xmlRequest = new DirectXmlRequest(getRequestHandler(), bodyAsString);

                if (isStreaming) {
                    streamingSolrServer.request(xmlRequest);
                } else {
                    solrServer.request(xmlRequest);
View Full Code Here
295
296
297
298
299
300
301
302
303
304
305
306
307
              logger.info("[{}]: sending: {}...", core, xmlFile);
              // Ensure it's in UTF-8 encoding
              Reader reader = new InputStreamReader(
                  new FileInputStream(xmlFile), "UTF-8");
              String body = IOUtils.toString(reader);
              SolrRequest request = new DirectXmlRequest("/update", body);
              /** Post the document to the Index */
              request.process(server);
              IOUtils.closeQuietly(reader);
            }
            // Commit the changes
            server.commit();
          } catch (Exception ex) {
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
312
313
              logger.info("[{}]: sending: {}...", core, xmlFile);
              // Ensure it's in UTF-8 encoding
              Reader reader = new InputStreamReader(
                  new FileInputStream(xmlFile), "UTF-8");
              String body = IOUtils.toString(reader);
              SolrRequest request = new DirectXmlRequest("/update", body);
              /** Post the document to the Index */
              request.process(server);
              IOUtils.closeQuietly(reader);
            }
            // Commit the changes
            server.commit();
          } catch (Exception ex) {
View Full Code Here
TOP

Related Classes of org.apache.solr.client.solrj.request.DirectXmlRequest

  • com.github.jknack.mwa.solr.SolrModule
  • org.apache.camel.component.solr.SolrProducer
  • org.apache.solr.client.solrj.response.UpdateResponse
  • org.apache.solr.client.solrj.SolrExampleTests
  • org.apache.solr.handler.dataimport.TestContentStreamDataSource
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.