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
11 changed files with 114 additions and 318 deletions

8
.classpath Normal file
View File

@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="src" path="src"/>
<classpathentry kind="lib" path="lib/mysql-connector-java-8.0.23.jar"/>
<classpathentry kind="lib" path="実行例/DAO_Simple.jar"/>
<classpathentry kind="output" path="bin"/>
</classpath>

1
.gitignore vendored Normal file
View File

@@ -0,0 +1 @@
/bin/

23
.project Normal file
View File

@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>em-jdbc</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
<buildCommand>
<name>org.eclipse.wst.validation.validationbuilder</name>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.jdt.core.javabuilder</name>
<arguments>
</arguments>
</buildCommand>
</buildSpec>
<natures>
<nature>org.eclipse.jdt.core.javanature</nature>
<nature>org.eclipse.wst.jsdt.core.jsNature</nature>
</natures>
</projectDescription>

7
.settings/.jsdtscope Normal file
View File

@@ -0,0 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.JRE_CONTAINER"/>
<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.baseBrowserLibrary"/>
<classpathentry kind="src" path=""/>
<classpathentry kind="output" path=""/>
</classpath>

View File

@@ -0,0 +1 @@
org.eclipse.wst.jsdt.launching.JRE_CONTAINER

View File

@@ -0,0 +1 @@
Global

View File

