検索条件に合う社員情報を表示

Question

含み検索を行い、検索条件に合うデータベースの社員情報を表示したいです。
Mainを実行したところ、なぜか二回検索条件を聞かれるうえに、検索もうまくできません。
まだ勉強したばかりで、どこが間違えているのか、なにがわかっていないのかよくわかりません・・・。
とても困っています。よろしくお願いいたします。

//SyainDAO
//社員に関するクラス
//検索条件に当てはます社員情報をリストとして戻す
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 SyainDAO(Connection con) {
		this.con = con;
	}

	public ArrayList<Syain> dokensaku() {
		ArrayList<Syain> syainList = new ArrayList<>();
		String sql = Kensaku.createSql(); //Kensakuで作成したSQL
		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;
	}
}

 //SyainTO
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();
	}
}

//Kensaku
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();
	}
}

//Main
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) {
        //データベースに接続
	String jdbcUrl =
		"jdbc:mysql://localhost/eimsdb?serverTimezone=JST";
	String userId = "eimsuser";
	String pass = "eimspass";

				try(Connection con = DriverManager.getConnection(jdbcUrl, userId, pass)){

					SyainDAO syain = new SyainDAO(con);
					Kensaku.createSql();
					ArrayList<Syain> sList = syain.dokensaku();

					for(Syain s :sList) {
						System.out.println(s);
					}
				}catch (SQLException e) {
					e.printStackTrace();
				}
	}
}

//Busyo
public class Busyo {
	private int deptno;
	private String deptname;

	public Busyo(int deptno, String deptname) {
		this.deptno = deptno;
		this.deptname = deptname;
	}

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

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

}

Answer 1

検索もうまくできません。

・全ての条件が無い時でもwhereが指定される。
・and +← +が文字列に含まれている。

※全てにandを付加しておいて、最後に先頭のandを除去するようにすると、2重に記述する必要は無くなります。

Comments

[lemon1027]

たしかにそうですね・・・見落としていました。
回答していただきありがとうございます！

Answer 2

検索条件を聞くのは Kensaku.createSql()メソッド

Main.javaで 以下の2行目で一回 これは何も受け取っていないから不要処理かな。
３行目のsyain.dokensaku()メソッド2行でも String sql = Kensaku.createSql(); を実行してるので2回聞かれるのだと思います

                    SyainDAO syain = new SyainDAO(con);
                    Kensaku.createSql();
                    ArrayList<Syain> sList = syain.dokensaku();

検索がうまくできないことについては未確認