Chapter 2~3. Statement - 회원관리 CRUD 만들기(STEP1)

김승현·2021년 10월 23일
JDBC국비수업
0

CRUD

  • Create, Read, Update, Delete의 앞글자를 딴 표현으로 데이터 처리 기능을 이야기함
  • 사용자의 요청에 따라 DB에 데이터를 생성, 검색, 수정, 삭제 등을 수행할 수 있어야함

MVC 패턴


TestRun Class

  • TestRun Class는 View 를 호출하여 시작하기 위한 Class (실행용)
package com.test.run;

import com.test.member.view.MemberView;

public class TestMain {

	public static void main(String[] args) {
		new MemberView().start();
	}
}

VO Class

  • VO 클래스는 사용자가 입력한 회원정보 및 DB에서 회원 정보를 가져오기 위한 DTO 역할도 수행하는 Class
  • Setter / Getter 메소드를 가지고 있으며, 상황에 따른 매개변수 있는 생성자를 만들어서 사용
package com.test.member.model.vo;

import java.sql.Date;

public class Member {

	private int memberNo;
	private String memberId;
	private String memberPwd;
	private String memberName;
	private char gender;
	private int age;
	private String email;
	private String phone;
	private String address;
	private String hobby;
	private Date enrollDate;
	private char withdrawYN;

	public Member() {}
	
	public Member(String memberId, String memberPwd, String memberName, char gender, int age, String email,
			String phone, String address, String hobby) {
		super();
		this.memberId = memberId;
		this.memberPwd = memberPwd;
		this.memberName = memberName;
		this.gender = gender;
		this.age = age;
		this.email = email;
		this.phone = phone;
		this.address = address;
		this.hobby = hobby;
	}

	public int getMemberNo() {
		return memberNo;
	}

	public void setMemberNo(int memberNo) {
		this.memberNo = memberNo;
	}

	public String getMemberId() {
		return memberId;
	}

	public void setMemberId(String memberId) {
		this.memberId = memberId;
	}

	public String getMemberPwd() {
		return memberPwd;
	}

	public void setMemberPwd(String memberPwd) {
		this.memberPwd = memberPwd;
	}

	public String getMemberName() {
		return memberName;
	}

	public void setMemberName(String memberName) {
		this.memberName = memberName;
	}

	public char getGender() {
		return gender;
	}

	public void setGender(char gender) {
		this.gender = gender;
	}

	public int getAge() {
		return age;
	}

	public void setAge(int age) {
		this.age = age;
	}

	public String getEmail() {
		return email;
	}

	public void setEmail(String email) {
		this.email = email;
	}

	public String getPhone() {
		return phone;
	}

	public void setPhone(String phone) {
		this.phone = phone;
	}

	public String getAddress() {
		return address;
	}

	public void setAddress(String address) {
		this.address = address;
	}

	public String getHobby() {
		return hobby;
	}

	public void setHobby(String hobby) {
		this.hobby = hobby;
	}

	public Date getEnrollDate() {
		return enrollDate;
	}

	public void setEnrollDate(Date enrollDate) {
		this.enrollDate = enrollDate;
	}

	public char getWithdrawYN() {
		return withdrawYN;
	}

	public void setWithdrawYN(char withdrawYN) {
		this.withdrawYN = withdrawYN;
	}

	@Override
	public String toString() {
		return memberNo + "/" + memberId + "/" + memberPwd + "/" + memberName + "/" + gender + "/" + age + "/" + email
				+ "/" + phone + "/" + address + "/" + hobby + "/" + enrollDate + "/" + withdrawYN;
	}

}

View Class

  • View 클래스는 사용자에게 보여지는 화면

  • Web 으로 표현하자면 Front-End 파트가 View Class 가 하는 역할

  • 사용자는 View 에서 보여주는 메뉴를 가지고 선택할 수 있게 되고, 선택된것에 따라 View는 Controller에게 요청 함

  • 현재 회원관리 프로그램에서는 다음과 같은 메뉴를 가지고 있다.

    • 회원 전체 조회 (SELECT)
    • ID로 조회 (SELECT)
    • 이름으로 조회 (SELECT)
    • 정보 추가 (INSERT)
    • 정보 수정 (UPDATE)
    • 정보 삭제 (UPDATE)
      • 삭제라고 해서 무조건 DELETE는 아니다.
        (회원 정보는 함부로 삭제 하지 않는다.)
package com.test.member.view;

