java 메모장 만들기 관련 질문인데요

패키지 컴파일을 제대로 하지 못한건지 아니면 일부러 빼놓은건지

몇개의 클래스가 빠져있고 

제때 커넥션이 연결되지 않는군요.

다른클래스를 만들어서 첨부합니다.

DriverManager.getConnection() <--이부분에 자신의 DB에 맞는 데이타베이스나 인스턴스를 채워넣으면

될것입니다.

또 sql부분도 오라클인지 mysql인지 선택하여 살리면 될것입니다.

test <-- 테이블 이름만 자신의 테이블 이름으로 바꾸면 될겁니다.

create table test

(memono int auto_increment primary key,

name varchar(20),

content varchar(100),

memodate timestamp);

테이블은 요정도로 만들면 됩니다.

실행화면

 메모 목록

 6 bdddddddd fdsafsdfasdffdsafdsf  (2012-03-30 00:58)

 5 bbbssss xxxxfdsafd  (2012-03-30 00:56)

 4 dddd fdsafsdafsafsd  (2012-03-30 00:49)

 3 ccc fdsafsdafdsafsd  (2012-03-30 00:49)

 1 dsf fdsafd  (2012-03-30 00:45)

+---------------------------------------------------------+

| 메모장 (Ver 1.3) |

+---------------------------------------------------------+

|1-입력 | 2-목록 | 3-최신글 | 4-수정 | 5-삭제 | 9-종료                 |

+---------------------------------------------------------+

메뉴를 선택하세요3

 메모 목록

 6 bdddddddd fdsafsdfasdffdsafdsf  (2012-03-30 00:58)

 5 bbbssss xxxxfdsafd  (2012-03-30 00:56)

 4 dddd fdsafsdafsafsd  (2012-03-30 00:49)

+---------------------------------------------------------+

| 메모장 (Ver 1.3) |

+---------------------------------------------------------+

|1-입력 | 2-목록 | 3-최신글 | 4-수정 | 5-삭제 | 9-종료                 |

+---------------------------------------------------------+

메뉴를 선택하세요

package memo;

import java.sql.*;

/**

 * @author Administrator

 *

 */

public class Memo {

public static void main(String[]args){

new Memo().init();

}

    public void init(){

        while(true){ // 무한 루틴

            menu();  // 같은 클래스 안에서는 메소드를 제약 없이 호출

        }

    }

   

    public void menu(){

        int cnt = 3; // 최신글 갯수

       

        pl("+---------------------------------------------------------+");

        pl("| 메모장 (Ver 1.3) |");

        pl("+---------------------------------------------------------+");

        pl("|1-입력 | 2-목록 | 3-최신글 | 4-수정 | 5-삭제 | 9-종료                 |");

        pl("+---------------------------------------------------------+");

       

        //------------------------------------------------

        int menu = 0;

   

        try {

            menu = InputData.readInt("메뉴를 선택하세요");  // 입력 대기 상태로 기다림.

           

            if (menu == 1) {      // 입력

                create();

            }else if(menu == 2){  // 화면 출력

                list();

            }else if(menu == 3){  // 최신글 출력

                listTop(cnt);

            }else if(menu == 4){  // 수정

                list();

                update();

            }else if(menu == 5){  // 삭제

                list();

                delete();

            }else if(menu == 9){  // 종료

                System.out.println("프로그램을 종료합니다.");

                System.exit(0);

            }           

        }

        catch (Exception e) {

            System.out.println("Error: " + e.toString());

        }

    }   

   

    // throws Exception: 예외를 이메소드에서 처리하지 않음을 선언.

   

    /**입력메서드

     * @throws Exception

     */

