이클립스 mysql 연동 데이터 읽고 쓰기.

package net.bitacademy.java41.step10;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Date;
import java.util.Scanner;

/* Statememt vs. PreparedStatement
 * 1) 소스 가독성:
 * SQL문이 복잡할 수록 읽기 어렵다  <==> 간결하다.
 *
 * 2) 바이너리 데이터(이미지, 음악, 동영상 등) 입력:
 * 불가(base64와 같은 문자열 형식으로 인코딩 시 가능) <==> 가능
 *
 * 3) 반복 수행 시 속도:
 * 매번 SQL문을 DBMS 형식에 따라 변환 속도 느리다
 * <==> 한번만 변환, 그리고 실행, 속도 빠르다.
 */
public class RedApp {
protected Scanner scanner;
private Member member;

public RedApp() {
scanner = new Scanner(System.in);
}

public void execute() {
while(true) {
System.out.print("명령>");
String command = scanner.nextLine().toLowerCase();

if (command.equals("add")) {
member = null;
add();
} else if (command.equals("list")) {
member = null;
list();
} else if (command.startsWith("view")) {
//명령>view a@test.com
String[] values = command.split(" ");
view( values[1] );
} else if (command.equals("update")) {
if (member != null) {
update();
} else {
System.out.println("먼저 멤버를 조회하세요!");
}
} else if (command.equals("delete")) {
if (member != null) {
detele();
} else {
System.out.println("먼저 멤버를 조회하세요!");
}
} else if (command.equals("quit")) {
System.out.println("안녕!");
break;
} else {
System.out.println("지원하지 않는 명령어입니다.");
}
}
}

private void add(){
Member m = new Member();
System.out.print("이름 : ");
m.setName(scanner.nextLine());
System.out.print("전화번호 : ");
m.setPhone(scanner.nextLine());
System.out.print("이메일 : ");
m.setEmail(scanner.nextLine());
System.out.print("블로그 : ");
m.setBlog(scanner.nextLine());
System.out.print("나이 : ");
m.setAge( Integer.parseInt( scanner.nextLine() ) );

System.out.print("등록하시겠습니까?(y/n)");
if(scanner.nextLine().toLowerCase().equals("y")){
m.setRegDate(new Date());

Connection con = null; //등록은  sql문을 전달만하고  DB에서 기능이 이루어지기때문에 커넥션과 스테이트먼트만 준비
PreparedStatement stmt = null;

try {
String driverClass = System.getProperty("driverClass"); //커넥션 인터페이스를 구현하는 드라이버클래스 정보 를 담는다.
Class.forName(driverClass); //담은 클래스정보를 로딩

con = DriverManager.getConnection( //매니저를 이용 커넥션 인터페이스를 구현한 클래스들 중에서
"jdbc:mysql://localhost/test", "test", "test"); //즉 my sql과 연결된 모든 정보들중 해당 주소와 아이디 비번 값을 가진
// 테이블에 연결
stmt = con.prepareStatement( // sql문 보내기
"insert into MEMBERS(MNAME,PHONE,EMAIL,BLOG,AGE,REG_DATE)"
+ " values(?,?,?,?,?,now())"); // insert 로 칼럼 만들고 값에다가 ? now()는 현재 시간
stmt.setString(1, m.getName()); // 덱스 번호 순서에따라 입력받은 데이터를 얻어와서 입력
stmt.setString(2, m.getPhone()); //
stmt.setString(3, m.getEmail()); //
stmt.setString(4, m.getBlog());
stmt.setInt(5, m.getAge());
int count = stmt.executeUpdate(); //

System.out.println("등록되었습니다!");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {stmt.close();} catch(Exception e) {}
try {con.close();} catch(Exception e) {}
}
} else {
System.out.println("등록 취소하였습니다!");
}
}

private void list() {
Connection con = null; //java.sql에 정의된 인터페이스 를 선언
Statement stmt = null; //서버에 sql문을 보낼 도구
ResultSet rs = null; //DB에 저장된 데이터를 가져오기 위한도구 위한 도구.

try {
// MySQL 서버에 연결할 도구를 준비
// - JDBC Driver 클래스 중(.jar 파일에 들어있는 클래스들 중에서)
//   java.sql.Driver 인터페이스를 구현한 클래스를 먼저 로딩한다.
// - 이 클래스가 java.sql.Connection 인터페이스를 구현한 클래스를 알고 있다.
//
String driverClass = System.getProperty("driverClass"); // 시스템 클래스의 getProperty 메소드를 이용 driverclass의 정보를 얻어와
Class.forName(driverClass); // String 타입으로 반환한다. 이것을 class.forName 메소드를 이용 해당클래스들을
//Class.forName("com.mysql.jdbc.Driver"); // 로딩한다.

// 1. 서버와 연결
con = DriverManager.getConnection( //로딩된 클래스들중 mysql인터페이스를 구현하는 클래스정보를
"jdbc:mysql://localhost/test", "test", "test"); //해당 주소,아이디,비밀번호 가진 mysql 데이터와 연결

// 2. SQL문을 보낼 도구를 얻기
// - createStatement()를 호출하여 SQL문을 서버에 보낼 도구를 얻는다.
stmt = con.createStatement();

// 3. SQL을 서버에 보냄
// - executeQuery()는 서버에 SQL문을 보낸다.
// - 서버는 결과를 준비한다.
// - executeQuery()는 서버에서 결과를 가져올 도구를 리턴한다.
rs = stmt.executeQuery(
"select MNAME,PHONE,EMAIL from MEMBERS order by MNAME"); // order by 는 이름순으로 정렬해서

// 4. 서버의 결과를 가져와서 출력
// - next()를 호출하여 서버로부터 1 레코드의 결과를 가져온다.
while(rs.next()) {
System.out.print(rs.getString("MNAME") + ","); //보내기위한 도구 rs에서 결과를 가져오는 메소드 next 호출
System.out.print(rs.getString("PHONE") + ","); //읽어올 데이타가 없을경우 1을 반환 false를 반환
System.out.println(rs.getString("EMAIL")); //문자열로 반환 화면에 출력
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {rs.close();} catch (Exception e) {} //마찬가지로 연결도구 모두 종료.
try {stmt.close();} catch (Exception e) {}
try {con.close();} catch (Exception e) {}
}
}

private void detele() {
Connection con = null; //연결도구
Statement stmt = null; //보낼도구

try {
String driverClass = System.getProperty("driverClass"); //역시 마찬가지로 연결을 위한 인터페이스를 구현하는 클래스를 로딩
Class.forName(driverClass);

con = DriverManager.getConnection( //로딩된 클래스에 manager 를 사용 해당주소로 연결
"jdbc:mysql://localhost/test", "test", "test");

stmt = con.createStatement(); //보낼도구 준비

int count = stmt.executeUpdate( // excuteUpdate 메소드를 이용 sql문을 이용 보냄.
"delete from MEMBERS"
+ " where EMAIL='" + member.getEmail() + "'"); // view 에서 이메일을 입력했을 경우 인스턴스변수 m 은 null 이 아니게되고.
// excuteUpdate 는 조건에 맞는 칼럼을 삭제하고 칼럼수를 인트로 반환
if (count > 0) { // 0보다 큰경우는 삭제를 확인
System.out.println("삭제되었습니다!");
} else {
System.out.println("해당 이메일의 멤버를 찾을 수 없습니다!"); // 그렇지 않은 경우는 해당 메세지 출력
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {stmt.close();} catch(Exception e) {}
try {con.close();} catch(Exception e) {}
}
}

private void update() {
Member copy = member.clone();
System.out.printf("이메일(%1$s):\n", member.getEmail()); // 이메일은 키(아이디)값이기 때문에 변경을 하지 않는다.
System.out.printf("이름(%1$s):", member.getName());
String value = scanner.nextLine();
if (value.length() > 0) {
copy.setName(value);
}
System.out.printf("전화(%1$s):", member.getPhone());
value = scanner.nextLine();
if (value.length() > 0) {
copy.setPhone(value);
}
System.out.printf("블로그(%1$s):", member.getBlog());
value = scanner.nextLine();
if (value.length() > 0) {
copy.setBlog(value);
}
System.out.printf("나이(%1$d):", member.getAge());
value = scanner.nextLine();
if (value.length() > 0) {
copy.setAge( Integer.parseInt(value) );
}

System.out.print("변경하시겠습니까?(y/n)");
if(scanner.nextLine().toLowerCase().equals("y")){
Connection con = null;
PreparedStatement stmt = null;

try {
String driverClass = System.getProperty("driverClass"); //역시 해당드라이버들 로딩
Class.forName(driverClass); //로딩

con = DriverManager.getConnection( // 해당 주소 연결
"jdbc:mysql://localhost/test", "test", "test");

stmt = con.prepareStatement( //sql문 전달.
"update MEMBERS set"
+ " MNAME=?,PHONE=?,BLOG=?,AGE=?,REG_DATE=now()" // ? 지역에 setString 을 이용 인덱스번호대로 입력한다.
+ " where EMAIL=?");
stmt.setString(1, copy.getName());
stmt.setString(2, copy.getPhone());
stmt.setString(3, copy.getBlog());
stmt.setInt(4, copy.getAge());
stmt.setString(5, member.getEmail());
int count = stmt.executeUpdate(); //역시 count로 반환

if (count > 0) {
System.out.println("변경되었습니다!"); //해당 데이터 변경
} else {
System.out.println("해당 이메일의 멤버를 찾을 수 없습니다."); //조건에 맞는 해당 데이터가 없을경우 count 값은 -1이기 때문에.
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {stmt.close();} catch(Exception e) {}
try {con.close();} catch(Exception e) {}
}
} else {
System.out.println("변경 취소하였습니다!");
}
}

private void view(String email) {
Connection con = null; //view 도 역시 list와 같이 데이터를 불러와야하기 때문에 ResultSet을 준비 한다.
Statement stmt = null;
ResultSet rs = null;

try {
String driverClass = System.getProperty("driverClass"); //해당 인터페이스를 구현하는 클래스 정보를 담는다
Class.forName(driverClass);       //클래스 로딩

con = DriverManager.getConnection(
"jdbc:mysql://localhost/test", "test", "test"); //연결

stmt = con.createStatement(); //sql문 전달.

rs = stmt.executeQuery( // 해당 칼럼 선택.
"select MNAME,PHONE,EMAIL,BLOG,AGE,REG_DATE"
+ " from MEMBERS"
+ " where EMAIL='" + email + "'"); // 조건은 입력받은 이메일 주소와 같은 이메일 주소데이타.

if (rs.next()) { //새로운 멤머 객체를 만들고 set 메소드를 이용 그안에 파라미터로
member = new Member(); //읽기위한 도구 rs(ResultSet)으로 getString 메소드 호출 파라미터로
member.setName(rs.getString("MNAME")); //칼럼이름.
member.setPhone(rs.getString("PHONE"));
member.setEmail(rs.getString("EMAIL")); //즉 입력된 칼럼이름 안에 데이터를 문자열 타입으로 변환 Member 인스턴스에 생성한다.
member.setBlog(rs.getString("BLOG"));
member.setAge(rs.getInt("AGE"));
member.setRegDate(rs.getDate("REG_DATE"));

} else {
throw new Exception("해당 이메일의 멤버가 없습니다."); //
}
} catch (Exception e) {
e.printStackTrace();
return;
} finally {
try {rs.close();} catch (Exception e) {}
try {stmt.close();} catch (Exception e) {}
try {con.close();} catch (Exception e) {}
}

System.out.println("이름:" + member.getName()); //셋팅된 Member 객체에서 출력.
System.out.println("전화:" + member.getPhone());
System.out.println("이메일:" + member.getEmail());
System.out.println("블로그:" + member.getBlog());
System.out.println("나이:" + member.getAge());
System.out.printf("등록일:%1$tY-%1$tm-%1$td \n", member.getRegDate());
}

public static void main(String[] args) {
RedApp app = new RedApp();
app.execute();
}
}