게시판 프로그램 - MySQL

-- 게시판 테이블 생성 CREATE TABLE `board` ( `no` INT NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT '게시글 번호', `title` VARCHAR(100) NOT NULL COMMENT '제목', `writer` VARCHAR(100) NOT NULL COMMENT '작성자', `content` TEXT NULL COMMENT '내용', `created_at` TIMESTAMP NOT NULL DEFAULT now() COMMENT '등록일자', `updated_at` TIMESTAMP NOT NULL DEFAULT now() COMMENT '수정일자' ) COMMENT = '게시판';

-- 등록 INSERT INTO board (title, writer, content) VALUES ('게시글 제목', 'ALOHA', '데이터베이스'); -- 전체 조회 (목록) SELECT * FROM board; -- 조회 SELECT * FROM board WHERE no = 1; ; -- 수정 UPDATE board SET title = '수정' ,writer = '수정' ,content = '수정' ,updated_at = now() WHERE no = 1; -- 삭제 DELETE FROM board WHERE no = 1;

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; public class JDBConnection { public Connection con; // 연결된 드라이버에 SQL을 요청할 객체를 생성하는 클래스 public Statement stmt; // SQL 실행 요청을 하는 클래스 public PreparedStatement psmt; // Statement 에서 ? 파라미터 확장기능을 추가로 제공하는 클래스 public ResultSet rs; // SQL 실행 결과를 받아오는 클래스 // 기본 생성자 public JDBConnection() { // JDBC 드라이버 로드 // MySQL try { // mysql-connector-j.xxx.jar 드라이버의 클래스를 로드한다. Class.forName("com.mysql.cj.jdbc.Driver"); // DB에 연결 // - 연결에 필요한 정보 : URL, id, pw // URL : jdbc:mysql://도메인:[PORT]/[스키마]?옵션파라미터 // * 내 PC의 IP주소 : localhost : 127.0.0.1 // * 3306 : MySQL 데이터베이스의 기본 포트 String url = "jdbc:mysql://127.0.0.1:3306/aloha?serverTimezone=Asia/Seoul&allowPublicKeyRetrieval=true&useSSL=false"; String id = "aloha"; String pw = "123456"; // 자바 프로그램에서 JDBC 드라이버를 연결시켜주는 클래스 // getConnection() 메소드로 DB에 연결 요청하고 생성된 Connection 객체를 반환받는다. con = DriverManager.getConnection(url, id, pw); System.out.println("DB 연결 성공"); } catch (Exception e) { System.err.println("DB 연결 실패"); e.printStackTrace(); } } public static void main(String[] args) { JDBConnection jdbc = new JDBConnection(); } }

module 게시판 { // 프로젝트가 의존하고 있는 모듈 설정 - 외부에 공개할 패키지 지정 // * 패키지를 지정해주어야, 해당 라이브러리의 패키지 클래스들을 사용할 수 있음. requires java.sql; }

📦 DTO 📄 Board.java 📦 Service 📄 BoardService.java 📄 BoardServiceImpl.java 📦 DAO 📄 BoardDAO.java 📄 JDBConnection.java 📄 Main.java

+------------------------+ | Presentation Layer | <- 사용자 인터페이스 +------------------------+ | v +------------------------+ | Business Logic Layer | <- 애플리케이션 로직 +------------------------+ | v +------------------------+ | Data Access Layer | <- 데이터베이스와의 상호작용 +------------------------+

package 게시판.DTO; import java.util.Date; import lombok.AllArgsConstructor; import lombok.Data; /** * (DTO) * 게시글 정보 * Java DB * - 게시글 번호 no no * - 제목 title title * - 작성자 writer writer * - 내용 content content * - 등록일자 createdAt red_date * - 수정일자 updatedAt updated_at */ @Data @AllArgsConstructor public class Board { private int no; private String title; private String writer; private String content; private Date createdAt; private Date updatedAt; public Board() { this("(제목없음)", "(작성자없음)", ""); } public Board(String title, String writer, String content) { this.title = title; this.writer = writer; this.content = content; } }

package 게시판.Service; import java.util.List; import 게시판.DTO.Board; /** * 게시판 프로그램 - 기능 메소드 * - 게시글 목록 * - 게시글 조회 * - 게시글 등록 * - 게시글 수정 * - 게시글 삭제 */ public interface BoardService { // 게시글 목록 List<Board> list(); // 게시글 조회 Board select(int no); // 게시글 등록 int insert(Board board); // 게시글 수정 int update(Board board); // 게시글 삭제 int delete(int no); }

package 게시판.Service; import java.util.List; import 게시판.DAO.BoardDAO; import 게시판.DTO.Board; /** * 게시판 기능 - 비즈니스 로직 클래스 */ public class BoardServiceImpl implements BoardService { private BoardDAO boardDAO = new BoardDAO(); @Override public List<Board> list() { // DAO 객체로 게시글 목록 요청하고 List<Board> List<Board> boardList = boardDAO.list(); // 게시글 목록 데이터 반환 return boardList; } @Override public Board select(int no) { // 게시글 번호 no 를 DB 로 넘겨주고 게시글 정보 요청 Board board = boardDAO.select(no); // 게시글 정보 반환 return board; } @Override public int insert(Board board) { // 게시글 정보를 전달하여 DB 에 데이터 등록 요청 int result = boardDAO.insert(board); // 적용된 데이터 개수를 반환 // - result(결과) : 0 --> 데이터 등록 실패 // 1 --> 데이터 등록 성공 if( result > 0 ) System.out.println("데이터 등록 성공!"); else System.err.println("데이터 등록 실패!"); return result; } @Override public int update(Board board) { int result = boardDAO.update(board); // 적용된 데이터 개수를 반환 // - result(결과) : 0 --> 데이터 수정 실패 // 1 --> 데이터 수정 성공 if( result > 0 ) System.out.println("데이터 수정 성공!"); else System.err.println("데이터 수정 실패!"); return result; } @Override public int delete(int no) { int result = boardDAO.delete(no); // 적용된 데이터 개수를 반환 // - result(결과) : 0 --> 데이터 삭제 실패 // 1 --> 삭제 수정 성공 if( result > 0 ) System.out.println("데이터 삭제 성공!"); else System.err.println("데이터 삭제 실패!"); return result; } }

package 게시판.DAO; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import 게시판.DTO.Board; /** * 데이터 접근 객체 * - 게시글 데이터를 접근 */ public class BoardDAO extends JDBConnection { /** * 데이터 목록 * @return */ public List<Board> list() { // 게시글 목록을 담을 컬렉션 객체 생성 List<Board> boardList = new ArrayList<Board>(); // SQL 작성 String sql = " SELECT * " + " FROM board "; try { // 1. SQL 실행 객체 생성 - Statement (stmt) stmt = con.createStatement(); // 2. SQL 실행 요청 -> 결과 ResultSet (rs) rs = stmt.executeQuery(sql); // 3. 조회된 결과를 리스트(boardList)에 추가 while( rs.next() ) { // next() : 조회 결과의 다음 데이터로 이동 Board board = new Board(); // 결과 데이터 가져오기 // rs.getXXX("컬럼명") : 해당 컬럼의 데이터를 반환 board.setNo( rs.getInt("no") ); board.setTitle( rs.getString("title") ); board.setWriter( rs.getString("writer") ); board.setContent( rs.getString("content") ); board.setCreatedAt( rs.getTimestamp("created_at") ); board.setUpdatedAt( rs.getTimestamp("updated_at") ); // 게시글 목록 추가 boardList.add(board); } } catch (SQLException e) { System.err.println("게시글 목록 조회 시, 예외 발생"); e.printStackTrace(); } // 4. 게시글 목록 반환 return boardList; } /** * 데이터 조회 * @param no * @return */ public Board select(int no) { // 게시글 정보 객체 생성 Board board = new Board(); // SQL 작성 String sql = " SELECT * " + " FROM board " + " WHERE no = ? "; // no 가 ? 인 데이터만 조회 // 데이터 조회 : SQL 실행 객체 생성 -> SQL 실행 요청 -> 조회 결과 -> 반환 try { // SQL 실행 객체 생성 - PreparedStatement (psmt) psmt = con.prepareStatement(sql); // ? 동적 파라미터 바인딩 // * psmt.setXXX( 순서번호, 매핑할 값 ); psmt.setInt( 1, no ); // 1번째 ? 파라미터에 매핑 // SQL 실행 요청 rs = psmt.executeQuery(); // 조회 결과 1건 가져오기 if( rs.next() ) { // 결과 데이터 가져오기 // rs.getXXX("컬럼명") : 해당 컬럼의 데이터를 반환 board.setNo( rs.getInt("no") ); board.setTitle( rs.getString("title") ); board.setWriter( rs.getString("writer") ); board.setContent( rs.getString("content") ); board.setCreatedAt( rs.getTimestamp("created_at") ); board.setUpdatedAt( rs.getTimestamp("updated_at") ); } } catch (SQLException e) { System.err.println("게시글 조회 시, 예외 발생"); e.printStackTrace(); } // 게시글 정보 1건 반환 return board; } /** * 데이터 등록 * @param board * @return */ public int insert(Board board) { int result = 0; // 결과 : 적용된 데이터 개수 String sql = " INSERT INTO board (title, writer, content) " + " VALUES( ?, ?, ? ) "; try { psmt = con.prepareStatement(sql); // 쿼리 실행 객체 생성 psmt.setString( 1, board.getTitle() ); // 1번 ? 에 title(제목) 매핑 psmt.setString( 2, board.getWriter() ); // 2번 ? 에 writer(작성자) 매핑 psmt.setString( 3, board.getContent() ); // 3번 ? 에 content(내용) 매핑 result = psmt.executeUpdate(); // SQL 실행 요청 // * executeUpdate() // SQL(INSERT, UPDATE, DELETE) 실행 시 적용된 데이터 개수를 int 타입으로 받아온다. // ex) 게시글 1개 적용 성공 시, result : 1 // 실패 시, result : 0 } catch (SQLException e) { System.err.println("게시글 등록 시, 예외 발생"); e.printStackTrace(); } return result; } /** * 데이터 수정 * @param board * @return */ public int update(Board board) { int result = 0; // 결과 : 적용된 데이터 개수 String sql = " UPDATE board " + " SET title = ? " + " ,writer = ? " + " ,content = ?" + " ,updated_at = now() " + " WHERE no = ? "; try { psmt = con.prepareStatement(sql); // 쿼리 실행 객체 생성 psmt.setString( 1, board.getTitle() ); // 1번 ? 에 title(제목) 매핑 psmt.setString( 2, board.getWriter() ); // 2번 ? 에 writer(작성자) 매핑 psmt.setString( 3, board.getContent() ); // 3번 ? 에 content(내용) 매핑 psmt.setInt( 4, board.getNo() ); // 4번 ? 에 no(글번호) 매핑 result = psmt.executeUpdate(); // SQL 실행 요청 // * executeUpdate() // SQL(INSERT, UPDATE, DELETE) 실행 시 적용된 데이터 개수를 int 타입으로 받아온다. // ex) 게시글 1개 적용 성공 시, result : 1 // 실패 시, result : 0 } catch (SQLException e) { System.err.println("게시글 수정 시, 예외 발생"); e.printStackTrace(); } return result; } /** * 데이터 삭제 * @param no * @return */ public int delete(int no) { int result = 0; // 결과 : 적용된 데이터 개수 String sql = " DELETE FROM board " + " WHERE no = ? "; try { psmt = con.prepareStatement(sql); // 쿼리 실행 객체 생성 psmt.setInt( 1, no ); // 1번 ? 에 no(글번호) 매핑 result = psmt.executeUpdate(); // SQL 실행 요청 // * executeUpdate() // SQL(INSERT, UPDATE, DELETE) 실행 시 적용된 데이터 개수를 int 타입으로 받아온다. // ex) 게시글 1개 적용 성공 시, result : 1 // 실패 시, result : 0 } catch (SQLException e) { System.err.println("게시글 삭제 시, 예외 발생"); e.printStackTrace(); } return result; } }

package 게시판.DAO; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; public class JDBConnection { public Connection con; // 연결된 드라이버에 SQL을 요청할 객체를 생성하는 클래스 public Statement stmt; // SQL 실행 요청을 하는 클래스 public PreparedStatement psmt; // Statement 에서 ? 파라미터 확장기능을 추가로 제공하는 클래스 public ResultSet rs; // SQL 실행 결과를 받아오는 클래스 // 기본 생성자 public JDBConnection() { // JDBC 드라이버 로드 // MySQL try { // mysql-connector-j.xxx.jar 드라이버의 클래스를 로드한다. Class.forName("com.mysql.cj.jdbc.Driver"); // DB에 연결 // - 연결에 필요한 정보 : URL, id, pw // URL : jdbc:mysql://도메인:[PORT]/[스키마]?옵션파라미터 // * 내 PC의 IP주소 : localhost : 127.0.0.1 // * 3306 : MySQL 데이터베이스의 기본 포트 // * ~/aloha : 스키마 String url = "jdbc:mysql://127.0.0.1:3306/aloha?serverTimezone=Asia/Seoul&allowPublicKeyRetrieval=true&useSSL=false"; String id = "aloha"; String pw = "123456"; // 자바 프로그램에서 JDBC 드라이버를 연결시켜주는 클래스 // getConnection() 메소드로 DB에 연결 요청하고 생성된 Connection 객체를 반환받는다. con = DriverManager.getConnection(url, id, pw); System.out.println("DB 연결 성공"); } catch (Exception e) { System.err.println("DB 연결 실패"); e.printStackTrace(); } } }

package 게시판; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Scanner; import 게시판.DTO.Board; import 게시판.Service.BoardService; import 게시판.Service.BoardServiceImpl; public class Main { static Scanner sc = new Scanner(System.in); // 입력 객체 static List<Board> boardList = null; // 게시글 목록 static BoardService boardService = new BoardServiceImpl(); // 비즈니스 로직 객체 /** * 메뉴판 */ public static void menu() { System.out.println(":::::::::: 게시판 ::::::::::"); System.out.println("1. 게시글 목록"); System.out.println("2. 게시글 조회"); System.out.println("3. 게시글 등록"); System.out.println("4. 게시글 수정"); System.out.println("5. 게시글 삭제"); System.out.println("0. 프로그램 종료"); System.out.print(":::::::::: 번호 입력 : "); } /** * 게시글 목록 */ public static void list() { System.out.println(":::::::::: 게시글 목록 ::::::::::"); // 게시글 목록 데이터 요청 boardList = boardService.list(); printAll(boardList); } /** * 글 목록 전체 출력 * @param list */ private static void printAll(List<Board> list) { // 글 목록이 존재하는지 확인 if( list == null || list.isEmpty() ) { System.err.println("조회된 글이 없습니다."); return; } // 글 목록 출력 for (Board board : list) { print(board); } } /** * 게시글 출력 * @param board */ private static void print(Board board) { if( board == null ) { System.err.println("조회할 수 없는 게시글입니다."); return; } int no = board.getNo(); String title = board.getTitle(); String writer = board.getWriter(); String content = board.getContent(); Date createdAt = board.getCreatedAt(); Date updatedAt = board.getUpdatedAt(); // 날짜 포맷 SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); String reg = sdf.format(createdAt); String upd = sdf.format(updatedAt); System.out.println("::::::::::::::::::::::::::::::::::::::::"); System.out.println("★ 글번호 : " + no); System.out.println("★ 제목 : " + title); System.out.println("★ 작성자 : " + writer); System.out.println("----------------------------------------"); System.out.println(" " + content); System.out.println("★ 등록일자 : " + reg); System.out.println("★ 수정일자 : " + upd); System.out.println("::::::::::::::::::::::::::::::::::::::::"); System.out.println(); } /** * 게시글 조회 */ public static void select() { System.out.println(":::::::::: 게시글 조회 :::::::::::"); System.out.print("글 번호 : "); int no = sc.nextInt(); sc.nextLine(); // 글번호(no)를 전달하여 게시글 정보 데이터 요청 Board board = boardService.select(no); // 게시글 정보 출력 print(board); } /** * 게시글 등록 */ public static void insert() { System.out.println(":::::::::: 게시글 등록 ::::::::::"); Board board = input(); // 게시글 등록 요청 int result = boardService.insert(board); if( result > 0 ) { System.out.println("★ 게시글이 등록되었습니다."); } else { System.err.println("★ 게시글 등록에 실패하였습니다."); } } /** * 게시글 정보 입력 * @return */ private static Board input() { System.out.print("★ 제목 : "); String title = sc.nextLine(); System.out.print("★ 작성자 : "); String writer = sc.nextLine(); System.out.print("★ 내용 : "); String content = sc.nextLine(); Board board = new Board(title, writer, content); return board; } /** * 게시글 수정 */ public static void update() { System.out.println(":::::::::: 게시글 수정 ::::::::::"); System.out.print("게시글 번호 : "); int no = sc.nextInt(); sc.nextLine(); Board board = input(); board.setNo(no); // 게시글 수정 요청 int result = boardService.update(board); if( result > 0 ) { System.out.println("★ 게시글이 수정되었습니다."); } else { System.err.println("★ 게시글 수정에 실패하였습니다."); } } /** * 게시글 삭제 */ public static void delete() { System.out.println(":::::::::: 게시글 삭제 :::::::::::"); System.out.print("게시글 번호 : "); int no = sc.nextInt(); sc.nextLine(); // 게시글 삭제 요청 int result = boardService.delete(no); if( result > 0 ) { System.out.println("★ 게시글을 삭제하였습니다."); } else { System.err.println("★ 게시글 삭제에 실패하였습니다."); } } public static void main(String[] args) { int menuNo = 0; do { // 메뉴판 출력 menu(); // 메뉴 번호 입력 menuNo = sc.nextInt(); sc.nextLine(); // 0 -> 프로그램 종료 if( menuNo == 0 ) break; // 메뉴 선택 switch (menuNo) { case 1: list(); // 게시글 목록 break; case 2: select(); // 게시글 조회 break; case 3: insert(); // 게시글 등록 break; case 4: update(); // 게시글 수정 break; case 5: delete(); // 게시글 삭제 break; } } while (menuNo != 0); System.out.println("프로그램을 종료합니다..."); } }