Cоединение сайта с сервером

Здравствуйте! Я новичок в PHP. Писал систему логина и регистрации с помощью PHP MySQL и сессий. Использую MAMP для создания внутреннего сервера и PHPMYAdmin для создания таблиц и датабаз. Для самого сайта использую Phpstorm. Вроде все написал, однако на стадии проверки на наличие логина и пароля в таблице все идет не так. С кодом вроде бы все в порядке, синтаксических ошибок нет, логических вроде тоже. Внизу сам код для login.php и register.php а также подключение к датабазе db.php
db.php:

PHP:

1. <?php
2. $servername = "localhost";
3. $username = "root";
4. $password = "root123";
5. $db = 'Trains';
6. // Create connection
7. $conn = mysqli_connect($servername, $username, $password, $db);
8.  
9. // Check connection
10. if ($conn->connect_error) {
11.     die("Connection failed: " . $conn->connect_error);
12. } else{
13.     echo "Connected to server successfully";
14. }
15.  
16. ?>

login.php:

PHP:

1. <?php
2. include("db.php");
3. if(isset($_SESSION['login_user'])){
4.     header("location: welcome.php");
5. }
6. session_start();
7. $error = '';
8. if (isset($_POST['submit'])) {
9.     if (empty($_POST['username']) or empty($_POST['password'])) {
10.         $error = "Please enter your login details";
11.     } else {
12.  
13.         $username = mysqli_real_escape_string($conn, $_POST['username']);
14.         $password = $_POST['password'];
15.  
16.  
17.  
18.         $query = mysqli_query($conn, "SELECT * FROM workers WHERE user_name =$username, AND  password = MD5($password) ");
19.         $rows = mysqli_num_rows($query);
20.         if ($rows == 1) {
21.             $_SESSION['login_user'] = $username;
22.             header('welcome.php');
23.         } else {
24.             $error = "Username or Password is invalid";
25.         }
26.  
27.     }
28. }
29. ?>

Вместе с login.php идет HTML код для формы , но я думаю тут не в нем проблема. После ввода информации в login.php , всегда возвращается ошибка $error = "Username or Password is invalid", следовательно проблема в $query но найти никак не могу.
Почти тоже самое происходит и в register.php

PHP:

