[JDBC] Day2 - Callablestatement

윤수인·2023년 12월 27일

📒국비학원 [DB]

목록 보기

13/14

Callablestatement - 거의 안함

: plsql - 프로시저를 호출해서 사용함
ex) sql = "{call insertScore(?,?,?,?,?)}"; //call프로시저를 호출하는 방법

1.

Callablestatement

💻 입력

1. procedure를 통해 DB access하는 법- 학번/과목점수/랭킹 출력 예제

Test3. 사용자한테 값을 받는 class와 DB에 저장하는 query로 나누기

✅ cmd

Score 패키지와 관련된 프로시저(Procedure) 생성하기

scoreDTO : DTO [Data Transfer Object] : 데이터를 DB에 전달해주는 역할

package com.score6;

public class ScoreDTO { // DTO [Data Transfer Object] : 데이터를 DB에 전달해주는 역할

	
	//사용자한테 5개 데이터 받았는데 어디에가 넣어야할지 모를땐 무조건 DTO!!! => 객체생성해야함 
	
	private String hak;
	private String name;
	private int kor;
	private int eng;
	private int mat;
	
	//집어넣을 땐 위에 5개의 데이터
	//꺼내올 땐 8개의 데이터 
	private int tot;
	private int ave;
	private int rank;
	
	
	
	public String getHak() {
		return hak;
	}
	public void setHak(String hak) {
		this.hak = hak;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getKor() {
		return kor;
	}
	public void setKor(int kor) {
		this.kor = kor;
	}
	public int getEng() {
		return eng;
	}
	public void setEng(int eng) {
		this.eng = eng;
	}
	public int getMat() {
		return mat;
	}
	public void setMat(int mat) {
		this.mat = mat;
	}
	public int getTot() {
		return tot;
	}
	public void setTot(int tot) {
		this.tot = tot;
	}
	public int getAve() {
		return ave;
	}
	public void setAve(int ave) {
		this.ave = ave;
	}
	public int getRank() {
		return rank;
	}
	public void setRank(int rank) {
		this.rank = rank;
	}
	
	
	@Override
		public String toString() {
		
		String str;
		str = String.format("%8s %8s %4d %4d %4d %4d %4d %4d", 
				hak,name,kor,eng,mat,tot,ave,rank);
	
			return str;
		}
}

scoreDAO DAO [Data Access Object] : DB에 연결 후 INSERT/UPDATE/DELETE를 통해 DB에 ACCESS하는 법

package com.score7;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.db.DBConn;

import oracle.jdbc.OracleTypes;


//CallableStatement (plsql - 프로시저를 호출해서 사용함)

public class ScoreDAO {//  JDBC

		public int insertData(ScoreDTO dto) {
			
			int result = 0;
			
			Connection conn = DBConn.getConnection();

			CallableStatement cstmt = null;
			String sql;
			
			try {
				
				sql = "{call insertScore(?,?,?,?,?)}"; //call프로시저를 호출하는 방법
				sql += "values (?,?,?,?,?)";
				
				cstmt = conn.prepareCall(sql);

				// getter로 들어온 5개의 값이 set으로 받아서 pstmt에 들어가게 됨
				cstmt.setString(1, dto.getHak()); 
				cstmt.setString(2, dto.getName());
				cstmt.setInt(3, dto.getKor());
				cstmt.setInt(4, dto.getEng());
				cstmt.setInt(5, dto.getMat());
				
				result = cstmt.executeUpdate(); 
				
				cstmt.close(); 
				
			} catch (Exception e) {
				System.out.println(e.toString());
			}
			
			return result;
		}
		
		
		
		// 수정
		public int updateData(ScoreDTO dto) {

			int result = 0;

			Connection conn = DBConn.getConnection(); //DBConn은 이미 static이라 메모리상에 올라가있으므로 run실행하자마자 그걸 가지고옴
			CallableStatement cstmt = null;
			String sql;

			try {

				sql = "{call updateScore(?,?,?,?)} "; 

				cstmt = conn.prepareCall(sql);
				
				cstmt.setString(1, dto.getHak());
				cstmt.setInt(2, dto.getKor());
				cstmt.setInt(3, dto.getEng());
				cstmt.setInt(4, dto.getMat());


				result = cstmt.executeUpdate();

			} catch (Exception e) {
				System.out.println(e.toString());
			}
			return result;

		}

		//삭제
		public int deleteData(String hak) {
			
			int result = 0;
			
			Connection conn = DBConn.getConnection();
			CallableStatement cstmt = null;
			String sql;
			
			try {
				
				sql = "delete score where hak = ? ";
				
				cstmt = conn.prepareCall(sql);
			
				cstmt.setString(1, hak);

				result = cstmt.executeUpdate();
				
				cstmt.close();
				
			} catch (Exception e) {
				System.out.println(e.toString());
			}
			
			return result;
		}
		
		
		
