[JDBC] 자바 오라클 디비 연동//만든 DB Connection CLASS 연동//데이터 /추가/삭제/수정/읽기/select/delete/update

2021.03.29 - [JAVA/JAVA(자바)설치 및 툴 이용(ECLIPSE)] - [JAVA] 자바 설치 및 환경 하기 JDK 1.8 버전

[JAVA] 자바 설치 및 환경 하기 JDK 1.8 버전

2021.03.22 - [[DB]데이터 베이스/오라클DB(Oracle)] - [오라클 DB 설치]오라클 11g 버전 데이터 베이스 설치 하기 쉽게 가자 다운로드 사이트 포함 // 오라클 11G

[오라클 DB 설치]오라클 11g 버전 데이터 베이스 설치 하기 쉽게 가자 다운로드 사이트 포함 // 오

개발 환경

운영체제 : Window 10 

JDK 1.8

툴 : 이클립스 2020_03 버전

데이터 베이스 : 오라클 11g  자바에서 사용//ojdbc6.jar

---

2021.03.24 - [[DB]데이터 베이스/오라클DB(Oracle)] - [DB] 데이터베이스 오라클 샘플데이터( SAMPLE DATA) 실습 가능한 데이터/sql 실습/table

[DB] 데이터베이스 오라클 샘플데이터( SAMPLE DATA) 실습 가능한 데이터/sql 실습/table

 

위에 데이터를 추가 하자 

본인의 db에 데이터 테이블이 있다면 테이블명 만 수정 하면 된다 . 그리고 유저명과 비밀 번호 만 수정 하면 된다

 

그전에 클래스 두개를 추가 해야한 디비와 오라클 연동해주는 ConnectionCloseHelper  Class

종료 할때 쓰는 ConnectionCloseHelper 가 필요 하다 아래에 링크 두개 달아 드립니다

2021.04.19 - [JAVA/JDBC] - [JDBC]데이터베이스 Connection class 만들기 / 모듈로 쓰기 //oracle/mysql

[JDBC]데이터베이스 Connection class 만들기 / 모듈로 쓰기 //oracle/mysql

2021.04.19 - [JAVA/JDBC] - [JDBC] 자바 오라클 디비 연동//DB 종료 하기ConnectionCloseHelper만들기Close//ResultSet//Statement//Statement//Statement

 

[JDBC] 자바 오라클 디비 연동//DB 종료 하기ConnectionCloseHelper만들기Close//ResultSet//Statement//Statement//Sta

dept2 테이블 /데이터 /추가/삭제/수정/읽기/select/delete/update 하기 

package ex01.jdbc;
import java.sql.*;
import java.util.Scanner;

import dbConn.util.ConnectionCloseHelper;
import dbConn.util.ConnectionHelper;

