수업일지 31일차 (23/11/2) - Jdbc

 + 코드블럭을 추가하면 한가지만 설정되는 것이 너무 거슬린다..SQL은 SQL, Java는 Java 이런 식으로 저장하고 싶은데 ㅠㅠ 

---

 

수업내용 정리 (Jdbc)

 

1. 과제

이전에 하던 전화번호부 프로젝트를 조건에 맞춰 완성하기
1. HashSet 대신 전화번호 리스트를 MySQL 서버 테이블에 저장
2. 저장 테이블(칼럼명): PHONEMEMBER(name,phone,major,year,company,kind)
 2-1. PK키: name, phone
 2-2. 자료형: VARCHAR(20) / 단, year은 int, kind(N,U,C)는 CHAR(1)로 한다.
3. 메뉴 입력 오류 시 예외처리
4. JDBC를 활용하여 DB 접속

등 이 외에도 전체 출력 시 AllayList 활용 등 조건이 있었지만 전부 작성하진 않았다.

 

 1-1) MySQL ㄱ 

create table PHONEMEMBER(
	PM_NO int unsigned auto_increment not null,
	NAME varchar(20),
	PHONE varchar(20),
	MAJOR varchar(20),
	YEAR tinyint unsigned,
	COMPANY varchar(20),
	KIND char(1) not null,
	constraint primary key PK_PM(PM_NO, NAME, PHONE)
);
desc phonemember;

• DB 테이블
• 조건에 맞춰 칼럼을 작성했고, 추가적으로 정렬할 때 전화번호를 입력한 순서대로 정렬하기 위해 자동으로 번호가 정렬되는 PM_NO 칼럼을 하나 더 작성했다.
• auto_increment는 기본키에 사용할 수 있다고 떠서 PK가 조건인 NAME, PHONE과 묶었다. (PK키인데 not null을 붙인 이유는 PK를 붙이기 전에 적고 넘어갔기 때문이다..)
• desc phonemember;는 phonemember 테이블에 대한 구조를 확인하는 코드다.

 

create or replace view pm_view
as select PM_NO, NAME, PHONE, MAJOR, YEAR, COMPANY, KIND
from phonemember order by pm_no;

• select로 검색할 때 어느 테이블에서 무엇을 어떻게 검색할 것인지 적은 view 생성

 

-- 검색 수정 삭제용 더미데이터
insert into phonemember(name, phone, kind) values('a', '1234', 'N');
insert into phonemember(name, phone, major, year, kind) values('b', '2222', 'af', '1', 'U');
insert into phonemember(name, phone, company, kind) values('c', '3333', 'ge', 'C');

-- 연습용
delete from phonemember;
select*from pm_view;
select*from pm_view where name='a';
update phonemember set name='aa' where name='a';

• Java에서 검색, 수정, 삭제할 때 사용할 더미데이터 및 문법 연습용 코드
• 나중에 추가적으로 중복이름에 관해 코드를 엎을 때는 데이터를 새로 더 추가하고 사용했다.

 

commit;
rollback;

 

 

 1-2) Java - common (db 관련 자주 쓸 메소드 클래스) ㄱ

package common;

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

// jdbc 공통 메소드
public class JdbcUtil {
	static {
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	
	public static Connection getConnection() {
		try {
			Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "icia", "1234");
			return con;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}
	
	public static void dbClose(ResultSet rs, PreparedStatement pstmt, Connection con) {
		try {
			if(rs!=null) rs.close();
			if(pstmt!=null) pstmt.close();
			if(con!=null) con.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	public static void txCommit(Connection con) {
		try {
			con.commit();
		} catch (SQLException e) {
			System.out.println("commit fail");
			e.printStackTrace();
		}
	}
	public static void txRollback(Connection con) {
		try {
			con.rollback();
		} catch (SQLException e) {
			System.out.println("rollback fail");
			e.printStackTrace();
		}
	}
}

• db 관련 자주 쓸 메소드 클래스
• 해당 프로젝트에서는 쓰지 않는 메소드(commit, rollback)도 있지만 Jdbc 공통 메소드 클래스로 사용하고 있기 때문에 따로 삭제는 하지 않았다.

 

 1-3) Java - exception (메뉴 예외 처리) ㄱ 

package exception;

public class MenuWrongException extends Exception {
	private int wrongMenuNum;
	
	public MenuWrongException(int menuNum) {
		this.wrongMenuNum = menuNum;
	}
	public void showWrongNumInfo() {
		System.out.println(" > "+wrongMenuNum+"에 해당하는 메뉴가 없습니다.");
	}
}

• 메뉴 예외 처리 클래스
• 메인 메뉴에서 설정한 번호가 아닌 다른 번호를 선택했을 시 해당 번호에 대한 메뉴가 없다는 메시지를 띄운다.

(서브 메뉴에 넣는 것을 잊어서 메인메뉴에만 존재한다..)

 

 1-4) Java - controller (메인 메뉴 / 메인 메뉴를 처리하는 메소드를 모아둔 클래스)

