day11

상은👸·2024년 1월 14일

oracleDB sql_developer

뚜벅뚜벅 세번째

목록 보기

11/11

📖 DB에서 JAVA로 데이터 SELECT, INSERT, UPDATE, DELETE 하기

1. DBConnectionManager 클래스, StudentDAO 클래스, StudentDTO 클래스, Main 클래스가 필요하다!

2. DBConnectionManager 클래스 에는 공통적으로 들어가는 연결, 연결종료 메소드를 넣어주고!

public class DBConnectionManager {
	
	public static Connection connectDB() {
		//DB 연결 관련된 라이브러리 로딩
		Connection conn = null;
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");

			String db_url = "jdbc:oracle:thin:@localhost:1521:orcl";
			String db_id = "scott";
			String db_pw = "tiger";

			conn = DriverManager.getConnection(db_url, db_id, db_pw);
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return conn;
	}
	
	public static void closeDB(Connection conn, PreparedStatement psmt, ResultSet rs) {
		try {
			if(conn != null) {
				conn.close();
			}

			if(psmt != null) {
				psmt.close();
			}

			if(rs != null) {
				rs.close();
			}

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} //DB Connection 연결 종료 
	}
}

3. StudentDTO 클래스 에는 student 테이블과 관련된 필드변수, 생성자, getter setter메소드를 넣어준다!

public class StudentDTO {
	//필드변수
	public int studno;
	public String name;
	public String id;
	public int grade;
	public String jumin;
	public String birthday; //날짜
	public String tel;
	public int height;
	public int weight;
	public int deptno1;
	public int deptno2;
	public int profno;
	
	//생성자
	public StudentDTO() {
		
	}
	public StudentDTO(int studno, String name, String id, int grade, String jumin, String birthday, String tel, int height,
			int weight, int deptno1, int deptno2, int profno) {
		super();
		this.studno = studno;
		this.name = name;
		this.id = id;
		this.grade = grade;
		this.jumin = jumin;
		this.birthday = birthday;
		this.tel = tel;
		this.height = height;
		this.weight = weight;
		this.deptno1 = deptno1;
		this.deptno2 = deptno2;
		this.profno = profno;
	}

	//메소드
	public int getStudno() {
		return studno;
	}

	public void setStudno(int studno) {
		this.studno = studno;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getId() {
		return id;
	}

	public void setId(String id) {
		this.id = id;
	}

	public int getGrade() {
		return grade;
	}

	public void setGrade(int grade) {
		this.grade = grade;
	}

	public String getJumin() {
		return jumin;
	}

	public void setJumin(String jumin) {
		this.jumin = jumin;
	}

	public String getbirthday() {
		return birthday;
	}

	public void setbirthday(String birthday) {
		this.birthday = birthday;
	}

	public String getTel() {
		return tel;
	}

	public void setTel(String tel) {
		this.tel = tel;
	}

	public int getHeight() {
		return height;
	}

	public void setHeight(int height) {
		this.height = height;
	}

	public int getWeight() {
		return weight;
	}

	public void setWeight(int weight) {
		this.weight = weight;
	}

	public int getDeptno1() {
		return deptno1;
	}

	public void setDeptno1(int deptno1) {
		this.deptno1 = deptno1;
	}

	public int getDeptno2() {
		return deptno2;
	}

	public void setDeptno2(int deptno2) {
		this.deptno2 = deptno2;
	}

	public int getProfno() {
		return profno;
	}

	public void setProfno(int profno) {
		this.profno = profno;
	}
	
	
}

4. StudentDAO 클래스에는 이제 SELECT, INSERT 해오는 메소드를 넣어줄건데 먼저 전체적으로 쓰이는 필드변수 conn, psmt, rs를 써주고!

🚨
UPDATE, DELETE는 INSERT와 똑같다!! sql 부분만 다르게 쓰고싶은데로 쓰는거고 psmt.setInt(1, grade); 이런 부분도 달라지는거고!

🚨
SELECT 는 rs = psmt.executeQuery();
UPDATE, DELETE, INSERT는 result = psmt.executeUpdate();

🚨
SELECT : find
INSERT : save
UPDATE : modify
DELETE : remove 로 변수명을 짓는다~!

public class StudentDAO {

