Skip to content

Commit faadc69

Browse files
kasunmendis7kasunmendis7
authored
Merge pull request #14 from kasunmendis7/feature/database-connection
Feature/database connection
2 parents 752c2d2 + 1034f82 commit faadc69

27 files changed

+857
-59
lines changed

‎.env-example

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
DB_DSN = mysql:host=localhost;port=3306;dbname=php-mvc-framework
2+
DB_USER = root
3+
DB_PASSWORD = root

‎.gitignore

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
vendor
22
.idea
3-
.env
3+
.env
4+
composer.lock

‎controllers/AuthController.php

+11-8
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,11 @@
22

33
namespace app\controllers;
44

5+
use app\core\Application;
56
use app\core\Controller;
67
use app\core\Request;
78
use app\models\CustomerRegisterModel;
8-
use app\models\TechnicianRegisterModel;
9+
use app\models\Technician;
910
use app\models\ServiceCenterRegisterModel;
1011

1112
class AuthController extends Controller
@@ -42,20 +43,22 @@ public function customerLogin(Request $request)
4243
// technician sign up method
4344
public function technicianSignUp(Request $request)
4445
{
45-
$registerModel = new TechnicianRegisterModel();
46+
$technician = new Technician();
4647
if ($request->isPost()) {
47-
$registerModel->loadData($request->getBody());
48-
if ($registerModel->validate() && $registerModel->register()) {
49-
return 'Success';
48+
$technician->loadData($request->getBody());
49+
50+
if ($technician->validate() && $technician->save()) {
51+
Application::$app->session->setFlash('success', 'You have been registered successfully!');
52+
Application::$app->response->redirect('/');
5053
}
5154
$this->setLayout('auth');
5255
return $this->render('/technician/technician-sign-up', [
53-
'model' => $registerModel
56+
'model' => $technician
5457
]);
5558
}
5659
$this->setLayout('auth');
5760
return $this->render('/technician/technician-sign-up', [
58-
'model' => $registerModel
61+
'model' => $technician
5962
]);
6063
}
6164
// technician login method
@@ -70,7 +73,7 @@ public function serviceCentreSignup(Request $request)
7073
$registerModel = new ServiceCenterRegisterModel();
7174
if ($request->isPost()) {
7275
$registerModel->loadData($request->getBody());
73-
if ($registerModel->validate() && $registerModel->register()) {
76+
if ($registerModel->validate() && $registerModel->save()) {
7477
return 'Success';
7578
}
7679
$this->setLayout('auth');

‎core/Application.php

+2
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ class Application
1010
public Router $router;
1111
public Request $request;
1212
public Response $response;
13+
public Session $session;
1314
public Database $db;
1415
public Controller $controller;
1516

@@ -19,6 +20,7 @@ public function __construct($rootPath, array $config)
1920
self::$app = $this;
2021
$this->request = new Request();
2122
$this->response = new Response();
23+
$this->session = new Session();
2224
$this->router = new Router($this->request, $this->response);
2325

2426
$this->db = new Database($config['db']);

‎core/Application.php~

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
<?php
2+
3+
namespace app\core;
4+
5+
class Application
6+
{
7+
8+
public static string $ROOT_DIR;
9+
public static Application $app;
10+
public Router $router;
11+
public Request $request;
12+
public Response $response;
13+
public Session $session;
14+
public Database $db;
15+
public Controller $controller;
16+
17+
public function __construct($rootPath, array $config)
18+
{
19+
self::$ROOT_DIR = $rootPath;
20+
self::$app = $this;
21+
$this->request = new Request();
22+
$this->response = new Response();
23+
$this->router = new Router($this->request, $this->response);
24+
25+
$this->db = new Database($config['db']);
26+
}
27+
28+
public function run()
29+
{
30+
echo $this->router->resolve();
31+
}
32+
}

‎core/Database.php

+77-4
Original file line numberDiff line numberDiff line change
@@ -4,17 +4,90 @@
44

55
class Database
66
{
7-
87
public \PDO $pdo;
98

109
public function __construct(array $config)
1110
{
1211
$dsn = $config['dsn'] ?? '';
1312
$user = $config['user'] ?? '';
1413
$password = $config['password'] ?? '';
15-
1614
$this->pdo = new \PDO($dsn, $user, $password);
17-
1815
$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
1916
}
20-
}
17+
18+
public function applyMigrations()
19+
{
20+
$this->createMigrationsTable();
21+
$appliedMigrations = $this->getAppliedMigrations();
22+
23+
$newMigrations = [];
24+
$files = scandir(Application::$ROOT_DIR.'/migrations');
25+
$toApplyMigrations = array_diff($files, $appliedMigrations);
26+
27+
foreach ($toApplyMigrations as $migration){
28+
if($migration === '.' || $migration === '..'){
29+
continue;
30+
}
31+
32+
require_once Application::$ROOT_DIR.'/migrations/'.$migration;
33+
$className = pathinfo($migration, PATHINFO_FILENAME);
34+
$instance = new $className();
35+
$this->log("Applying Migrations $migration");
36+
$instance->up();
37+
$this->log("Applied Migrations $migration");
38+
$newMigrations[] = $migration;
39+
// echo '<pre>';
40+
// var_dump($className);
41+
// echo '</pre>';
42+
// exit;
43+
}
44+
45+
if (!empty($newMigrations)) {
46+
$this->saveMigrations($newMigrations);
47+
} else {
48+
$this->log("All Migrations are applied");
49+
}
50+
51+
}
52+
53+
public function createMigrationsTable()
54+
{
55+
$this->pdo->exec("CREATE TABLE IF NOT EXISTS migrations (
56+
id INT AUTO_INCREMENT PRIMARY KEY,
57+
migration VARCHAR(255),
58+
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
59+
) ENGINE=INNODB;");
60+
61+
}
62+
63+
public function getAppliedMigrations()
64+
{
65+
$statement = $this->pdo->prepare("SELECT migration FROM migrations");
66+
$statement->execute();
67+
68+
return $statement->fetchAll(\PDO::FETCH_COLUMN);
69+
}
70+
71+
public function saveMigrations(array $migrations)
72+
{
73+
$str = implode(",", array_map(fn($m) => "('$m')", $migrations));
74+
$statement = $this->pdo->prepare("INSERT INTO migrations (migration) VALUES
75+
$str
76+
");
77+
$statement->execute();
78+
}
79+
80+
public function prepare($sql)
81+
{
82+
return $this->pdo->prepare($sql);
83+
84+
}
85+
86+
protected function log($message)
87+
{
88+
echo '['.date('Y-m-d H:i:s').']-'.$message.PHP_EOL;
89+
}
90+
91+
92+
93+
}

‎core/DbModel.php

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
<?php
2+
3+
namespace app\core;
4+
5+
abstract class DbModel extends Model
6+
{
7+
abstract public function tableName(): string;
8+
9+
abstract public function attributes(): array;
10+
11+
public function save(){
12+
13+
$tableName = $this->tableName();
14+
$attributes = $this->attributes();
15+
$params=array_map(fn($attr)=>":$attr", $attributes);
16+
$statement = self::prepare("INSERT INTO $tableName (".implode(',', $attributes).")
17+
VALUES (".implode(',', $params).")");
18+
19+
foreach ($attributes as $attribute) {
20+
$statement->bindValue(":$attribute", $this->$attribute);
21+
}
22+
23+
$statement->execute();
24+
return true;
25+
}
26+
27+
public function prepare($sql)
28+
{
29+
return Application::$app->db->pdo->prepare($sql);
30+
31+
}
32+
}

‎core/Model.php

+14
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ abstract class Model
99
public const RULE_MIN = 'min';
1010
public const RULE_MAX = 'max';
1111
public const RULE_MATCH = 'match';
12+
public const RULE_UNIQUE = 'unique';
1213

1314
public function loadData($data)
1415
{
@@ -47,6 +48,18 @@ public function validate()
4748
if ($ruleName === self::RULE_MATCH && $value !== $this->{$rule['match']}) {
4849
$this->addError($attribute, self::RULE_MATCH, $rule);
4950
}
51+
if ($ruleName === self::RULE_UNIQUE) {
52+
$className = $rule['class'];
53+
$uniqueAttr = $rule['attribute'] ?? $attribute;
54+
$tableName = $className::tableName();
55+
$statement = Application::$app->db->prepare("SELECT * FROM $tableName WHERE $uniqueAttr = :attr");
56+
$statement->bindValue(":attr", $value);
57+
$statement->execute();
58+
$record = $statement->fetchObject();
59+
if ($record) {
60+
$this->addError($attribute, self::RULE_UNIQUE, ['field' => $attribute]);
61+
}
62+
}
5063
}
5164
}
5265
return empty($this->errors);
@@ -69,6 +82,7 @@ public function errorMessages()
6982
self::RULE_MIN => 'Min length of this field must be {min}',
7083
self::RULE_MAX => 'Max length of this field must be {max}',
7184
self::RULE_MATCH => 'This field must be the same as {match}',
85+
self::RULE_UNIQUE => 'This {field} already exists',
7286
];
7387
}
7488

‎core/Model.php~

+98
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,98 @@
1+
<?php
2+
3+
namespace app\core;
4+
5+
abstract class Model
6+
{
7+
public const RULE_REQUIRED = 'required';
8+
public const RULE_EMAIL = 'email';
9+
public const RULE_MIN = 'min';
10+
public const RULE_MAX = 'max';
11+
public const RULE_MATCH = 'match';
12+
public const RULE_UNIQUE = 'unique';
13+
14+
public function loadData($data)
15+
{
16+
foreach ($data as $key => $value) {
17+
if (property_exists($this, $key)) {
18+
$this->{$key} = $value;
19+
}
20+
}
21+
}
22+
23+
abstract public function rules(): array;
24+
25+
public array $errors = [];
26+
27+
public function validate()
28+
{
29+
foreach ($this->rules() as $attribute => $rules) {
30+
$value = $this->{$attribute};
31+
foreach ($rules as $rule) {
32+
$ruleName = $rule;
33+
if (!is_string($ruleName)) {
34+
$ruleName = $rule[0];
35+
}
36+
if ($ruleName === self::RULE_REQUIRED && !$value) {
37+
$this->addError($attribute, self::RULE_REQUIRED);
38+
}
39+
if ($ruleName === self::RULE_EMAIL && !filter_var($value, FILTER_VALIDATE_EMAIL)) {
40+
$this->addError($attribute, self::RULE_EMAIL);
41+
}
42+
if ($ruleName === self::RULE_MIN && strlen($value) < $rule['min']) {
43+
$this->addError($attribute, self::RULE_MIN, $rule);
44+
}
45+
if ($ruleName === self::RULE_MAX && strlen($value) > $rule['max']) {
46+
$this->addError($attribute, self::RULE_MAX, $rule);
47+
}
48+
if ($ruleName === self::RULE_MATCH && $value !== $this->{$rule['match']}) {
49+
$this->addError($attribute, self::RULE_MATCH, $rule);
50+
}
51+
if ($ruleName === self::RULE_UNIQUE) {
52+
$className = $rule['class'];
53+
$uniqueAttr = $rule['attribute'] ?? $attribute;
54+
$tableName = $className::tableName();
55+
$statement = Application::$app->db->prepare("SELECT * FROM $tableName WHERE $uniqueAttr = :attr");
56+
$statement->bindValue(":attr", $value);
57+
$statement->execute();
58+
$record = $statement->fetchObject();
59+
if ($record) {
60+
$this->addError($attribute, self::RULE_UNIQUE, ['field' => $record]);
61+
}
62+
}
63+
}
64+
}
65+
return empty($this->errors);
66+
}
67+
68+
public function addError(string $attribute, string $rule, $params = [])
69+
{
70+
$message = $this->errorMessages()[$rule] ?? '';
71+
foreach ($params as $key => $value) {
72+
$message = str_replace("{{$key}}", $value, $message);
73+
}
74+
$this->errors[$attribute][] = $message;
75+
}
76+
77+
public function errorMessages()
78+
{
79+
return [
80+
self::RULE_REQUIRED => 'This field is required',
81+
self::RULE_EMAIL => 'This field must be a valid email address',
82+
self::RULE_MIN => 'Min length of this field must be {min}',
83+
self::RULE_MAX => 'Max length of this field must be {max}',
84+
self::RULE_MATCH => 'This field must be the same as {match}',
85+
self::RULE_UNIQUE => 'This {field} already exists',
86+
];
87+
}
88+
89+
public function hasError($attribute)
90+
{
91+
return $this->errors[$attribute] ?? false;
92+
}
93+
94+
public function getFirstError($attribute)
95+
{
96+
return $this->errors[$attribute][0] ?? false;
97+
}
98+
}

‎core/Response.php

+5
Original file line numberDiff line numberDiff line change
@@ -9,4 +9,9 @@ public function setStatusCode(int $code)
99
{
1010
http_response_code($code);
1111
}
12+
13+
public function redirect(string $url)
14+
{
15+
header('Location: '. $url);
16+
}
1217
}

0 commit comments

Comments
 (0)