 메인메뉴 ㄱ 

package controller;

import java.util.InputMismatchException;
import java.util.Scanner;
import exception.MenuWrongException;

public class JdbcPBMain {
	public static Scanner sc = new Scanner(System.in);
	public static void main(String[] args) {
		
		while(true) {
			try {
				showMenu();
				int menu = sc.nextInt();
				if(menu < 0 || menu > 5) throw new MenuWrongException(menu);
				System.out.println();
				
				switch (menu) {
				case 1:
					System.out.println("===> 전화번호 입력");
					JdbcPBManager.inputData();
					break;

				case 2:
					System.out.println("===> 전화번호 검색");
					JdbcPBManager.serchData();
					break;
					
				case 3:
					System.out.println("===> 전화번호 수정");
					JdbcPBManager.updateData();
					break;

				case 4:
					System.out.println("===> 전화번호 삭제");
					JdbcPBManager.deletData();
					break;
					
				case 5:
					System.out.println("===> 전체 목록");
					JdbcPBManager.showAllData();
					break;
					
				case 0:
					System.out.println(" > 프로그램을 종료합니다.");
					return;

				default:

				}
			} catch (InputMismatchException e) {
				System.out.println(" > 문자를 입력하셨습니다.");
				sc.nextLine();
			} catch (MenuWrongException e) {
				e.showWrongNumInfo();
			}
			System.out.println();
		}
	}

	private static void showMenu() {
		System.out.println("===== 전화번호부 =====");
		System.out.println("""
				------------------
				 1. 전화번호 입력
				 2. 전화번호 검색
				 3. 전화번호 수정
				 4. 전화번호 삭제
				 5. 전체 목록 출력
				 0. 프로그램 종료
				------------------ """);
		System.out.print(" 메뉴선택> ");
	}
}

• 메인메뉴
• 메뉴 외의 숫자를 입력하면 throw를 통해 밑의 catch MenuWrongException으로 던져서 MenuWrongException 클래스의 메소드를 실행한다.
• 숫자가 아닌 문자를 입력했을 경우엔 InputMismatchException으로 들어가서 문자를 입력했다는 문구를 출력한다.

 메인 메뉴를 처리하는 메소드를 모아둔 클래스 ㄱ 

package controller;

import dao.JdbcPBDAO;

public class JdbcPBManager {
	private static JdbcPBDAO dao = new JdbcPBDAO();
	public static void inputData() {
		System.out.print(" ✏️   이름 입력\t:  ");
		String name = JdbcPBMain.sc.next();
		System.out.print(" ✏️  전화번호 입력\t:  ");
		String phone = JdbcPBMain.sc.next();
		try {
			boolean flag = dao.insert(name, phone);
			if(flag) {
				System.out.println("\n 📃 전화번호 입력 완료!");
			}else {
				System.out.println("\n ❌ 전화번호 입력 실패 ❌");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void serchData() {
		System.out.print(" 📒 검색할 이름: ");
		String serchN = JdbcPBMain.sc.next();
		dao.select(serchN);
	}

	public static void updateData() {
		System.out.print(" ✏️ 수정할 이름: ");
		String corN = JdbcPBMain.sc.next();
		dao.update(corN);
	}

	public static void deletData() {
		System.out.print(" ✂️ 삭제할 이름: ");
		String delN = JdbcPBMain.sc.next();
		dao.delete(delN);
	}

	public static void showAllData() {
		dao.selectAll();
	}
}

• 메인 메뉴에서 선택한 메뉴들에 해당하는 메소드
• 처리하기 위해 각 필요한 값을 입력받고, db 작업이 필요한 때에 dao 클래스의 메소드를 호출했다.
• insert에서 boolean 변수를 통해 입력이 되었다면 true가 반환될테니 입력 완료를 출력하고, 입력이 안 되었다면 false가 반환될테니 입력 실패를 출력한다.

 

 1-5) Java - been (db에서 가져온 정보를 담기 위한 클래스) ㄱ 

package been;

public class Member {
	String kind;
	String name;
	String phone;
	String major;
	int year;
	String company;
	
	public Member (String kind, String name, String phone) {
		this.kind = kind;
		this.name = name;
		this.phone = phone;
	}
	public Member (String kind, String name, String phone, String major, int year) {
		this(kind, name, phone);
		this.major = major;
		this.year = year;
	}
	public Member (String kind, String name, String phone, String company) {
		this(kind, name, phone);
		this.company = company;
	}
	
	public String getPH(){
		return phone;
	};
	
	public void sel() {
		if(major==null && company==null) {
			System.out.println(" +==================================+");
			System.out.println("   KIND\t  NAME\t  PHNUM");
			System.out.println("  -----\t  -----\t ------");
			System.out.println(" ✨ " + kind + "\t  " + name + "\t  " + phone);
			System.out.println(" +==================================+");
		}else if(company==null) {
			System.out.println(" +==================================+");
			System.out.println("   KIND\t  NAME\t  PHNUM\t MAJOR(YEAR)");
			System.out.println("  -----\t  -----\t ------\t -----------");
			System.out.println(" 🏫 " + kind + "\t  " + name + "\t  "+ phone
					+ "\t   " + major + "(" + year + ")");
			System.out.println(" +==================================+");
		}else if(major==null) {
			System.out.println(" +==================================+");
			System.out.println("   KIND\t  NAME\t  PHNUM\t  COMPANY");
			System.out.println("  -----\t  -----\t  ------  --------");
			System.out.println(" 💼 " + kind + "\t  " + name + "\t  "
					+ phone + "\t   " + company);
			System.out.println(" +==================================+");
		}
	}
	
	public String tS(int i) {
		String str;
		if(major==null && company==null) {
			str=(" "+i+" "+kind+"\t"+name+"\t "+phone);
		}else if(company==null) {
			str=(" "+i+" "+kind+"\t"+name+"\t "+phone+"\t  "+major+"("+year+")");
		}else if(major==null) {
			str=(" "+i+" "+kind+"\t"+name+"\t "+phone+"\t\t\t "+company);
		}else {
			str=null;
		}
		return str;
	}
	@Override
	public String toString() {
		String str;
		if(major==null && company==null) {
			str=(" ✨ "+kind+"\t"+name+"\t "+phone);
		}else if(company==null) {
			str=(" 🏫 "+kind+"\t"+name+"\t "+phone+"\t  "+major+"("+year+")");
		}else if(major==null) {
			str=(" 💼 "+kind+"\t"+name+"\t "+phone+"\t\t\t "+company);
		}else {
			str=null;
		}
		return str;
	}
}

• ArrayList로 출력할 때 타입이 되어줄 Member 클래스
• 값을 담아둘 필드들과 값을 받아올 생성자, phone 값을 리턴할 메소드를 제외하곤 거의 꾸밈용으로 인해 코드가 길어졌다..

 

 1-6) Java - dao (메인메뉴를 처리하는 메소드의 동작 / 실상 모든 동작)

(선생님이 따로 dao라는 패키지-클래스를 만들어서 하라고 하셔서 만들었지만, 아직 메소드를 모아둔 클래스에서 바로 처리하지 않는 이유를 잘 이해하지 못하겠다.)

