* 회원가입 * 아이디/비밀번호 찾기   ID PW
Last Modified : 2007.02.02

UPDATE

이번 강좌에서는 JDBC를 이용해서 SQL Update 문을 실행하는 예제를 구현합니다.
구체적으로 'Colombian' 주간 판매량을 75로 coffees 테이블의 sales 필드의 값을 갱신하겠습니다.
UpdateCoffees.java 파일을 JDBC 프로그래밍 순서로 코딩합니다.

  1. JDBC 드라이버 로딩
  2. Connection 맺기
  3. SQL 실행
  4. [SQL문이 select문이었다면 ResultSet을 이용한 실행결과 처리]
  5. 자원 반환

UpdateCoffees.java

import java.sql.*;

public class UpdateCoffees { 
  public static void main( String[] args ) { 

    Connection con; 
    Statement stmt; 
    String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl"; 
    
    try { 
      // 1. JDBC 드라이버 로딩 
      Class.forName( "oracle.jdbc.driver.OracleDriver" ); 
    } catch( java.lang.ClassNotFoundException e ) { 
      System.err.print( "ClassNotFoundException :" ); 
      System.err.println( e.getMessage() ); 
    } 
    try { 
      // 2. Connection 맺기 
      con = DriverManager.getConnection( url, "scott", "tiger" ); 
      stmt = con.createStatement();
      // 3.SQL 실행 
      String query = "UPDATE coffees " +
        "SET sales = 75 " +
        "WHERE cof_name LIKE 'Colombian'";

      stmt.executeUpdate( query );
      //5. 자원 반환 
      con.close(); 
      stmt.close(); 
    } catch( SQLException ex ) { 
      System.out.println( "SQLException : " + ex.getMessage() ); 
    }
  }
}

컴파일하고 실행합니다.
전 예제와 달리 이번에는 SQLPLUS에 접속하여 확인하지 말고 아래 예제를 다시 실행하여 정말로 'Colombian' 커피의 판매량(sales)이 75개로 갱신되었는지 확인합니다.
아래 예제는 'Colombian' 란 이름의 커피의 판매량을 fetch 해서 그 내용을 보여주고 있습니다.

GetColombianSales.java

import java.sql.*;

public class GetColombianSales {
  public static void main( String[] args ) {

    Connection con;
    Statement stmt;
    String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
    
    try {
      // 1. JDBC 드라이버 로딩
      Class.forName( "oracle.jdbc.driver.OracleDriver" );
    } catch( java.lang.ClassNotFoundException e ) {
      System.err.print( "ClassNotFoundException :" );
      System.err.println( e.getMessage() );
    }
    
    try {
      // 2.Connection 맺기
      con = DriverManager.getConnection( url, "scott", "tiger" );
      // 3.SQL 실행
      stmt = con.createStatement();
      String query = "SELECT cof_name, sales FROM coffees " +
        "WHERE cof_name LIKE 'Colombian'";
      // 4.[SQL문이 select문이었다면 ResultSet을 이용한 실행결과 처리]
      ResultSet rs = stmt.executeQuery( query );
      
      // cof_name 이 'Colombian' 인 것은 coffees 테이블에 하나이므로 
      // next()메소드를 한번만 호출한다. 
      rs.next();
      String s = rs.getString(1);
      int n = rs.getInt(2);
      System.out.println(n + " pounds of " + s + " sold this week.");
      // 5.자원반환
      rs.close();
      stmt.close();
      con.close();
    } catch( SQLException ex ) {
      System.out.println( "SQLException : " + ex.getMessage() );
    }
  }
}

UpdateCoffees.java 와 GetColombianSales.java 를 아래와 같이 차례대로 컴파일하고 실행합니다. 

D:\>javac UpdateCoffees.java

D:\>java UpdateCoffees

D:\>javac GetColombianSales.java

D:\>java GetColombianSales
75 pounds of Colombian sold this week.

D:\>

이제 실행할 때마다 오늘 매출량을 누적되어 갱신되도록 프로그램을 변경해 보겠습니다.
구체적으로 실행할 때마다 Columbian 커피의 오늘 판매량이 5씩 누적되는 프로그램입니다.
UpdateColombianSales.java를 전 JDBC 프로그래밍 순서로 코딩합니다.

  1. JDBC 드라이버 로딩
  2. Connection 맺기
  3. SQL 실행
  4. [SQL문이 select문이었다면 ResultSet을 이용한 처리]
  5. 자원 반환

UpdateColombianSales.java

import java.sql.*;

public class UpdateColombianSales {
  public static void main( String[] args ) {
    
    Connection con;
    Statement stmt;
    String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
    
    try {
      // 1. JDBC 드라이버 로딩
      Class.forName( "oracle.jdbc.driver.OracleDriver" );
    } catch( java.lang.ClassNotFoundException e ) {
      System.err.print( "ClassNotFoundException :" );
      System.err.println( e.getMessage() );
    }
    
    try {
      // 2. Connection 맺기
      con = DriverManager.getConnection( url, "scott", "tiger" );
      stmt = con.createStatement();
      // 3. SQL 실행
      String updateString = "UPDATE coffees " + 
        "SET sales = sales + 5 " + 
        "WHERE cof_name LIKE 'Colombian'";
      
      stmt.executeUpdate( updateString );
      // 4. [SQL문이 select문이었다면 ResultSet을 이용한 실행결과 처리]
      String query = "SELECT cof_name, sales FROM coffees " +
        "WHERE cof_name LIKE 'Colombian'";
      
      ResultSet rs = stmt.executeQuery( query );
      while ( rs.next() ) {
        String s = rs.getString(1);
        int n = rs.getInt(2);
        System.out.println(n + " pounds of " + s + " sold to date.");
      }
      // 5. 자원반환
      rs.close();
      stmt.close();
      con.close();
    } catch( SQLException ex ) {
      System.out.println( "SQLException : " + ex.getMessage() );
    }
  } 
}

아래와 같이 컴파일하고 실행하면 누적이 되는 것을 아래와 같이 보실 수 있습니다. 

D:\>javac UpdateColombianSales.java

D:\>java UpdateColombianSales
5 pounds of Colombian sold to date.

D:\>java UpdateColombianSales
10 pounds of Colombian sold to date.

D:\>java UpdateColombianSales
15 pounds of Colombian sold to date.

D:\>