lu sp dataaccess

src/Utils/DataAccess/LuStoredProcedure.php

 namespace Luticate\Utils\DataAccess;
 
 use Illuminate\Database\Connection;
+use Luticate\Utils\Business\LuStringUtils;
 use Luticate\Utils\Dbo\LuDbo;
 use Illuminate\Database\Capsule\Manager as Capsule;
+use Luticate\Utils\Dbo\LuMultipleDbo;
 
 abstract class LuStoredProcedure
 {
     protected static $_connection = "mydb";
+    protected static $_storedProcedure = "mydb_table";
     protected static $_dboClass = LuDbo::class;
+    protected static $_dboArrayClass = LuDbo::class;
 
     /**
      * @return Connection
     {
         return Capsule::connection(static::$_connection);
     }
+
+    public static function getArgsArray($args)
+    {
+        $argsArray = [];
+        for ($i = 0; $i < count($args); ++$i) {
+            $argsArray[":_arg" . $i] = $args[$i];
+        }
+        return $argsArray;
+    }
+
+    public static function getSqlSelectQuery($args)
+    {
+        $storedProcedure = static::$_storedProcedure;
+        $argsString = implode(", ", array_map(function($i)
+        {
+            return ":_arg" . $i;
+        }, range(0, count($args) - 1)));
+        $query = "SELECT COALESCE(json_agg(data), '[]'::json) as data FROM ${storedProcedure}(${argsString}) data";
+        return $query;
+    }
+
+    /**
+     * @param $args array
+     * @return LuDbo[]
+     */
+    public static function getMultiple($args)
+    {
+        $argsArray = static::getArgsArray($args);
+        $query = static::getSqlSelectQuery($args);
+        $values = static::getConnection()->select($query, $argsArray);
+
+        $value = $values[0]->data;
+        $json = LuStringUtils::convertJsonString($value);
+        $dboValues = call_user_func([static::$_dboArrayClass, 'jsonDeserialize'], $json)->getArray();
+        return $dboValues;
+    }
+
+    /**
+     * @param $args array
+     * @return LuDbo|null
+     */
+    public static function getSingle($args)
+    {
+        $argsArray = static::getArgsArray($args);
+        $query = static::getSqlSelectQuery($args);
+        $values = static::getConnection()->select($query, $argsArray);
+
+        $value = $values[0]->data;
+        $json = LuStringUtils::convertJsonString($value);
+        if (count($json) < 1 || is_null($json[0])) {
+            return null;
+        }
+        $dboValue = call_user_func([static::$_dboArrayClass, 'jsonDeserialize'], $json)->getArray()[0];
+        return $dboValue;
+    }
+
+    /**
+     * @param $args array
+     * @param $page int The page number, 0 based
+     * @param $perPage int The number of items per page
+     * @return LuMultipleDbo
+     */
+    public static function getMultiplePaginated($args, $page, $perPage)
+    {
+        $argsArray = static::getArgsArray($args);
+        $argsArray[":_page"] = $page;
+        $argsArray[":_perPage"] = $perPage;
+
+        $storedProcedure = static::$_storedProcedure;
+        $argsString = implode(", ", array_map(function($i)
+        {
+            return ":_arg" . $i;
+        }, range(0, count($args) - 1)));
+
+        $query = "SELECT (SELECT count(*) FROM ${storedProcedure}(${argsString})) as count,
+          (SELECT COALESCE(json_agg(data), '[]'::json) FROM (SELECT data FROM ${storedProcedure}(${argsString}) data OFFSET (:_page::int * :_perPage::int) LIMIT :_perPage) data) as data";
+        $values = static::getConnection()->select($query, $argsArray);
+
+        $value = $values[0];
+        if (is_null($value->data))
+        {
+            $value->data = '[]';
+        }
+        $json = LuStringUtils::convertJsonString($value->data);
+        $dboValues = call_user_func([static::$_dboArrayClass, 'jsonDeserialize'], $json)->getArray();
+        return new LuMultipleDbo($value->count, $dboValues);
+    }
 }

tests/DatabaseTest.php

 use Luticate\Utils\Controller\LuticateApplication;
 use Illuminate\Database\Capsule\Manager as Capsule;
 use Luticate\Utils\DataAccess\LuDataAccess;
+use Luticate\Utils\DataAccess\LuStoredProcedure;
 use Luticate\Utils\DataAccess\PgSqlDataAccess;
 use Luticate\Utils\Dbo\LuDbo;
 use Luticate\Utils\Dbo\LuDboDeserializeException;
+use Luticate\Utils\Dbo\LuIntDbo;
+use Luticate\Utils\Dbo\LuIntDboArray;
 
 /**
  * Created by PhpStorm.
 
 }
 
+class SpTest extends LuStoredProcedure {
+
+    protected static $_connection = "mydb";
+    protected static $_storedProcedure = "sp_test";
+    protected static $_dboClass = LuIntDbo::class;
+    protected static $_dboArrayClass = LuIntDboArray::class;
+
+    public static function execute($an_int) {
+        return self::getSingle([$an_int]);
+    }
+
+}
+
+class SpTest2 extends LuStoredProcedure {
+
+    protected static $_connection = "mydb";
+    protected static $_storedProcedure = "sp_test2";
+    protected static $_dboClass = LuIntDbo::class;
+    protected static $_dboArrayClass = LuIntDboArray::class;
+
+    public static function execute($an_int) {
+        return self::getMultiple([$an_int]);
+    }
+
+    public static function executePaginated($an_int, $page, $perPage) {
+        return self::getMultiplePaginated([$an_int], $page, $perPage);
+    }
+
+}
+
 class TestTableDataAccess extends LuDataAccess
 {
     protected static $_connection = "mydb";
 {
     public function testSetup()
     {
-//        $config = ['databases' => [
-//            [
-//                'name'      => 'mydb',
-//                'driver'    => 'pgsql',
-//                'host'      => '172.17.0.1',
-//                'database'  => 'luticate2',
-//                'username'  => 'dev',
-//                'password'  => 'dev'
-//            ]
-//        ]];
-//        $app = new LuticateApplication($config);
-//        $app->setupDatabases();
+        $config = ['databases' => [
+            [
+                'name'      => 'mydb',
+                'driver'    => 'pgsql',
+                'host'      => '172.17.0.1',
+                'database'  => 'luticate2',
+                'username'  => 'dev',
+                'password'  => 'dev'
+            ]
+        ]];
+        $app = new LuticateApplication($config);
+        $app->setupDatabases();
+
+        var_dump(SpTest::execute(42));
+        var_dump(SpTest::execute(4));
+        var_dump(SpTest2::execute(42));
+        var_dump(SpTest2::executePaginated(42, 0, 2));
+        var_dump(SpTest2::executePaginated(42, 1, 2));
 //
 //        $dbo = new TestTableDbo();
 //        $dbo->setId(11);