 전체 코드 ㄱ 

package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import been.Member;
import common.JdbcUtil;
import controller.JdbcPBMain;

// db 작업 로직
public class JdbcPBDAO {
	Connection con;
	PreparedStatement pstmt;
	ResultSet rs;
	private String major;
	private int year;
	private String company;
	private ArrayList<Member> mList;
	private ArrayList<Member> serchList;

	public boolean insert(String name, String phone) {
		con = JdbcUtil.getConnection();
		String sql = "select*from pm_view where name=? and phone=?";
		try {
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, name);
			pstmt.setString(2, phone);
			rs = pstmt.executeQuery();
			if (!rs.next()) {
				plusAns();
				if (major == null && company == null) {
					sql = "insert into phonemember(name, phone, kind)" + " values(?, ?, ?)";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, name);
					pstmt.setString(2, phone);
					pstmt.setString(3, "N");
				} else if (company == null) {
					sql = "insert into phonemember(name, phone, major, year, kind)" + " values(?, ?, ?, ?, ?)";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, name);
					pstmt.setString(2, phone);
					pstmt.setString(3, major);
					pstmt.setInt(4, year);
					pstmt.setString(5, "U");
				} else if (major == null) {
					sql = "insert into phonemember(name, phone, company, kind)" + " values(?, ?, ?, ?)";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, name);
					pstmt.setString(2, phone);
					pstmt.setString(3, company);
					pstmt.setString(4, "C");
				}
				pstmt.executeUpdate();
				return true;
			} else {
				System.out.println(" > 이미 입력된 정보입니다.");
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			JdbcUtil.dbClose(rs, pstmt, con);
		}
		return false;
	}

	
	public void selectAll() {
		addArray();
		print(mList);
	}
	
	public void select(String serchN) {
		addArray(serchN);
		if(serchList.size()==1) {
			serchList.get(0).sel();
		}else if(serchList.size()==0){
			System.out.println(" > 정보를 찾을 수 없습니다.");
		}else {
			print(serchList);
		}
	}
	
	
	public void update(String corN) {
		addArray(corN);
		if(serchList.size()==1) {
			update(corN, serchList.get(0).getPH());
		}else if(serchList.size()==0){
			System.out.println(" > 정보를 찾을 수 없습니다.");
		}else {
			print(serchList, 1);
			System.out.println(" ⚠️ 이름이 중복됩니다.\n > 수정할 번호를 선택해주세요.");
			System.out.print(" ✏️ 수정할 번호: ");
			int corNum = JdbcPBMain.sc.nextInt();
			String corPH = serchList.get(corNum-1).getPH();
			update(corN, corPH);
		}
	}
	
	
	public void delete(String delN) {
		addArray(delN);
		if(serchList.size()==1) {
			delete(delN, serchList.get(0).getPH());
		}else if(serchList.size()==0){
			System.out.println(" > 정보를 찾을 수 없습니다.");
		}else {
			print(serchList, 1);
			System.out.println(" ⚠️ 이름이 중복됩니다.\n > 삭제할 번호를 선택해주세요.");
			System.out.print(" ✂️ 삭제할 번호: ");
			int delNum = JdbcPBMain.sc.nextInt();
			String delPH = serchList.get(delNum-1).getPH();
			delete(delN, delPH);
		}
	}
	
	
	
	
	
	
	/* private
	 * 
	 * 
	 * 							private
	 * 
	 * 
	 * 														private */
	
	private void plusAns() {
		major = null;
		year = 0;
		company = null;
		System.out.println("\n > 추가로 입력하시겠습니까?");
		System.out.println("""
				------------------
				 0. 다른 번호 선택 시 입력을 종료합니다.
				 1. 대학
				 2. 회사
				------------------""");
		System.out.print(" 메뉴선택> ");
		int ans = JdbcPBMain.sc.nextInt();
		if(ans<0 || ans>2)
		if (ans == 1) {
			System.out.print("\n ✏️   전공 입력\t:  ");
			major = JdbcPBMain.sc.next();
			System.out.print("\n ✏️   학년 입력\t:  ");
			year = JdbcPBMain.sc.nextInt();
		} else if (ans == 2) {
			System.out.print("\n ✏️   회사 입력\t:  ");
			company = JdbcPBMain.sc.next();
		} else {
			System.out.println(" > 입력을 종료하셨습니다.");
		}
	}

	
	private void addArray() {	// 전체출력을 위한것
		con = JdbcUtil.getConnection();
		String sql = "select*from pm_view";
		try {
			pstmt = con.prepareStatement(sql);
			rs = pstmt.executeQuery();
			mList = new ArrayList<>();
			while (rs.next()) {
				Member m = null;
				if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
				} else if (rs.getString("COMPANY") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
							rs.getString("MAJOR"), rs.getInt("YEAR"));
				} else if (rs.getString("MAJOR") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
							rs.getString("COMPANY"));
				}
				mList.add(m);
			}
		} catch (SQLException e) {
			System.out.println(" > 정보 불러오기 실패");
			e.printStackTrace();
		} finally {
			JdbcUtil.dbClose(rs, pstmt, con);
		}
	}
	private void addArray(String name) {	// 중복된 이름을 위한 것
		con = JdbcUtil.getConnection();
		String sql = "select*from pm_view where name=?";
		try {
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, name);
			rs = pstmt.executeQuery();
			serchList = new ArrayList<>();
			while (rs.next()) {
				Member m = null;
				if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
				} else if (rs.getString("COMPANY") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
							rs.getString("MAJOR"), rs.getInt("YEAR"));
				} else if (rs.getString("MAJOR") == null) {
					m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
							rs.getString("COMPANY"));
				}
				serchList.add(m);
			}
		} catch (SQLException e) {
			System.out.println(" > 정보 불러오기 실패");
			e.printStackTrace();
		} finally {
			JdbcUtil.dbClose(rs, pstmt, con);
		}
	}
	

	private void update(String corN, String corPH) {
		con = JdbcUtil.getConnection();
		String sql = "select*from pm_view where name = ? and phone = ?";
		try {
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, corN);
			pstmt.setString(2, corPH);
			rs = pstmt.executeQuery();
			if (rs.next()) {
				if (rs.getString("KIND").equals("N")) {
					selN(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"));
					System.out.print(" ✏️   이름 수정\t:  ");
					String reName = JdbcPBMain.sc.next();
					System.out.print(" ✏️  전화번호 수정\t:  ");
					String rePhone = JdbcPBMain.sc.next();
					sql = "update phonemember set name=?, phone=? where name=? and phone=?";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, reName);
					pstmt.setString(2, rePhone);
					pstmt.setString(3, corN);
					pstmt.setString(4, corPH);
					pstmt.executeUpdate();

				} else if (rs.getString("KIND").equals("U")) {
					selU(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("MAJOR"), rs.getInt("YEAR"));
					System.out.print(" ✏️   이름 수정\t:  ");
					String reName = JdbcPBMain.sc.next();
					System.out.print(" ✏️  전화번호 수정\t:  ");
					String rePhone = JdbcPBMain.sc.next();
					System.out.print(" ✏️   전공 수정\t:  ");
					String reMajor = JdbcPBMain.sc.next();
					System.out.print(" ✏️   학년 수정\t:  ");
					int reYear = JdbcPBMain.sc.nextInt();
					sql = "update phonemember set name=?, phone=?, major=?, year=? where name=? and phone=?";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, reName);
					pstmt.setString(2, rePhone);
					pstmt.setString(3, reMajor);
					pstmt.setInt(4, reYear);
					pstmt.setString(5, corN);
					pstmt.setString(6, corPH);
					pstmt.executeUpdate();
					
				} else if (rs.getString("KIND").equals("C")) {
					selC(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("COMPANY"));
					System.out.print(" ✏️   이름 수정\t:  ");
					String reName = JdbcPBMain.sc.next();
					System.out.print(" ✏️  전화번호 수정\t:  ");
					String rePhone = JdbcPBMain.sc.next();
					System.out.print(" ✏️   회사 수정\t:  ");
					String reCompany = JdbcPBMain.sc.next();
					sql = "update phonemember set name=?, phone=?, company=? where name=? and phone=?";
					pstmt = con.prepareStatement(sql);
					pstmt.setString(1, reName);
					pstmt.setString(2, rePhone);
					pstmt.setString(3, reCompany);
					pstmt.setString(4, corN);
					pstmt.setString(5, corPH);
					pstmt.executeUpdate();
				}
				System.out.println("\n > 수정이 완료되었습니다!");
			}
		} catch (SQLException e) {
			System.out.println(" ❌ 수정 실패 ❌");
			e.printStackTrace();
		} finally {
			JdbcUtil.dbClose(rs, pstmt, con);
		}
	}

	
	private void delete(String delN, String delPH) {
		con = JdbcUtil.getConnection();
		String sql = "select*from pm_view where name = ? and phone = ?";
		try {
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, delN);
			pstmt.setString(2, delPH);
			rs = pstmt.executeQuery();
			if (rs.next()) {
				if (rs.getString("KIND").equals("N")) {
					selN(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"));
				} else if (rs.getString("KIND").equals("U")) {
					selU(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("MAJOR"), rs.getInt("YEAR"));
				} else if (rs.getString("KIND").equals("C")) {
					selC(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("COMPANY"));
				}
				sql = "delete from phonemember where name=? and phone = ?";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, delN);
				pstmt.setString(2, delPH);
				pstmt.executeUpdate();
				System.out.println("\n > 삭제가 완료되었습니다.");
			}

		} catch (SQLException e) {
			System.out.println(" ❌ 삭제 실패 ❌");
			e.printStackTrace();
		}
	}
	
	
	
	private void print(ArrayList<Member> list) {
		if(list.size()!=0) {
			System.out.println(" > 입력한 순서대로 출력됩니다.");
			column();
			for (Member m : list) {
				if(mList.get(0) != m) {
					System.out.println(" |----\t-----\t------\t----------\t-------|");
				}
				System.out.println(m);
			}
			System.out.println(" +=============================================+");
		}else {
			System.out.println(" ⚠️ 저장된 정보가 없습니다.");
		}
	}
	private void print(ArrayList<Member> list, int i) {
		column();
		for (Member m : list) {
			if(list.get(0) != m) {
				System.out.println(" |----\t-----\t------\t----------\t-------|");
			}
			System.out.println(m.tS(i++));
		}
		System.out.println(" +=============================================+");
	}
	
	
	private void column() {
		System.out.println(" +=============================================+");
		System.out.println("  KIND\tNAME\tPHNUM\tMAJOR(YEAR)\tCOMPANY");
		System.out.println(" |=============================================|");
	}
	private void selN(String selK, String selN, String selPH) {
		System.out.println(" >---------------------+");
		System.out.println("   KIND\t  NAME\t  PHNUM");
		System.out.println(" >---------------------+");
		System.out.println(" ✨ " + selK + "\t  " + selN + "\t  " + selPH);
	}

	private void selU(String selK, String selN, String selPH, String selM, int selY) {
		System.out.println(" >----------------------------------+");
		System.out.println("   KIND\t  NAME\t  PHNUM\t MAJOR(YEAR)");
		System.out.println(" >----------------------------------+");
		System.out.println(" 🏫 " + selK + "\t  " + selN + "\t  " + selPH + "\t   " + selM + "(" + selY + ")\n");
	}

	private void selC(String selK, String selN, String selPH, String selC) {
		System.out.println(" >----------------------------------+");
		System.out.println("   KIND\t  NAME\t  PHNUM\t  COMPANY");
		System.out.println(" >----------------------------------+");
		System.out.println(" 💼 " + selK + "\t  " + selN + "\t  " + selPH + "\t   " + selC + "\n");
	}
}

 코드 설명 ㄱ 

