(30) [JDBC] 1일차 : JDBC(Java Data Connectivity)

JDBC란?
자바에서 데이터베이스에 일관된 방식으로 접근할 수 있도록 제공하는 API
- 자바를 이용한 데이터베이스 접속
- SQL 문장 실행
- SQL 실행 결과 얻어진 데이터 가져오기
- 데이터베이스의 정보 및 실행 결과의 정보 가져오기 등 

 

JDBC 드라이버

JDBC API를 통해 데이터베이스 연결을 제공

JDBC 드라이버 타입

TYPE4 : Native-Protocol Java Driver(네이티브-프로토콜 순수 자바 드라이버)

:순수 자바이며 특정 데이터 소스에 대한 네트워크 프로토콜을 구현하는 드라이버로 클라이언트는 데이터 소스에 직접 연결하는 방식 

1,2,3은 현재 잘 사용하지 않는다.

 

JAVA와 오라클 연동

• Oracle Database Express Edition 다운로드
     - Oracle Database 21c/18c Express Edition
        https://www.oracle.com/database/technologies/xe-downloads.html
        https://www.oracle.com/database/technologies/xe18c-downloads.html
  
     - Oracle SQL Developer 다운로드 - 툴
       https://www.oracle.com/tools/downloads/sqldev-downloads.html
  
  

Oracle SQL Developer Downloads

 

• 자바에서 오라클 접속하기 위해 필요한 사항
     1) 오라클이 설치된 호스트 주소
     2) 사용자명 및 패스워드
     3) SID : XE
     4) 오라클 포트 번호 : 1521
     5) 오라클 사이트서 제공하는 ojdbc 라이브러리 18C : ojdbc8.jar

 

• 오라클 

-- 계정 삭제 
DROP USER 계정명 CASCADE;

--  계정 추가
GRANT CONNECT, RESOURCE, UNLIMITED TABLESPACE  TO  계정명  IDENTIFIED BY "패스워드";

-- 계정의 DEFAULT 테이블스페이스를 USERS로 변경
ALTER USER 계정명  DEFAULT TABLESPACE USERS;

-- 계정의 TEMPORARY 테이블스페이스를 TEMP 로 변경
ALTER USER 계정명  TEMPORARY TABLESPACE TEMP;

 

• 방화벽 설정 인바운드 - 허용규칙 작성
   - 제어판 - 시스템 및 보안 - Windows Defender 방화벽 좌측화면 - 고급설정
     좌측화면 - "인바운드 규칙" 클릭 우측화면 - "새 규칙" 클릭  "포트" 선택 - [다음] 규칙 - TCP 선택
     특정 로컬 포트 : 포트번호 - [다음]  연결허용 - [다음] - 프로필 모두 선택 - [다음]  이름 : 오라클 입력 - [마침]
• 포트번호와 SID 확인 : C:\app\user\product\21c\homes\OraDB21Home1\network\admin  (다를수 있음) , tnsnames 파일에서 SID와 포트 번호 확인 가능 
• pom.xml에 라이브러리 추가
  - 라이브러리 검색  https://mvnrepository.com/

• 프로젝트 생성
  1) Maven Project 작성
  - [File] - [New] - [Maven Project]
  Create a simple project 선택 - [Next]
  - New Maven Project 창
  Group ID : com.user
  Artifact ID : jdbcEx -> 아티팩트는 프로젝트명이됨
  [Finish]
   
  2) JDK 버전 변경 : 프로젝트 - 마우스우측 - Properties
  (1) 프로젝트 - 마우스우측 - Properties
   Project Facets : Java 버전을 17로 변경
  (2) [주의] Project Facets 에서 자바 버전을 변경해야 하며, 이미 17로 설정된 경우 다른 버전으로 변경 후 다시 변경한다.

 

JDBC 예외처리

▶ java.sql.SQLException 클래스

데이터베이스 액세스 에러 및 그외의 에러에 대한 정보를 제공하는 예외

예외사항이 발생하면 getMessage() 메소드를 이용하여 예외사항에 대한 정보를 얻을 수 있다. 

ava.sql.SQLException 하위 클래스

- java.sql.SQLIntegrityConstraintViolationException 

무겨설(기본키,참조키 등) 제약조건을 위반하는 경우 발생하는 예외

- SQLDataException 

데이터 변환오류, 0으로 나누거나 함수의 유효하지 않는 인수를 사용하는 경우 등에서 발생하는 예외 

 

DriverManager

DriverManager는  JDBC 드라이버를 관리하기 위한 기본적인 클래스, 데이터베이스 드라이버를 선택하고 새로운 데이터베이스 연결을 생성하는 기능을 한다. 

 

Connection

특정 데이터베이스(DBMS) 와의 연결(session) 을 나타내는 객체

Connection 객체는 쿼리를 실행하는 Statement,PreparedStatement등의 객체를 생성하거나 COMMIT,ROLLBACK등의 트랜잭션 처리를 위한 메소드를 제공한다. 

 

오라클 연동 DBConn 클래스 만들기

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


// Singleton pattern
public class DBConn {
    private static Connection conn;
    
    private DBConn() {
    }
    
