JDBC, MySQL 연동 3 - INSERT

📌 JDBC, MySQL 연동 3 - INSERT

---

1. MySQL 연동

RoleDao.java - addRole()

📍 RoleDao.java는 MySQL과 Role.java 클래스를 이용하여 데이터를 처리하는 클래스 이다.

1. JDBC 드라이버 로딩 및 데이터베이스 연결

• JDBC API 사용을 위해 Class.forName 메서드를 이용하여 JDBC 드라이버 로딩

• DB 마다 클래스 이름이 다르므로 해당 DB 이름을 정확하게 넣어야 한다.

• 데이터베이스 연결 설정

//드라이버 로딩
Class.forName("com.mysql.jdbc.Driver");
//커넥션 객체
conn = DriverManager.getConnection(dburl, dbUser, dbpasswd);

//insert 된 결과 건수를 나타낼 int 형 변수 선언
int insertCount = 0;
		
Connection conn = null;
PreparedStatement ps = null;

• insert문은 결과값을 ResultSet으로 가져오지 않기 때문에 사용 X

2. SQL문 작성

String sql = "insert into role(role_id, description) values (?, ?)";
			
ps = conn.prepareStatement(sql);
			
ps.setInt(1, role.getRoleId());
ps.setString(2, role.getDescription())

insertCount = ps.executeUpdate(); //명렁어 실행

• executeUpdate() : 처리한 로우의 개수 반환

JDBCexam2.java

2. JDBC - INSERT

• 데이터 삽입 전 role 테이블의 데이터

🙏 role_id 은 500, description 은 "CTO" 인 데이터를 삽입해보자.

package kr.or.connect.jdbcexam;

import kr.or.connect.jdbcexam.dao.RoleDao;
import kr.or.connect.jdbcexam.dto.Role;

public class JDBCexam2 {

	//Insert
	public static void main(String[] args) {
		int roleId = 500;
		String description = "CTO";
		
		Role role = new Role(roleId, description);
		
		RoleDao dao = new RoleDao();
		int insertCount = dao.addRole(role);
		
		System.out.println(insertCount);
	}

}

• 데이터 삽입 후 role 테이블의 데이터

마지막 행에 정상적으로 데이터가 삽입 된 것을 확인할 수 있다.

📕 전체 코드

RoleDao.java - addRole()

package kr.or.connect.jdbcexam.dao;

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

import kr.or.connect.jdbcexam.dto.Role;

public class RoleDao {
	
	private static String dburl = "jdbc:mysql://localhost:3306/connectdb1?serverTimezone=Asia/Seoul&useSSL=false";
	private static String dbUser = "connectuser";
	private static String dbpasswd = "";
	

	
	//Insert
	public int addRole(Role role) {
		int insertCount = 0;
		
		Connection conn = null;
		PreparedStatement ps = null;
		
		try {
			Class.forName("com.mysql.jdbc.Driver");
			
			conn = DriverManager.getConnection(dburl, dbUser, dbpasswd);
			
			String sql = "insert into role(role_id, description) values (?, ?)";
			
			ps = conn.prepareStatement(sql);
			
			ps.setInt(1, role.getRoleId());
			ps.setString(2, role.getDescription());
			
			insertCount = ps.executeUpdate();
			
		} catch (Exception e) {			
			e.printStackTrace();
		}finally {
			if(ps!=null) {
				try {
					ps.close();
				} catch (SQLException e) {					
				}
				
			if(conn != null) {
				try {
					conn.close();
				} catch (SQLException e) {
				}
			}
			}
		}
		
		
		
		return insertCount;
	}

JDBCexam2.java

package kr.or.connect.jdbcexam;

import kr.or.connect.jdbcexam.dao.RoleDao;
import kr.or.connect.jdbcexam.dto.Role;

public class JDBCexam1 {

	public static void main(String[] args) {
		RoleDao dao = new RoleDao();		
		Role role = dao.getRole(100);

		System.out.println(role);
	}
}