package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import been.Member;
import common.JdbcUtil;
import controller.JdbcPBMain;

• package 및 import 정보

 

 

Connection con;
PreparedStatement pstmt;
ResultSet rs;
private String major;
private int year;
private String company;
private ArrayList<Member> mList;
private ArrayList<Member> serchList;

• 필드
• Connection: DB 연결
• PreparedStatement: sql 문장 전달
• ResultSet: DB에서 가져올 값 저장
• String major, int year, String company: 잠깐 값을 저장해두기 위한 필드 변수
• ArrayList<Member> mList: 전체출력을 위해 정보를 담아둘 ArrayList
• ArrayList<Member> serchList: 동명이인이 있을 경우을 계산해서 동명이인 정보만 담아둘 ArrayList

 

 

public boolean insert(String name, String phone) {
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name=? and phone=?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, name);
		pstmt.setString(2, phone);
		rs = pstmt.executeQuery();
		if (!rs.next()) {
			plusAns();
			if (major == null && company == null) {
				sql = "insert into phonemember(name, phone, kind)" + " values(?, ?, ?)";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, name);
				pstmt.setString(2, phone);
				pstmt.setString(3, "N");
			} else if (company == null) {
				sql = "insert into phonemember(name, phone, major, year, kind)" +
			 		" values(?, ?, ?, ?, ?)";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, name);
				pstmt.setString(2, phone);
				pstmt.setString(3, major);
				pstmt.setInt(4, year);
				pstmt.setString(5, "U");
			} else if (major == null) {
				sql = "insert into phonemember(name, phone, company, kind)" +
					" values(?, ?, ?, ?)";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, name);
				pstmt.setString(2, phone);
				pstmt.setString(3, company);
				pstmt.setString(4, "C");
			}
			pstmt.executeUpdate();
			return true;
		} else {
			System.out.println(" > 이미 입력된 정보입니다.");
		}
	} catch (SQLException e) {
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
	return false;
}