import java.util.ArrayList;
import java.util.Scanner;

import com.test.member.controller.MemberController;
import com.test.member.model.vo.Member;

public class MemberView {

	private Scanner sc = new Scanner(System.in);
	private MemberController mCon = new MemberController();

	// 가장 먼저 시작하는 메소드
	public void start() {

		while (true) {
			System.out.println("---------- 회원 관리 프로그램 ver 1.0 ----------");
			System.out.println("1. 전체 회원 정보 조회");
			System.out.println("2. ID로 회원 조회");
			System.out.println("3. 이름으로 회원 조회");
			System.out.println("4. 회원 정보 추가");
			System.out.println("5. 회원 정보 수정");
			System.out.println("6. 회원 정보 삭제");
			System.out.println("0. 프로그램 종료");
			System.out.print("선택 : ");
			int select = sc.nextInt();

			if (select == 0) {
				System.out.println("프로그램을 종료합니다. 사용해주셔서 감사합니다. (--) (_ _) 꾸벅");
				return;
			}

			switch (select) {
			case 1:
				selectAll();
				break;
			case 2:
				selectOneId();
				break;
			case 3:
				selectName();
				break;
			case 4:
				insertMember();
				break;
			case 5:
				updateMember();
				break;
			case 6:
				deleteMember();
				break;

			}
		}
	}

	public void selectAll() {

		ArrayList<Member> list = mCon.selectAll();

		System.out.println("============= 회원정보 출력 =============");

		for (Member m : list) {
			System.out.println(m);
		}
	}

	public void selectOneId() {
		// 사용자에게 찾으려고하는 ID 를 입력하라고 해야함
		System.out.print("검색하려는 회원ID 입력 : ");
		String memberId = sc.next();

		Member m = mCon.selectOneId(memberId);

		if (m != null) {
			System.out.println("------------- " + memberId + " 회원정보-------------");
			System.out.println("이름 : " + m.getMemberName());
			System.out.println("나이 : " + m.getAge());
			System.out.println("주소 : " + m.getAddress());
			System.out.println("성별 : " + m.getGender());
			System.out.println("폰번호 : " + m.getPhone());
			System.out.println("이메일 : " + m.getEmail());
			System.out.println("취미 : " + m.getHobby());
			System.out.println("가입일 : " + m.getEnrollDate());
		} else {
			System.out.println(memberId + "를(을) 가진 회원을 검색하지 못하였습니다.");
		}

	}

	public void selectName() {
		System.out.print("검색하려는 회원 이름 입력 : ");
		String memberName = sc.next();

		ArrayList<Member> list = mCon.selectName(memberName);

		// 결과 2가지 상황
		// 1. 찾았다면 -> 리스트 안에 Member 객체 있다.
		// 2. 못찾았으면 -> 리스트 안에 Member 객체 없다.

		if (!list.isEmpty()) {
			for (Member m : list) {
				System.out.println(m);
			}
		} else {
			System.out.println(memberName + "이라는 이름을 가진 사람을 검색하지 못하였습니다.");
		}
	}

	public void insertMember() {
		System.out.println("----------- 추가될 회원 정보 입력 -----------");
		System.out.print("회원ID : ");
		String memberId = sc.next();

		System.out.print("회원 PWD : ");
		String memberPwd = sc.next();

		System.out.print("회원 이름 : ");
		String memberName = sc.next();

		System.out.print("회원성별(1.남/2.여) : ");
		int gender = sc.nextInt();

		System.out.print("회원 나이 : ");
		int age = sc.nextInt();

		System.out.print("회원 이메일 : ");
		String email = sc.next();

		System.out.print("회원 폰번호 : ");
		String phone = sc.next();

		System.out.print("회원 주소 : ");
		sc.nextLine();
		String address = sc.nextLine();

		System.out.print("회원 취미(여러개인경우,(콤마)로 구분) : ");
		String hobby = sc.next();

		char genderChar;
		if (gender == 1) {
			genderChar = 'M';
		} else {
			genderChar = 'F';
		}

		Member m = new Member(memberId, memberPwd, memberName, genderChar, age, email, phone, address, hobby);

		boolean result = mCon.insertMember(m);

		if (result) {
			System.out.println(m.getMemberName() + "님의 회원정보가 추가 되었습니다.");
		} else {
			System.out.println("회원정보 추가를 실패하였습니다. - 지속적인 문제 발생시 관리자에게 문의해주세요 -");
		}
	}

