PreparedStatement 활용

 

myBatis를 사용하면 아래에 설명된 번거로운 작업을 간편화할 수 있다...

 

 

MemberDTO 클래스

데이터 전송 객체

한 회원의 정보를 담고 있음 

getter, setter을 통해 다른 클래스에서 접근 가능 

package db.member2;

public class MemberDTO {
	private String id;
	private String pwd;
	private String name;
	private String birth;
	private String email;
	private String tel;

	public String getId() {
		return id;
	}

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

	public String getPwd() {
		return pwd;
	}

	public void setPwd(String pwd) {
		this.pwd = pwd;
	}

	public String getName() {
		return name;
	}

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

	public String getBirth() {
		return birth;
	}

	public void setBirth(String birth) {
		this.birth = birth;
	}

	public String getEmail() {
		return email;
	}

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

	public String getTel() {
		return tel;
	}

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

 

MemberDAO 인터페이스

데이터베이스의 CRUD를 위한 인터페이스

인터페이스 : 모든 기능을 추상화로 정의하고 구현은 하지 않은 것 

package db.member2;
import java.sql.SQLException;
import java.util.List;

public interface MemberDAO {
	public int insertMember(MemberDTO dto) throws SQLException;
	public int updateMember(MemberDTO dto) throws SQLException;
	public int deleteMember(String id) throws SQLException;
	
	public MemberDTO readMember(String id);
	public List<MemberDTO> listMember();
	public List<MemberDTO> listMember(String name);
}

 

 

MemberDAOImpl 클래스

MemberDAO 인터페이스 구현 클래스 (MemberDAO를 상속)

member1, member2 테이블의 DML, SELECT 등 데이터 처리를 주목적으로 하는 클래스

주요 기능이 구현되는 클래스

package db.ch1;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLDataException;
import java.sql.SQLException;
import java.sql.SQLIntegrityConstraintViolationException;
import java.util.ArrayList;
import java.util.List;

import db.util.DBConn;

public class MemberDAOImpl implements MemberDAO {
	private Connection conn = DBConn.getConnection(); //DB 연결

	@Override
	public int insertMember(MemberDTO dto) throws SQLException {
    // 회원 삽입
		int result = 0;
		PreparedStatement pstmt = null; //PreparedStatement 객체 선언
		String sql;

		try {
			sql = "INSERT INTO member1(id, pwd, name) VALUES ( ?, ?, ? )";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, dto.getId()); //1번째 ?에 dto객체에서 Id를 가져오겠다는 의미
			pstmt.setString(2, dto.getPwd());
			pstmt.setString(3, dto.getName());

			result = pstmt.executeUpdate(); //sql문 실행
			pstmt.close();

			sql = "INSERT INTO member2(id, birth, email, tel) VALUES ( ?, ?, ?, ? )";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, dto.getId());
			pstmt.setString(2, dto.getBirth());
			pstmt.setString(3, dto.getEmail());
			pstmt.setString(4, dto.getTel());