private void plusAns() {
	major = null;
	year = 0;
	company = null;
	System.out.println("\n > 추가로 입력하시겠습니까?");
	System.out.println("""
			------------------
			 0. 다른 번호 선택 시 입력을 종료합니다.
			 1. 대학
			 2. 회사
			------------------""");
	System.out.print(" 메뉴선택> ");
	int ans = JdbcPBMain.sc.nextInt();
	if(ans<0 || ans>2)
	if (ans == 1) {
		System.out.print("\n ✏️   전공 입력\t:  ");
		major = JdbcPBMain.sc.next();
		System.out.print("\n ✏️   학년 입력\t:  ");
		year = JdbcPBMain.sc.nextInt();
	} else if (ans == 2) {
		System.out.print("\n ✏️   회사 입력\t:  ");
		company = JdbcPBMain.sc.next();
	} else {
		System.out.println(" > 입력을 종료하셨습니다.");
	}
}

• insert (정보 입력)
• Manager에서 입력받아온 매개변수를 통해 정보가 있는지 확인(이름과 전화번호가 같은지)하고 만약 정보가 없다면 plusAns 메소드를 통해 정보를 입력받을지(대학이나 회사) 물어보고 만약 입력한다면 정보를 입력받은 뒤 다시 돌아온다. (입력받지 않아도 돌아온다.)
• 만약 필드 변수 major과 company가 null 값이라면, 그렇지 않고 필드 변수 company가 null 값이라면, 그렇지 않고 major이 null 값이라면. 세 경우에 따라 sql 문장을 달리해서 insert로 db에 값을 저장한다.
• 저장이 성공적으로 완료되었다면 true를 return하고, 저장에 실패했다면 false를 return한다.

 

 