1. <?php
2. if( isset($_SESSION['login_user'])!="" ){
3.     header("Location: welcome.php");
4. }
5.  
6. include_once ('db.php');
7. session_start();
8.  
9.  
10.  
11.  
12.  
13. $error = false;
14. $nameError = '';
15. $passwordError = '';
16. $usernameError = '';
17. $surnameError = '';
18. $emailError = '';
19. $MSG = '';
20.  
21. if ( isset($_POST['Register']) ) {
22.  
23.     // clean user inputs to prevent sql injections
24.     $name = trim($_POST['name']);
25.     $name = strip_tags($name);
26.     $name = htmlspecialchars($name);
27.  
28.     $surname = trim($_POST['surname']);
29.     $surname = strip_tags($surname);
30.     $surname = htmlspecialchars($surname);
31.  
32.     $email = trim($_POST['email']);
33.     $email = strip_tags($email);
34.     $email = htmlspecialchars($email);
35.  
36.     $password = trim($_POST['password']);
37.     $password = strip_tags($password);
38.     $password = htmlspecialchars($password);
39.  
40.     $username = trim($_POST['username']);
41.     $username = strip_tags($username);
42.     $username = htmlspecialchars($username);
43.     // Username validation
44.     if(empty($username)){
45.         $error = true;
46.         $usernameError = 'Please enter your username';
47.     }else {
48.         if (!preg_match('/^[a-zA-Z0-9]{5,}$/', $username)) {
49.             $error = true;
50.             $usernameError = 'Invalid Username';
51.         }
52.     }
53.     //Name validation
54.     if (empty($name)) {
55.         $error = true;
56.         $nameError = "Please enter your full name.";
57.     } else if (strlen($name) < 3) {
58.         $error = true;
59.         $nameError = "Name must have at least 3 characters.";
60.     } else if (!preg_match("/^[a-zA-Z ]+$/",$name)) {
61.         $error = true;
62.         $nameError = "Name must contain alphabets and space.";
63.     }
64.     //surname validation
65.     if (empty($surname)){
66.         $error = true;
67.         $surnameError = "Please enter your surname";
68.     } else if (strlen($surname)< 3) {
69.         $error = true;
70.         $surnameError = "Surname must have at least 3 characters";
71.     } else if (!preg_match("/^[a-zA-Z ]+$/",$surname)){
72.         $error = true;
73.         $surnameError = "Surname must contain alphabets";
74.     }
75.  
76.  
77.     //basic email validation
78.     if ( !filter_var($email,FILTER_VALIDATE_EMAIL) ) {
79.         $error = true;
80.         $emailError = "Please enter valid email";
81.     } else {
82.         // check email exist or not
83.         $query = "SELECT email FROM workers WHERE email='$email'";
84.         $result = mysqli_query($conn,$query);
85.         $count = mysqli_num_rows($result);
86.         if($count!=0){
87.             $error = true;
88.             $emailError = "Provided Email is already in use.";
89.         }
90.     }
91.     // password validation
92.     if (empty($password)){
93.         $error = true;
94.         $passwordError = "Please enter password.";
95.     } else if(strlen($password) < 6) {
96.         $error = true;
97.         $passwordError = "Password has to be at least 6 charachters long";
98.     }
99.  
100.     // password encrypt using MD5();
101.     $password = MD5($password);
102.  
103.  
104.  
105.     // if there's no error, continue to signup
106.     if( !$error ) {
107.         $query = mysqli_query($conn,"INSERT INTO workers(id,user_name,password,email,surname,name) VALUES(NULL ,$username,$password,$email,$surname,$name)");
108.  
109.  
110.         if ($query) {
111.             $MSG= "Successfully registered, you may login now";
112.             unset($name);
113.             unset($email);
114.             unset($password);
115.             unset($name);
116.             unset($surname);
117.  
118.         } else {
119.             $MSG = "Something went wrong, try again later...";
120.         }
121.  
122.     }
123.  
124.  
125. }
126. ?>

Здесь все время выводит $MSG следовательно опять проблема в query. Надеюсь на вашу помощь!

 

Спасибо за замечания. Исправил login.php и register.php. Добавил prepared statement в login.php. Теперь при правельном вводе обновляется страница , а не переходит в welcome.php.
login.php

PHP:

1. <?php
2. include("db.php");
3. session_start();
4. if(isset($_SESSION['login_user'])){
5.     header("location: welcome.php");
6. }
7.  
8. $error = '';
9. if (isset($_POST['submit'])) {
10.     if (empty($_POST['username']) or empty($_POST['password'])) {
11.         $error = "Please enter your login details";
12.     } else {
13.  
14.         $username = mysqli_real_escape_string($conn, $_POST['username']);
15.         $password = md5($_POST['password']);
16.  
17.  
18.  
19.         $query = mysqli_prepare($conn, "SELECT password FROM workers WHERE user_name=?");
20.         if ($query){
21.             mysqli_stmt_bind_param($query,"s",$username);
22.             mysqli_stmt_execute($query);
23.             mysqli_stmt_bind_result($query,$pass);
24.             mysqli_stmt_fetch($query);
25.             if ($password == $pass){
26.                 $_SESSION['login_user'] = $username;
27.                 header('welcome.php');
28.             }else{
29.                 $error = "You typed the wrong password";
30.                 unset($username,$password);
31.  
32.  
33.             }
34.         }else{
35.             $error = "User Login doesn't exists";
36.             unset($username,$password);
37.         }
38.  
39.     }
40. }

register.php

Код (Text):

