[JDBC]PreparedStatement의 동적 쿼리출력

PreparedStatement를 이용하여 동적sql객체 생성시 보내지는 쿼리문을 알 수 없어

디버깅시 불편하기에 보내지는 쿼리문을 invoke를 이용하여 재구현해보았다.

log4sql 라이브러리를 설치하는 방법이 있으니 여기선 Reflection api활용을 연습하기위해 생략한다.

import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.sql.Connection; import java.sql.Date; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.ArrayList; public class EmployeeDAO { private static final String driver = "oracle.jdbc.driver.OracleDriver"; private static final String url = "jdbc:oracle:thin:@localhost:1521:orcl"; private static final String user = "hr"; private static final String pwd = "1234"; Connection conn = null; //Statement stmt = null; 정적 sql에서만 쓰임 PreparedStatement pstmt = null; //동적 sql 객체 ResultSet rs = null; public EmployeeDAO() {connDB();} public void connDB() { try { //Class.forName(driver); conn = DriverManager.getConnection(url, user, pwd); } catch (SQLException e) { e.printStackTrace(); } } public void addEmployee(EmployeeVO employee) { String query1 = "insert into employee(companyID, name, joinDate) values (?, ?, SYSDATE)"; try { pstmt = conn.prepareStatement(query1); pstmt.setInt(1, employee.getCompanyID()); pstmt.setString(2, employee.getName()); String aq=((oracle.jdbc.internal.OraclePreparedStatement)pstmt).getOriginalSql(); //actual query Method[] methods = employee.getClass().getDeclaredMethods(); //선언된 모든 메소드를 메소드배열에 담음 //↑[ getName, setName, setCompanyID, getJoinDate, getCompanyID, setJoinDate, getName... ] String []cs = aq.substring(aq.indexOf("(")+1, aq.indexOf(")")).replace(" ","").split(","); Object value = null; //↑[ "companyID", "name", "joinDate" ] 배열생성 for(String c:cs) //배열의 값을 순서대로 c에 넣어 루프 for(Method m : methods) { //메소드배열의 메소드를 순서대로 m에 넣어 루프 if (m.getName().equalsIgnoreCase("get"+c)) { //get으로 시작되는 메소드명이 대소문자 구별없이 c와 같을경우 value = m.invoke(employee, null); //해당 메소드 호출후 리턴값을 저장 if (value instanceof Integer) //리턴된 타입이 Integer형 인경우 aq=aq.replaceFirst("\\?", value.toString()); //리턴값을 해당타입으로 변환후 처음 검색되는 ?에 치환 else if(value instanceof String) //리턴된 타입이 String형 인경우 aq=aq.replaceFirst("\\?",(String)value); else if(value instanceof Date) //리턴된 타입이 Date형 인경우 aq=aq.replaceFirst("\\?",new SimpleDateFormat("yy/mm/dd").format((Date)value)); /*if(m.getName().equals("getCompanyID")) aq=aq.replaceFirst("\\?", Integer.toString((int)m.invoke(employee, null))); else if(m.getName().equals("getName")) aq=aq.replaceFirst("\\?",(String)m.invoke(employee, null)); else if(m.getName().equals("getJoinDate")) aq=aq.replaceFirst("\\?",new SimpleDateFormat("yy/mm/dd").format((Date)m.invoke(employee, null))); */ } } System.out.println(aq); pstmt.executeUpdate(); pstmt.close(); } catch (SQLException | IllegalAccessException | IllegalArgumentException | InvocationTargetException e) { e.printStackTrace(); } } public ArrayList<EmployeeVO> getListAll() { ArrayList<EmployeeVO> empList = new ArrayList<EmployeeVO>(); String query2 = "select * from employee order by companyID"; try { pstmt = conn.prepareStatement(query2); rs = pstmt.executeQuery(); while(rs.next()) { int id = rs.getInt("companyID"); String name = rs.getString("name"); Date date = rs.getDate("joinDate"); EmployeeVO employee = new EmployeeVO(); employee.setCompanyID(id); employee.setName(name); employee.setJoinDate(date); empList.add(employee); } rs.close(); pstmt.close(); } catch (SQLException e) { e.printStackTrace(); } return empList; } }