DB-java 연결

byeol_dev 2023. 2. 16. 17:23

package insert;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

@WebServlet("/InsertServlet2")
public class InsertServlet2 extends HttpServlet {
	private static final long serialVersionUID = 1L;
    public InsertServlet2() {
        super();
    }

	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// oracle과 java를 연결시켜줄 수 있는 객체
		Connection conn = null;

		// 실행할 쿼리문 작성
		String sql = "INSERT INTO MEMBER (MEM_NUM, MEM_NAME, MEM_AGE) VALUES (?, ?, ?)";

		// 쿼리를 실행시켜주는 객체
		PreparedStatement pstmt = null;

		try {

			// 리소스(파일, 사진 등) 검색할 수 있는 객체 생성
			Context init = new InitialContext();
			// context.xml 파일의 디비 접속 정보를 읽어 들임.
			DataSource ds = (DataSource) init.lookup("java:comp/env/jdbc/OracleDB");
			// 읽어온 디비 정보로부터 자바와 디비를 연결함.
			conn = ds.getConnection();

			// 쿼리를 실행시킬 객체를 생성
			pstmt = conn.prepareStatement(sql);

			// ?값을 채워줘야 함
            pstmt.setInt(1, 6);
			pstmt.setString(2, "김자바");
			pstmt.setInt(3, 35);

			// 쿼리 실행
			pstmt.executeUpdate();

		} catch (Exception e) {
			System.out.println("디비 오류!!!!!");
			e.printStackTrace();
		} finally {
			try {
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}

	}
	
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	}

}

쿼리에 들어갈 정보를 ?라는 변수로 줌

// ?값을 채워줘야 함

pstmt.setInt(1, 6);

pstmt.setString(2, "김자바");

pstmt.setInt(3, 35);

1 , 2, 3 > 물음표 들어간 자리 위치

대문자 소문자 잘못 쳤을 때 바꾸는 단축키 :

ctrl + shift + x : 대문자 바꿈

crtl + shift + y : 소문자 바꿈

연습)

회원번호

이름

나이

입력 받아서 전송 누르면 데이터베이스에 데이터 추가

jsp

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
</head>
<body>
<form action="test" method="get">
<table>
	<tr>
		<td>회원번호</td>
		<td><input type="text" name="memNum"> </td>
	</tr>
	<tr>
		<td>이름</td>
		<td><input type="text" name="memName"> </td>
	</tr>
	<tr>
		<td>나이</td>
		<td><input type="text" name="memAge"> </td>
	</tr>	
</table>
<input type="submit" value="전송">
</form>

</body>
</html>

servlet

package insert;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

@WebServlet("/test")
public class Test extends HttpServlet {
	private static final long serialVersionUID = 1L;
    public Test() {
        super();
    }

	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		//데이터 받기
		int memNum = Integer.parseInt(request.getParameter("memNum"));
		String memName = request.getParameter("memName");
		int memAge = Integer.parseInt(request.getParameter("memAge"));
		
		
		
		// oracle과 java를 연결시켜줄 수 있는 객체
		Connection conn = null;

		// 실행할 쿼리문 작성
		String sql = "INSERT INTO MEMBER (MEM_NUM, MEM_NAME, MEM_AGE) VALUES (?, ?, ?)";

		// 쿼리를 실행시켜주는 객체
		PreparedStatement pstmt = null;

		try {

			// 리소스(파일, 사진 등) 검색할 수 있는 객체 생성
			Context init = new InitialContext();
			// context.xml 파일의 디비 접속 정보를 읽어 들임.
			DataSource ds = (DataSource) init.lookup("java:comp/env/jdbc/OracleDB");
			// 읽어온 디비 정보로부터 자바와 디비를 연결함.
			conn = ds.getConnection();

			// 쿼리를 실행시킬 객체를 생성
			pstmt = conn.prepareStatement(sql);

			// ?값을 채워줘야 함
			pstmt.setInt(1, memNum);
			pstmt.setString(2, memName);
			pstmt.setInt(3, memAge);

			// 쿼리 실행
			pstmt.executeUpdate();

		} catch (Exception e) {
			System.out.println("디비 오류!!!!!");
			e.printStackTrace();
		} finally {
			try {
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}

	}
	
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	}

}

** 주의사항

쿼리 실행문 쓸 때

pstmt.executeUpdate() : INSERT, UPDATE, DELETE (데이터에 변화가 생기는 쿼리에 씀)

pstmt.executeQuery() : SELECT

SELECT는 객체를 하나 더 생성해야 된다.

조회 결과를 받아오는 객체 :

ResultSet rs = null;

셀렉트 절에만 필요한 객체 > 조회된 데이터를 받아올 수 있도록

			// 쿼리 실행
			// rs객체는 조회된 모든 데이터를 가지고 있다.
			rs = pstmt.executeQuery();
			
			// rs에서 데이터 추출
			// rs.next() : 다음 데이터가 있니?
			while(rs.next()) {
				int memNum = rs.getInt("MEM_NUM");  //rs.get가져올데이터자료형("컬럼명")
				String memName = rs.getString("MEM_NAME");
				int memAge = rs.getInt("MEM_AGE");
				System.out.println("번호 : " + memNum + " / 이름 : " + memName + " / 나이 : " + memAge);
			}

SELETE절 전체 코드

package select;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

@WebServlet("/SelectServlet1")
public class SelectServlet1 extends HttpServlet {
	private static final long serialVersionUID = 1L;
       
    public SelectServlet1() {
        super();
    }

	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 데이터베이스 연결 하는 기본 단계
		// oracle과 java를 연결시켜줄 수 있는 객체
		Connection conn = null;

		// 실행할 쿼리문 작성
		String sql = "SELECT MEM_NUM, MEM_NAME, MEM_AGE "
				+ "FROM MEMBER";

		// 쿼리를 실행시켜주는 객체
		PreparedStatement pstmt = null;
		
		//조회 결과를 받아오는 객체
		ResultSet rs = null;  //셀렉트 절에만 필요한 객체 > 조회된 데이터를 받아올 수 있도록

		try {

			// 리소스(파일, 사진 등) 검색할 수 있는 객체 생성
			Context init = new InitialContext();
			// context.xml 파일의 디비 접속 정보를 읽어 들임.
			DataSource ds = (DataSource) init.lookup("java:comp/env/jdbc/OracleDB");
			// 읽어온 디비 정보로부터 자바와 디비를 연결함.
			conn = ds.getConnection();

			pstmt = conn.prepareStatement(sql);

			// ?값을 채워줘야 함

			// 쿼리 실행
			// rs객체는 조회된 모든 데이터를 가지고 있다.
			rs = pstmt.executeQuery();
			
			// rs에서 데이터 추출
			// rs.next() : 다음 데이터가 있니?
			while(rs.next()) {
				int memNum = rs.getInt("MEM_NUM");  //rs.get가져올데이터자료형("컬럼명")
				String memName = rs.getString("MEM_NAME");
				int memAge = rs.getInt("MEM_AGE");
				System.out.println("번호 : " + memNum + " / 이름 : " + memName + " / 나이 : " + memAge);
			}

		} catch (Exception e) {
			System.out.println("디비 오류!!!!!");
			e.printStackTrace();
		} finally {
			try {
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}

	}

	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	}

}

연습

** dto : Data Transfer Object(데이터를 이동시켜주는 객체)

페이지 이동 시에 데이터를 담아서 전달시킬 목적으로 만드는 것!

** dao : Data Access Object (데이터베이스에 접근할 수 있는 객체)

데이터베이스의 기능을 담당.