Add files via upload

Account.java

@@ -17,19 +17,23 @@ public void setUsername() {
         Scanner input = new Scanner(System.in);
         System.out.print("Enter your username:");
         this.username = input.nextLine();
-        if(username.length()>20)
+        while(username.length()>20) {
         System.out.println("Your username should contain only 20 characters ");
-        setUsername();
+        this.username = input.nextLine();
+        }
+
 
     }
     //o xrhsths eisagei ton kwdiko tou
     public void setPassword() {
         Scanner input = new Scanner(System.in);
         System.out.print("Enter your password:");
             this.password= input.nextLine();
-            if(password.length()>15)
+
+            while (password.length()>15) {
             System.out.println("Your password should contain only 15 characters ");
-            setPassword();
+            this.password= input.nextLine();
+            }
     }
     // epistefei to username 
     public String getUsername() {
@@ -89,19 +93,30 @@ public int addAccount(String username,String password) {
         return result;
     }
 //ginetai eisodos efoson yparxei aytos o logariasmos
-    public void verifyAccount(String username,String password) {
-        
+
+    public boolean verifyAccount(String username,String password) {
         ResultSet rs=null;
+        boolean checkAccount = false;
+
         try {
          findAccount.setString(1, username);
          findAccount.setString(2, password);   
             rs=findAccount.executeQuery();
-            int count=0;
 
-    while(rs.next()) {
-        count = count + 1;
+           // int count=0;
+
+    if(rs.next()) {
+        //count = count + 1;
+        checkAccount=true;
+    }
+} catch (SQLException sqlException) {
+    System.out.println(sqlException);
+    close();
+}
+return checkAccount;
     }
-    if (count==1) {
+    /*if (count==1) {
+
         String ur=getUsername(); 
         System.out.println("Sign In Successfull");
         System.out.println("Hello " + ur);
@@ -122,7 +137,9 @@ public void verifyAccount(String username,String password) {
     }
 }
 
-        }
+
+        }*/
+
 
 
         public void close() {

AccountTest.java

@@ -0,0 +1,16 @@
+import org.junit.Test;
+import static org.junit.Assert.assertEquals;
+
+public class AccountTest {
+    @Test
+    public void testAddAccount() {
+        // setup
+        Account account = new Account();
+
+        // exercise
+        int result = account.addAccount("testuser", "testpass");
+
+        // verify
+        assertEquals(1, result);
+    }
+}

Dislikes.java

@@ -0,0 +1,106 @@
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public class Dislikes {
+		Connection conn = null;
+		Statement st = null;
+		ResultSet rs = null;
+	    String SQL_statement = null;
+		Message message;
+
+		public String dislikedUser(int y) {
+			connectDB();
+			String dislkduser = null;
+			y =+ 1002;
+			SQL_statement = "SELECT sender FROM Messages WHERE message_id = " + y +";";
+			try {
+				if (conn != null ) {
+					st = conn.createStatement();
+					rs = st.executeQuery(SQL_statement);
+					dislkduser = rs.getString("sender");
+					st.close();
+					rs.close();
+
+				}
+			}catch (SQLException e){
+					System.out.println("SQL statement exception" + e);
+			}
+			return dislkduser;
+		}
+
+	       public String messageBody(int y) {
+				connectDB();
+				String msgbody = null;
+				y =+ 1002;
+				SQL_statement = "SELECT message_body FROM Messages WHERE message_id = " + y + ";";
+				try {
+					if (conn != null ) {
+						st = conn.createStatement();
+						rs = st.executeQuery(SQL_statement);
+						msgbody = rs.getString("message_body");
+						st.close();
+						rs.close();
+						}
+				}catch (SQLException e) {
+						System.out.println("SQL statement exception" + e);
+				}
+				return msgbody;
+		}
+
+
+
+
+		public int dislikeCounter(int y) {
+			connectDB();
+			int d = -1;
+	    	SQL_statement =" SELECT COUNT(*) FROM Dislikes WHERE message_id=" + y + ";";
+	    	try {
+				if (conn != null ) {
+					st = conn.createStatement();
+					rs = st.executeQuery(SQL_statement);
+					d = rs.getInt("COUNT");
+					st.close();
+					rs.close();
+		        }
+			} catch (SQLException e) {
+				System.out.println("SQL statement exception" + e);
+			}
+			return d;
+		}
+
+
+
+		public void updateDislikes(String username, String dislikedName, int y) {
+			connectDB();
+			SQL_statement = "INSERT INTO Dislikes(message_id,disliked_user,disliker) VALUES('" + y + "','" + dislikedName + "','" + username + "');";
+			try {
+				if (conn != null ) {
+					st = conn.createStatement();
+					st.executeUpdate(SQL_statement);
+					String answer = messageBody(y);
+					message.updateMessages(username,answer,-2);
+					st.close();
+				}
+			} catch (SQLException e) {
+				System.out.println("SQL statement exception" + e);
+			}
+		}
+
+
+		public void connectDB() {
+			try {
+				Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
+				Connection conn = DriverManager.getConnection(
+						"jdbc:sqlserver://DESKTOP-NVDOEDC:1433;"
+						+ "DatabaseName=Codecom;encrypt=true;trustServerCertificate=true;", "Progr2", "programmatismos2");
+			} catch (Exception e) {
+						System.err.println("Connection failed");
+			}
+		}
+
+
+
+}

Likes.java

@@ -0,0 +1,106 @@
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+public class Likes {
+
+	Connection conn = null;
+	Statement st = null;
+	ResultSet rs = null;
+    String SQL_statement = null;
+    Message message;
+
+	public String likedUser(int y) {
+		connectDB();
+		String lkduser = null;
+		y =+ 1002;
+		SQL_statement = "SELECT sender FROM Messages WHERE message_id = " + y + ";";
+		try {
+			if (conn != null ) {
+				st = conn.createStatement();
+				rs = st.executeQuery(SQL_statement);
+				lkduser = rs.getString("sender");
+				st.close();
+				rs.close();
+			}
+		}catch (SQLException e){
+				System.out.println("SQL statement exception" + e);
+		}
+			return lkduser;
+	}
+
+
+
+	public String messageBody(int y) {
+		connectDB();
+		String msgbody = null;
+		y =+ 1002;
+		SQL_statement = "SELECT message_body FROM Messages WHERE message_id = " + y + ";";
+		try {
+			if (conn != null ) {
+				st = conn.createStatement();
+				rs = st.executeQuery(SQL_statement);
+				msgbody = rs.getString("message_body");
+				st.close();
+				rs.close();
+				}
+		}catch (SQLException e) {
+				System.out.println("SQL statement exception" + e);
+		}
+		return msgbody;
+	}
+
+
+
+	public int likeCounter(int y) {
+		connectDB();
+		int d = -1;
+    	SQL_statement =" SELECT COUNT(*) FROM Likes WHERE message_id=" + y + ";";
+    	try {
+			if (conn != null ) {
+				st = conn.createStatement();
+				rs = st.executeQuery(SQL_statement);
+				d = rs.getInt("COUNT");
+				st.close();
+				rs.close();
+	        }
+		}catch (SQLException e) {
+			System.out.println("SQL statement exception" + e);
+		}
+		return d;
+	}
+
+
+
+	public void updateLikes(String username, String likedname, int y) {
+		connectDB();
+		SQL_statement = "INSERT INTO Likes(message_id,liked_user,liker) VALUES('" + y + "','" + likedname + "','" + username + "');";
+		try {
+			if (conn != null ) {
+				st = conn.createStatement();
+				st.executeUpdate(SQL_statement);
+				String answer = messageBody(y);
+				message.updateMessages(username,answer,-1);
+				st.close();
+			}
+		} catch (SQLException e) {
+			System.out.println("SQL statement exception" + e);
+		}
+	}
+
+
+	public void connectDB() {
+		try {
+			Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
+			Connection conn = DriverManager.getConnection(
+					"jdbc:sqlserver://DESKTOP-NVDOEDC:1433;"
+					+ "DatabaseName=Codecom;encrypt=true;trustServerCertificate=true;", "Progr2", "programmatismos2");
+		} catch (Exception e) {
+					System.err.println("Connection failed");
+		}
+	}
+
+
+}

Likestest.java

@@ -0,0 +1,42 @@
+import static org.junit.Assert.*;
+import org.junit.Test;
+
+public class TestLikes {
+
+    @Test
+    public void testLikedUser() {
+        Likes like = new Likes();
+        String expected = "John";
+        String actual = like.likedUser(1);
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testMessageBody() {
+        Likes like = new Likes();
+        String expected = "Hello World!";
+        String actual = like.messageBody(1);
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testLikeCounter() {
+        Likes like = new Likes();
+        int expected = 3;
+        int actual = like.likeCounter(1);
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    public void testUpdateLikes() {
+    Likes like = new Likes();
+    String username = "Maria";
+    String likedname = "John";
+    int y = 1;
+    int expected = 4;
+    like.updateLikes(username, likedname, y);
+    int actual = like.likeCounter(1);
+    assertEquals(expected, actual);
+    }
+
+}

Logout.java

@@ -0,0 +1,33 @@
+import java.util.Scanner;
+public class Logout {
+
+	Scanner input = new Scanner(System.in);
+	boolean flag;
+
+	public boolean getLogout(String answer) {
+		if (answer.equals("y") || answer.equals("Y")) {
+			System.out.println("Bye.. Hope you liked our app");
+			flag = true;
+		} else 	if (answer.equals("N") || answer.equals("n")) {
+			flag = false;
+		} else {
+			falseInput();
+		}
+		return flag;
+	} // close getLogout
+
+
+	public boolean falseInput() {
+		System.out.println("Please type correctly!! (Y/N)");
+		 String ans = input.next();
+		if (ans.equals("N") || ans.equals("n")) {
+			flag = false;
+		} else if (ans.equals("y") || ans.equals("Y")) {
+			flag = true;
+		} else {
+			falseInput();
+		} //close if
+		return flag;
+	} // close falseInput
+
+} // close classs