	public void updateMember() {
		System.out.print("수정하려는 회원의 ID를 입력 : ");
		String memberId = sc.next();

		Member m = mCon.selectOneId(memberId);

		if (m != null) {

			while (true) {
				System.out.println("------------ 검색된 " + m.getMemberName() + " 회원 정보 ------------");
				System.out.println("ID : " + m.getMemberId());
				System.out.println("이름 : " + m.getMemberName());
				System.out.println("성별 : " + m.getGender());
				System.out.println("나이 : " + m.getAge());
				System.out.println("주소 : " + m.getAddress());
				System.out.println("이메일 : " + m.getEmail());
				System.out.println("폰번호 : " + m.getPhone());
				System.out.println("취미 : " + m.getHobby());
				System.out.println("가입일 : " + m.getEnrollDate());
				System.out.println("삭제 여부: " + m.getWithdrawYN());

				System.out.println("-------------------------------------");
				System.out.println("1. 주소 수정");
				System.out.println("2. 이메일 수정");
				System.out.println("3. 폰번호 수정");
				System.out.println("4. 취미 수정");
				System.out.println("0. 수정 취소");
				System.out.print("선택 : ");
				int select = sc.nextInt();

				if (select == 0) {
					break;
				}
				switch (select) {
				case 1:
					System.out.print("수정될 주소 입력 : ");
					sc.nextLine();
					String address = sc.nextLine();
					m.setAddress(address);
					break;
				case 2:
					System.out.print("수정될 이메일 입력 :");
					String email = sc.next();
					m.setEmail(email);
					break;

				case 3:
					System.out.print("수정될 폰번호 입력 : ");
					String phone = sc.next();
					m.setPhone(phone);
					break;
				case 4:
					System.out.print("수정될 취미 입력 (여러개인 경우 ,(콤마)로 구분) : ");
					String hobby = sc.next();
					m.setHobby(hobby);
					break;
				}
				// 수정된 데이터가 DB에 반영되기 위해서 view에서 controller로 보내주어야한다.
				boolean result = mCon.updateMember(m);

				if (result) {
					System.out.println("회원 정보가 수정되었습니다.");
				} else {
					System.out.println("회원 정보 수정에 실패하였습니다. - 지속적인 문제 발생시 관라자에게 문의해주세요 -");
				}
			}

		} else {
			System.out.println(memberId + "(을)를 가진 회원을 검색하지 못하였습니다.");
		}
	}

	public void deleteMember() {
		System.out.print("삭제하려는 회원의 ID를 입력 : ");
		String memberId = sc.next();
		
		Member m = mCon.selectOneId(memberId);
		
		if(m!=null) {
			System.out.print(m.getMemberId()+"("+m.getMemberName()+")회원을 정말로 삭제하시겠습니까? (Y,N) : ");
			char select = sc.next().toUpperCase().charAt(0);
			
			if(select=='Y') {
				boolean result = mCon.deleteMember(memberId);
				
				if(result) {
					System.out.println(memberId + " 회원을 정상적으로 삭제하였습니다.");
				}else {
					System.out.println("회원삭제를 처리하지 못하였습니다. - 지속적인 문제 발생시 관리자에게 문의해주세요 -");
				}
			}else {
				System.out.println("삭제를 취소하였습니다.");
			}
		}else
			System.out.println(memberId+"(을)를 가진 회원이 없습니다.");
	}
}

Controller Class

  • Controller 클래스는 View를 통해 사용자가 요청한 데이터를 가지고, 어떤 DAO와 연결해줄지에 대한 제어를 해주는 중간 역할
  • JAVA의 코드만으로는 Controller가 필요 없을 수 있음
  • 실제 컨트롤러
    • 넘어오는 데이터 필터링, 인코딩 해주는 등 (한글 인코딩 처리 작업)
      데이터가 DAO로 넘어가기전에 필터링해주는 작업들을 수행
    • DAO에서 DB와의 업무 처리를 빠르게 해주도록 함 
  package com.test.member.controller;

import java.util.ArrayList;

import com.test.member.model.dao.MemberDAO;
import com.test.member.model.vo.Member;

public class MemberController {
	
	private MemberDAO mDAO = new MemberDAO();
	
	public ArrayList<Member> selectAll() {

		// cotroller의 역할은 요청을 처리할 수 있는  DAO를 연결하는 역할
		ArrayList<Member> list = mDAO.selectAll();
		return list;
	}
	