public void selectAll() {
	addArray();
	print(mList);
}

private void addArray() {	// 전체출력을 위한것
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view";
	try {
		pstmt = con.prepareStatement(sql);
		rs = pstmt.executeQuery();
		mList = new ArrayList<>();
		while (rs.next()) {
			Member m = null;
			if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
			} else if (rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("MAJOR"), rs.getInt("YEAR"));
			} else if (rs.getString("MAJOR") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("COMPANY"));
			}
			mList.add(m);
		}
	} catch (SQLException e) {
		System.out.println(" > 정보 불러오기 실패");
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
}

private void print(ArrayList<Member> list) {
	if(list.size()!=0) {
		System.out.println(" > 입력한 순서대로 출력됩니다.");
		column();
		for (Member m : list) {
			if(mList.get(0) != m) {
				System.out.println(" |----\t-----\t------\t----------\t-------|");
			}
			System.out.println(m);
		}
		System.out.println(" +=============================================+");
	}else {
		System.out.println(" ⚠️ 저장된 정보가 없습니다.");
	}
}

private void column() {
	System.out.println(" +=============================================+");
	System.out.println("  KIND\tNAME\tPHNUM\tMAJOR(YEAR)\tCOMPANY");
	System.out.println(" |=============================================|");
}

• selectAll (DB의 모든 정보 출력)
• addArray 메소드를 통해 DB의 모든 값을 Member 객체에 저장한 후 ArrayList(mList)에 하나씩 추가한다. Member 객체에 저장할 때, 타입(kind)에 따라 저장하는 값을 다르게 했다.
• addArray 메소드가 끝나고 selectAll 메소드로 돌아오면 print(ArrayList<Member>) 메소드를 통해 모든 멤버를 출력하도록 했다.
• column 메소드는 꾸밈용 메소드다.

 

 

public void select(String serchN) {
	addArray(serchN);
	if(serchList.size()==1) {
		serchList.get(0).sel();
	}else if(serchList.size()==0){
		System.out.println(" > 정보를 찾을 수 없습니다.");
	}else {
		print(serchList);
	}
}

private void addArray(String name) {	// 중복된 이름을 위한 것
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name=?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, name);
		rs = pstmt.executeQuery();
		serchList = new ArrayList<>();
		while (rs.next()) {
			Member m = null;
			if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
			} else if (rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("MAJOR"), rs.getInt("YEAR"));
			} else if (rs.getString("MAJOR") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("COMPANY"));
			}
			serchList.add(m);
		}
	} catch (SQLException e) {
		System.out.println(" > 정보 불러오기 실패");
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
}

private void print(ArrayList<Member> list) {
	if(list.size()!=0) {
		System.out.println(" > 입력한 순서대로 출력됩니다.");
		column();
		for (Member m : list) {
			if(mList.get(0) != m) {
				System.out.println(" |----\t-----\t------\t----------\t-------|");
			}
			System.out.println(m);
		}
		System.out.println(" +=============================================+");
	}else {
		System.out.println(" ⚠️ 저장된 정보가 없습니다.");
	}
}

• select (검색)
• 다른 것들보다 검색이 쉬울 것 같아서 검색부터 진행했다.
• addArray(String) 메소드를 통해 DB에서 매개변수로 받아온 이름과 중복된 이름이 있다면 Member 객체에 저장한 후, 새로운 ArrayList(serchList)에 하나씩 추가했다. 이때, 전체 출력과 마찬가지로 타입(kind)에 따라 저장하는 값을 다르게 했다.
• select로 돌아오면 serchList의 길이(size)에 따라 if문으로 나눴다.
• 만약 serchList의 길이가 1이라면 그대로 출력한다.
• 그렇지 않고 serchList의 길이가 0이라면 정보를 찾을 수 없다는 문구를 출력한다.
• 전부 아니라면 print(ArrayList<Member>) 메소드를 통해 serchList의 값을 출력한다.

 

 

public void update(String corN) {
	addArray(corN);
	if(serchList.size()==1) {
		update(corN, serchList.get(0).getPH());
	}else if(serchList.size()==0){
		System.out.println(" > 정보를 찾을 수 없습니다.");
	}else {
		print(serchList, 1);
		System.out.println(" ⚠️ 이름이 중복됩니다.\n > 수정할 번호를 선택해주세요.");
		System.out.print(" ✏️ 수정할 번호: ");
		int corNum = JdbcPBMain.sc.nextInt();
		String corPH = serchList.get(corNum-1).getPH();
		update(corN, corPH);
	}
}

private void addArray(String name) {	// 중복된 이름을 위한 것
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name=?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, name);
		rs = pstmt.executeQuery();
		serchList = new ArrayList<>();
		while (rs.next()) {
			Member m = null;
			if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
			} else if (rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("MAJOR"), rs.getInt("YEAR"));
			} else if (rs.getString("MAJOR") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("COMPANY"));
			}
			serchList.add(m);
		}
	} catch (SQLException e) {
		System.out.println(" > 정보 불러오기 실패");
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
}

private void print(ArrayList<Member> list, int i) {
	column();
	for (Member m : list) {
		if(list.get(0) != m) {
			System.out.println(" |----\t-----\t------\t----------\t-------|");
		}
		System.out.println(m.tS(i++));
	}
	System.out.println(" +=============================================+");
}

