phpvms/app/Support/Database.php
2019-07-23 10:17:51 -04:00

109 lines
2.3 KiB
PHP

<?php
namespace App\Support;
use Carbon\Carbon;
use Illuminate\Database\QueryException;
use Illuminate\Support\Facades\DB;
use Log;
use Symfony\Component\Yaml\Yaml;
class Database
{
/**
* @return string
*/
protected static function time(): string
{
return Carbon::now('UTC');
}
/**
* @param $yaml_file
* @param bool $ignore_errors
*
* @throws \Exception
*
* @return array
*/
public static function seed_from_yaml_file($yaml_file, $ignore_errors = false): array
{
$yml = file_get_contents($yaml_file);
return static::seed_from_yaml($yml, $ignore_errors);
}
/**
* @param $yml
* @param bool $ignore_errors
*
* @throws \Exception
*
* @return array
*/
public static function seed_from_yaml($yml, $ignore_errors = false): array
{
$imported = [];
$yml = Yaml::parse($yml);
if (empty($yml)) {
return $imported;
}
foreach ($yml as $table => $rows) {
$imported[$table] = 0;
foreach ($rows as $row) {
try {
static::insert_row($table, $row);
} catch (QueryException $e) {
if ($ignore_errors) {
continue;
}
throw $e;
}
$imported[$table]++;
}
}
return $imported;
}
/**
* @param $table
* @param $row
*
* @throws \Exception
*
* @return mixed
*/
public static function insert_row($table, $row)
{
// encrypt any password fields
if (array_key_exists('password', $row)) {
$row['password'] = bcrypt($row['password']);
}
if (empty($row)) {
return $row;
}
// if any time fields are == to "now", then insert the right time
foreach ($row as $column => $value) {
if (strtolower($value) === 'now') {
$row[$column] = static::time();
}
}
try {
DB::table($table)->insert($row);
} catch (QueryException $e) {
Log::error($e);
throw $e;
}
return $row;
}
}