	//필드변수
	Connection conn;
	PreparedStatement psmt;
	ResultSet rs;
    
    // 1. 기본 student 전체 조회 메소드 
    (SELECT)
	public List<StudentDTO> findStudentList()
	
	//2. 학년(grade)을 받아서 해당 학년 student 데이터를 조회하는 메소드 
    (SELECT)
	public List<StudentDTO> findStudentList(int grade)
	
    //3. StudentDTO 객체를 전달받아서 데이터를 저장(Insert)하는 메소드 
    (INSERT)
	public int saveStudent (StudentDTO studentDTO)
	
	
}

// 1. 기본 student 전체 조회 메소드

	public List<StudentDTO> findStudentList() {
		//DBConnectionManager 만들어준 connection 을 활용
		conn = DBConnectionManager.connectDB();

		String sql =  " SELECT studno, name, id, grade, jumin, TO_CHAR(birthday, 'YYYY-MM-DD') birthday, tel, height, weight, deptno1, deptno2, profno "
				+ "FROM student " ;

		List<StudentDTO> studentList = null;

		try {
			psmt = conn.prepareStatement(sql);
			//Connection 활용해서 sql 명령을 실행하는 객체

			rs = psmt.executeQuery(); //준비된 sql 쿼리문 실행!
			studentList = new ArrayList<StudentDTO>(); // 리스트생성

			while(rs.next()) { 
				
				int studno = rs.getInt("studno");
				String name = rs.getString("name");
				String id = rs.getString("id");
				int grade = rs.getInt("grade");
				String jumin = rs.getString("jumin");
				String birthday = rs.getString("birthday"); //DB에서 TO_CHAR로 String으로 만들어준다음 사용!
				String tel = rs.getString("tel");
				int height = rs.getInt("height");
				int weight = rs.getInt("weight");
				int deptno1 = rs.getInt("deptno1");
				int deptno2 = rs.getInt("deptno2");
				int profno = rs.getInt("profno");
				
				StudentDTO stu = new StudentDTO(studno, name, id, grade, jumin, birthday, tel, height, weight, deptno1, deptno2, profno); 
				//한줄 데이터 가지고 옴 
				
				studentList.add(stu);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnectionManager.closeDB(conn, psmt, rs);
		}

		return studentList;
	}

//2. 학년(grade)을 받아서 해당 학년 student 데이터를 조회하는 메소드

	public List<StudentDTO> findStudentList(int grade) {
		//결과가 한개인지 여러개(List)인지

		//DBConnectionManager 만들어준 connection 을 활용
		conn = DBConnectionManager.connectDB();

		String sql =  " SELECT studno, name, id, grade, jumin, TO_CHAR(birthday, 'YYYY-MM-DD') birthday, tel, height, weight, deptno1, deptno2, profno "
				+ " FROM student "
				+ " WHERE grade = ? " ;
 
		List<StudentDTO> studentList2 = null;

		try {
			psmt = conn.prepareStatement(sql);
			//Connection 활용해서 sql 명령을 실행하는 객체
			
			psmt.setInt(1, grade);
			
			rs = psmt.executeQuery(); //준비된 sql 쿼리문 실행!
						
			studentList2 = new ArrayList<StudentDTO>();

			while(rs.next()) { 
				int studno = rs.getInt("studno");
				String name = rs.getString("name");
				String id = rs.getString("id");
				int grade2 = rs.getInt("grade");
				String jumin = rs.getString("jumin");
				String birthday = rs.getString("birthday"); //DB에서 TO_CHAR로 String으로 만들어준다음 사용!
				String tel = rs.getString("tel");
				int height = rs.getInt("height");
				int weight = rs.getInt("weight");
				int deptno1 = rs.getInt("deptno1");
				int deptno2 = rs.getInt("deptno2");
				int profno = rs.getInt("profno");
				
				StudentDTO stu = new StudentDTO(studno, name, id, grade2, jumin, birthday, tel, height, weight, deptno1, deptno2, profno); 
				//한줄 데이터 가지고 옴 
				
				studentList2.add(stu);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnectionManager.closeDB(conn, psmt, rs);
		}

		return studentList2;
	}

//3. StudentDTO 객체를 전달받아서 데이터를 저장(Insert)하는 메소드

	public int saveStudent (StudentDTO studentDTO) {
		//DBConnectionManager 만들어준 connection 을 활용
		conn = DBConnectionManager.connectDB();

		String sql =  " INSERT INTO student "
					+ " VALUES ( ?, ?, ?, ?, ?, TO_DATE(?, 'YYYY-MM-DD'), ?, ?, ?, ?, ? ,? ) ";

		int result = 0;

		try {
			psmt = conn.prepareStatement(sql);
			//Connection 활용해서 sql 명령을 실행하는 객체

			psmt.setInt(1, studentDTO.getStudno());
			psmt.setString(2, studentDTO.getName());
			psmt.setString(3, studentDTO.getId());
			psmt.setInt(4, studentDTO.getGrade());
			
			psmt.setString(5, studentDTO.getJumin()); 
			psmt.setString(6, studentDTO.getbirthday()); //String //TO_DATE('2023-05-01', 'YYYY-MM-DD')
			psmt.setString(7, studentDTO.getTel());
			
			psmt.setInt(8, studentDTO.getHeight());
			psmt.setInt(9, studentDTO.getWeight());
			psmt.setInt(10, studentDTO.getDeptno1());
			psmt.setInt(11, studentDTO.getDeptno2());
			psmt.setInt(12, studentDTO.getProfno());
					
			result = psmt.executeUpdate(); //준비된 sql 쿼리문 실행!

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnectionManager.closeDB(conn, psmt, rs);
		}
		
		return result;
	}

// 4. 수정 UPDATE -> modify 예시

public int modifyPersonInfo(PersonInfoDTO personInfo) { //포장박스(DTO)불러오면 그안에 있는 id name 사용가능!
		//해당 아이디에 맞는 사람의 이름을 수정!
		
		conn = DBConnectionManager.connectDB();

		String sql =  " UPDATE t_person_info " 
					+ " SET name = ? " 
					+ " WHERE id = ? ";

		int result = 0;

		try {
			psmt = conn.prepareStatement(sql);
			//Connection 활용해서 sql 명령을 실행하는 객체
			
			psmt.setString(1, personInfo.getName()); //포장박스(DTO) 안에 있는 id
			psmt.setInt(2, personInfo.getId()); //포장박스(DTO) 안에 있는 name
			
			result = psmt.executeUpdate(); // 1, 0
			//rs = psmt.executeQuery(); //준비된 sql 쿼리문 실행! -> SELECT문일때!
			/*
			SELECT 쿼리 : psmt.excuteQuery(); -> 결과로 ResultSet
			INSERT, UPDATE, DELETE 쿼리 : psmt.excuteUpdate();
										-> 결과 : 적용된 행의 숫자
			 */

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnectionManager.closeDB(conn, psmt, rs);
		}
		
		return result;
	}

// 5. 삭제 DELETE -> remove 예시

public int removePersonInfoById(int id) { 
		//해당 아이디에 맞는 사람의 이름을 수정!
		
		conn = DBConnectionManager.connectDB();

		String sql =  " DELETE FROM t_person_info "
					+ " WHERE id = ? ";

		int result = 0;

		try {
			psmt = conn.prepareStatement(sql);
			//Connection 활용해서 sql 명령을 실행하는 객체
			
			psmt.setInt(1, id);
			
			result = psmt.executeUpdate(); // 1, 0
			//rs = psmt.executeQuery(); //준비된 sql 쿼리문 실행! -> SELECT문일때!
			/*
			SELECT 쿼리 : psmt.excuteQuery(); -> 결과로 ResultSet
			INSERT, UPDATE, DELETE 쿼리 : psmt.excuteUpdate();
										-> 결과 : 적용된 행의 숫자
			 */

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnectionManager.closeDB(conn, psmt, rs);
		}
		
		return result;
	}

상은👸

뒤죽박죽 벨로그

이전 포스트