@@ -61,170 +61,47 @@ 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(rs.getInt(ID_EMPLOYEE), rs.getString(NM_EMPLOYEE), EmployeeDTO dto = new EmployeeDTO();
rs.getString(KN_EMPLOYEE), rs.getString(MAIL_ADDRESS), rs.getString(PASSWORD), dto.setId_employee(rs.getInt("id_employee"));
rs.getInt(ID_DEPARTMENT)); 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"));
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 {
* 社員テーブルから社員IDに合致する情報を取得する List<EmployeeDTO> rtnList2 = new ArrayList<>();
* @param id
* 検索する社員ID
* @return 検索結果
* @throws SQLException
* @throws ClassNotFoundException
* @throws NumberFormatException
*/
public List<EmployeeDTO> selectById​(int id)
throws SQLException, ClassNotFoundException, NumberFormatException {
List<EmployeeDTO> rtnList = new ArrayList<>();
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append(" SELECT "); sql.append(" SELECT ");
sql.append(" " + "*"); sql.append(" " + "*");
sql.append(" FROM "); sql.append(" FROM ");
sql.append(" " + TBL_NAME); sql.append(" " + TBL_NAME);
sql.append(" WHERE "); sql.append(" WHERE " + ID_EMPLOYEE+ "=?");
sql.append(" " + ID_EMPLOYEE);
sql.append(" = ");
sql.append(" " + id);
try { try {
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(rs.getInt(ID_EMPLOYEE), rs.getString(NM_EMPLOYEE), dto.setId_employee(rs.getInt("id_employee"));
rs.getString(KN_EMPLOYEE), rs.getString(MAIL_ADDRESS), rs.getString(PASSWORD), dto.setNm_employee(rs.getString("nm_employee"));
rs.getInt(ID_DEPARTMENT)); dto.setKn_employee(rs.getString("kn_employee"));
rtnList.add(dto); dto.setMail_address(rs.getString("mail_address"));
dto.setPassword(rs.getString("password"));
dto.setId_department(rs.getInt("id_department"));
rtnList2.add(dto);
} }
} finally { } finally {
DbUtil.closeStatement(this.stmt); DbUtil.closestatement(this.stmt);
} }
if (rtnList.size() == 0) { return rtnList2;
System.out.println("入力された値で情報がみつかりませんでした");
}
return rtnList;
} }
/**
* 社員テーブルの社員IDに合致する情報を削除する
*
* @param id
* 削除ID
* @throws ClassNotFoundException
* @throws SQLException
* @throws NumberFormatException
*/
public void empDelete​(int id)
throws ClassNotFoundException, SQLException, NumberFormatException {
StringBuilder sql = new StringBuilder();
sql.append(" DELETE ");
sql.append(" FROM ");
sql.append(" " + TBL_NAME);
sql.append(" WHERE ");
sql.append(" " + ID_EMPLOYEE);
sql.append(" = ");
sql.append(" " + id);
try {
this.stmt = con.prepareStatement(sql.toString());
stmt.executeUpdate();
System.out.println("削除が完了しました");
} finally {
DbUtil.closeStatement(this.stmt);
}
}
/**
* 社員テーブルに指定された情報を新規登録する
*
* @param name - 社員名
* @param kana - 社員名カナ
* @param mail - メールアドレス
* @param pass - パスワード
* @param depId - 部署ID
* @throws NumberFormatException
* @throws SQLException
* @throws ClassNotFoundException
*/
public void empInsert​(String name, String kana, String mail, String pass, int depId)
throws NumberFormatException, SQLException, ClassNotFoundException {
StringBuilder sql = new StringBuilder();
sql.append(" INSERT ");
sql.append(" INTO ");
sql.append(" " + TBL_NAME);
sql.append(" ( " + NM_EMPLOYEE);
sql.append(" , " + KN_EMPLOYEE);
sql.append(" , " + MAIL_ADDRESS);
sql.append(" , " + PASSWORD);
sql.append(" , " + ID_DEPARTMENT + " ) ");
sql.append(" VALUES ");
sql.append(" ( '" + name);
sql.append("' , '" + kana);
sql.append("' , '" + mail);
sql.append("' , '" + pass);
sql.append("' , " + depId + " ) ");
try {
this.stmt = con.prepareStatement(sql.toString());
stmt.executeUpdate();
System.out.println("登録が完了しました");
} finally {
DbUtil.closeStatement(this.stmt);
}
}
/**
* 社員テーブルの社員IDに合致する情報を更新する
*
* @param id - 社員ID
* @param name - 社員名
* @param kana - 社員名カナ
* @param mail - メールアドレス
* @param pass - パスワード
* @param depId - 部署ID
* @throws ClassNotFoundException
* @throws SQLException
* @throws NumberFormatException
*/
public void empUpdate​(int id, String name, String kana, String mail, String pass, int depId)
throws ClassNotFoundException, SQLException, NumberFormatException {
StringBuilder sql = new StringBuilder();
sql.append(" UPDATE ");
sql.append(" " + TBL_NAME);
sql.append(" SET ");
sql.append(" " + NM_EMPLOYEE);
sql.append(" = '" + name + " ' ");
sql.append(" , " + KN_EMPLOYEE);
sql.append(" = '" + kana + " ' ");
sql.append(" , " + MAIL_ADDRESS);
sql.append(" = '" + mail + " ' ");
sql.append(" , " + PASSWORD);
sql.append(" = '" + pass + " ' ");
sql.append(" , " + ID_DEPARTMENT);
sql.append(" = " + depId);
sql.append(" WHERE ");
sql.append(" " + ID_EMPLOYEE);
sql.append(" = ");
sql.append(" " + id);
try {
this.stmt = con.prepareStatement(sql.toString());
stmt.executeUpdate();
System.out.println("更新が完了しました");
} finally {
DbUtil.closeStatement(this.stmt);
}
}
} }

View File

