Atualizando
This commit is contained in:
parent
5c59f6a412
commit
1ea4ba5b96
2 changed files with 247 additions and 0 deletions
12
vendor/action/log/log_save.php
vendored
12
vendor/action/log/log_save.php
vendored
|
|
@ -10,6 +10,7 @@ use vendor\model\Backup;
|
|||
use vendor\model\Station;
|
||||
use vendor\model\StationDisk;
|
||||
use vendor\model\StationFolder;
|
||||
use vendor\model\Database;
|
||||
use vendor\controller\log\LogValidate;
|
||||
|
||||
try {
|
||||
|
|
@ -19,6 +20,7 @@ try {
|
|||
$Client = new Client();
|
||||
$Backup = new Backup();
|
||||
$Station = new Station();
|
||||
$Database = new Database();
|
||||
$StationDisk = new StationDisk();
|
||||
$LogValidate = new LogValidate();
|
||||
$StationFolder = new StationFolder();
|
||||
|
|
@ -239,6 +241,16 @@ try {
|
|||
);
|
||||
}
|
||||
|
||||
|
||||
/** Exclui o registro anterior sobre o banco de dados */
|
||||
$Database->Delete($clientId);
|
||||
|
||||
/** Grava os novos dados do banco de dados */
|
||||
$Database->Save($clientId,
|
||||
$jsonLog->database->file_size,
|
||||
$jsonLog->database->last_modified,
|
||||
$jsonLog->database->db_accessible);
|
||||
|
||||
/** Exclui o log anterior da estação correspondente */
|
||||
$Log->Delete($clientId, $stationId);
|
||||
|
||||
|
|
|
|||
235
vendor/model/Database.class.php
vendored
Normal file
235
vendor/model/Database.class.php
vendored
Normal file
|
|
@ -0,0 +1,235 @@
|
|||
<?php
|
||||
/**
|
||||
* Classe Database.class.php
|
||||
* @filesource
|
||||
* @autor Kenio de Souza
|
||||
* @copyright Copyright 2024 - Souza Consultoria Tecnológica
|
||||
* @package vendor
|
||||
* @subpackage model
|
||||
* @version 1.0
|
||||
* @date 10/08/2024
|
||||
*/
|
||||
|
||||
|
||||
/** Defino o local onde esta a classe */
|
||||
namespace vendor\model;
|
||||
|
||||
class Database
|
||||
{
|
||||
/** Declaro as vaiavéis da classe */
|
||||
private $connection = null;
|
||||
private $sql = null;
|
||||
private $stmt = null;
|
||||
private $start = null;
|
||||
private $max = null;
|
||||
private $limit = null;
|
||||
private $dbId = null;
|
||||
private $stationId = null;
|
||||
private $description = null;
|
||||
private $capacity = null;
|
||||
private $used = null;
|
||||
private $available = null;
|
||||
private $availablePercentage = null;
|
||||
private $registrationDate = null;
|
||||
private $field = null;
|
||||
private $lastId = null;
|
||||
private $errors = [];
|
||||
private $info = null;
|
||||
|
||||
/** Construtor da classe */
|
||||
function __construct()
|
||||
{
|
||||
/** Cria o objeto de conexão com o banco de dados */
|
||||
$this->connection = new Mysql();
|
||||
}
|
||||
|
||||
/** Carrega os campos de uma tabela */
|
||||
public function Describe()
|
||||
{
|
||||
|
||||
/** Consulta SQL */
|
||||
$this->sql = "describe db";
|
||||
|
||||
/** Preparo o SQL para execução */
|
||||
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
||||
|
||||
/** Executo o SQL */
|
||||
$this->stmt->execute();
|
||||
|
||||
/** Retorno o resultado */
|
||||
$this->field = $this->stmt->fetchAll(\PDO::FETCH_OBJ);
|
||||
|
||||
/** Declara o objeto */
|
||||
$resultDescribe = new \stdClass();
|
||||
$Field = '';
|
||||
|
||||
/** Lista os campos da tabela para objetos */
|
||||
foreach($this->field as $UsersKey => $Result){
|
||||
|
||||
/** Pega o nome do Field/Campo */
|
||||
$Field = $Result->Field;
|
||||
|
||||
/** Carrega os objetos como null */
|
||||
$resultDescribe->$Field = null;
|
||||
|
||||
}
|
||||
|
||||
/** Retorna os campos declarados como vazios */
|
||||
return $resultDescribe;
|
||||
|
||||
}
|
||||
|
||||
/** Lista os registros do banco de dados com limitação */
|
||||
public function Get(int $dbId)
|
||||
{
|
||||
|
||||
/** Parametros de entrada */
|
||||
$this->dbId = $dbId;
|
||||
|
||||
/** Consulta SQL */
|
||||
$this->sql = 'select * from db
|
||||
where db_id = :db_id';
|
||||
|
||||
/** Preparo o SQL para execução */
|
||||
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
||||
|
||||
/** Preencho os parâmetros do SQL */
|
||||
$this->stmt->bindParam(':db_id', $this->dbId);
|
||||
|
||||
/** Executo o SQL */
|
||||
$this->stmt->execute();
|
||||
|
||||
/** Retorno o resultado */
|
||||
return $this->stmt->fetchObject();
|
||||
|
||||
}
|
||||
|
||||
/** Insere um novo registro no banco */
|
||||
public function Save(int $clientId,
|
||||
? string $fileSize,
|
||||
? string $lastModified,
|
||||
? string $dbAccessible)
|
||||
{
|
||||
|
||||
|
||||
/** Parametros */
|
||||
$this->clientId = $clientId;
|
||||
$this->fileSize = $fileSize;
|
||||
$this->lastModified = $lastModified;
|
||||
$this->dbAccessible = $dbAccessible;
|
||||
|
||||
/** Consulta SQL */
|
||||
$this->sql = 'insert into db(client_id,
|
||||
file_size,
|
||||
last_modified,
|
||||
db_accessible
|
||||
) values (:client_id,
|
||||
:file_size,
|
||||
:last_modified,
|
||||
:db_accessible,
|
||||
:capacity)';
|
||||
|
||||
/** Preparo o sql para receber os valores */
|
||||
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
||||
|
||||
|
||||
/** Inicia a transação */
|
||||
$this->connection->connect()->beginTransaction();
|
||||
|
||||
/** Preencho os parâmetros do SQL */
|
||||
$this->stmt->bindParam(':client_id', $this->clientId);
|
||||
$this->stmt->bindParam(':file_size', $this->fileSize);
|
||||
$this->stmt->bindParam(':last_modified', $this->lastModified);
|
||||
$this->stmt->bindParam(':db_accessible', $this->dbAccessible);
|
||||
|
||||
/** Executo o SQL */
|
||||
$this->stmt->execute();
|
||||
|
||||
}
|
||||
|
||||
/** Deleta um determinado registro no banco de dados */
|
||||
function Delete(int $clientId)
|
||||
{
|
||||
/** Parametros de entrada */
|
||||
$this->clientId = $clientId;
|
||||
|
||||
/** Consulta SQL */
|
||||
$this->sql = 'delete from db
|
||||
where client_id = :client_id';
|
||||
|
||||
/** Preparo o sql para receber os valores */
|
||||
$this->stmt = $this->connection->connect()->prepare($this->sql);
|
||||
|
||||
try {
|
||||
|
||||
/** Inicia a transação */
|
||||
$this->connection->connect()->beginTransaction();
|
||||
|
||||
/** Preencho os parâmetros do SQL */
|
||||
$this->stmt->bindParam('client_id', $this->clientId);
|
||||
|
||||
/** Executo o SQL */
|
||||
$this->stmt->execute();
|
||||
|
||||
/** Confirma a transação */
|
||||
$this->connection->connect()->commit();
|
||||
return true;
|
||||
|
||||
} catch (\Exception $exception) {
|
||||
|
||||
/** Desfaz a transação */
|
||||
$this->connection->connect()->rollback();
|
||||
|
||||
/** Captura o erro */
|
||||
array_push($this->errors, 'Error:: ' . $exception->getMessage());
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/** Define o Último ID inserido */
|
||||
public function setId($lastId) : void
|
||||
{
|
||||
$this->lastId = $lastId;
|
||||
}
|
||||
|
||||
/** Recupera o Último ID inserido */
|
||||
public function getId(): ? int
|
||||
{
|
||||
return (int)$this->lastId;
|
||||
}
|
||||
|
||||
/** Retorna os erros ocorridos */
|
||||
public function getErrors(): ? string
|
||||
{
|
||||
|
||||
/** Verifico se deve informar os erros */
|
||||
if (count($this->errors)) {
|
||||
|
||||
/** Verifica a quantidade de erros para informar a legenda */
|
||||
$this->info = count($this->errors) > 1 ? '<center>Os seguintes erros foram encontrados</center>' : '<center>O seguinte erro foi encontrado</center>';
|
||||
|
||||
/** Lista os erros */
|
||||
foreach ($this->errors as $keyError => $error) {
|
||||
|
||||
/** Monto a mensagem de erro */
|
||||
$this->info .= '</br>' . ($keyError + 1) . ' - ' . $error;
|
||||
|
||||
}
|
||||
|
||||
/** Retorno os erros encontrados */
|
||||
return (string)$this->info;
|
||||
|
||||
} else {
|
||||
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/** Fecha uma conexão aberta anteriormente com o banco de dados */
|
||||
function __destruct()
|
||||
{
|
||||
$this->connection = null;
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Reference in a new issue