			result += pstmt.executeUpdate();

		} catch (SQLIntegrityConstraintViolationException e) {
			// 기본키 제약 위반, NOT NULL 등의 제약 위반 - 무결성 제약 위반시 발생
			if (e.getErrorCode() == 1) { // 기본키 중복
				System.out.println("아이디 중복으로 등록이 불가능합니다.");
			} else if (e.getErrorCode() == 1400) { // NOT NULL
				System.out.println("필수 입력 사항을 입력 하지 않았습니다.");
			} else {
				System.out.println(e.toString());
			}

			throw e;

		} catch (SQLDataException e) {
			// 날짜등의 형식 잘못으로 인한 예외
			if (e.getErrorCode() == 1840 || e.getErrorCode() == 1861) {
				System.out.println("날짜 입력 형식 오류 입니다.");
			} else {
				System.out.println(e.toString());
			}

			throw e;

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

			throw e;

		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}
		}

		return result;
	}

	@Override
	public int updateMember(MemberDTO dto) throws SQLException {
		int result = 0;
		PreparedStatement pstmt = null;
		String sql;

		try {
			sql = "UPDATE member1 SET pwd = ?, name = ? WHERE id = ?";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, dto.getPwd());
			pstmt.setString(2, dto.getName());
			pstmt.setString(3, dto.getId());

			result = pstmt.executeUpdate();
			pstmt.close();

			sql = "UPDATE member2 SET birth = ?, email = ?, tel = ? WHERE id = ?";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, dto.getBirth());
			pstmt.setString(2, dto.getEmail());
			pstmt.setString(3, dto.getTel());
			pstmt.setString(4, dto.getId());

			result += pstmt.executeUpdate();

		} catch (SQLIntegrityConstraintViolationException e) {
			if (e.getErrorCode() == 1400) { // NOT NULL
				System.out.println("필수 입력 사항을 입력 하지 않았습니다.");
			} else {
				System.out.println(e.toString());
			}

			throw e;

		} catch (SQLDataException e) {
			// 날짜등의 형식 잘못으로 인한 예외
			if (e.getErrorCode() == 1840 || e.getErrorCode() == 1861) {
				System.out.println("날짜 입력 형식 오류 입니다.");
			} else {
				System.out.println(e.toString());
			}

			throw e;

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

			throw e;

		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}
		}

		return result;
	}

	@Override
	public int deleteMember(String id) throws SQLException {
		int result = 0;
		PreparedStatement pstmt = null;
		String sql;

		try {
			sql = "DELETE FROM member2 WHERE id = ?";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, id);

			result = pstmt.executeUpdate();
			pstmt.close();

			sql = "DELETE FROM member1 WHERE id = ?";
			pstmt = conn.prepareStatement(sql);

			pstmt.setString(1, id);

			result += pstmt.executeUpdate();

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

			throw e;

		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}
		}

		return result;
	}

	@Override
	public MemberDTO readMember(String id) {
		MemberDTO dto = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql;

		try {
			sql = "SELECT m1.id, pwd, name, TO_CHAR(birth, 'YYYY-MM-DD') birth, email, tel " + " FROM member1 m1 "
					+ " LEFT OUTER JOIN member2 m2 ON m1.id = m2.id " + " WHERE m1.id = ? ";

			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, id);
			rs = pstmt.executeQuery();

			if (rs.next()) {
				dto = new MemberDTO();

				dto.setId(rs.getString("id"));
				dto.setPwd(rs.getString("pwd"));
				dto.setName(rs.getString("name"));
				dto.setBirth(rs.getString("birth"));
				dto.setEmail(rs.getString("email"));
				dto.setTel(rs.getString("tel"));
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if (rs != null) {
				try {
					rs.close();
				} catch (Exception e2) {
				}
			}

			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}

		}

		return dto;
	}

	@Override
	public List<MemberDTO> listMember() {
		List<MemberDTO> list = new ArrayList<>();
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql;

		try {
			sql = "SELECT m1.id, pwd, name, TO_CHAR(birth, 'YYYY-MM-DD') birth, email, tel " + " FROM member1 m1 "
					+ " LEFT OUTER JOIN member2 m2 ON m1.id = m2.id ";

			pstmt = conn.prepareStatement(sql);

			rs = pstmt.executeQuery();

			while (rs.next()) {
				MemberDTO dto = new MemberDTO();

				dto.setId(rs.getString("id"));
				dto.setPwd(rs.getString("pwd"));
				dto.setName(rs.getString("name"));
				dto.setBirth(rs.getString("birth"));
				dto.setEmail(rs.getString("email"));
				dto.setTel(rs.getString("tel"));

				list.add(dto);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if (rs != null) {
				try {
					rs.close();
				} catch (Exception e2) {
				}
			}

			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}

		}

		return list;
	}

	@Override
	public List<MemberDTO> listMember(String name) {
		List<MemberDTO> list = new ArrayList<>();
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql;

		try {
			sql = "SELECT m1.id, pwd, name, TO_CHAR(birth, 'YYYY-MM-DD') birth, email, tel " + " FROM member1 m1 "
					+ " LEFT OUTER JOIN member2 m2 ON m1.id = m2.id " + " WHERE INSER(name, ?) > 0";

			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, name);

			rs = pstmt.executeQuery();

			while (rs.next()) {
				MemberDTO dto = new MemberDTO();

				dto.setId(rs.getString("id"));
				dto.setPwd(rs.getString("pwd"));
				dto.setName(rs.getString("name"));
				dto.setBirth(rs.getString("birth"));
				dto.setEmail(rs.getString("email"));
				dto.setTel(rs.getString("tel"));

				list.add(dto);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			if (rs != null) {
				try {
					rs.close();
				} catch (Exception e2) {
				}
			}

			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {
				}
			}

		}

		return list;
	}

}

 

INSERT ALL을 이용한 다중행 삽입

sql = "INSERT ALL "
	+ " INTO member1(id, pwd, name) VALUES ( ?, ?, ? )"
	+ " INTO member2(id, birth, email, tel) VALUES ( ?, ?, ?, ? )"
	+ " SELECT * FROM dual ";

pstmt = conn.prepareStatement(sql);
			
pstmt.setString(1, dto.getId());
pstmt.setString(2, dto.getPwd());
pstmt.setString(3, dto.getName());
pstmt.setString(4, dto.getId());
pstmt.setString(5, dto.getBirth());
pstmt.setString(6, dto.getEmail());
pstmt.setString(7, dto.getTel());
			
result = pstmt.executeUpdate();

 

DAO(Data Access Object)

DB를 사용하여 데이터의 조회 및 조작하는 기능을 담당

데이터에 접근하기 위해 생성하는 객체

데이터베이스에 접근하기 위한 로직과 비즈니스 로직을 분리하기 위해 사용되는 개념 

 

MemberUI 클래스

데이터 입출력을 위한 클래스

package db.member2;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.List;

import db.util.DBConn;

public class MemberUI {
	private BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
	private MemberDAO dao = new MemberDAOImpl();

