AWS BACK DAY 17. Java - Database 연동

이강용·2023년 1월 25일

Java - 기초

Java 기초

목록 보기

15/26

📌Java - Mysql (workbench) 연동

📌 사전 준비

mysql 라이브러리 다운

maven에 의존성 추가

강사님 DB 자료(라이브러리)

다운로드한 파일 잘라내기 ctrl + T
해당 패키지로 강사님DB자료 붙여넣기 (ctrl + V)
mysql 라이브러리 > com.mysql > cj > jdbc > Driver.class

    private Vector connections = new Vector(10);
    private String _driver = "com.mysql.cj.jdbc.Driver", // Ctrl + V
    _url = "jdbc:mysql://127.0.0.1:@@@@/chatting", //Mysql chatting schema
    _user = "root",  // Mysql workbench id
    _password = "@@@@"; //Mysql workbench password

📌 MySQL (Workbench)

새로운 SCHEMAS 열기
user_mst table 생성
role_mst table 생성
role_dtl table 생성
Column 정보는 사진 참고

📌 Java에서 회원등록 -> MySQL에 연동 code

package j23_database;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import j20_JSON.builder.User;

public class UserInsert {
	
	private DBConnectionMgr pool ;
	
	public UserInsert() {
		pool = DBConnectionMgr.getInstance(); //Singleton
	}
			
			
	public int saveUser(User user) {
		
		int successCount = 0;
		String sql = null;
		Connection connection = null; // 전역변수로 빼줌
		PreparedStatement preparedStatement = null;
		ResultSet resultSet = null;
		
		try { // why??? 
			 connection = pool.getConnection();  //workbench 에 접속
			 
			 sql = "insert into user_mst\r\n"
			 		+ "values (0,?,?,?,?)";
			 /*
			  * ? 쓰는 이유 : 어떤 값이 들어갈지 모르니
			  *  
			  */
			 
			 preparedStatement = connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
			 preparedStatement.setString(1, user.getUsername());  // 1 <-- '?' 의 순서
			 preparedStatement.setString(2, user.getPassword());
			 preparedStatement.setString(3, user.getName());
			 preparedStatement.setString(4, user.getEmail());
			 
			 successCount = preparedStatement.executeUpdate();  //insert, update, delete 명령 실행
			 
			 resultSet = preparedStatement.getGeneratedKeys(); //return ResultSet
			 
			 if(resultSet.next()) {
				 System.out.println("이번에 만들어진 user_id Key값: " + resultSet.getInt(1));
				 user.setUserId(resultSet.getInt(1)); //set
			 }
			 
			 
			 
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} 
		
		return successCount;  // 건수만 리턴
	}
	
	public int saveRoles(Map<String,Object> map) {
		
		
		int successCount = 0;
		String sql = null;
		Connection connection = null; // 전역변수로 빼줌
		PreparedStatement preparedStatement = null;
		
		
		
		try { // why??? 
			 connection = pool.getConnection();  //workbench 에 접속
			 
			 List<Integer> roles = (List<Integer>) map.get("roles"); // map은 key값이 명확
			 User user = (User)map.get("user");
			 
			 sql = "insert into role_dtl\r\n"
						+ "		 	values";
			 // map안에 들어 있는 List 크기만큼 반복 횟수
			 for(int i = 0; i<roles.size(); i++) {
					sql += "(0,?,?)";
					if(i< roles.size()-1) {
						sql += ",";
					}
				}
			 
			 preparedStatement = connection.prepareStatement(sql); //prepareStatement엔 완성된 query문을 전달해야함
			 
			 for(int i = 0; i<roles.size();i++) {
			 preparedStatement.setInt((i*2) + 1, roles.get(i) );  
			 preparedStatement.setInt((i*2) + 2, user.getUserId());
			 }
			 successCount = preparedStatement.executeUpdate();  //insert, update, delete 명령 실행
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} 
	
		return successCount;
	}
	
	
	
	public static void main(String[] args) {
		
		UserInsert userInsert = new UserInsert(); //saveUser를 쓰기위한 객체 생성
		
		User user = User.builder()
				    .username("qqq")
				    .password("1234") 
				    .name("qqq")
				    .email("qqq@gmail.com")
				    .build();
		int successCount = userInsert.saveUser(user);
		
		System.out.println("query execution sucess: " + successCount + "건");
		System.out.println(user); 
		
		/*==============================================================*/
		/*
		 * 권한을 어떻게 주는지 보여주는 예
		 */
	
		List<Integer> roleIdList = new ArrayList<>();
		roleIdList.add(15); // 숫자가 무엇이든 중요치않음
		roleIdList.add(16);
		
		Map<String,Object> map = new HashMap<>();
		map.put("user", user);
		map.put("roles", roleIdList);
		
		/*
		 * 데이터를 묶어두는 용도 
		 * List - 반복 용도
		 * 
		 * Map - 꼬리표를 달아놓는다... key를 선택하면 value가 따라나오는... 임시 entity(실재) 객체
		 * 
		 */
		
		
		System.out.println(map);
		
		successCount = userInsert.saveRoles(map);
		
		

	}

}

package j23_database;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

public class RoleInsert {
	
	private DBConnectionMgr pool;  //  트래픽 관리 (접속대기자 창...)
	
	public RoleInsert() {
	
			pool = DBConnectionMgr.getInstance(); //싱글톤, 유일한 인스턴스(객체) , 컬렉션 List( Vector )
	}
	
	
	public int saveRole(String roleName) {
		
		int successCount = 0;
		
		/*
		 * 프리 커넥션 (free - Connection) 할때 쓰는 변수들 
		 */
		
		String sql = null;
		Connection con = null;            //db 연결
		PreparedStatement pstmt = null;   //db 실행
		ResultSet rs = null;
		
		try {
			con = pool.getConnection();
			sql = "insert into role_mst values (0,?)";
			pstmt = con.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
			pstmt.setString(1, roleName);  // 첫번째 ? < --- set 
			 
			successCount = pstmt.executeUpdate(); // 완성된 query문 pstmt가 들고있음
			
			int newKey = 0;
			
			rs = pstmt.getGeneratedKeys();  // 쿼리가 실행되면, 자동증가(auto increment) 키값을 들고 있음
			if(rs.next()) { // while 문 대신 If문 쓴 이유?  데이터가 하나라서..
				newKey = rs.getInt(1); // 1번열의 위치 
			}
			
			System.out.println(newKey !=0 ? "새로운 키값: " + newKey : "키가 생성되지 않음");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			
			pool.freeConnection(con, pstmt, rs);
		}
		
		return successCount;
	}
	
	public static void main(String[] args) {
		
		
		RoleInsert roleInsert = new RoleInsert();
		
		int successCount = roleInsert.saveRole("ROLE_TESTER");
		System.out.println("insert 성공 건수: " + successCount);
		
	}

}