@@ -1,79 +1,69 @@
package com.rhizome.example.dto; package com.rhizome.example.dto;
public class EmployeeDTO { public class EmployeeDTO {
private int ID_EMPLOYEE;
private String NM_EMPLOYEE;
private String KN_EMPLOYEE;
private String MAIL_ADDRESS;
private String PASSWORD;
private int ID_DEPARTMENT;
public EmployeeDTO() { 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() {
return id_employee;
} }
public EmployeeDTO(int ID_EMPLOYEE, String NM_EMPLOYEE, String KN_EMPLOYEE, String MAIL_ADDRESS, String PASSWORD, public void setId_employee(Integer id_employee) {
int ID_DEPARTMENT) { this.id_employee = id_employee;
setID_EMPLOYEE(ID_EMPLOYEE);
setNM_EMPLOYEE(NM_EMPLOYEE);
setKN_EMPLOYEE(KN_EMPLOYEE);
setMAIL_ADDRESS(MAIL_ADDRESS);
setPASSWORD(PASSWORD);
setID_DEPARTMENT(ID_DEPARTMENT);
} }
public int getID_EMPLOYEE() { public String getNm_employee() {
return ID_EMPLOYEE; return nm_employee;
} }
public void setID_EMPLOYEE(int iD_EMPLOYEE) { public void setNm_employee(String nm_employee) {
ID_EMPLOYEE = iD_EMPLOYEE; this.nm_employee = nm_employee;
} }
public String getNM_EMPLOYEE() { public String getKn_employee() {
return NM_EMPLOYEE; return kn_employee;
} }
public void setNM_EMPLOYEE(String nM_EMPLOYEE) { public void setKn_employee(String kn_employee) {
NM_EMPLOYEE = nM_EMPLOYEE; this.kn_employee = kn_employee;
} }
public String getKN_EMPLOYEE() { public String getMail_address() {
return KN_EMPLOYEE; return mail_address;
} }
public void setKN_EMPLOYEE(String kN_EMPLOYEE) { public void setMail_address(String mail_address) {
KN_EMPLOYEE = kN_EMPLOYEE; this.mail_address = mail_address;
} }
public String getMAIL_ADDRESS() { public String getPassword() {
return MAIL_ADDRESS; return password;
} }
public void setMAIL_ADDRESS(String mAIL_ADDRESS) { public void setPassword(String password) {
MAIL_ADDRESS = mAIL_ADDRESS; this.password = password;
} }
public String getPASSWORD() { public Integer getId_department() {
return PASSWORD; return id_department;
} }
public void setPASSWORD(String pASSWORD) { public void setId_department(Integer id_department) {
PASSWORD = pASSWORD; this.id_department = id_department;
} }
public int getID_DEPARTMENT() { public String toString() {
return ID_DEPARTMENT; return id_employee + "\t"
} + nm_employee + "\t"
+ kn_employee + "\t"
+ mail_address + "\t"
+ password + "\t"
+ id_department;
public void setID_DEPARTMENT(int iD_DEPARTMENT) {
ID_DEPARTMENT = iD_DEPARTMENT;
} }
public void showInfo() {
System.out.println(ID_EMPLOYEE + "\t" + NM_EMPLOYEE +
"\t" + KN_EMPLOYEE + "\t" + MAIL_ADDRESS +
"\t" + PASSWORD + "\t" + ID_DEPARTMENT);
}
} }

View File

