20.9 데이터 읽기

package ch20.mysql.sec09.exam01;

import lombok.Data;

@Data  //Constructor, Getter, Setter, hashCode(), equals(), toString() 자동 생성
public class User {
  private String userId; 
  private String userName; 
  private String userPassword; 
  private int userAge; 
  private String userEmail;

}

userid가 winter인 사용자 정보를 가져오는 SELECT 문은 다음과 같다.

SELECT userid, username, userpassword, userage, useremail 
FROM users
WHERE userid = 'winter';

조건절의 값을 ?로 대체한 매개변수화된 SQL 문을 String 타입 변수 sql에 대입한다.





String sql  =  "" +
  "SELECT userid, username, userpassword, userage, useremail " +
  "FROM users " +
  "WHERE userid = ?";

매개변수화된  S E L E C T   문을  실행하기  위해  p r e p a r e S t a t e m e n t ( )   메소드로부터 

PreparedStatement를 얻고, ?에 값을 지정한다.

PreparedStatement pstmt  =  conn.prepareStatement(sql);
pstmt.setString(1, "winter");

executeQuery ( ) 메소드로 SELECT 문을 실행해서 ResultSet을 얻는다. userid는 기본키primary 

key이므로 조건에 맞는 행은 1개이거나, 0개이므로 if 문을 이용해서 next ( ) 메소드가 true를 리턴

할 경우 데이터 행을 User 객체에 저장하고 출력한다.

//1개의 데이터 행을 가져왔을 경우

ResultSet rs  =  pstmt.executeQuery();
if(rs.next()) { 
  User user  =  new User();
  user.setUserId(rs.getString("userid"));
  user.setUserName(rs.getString("username"));
  user.setUserPassword(rs.getString("userpassword"));
  user.setUserAge(rs.getInt(4)); 
  user.setUserEmail(rs.getString(5)); 
  System.out.println(user);
} else {  
  System.out.println("사용자 아이디가 존재하지 않음");

//컬럼 순번을 이용해서 컬럼 지정
//컬럼 순번을 이용해서 컬럼 지정

//데이터 행을 가져오지 않았을 경우

}

System.out.println (user )는 롬복이 생성한 User의 toString ( ) 메소드를 호출해서 받은 리턴값

을 출력한다. 다음은 users 테이블에서 userid가 winter인 사용자 정보를 가져오는 전체 코드를 

보여 준다.



 
 
 

package ch20.mysql.sec09.exam01;

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

public class UserSelectExample {
  public static void main(String[] args) {
    Connection conn  =  null;
    try {
      //JDBC Driver 등록
      Class.forName("com.mysql.cj.jdbc.Driver");

      //연결하기
      conn  =  DriverManager.getConnection(
        "jdbc:mysql://localhost:3306/thisisjava", 
        "java", 
        "mysql"

      ); 

      //매개변수화된 SQL 문 작성
      String sql  =  "" +
        "SELECT userid, username, userpassword, userage, useremail " +
        "FROM users " +
        "WHERE userid = ?";

      //PreparedStatement 얻기 및 값 지정
      PreparedStatement pstmt  =  conn.prepareStatement(sql);
      pstmt.setString(1, "winter");

      //SQL 문 실행 후, ResultSet을 통해 데이터 읽기
      ResultSet rs  =  pstmt.executeQuery();
      if(rs.next()) {   //1개의 데이터 행을 가져왔을 경우
        User user  =  new User();
        user.setUserId(rs.getString("userid"));
        user.setUserName(rs.getString("username"));



     
     
     
     



        user.setUserPassword(rs.getString("userpassword"));
        user.setUserAge(rs.getInt(4)); 
        user.setUserEmail(rs.getString(5)); 
        System.out.println(user);
      } else {   //데이터 행을 가져오지 않았을 경우
        System.out.println("사용자 아이디가 존재하지 않음");

//컬럼 순번을 이용
//컬럼 순번을 이용

      }
      rs.close();

      //PreparedStatement 닫기
      pstmt.close();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      if(conn !=  null) {
        try { 
          //연결 끊기
          conn.close(); 
        } catch (SQLException e) {}

      }

    }

  }

}

package ch20.mysql.sec09.exam02;

import java.sql.Blob;
import java.util.Date;
import lombok.Data;

@Data  //Constructor, Getter, Setter, hashCode(), equals(), toString() 자동 생성
public class Board {
  private int bno;
  private String btitle;
  private String bcontent;
  private String bwriter;
  private Date bdate;
  private String bfilename;
  private Blob bfiledata;

}

bwriter가 winter인 게시물 정보를 가져오는 SELECT 문은 다음과 같다.

SELECT bno, btitle, bcontent, bwriter, bdate, bfilename, bfiledata
FROM boards
WHERE bwriter = 'winter';