	public void menu() {
		System.out.println("PreparedStatement - 회원 예제...");

		int ch;

		while (true) {
			try {
				System.out.print("1.등록 2.수정 3.삭제 4.아이디검색 5.이름검색 6.리스트 7.종료 => ");
				ch = Integer.parseInt(br.readLine());

				if (ch == 7) {
					DBConn.close();
					return;
				}
	
				switch(ch) {
				case 1: insert(); break;
				case 2: update(); break;
				case 3: delete(); break;
				case 4: findById(); break;
				case 5: findByName(); break;
				case 6: listAll(); break;
				}
				
			} catch (Exception e) {
			}
		}
		
	}

	protected void insert() {
		System.out.println("\n회원 가입 !!!");

		try {
			MemberDTO dto = new MemberDTO();

			System.out.print("아이디 ? ");
			dto.setId(br.readLine());

			System.out.print("패스워드 ? ");
			dto.setPwd(br.readLine());

			System.out.print("이름 ? ");
			dto.setName(br.readLine());

			System.out.print("생년월일 ? ");
			dto.setBirth(br.readLine());

			System.out.print("이메일 ? ");
			dto.setEmail(br.readLine());

			System.out.print("전화번호 ? ");
			dto.setTel(br.readLine());

			dao.insertMember(dto);

			System.out.println("회원가입이 성공 했습니다.");
		} catch (Exception e) {
		}

		System.out.println();
	}

	protected void update() {
		System.out.println("\n회원 정보 수정 !!!");

		try {
			MemberDTO dto = new MemberDTO();

			System.out.print("수정할 아이디 ? ");
			dto.setId(br.readLine());

			System.out.print("패스워드 ? ");
			dto.setPwd(br.readLine());

			System.out.print("이름 ? ");
			dto.setName(br.readLine());

			System.out.print("생년월일 ? ");
			dto.setBirth(br.readLine());

			System.out.print("이메일 ? ");
			dto.setEmail(br.readLine());

			System.out.print("전화번호 ? ");
			dto.setTel(br.readLine());

			int result = dao.updateMember(dto);

			if (result == 0) {
				System.out.println("등록된 자료가 아닙니다.");
			} else {
				System.out.println("회원정보가 수정 되었습니다.");
			}
		} catch (Exception e) {
		}
		System.out.println();

	}

	protected void delete() {
		System.out.println("\n회원 탈퇴 !!!");

		String id;

		try {
			System.out.print("삭제할 아이디 ? ");
			id = br.readLine();

			int result = dao.deleteMember(id);

			if (result == 0) {
				System.out.println("등록된 자료가 아닙니다.");
			} else {
				System.out.println("회원정보가 삭제 되었습니다.");
			}
		} catch (Exception e) {
		}
		System.out.println();

	}

	protected void findById() {
		System.out.println("\n아이디 검색 !!!");
		String id;

		try {
			System.out.print("검색할 아이디 ? ");
			id = br.readLine();

			MemberDTO dto = dao.readMember(id);
			if (dto == null) {
				System.out.println("등록된 아이디가 아닙니다.\n");
				return;
			}

			System.out.print(dto.getId() + "\t");
			// System.out.print(dto.getPwd()+"\t");
			System.out.print(dto.getName() + "\t");
			System.out.print(dto.getBirth() + "\t");
			System.out.print(dto.getEmail() + "\t");
			System.out.println(dto.getTel());
		} catch (Exception e) {
		}

		System.out.println();
	}

	protected void findByName() {
		System.out.println("\n이름 검색 !!!");

		String name;

		try {
			System.out.print("검색할 이름 ? ");
			name = br.readLine();

			List<MemberDTO> list = dao.listMember(name);
			if (list.size() == 0) {
				System.out.println("등록된 이름이 없습니다.\n");
				return;
			}

			for (MemberDTO dto : list) {
				System.out.print(dto.getId() + "\t");
				// System.out.print(dto.getPwd()+"\t");
				System.out.print(dto.getName() + "\t");
				System.out.print(dto.getBirth() + "\t");
				System.out.print(dto.getEmail() + "\t");
				System.out.println(dto.getTel());
			}
		} catch (Exception e) {
		}

		System.out.println();

	}

	protected void listAll() {
		System.out.println("\n전체 리스트 !!!");

		List<MemberDTO> list = dao.listMember();

		for (MemberDTO dto : list) {
			System.out.print(dto.getId() + "\t");
			// System.out.print(dto.getPwd()+"\t");
			System.out.print(dto.getName() + "\t");
			System.out.print(dto.getBirth() + "\t");
			System.out.print(dto.getEmail() + "\t");
			System.out.println(dto.getTel());
		}

		System.out.println();
	}
}

 

App 클래스

main 메소드를 포함하고 있는 클래스

MemberUI의 menu() 메소드를 호출해 프로그램을 실행

public class App {
	public static void main(String[] args) {
		new MemberUI().menu();
	}
}

 

 

예외 처리

SQLIntegrityConstraintViolationException

무결성 제약 조건(외래 키, 기본 키 또는 고유 키)이 위반

 

SQLDataException

 허용되지 않는 변환, 0으로 나누기 및 함수에 대한 유효하지 않은 인수를 포함하되 이에 국한되지 않는 다양한 데이터 오류

 

SQLException

데이터베이스 액세스 오류 또는 기타 오류에 대한 정보를 제공하는 예외