private void print(ArrayList<Member> list, int i) {
	column();
	for (Member m : list) {
		if(list.get(0) != m) {
			System.out.println(" |----\t-----\t------\t----------\t-------|");
		}
		System.out.println(m.tS(i++));
	}
	System.out.println(" +=============================================+");
}

private void update(String corN, String corPH) {
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name = ? and phone = ?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, corN);
		pstmt.setString(2, corPH);
		rs = pstmt.executeQuery();
		if (rs.next()) {
			if (rs.getString("KIND").equals("N")) {
				selN(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"));
				System.out.print(" ✏️   이름 수정\t:  ");
				String reName = JdbcPBMain.sc.next();
				System.out.print(" ✏️  전화번호 수정\t:  ");
				String rePhone = JdbcPBMain.sc.next();
				sql = "update phonemember set name=?, phone=? where name=? and phone=?";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, reName);
				pstmt.setString(2, rePhone);
				pstmt.setString(3, corN);
				pstmt.setString(4, corPH);
				pstmt.executeUpdate();
                
				} else if (rs.getString("KIND").equals("U")) {
				selU(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("MAJOR"), rs.getInt("YEAR"));
				System.out.print(" ✏️   이름 수정\t:  ");
				String reName = JdbcPBMain.sc.next();
				System.out.print(" ✏️  전화번호 수정\t:  ");
				String rePhone = JdbcPBMain.sc.next();
				System.out.print(" ✏️   전공 수정\t:  ");
				String reMajor = JdbcPBMain.sc.next();
				System.out.print(" ✏️   학년 수정\t:  ");
				int reYear = JdbcPBMain.sc.nextInt();
				sql = "update phonemember set name=?, phone=?, major=?, year=? where name=? and phone=?";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, reName);
				pstmt.setString(2, rePhone);
				pstmt.setString(3, reMajor);
				pstmt.setInt(4, reYear);
				pstmt.setString(5, corN);
				pstmt.setString(6, corPH);
				pstmt.executeUpdate();
				
			} else if (rs.getString("KIND").equals("C")) {
				selC(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("COMPANY"));
				System.out.print(" ✏️   이름 수정\t:  ");
				String reName = JdbcPBMain.sc.next();
				System.out.print(" ✏️  전화번호 수정\t:  ");
				String rePhone = JdbcPBMain.sc.next();
				System.out.print(" ✏️   회사 수정\t:  ");
				String reCompany = JdbcPBMain.sc.next();
				sql = "update phonemember set name=?, phone=?, company=? where name=? and phone=?";
				pstmt = con.prepareStatement(sql);
				pstmt.setString(1, reName);
				pstmt.setString(2, rePhone);
				pstmt.setString(3, reCompany);
				pstmt.setString(4, corN);
				pstmt.setString(5, corPH);
				pstmt.executeUpdate();
			}
			System.out.println("\n > 수정이 완료되었습니다!");
		}
	} catch (SQLException e) {
		System.out.println(" ❌ 수정 실패 ❌");
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
}

• updata (수정)
• updata(String,String) 코드 줄이기를 안 한 상태이다.
• select(검색)처럼 addArray(String) 메소드를 통해 중복된 이름은 serchList에 저장했다.
• updata로 돌아오면 serchList의 사이즈가 1이면 바로 매개변수와 serchList에 저장된 번호를 updata(String, String)의 매개변수로 적는다.
• serchList의 사이즈가 0이면 정보를 찾을 수 없다고 출력한다.
• serchList의 사이즈가 1, 0 둘 다 아니라면 print(ArrayList<Member>, int) 메소드를 통해 중복된 이름의 정보들을 출력한 후, 이름이 중복된다고 출력한다. 수정할 번호를 입력받아 해당 번호의 1을 뺀 인덱스에 저장된 번호와 매개변수를 updata(String, String)의 매개변수로 적는다. 이때, int는 출력 순서의 시작 번호이기 때문에 고정값 1을 적는다.  출력이 모두 끝나고 다시 돌아오면 수정할 번호를 입력받고, updata(String,String) 메소드에 매개변수와 serchList의 입력받은 수정할 번호에서 1을 뺀 인덱스에 저장된 번호를 적는다.
•  updata(String, String)에서 입력받은 매개변수들을 통해 정보를 select(검색)해오고 kind 값에 따라 if문으로 나누어 수정하게 했다. 

 

 

public void delete(String delN) {
	addArray(delN);
	if(serchList.size()==1) {
		delete(delN, serchList.get(0).getPH());
	}else if(serchList.size()==0){
		System.out.println(" > 정보를 찾을 수 없습니다.");
	}else {
		print(serchList, 1);
		System.out.println(" ⚠️ 이름이 중복됩니다.\n > 삭제할 번호를 선택해주세요.");
		System.out.print(" ✂️ 삭제할 번호: ");
		int delNum = JdbcPBMain.sc.nextInt();
		String delPH = serchList.get(delNum-1).getPH();
		delete(delN, delPH);
	}
}

