1.9

* [+] showMeta moved to SphinxToolkitHelper
* [+] `::spql_getDataSet()`

Author: KarelWintersky

.gitattributes

@@ -0,0 +1,2 @@
+.gitignonre     export-ignore
+README*.*       export-ignore

TODO.md

@@ -4,6 +4,7 @@
 
 use Closure;
 use Exception;
+use Foolz\SphinxQL\Drivers\ConnectionInterface;
 use Foolz\SphinxQL\Exception\ConnectionException;
 use Foolz\SphinxQL\Exception\SphinxQLException;
 use PDO;
@@ -317,7 +318,7 @@ public function checkIndexExist(string $sphinx_index)
      */
     private static $spql_connection_port;
     /**
-     * @var Connection
+     * @var ConnectionInterface
      */
     private static $spql_connection;
 
@@ -523,6 +524,79 @@ public static function rt_RebuildAbstractIndex(PDO $pdo_connection, string $sql_
         return $total_updated;
     }
 
+    
+    /**
+     *
+     *
+     * @param string $search_query
+     * @param string $source_index
+     * @param string $sort_field
+     * @param string $sort_order
+     * @param int $limit
+     * @param array $option_weight
+     * @return array
+     * 
+     * @throws ConnectionException
+     * @throws DatabaseException
+     * @throws SphinxQLException
+     */
+    public static function spql_getDataSet(string $search_query, string $source_index, string $sort_field, string $sort_order = 'DESC', int $limit = 5, array $option_weight = []): array
+    {
+        $found_dataset = [];
+        $compiled_request = '';
+        
+        if (empty($source_index)) return $found_dataset;
+        
+        try {
+            $search_request = self::createInstance()
+                ->select()
+                ->from($source_index);
+            
+            if (!empty($sort_field)) {
+                $search_request = $search_request
+                    ->orderBy($sort_field, $sort_order);
+            }
+            
+            if (!empty($option_weight)) {
+                $search_request = $search_request
+                    ->option('field_weights', $option_weight);
+            }
+            
+            if (!is_null($limit) && is_numeric($limit)) {
+                $search_request = $search_request
+                    ->limit($limit);
+            }
+            
+            if (strlen($search_query) > 0) {
+                $search_request = $search_request
+                    ->match(['title'], $search_query);
+            }
+            
+            $search_result = $search_request->execute();
+            
+            while ($row = $search_result->fetchAssoc()) {
+                $found_dataset[] = $row['id'];
+            }
+            
+        } catch (Exception $e) {
+            
+            $meta = SphinxToolkitHelper::showMeta(self::$spql_connection);
+            
+            self::$spql_logger->error(
+                __CLASS__ . '/' . __METHOD__ .
+                " Error fetching data from `{$source_index}` : " . $e->getMessage(),
+                [
+                    $e->getCode(),
+                    htmlspecialchars(urldecode($_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI'])),
+                    $search_request->getCompiled(),
+                    $meta
+                ]
+            );
+        }
+        return $found_dataset;
+    } // get_IDs_DataSet()
+    
+    
     /**
      *
      * @param string $index_name

src/SphinxToolkit.php

@@ -238,13 +238,17 @@ public static function EmulateBuildExcerpts($source, $needle, $options)
     /**
      *
      * @param ConnectionInterface $connection
+     * @return array
+     *
      * @throws \Foolz\SphinxQL\Exception\ConnectionException
      * @throws \Foolz\SphinxQL\Exception\DatabaseException
      * @throws \Foolz\SphinxQL\Exception\SphinxQLException
      */
     public static function showMeta(ConnectionInterface $connection)
     {
-        (new Helper($connection))->showMeta()->execute()->fetchAllAssoc();
+        return (new Helper($connection))->showMeta()->execute()->fetchAllAssoc();
     }
 
+    
+    
 }