21.02.19 TIL(D+28 JDBC을 통한 DML 구현)

학습 내용

Eclipse와 Oracle을 연동한 JDBC

 

- JDBC (Java DataBase Connectivity)

 

 자바에서 데이터베이스에 접속할 수 있도록 하는 자바 API이다.

 

 

기본적인 연동 방법

 

1. JdbcConnect 클래스 (예시) 생성

2. 기본 생성자로 JDBC 드라이버를 로딩할 수 있는 try, catch문 작성 (주석 참고)

3. java.sql 에 속해있는 Connection 클래스의 getConnection() 메소드를 통해 해당 url의 객체 생성

4. getConnection()에 입력할 url 주소는 아래와 같이 찾을 수 있다.

5. Main 메소드에서 인스턴스 생성 후 접속이 되는지 확인

 

Perspective - Database Development 선택 후 생성한 Oracle Properties 선택

 

Connection URL 값 = URL

 

 

JdbcConnect 클래스

package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;


public class JdbcConnect {

	public JdbcConnect() { // JDBC 드라이버 로딩
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver"); //Class.forName()을 이용해서 Driver Class를 로딩하면 객체가 생성
			
			System.out.println("Driver loading Success");
			
		} catch (ClassNotFoundException e) { //Driver 클래스를 찾지 못할 경우, ClassNotFoundException 예외가 발생
			
			System.out.println("Driver가 없습니다."); 
			
		}
	}
	
	
	public Connection getConnection() {
		
		Connection conn = null;  //Connection - 데이터베이스와 연결하는 객체
		try {
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:xe", "hr", "hr");
			     //DriverManager.getConnection(연결문자열, DB_ID, DB_PW) 으로 Connection 객체를 생성
			
			System.out.println("Oracle Connection Success");
			
		} catch(SQLException e) {
			
			System.out.println("DB를 연결하지 못했습니다.");
		}
	
		return conn;
		
	}
		
		
}

 

Main 클래스

package jdbcConnecttion;
import jdbc.JdbcConnect;

public class MainClass {

	public static void main(String[] args) {

		JdbcConnect jc = new JdbcConnect();

		jc.getConnection();
	}

}

 

실행 값 :

 Driver loading Success
 Oracle Connection Success

 

---

- JDBC를 통한 DML 구현

 

 

1. insert 클래스 ( delete, update도 비슷하다.)

 

위에 적어둔 기본 연동을 해두고 insertData() 메소드를 추가해주었다.

 

작성 시 주의할 점

 1. sql 쿼리문 작성 시엔 큰따옴표의 처음과 앞에 한칸씩 띄워주는 습관을 갖는다. 

   (편의상 개행되어 작성된 쿼리가 이전 행의 쿼리와 맞붙으면 구문 오류가 날수 있기 때문)

 

 2. 매개변수로 받는 자료형과 DB안에 저장될 컬럼의 자료형을 맞춰준다. 

    (아래 예시는 DB에 id, 이름, 나이, 등록일(SYSDATE)를 받기 때문에  id, 이름, 나이를 매개 변수로 받아준다.)

 

 3. Connection conn = getConnection(); 와
     Statement stmt = null; 은 DB와 연결하기 위해 무조건 필요한 과정이다. (그냥 외우자)

    예외 처리를 위해 try, catch문으로 작성한다.

    insert, delete, update 문에 모두 쓰인다. ( 참고로 select는 하나 더 있기에 다음 예제 때 작성한다.)

 

 4.  위의 try, catch문에 finally문(예외에 상관없이 실행이 보장되는 구문)을 추가하여 그 안에 DB를 닫아주는

      close() 메소드를 다시 한번 try, catch문으로 작성해준다. (반드시 닫아주는 습관을 가진다.)

 

 5. executeUpdate() :  INSERT / DELETE / UPDATE 관련 구문에서는 반영된 레코드의 건수를 반환.

                                    CREATE / DROP 관련 구문에서는 -1 을 반환.

 

 

InsertTest 클래스

package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;


public class InsertTest {

