<?php require(__DIR__.'/init.php'); use Solarium\Plugin\BufferedAdd\Event\Events; use Solarium\Plugin\BufferedAdd\Event\PreFlush as PreFlushEvent; htmlHeader(); // create a client instance and autoload the buffered add plugin $client = new Solarium\Client($config); $buffer = $client->getPlugin('bufferedadd'); $buffer->setBufferSize(10); // this is quite low, in most cases you can use a much higher value // also register an event hook to display what is happening $client->getEventDispatcher()->addListener( Events::PRE_FLUSH, function (PreFlushEvent $event) { echo 'Flushing buffer (' . count($event->getBuffer()) . 'docs)<br/>'; } ); // let's insert 25 docs for ($i=1; $i<=25; $i++) { // create a new document with dummy data and add it to the buffer $data = array( 'id' => 'test_'.$i, 'name' => 'test for buffered add', 'price' => $i, ); $buffer->createDocument($data); // alternatively you could create document instances yourself and use the addDocument(s) method } // At this point two flushes will already have been done by the buffer automatically (at the 10th and 20th doc), now // manually flush the remainder. Alternatively you can use the commit method if you want to include a commit command. $buffer->flush(); // In total 3 flushes (requests) have been sent to Solr. This should be visible in the output of the event hook. htmlFooter();