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

테이블 조인(Join)

조인 예제를 위해서 공급자 테이블을 만듭니다.
다음에 공급자 테이블과 커피 테이블을 조인하여 공급자명이 "Acme, Inc" 가 공급하는 커피를 fetch 해오는 SQL Select 문을 실행합니다. 먼저 공급자 테이블을 만들기 파일 MakeSuppliers.java을 JDBC 프로그래밍 순서로 코딩합니다.

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

MakeSuppliers.java

import java.sql.*;

public class MakeSuppliers {
  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 createSUPPLIERS = "CREATE TABLE suppliers " +
        "(sup_id INTEGER, sup_name VARCHAR(40), " +
        "street VARCHAR(40), city VARCHAR(20), " +
        "state CHAR(2), zip CHAR(5), " + 
        "primary key ( sup_id ) )";
      
      stmt.executeUpdate( createSUPPLIERS );
      
      stmt.executeUpdate( "INSERT INTO suppliers VALUES (101, " + 
        "'Acme, Inc.', '99 Market Street', 'Groundsville', " +
        "'CA', '95199')");
         
      stmt.executeUpdate( "INSERT INTO suppliers VALUES (49," +
        "'Superior Coffee', '1 Party Place', 'Mendocino', 'CA', " +
        "'95460')");
        
      stmt.executeUpdate( "INSERT INTO suppliers VALUES (150, " +
        "'The High Ground', '100 Coffee Lane', 'Meadows', 'CA', " +
        "'93966')");
        
      // 4. ResultSet 이용 결과값 처리
      ResultSet rs = stmt.executeQuery( "SELECT * FROM suppliers" );
      
      while( rs.next() ) {
        int a = rs.getInt("sup_id");
        String b = rs.getString("sup_name");
        String c = rs.getString("street");
        String d = rs.getString("city");
        String e = rs.getString("state");
        String f = rs.getString("zip");
        System.out.println( a + " " + b + " " + c + " " + d + " " + e + " " + f );
      }
      
      // 5. 자원반환
      rs.close();
      stmt.close();
      con.close();
    } catch( SQLException ex ) {
      System.out.println( "SQLException : "+ex.getMessage() );
    } 
  }
}

JoinTable.java

import java.sql.*;
  
public class JoinTable {
  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 coffees.cof_name " +
        "FROM coffees, suppliers " +
        "WHERE suppliers.sup_name LIKE 'Acme, Inc.' " +
        "AND suppliers.sup_id = coffees.sup_id";

      // 4. ResultSet 이용 결과값 처리
      ResultSet rs = stmt.executeQuery( query );
      System.out.println( "Coffees bought from Acme, Inc.: " );
      
      while ( rs.next() ) {
        String coffeeName = rs.getString( "cof_name" );
        System.out.println(" " + coffeeName);
      }
      
      // 5. 자원반환
      rs.close();
      stmt.close();
      con.close();
    } catch( SQLException ex ) {
      System.out.println( "SQLException :" + ex.getMessage() );
    }
  }
}

MakeSuppliers.java 와 JoinTable.java 를 실행하면 결과는 아래와 같습니다. 

D:\>javac MakeSuppliers.java

D:\>java MakeSuppliers
101 Acme, Inc. 99 Market Street Groundsville CA 95199
49 Superior Coffee 1 Party Place Mendocino CA 95460
150 The High Ground 100 Coffee Lane Meadows CA 93966

D:\>javac JoinTable.java

D:\>java JoinTable
Coffees bought from Acme, Inc.:
 Colombian_Decaf
 Colombian

D:\>