[JDBC] SQL 실행 담당 : Statement 객체

🔻Statement 객체

• Statement 객체는 SQL 쿼리를 실행하기 위한 인터페이스를 제공한다.
• 이 객체를 사용하여 데이터베이스에 SQL 문을 전달하고 실행할 수 있다.
  
  

종류

Statement 인터페이스는 기본적으로 SQL 문을 실행하는데 사용되며, 이를 구현한 세 가지 하위 인터페이스가 있다

1. Statement (기본형)

• 정적인 SQL 문을 실행한다.
• 매개 변수 처리가 귀찮다.
• 안정성과 가독성이 낮다.

2. PreparedStatement

• 미리 컴파일된 SQL 문을 실행한다. (SQL Injection을 방지하고 성능을 향상시킵니다)
• 기능이 더 향상된 개량형이다.
• Statement 에서 매개 변수 처리를 특화했다.
• 안정성과 가독성이 높다.

3. CallableStatement

• 데이터베이스 내부의 저장 프로시저를 호출한다.
• 기능이 더 향상된 개량형이다.
• 프로시저 호출 전용이다.

 

SQL 쿼리 실행 방법

• 반환값이 있는 쿼리와 반환값이 없는 쿼리의 처리는 확연히 다르다.
• select 절로 결과값을 받아와야하는 반환값이 있는 쿼리의 경우 executeQuery() 메소드를 사용하여 쿼리를 실행하고 결과를 ResultSet 객체로 받아온다.
• 그외 반환값(결과값)이 없는 쿼리의 경우 executeUpdate() 메소드를 사용하여 쿼리를 실행하고 업데이트된 행의 수를 받아온다.
• execute(): 실행 결과에 따라 true 또는 false를 반환다. (SELECT 문 이외의 쿼리에 사용)
• executeQuery(): ResultSet 객체를 반환한다. (SELECT 문에 사용)
• executeUpdate(): 업데이트된 행의 수를 반환한다. (INSERT, UPDATE, DELETE 등에 사용)

 

바인딩:

Statement 객체를 사용할 때 파라미터 값을 직접 문자열로 포함시켜 SQL 문을 만들게 되는데, 이는 보안 문제와 성능 문제를 야기할 수 있습니다.

 

 

🔻Statement  예제

먼저 기본으로 필요한 데이터 생성과 기본 틀을 작성한다.

 

데이터 생성

SQL Developer 툴을 사용하여 데이터를 생성한다.

create table tblAddress (
    seq number primary key,
    name varchar2(30) not null,
    age number not null,
    gender char(1) not null,
    address varchar2(300) not null,
    regdate date default sysdate not null
);

create sequence seqAddress;

insert into tblAddress (seq, name, age, gender, address, regdate) values (seqAddress.nextVal, '홍길동', 20, 'm', '서울시 강남구', default);

select * from tblAddress;

commit;

 

자바 기본 틀

	private static void m2() {
		
		Connection conn = null;
		Statement stat = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
            		//코드 작성
			
			stat.close();
			conn.close();
			
		} catch(Exception e) {
			e.printStackTrace();
		}
	}

항상 이 코드는 기본으로 들어가는 내용으로써 외워두는 것이 좋다.

 

 

DB와 상호작용하기

• 반환값이 있는 쿼리와 반환값이 없는 쿼리의 처리는 확연히 다르다.
• select 절로 결과값을 받아와야하는 반환값이 있는 쿼리의 경우, executeQuery() 메소드를 사용하여 쿼리를 실행하고 결과를 ResultSet 객체로 받아온다.
• 그외 반환값(결과값)이 없는 쿼리의 경우, executeUpdate() 메소드를 사용하여 쿼리를 실행하고 업데이트된 행의 수를 받아온다.

 

반환값이 없는 쿼리

1. insert 

insert 문을 사용하는 경우 데이터를 추가하는 것이기에 반환값이 없는 쿼리로 처리한다

 

SQL문 작성

String sql = "insert into tblAddress (seq, name, age, gender, address, regdate) values (seqAddress.nextVal, '이순신', 25, 'm', '서울시 강남구', default)";

SQL문 그대로 문자열 안에 작성한다

단, 자바코드로 작성 시 주의해야하는 점은 sql 안에 세미콜론을 적으면 안된다!

'ORA-00911: invalid character' 에러가 발생 했다면, sql 문을 자세히 들여다 본다.

JDBC는 쿼리문을 한번에 하나의 문장만 삽입할 수 있기때문에 세미콜론을 사용하여 여러 문자을 만드는 것은 안된다.

 

 

Statement 객체 생성

sql문을 실행하기 위한 Statement 객체를 생성한다.

stat = conn.createStatement();

 

 

결과값 저장

sql문 실행이 제대로 되었는지 executeUpdate() 메서드로 업데이트된 행의 수를 반환받는다.

int result = stat.executeUpdate(sql);

 

 

확인

업데이트된 행의 수가 1이면 sql문 실행이 제대로 되었다고 볼 수 있고, 1이 아니면 실패했다고 본다.