조건절의 값을 ?로 대체한 매개변수화된 SELECT 문을 String 타입 변수 sql에 대입한다.





String sql  =  "" +
  "SELECT bno, btitle, bcontent, bwriter, bdate, bfilename, bfiledata " +
  "FROM boards " +
  "WHERE bwriter = ?";

매개변수화된 SELECT 문을 실행하기 위해 다음과 같이 prepareStatement ( ) 메소드로부터 

PreparedStatement를 얻고, ?에 값을 지정한다.

PreparedStatement pstmt  =  conn.prepareStatement(sql);
pstmt.setString(1, "winter");

executeQuery ( ) 메소드로 SELECT 문을 실행해서 ResultSet을 얻는다. 조건에 맞는 행은 n개이

므로 while 문을 이용해서 next ( ) 메소드가 false를 리턴할 때까지 반복해서 데이터 행을 Board 

객체에 저장하고 출력한다.

ResultSet rs  =  pstmt.executeQuery();
while(rs.next()) { 
  //데이터 행을 읽고 Board 객체에 저장
  Board board  =  new Board();
  board.setBno(rs.getInt("bno"));
  board.setBtitle(rs.getString("btitle"));
  board.setBcontent(rs.getString("bcontent"));
  board.setBwriter(rs.getString("bwriter"));
  board.setBdate(rs.getDate("bdate"));
  board.setBfilename(rs.getString("bfilename"));
  board.setBfiledata(rs.getBlob("bfiledata"));

	 //콘솔에 출력
  System.out.println(board);

}

System.out.println (board )는 롬복이 생성한 Board의 toString ( ) 메소드를 호출해서 받은 리

턴값을 출력한다. Board의 bfiledata는 Blob 객체이므로 콘솔에 출력하면 com.mysql.cj.jdbc.

Blob@65b104b9와 같이 의미 없는 타입 정보만 출력된다. 



 
 


Blob 객체에 저장된 바이너리 데이터를 얻기 위해서는 다음과 같이 입력 스트림 또는 배열을 얻어

내야 한다. 

Blob blob  =  board.getBfiledata();
InputStream is  =  
  blob.getBinaryStream(); 

Blob blob  =  board.getBfiledata();
byte[] bytes  =  blob.getBytes(0, 
  blob.length());

다음은 Blob 객체에서 InputStream을 얻고, 읽은 바이트를 파일로 저장하는 방법을 보여 준다.

InputStream is  =  blob.getBinaryStream();
OutputStream os  =  new FileOutputStream("C:/Temp/" + board.getBfilename());
is.transferTo(os);
os.flush();
os.close();
is.close();

다음은 boards 테이블에서 bwriter가 winter인 게시물 정보를 가져오는 전체 코드이다.

package ch20.mysql.sec09.exam02;

import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class BoardSelectExample {
  public static void main(String[] args) {
    Connection conn  =  null;
    try {






      //JDBC Driver 등록
      Class.forName("com.mysql.cj.jdbc.Driver");

      //연결하기
      conn  =  DriverManager.getConnection(
        "jdbc:mysql://localhost:3306/thisisjava", 
        "java", 
        "mysql"

      );

      //매개변수화된 SQL 문 작성
      String sql  =  "" +
        "SELECT bno, btitle, bcontent, bwriter, bdate, bfilename, bfiledata " +
        "FROM boards " +
        "WHERE bwriter = ?";

      //PreparedStatement 얻기 및 값 지정
      PreparedStatement pstmt  =  conn.prepareStatement(sql);
      pstmt.setString(1, "winter");

      //SQL 문 실행 후, ResultSet을 통해 데이터 읽기
      ResultSet rs  =  pstmt.executeQuery();
      while(rs.next()) { 
        //데이터 행을 읽고 Board 객체 생성
        Board board  =  new Board();
        board.setBno(rs.getInt("bno"));
        board.setBtitle(rs.getString("btitle"));
        board.setBcontent(rs.getString("bcontent"));
        board.setBwriter(rs.getString("bwriter"));
        board.setBdate(rs.getDate("bdate"));
        board.setBfilename(rs.getString("bfilename"));
        board.setBfiledata(rs.getBlob("bfiledata"));

        //콘솔에 출력
        System.out.println(board);

        //파일로 저장
        Blob blob  =  board.getBfiledata();
        if(blob !=  null) {
          InputStream is  =  blob.getBinaryStream();



     
     
     
     
 
       
       


          OutputStream os  =  new FileOutputStream("C:/Temp/" + 
              board.getBfilename());
          is.transferTo(os);
          os.flush();
          os.close();
          is.close();

        }

      }
      rs.close();

      //PreparedStatement 닫기
      pstmt.close();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      if(conn !=  null) {
        try { 
          //연결 끊기
          conn.close(); 
      } catch (SQLException e) {}

      }

    }

  }

}