    public void create() throws Exception{

        System.out.println("메모 입력");

        Connection con = null;

        PreparedStatement  pstmt=null;

        int ret = 0;         // 추가 레코드 수

       

        StringBuffer sql = null;     // SQL

        String name = "";    // 성명

        String content = ""; // 내용

       

        name = InputData.readString("영문이름 입력(exit: 취소) ☞ ");     // 이름 입력

        name = name.toLowerCase();  // 소문자로 변경

       

        if (name.equals("exit")){

            pl(" 등록을 취소 했습니다.");

            return;   // 메소드의 실행을 취소, 리턴 값은 없음

        }

           

        content = InputData.readString("내용 입력 ☞ ");  // 내용 입력

        sql=new StringBuffer("INSERT INTO test ");

        //mysql 시

        sql.append("VALUES(null,?,?,now())");

        

        //oracle 시

       // sql.append("VALUES(시퀀스네임.NEXTVAL,?,? sysdate)");

        

        con=DBConnect.getConnection();

        pstmt = con.prepareStatement(sql.toString());

        pstmt.setString(1, name);

        pstmt.setString(2, content);

       

        ret = pstmt.executeUpdate();

       

        if (ret == 1){

            System.out.println("\n메모를 추가했습니다.\n");

        }else{

            System.out.println("\n메모 추가에 실패 했습니다. 다시 입력해 주세요.\n");

        }

       

        DBClose.close(con, pstmt);

       

    }

   

    /**수정

     * @throws Exception

     */

    public void update() throws Exception{

        Connection con = null;

        PreparedStatement  pstmt=null;

        int ret = 0;         // 추가 레코드 수

       

        StringBuffer sql = null;     // SQL

        String name = "";    // 성명

        String content = ""; // 내용

        int memono = 0;      // 메모 번호

       

        sql=new StringBuffer();

        sql.append("UPDATE  test ")

        .append("SET memoname=? , content=? ")

        .append("WHERE memono=? ");

       

        memono = InputData.readInt("수정할 메모 번호를 입력 하세요(EXIT: 999). ☞ ");

        if (memono == 999){

            pl(" 수정을 취소 했습니다.");

            return;

        }

        

        

        name = InputData.readString("이름 입력 ☞ ");

        content = InputData.readString("내용 입력 ☞ ");

        

        con=DBConnect.getConnection();

        pstmt = con.prepareStatement(sql.toString());

        pstmt.setString(1, name);

        pstmt.setString(2, content);

        pstmt.setInt(3, memono);

       

        ret = pstmt.executeUpdate();

       

        if (ret == 1){

            System.out.println("메모를 수정했습니다.");

        }else{

            System.out.println("메모 수정에 실패 했습니다. 다시 입력해 주세요.");

        }

       

        DBClose.close(con, pstmt);

       

    }

   

    /**삭제

     * @throws Exception

     */

    public void delete() throws Exception{

        Connection con = null;

        PreparedStatement  pstmt=null;

        int ret = 0;         // 추가 레코드 수

       

        StringBuffer sql = null;     // SQL

        int memono = 0;      // 메모 번호

       

        sql=new StringBuffer();

        sql.append("DELETE FROM test WHERE memono=?");

        con = DBConnect.getConnection();

        memono = InputData.readInt("삭제할 메모 번호 입력(EXIT: 999) ☞ ");

        if (memono == 999){

            pl(" 삭제를 취소 했습니다.");

            return;

        }

       

        pstmt = con.prepareStatement(sql.toString());

        pstmt.setInt(1, memono);

       

        ret = pstmt.executeUpdate();

       

        if (ret == 1){

            System.out.println("메모를 삭제했습니다.");

        }else{

            System.out.println("메모 삭제에 실패 했습니다. 다시 입력해 주세요.");

        }

       

        DBClose.close(con, pstmt);       

    }

    

    

    /** 전체 출력

     * @throws Exception

     */

    public void list() throws Exception{

        System.out.println("\n");

        System.out.println(" 메모 목록");

        Connection con = null;

        PreparedStatement  pstmt=null;

        ResultSet rs = null;

       

        /////////////////////////////////

        StringBuffer sql=new StringBuffer();

        sql.append("SELECT * ")

        .append("FROM test ")

        .append("ORDER BY memono DESC");

        /////////////////////////////////////

      

        con=DBConnect.getConnection();

        pstmt = con.prepareStatement(sql.toString());

        rs = pstmt.executeQuery();

   

        while(rs.next()){

            // 기준 출력 문자열 갯수: 80

            // printf("%20s", ""): 문자열 출력폭을 고정할수 없음.

            System.out.print(" ");

            System.out.print(rs.getInt("memono"));

            System.out.print("\t" + rs.getString("name"));

            System.out.print("\t" + rs.getString("content"));

           

            String memodate = rs.getString("memodate");

            System.out.print("  (" + memodate.substring(0, 16) + ")" );

            System.out.println("");

        }

       

        DBClose.close(con, pstmt, rs);       

    }

   

    