		//전체 출력 ((동명이인이 나올 수도 있으니까 LIST로 받음)
		public List<ScoreDTO> getList(){
			
			List<ScoreDTO> lists = new ArrayList<ScoreDTO>();
			
			
			Connection conn = DBConn.getConnection();
			CallableStatement cstmt = null;
			
			//select를 하게 됐을때 select 한 결과(table)를 담는 그릇인 ResultSet (interface) 가 무조건 필요함
			ResultSet rs = null;
					
			String sql;
			
			try {
				
				//select문
				sql =  "{call selectAllScore(?)}"; //out용도로 precedure만들때 돌려받는 커서를 만듦
				
				cstmt = conn.prepareCall(sql);
				
				//out 파라미터의 자료형 설정 (line 129)
				cstmt.registerOutParameter(1, OracleTypes.CURSOR); //반환받는 cursor타입의 ? 타입을 정한거
				
				//프로시저 실행
				cstmt.executeQuery(); 
				
				// out 파라미터 값 돌려받기 
				rs = (ResultSet)cstmt.getObject(1);
				
				
				while(rs.next()) { //next() : 다음 한칸 내려봤을때 데이터가 있니?
					
					//데이터가 있으면
					ScoreDTO dto = new ScoreDTO();
					
					dto.setHak(rs.getString(1));//1번부터 시작 
					dto.setName(rs.getString("name"));
					dto.setKor(rs.getInt(3));
					dto.setEng(rs.getInt("eng"));
					dto.setMat(rs.getInt(5));
					
					dto.setTot(rs.getInt("tot"));
					dto.setAve(rs.getInt(7));
					dto.setRank(rs.getInt("rank"));
					
					
					lists.add(dto);
					
				}
				rs.close();
				cstmt.close();

			} catch (Exception e) {
				System.out.println(e.toString());
			}

			return lists;

		}

		
		
		
		// 이름검색 (동명이인이 나올 수도 있으니까 LIST로 받음)
		public List<ScoreDTO> searchName(String name) {

			List<ScoreDTO> lists = new ArrayList<ScoreDTO>();

			Connection conn = DBConn.getConnection();
			CallableStatement cstmt = null;

			// select를 하게 됐을때 select 한 결과(table)를 담는 그릇인 ResultSet (interface) 가 무조건 필요함
			ResultSet rs = null;
					
			String sql;
			
			try {
				
				//select문
				sql = "{call selectNameScore(?,?)}"; //이름검색은 매개변수 2개 나오는 cursor값/돌려받는 값
				
				cstmt = conn.prepareCall(sql);
				
				//out 파라미터의 자료형 설정 (line 129)
				cstmt.registerOutParameter(1, OracleTypes.CURSOR); 
				
				//in 파라미터
				cstmt.setString(2, name);
				
				//프로시저 실행
				cstmt.executeQuery(); 
				
				rs = (ResultSet)cstmt.getObject(1); //첫번째 물음표 값 받아주기
				
				
				while(rs.next()) { // 이름몇개인지 모르니까 while / next() : 다음 한칸 내려봤을때 데이터가 있니?
					
					//데이터가 있으면
					ScoreDTO dto = new ScoreDTO();
					
					dto.setHak(rs.getString(1));//1번부터 시작 
					dto.setName(rs.getString("name"));
					dto.setKor(rs.getInt(3));
					dto.setEng(rs.getInt("eng"));
					dto.setMat(rs.getInt(5));
					
					dto.setTot(rs.getInt("tot"));
					dto.setAve(rs.getInt(7));
					dto.setRank(rs.getInt("rank"));
					
					
					lists.add(dto);
					
				}
				rs.close();
				cstmt.close();

			} catch (Exception e) {
				System.out.println(e.toString());
			}

			return lists;

		}
		
		
		
		//학번검색  (동명이인이 나올 수도 있으니까 LIST로 받음)
			public ScoreDTO searchHak(String hak) { //hak은 똑같은 데이터 없음 - primary key => dto에 담을거고 dto를 반환해주면 됨

				ScoreDTO dto = null; //new 객체생성 - 없을 수도 있으니까 , 필요할때 객체생성하면 됨

				Connection conn = DBConn.getConnection();
				CallableStatement cstmt = null;

				// select를 하게 됐을때 select 한 결과(table)를 담는 그릇인 ResultSet (interface) 가 무조건 필요함
				ResultSet rs = null;
						
				String sql;
				
				try {
					
					//select문
					sql =  "{call selectHakScore(?,?)}";
					
					cstmt = conn.prepareCall(sql);
					
					//out 파라미터의 자료형 설정 (line 129)
					cstmt.registerOutParameter(1, OracleTypes.CURSOR); 
					
					//in 파라미터
					cstmt.setString(2, hak);
					
					//프로시저 실행
					cstmt.executeQuery(); 
					
					rs = (ResultSet)cstmt.getObject(1); //첫번째 물음표 값 받아주기
					
					if(rs.next()) { // 어차피 하나 = if /  다음 한칸 내려봤을때 데이터가 있니?
						
						// 데이터가 있으면
						dto = new ScoreDTO();

						dto.setHak(rs.getString(1));// 1번부터 시작
						dto.setName(rs.getString("name"));
						dto.setKor(rs.getInt(3));
						dto.setEng(rs.getInt("eng"));
						dto.setMat(rs.getInt(5));

						dto.setTot(rs.getInt("tot"));
						dto.setAve(rs.getInt(7));
					}

					rs.close();
					cstmt.close();

				} catch (Exception e) {
					System.out.println(e.toString());
				}

				return dto;

			}
		}

score : 사용자한테 데이터 5개 받아내는 클래스

package com.score6;

import java.util.Iterator;
import java.util.List;
import java.util.Scanner;

public class Score { //사용자한테 데이터 5개 받아내는 클래스

