171 lines
3.3 KiB
PHP
171 lines
3.3 KiB
PHP
<?php
|
|
%model_start%
|
|
/*
|
|
Generated from %filename%
|
|
*/
|
|
namespace Vvveb\Sql%namespace%;
|
|
|
|
use \Vvveb\System\Db;
|
|
|
|
class %name%SQL {
|
|
|
|
private $db;
|
|
|
|
protected $filters = %filters%;
|
|
|
|
protected $paramTypes = %paramTypes%;
|
|
|
|
public function __construct(){
|
|
$this->db = Db::getInstance();
|
|
}
|
|
|
|
public function validate($data, $method, $table = '', $ignoreMissing = false) {
|
|
$params = $this->paramTypes[$method] ?? [];
|
|
if (!$params) {
|
|
return false;
|
|
}
|
|
|
|
foreach ($params as $name => $type) {
|
|
if (isset($this->filters[$name])) {
|
|
$params[$name] = $this->filters[$name];
|
|
}
|
|
}
|
|
|
|
return $this->db->validate($data, $params, $table, $ignoreMissing);
|
|
}
|
|
|
|
%methods_start%
|
|
|
|
%methodMultipleTemplate_start%
|
|
|
|
function %name%($params = array()) {
|
|
$paramTypes = %param_types%;
|
|
|
|
$results = [];
|
|
$stmt = [];
|
|
|
|
%statement%
|
|
|
|
if ($results)
|
|
return $results;
|
|
}
|
|
|
|
%methodMultipleTemplate_end%
|
|
|
|
%methods_end%
|
|
}
|
|
%model_end%
|
|
|
|
%query_start%
|
|
|
|
$prevSql = $sql ?? '';
|
|
$sql = '%statement%';
|
|
$sql = trim($sql);
|
|
|
|
if ($sql) {
|
|
$stmt['%query_id%'] = $this->db->execute($sql, $params, $paramTypes);
|
|
|
|
$result = $stmt['%query_id%'];
|
|
/*
|
|
if ($stmt['%query_id%']) {
|
|
if (method_exists($stmt['%query_id%'], 'get_result')) {
|
|
$result = $stmt['%query_id%']->get_result();
|
|
} else {
|
|
$result = $this->db->get_result($stmt['%query_id%']);
|
|
}
|
|
}
|
|
*/
|
|
|
|
if (!empty('%array_key%')) {
|
|
if ($result)
|
|
while ($row = pg_fetch_assoc($result)) {
|
|
$values = $row;
|
|
if (!empty('%array_value%')) {
|
|
$values = $row['array_value'];
|
|
}
|
|
|
|
if ('%query_id%' == '_') {
|
|
if ($row['array_key'] === null) {
|
|
$results[] = $values;
|
|
} else {
|
|
$results[$row['array_key']] = $values;
|
|
}
|
|
} else {
|
|
if ($row['array_key'] === null) {
|
|
$results['%query_id%'][] = $values;
|
|
} else {
|
|
$results['%query_id%'][$row['array_key']] = $values;
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
if ('%query_id%' == '_') {
|
|
if ($result) {
|
|
$value = %fetch%;
|
|
} else {
|
|
$value = null;
|
|
}
|
|
|
|
if ($value) {
|
|
if (is_array($value)) {
|
|
$results = $results + $value;
|
|
} else {
|
|
$results = $value;
|
|
}
|
|
}
|
|
} else {
|
|
if ($result) {
|
|
if (isset($results['%query_id%'])) {
|
|
//if multiple results like insert id from @EACH
|
|
if (!is_array($results['%query_id%'])){
|
|
$results['%query_id%'] = [$results['%query_id%']];
|
|
}
|
|
$results['%query_id%'][] = %fetch%;
|
|
} else {
|
|
$results['%query_id%'] = %fetch%;
|
|
}
|
|
} else {
|
|
$results['%query_id%'] = null;
|
|
}
|
|
}
|
|
}
|
|
if ($result) {
|
|
pg_free_result($result);
|
|
}
|
|
}
|
|
|
|
%query_end%
|
|
|
|
%varsTemplate_start%
|
|
|
|
if (isset($params['%name%'])) {
|
|
$stmt->bindValue(':%name%', (%type%)$params['%name%'], PDO::PARAM_%type%);
|
|
}
|
|
|
|
%varsTemplate_end%
|
|
|
|
|
|
%insert_id_start%
|
|
$this->db->insert_id
|
|
%insert_id_end%
|
|
|
|
%affected_rows_start%
|
|
$this->db->affected_rows
|
|
%affected_rows_end%
|
|
|
|
%fetch_row_start%
|
|
pg_fetch_assoc($result)
|
|
%fetch_row_end%
|
|
|
|
%fetch_one_start%
|
|
pg_num_rows($result) ? pg_fetch_result($result, 0, 0) ?? null : null;
|
|
%fetch_one_end%
|
|
|
|
%fetch_result_start%
|
|
isset($results['%key%']) ? $results['%key%'] : 'NULL'
|
|
%fetch_result_end%
|
|
|
|
%fetch_all_start%
|
|
$this->db->fetchAll($result)
|
|
%fetch_all_end%
|