refactoring

Author: michael-rubel

config/sql-function-repository.php

@@ -1,17 +1,31 @@
 <?php
 
+use Illuminate\Support\Facades\DB;
+
 return [
 
     /*
     |--------------------------------------------------------------------------
-    | SQL Function Repository Configuration
+    | Database Connection Name
+    |--------------------------------------------------------------------------
+    |
+    | Database connection name to use by the repository.
+    |
+    | Default: `pgsql`
+    |
+    */
+
+    'connection' => DB::getDefaultConnection(),
+
+    /*
+    |--------------------------------------------------------------------------
+    | Default select statement
     |--------------------------------------------------------------------------
     |
-    | Database connection & base select.
+    | Default: `select * from `
     |
     */
 
-    'connection' => 'default',
-    'select'     => 'select * from public',
+    'select' => 'select * from ',
 
 ];

src/Repositories/PostgresqlFunctionRepository.php

@@ -0,0 +1,62 @@
+<?php
+
+declare(strict_types=1);
+
+namespace MichaelRubel\SqlFunctionRepository\Repositories;
+
+use Illuminate\Support\Facades\DB;
+use MichaelRubel\SqlFunctionRepository\SqlFunctionRepository;
+
+class PostgresqlFunctionRepository implements SqlFunctionRepository
+{
+    /**
+     * @param string|null $connection
+     * @param string|null $select
+     */
+    public function __construct(
+        public ?string $connection = null,
+        public ?string $select = null,
+    ) {
+        if (is_null($this->connection)) {
+            $this->connection = config('sql-function-repository.connection', DB::getDefaultConnection());
+        }
+
+        if (is_null($this->select)) {
+            $this->select = config('sql-function-repository.select', 'select * from ');
+        }
+    }
+
+    /**
+     * Execute the database function.
+     *
+     * @param string $name
+     * @param array  $parameters
+     *
+     * @return array
+     */
+    public function runDatabaseFunction(string $name, array $parameters = []): array
+    {
+        return DB::connection($this->connection)->select(
+            $this->buildSqlFunction($name, $parameters),
+            $parameters
+        );
+    }
+
+    /**
+     * @param string $name
+     * @param array  $parameters
+     *
+     * @return string
+     */
+    protected function buildSqlFunction(string $name, array $parameters): string
+    {
+        $prepareForBindings = collect($parameters)->implode(
+            fn ($param) => '?, '
+        );
+
+        return $this->select . $name . str($prepareForBindings)
+                ->replaceLast(', ', '')
+                ->start('(')
+                ->finish(')');
+    }
+}

src/SqlFunctionRepositoryServiceProvider.php

@@ -4,11 +4,15 @@
 
 namespace MichaelRubel\SqlFunctionRepository;
 
+use MichaelRubel\SqlFunctionRepository\Repositories\PostgresqlFunctionRepository;
+use MichaelRubel\SqlFunctionRepository\Traits\ResolvesDatabaseDriver;
 use Spatie\LaravelPackageTools\Package;
 use Spatie\LaravelPackageTools\PackageServiceProvider;
 
 class SqlFunctionRepositoryServiceProvider extends PackageServiceProvider
 {
+    use ResolvesDatabaseDriver;
+
     /**
      * Configure the package.
      *
@@ -22,4 +26,17 @@ public function configurePackage(Package $package): void
             ->name('laravel-sql-function-repository')
             ->hasConfigFile();
     }
+
+    /**
+     * Register the bindings.
+     *
+     * @return void
+     */
+    public function packageRegistered(): void
+    {
+        $this->app->singleton(
+            SqlFunctionRepository::class,
+            PostgresqlFunctionRepository::class
+        );
+    }
 }