	ScoreDAO dao = new ScoreDAO();
	
	Scanner sc = new Scanner(System.in);
	
	//입력
	public void insert() {
		
		ScoreDTO dto = new ScoreDTO(); //dto는 실행할때마다 새롭게 만들거니까 안에다가 만들어줘야함
		
		System.out.print("학번?");
		dto.setHak(sc.next());
		
		System.out.print("이름?");
		dto.setName(sc.next());
		
		System.out.print("국어?");
		dto.setKor(sc.nextInt());
		
		System.out.print("영어?");
		dto.setEng(sc.nextInt());
		
		System.out.print("수학?");
		dto.setMat(sc.nextInt());
		
		int result = dao.insertData(dto); //5개의 데이터를 dto를 가지고 dao에 가서 실행 한후 1/0으로 반환
		
		if(result != 0) {
			System.out.println("추가 성공!");
		}else {
			System.out.println("추가 실패!");
		}
	}
	
	
	//수정
	public void update() {
		ScoreDTO dto = new ScoreDTO();
		
		System.out.println("수정할 학번?");
		dto.setHak(sc.next());
		
		System.out.print("국어?");
		dto.setKor(sc.nextInt());
		
		System.out.print("영어?");
		dto.setEng(sc.nextInt());
		
		System.out.print("수학?");
		dto.setMat(sc.nextInt());
		
		int result = dao.updateData(dto);
		
		if(result != 0) {
			System.out.println("수정 성공!");
		}else {
			System.out.println("수정 실패!");
		}
		
	}
	
	
	
	//
	public void delete() {
		
		try {
			
			System.out.print("삭제할 학번?");
			String hak = sc.next();
			
			int result = dao.deleteData(hak);// 학을 넘기면 삭제가 됨

			
			if(result != 0) {
				System.out.println("삭제 성공!");
			}else {
				System.out.println("삭제 실패!");
			}
			
		} catch (Exception e) {
			// TODO: handle exception
		}
		
		
	}

	public void selectAll() {

		List<ScoreDTO> lists = dao.getList();

		Iterator<ScoreDTO> it = lists.iterator();

		while (it.hasNext()) {
			ScoreDTO dto = it.next();
			System.out.println(dto.toString());
		}

	}

	public void searchName() {
		
		System.out.print("검색할 이름?");
		String name = sc.next();
		
		List<ScoreDTO> lists = dao.searchName(name); //name으로 select를 해서 lists로 돌려줌.
		
		Iterator<ScoreDTO> it = lists.iterator();

		while (it.hasNext()) {
			ScoreDTO dto = it.next();
			System.out.println(dto.toString());
		}
	}

	
	public void searchHak() {

		System.out.print("검색할 학번?");
		String hak = sc.next();

		ScoreDTO dto = dao.searchHak(hak); //name으로 select를 해서 lists로 돌려줌.
		
		if (dto != null) { //안에 뭐가있다면
			System.out.println(dto.toString()); //그냥 어차피 하나 나오니까 그거 출력해~
		}
	}
}

scoreMain : 메뉴) 1. 2. 3.

package com.score6;

import java.util.Scanner;

public class ScoreMain {

	public static void main(String[] args) {

		Scanner sc = new Scanner(System.in);
		Score ob = new Score();
		
		int ch;
		
		while(true) {
			
			do {
				System.out.print("1.추가 2.수정 3.삭제 4.전체출력 5.이름검색 6.학번검색 7.종료");
				ch = sc.nextInt();
				
			}while(ch<1);
			
			switch (ch) {
			
			case 1:
				ob.insert();
				break;
				
			case 2:
				ob.update();
				break;
				
			case 3:
				ob.delete();
				break;
				
			case 4:
				ob.selectAll();
				break;
				
			case 5:
				ob.searchName();
				break;

			case 6:
				ob.searchHak();
				break;

			case 7:
				System.exit(0);
				break;

			default:
				break;
			}
		}
	}
}

✨ 출력

1.추가 2.종료1
학번?111
이름?suzi
국어?50
영어?60
수학?70
추가 성공!
1.추가 2.종료1
학번?222
이름?inna
국어?60
영어?70
수학?80
추가 성공!
1.추가 2.종료

윤수인

어제보다 조금 더 성장하기!

이전 포스트

[PL/SQL] Day3 - TRIGGER

다음 포스트