Java データベース検索でのエラー

Question

含み検索を行い、検索条件に合うデータベースの社員情報を表示したいです。
ログインしようとするとエラーになってしまい、上手くいきません。
ResultSet rs = pstmt.executeQuery();のところ
fact=Login.doLogin(con, empno, password);のところ

まだ勉強を始めたばかりで原因が全く分からないので、困っています。
また、コードが長くなってしまったのですが、もっと簡潔に書ける方法はないでしょうか。
MainSystemに追加、変更、削除がありますが、今回は検索だけなので、ここは無視してもらって大丈夫です。
よろしくお願いいたします。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;


public class MainSystem{
	public static void main(String[] args) {
		// TODO 自動生成されたメソッド・スタブ

		String jdbcUrl="jdbc:mysql://localhost/eimsdb?serverTimezone=JST";//データベースに接続するためのURL
		String user="eimsuser";//データベースに接続するためのユーザ名
		String passwd="eimspass";//データベースに接続するためパスワード


		try(Connection con = DriverManager.getConnection(jdbcUrl,user,passwd)){

			boolean fact=true;
			while(fact) {
				ArrayList<String> inf =LoginGamen.getLoginInfo();
				int empno = Integer.parseInt(inf.get(0));
				String password=inf.get(1);

				fact=Login.doLogin(con, empno, password); //★at MainSystem.main(MainSystem.java:24)
			}

			fact=true;
			String function;
			if(Login.getDeptname().equals("人事部")){
				JinjiDAO jinji =new JinjiDAO(con);
				while(fact) {
					function = JinjiDAO.showFunctions();
					if(function.equals("検索")) {
						ArrayList<Syain> syain =jinji.dokensaku();

						for(Syain s : syain) {
							System.out.println(s);
						}

					}else if(function.equals("追加")) {

					}else if(function.equals("削除")) {

					}else if(function.equals("変更")) {

					}

				}

			}else {
				SyainDAO syain = new SyainDAO(con);
				while(fact) {
					function=SyainDAO.showFunctions();
					if(function.equals("検索")) {
						ArrayList<Syain> sList =syain.dokensaku();

						for(Syain s : sList) {
							System.out.println(s);
						}
					}


				}
			}
		}catch(SQLException e) {
			e.printStackTrace();
		}

	}

}

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Login {
   private static String deptname;

   public static boolean doLogin(Connection con, int empno, String password) {
	String sql = "SELECT * FROM emproyee e JOIN department d on e.deptno = d.deptno WHERE empno = ? and password = ?";
	boolean fact = true;
	try {
	PreparedStatement pstmt = con.prepareStatement(sql);
	pstmt.setInt(1,empno);
	pstmt.setString(2,password);
	ResultSet rs = pstmt.executeQuery(); //★at MainSystem.main(MainSystem.java:24) 

	//false = ログイン成功
	if(rs.next()==true) {
		System.out.println("ログインに成功しました");
		deptname=rs.getString("deptname");
		fact = false;
	}else {
		System.out.println("ログインに失敗しました。入力しなおしてください");
		fact = true;
		}
   }catch(SQLException e) {
	   e.printStackTrace();
   }
   return fact;
   }
   public static String getDeptname() {
		return deptname;
}
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;

public class LoginGamen {

	/*
	 * メソッド名：ログイン情報の取得
	 * 引数：なし
	 * 戻り値：入力されたログインに必要な社員情報（社員番号、パスワード）
	 */
	public static ArrayList<String> getLoginInfo() {
		ArrayList <String> inf = new ArrayList<>();
		try {
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
			System.out.println("社員番号を入力してください");
			System.out.printf("->社員番号：");
			inf.add(br.readLine());
			System.out.println("パスワードを入力してください");
			System.out.printf("->パスワード：");
			inf.add(br.readLine());

		}catch(IOException e) {
			e.printStackTrace();
		}
		return inf;
	}
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

public class SyainDAO {
	private Connection con = null;

	public static String showFunctions() {
		String function=null;
		try {
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
			while(true) {
				System.out.println("その他社員用機能一覧");
				System.out.println("->検索");
				System.out.println("どの処理を実行しますか？行う処理を入力してください。");
				System.out.printf("->行う処理：");
				function =br.readLine();
				if(function.equals("検索")) {
					break;
				}else {
					System.out.println("正しい機能を入力してください");
				}
			}
		}catch(IOException e) {
			e.printStackTrace();
		}
		return function;
	}

	public SyainDAO(Connection con) {
		this.con = con;
	}

	public ArrayList<Syain> dokensaku() {　//メソッド名：社員情報の検索
		ArrayList<Syain> syainList = new ArrayList<>();
		String sql = Kensaku.createSql();
		PreparedStatement pStmt = null;

		try {
			pStmt = con.prepareStatement(sql);
			ResultSet rs =pStmt.executeQuery();
			while (rs.next()) {
				int empno = rs.getInt("emp_no");
				String lname = rs.getString("l_name");
				String fname = rs.getString("f_name");
				String lkana = rs.getString("l_kana");
				String fkana = rs.getString("f_kana");
				String password = rs.getString("pass_word");
				int gender = rs.getInt("gen_der");
				int deptno = rs.getInt("dept_no");
				String deptname = rs.getString("dept_name");

				Busyo busyo = new Busyo(deptno, deptname);
				syainList.add(new Syain(empno, lname, fname, lkana, fkana, password, gender, deptno, busyo));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}

		if(syainList.size()==0) {
			System.out.println("入力された社員は存在しません");
		}

		return syainList;
	}
}

//社員情報を格納するTO

public class Syain {
	private int empno;
	private String lname;
	private String fname;
	private String lkana;
	private String fkana;
	private String password;
	private int gender;
	private int deptno;
	private Busyo busyo;

	public Syain(int empno, String lname, String fname, String lkana, String fkana, String password, int gender, int deptno, Busyo busyo) {
		this.empno = empno;
		this.lname = lname;
		this.fname = fname;
		this.lkana = lkana;
		this.fkana = fkana;
		this.password = password;
		this.gender = gender;
		this.deptno = deptno;
		this.busyo = busyo;
	}


	//empno
	public int getEmpno() {
		return empno;
	}

	//lname
	public String getLname() {
		return lname;
	}

	//fname
	public String getFname() {
		return fname;
	}

	//lkana
	public String getLkana() {
		return lkana;
	}

	//fkana
	public String getFkana() {
		return fkana;
	}

	//password
	public String getPassword() {
		return password;
	}

	//gender
	public int getGender() {
		return gender;
	}

	//deptno
	public int getDeptno() {
		return deptno;
	}

	//deptname
	public String getDeptname() {
		return busyo.getDeptname();
	}

	public String toString() {
		return getEmpno() + getLname() + " " + getFname() + "(" +getLkana() + " " + getFkana() + ")" + getDeptname();
	}
}

//JinjiDAO
SyainDAOの継承

//Jinji
Syainとほぼ同じ

//検索機能
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class Kensaku {

	public static String createSql() {
	StringBuilder sql = new StringBuilder();
	sql.append("SELECT e.empno, e.lname, e.fname, e.lkana, e.fkana, e.password, e.gender, e.deptno, d.deptname FROM employee e JOIN department d ON e.deptno = d.deptno WHERE");

	//入力されていればwhere句で連結、されなければスキップ
	try {
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
		boolean flag = false;

		System.out.print("氏");
		System.out.println("->");
		String lname = br.readLine();
		if (lname.equals("")) {
			sql.append("lname like '%" + lname + "%'");
			flag = true;
		}

		System.out.print("名");
		System.out.println("->");
		String fname = br.readLine();
		if (lname.equals("")) {
			if(!flag){
			sql.append("fname like '%" + fname + "%'");
			flag = true;
			}else {
			sql.append("and fname like '%" + fname + "%'");
			}
		}

		System.out.print("氏（カナ）");
		System.out.println("->");
		String lkana = br.readLine();
		if (lkana.equals("")) {
			if(!flag){
			sql.append("lkana like '%" + lkana + "%'");
			flag = true;
			}else {
			sql.append("and lkana like '%" + lkana + "%'");
			}
		}

		System.out.print("名（カナ）");
		System.out.println("->");
		String fkana = br.readLine();
		if (fkana.equals("")) {
			if(!flag){
			sql.append("fkana like '%" + fkana + "%'");
			flag = true;
			}else {
			sql.append("and fkana like '%" + fkana + "%'");
			}
		}

		System.out.print("部署名");
		System.out.println("->");
		String deptname = br.readLine();
		if (deptname.equals("")) {
			if(!flag){
			sql.append("deptname like '%" + deptname + "%'");
			flag = true;
			}else {
			sql.append("and fdeptname like '%" + deptname + "%'");
			}
		}

		System.out.print("部署コード");
		System.out.println("->");
		String deptno = br.readLine();
		if (deptno.equals("")) {
			if(!flag){
			sql.append("deptno like '%" + deptno + "%'");
			flag = true;
			}else {
			sql.append("and deptno like '%" + deptno + "%'");
			}
		}
	}catch(IOException e) {
		e.printStackTrace();
	}
	return sql.toString();
	}
}

Answer 1

そのメッセージには、eimsdbというデータベースのemproyeeテーブルが見つからない、と書いてあります。
MySQLにあるデータベース、テーブルの名前はそれで合っていますか？
（※"employee"の間違いではないでしょうか）

Comments

[lemon1027]

ありがとうございます。スペルミスを直してログインはできました。
しかし、実際に検索機能をしたら新しいエラーが出てきてしまいました・・・。

java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'WHERElname like '%%'and fname like '%%'and lkana like '%%'and fkana like '%%'and' at line 1
入力された社員は存在しません
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:953)
at com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:1003)
at SyainDAO.dokensaku(SyainDAO.java:47)
at MainSystem.main(MainSystem.java:34)

at SyainDAO.dokensaku(SyainDAO.java:47)→ResultSet rs =pStmt.executeQuery();のところ
at MainSystem.main(MainSystem.java:34)→ArrayList<Syain> syain =jinji.dokensaku();のところ

[hallen0225]

そのエラーメッセージの内容は分かりましたか？
「新しいエラーが出てきました」ではなく、その内容を調べて、そのうえで分からなかったら「このエラーはどういう意味ですか？」という質問をされた方がよいです。

[lemon1027]

SQL文が違うと思っていろいろ試してみたのですが、上手く動きませんでした。

[hallen0225]

「SQL文が違う」ことはあっています。
'WHERElname like '%%'and fname like '%%'and lkana like '%%'and fkana like '%%'and'の部分に間違いがあると書いてあるのですが、まず分かりやすいものが1つありますね。"WHERE"の後にスペースがありません。
あと、"lkana like '%%'"のようなものは、その検索項目に文字列が入力されているときに挿入したいのだと思うのですが、今は文字列が「入力されていない」ときに挿入されてしまっていますね。

[lemon1027]

WHEREは自力で気づくことができたのですが、後者は全然気づかなくて勉強不足だと思いました・・・。
なんとかエラーが出ずに検索実行まで行けたのですが、今度は検索条件を入れても条件に当てはまらない社員まで表示されてしまいます。自分なりに考えてみたのですが、やはり、まだSQL文がおかしいのでしょうか。
現在のSQL文は↓のような感じです。

sql.append("Select　e.empno,e.lname,e.fname,e.lkana,e.fkana,e.password,e.gender,e.deptno,d.deptname from employee e join department d on e.deptno =d.deptno where");

//入力されていればwhere句で連結、されなければスキップ
try {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
boolean flag = false;

System.out.print("氏");
System.out.println("->");
String lname = br.readLine();
if (lname.equals("")) {
sql.append(" lname like \"%"+ lname +"%\"");
flag = true;
}

System.out.print("名");
System.out.println("->");
String fname = br.readLine();
if (lname.equals("")) {
if(flag == false){
sql.append(" fname like '%" + fname + "%'");
flag = true;
}else {
sql.append(" and fname like '%" + fname + "%'");
}
}・・・

[hallen0225]

先ほどお伝えした、
> "lkana like '%%'"のようなものは、その検索項目に文字列が入力されているときに挿入したいのだと思うのですが、今は文字列が「入力されていない」ときに挿入されてしまっていますね。

の部分が修正されていません。
"if (lname.equals("")) {...}"の中身は、lnameが「空白のとき」しか実行されないのでこういうことになります。

[lemon1027]

申し訳ありません。色々付け加えたり戻したりしていたら、気付かない間に消えてしまっていたようです。
無事完成することが出来ました。
夜遅くまでありがとうございます。
今日1日中頑張ってもなかなかできなかったので、本当に嬉しいです！
プログラミング自体慣れておらず、ミスに全然気づけなかったので、これからはもっと注意深くコードを見たいと思います。

[hallen0225]

ともあれ、上手くいって良かったです。
ただ、「何故動くようになったか」は考えるようにしてくださいね。それがないと、同じような間違いをずっと繰り返してしまうので。