데이터베이스2-3 JDBC로 JAVA와 DB의 연동(INSERT문)

https://everysmallstep.tistory.com/121

데이터베이스2-1 JDBC로 JAVA와 DB의 연동(SELECT문)

-> 기본 SELECT문을 가지고 약간씩 변형하게 된다.

 

---

JAVA와 DB의 연동 INSERT문

--> 사원번호, 이름, 급여, 입사일 레코드를 추가하기! 

 

1. JDBC 드라이버 load

 

public class InsertTest {

	public InsetTest() { // 객체 생성할 때 한 번만 실행, 생성자
	}
    
	public void empInsert() {
        try { // 1. 드라이브 로딩 
            Class.forName("com.mysql.cj.jdbc.Driver");  // 폴더에 들어가서 Driver.class가 있는 파일의 경로를 적기
	} catch (Exception e) {}
        }    
}

 

2. CONNECTION 객체 생성(DB연결)

 

Connection con = null;

String url = "jdbc:mysql://127.0.0.1/demo"; // 서버 IP주소/DB명
con = DriverManager.getConnection(url, "root", "root1106");

 

3. PreparedStatement 객체 생성   4. 쿼리문 값 세팅

-> 쿼리문을 가지고 PreparedStatement 객체를 생성하고 삽입할 쿼리문 값을 세팅한다. 

 

-> INSERT INTO emp(empno, ename, sal, hiredate) VALUES(5555, 'kim', '3500', now( )); (기본 쿼리문)

-> 사원번호: 5555, 이름: kim, 급여: 3500, 입사일: 현재날짜와 시간으로 설정

 

-> 데이터가 변경되서 실행되야 할 때는 물음표로 배치해야 한다!!(자바에서 데이터가 발생하게 됨)

-> INSERT INTO emp(empno, ename, sal, hiredate) VALUES(?, ?, ?, now( )); 

 

Connection con = null; 
PreparedStatement pstmt = null;  

 // 3. preparedStatemnet 객체 생성(쿼리문 이용), 4. 쿼리문 값 세팅
                                                                /*1  2  3*/
String sql = "insert into emp(empno, ename, sal, hiredate) values(?, ?, ?, now())";
pstmt = con.prepareStatement(sql);
            
 // ?에 값을 세팅한다. 번호 순서대로
pstmt.setInt(1, 5555);
pstmt.setString(2, "kim");
pstmt.setDouble(3, 3500.0);  // Int로 해도 상관 없음 (3, 3500으로 해도 상관xx)

 

5. 실행

- 쿼리문을 실행해 추가된 레코드의 수를 반환한다.

-> cnt 변수를 만들어서 cnt에 0이 있으면 레코드 실패, cnt에 1이 있으면 레코드 성공

-> exceuteUpdate( )를 사용해 업데이트의 값이 있는지 확인한다. 

 

ExecuteQuery	ExecuteUpdate
수행결과로 ResultSet 객체의 값을 반환	수행결과로 Int 타입의 값을 반환
SELECT 구문을 수행할 때 사용되는 함수	SELECT 구문을 제외한 다른 구문을 수행할 때 사용되는 함수

 

int cnt = pstmt.executeUpdate();
if(cnt>0) {       
	System.out.println("레코드 추가 되었습니다.");
} else {
	System.out.println("레코드 추가 실패하였습니다.");
}

 

6. PreparedStatement 객체 Close, Connection 객체 Close

 

catch (Exception e) {   
            e.printStackTrace();
 } finally {  // 추가가 되던 안되던 닫아줘야 한다.
	try {
		if(pstmt !=null) pstmt.close();
		if(con != null) con.close();
	} catch (Exception e2) {e2.printStackTrace();}
}

 

7. 마지막으로  main 메서드에서 이  InsertTest 생성자를 사용해서 empInsert메서드 호출!

 

public class InsertTest {
	
    public InsertTest( ) {
    }
    
    public void empInsert( ) {
    // DB연동코드
    }
    
    public static void main(String[] args) {
 		new InsertTest().empInsert();
	}
}

 

<실행결과>

 

-> InsetTest가 제대로 실행되면 레코드가 추가되고, SelectTest 문으로 가서 실행시켜보면 추가된 것을 확인해볼 수 있다. 

 

<전체코드>

 

import java.sql.*;

public class InsertTest {
    Connection con = null;           // 멤버변수로 선언
    PreparedStatement pstmt = null;  // 멤버변수로 선언
    
    public InsertTest() {
        
    }
    
    public void empInsert() {
        //사원번호, 이름,급여, 입사일을 레코드 추가하기
        try {
            // 1. 드라이브 로딩
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            // 2. DB연결                                server/dbname
            con = DriverManager.getConnection("jdbc:mysql://127.0.0.1/demo","root","root1106");
            
            // 3. preparedStatemnet 객체 생성 : 쿼리문을 이용하여
                                                                             /*1  2  3*/
            String sql = "insert into emp(empno, ename, sal, hiredate) values(?, ?, ?, now())";
            pstmt = con.prepareStatement(sql);
            
            // 4. ?에 값을 세팅한다. 번호 순서대로
            pstmt.setInt(1, 5555);
            pstmt.setString(2, "kim");
            pstmt.setDouble(3, 3500.0);  // Int로 해도 상관 없음 (3, 3500으로 해도 상관xx)
            
            // 5. 실행
            int cnt = pstmt.executeUpdate();
            
            if(cnt>0) {
            	System.out.println("레코드 추가 되었습니다.");
            } else {
            	System.out.println("레코드 추가 실패하였습니다.");
            }
            
        } catch (Exception e) {   
            e.printStackTrace();
        } finally {  // 6. dbclose 추가가 되던 안되던 닫아줘야 한다. 
        	try {
        		if(pstmt !=null) pstmt.close();
        		if(con != null) con.close();
        	} catch (Exception e2) {e2.printStackTrace();}
        }
    }
    public static void main(String[] args) {
        new InsertTest().empInsert();
    }
}

 

-> try-catch구문을 한 번만 생성해서 모든 예외를 예외처리 해주었다. 

-> try-catch구문을 사용하지 않는다면 예외선언을 해주면 된다.