public class Dept2Select {
	public static void main(String[] args) throws Exception {
		String dcode, dname, pdept, area;
		String modiDept = null;
		dcode=dname=pdept=area = null;
		
		int numjob = 0, num = 0;
		Scanner sc = new Scanner(System.in);
		
		Connection conn = ConnectionHelper.getConnection("oracle", "sk_01", "1111");
		conn.setAutoCommit(false);  // 자동 커밋 끄기
		Statement stmt = conn.createStatement();
		ResultSet rs = null;
		PreparedStatement pstmt = null;
		
		while(true) {
			System.out.println("원하는 기능을 선택해 주세요.");
			System.out.println("1. Dept2 select, 2. insert , 3. update, 4. delete, 5. rollback, 6. exit ");
			numjob = sc.nextInt();
			
			switch( numjob ) {
				// select
				case 1 :  rs = stmt.executeQuery("SELECT * FROM DEPT2 ORDER BY DCODE");
							printdata(rs);
							break;
				// insert 
				case 2 : 
					System.out.print("DCODE = ");  					dcode = sc.next();
					System.out.print("DNAME = ");  					dname = sc.next();
					System.out.print("PDEPT = ");  						pdept = sc.next();
					System.out.print("AREA = ");  						area = sc.next();
					String sql = "insert into dept2 values('" + dcode + "','" 
									+ new String( dname.getBytes("utf-8"), "utf-8" )
									+ "', '" + new String(pdept.getBytes("utf-8"), "utf-8") 
									+ "', '" +  new String(pdept.getBytes("utf-8"), "utf-8") + "')" ;
									
//					System.out.println(sql);
					stmt.executeQuery(sql);
					conn.commit();   // 커밋
					System.out.println(dname + " 추가 되었습니다. ");
					     break;
					     
			 // update====================================================================================
					    
				case 3:
						rs = stmt.executeQuery("select * from dept2");
						printdata(rs);
						System.out.println("수정할 dept code 를 입력하세요. ");
						modiDept = sc.next();
						
						System.out.println("수정할 레코드의 요소는 무엇 ? ");
						System.out.println("1. dcode , 2. dname, 3. pdept,  4. area");
						num = sc.nextInt();
						
						switch( num ) {
							case 1 : // 코드 변경
								System.out.println("현재 dcode : ");
								rs = stmt.executeQuery("select dcode from dept2 where dcode = '" + modiDept +"'");
								while( rs.next() ) {
									System.out.println(rs.getString(1) + " 입니다.");
								} // in while end
								
								System.out.println("몇번으로 변경 원하니? ");		dcode = sc.next();
								pstmt = conn.prepareStatement(
										"update dept2 set dcode = ? where dcode = '" + modiDept  + "'" );
								pstmt.setString(1, dcode);								pstmt.executeUpdate(); ///
								conn.commit();
								System.out.println("dcode 가(이) 수정이 완료 되었습니다.");
								break;	 
							
							case 2 :  // 부서명 변경
								System.out.println("현재 dname : ");
								rs = stmt.executeQuery("select dname from dept2 where dcode = '" + modiDept +"'");
								while( rs.next() ) {
									System.out.println(rs.getString(1) + " 입니다.");
								} // in while end
								
								System.out.println("무엇으로 변경 원하니? ");		dname = sc.next();
								pstmt = conn.prepareStatement(
										"update dept2 set dname = ? where dcode = '" + modiDept  + "'" );
								pstmt.setString(1, dname);								pstmt.executeUpdate(); ///
								conn.commit();
								System.out.println("dname 가(이) 수정이 완료 되었습니다.");
								break;	 
								
							case 3 :  // 상위부서명 변경
								System.out.println("현재 pdept : ");
								rs = stmt.executeQuery("select pdept from dept2 where dcode = '" + modiDept +"'");
								while( rs.next() ) {
									System.out.println(rs.getString(1) + " 입니다.");
								} // in while end
								
								System.out.println("pdept 무엇으로 변경 원하니? ");		pdept = sc.next();
								pstmt = conn.prepareStatement(
										"update dept2 set pdept = ? where dcode = '" + modiDept  + "'" );
								pstmt.setString(1, pdept);								pstmt.executeUpdate(); ///
								System.out.println("pdept 가(이) 수정이 완료 되었습니다.");
								break;	 
								
							case 4 :  // 지점 변경
								System.out.println("현재 area : ");
								rs = stmt.executeQuery("select area from dept2 where dcode = '" + modiDept +"'");
								while( rs.next() ) {
									System.out.println(rs.getString(1) + " 입니다.");
								} // in while end
								
								System.out.println("area 무엇으로 변경 원하니? ");		area = sc.next();
								pstmt = conn.prepareStatement(
										"update dept2 set area = ? where dcode = '" + modiDept  + "'" );
								pstmt.setString(1, area);								pstmt.executeUpdate(); ///
								System.out.println("area 가(이) 수정이 완료 되었습니다.");
								break;	 
								
								default: System.out.println("잘못 입력 하셨습니다. (1 ~ 4) ");
										   break;
						} // in update switch end
					    break;  
			 // delete=======================================================================================
				case 4:
						rs = stmt.executeQuery("select * from dept2");
						printdata(rs);
						System.out.println("삭제할 dept code 를 입력하세요. ");
						dcode = sc.next();
						sql = "delete from dept2 where dcode = ? ";
						pstmt = conn.prepareStatement(sql);
						pstmt.setString(1, dcode);
						pstmt.executeUpdate();  //
						System.out.println(dcode + " 에 해당하는 상품이 삭제 되었습니다. ");
						break;	  
					
			// rollback
				case 5:
						conn.rollback();
						System.out.println("롤백 했습니다.");
						break;
				case 6 :  
                		// ConnectionCloseHelper Class 사용 완벽한 종료
                        
						ConnectionCloseHelper.close_all(rs,stmt,pstmt,conn);
//						ConnectionCloseHelper.close(rs);
//						ConnectionCloseHelper.close(stmt);
//						ConnectionCloseHelper.close(pstmt);
//						ConnectionCloseHelper.close(conn);
						System.exit(0);
						break;
					
					default : 
						System.out.println("다시 입력해 주세요.");
						break;
			} // end switch
		} // end while
	}

	public static void printdata(ResultSet rs) {
		int num = 1;
		try {
			ResultSetMetaData rsmd = null;  //테이블의 정보를 얻어 올 수 있는 인터페이스
			//  resultset의 데이터를 MetaData로 구조를 파악한다.
			// MetaData = 속성 정보 라고 할 수 있다.
			rsmd = rs.getMetaData();
			
			int colCount = rsmd.getColumnCount();  // 컬럼 수를 구한다.
			System.out.println("======================================");
			System.out.println("SEQ \t DCODE  \t DNAME \t  PDEPT \t  AREA"  );
			System.out.println("======================================");
			
			while( rs.next() ) {
				System.out.print( num + " 번 \t");
				num++;
			
				for (int i = 1; i <= colCount ; i++) {  // db --> 필드명이 1부터 시작함
					
					switch( rsmd.getColumnType(i) ) {
						case Types.NUMERIC :
						case Types.INTEGER :
							System.out.print( rsmd.getColumnName(i) + " : " + rs.getInt(i) );
							break;
						case Types.FLOAT :
							System.out.print( rsmd.getColumnName(i) + " : " + rs.getFloat(i) );
							break;
							
						case Types.DOUBLE :
							System.out.print( rsmd.getColumnName(i) + " : " + rs.getDouble(i) );
							break;
							
						case Types.CHAR :
							System.out.print( rsmd.getColumnName(i) + " : " + rs.getString(i) );
							break;
						case Types.DATE :
							System.out.print( rsmd.getColumnName(i) + " : " + rs.getDate(i) );
							break;
							
							default :
								//System.out.print( rsmd.getColumnName(i) + " : " + rs.getString(i) );
								if( rs.getString(i) == null ) {
									System.out.print( " " + "\t");
								} else {
									System.out.print(  rs.getString(i)+ "\t");
								}
					} // switch end
				} // for end
				System.out.println();
			} // while end
		} catch (Exception e) {
			System.out.println("SQLExeption : " + e.getMessage());
		} // try end		
	}
}

 

 

[JDBC]데이터베이스 Connection class 만들기 / 모듈로 쓰기 //oracle/mysql

 

---