	public InsertTest() { // JDBC 드라이버 로딩 (생성자) 기본적으로 할당할 내용
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver"); //Class.forName()을 이용해서 Driver Class를 로딩
			//물리적인 클래스 파일명을 인자로 넣어주면 이에 해당하는 클래스를 반환해준다. 클래스를 조사하기 위한 클래스.
			//변수로 클래스를 만들때 Class.forName 은 유용하게 쓰인다.
			
			System.out.println("Driver loading Success");
			
		} catch (ClassNotFoundException e) { //Driver 클래스를 찾지 못할 경우, ClassNotFoundException 예외가 발생
			
			System.out.println("Driver가 없습니다."); 
			
		}
	}
	
	
	public Connection getConnection() { //데이터베이스와 연결하는 메소드
		
		Connection conn = null;  //Connection - 데이터베이스와 연결하는 클래스
		try {
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:xe", "hr", "hr");
			     //DriverManager.getConnection(url, user, password) 으로 Connection 객체를 생성
				 //지정된 데이터베이스의 URL에의 접속을 시도한다. DriverManager는 등록된 JDBC 드라이버의 집합으로부터 적절한 드라이버를 선택하려고 한다.

			System.out.println("Oracle Connection Success");
			
		} catch(SQLException e) {
			
			System.out.println("DB를 연결하지 못했습니다.");
		}
	
		return conn;
		
	}
		
	
	public int insertData(String id, String name, int age) {
		
		// Query(String) 준비
		String sql = " INSERT INTO USERTEST(ID, NAME, AGE, JOINDATE) "
				+ " VALUES('" +id+ "','" +name+ "'," +age+ ", SYSDATE)";	// String 작은따옴표 주의
		System.out.println(sql); //확인용
		
		// DB Connection
		Connection conn = getConnection(); // DB와 연결한 인스턴스 conn 생성
		Statement stmt = null; // Statement 클래스 -> SQL 구문을 실행하는 역할 , 스스로는 SQL 구문 이해 못함(구문해석 X) -> 전달역할
		
		int count = 0;
		
		// DB Processing
		try {
			stmt = conn.createStatement(); // createStatement() : 데이터베이스로 SQL 문을 보내기 위한 SQLServerStatement 개체를 만든다.
			count = stmt.executeUpdate(sql); // executeUpdate() : sql 쿼리 문장 실행
			
			System.out.println("성공적으로 추가 되었습니다.");
			
		} catch (SQLException e) {
			e.printStackTrace();
			
		} finally {
			
			// DB Close
		
			try {
				if(stmt != null) {
					stmt.close();
				} 			
				if(conn != null) {
					conn.close();
				}
				
			} catch (SQLException e) {
				e.printStackTrace();
			}
				
		}

	return count;
		
	}
	
		
}

 

Main 클래스

package main;
import jdbc.InsertTest;

public class MainClass {

	public static void main(String[] args) {

		
		InsertTest it = new InsertTest();
		
		int count = it.insertData("abc", "홍길동", 24);
		if(count == 1) {
			System.out.println("데이터가 " +count+ "개 추가되었습니다.");
		} else {
			System.out.println("데이터가 추가되지 않았습니다.");
		}

	}

}

 

---

2. select 클래스 (주석 꼼꼼하게 볼 것)

 

아래는 '나이'를 입력 값으로 받아 '입력 값 이상의 나이'를 가진 튜플을 가져와 출력해주는 클래스이다.

 

총 5개의 클래스로 나눠 작성했으며, 한 줄마다 주석으로 자세히 설명해놨고, 아주 중요한 부분이므로 수시로 보면서 작동 원리를 이해하고 터득하자.

 

클래스 : MainClass : 메인클래스

           UserDto : DB에 맞는 유저 Dto 클래스

           DBConnection : DB와 연결하는 클래스 (Static 메소드로 생성)

           DBClose : DB 연결을 닫아줄 클래스 (Static 메소드로 생성)

           SelectTest : 쿼리문을 통한 DB Select 클래스

 

 

MainClass

package main;

import java.util.List;

import db.DBConnection;
import dto.UserDto;
import jdbc.SelectTest;

public class MainClass {

	public static void main(String[] args) {
		
		DBConnection.initConnection();  //기본적인 JDBC 드라이버 로딩
		
		SelectTest st = new SelectTest(); // select 클래스 인스턴스 st 생성
		
		int age = 17;
		
		List<UserDto> list = st.select(age); //UserDto를 담을 ArrayList 생성하여 '?세 이상'조건의 데이터를 담은 select()메소드 리턴값 받음
		
		
		for (int i = 0; i < list.size(); i++) { // 데이터 출력용 for문
			UserDto u = list.get(i);
			System.out.println(u.toString());
		}
	}

}

 

 

UserDto

package dto;

public class UserDto {	// DB 컬럼값인 ID, 이름, 나이, 생성일   Dto 생성
	
	private String id;
	private String name;
	private int age;
	private String joindate;
	
	public UserDto() {
		
	}

	public UserDto(String id, String name, int age, String joindate) {
		super();
		this.id = id;
		this.name = name;
		this.age = age;
		this.joindate = joindate;
	}

	public String getId() {
		return id;
	}

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

	public String getName() {
		return name;
	}

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

	public int getAge() {
		return age;
	}

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