@@ -54,13 +54,10 @@ public class Main {
empSelect(); empSelect();
break; break;
case "2": case "2":
empInsert​();
break; break;
case "3": case "3":
empUpdate​();
break; break;
case "4": case "4":
empDelete​();
break; break;
case "9": case "9":
return; return;
@@ -73,93 +70,6 @@ public class Main {
} }
} }
/**
* 社員テーブルの社員IDに合致する情報を更新する
*
* @throws ClassNotFoundException
* @throws SQLException
* @throws NumberFormatException
*/
public static void empUpdate​()
throws ClassNotFoundException, SQLException, NumberFormatException {
Connection con = DbUtil.getConnection();
EmployeeDAO empDao = new EmployeeDAO(con);
int id = Integer.parseInt(inputCheck("ID", true));
if (empDao.selectById​(id).size() == 0) {
return;
}
String name = inputCheck("社員名", false);
String kana = inputCheck("フリガナ", false);
String mail = inputCheck("メールアドレス", false);
String pass = inputCheck("パスワード", false);
int depId = Integer.parseInt(inputCheck("部署ID", true));
try {
empDao.empUpdate​(id, name, kana, mail, pass, depId);
} finally {
DbUtil.closeConnection(empDao.con);
}
}
/**
* 社員テーブルに指定された情報を新規登録する
* @throws NumberFormatException
* @throws SQLException
* @throws ClassNotFoundException
*/
public static void empInsert​()
throws NumberFormatException, SQLException, ClassNotFoundException {
Connection con = DbUtil.getConnection();
EmployeeDAO empDao = new EmployeeDAO(con);
String name = inputCheck("社員名", false);
String kana = inputCheck("フリガナ", false);
String mail = inputCheck("メールアドレス", false);
String pass = inputCheck("パスワード", false);
int depId = Integer.parseInt(inputCheck("部署ID", true));
try {
empDao.empInsert​(name, kana, mail, pass, depId);
} finally {
DbUtil.closeConnection(empDao.con);
}
}
/**
* 社員テーブルの社員IDに合致する情報を削除する
*
* @throws ClassNotFoundException
* @throws SQLException
*/
public static void empDelete​()
throws ClassNotFoundException, SQLException, NumberFormatException {
List<EmployeeDTO> rtnList = new ArrayList<>();
Connection con = DbUtil.getConnection();
EmployeeDAO empDao = new EmployeeDAO(con);
int id = Integer.parseInt(inputCheck("ID", true));
rtnList = empDao.selectById​(id);
if (rtnList.size() == 0) {
return;
}
System.out.println("指定されたIDの情報を削除します? Y/y\r\n"
+ "(Y/y以外の入力であればキャンセル)");
String str = inputCheck(false);
if (!str.equalsIgnoreCase("y")) {
System.out.println("キャンセルしました");
return;
}
try {
empDao.empDelete​(id);
} finally {
DbUtil.closeConnection(empDao.con);
}
}
/** /**
* 社員テーブルから情報を検索する * 社員テーブルから情報を検索する
* *
@@ -178,13 +88,15 @@ public class Main {
empList = empDao.selectAll(); empList = empDao.selectAll();
break; break;
case "2": case "2":
empList = empDao.selectById​(Integer.parseInt(inputCheck("ID", true))); System.out.println("IDを入力してください");
empList = empDao.selectById(tblFlg);
break; break;
default: default:
return; return;
} }
for (EmployeeDTO emp : empList) { for (EmployeeDTO emp : empList) {
emp.showInfo(); System.out.println(emp);
} }
} finally { } finally {
DbUtil.closeConnection(empDao.con); DbUtil.closeConnection(empDao.con);
@@ -240,26 +152,4 @@ public class Main {
} }
return str; return str;
} }
public static String inputCheck(boolean flg) {
String str = null;
while (true) {
str = sc.nextLine();
if (str.trim().length() == 0) {
continue;
}
if (flg) {
if (str.trim().length() > 0) {
try {
Integer.parseInt(str);
} catch (NumberFormatException e) {
continue;
}
}
}
break;
}
return str;
}
} }

View File

@@ -4,7 +4,6 @@ import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.Objects;
public class DbUtil { public class DbUtil {
// 定数定義(共通) // 定数定義(共通)
@@ -45,13 +44,10 @@ public class DbUtil {
* 生成されたConnectionを返却する * 生成されたConnectionを返却する
* ※Connection生成には上記の定数を活用してください * ※Connection生成には上記の定数を活用してください
*/ */
public static Connection getConnection() throws SQLException {
public static Connection getConnection() throws ClassNotFoundException, SQLException { //データベースの接続
if (con != null && con.isValid(1)) { con = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS);
return con; return con;
}
Class.forName(DB_DRIVER);
return con = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS);
} }
/* /*
@@ -64,9 +60,11 @@ public class DbUtil {
* 処理 :引数のDBステートメントがnullでない場合、そのDBステートメントをクローズする * 処理 :引数のDBステートメントがnullでない場合、そのDBステートメントをクローズする
*/ */
public static void closeStatement(PreparedStatement ps) throws SQLException { public static void closestatement(PreparedStatement stmt) throws SQLException {
if (Objects.nonNull(ps)) if (!stmt.equals(null)) {
ps.close(); //DBステートメントを閉じる
stmt.close();
}
} }
/* /*
@@ -79,8 +77,8 @@ public class DbUtil {
* 処理 :引数のコネクションがnullでない場合、そのコネクションを切断する * 処理 :引数のコネクションがnullでない場合、そのコネクションを切断する
*/ */
public static void closeConnection(Connection con) throws SQLException { public static void closeConnection(Connection con) throws SQLException {
if (Objects.nonNull(con)) if (!con.equals(null)) {
con.close(); con.close();
}
} }
} }