fiqhpratama
106 lines
2.9 KiB
PHP
106 lines
2.9 KiB
PHP
<?php
|
|
|
|
namespace App\Helpers;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
|
|
class QueryHelper
|
|
{
|
|
/**
|
|
* Execute a stored procedure with input and output parameters.
|
|
*
|
|
* @param string $procedureName The name of the stored procedure.
|
|
* @param array $inputParams An associative array of input parameters.
|
|
* @param array $outputParams An associative array of output parameters with PDO types.
|
|
* @return array An associative array of output parameters with their values.
|
|
*/
|
|
public static function returnProcedure($connection, $procedureName, $inputParams = [], $outputParams = [])
|
|
{
|
|
$connection = $connection->getPdo();
|
|
|
|
$inputPlaceholders = [];
|
|
$outputPlaceholders = [];
|
|
$bindings = [];
|
|
|
|
foreach ($inputParams as $key => $value) {
|
|
$inputPlaceholders[] = ":{$key}";
|
|
$bindings[":{$key}"] = $value;
|
|
}
|
|
|
|
foreach ($outputParams as $key => $type) {
|
|
$outputPlaceholders[] = ":{$key}";
|
|
$bindings[":{$key}"] = null;
|
|
}
|
|
|
|
// Build the SQL statement
|
|
$sql = sprintf(
|
|
'BEGIN %s(%s, %s); END;',
|
|
$procedureName,
|
|
implode(', ', $inputPlaceholders),
|
|
implode(', ', $outputPlaceholders)
|
|
);
|
|
|
|
// Prepare the callable statement
|
|
$stmt = $connection->prepare($sql);
|
|
|
|
// Bind input parameters
|
|
foreach ($inputParams as $key => $value) {
|
|
$stmt->bindValue(":{$key}", $value);
|
|
}
|
|
|
|
// Bind output parameters with specific types
|
|
foreach ($outputParams as $key => $type) {
|
|
$stmt->bindParam(":{$key}", $bindings[":{$key}"], $type, 255);
|
|
}
|
|
// Execute the procedure
|
|
$stmt->execute();
|
|
|
|
// Fetch the output parameters
|
|
$outputResults = [];
|
|
foreach ($outputParams as $key => $type) {
|
|
$outputResults[$key] = $bindings[":{$key}"];
|
|
}
|
|
|
|
$connection = null;
|
|
return $outputResults;
|
|
}
|
|
|
|
|
|
|
|
public static function execProcedure($connection, $procedureName, $inputParams = [])
|
|
{
|
|
// Get the database connection
|
|
$connection = $connection->getPdo();
|
|
|
|
// Build the parameter placeholders for the stored procedure
|
|
$placeholders = [];
|
|
$bindings = [];
|
|
|
|
foreach ($inputParams as $key => $value) {
|
|
$placeholders[] = ":{$key}";
|
|
$bindings[":{$key}"] = $value;
|
|
}
|
|
|
|
// Build the SQL statement
|
|
$sql = sprintf(
|
|
'BEGIN %s(%s); END;',
|
|
$procedureName,
|
|
implode(', ', $placeholders)
|
|
);
|
|
|
|
// Prepare the callable statement
|
|
$stmt = $connection->prepare($sql);
|
|
|
|
// Bind input parameters
|
|
foreach ($inputParams as $key => $value) {
|
|
$stmt->bindValue(":{$key}", $value);
|
|
}
|
|
|
|
|
|
// Execute the procedure
|
|
$stmt->execute();
|
|
$connection = null;
|
|
}
|
|
}
|