" . $sql . "";
}
$stmt = $conn->prepare($sql);
$stmt->execute();
$data = $stmt->fetchAll(PDO::FETCH_OBJ);
$TotalReg = $stmt->rowCount();
$data = $data!=null?$data:array([]);
// $TotalReg = 0;
return array($data[0], $TotalReg);
}
public static function get($sql)
{
$conn = DatabasePg::connectPg();
if (Core::$debug_sql) {
print "" . $sql . "
";
}
$stmt = $conn->prepare($sql);
$stmt->execute();
$data = $stmt->fetchAll(PDO::FETCH_ASSOC);
$TotalReg = $stmt->rowCount();
$data = $data!=null?$data:array([0]);
// $TotalReg = 0;
return array($data[0], $TotalReg);
}
public static function insert($sql, $values)
{
$conn = DatabasePg::connectPg();
if (Core::$debug_sql) {
print "" . $sql . "
";
print_r($values);
// Core::alert("".$sql."
");
}
$stmt = $conn->prepare($sql);
$stmt->execute($values);
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
// $insert_id = $conn->lastInsertId($table.'_id_seq');
// $TotalReg = $stmt->rowCount();
// $TotalReg = 0;
return array($result[0], $conn);
}
public static function update($sql, $values)
{
$conn = DatabasePg::connectPg();
if (Core::$debug_sql) {
print "" . $sql . "
";
print "" . $values . "
";
// Core::alert("".$sql."
");
}
$stmt = $conn->prepare($sql);
$stmt->execute($values);
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
$total_result = 0;
return array($result, $total_result);
}
public static function del($sql,$id)
{
$conn = DatabasePg::connectPg();
if (Core::$debug_sql) {
print "" . $sql . "
";
print "" . $id . "
";
}
$stmt = $conn->prepare($sql);
$resul = $stmt->execute([$id]);
return $resul;
}
}