[JAVA] 오라클 연동

Ex01

package DBconn;

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

public class DBtest {

	public static void main(String[] args) {
		/* 오라클 접속할 때, 아래와 같이 사용. 약속된 형식.*/
		String driver = "oracle.jdbc.driver.OracleDriver";
		String url = "jdbc:oracle:thin:@localhost:1521:orcl";
		/* 유저 정보 저장 */
		String userId = "scott";
		String userPw = "tiger";
		
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null; //검색할 단어를 담을 객체
		
		try {
			//1. 드라이버 로드
			Class.forName(driver);
			//2. DB접속 
			conn = DriverManager.getConnection(url, userId, userPw);
			//System.out.println("DB접속 성공");
			
			String sql = "select deptno, dname, loc from dept";
			
			//연결 성공하면 SQL문 실행
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			//executeQuery는 select만
			//executeUpdate는 삭제 등록까지
			
			while(rs.next()) { //검색할 결과가 있다면
				int deptno = rs.getInt("deptno");
				String dname = rs.getString("dname");
				String loc = rs.getString("loc");
				System.out.println(deptno + "\t" + dname + "\t" + loc);
			}
			
		} catch (Exception e) {
			System.out.println("접속 오류");
		} finally {
			try {
				if(rs != null) rs.close();
				if(stmt != null) stmt.close();
				if(conn != null) conn.close();
			} catch (Exception e) {
				
			}
		}
	}
}

 

 

EX02

package DBconn;

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

public class DBtest {

	public static void main(String[] args) {
		/* 오라클 접속할 때, 아래와 같이 사용. 약속된 형식.*/
		String driver = "oracle.jdbc.driver.OracleDriver";
		String url = "jdbc:oracle:thin:@localhost:1521:orcl";
		/* 유저 정보 저장 */
		String userId = "scott";
		String userPw = "tiger";
		
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null; //검색할 단어를 담을 객체
		
		try {
			//1. 드라이버 로드
			Class.forName(driver);
			//2. DB접속 
			conn = DriverManager.getConnection(url, userId, userPw);
			//System.out.println("DB접속 성공");
			
			String sql = "select * from emp";
			
			//연결 성공하면 SQL문 실행
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			//executeQuery는 select만
			//executeUpdate는 삭제 등록까지
			
			while(rs.next()) { //검색할 결과가 있다면
				int empno = rs.getInt(1);
				String ename = rs.getString(2);
				String job = rs.getString(3);
				String mgr = rs.getString(4);
				String hiredate = rs.getString(5);
				String sal = rs.getString(6);
				String comm = rs.getString(7);
				System.out.println(empno + "\t" + ename + "\t" + job + "\t" + mgr + "\t" + 
				hiredate + "\t" + sal + "\t" + comm);
			}
			
		} catch (Exception e) {
			System.out.println("접속 오류");
		} finally {
			try {
				if(rs != null) rs.close();
				if(stmt != null) stmt.close();
				if(conn != null) conn.close();
			} catch (Exception e) {
				
			}
		}
	}
}