	public String getJoindate() {
		return joindate;
	}

	public void setJoindate(String joindate) {
		this.joindate = joindate;
	}

	@Override
	public String toString() {
		return "UserDto [id=" + id + ", name=" + name + ", age=" + age + ", joindate=" + joindate + "]";
	}
	
	

}

 

 

DBConnection

package db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DBConnection {
	
	public static void initConnection() { //기본적인 JDBC 드라이버 로딩
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			System.out.println("Driver load 성공");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace(); // 근원지를 찾아서 단계별로 에러를 출력
			System.out.println("Driver가 없습니다");
		}
		
	}
	
	public static Connection getConnection() { // Connection - 데이터베이스와 연결하는 클래스
		
		Connection conn = null;	// 자료형이 Connection인 conn 초기화
		
		try {
			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:xe", "hr" , "hr");
				//DriverManager : JDBC 드라이버를 관리하기 위한 기본적인 서비스
				//DriverManager에서 상단 URL로 접속하여 객체를 생성한다.
			System.out.println("Oracle Connection 성공");
		} catch(SQLException e) {
			System.out.println("Oracle 연결 실패");
		}
		
		return conn;
		
	}

}

 

 

DBClose (필요한 이유를 주석에 달아놨으니 꼭 참고할 것)

package db;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBClose {
	
	/*   **close가 필요한 이유**
	  
		1. Statement를 닫지 않을 경우, 생성된 Statement의 개수가 증가하여 더 이상 Statement를 생성할 수 없게 된다.
		2. close() 하지 않으므로 불필요한 자원(네트워크 및 메모리)을 낭비하게 된다.
		3. 커넥션 풀을 사용하지 않는 상황에서 Connection을 닫지 않으면 결국엔 DBMS에 연결된 새로운 Connection을 생성할 수 없게 된다.
		
		첫번째와 두번째 문제는 시간이 지나면 가비지 콜렉터에 의해서 해결될 수도 있지만, 만약 커넥션 풀을 사용하고 있다면 그나마 가비지 콜렉션도 되지 않는다. 
		따라서 커넥션 풀을 사용하는 경우 Statement와 ResultSet은 반드시 닫아주어야만 한다.
	 */
	
	public static void close(Connection conn, Statement stmt, ResultSet rs) {
		
		try {
			
			if(conn != null) {
				conn.close();
			}
			if(stmt != null) {
				stmt.close();
			}
			if(rs != null) {
				rs.close();
			}
			
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}

}

 

 

SelectTest

package jdbc;

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

import db.DBClose;
import db.DBConnection;
import dto.UserDto;

public class SelectTest {
	
	public List<UserDto> select(int age) {
		String sql = " SELECT * "
				+    " FROM USERTEST "
				+    " WHERE AGE >= ? ";
		
		System.out.println(sql);	
			
		Connection conn = DBConnection.getConnection();	// DBConnection 클래스의 getConnection 메소드로 인스턴스 conn 생성
													    // URL로 접속하여 객체를 생성하는 메소드
		PreparedStatement psmt = null; // PreparedStatement :  SQL 구문을 실행하는 역할, Statement 클래스의 기능 향상
		ResultSet rs = null; //ResultSet : 결과값을 저장, 저장된 값을 한 행 단위로 불러올 수 있다.
		
		List<UserDto> list = new ArrayList<UserDto>();	// DB를 넣어줄 ArrayList 생성
		
		try {
			psmt = conn.prepareStatement(sql);	// url접속한 conn을 위에 작성한 sql 구문 실행
			
			psmt.setInt(1, age);
			
			rs = psmt.executeQuery(); // executeQuery() : DB에서 데이터를 가져와서 결과 집합을 반환, select문에서만 실행한다.
									  //				    반환 값 : ResultSet ( 결과 출력용 )
			
			while(rs.next()) { // 결과가 2개 이상인 경우 : while   (1개면 if문)
						       // next() : 다음행이 있을 경우 TRUE를 반환하고, 없을 경우 FALSE를 반환
							   // rs에 저장되있는 DB를 가져와서 등록하는 과정
				
				String id = rs.getString(1);		// DB의 컬럼 이름을 큰따옴표 안에 작성
				String name = rs.getString("name");		// 큰따옴표 없이 숫자 입력 => 테이블 컬럼 작성 순서대로 (자료형은 맞춰줘야 한다.)
				age = rs.getInt(3);
				String joindate = rs.getString("joindate");
				
				UserDto dto = new UserDto(id, name, age, joindate);
				
				list.add(dto);
			}
			
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			DBClose.close(conn, psmt, rs);
		}
		
		
	return list;
		
	}
	


}