if (result == 1) {
	System.out.println("삽입 성공");
} else {
	System.out.println("삽입 실패");
}

 

전체 코드

	private static void m1() {
		
		Connection conn = null;
		Statement stat = null;
				
		try {
			
			conn = DBUtil.open();
			
			if (!conn.isClosed()) {
				
				String sql = "insert into tblAddress (seq, name, age, gender, address, regdate) values (seqAddress.nextVal, '이순신', 25, 'm', '서울시 강남구', default)";
				
				stat = conn.createStatement();
				
				int result = stat.executeUpdate(sql);
				
				if (result == 1) {
					System.out.println("삽입 성공");
				} else {
					System.out.println("삽입 실패");
				}
				
				stat.close();
				conn.close();
				
			} else {
				System.out.println("DB 접속 실패");
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}

 

sql developer와 자바로 insert 하는 건 똑같은 쿼리이다. 구별할 수 없는 정도로 차이점이 없다.

 

 

2. update

update 문을 사용하는 경우 데이터를 수정하는 것이기에 반환값이 없는 쿼리로 처리한다.

대부분의 코드는 insert 할 때와 동일하다.

private static void m2() {
		
		Connection conn = null;
		Statement stat = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "update tblAddress set age = age + 1";
			
			int result = stat.executeUpdate(sql);
			
			if (result > 0) {
				System.out.println("수정 성공");
			} else {
				System.out.println("수정 실패");
			}
			
			stat.close();
			conn.close();
			
		} catch(Exception e) {
			e.printStackTrace();
		}
	}

 

3. delete

delete 문을 사용하는 경우 데이터를 삭제하는 것이기에 반환값이 없는 쿼리로 처리한다.

대부분의 코드는 insert 할 때와 동일하다.

private static void m3() {
		
		Connection conn = null;
		Statement stat = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "delete from tblAddress where seq = 1";
			
			int result = stat.executeUpdate(sql);
			
			if (result > 0) {
				System.out.println("삭제 성공");
			} else {
				System.out.println("삭제 실패");
			}
			
			stat.close();
			conn.close();
			
		} catch(Exception e) {
			e.printStackTrace();
		}
	}

 

4. create

DDL은 아니지만 create 문을 사용하는 경우도 데이터를 추가하는 것이기에 반환값이 없는 쿼리로 처리한다.

대부분의 코드는 insert 할 때와 동일하다.

private static void m4() {
		
		Connection conn = null;
		Statement stat = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "create table tblAddress (\r\n"
					+ "    seq number primary key,\r\n"
					+ "    name varchar2(30) not null,\r\n"
					+ "    age number not null,\r\n"
					+ "    gender char(1) not null,\r\n"
					+ "    address varchar2(300) not null,\r\n"
					+ "    regdate date default sysdate not null\r\n"
					+ ")";
			
			int result = stat.executeUpdate(sql);
			
			stat.close();
			conn.close();
			
		} catch(Exception e) {
			e.printStackTrace();
		}
	}

테이블 생성은 라인이 삽입되는 것이 아니라 result는 0이다.

그래서 테이블 생성이 잘 되었는지 어차피 0이기 때문에 executeUpdate로 확인할 수 가 없다. 

 

 

5. 사용자에게 입력받은 값으로 insert

사용자에게 값을 입력받아 insert하는 것이 기존 insert문과 다른 점은 sql문에 입력받은 값을 넣는 것이다.

String.format() 메소드를 활용하여 sql문에 값을 넣는다.

그 외 다른 점은 없다.

String sql = String.format("insert into tblAddress (seq, name, age, gender, address, regdate) values "
						+ "(seqAddress.nextVal, '%s', %s, '%s', '%s', default)", name, age, gender, address);

 

	private static void m5() {
		
		Scanner scan = new Scanner(System.in);
		String name = "";
		String age = "";
		String gender = "";
		String address = "";
		
		Connection conn = null;
		Statement stat = null;
				
		try {
			
			System.out.print("이름: ");
			name = scan.nextLine();
			
			System.out.print("나이: ");
			age = scan.nextLine();
			
			System.out.print("성별(m,f): ");
			gender = scan.nextLine();
			
			System.out.print("주소: ");
			address = scan.nextLine();
			
			conn = DBUtil.open();
			
			if (!conn.isClosed()) {
				System.out.println("DB 접속 성공");
				
				String sql = String.format("insert into tblAddress (seq, name, age, gender, address, regdate) values "
						+ "(seqAddress.nextVal, '%s', %s, '%s', '%s', default)", name, age, gender, address);
				
				stat = conn.createStatement();
				int result = stat.executeUpdate(sql);
				
				if (result == 1) {
					System.out.println("삽입 성공");
				} else {
					System.out.println("삽입 실패");
				}
				
				stat.close();
				conn.close();
				
			} else {
				System.out.println("DB 접속 실패");
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

 

반환값이 있는 쿼리(select 문)

• 반환값이 있는 쿼리는 네 가지 종류가 나올 수 있다.
• 1. 단일값 반환(1행 1열) - ex) 집계함수를 사용하여 테이블 전체 행을 조회할 때
• 2. 다중값 반환(1행 n열) - ex) 특정 한 사람에 대한 정보를 조회할 때
• 3. 다중값 반환(n행 1열) - ex) 모든 직원의 이름를 조회할 때
• 4. 다중값 반환(n행 n열) - ex) 모든 직원의 모든 정보를 조회할 때

 