private void addArray(String name) {	// 중복된 이름을 위한 것
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name=?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, name);
		rs = pstmt.executeQuery();
		serchList = new ArrayList<>();
		while (rs.next()) {
			Member m = null;
			if (rs.getString("MAJOR") == null && rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"));
			} else if (rs.getString("COMPANY") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("MAJOR"), rs.getInt("YEAR"));
			} else if (rs.getString("MAJOR") == null) {
				m = new Member(rs.getString("kind"), rs.getString("NAME"), rs.getString("PHONE"),
						rs.getString("COMPANY"));
			}
			serchList.add(m);
		}
	} catch (SQLException e) {
		System.out.println(" > 정보 불러오기 실패");
		e.printStackTrace();
	} finally {
		JdbcUtil.dbClose(rs, pstmt, con);
	}
}

private void delete(String delN, String delPH) {
	con = JdbcUtil.getConnection();
	String sql = "select*from pm_view where name = ? and phone = ?";
	try {
		pstmt = con.prepareStatement(sql);
		pstmt.setString(1, delN);
		pstmt.setString(2, delPH);
		rs = pstmt.executeQuery();
		if (rs.next()) {
			if (rs.getString("KIND").equals("N")) {
				selN(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"));
			} else if (rs.getString("KIND").equals("U")) {
				selU(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("MAJOR"), rs.getInt("YEAR"));
			} else if (rs.getString("KIND").equals("C")) {
				selC(rs.getString("KIND"), rs.getString("NAME"), rs.getString("PHONE"), rs.getString("COMPANY"));
			}
			sql = "delete from phonemember where name=? and phone = ?";
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, delN);
			pstmt.setString(2, delPH);
			pstmt.executeUpdate();
			System.out.println("\n > 삭제가 완료되었습니다.");
		}
	} catch (SQLException e) {
		System.out.println(" ❌ 삭제 실패 ❌");
		e.printStackTrace();
	}
}

• delete (삭제)
• delete(String,String) 코드 줄이기를 안 한 상태이다.
• select(검색), updata(수정)처럼 addArray(String) 메소드를 통해 중복된 이름은 serchList에 저장했다.
• 돌아오면 serchList의 사이즈가 1이면 바로 매개변수와 serchList에 저장된 번호를 delete(String, String)의 매개변수로 적는다.
• serchList의 사이즈가 0이면 정보를 찾을 수 없다고 출력한다.
• serchList의 사이즈가 1, 0 둘 다 아니라면 print(ArrayList<Member>, int) 메소드를 통해 중복된 이름의 정보들을 출력한 후, 이름이 중복된다고 출력한다. 수정할 번호를 입력받아 해당 번호의 1을 뺀 인덱스에 저장된 번호와 매개변수를 delete(String, String)의 매개변수로 적는다. 이때, int는 출력 순서의 시작 번호이기 때문에 고정값 1을 적는다.  출력이 모두 끝나고 다시 돌아오면 수정할 번호를 입력받고, delete(String,String) 메소드에 매개변수와 serchList의 입력받은 수정할 번호에서 1을 뺀 인덱스에 저장된 번호를 적는다.
• delete(String, String)에서 입력받은 매개변수들을 통해 정보를 한 번 더 select(검색)해오고 kind 값에 따라 if문으로 나누어 출력을 한 번 해준 후, 삭제를 진행했다.

 

 

---

• 밑은 꾸밈용 메소드

private void column() {
	System.out.println(" +=============================================+");
	System.out.println("  KIND\tNAME\tPHNUM\tMAJOR(YEAR)\tCOMPANY");
	System.out.println(" |=============================================|");
}
private void selN(String selK, String selN, String selPH) {
	System.out.println(" >---------------------+");
	System.out.println("   KIND\t  NAME\t  PHNUM");
	System.out.println(" >---------------------+");
	System.out.println(" ✨ " + selK + "\t  " + selN + "\t  " + selPH);
}
private void selU(String selK, String selN, String selPH, String selM, int selY) {
	System.out.println(" >----------------------------------+");
	System.out.println("   KIND\t  NAME\t  PHNUM\t MAJOR(YEAR)");
	System.out.println(" >----------------------------------+");
	System.out.println(" 🏫 " + selK + "\t  " + selN + "\t  " + selPH + "\t   " + selM + "(" + selY + ")\n");
}
private void selC(String selK, String selN, String selPH, String selC) {
	System.out.println(" >----------------------------------+");
	System.out.println("   KIND\t  NAME\t  PHNUM\t  COMPANY");
	System.out.println(" >----------------------------------+");
	System.out.println(" 💼 " + selK + "\t  " + selN + "\t  " + selPH + "\t   " + selC + "\n");
}

 

---

 

전체 피드백

• 테이블은 하나이든 셋이든 상관이 없다고 하셨는데 나는 DB는 내 길이 아닌지 너무 어려워서 비교적 간단한 하나로 진행했다.
• 과제에서 메인 메뉴 부분을 이전에 만들었던 것으로 재활용했다가 서브 메뉴들에서 메뉴 입력 오류 시 예외처리 하는 것을 잊고 제출해버렸다. 처음부터 끝까지 직접 짰면 하지 않았다는 것을 기억했을텐데, 하는 아쉬움이 남았지만 간단하지만 조금 귀찮은 부분을 타이핑하느라 시간을 보내기 싫었던 탓이라 나중에는 조금 더 꼼꼼히 확인해야겠다.
• 코드를 줄이고 싶어서 메소드를 생성해두고 메소드 안에서 그 메소드를 사용하는 식으로 했는데 너무 메소드 안에 메소드인가 싶어지기도 해서 고민이 많았다.
• 제출하고 나니 자꾸 아쉬운 부분이 보여서 슬펐다.

 

• VSCode로 html도 잠깐 배웠는데 내일 함께 정리해서 올릴 예정이다.

 

---