    /** 최신글 보기

     * @param int cnt

     * @throws Exception

     */

    public void listTop(int cnt) throws Exception{

        System.out.println("\n");

        System.out.println(" 메모 목록");

        Connection con = null;

        PreparedStatement  pstmt=null;

        ResultSet rs = null;

       

        StringBuffer sql=new StringBuffer();

       

    /*    //오라클

        sql.append("SELECT memono,name,content,memodate FROM ")

        .append("(SELECT memono,name,content,memodate,ROWNUM FROM test ")

        .append("ORDER BY ROWNUM DESC ) ")

        .append("WHERE ROWNUM <=?");*/

        

        //mysql

        sql.append("SELECT * FROM test ")

        .append("ORDER BY memono DESC ")

        .append("limit 0,?");

        

        con = DBConnect.getConnection();

       

        pstmt = con.prepareStatement(sql.toString());

        pstmt.setInt(1, cnt);

        rs = pstmt.executeQuery();

   

        while(rs.next()){

            // 기준 출력 문자열 갯수: 80

            // printf("%20s", ""): 문자열 출력폭을 고정할수 없음.

            System.out.print(" ");

            System.out.print(rs.getInt("memono"));

            System.out.print("\t" + rs.getString("name"));

            System.out.print("\t" + rs.getString("content"));

           

            String memodate = rs.getString("memodate");

            System.out.print("  (" + memodate.substring(0, 16) + ")" );

            System.out.println("");

        }

       

        DBClose.close(con, pstmt, rs);       

    }

   

    // 출력후 라인 변경

    public void pl(String inData){

        System.out.println(inData);

    }

    // 출력후 라인을 변경하지 않음

    public void p(String inData){

        System.out.print(inData);

    }

   

}

class DBClose{

public static void close(Connection con){

try {

if(con!=null){

if(!con.isClosed()) con.close();

}

} catch (java.sql.SQLException e) {

e.printStackTrace();

}

}

public static void close(Connection con, PreparedStatement pstmt){

if(con!=null){

try{

if(!con.isClosed()) {con.close();}

}catch(java.sql.SQLException ex){}

}

if(pstmt!=null){

try{

pstmt.close();

}catch(java.sql.SQLException ex){}

}

}

public static void close(Connection con, PreparedStatement pstmt,ResultSet rs){

if(con!=null){

try{

if(!con.isClosed()) {con.close();}

}catch(java.sql.SQLException ex){}

}

if(pstmt!=null){

try{

pstmt.close();

}catch(java.sql.SQLException ex){

}

}

if(rs!=null){

try{

rs.close();

}catch(java.sql.SQLException ex){}

}

}

}

class DBConnect {

private Connection conn=null;

private DBConnect(){}

public static Connection getConnection(){

DBConnect db=new DBConnect();

try {

//오라클

//Class.forName("oracle.jdbc.driver.OracleDriver");

//mysql

Class.forName("com.mysql.jdbc.Driver");

} catch (ClassNotFoundException e) {

}

try {

db.conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/databaseName","id","pass");

//db.conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:oracleInstance", "id", "pass");

} catch (SQLException e) {

e.printStackTrace();

}

return db.conn;

}

}

class InputData{

public static java.io.BufferedReader br=null;

static{

br=new java.io.BufferedReader(

new java.io.InputStreamReader(System.in));

}

private InputData(){

//default

}

public static String readString(String str){

String inputString="";

try {

System.out.print(str);

inputString =br.readLine();

} catch (java.io.IOException e) {

e.printStackTrace();

return null;

}

return inputString;

}

public static int readInt(String str){

int x=-1;

try {

System.out.print(str);

x= Integer.parseInt(br.readLine());

} catch (NumberFormatException e) {

System.err.println("숫자입력에러");

e.printStackTrace();

return x;

} catch(java.io.IOException ex){

ex.printStackTrace();

}

return x;

}

}