1. 단일값 반환(1행 1열)

테이블 전체 행의 값을 조회한다.

 

ResultSet 생성

결과테이블을 받아주는 클래스를 생성해준다.

ResultSet rs = null;

 

 

Statement 객체 생성

sql문을 실행하기 위한 Statement 객체를 생성한다.

stat = conn.createStatement();

 

 

SQL문 작성

String sql = "select count(*) as cnt from tblAddress";

 

 

반환값 저장

executeQuery() 로 ResultSet를 반환받아 위에서 생성한 ResultSet 변수에 저장한다.

rs = stat.executeQuery(sql);

 

한칸 전진하기

rs.next();

ResultSet은 Interator, 향상된 for, 스트림, 커서와 같은 방식으로 불러온다.

커서가 BOF(헤더)에 위치한 것을 한 칸 전진하여 실제 데이터가 있는 레코드로 이동한다.

 

 

rs.getXXX()

현재 커서가 가르키고 있는 레코드의 원하는 컬럼을 접근하여 데이터를 가져오면 오는 접근 방법이다.

getInt 와 getString 이 존재한다.
getInt(n)는 n번째 컬럼값을 숫자로 반환한다. 인덱스는 1부터 시작한다.
getString("컬럼명")는 조회할 특정 컬럼명을 매개변수 사용하여 컬럼값을 문자열로 반환한다. 컬럼의 이름이 긴 경우 가독성이 떨어지고, 에러가 날 경우가 있으므로 Alias를 사용하여 간결하게 만들어준다.

위 두가지 방법 중에서 getString이 가독성이 높아서 더 많이 사용한다.

int count = rs.getInt("cnt");

 

 

자원 해제

생성한 역순으로 해제한다.

rs.close();
stat.close();
conn.close();

 

 

전체 코드

	private static void m6() {
    
		Connection conn = null;
		Statement stat = null;
		ResultSet rs = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "select count(*) as cnt from tblAddress";
			
			rs = stat.executeQuery(sql);
			
			rs.next(); 
			
			int count = rs.getInt("cnt");
			
			System.out.println(count);
			
			rs.close();
			stat.close();
			conn.close();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}

 

 

2. 다중값 반환(1행 n열)

조회할 번호를 입력받아 그 사람의 정보를 조회한다.

사용자가 입력한 번호가 있는 데이터인지 조건문으로 확인하고 있다면 n개의 열만큼 getString으로 접근하여 출력한다.

	private static void m7() {
		
		Scanner scan = new Scanner(System.in);
		
		System.out.print("번호: ");
		String seq = scan.nextLine();
		
		Connection conn = null;
		Statement stat = null;
		ResultSet rs = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "select * from tblAddress where seq = " + seq;
			
			rs = stat.executeQuery(sql);
			
			//결과데이터가 있을수도 있고 없을수도 있음
			if (rs.next()) {
				
				System.out.println("번호: " + rs.getString("seq"));
				System.out.println("이름: " + rs.getString("name"));
				System.out.println("나이: " + rs.getString("age"));
				System.out.println("주소: " + rs.getString("address"));
				
			} else {
				System.out.printf("입력한 %s번의 데이터가 없습니다.\n", seq);
			}
			
			rs.close();
			stat.close();
			conn.close();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

 

3. 다중값 반환(n행 1열)

테이블에서 모든 "name" 열을 조회한다.

커서가 존재할 때까지 출력한다.

	private static void m8() {
		
		Connection conn = null;
		Statement stat = null;
		ResultSet rs = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "select name from tblAddress";
			
			rs = stat.executeQuery(sql);
			
			while(rs.next()) {
				System.out.println(rs.getString("name"));
			}

			rs.close();
			stat.close();
			conn.close();
			
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

 

4. 다중값 반환(n행 n열)

1행 n열, n행 1열에서 작성한 코드를 합쳐서 사용한다.

	private static void m9() {
		
		Connection conn = null;
		Statement stat = null;
		ResultSet rs = null;
		
		try {
			
			conn = DBUtil.open();
			stat = conn.createStatement();
			
			String sql = "select * from tblAddress";
			
			rs = stat.executeQuery(sql);
			
			System.out.println("[번호]\t[이름]\t[나이]\t[주소]");
			while(rs.next()) {
				System.out.printf("%s\t%s\t%s\t%s\n"
									,rs.getString("seq")
									,rs.getString("name")
									,rs.getString("age")
									,rs.getString("address"));
			}
			
			rs.close();
			stat.close();
			conn.close();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}