	public Member selectOneId(String memberId) {
		Member m = mDAO.selectOneId(memberId);
		
		return m;
	
	}
	
	public ArrayList<Member> selectName(String memberName) {
		
		ArrayList <Member> list = mDAO.selectName(memberName);
		
		return list;
	}
	
	
	public boolean insertMember(Member m) {
		
		int resultRow = mDAO.insertMember(m);
		
		if(resultRow>0) {
			return true;	
		}else {
			return false;
		}
	}
	
	public boolean updateMember(Member m) {
		
		int resultRow = mDAO.updateMember(m);
		
		if(resultRow>0) {
			return true;
		}else {
			return false;
		}
	}
	
	public boolean deleteMember(String memberId) {
		
		int result = mDAO.deleteMember(memberId);
		
		if(result >0) {
			return true;
		}else {
			return false;
		}
	}
}

DAO Class

  • DAO: Data Access Object의 약자로써 DB에 접근하여 요청한 작업을 수행하기 위한 객체
  • DB를 통하여 데이터 검색, 삽입, 수정, 삭제 등의 업무 수행
  • DAO에서는 JDBC 작업을 수행하기 위하여 다음과 같은 작업을 수행한다.

    1. 드라이버 등록

    2. DBMS 연결(Connection 객체)

      Statement 방식PreparedStatement 방식
      3-1. Statement 객체 생성(SQL 전송을 위한 객체)
      3-2. SQL문 작성      		3-1. SQL문 작성
      3-2. PreparedStatement 객체 생성
      3-3. 위치 홀더 set

    3. SQL 구문 전송 및 결과 리턴(ResultSet 객체)

    4. 결과 처리

    5. close();

Statement / PreparedStatement

  • 연동된 DBMS에 쿼리를 전송하는 객체
  • PreparedStatement는 Statement를 상속한 자손 Interface (즉, Statement가 부모)

공통점

  • 두 인터페이스 모두 SQL 질의문을 DBMS에 전달하는 역할을 수행
  • 사용시 반드시 try ~ catch 문 또는 throws 처리를 해야 한다.

차이점

  • Statement 방식은 쿼리구문에 데이터를 즉시 명시 해야 함
    (즉, 쿼리문에 값이 미리 입력 되어야 함)
    • INSERT INTO TEST VALUES ('no','id','pw');
  • PreparedStatement 방식은 위치홀더를 이용하여 쿼리구문을 작성할 수 있음
    • INSERT INTO TEST VALUES(?,?,?);
    • setInt(1,'no');
    • setString(2,'id');
    • setString(3,'pw');
  • PreparedStatement 방식은 SQL Injection 중 기본적인 공격 방어가 가능 (간단한 쿼리 조작 공격) 
package com.test.member.model.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import com.test.member.model.vo.Member;

public class MemberDAO {

