3 Commits

Author SHA1 Message Date
d8d9f1d9b7 提出物です 2026-09-30 16:24:35 +09:00
65ff97be06 2段階目終わりました。 2026-09-30 13:43:50 +09:00
bb5df7baad 1段階目終了しました 2026-09-30 11:26:04 +09:00
5 changed files with 56 additions and 17 deletions

View File

@@ -61,7 +61,6 @@ public class EmployeeDAO {
this.stmt = con.prepareStatement(sql.toString()); this.stmt = con.prepareStatement(sql.toString());
rs = stmt.executeQuery(); rs = stmt.executeQuery();
while (rs.next()) { while (rs.next()) {
//インスタンス生成
EmployeeDTO dto = new EmployeeDTO(); EmployeeDTO dto = new EmployeeDTO();
dto.setId_employee(rs.getInt("id_employee")); dto.setId_employee(rs.getInt("id_employee"));
dto.setNm_employee(rs.getString("nm_employee")); dto.setNm_employee(rs.getString("nm_employee"));
@@ -72,9 +71,37 @@ public class EmployeeDAO {
rtnList.add(dto); rtnList.add(dto);
} }
} finally { } finally {
DbUtil.closeStatement(this.stmt); DbUtil.closestatement(this.stmt);
} }
return rtnList; return rtnList;
} }
public List<EmployeeDTO> selectById(int id_employee) throws SQLException, ClassNotFoundException {
List<EmployeeDTO> rtnList2 = new ArrayList<>();
StringBuilder sql = new StringBuilder();
sql.append(" SELECT ");
sql.append(" " + "*");
sql.append(" FROM ");
sql.append(" " + TBL_NAME);
sql.append(" WHERE " + ID_EMPLOYEE+ "=?");
try {
this.stmt = con.prepareStatement(sql.toString());
rs = stmt.executeQuery();
while (rs.next()) {
EmployeeDTO dto = new EmployeeDTO();
dto.setId_employee(rs.getInt("id_employee"));
dto.setNm_employee(rs.getString("nm_employee"));
dto.setKn_employee(rs.getString("kn_employee"));
dto.setMail_address(rs.getString("mail_address"));
dto.setPassword(rs.getString("password"));
dto.setId_department(rs.getInt("id_department"));
rtnList2.add(dto);
}
} finally {
DbUtil.closestatement(this.stmt);
}
return rtnList2;
}
} }

View File

@@ -1,15 +1,14 @@
package com.rhizome.example.dto; package com.rhizome.example.dto;
public class EmployeeDTO { public class EmployeeDTO {
//フィールド宣言
private Integer id_employee;//社員ID
private String nm_employee;//社員名
private String kn_employee;//社員名カナ
private String mail_address;//メールアドレス
private String password;//パスワード
private Integer id_department;//部署ID
//getter/setter private Integer id_employee;
private String nm_employee;
private String kn_employee;
private String mail_address;
private String password;
private Integer id_department;
public Integer getId_employee() { public Integer getId_employee() {
return id_employee; return id_employee;
} }
@@ -58,4 +57,13 @@ public class EmployeeDTO {
this.id_department = id_department; this.id_department = id_department;
} }
public String toString() {
return id_employee + "\t"
+ nm_employee + "\t"
+ kn_employee + "\t"
+ mail_address + "\t"
+ password + "\t"
+ id_department;
}
} }

View File

@@ -87,6 +87,11 @@ public class Main {
case "1": case "1":
empList = empDao.selectAll(); empList = empDao.selectAll();
break; break;
case "2":
System.out.println("IDを入力してください");
empList = empDao.selectById(tblFlg);
break;
default: default:
return; return;
} }

View File

@@ -45,7 +45,7 @@ public class DbUtil {
* ※Connection生成には上記の定数を活用してください * ※Connection生成には上記の定数を活用してください
*/ */
public static Connection getConnection() throws SQLException { public static Connection getConnection() throws SQLException {
//データベースへの接続 //データベースの接続
con = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS); con = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS);
return con; return con;
} }
@@ -59,9 +59,10 @@ public class DbUtil {
* 例外 :SQLException * 例外 :SQLException
* 処理 :引数のDBステートメントがnullでない場合、そのDBステートメントをクローズする * 処理 :引数のDBステートメントがnullでない場合、そのDBステートメントをクローズする
*/ */
public static void closeStatement(PreparedStatement stmt) throws SQLException {
//nullチェック public static void closestatement(PreparedStatement stmt) throws SQLException {
if (stmt != null) { if (!stmt.equals(null)) {
//DBステートメントを閉じる
stmt.close(); stmt.close();
} }
} }
@@ -76,10 +77,8 @@ public class DbUtil {
* 処理 :引数のコネクションがnullでない場合、そのコネクションを切断する * 処理 :引数のコネクションがnullでない場合、そのコネクションを切断する
*/ */
public static void closeConnection(Connection con) throws SQLException { public static void closeConnection(Connection con) throws SQLException {
//nullチェック if (!con.equals(null)) {
if (con != null) {
con.close(); con.close();
} }
} }
} }