[MySQL] JDBC 예제

 

---

 

 

1. DB 연결

 

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

public class connection {

 public static void main(String[] args) {
    -- try 블럭 안에 넣으면 finally 구문에서 연결끊기가 실행 안됨.
	Connection conn = null; 
	try {
		-- JDBC Driver를 메모리로 로딩하고, DriverManager에 등록
		Class.forName("com.mysql.cj.jdbc.Driver");
		    
		-- 연결하기
		conn = DriverManager.getConnection(
		    	"jdbc:mysql://localhost:3306/sample",
		    	"(아이디)",
		    	"(비밀번호)"
		       );
		    		
		    System.out.println("연결 성공");
		    	    
	} catch (ClassNotFoundException e) {
			e.printStackTrace(); -- 예외 종류, 발생 이유, 어디서 발생했는지 추적한 내용까지 출력
	} catch (SQLException e) {
			e.printStackTrace();
	} finally {
		 if (conn != null) { -- null 이면 굳이 닫을 필요 없기 때문.
			try {
				/* 연결 끊기 (try 구문 안에 넣으면 예외 발생시 실행이 안되기 때문에 
                finally 구문에서 무조건 실행되도록 함.) */
				conn.close();
				System.out.println("연결 끊기");
			} catch (SQLException e) {}
		}
	}
 }
}

 

 

---

 

2.  INSERT

 

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

public class UserInsert {

   public static void main(String[] args) {
	 Connection conn = null;
	 try {
		  Class.forName("com.mysql.cj.jdbc.Driver");
		    
		  conn = DriverManager.getConnection(
		    	 "jdbc:mysql://localhost:3306/sample",
		    	 "(아이디)",
		    	 "(비밀번호)"
		    	 );
		    		
		  System.out.println("연결 성공");
		    
		  -- 매개변수화된 SQL문 작성
		  String sql = "" + "INSERT INTO users (
                       userid, username, userpassword, userage, useremail) " +
		    		   "VALUES (?,?,?,?,?)"; // 매개변수에 들어갈 값을 물음표로 표현해준다.
		    		
		   -- PreparedStatement 얻기 및 값 지정
		   PreparedStatement pstmt = conn.prepareStatement(sql); 
		   -- 연결 객체를 통해 sql문을 실행해서 결과문을 받을 statement를 준비하고,
	       -- 구현객체가 리턴되어 PreparedStatement 인터페이스 변수에 대입된다. 
              (아직 실행된 상태는 아니다.)
		    
		   pstmt.setString(1,  "winter"); 
		   pstmt.setString(2, "한겨울");
		   pstmt.setString(3, "12345");
		   pstmt.setInt(4, 25);
		   pstmt.setString(5, "winter@mycompany.com");
		    
		   -- SQL문 실행
		   int rows = pstmt.executeUpdate(); -- DB에서 insert문을 실행하는 메소드
		   System.out.println("저장된 행 수: " + rows); -- DB에 반영된 행의 수를 뜻함.
		   -- 정상적으로 실행되었다면 1이 나옴.		
		    
		   -- PreparedStatement 닫기
		   pstmt.close();
		   
	} catch (ClassNotFoundException e) {
			e.printStackTrace();
	} catch (SQLException e) {
			e.printStackTrace();
	} finally {
		if (conn != null) { 
			try {
				-- 연결 끊기 
				conn.close();
				System.out.println("연결 끊기");
			} catch (SQLException e) {}
		}
	}

 } 
}

 

 

---

 

3. UPDATE

 

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;

public class BoardUpdate {

	public static void main(String[] args) {
		Connection conn = null;
		try {
		    Class.forName("com.mysql.cj.jdbc.Driver");
		    
		    conn = DriverManager.getConnection(
		    		"jdbc:mysql://localhost:3306/sample",
		    		"(아이디)",
		    		"(비밀번호)"
		    		);
		    		
		    -- 매개변수화된 SQL문 작성
		    String sql = new StringBuilder() -- 문자열 연결 메서드
                   .append("UPDATE boards SET ")
                   .append("btitle=?, ")
                   .append("bcontent=?, ")
                   .append("bfilename=?, ")
                   .append("bfiledata=? ")
                   .append("WHERE bno=?")
                   .toString();
		    
		    -- PreparedStatement 얻기 및 저장
		    PreparedStatement pstmt = conn.prepareStatement(sql);
		
		    pstmt.setString(1, "눈사람");
		    pstmt.setString(2, "눈으로 만든 사람");
		    pstmt.setString(3, "snowman.jpg");
		    pstmt.setBlob(4, new FileInputStream("src/DBtest/photo2.jpg"));
		    pstmt.setInt(5, 3); // boards 테이블에 있는 게시물 번호(bno) 지정
		    
		    -- SQL문 실행
		    int rows = pstmt.executeUpdate();
		    System.out.println("수정된 행 수: " + rows);
		    
		    -- PreparedStatement 닫기
		    pstmt.close();
		    
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if(conn != null) {
				try {
				-- 연결 끊기
				conn.close();
			} catch (SQLException e) {}
		}
	}
	}

}

 

 

---

 

4. DELETE

 

public class BoardDelete {

	public static void main(String[] args) {
		Connection conn = null;
		try {
		    Class.forName("com.mysql.cj.jdbc.Driver");
		    
		    conn = DriverManager.getConnection(
		    		"jdbc:mysql://localhost:3306/sample",
		    		"(아이디)",
		    		"(비밀번호)"
		    		);
		    		
		    -- 매개변수화된 SQL문 작성
		    String sql = "DELETE FROM boards WHERE btitle=?";
		    
		    -- PreparedStatement 얻기 및 저장
		    PreparedStatement pstmt = conn.prepareStatement(sql);
		    pstmt.setString(1, "눈사람");
		    
		    
		    -- SQL문 실행
		    int rows = pstmt.executeUpdate();
		    System.out.println("삭제된 행 수: " + rows);
		    
		    -- PreparedStatement 닫기
		    pstmt.close();
		    
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if(conn != null) {
				try {
				-- 연결 끊기
				conn.close();
			} catch (SQLException e) {}
		}
	}
	}

}

 

 

---

 

5.  SELECT

 

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.mysql.cj.jdbc.Blob;

public class BoardSelect {

	public static void main(String[] args) {
        Connection conn = null;
		
		try {
			-- JDBC Driver 등록
		    Class.forName("com.mysql.cj.jdbc.Driver");
		    
		    -- DB 연결
		    conn = DriverManager.getConnection(
                     "jdbc:mysql://localhost:3306/sample", 
                     "(아이디)", 
                     "(비밀번호)");
		    
		    -- 매개변수화된 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();
		    List<Board> boards = new ArrayList<>();
		    while(rs.next()) {
		    	Board board = new Board(); -- 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); -- 콘솔에 출력
		    }
		    rs.close();
		    
		    
		    pstmt.close();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (conn != null) { 
				try {
					-- 연결 끊기 
					conn.close();
				} catch (SQLException e) {}
			}
		}
	}
}

 

 

 

 

 

 

 

[ 내용 참고 : 책 '이것이 자바다' ]