	public ArrayList<Member> selectAll() {
		// DAO는 DBMS와 연결을 하여 SQL을 전송하고 결과를 받아오는 객체
		// 여기서 필요한 코딩이 JDBC

		Connection conn = null;
		Statement stmt = null;
		ResultSet rset = null;

		// list도 추후 리턴을 위해서 객체를 만들어 주고 try 에서 사용할수 있도록
		ArrayList<Member> list = new ArrayList<Member>();

		try {
			// 1. 드라이버 등록
			Class.forName("oracle.jdbc.driver.OracleDriver");

			// 2. DBMS와의 연결(Connection) (DBMS Connection info, 계정, 비번)
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe", "member", "1234");

			// 3. Statement 객체 생성(SQL을 전송하기 위한 객체)
			stmt = conn.createStatement();

			// 4. SQL 전송
			String sql = "select * from member";
			rset = stmt.executeQuery(sql);

			// rset에 있는 cursor는 처음에는 전체 결과를 가르키고 있다.

			// 5. 결과 처리

			// rset.next() 메소드를 호출하게 되면, 그때부터는 하나의 행을 가르키게 된다.
			// System.out.println(rset.getString("member_name")); // member_no 컬럼 데이터를 가져와서
			// 출력

			// 정보를 가져와서 저장

			while (rset.next()) {

				Member m = new Member();

				m.setMemberNo(rset.getInt("member_no"));
				m.setMemberId(rset.getString("member_id"));
				m.setMemberPwd(rset.getString("member_pwd"));
				m.setMemberName(rset.getString("member_name"));
				m.setGender(rset.getString("gender").charAt(0));
				m.setAge(rset.getInt("age"));
				m.setEmail(rset.getString("email"));
				m.setPhone(rset.getString("phone"));
				m.setAddress(rset.getString("address"));
				m.setHobby(rset.getString("hobby"));
				m.setEnrollDate(rset.getDate("enroll_date"));
				m.setWithdrawYN(rset.getString("withdraw_YN").charAt(0));

				list.add(m);
			}
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			// 6. close 처리
			try {
				rset.close();
				stmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return list;
	}

	public Member selectOneId(String memberId) {

		Connection conn = null;
		PreparedStatement pstmt =null;
		ResultSet rset = null;

		Member m = null;
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe", "member", "1234");
			
			// 기존 SQL
			//String sql = "SELECT * FROM MEMBER WHERE MEMBER_ID= '"+memberId+ "'";
			
			String sql = "SELECT * FROM MEMBER WHERE MEMBER_ID= ?";
			pstmt= conn.prepareStatement(sql);
			pstmt.setString(1, memberId);
			
			//4. SQL 전송 ->PreparedStatement 방식은 이미 생성할때 sql을 담고 있기 때문에 또 넣어줄 필요 없다.
			rset = pstmt.executeQuery();
			
			// 5. 결과 처리
			if(rset.next()) {
				
				m = new Member();

				m.setMemberNo(rset.getInt("member_no"));
				m.setMemberId(rset.getString("member_id"));
				m.setMemberPwd(rset.getString("member_pwd"));
				m.setMemberName(rset.getString("member_name"));
				m.setGender(rset.getString("gender").charAt(0));
				m.setAge(rset.getInt("age"));
				m.setEmail(rset.getString("email"));
				m.setPhone(rset.getString("phone"));
				m.setAddress(rset.getString("address"));
				m.setHobby(rset.getString("hobby"));
				m.setEnrollDate(rset.getDate("enroll_date"));
				m.setWithdrawYN(rset.getString("withdraw_YN").charAt(0));

			}
				
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			
			//6. close
			try {
				rset.close();
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
			
		}
		// 7. 리턴
		return m;
	}

	public ArrayList<Member> selectName(String memberName) {

		Connection conn =null;
		PreparedStatement pstmt= null;
		ResultSet rset = null;
		
		ArrayList<Member> list = new ArrayList<Member>();
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			conn= DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","member","1234");
			
			String sql = "SELECT * FROM MEMBER WHERE MEMBER_NAME LIKE ?";
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, "%"+memberName+"%");
			
			rset = pstmt.executeQuery();
			
			while(rset.next()) {
				Member m  = new Member();
				
				m.setMemberNo(rset.getInt("member_no"));
				m.setMemberId(rset.getString("member_id"));
				m.setMemberPwd(rset.getString("member_pwd"));
				m.setMemberName(rset.getString("member_name"));
				m.setGender(rset.getString("gender").charAt(0));
				m.setAge(rset.getInt("age"));
				m.setEmail(rset.getString("email"));
				m.setPhone(rset.getString("phone"));
				m.setAddress(rset.getString("address"));
				m.setHobby(rset.getString("hobby"));
				m.setEnrollDate(rset.getDate("enroll_date"));
				m.setWithdrawYN(rset.getString("withdraw_YN").charAt(0));
				
				list.add(m);
			}
			
			
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				rset.close();
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return list;

	}

	public int insertMember(Member m) {

		Connection conn = null;
		PreparedStatement pstmt = null;
		int resultRow = 0;

		try {
			// 1. 드라이버 등록
			Class.forName("oracle.jdbc.driver.OracleDriver");

			// 2. DBMS 연결
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe", "member", "1234");

			// 오토커밋 해제
			conn.setAutoCommit(false);

			// 3. PreparedStatement 객체 생성(SQL 처리)
			String sql = "INSERT INTO MEMBER VALUES(SEQ_M_NO.NEXTVAL,?,?,?,?,?,?,?,?,?, SYSDATE, 'N')";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, m.getMemberId());
			pstmt.setString(2, m.getMemberPwd());
			pstmt.setString(3, m.getMemberName());
			pstmt.setString(4, String.valueOf(m.getGender()));
			pstmt.setInt(5, m.getAge());
			pstmt.setString(6, m.getEmail());
			pstmt.setString(7, m.getPhone());
			pstmt.setString(8, m.getAddress());
			pstmt.setString(9, m.getHobby());
			
			// 4. SQL 전송
			// INSERT, UPDATE, DELETE를 처리하기 위한 메소드
			resultRow = pstmt.executeUpdate();

			// 검증
			// System.out.println("처리된 행의 개수: " +resultRow);

			// 5. 결과 처리
			if (resultRow > 0) {
				// 정상 처리 -> 커밋 처리
				conn.commit();
			} else {
				// 비정상 처리 -> 롤백 처리
				conn.rollback();
			}

		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {

			try {
				// 6. close처리
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}
		return resultRow;
	}

	public int updateMember(Member m) {
		Connection conn = null;
		PreparedStatement pstmt = null;
		int resultRow = 0;
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			
			conn= DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","member","1234");
			conn.setAutoCommit(false);
			
			String sql = "UPDATE MEMBER SET ADDRESS=?, EMAIL=?, PHONE=? , HOBBY=? WHERE MEMBER_ID = ?";
			pstmt= conn.prepareStatement(sql);
			
			pstmt.setString(1, m.getAddress());
			pstmt.setString(2, m.getEmail());
			pstmt.setString(3, m.getPhone());
			pstmt.setString(4, m.getHobby());
			pstmt.setString(5, m.getMemberId());
			
			
			resultRow = pstmt.executeUpdate();
			
			if (resultRow>0) {
				conn.commit();
			}else {
				conn.rollback();
			}
			
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally {
			try {
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return resultRow;
		
	}

	public int deleteMember(String memberId) {
		
		Connection conn = null;
		PreparedStatement pstmt = null;
		PreparedStatement pstmt2 = null;
		int result = 0;
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			conn= DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe","member","1234");
			conn.setAutoCommit(false);
			
			String delMemberWriteSql = "INSERT INTO DEL_MEMBER (" + 
					"SELECT SEQ_DEL_MEMBER_NO.NEXTVAL, " + 
					"MEMBER_ID, " + 
					"MEMBER_NAME," + 
					"SYSDATE " + 
					"FROM MEMBER " + 
					"WHERE MEMBER_ID = ?)";
			
			pstmt= conn.prepareStatement(delMemberWriteSql);
			
			pstmt.setString(1, memberId);
			
			int delMemberWriteResult = pstmt.executeUpdate();
			
			
			String memberUpdateSql = "UPDATE MEMBER SET " + 
					"MEMBER_PWD='DELETE-DATA', " + 
					"MEMBER_NAME='DELETE-DATA', " + 
					"GENDER= '-', " + 
					"AGE=0, " + 
					"EMAIL='DELETE-DATA', " + 
					"PHONE='DELETE-DATA', " + 
					"ADDRESS='DELETE-DATA', " + 
					"HOBBY='DELETE-DATA', " + 
					"WITHDRAW_YN='Y' " + 
					"WHERE MEMBER_ID= ?";
			
			pstmt2= conn.prepareStatement(memberUpdateSql);
			pstmt2.setString(1, memberId);
			
			int memberUpdateResult = pstmt2.executeUpdate();
			
			if(delMemberWriteResult>0 && memberUpdateResult>0) {
				conn.commit();
				result =1;
			}else {
				conn.rollback();
				result =0;
			}
			
			
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				conn.rollback();
				pstmt2.close();
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return result;
		
		
	}
}

  • 데이터 표현
구분DBMSJAVA
숫자NUMBERint
문자CHAR(VARCHAR)char
문자열CHAR(VARCHAR)String
  • DBMS는 char형을 하용하지만 , char형은 문자열 형

  • executeQuery 메소드
    • SQL을 전송하고ResultSet을 반환하는 메소드
    • SELECT를 처리하기 위한 메소드

  • executeUpdate 메소드
    • SQL을 전송하고 반영된 행의 개수(int)를 반환하는 메소드
    • INSERT, UPDATE, DELETE 를 처리하기 위한 메소드

  • 자바애플리케이션을 통하여 제공하는 JDBC처리를 하게 되면 자동 커밋 처리
    • 트랜잭션을 제어할 수 없다는 문제점 발생
    • 해결 방법: 자동 커밋처리 해제
      //오토커밋 해제
      conn.setAutoCommit(false);
      - 예외 같은 문제가 발생하여 커밋 또는 롤백을 하지 않고 그냥 connection 을 끊어버리면 -> commit이 된다.


profile
김승현
개발자로 매일 한 걸음
이전 포스트

Chapter 1. JDBC

다음 포스트

Chapter 4. Service 구현(회원관리 CRUD 만들기 STEP2)

0개의 댓글