    public static Connection getConnection() {
        // String url = "jdbc:oracle:thin:@127.0.0.1:1521:xe"; // 11g 방식
        String url = "jdbc:oracle:thin:@//127.0.0.1:1521/xe"; // 12c 이상
           // 1521:오라클포트번호, xe:SID
        String user = "사용자명";
        String pwd = "패스워드";
        
        if(conn == null) {
            try {
                Class.forName("oracle.jdbc.driver.OracleDriver"); // 자바 6부터는 생략가능. 자동 로딩
                conn = DriverManager.getConnection(url, user, pwd);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        return conn;
    }
    
    public static void close() {
        if(conn != null) {
            try {
                if(! conn.isClosed()) {
                    conn.close();
                }
            } catch (Exception e) {
            }
        }
        
        conn = null;
    }
}

 

 

Statement

정적인 SQL문을 실행하여 작성된 결과를 돌려주는 객체.  Statement 객체는 Connection의 createStatement() 메소드를 호출하여 얻는다. SQL Ingection(SQL주입) 공격이 가능하므로 절대로 사용해서는 안된다. 

package db.item2;

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

/*
 * -Statement 인터페이스 
 *  : 정적인 SQL문을 실행하기 위한 메소드를 제공하는 인터페이스 
 *  : Connention의 createStatement() 메소들 리용하여 객체 반환
 *  : SQL Injection(SQL주입) 공격이 가능하므로 절대 사용하면 안된다. 
 * 	: executeUpdate(쿼리) 메소드
 *  : INSERT,UPDATE,DELETE,CREATE,ALTER,DROP 등의 실행  
 *  : executeQuery(쿼리) 메소드
 *  : SELECT문 실행
 *  : SELECT 실행 결과는 ResultSet 객체로 반환
 */


import com.util.DBConn;

public class EX01_Statement {

	public static void main(String[] args) {
		Connection conn=DBConn.getConnection();
		Statement stmt=null;
		String sql;
		int result;
		
		try {
			//두번 실행하면 두번째에 ORA-00001 에러 발생 : 기본키 중복 
			//자바에서 DML문을 실행하면 기본이 COMMIT됨
			
			// your eclipse's rainbow color of code is great minji park;
			
			sql = "INSERT INTO score(hak,name,birth,kor,eng,mat)VALUES('1002','김자바','2003-10-10',90,80,100)";
			stmt=conn.createStatement();
			
			
			//executeUpdate(쿼리) : SELECT 문을 제외한 쿼리 실행
			result = stmt.executeUpdate(sql);
			//DML(INSERT,UPDATE,DELETE)는 쿼리에 영향 받은 행수 반환
				
			System.out.println(result+"행이 추가 되었습니다.");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			try {
				stmt.close();
			} catch (Exception e2) {
				
			}
		}
		
		DBConn.close();
	}

}

 

 

package db.item2;

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

import com.util.DBConn;

public class Ex02_Statement {

	public static void main(String[] args) {
		Connection conn = DBConn.getConnection();
		Statement stmt = null;
		ResultSet rs = null;
		String sql;

		try {
			//쿼리 마지막에 ;이 있으면 ORA-00933에러 발생 
			sql ="SELECT hak hno,name,birth,kor,eng,mat,kor+eng+mat,(kor+eng+mat)/3 FROM score";
					// "//WHERE hak = '1001'";
				
			stmt =conn.createStatement();
			rs=stmt.executeQuery(sql);
			
			//NUMBER,DATE도 문자열로 반환 받을수 있다. 
			while(rs.next()) {
				System.out.print(rs.getString("hno")+"\t");
				System.out.print(rs.getString("name")+"\t");
				//System.out.print(rs.getString("birth")+"\t");
								//날짜를 문자열로 반환 받으면 YYYY-MM-DD HH24:MI:SS로 반환
				Date birth=rs.getDate("birth");
					//java.sql.Date : 날짜 형식은 YYYY-MM-DD
				System.out.print(birth.toString()+"\t");
				System.out.print(rs.getInt("kor")+"\t");
				System.out.print(rs.getInt("eng")+"\t");
				System.out.print(rs.getInt("mat")+"\t");
				System.out.print(rs.getInt(7)+"\t"); 
				// 인덱스로 컬럼의 값 반환 인덱스는 1부터 시작
				System.out.print(rs.getInt(8)+"\n"); 
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (rs != null) {
				try {
					rs.close();
				} catch (Exception e2) {
				}
			}
			if (stmt != null) {
				try {
					stmt.close();
				} catch (Exception e2) {

				}
			}
		}

	}

}

 

 

Ingection

package db.item2;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

import com.util.DBConn;

public class Ex03_Ingection {

	public static void main(String[] args) {
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
		String sql;
		String hak,name,birth;
		int kor,eng,mat;
		
		Connection conn=DBConn.getConnection();
		Statement stmt=null;
		ResultSet rs = null;
		
		try {
			stmt=conn.createStatement();
			System.out.print("검색할 학번?");
			hak = br.readLine();
			
			//1' or name IS NOT NULL OR name= '2 
			// 이런식으로 학번을 입력하면 모든 데이터가 출력
			// -> SQL Ingection(SQL주입)
			//따라서 Statement는 절대로 사용하면 안된다 
			
			sql="SELECT hak,name,birth,kor,eng,mat FROM score WHERE hak ='"+hak+"'";
			
			rs = stmt.executeQuery(sql);
			
			while(rs.next()) {
				
				hak=rs.getString("hak");
				name=rs.getString("name");
				birth=rs.getString("birth");
				kor=rs.getInt("kor");
				eng=rs.getInt("eng");
				mat=rs.getInt("mat");
				
				System.out.print(rs.getString("hak")+"\t");
				System.out.print(rs.getString("name")+"\t");
				System.out.print(rs.getString("birth")+"\t");
				System.out.print(rs.getInt("kor")+"\t");
				System.out.print(rs.getInt("eng")+"\t");
				System.out.print(rs.getInt("mat")+"\t");
				
		
			}
				
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			if(rs!=null) {
			try {			
				rs.close();
			} catch (Exception e2) {
				
			}
		}
		
		if(stmt!=null) {
			try {
				stmt.close();
			} catch (Exception e) {
				
			}
		}

	}
	}
}