1. <?php
2. session_start();
3. if( isset($_SESSION['login_user'])!="" ){
4.     header("Location: welcome.php");
5. }
6.  
7. include_once ('db.php');
8.  
9. $error = false;
10. $nameError = '';
11. $passwordError = '';
12. $usernameError = '';
13. $surnameError = '';
14. $emailError = '';
15. $MSG = '';
16.  
17. if ( isset($_POST['Register']) ) {
18.  
19.  
20.     $name = $_POST['name'];
21.     $name = mysqli_real_escape_string($conn,$name);
22.     $surname = ($_POST['surname']);
23.     $surname = mysqli_real_escape_string($conn,$name);
24.     $email = $_POST['email'];
25.     $email = mysqli_real_escape_string($conn,$name);
26.     $password = $_POST['password'];
27.     $password = mysqli_real_escape_string($conn,$password);
28.     $username = $_POST['username'];
29.     $username = mysqli_real_escape_string($conn,$username);
30.  
31.     // Username validation
32.     if(empty($username)){
33.         $error = true;
34.         $usernameError = 'Please enter your username';
35.     }else {
36.         if (!preg_match('/^[a-zA-Z0-9]{5,}$/', $username)) {
37.             $error = true;
38.             $usernameError = 'Invalid Username';
39.         }
40.     }
41.     //Name validation
42.     if (empty($name)) {
43.         $error = true;
44.         $nameError = "Please enter your full name.";
45.     } else if (strlen($name) < 3) {
46.         $error = true;
47.         $nameError = "Name must have at least 3 characters.";
48.     } else if (!preg_match("/^[a-zA-Z ]+$/",$name)) {
49.         $error = true;
50.         $nameError = "Name must contain alphabets and space.";
51.     }
52.     //surname validation
53.     if (empty($surname)){
54.         $error = true;
55.         $surnameError = "Please enter your surname";
56.     } else if (strlen($surname)< 3) {
57.         $error = true;
58.         $surnameError = "Surname must have at least 3 characters";
59.     } else if (!preg_match("/^[a-zA-Z ]+$/",$surname)){
60.         $error = true;
61.         $surnameError = "Surname must contain alphabets";
62.     }
63.  
64.  
65.     //basic email validation
66.     if ( !filter_var($email,FILTER_VALIDATE_EMAIL) ) {
67.         $error = true;
68.         $emailError = "Please enter valid email";
69.     } else {
70.         // check email exist or not
71.         $query = "SELECT email FROM workers WHERE email='$email'";
72.         $result = mysqli_query($conn,$query);
73.         $count = mysqli_num_rows($result);
74.         if($count!=0){
75.             $error = true;
76.             $emailError = "Provided Email is already in use.";
77.         }
78.     }
79.     // password validation
80.     if (empty($password)){
81.         $error = true;
82.         $passwordError = "Please enter password.";
83.     } else if(strlen($password) < 6) {
84.         $error = true;
85.         $passwordError = "Password has to be at least 6 charachters long";
86.     }
87.  
88.     // password encrypt using MD5();
89.     $password = MD5($password);
90.  
91.  
92.  
93.     // if there's no error, continue to signup
94.     if( !$error ) {
95.         $query = mysqli_query($conn,"INSERT INTO workers(id,user_name,password,email,surname,name) VALUES(NULL ,$username,$password,$email,$surname,$name)");
96.  
97.  
98.         if ($query !== false) {
99.             $MSG= "Successfully registered, you may login now";
100.             unset($name);
101.             unset($email);
102.             unset($password);
103.             unset($name);
104.             unset($surname);
105.  
106.         } else {
107.             $MSG = "Something went wrong, try again later...";
108.         }
109.  
110.     }
111.  
112.  
113. }
114. ?>

Здесь сheck.php который должен проверять залогинился ли юзер.

PHP:

1. <?php
2. include('db.php');
3. session_start();
4. $user_check=$_SESSION['login_user'];
5.  
6. $sql = mysqli_query($conn,"SELECT user_name FROM workers WHERE user_name='$user_check' ");
7.  
8. $row=mysqli_fetch_array($sql,MYSQLI_ASSOC);
9.  
10. $login_user=$row['user_name'];
11.  
12. if(!isset($user_check))
13. {
14.     header("Location: login.php");
15. }
16. ?>