[Java] 與 MySQL 溝通

class dbMySQL{

    final private String dbDriver   = "com.mysql.jdbc.Driver";

    public String dbAddress         = null;

    public String dbName            = null;

    public String dbUrl             = null;

    public String dbUser            = null;

    public String dbPasswd          = null;

    dbMySQL(String db_url,String db_name,String db_user,String db_passwd){

        setupDB(db_url,db_name,db_user,db_passwd);

    }

    public void setupDB(String url,String dbname,String dbuser,String dbpasswd){

        dbAddress = url;

        setupDBUser(dbuser,dbpasswd);

        setupDBName(dbname);

    }

    private void setupDBName(String dbname){

        dbName    = dbname;

      //dbUrl     = "jdbc:mysql://"+dbAddress+":3306/"+dbName+"?useUnicode=true&characterEncoding=Big5";

        dbUrl     = "jdbc:mysql://"+dbAddress+":3306/"+dbName+"?useUnicode=true&characterEncoding=utf-8";

    }

    private void setupDBUser(String dbuser,String dbpasswd){

        dbUser = dbuser;dbPasswd = dbpasswd;

    }

    public java.sql.ResultSet SQLquery(String cmd){

        try{

            Class.forName(dbDriver);

            java.sql.Connection con = java.sql.DriverManager.getConnection(dbUrl, dbUser, dbPasswd);

            if(!con.isClosed()){

                java.sql.PreparedStatement pstmt = con.prepareStatement(cmd);

                java.sql.ResultSet rs = pstmt.executeQuery();

                con.close();

                return rs;

            }

        }catch(java.lang.ClassNotFoundException e){

            e.printStackTrace();//Can't find: "+dbDriver+"

        }catch(java.sql.SQLException e){

            e.printStackTrace();

        }

        return null;

    }

    public String SQLupdate(String cmd){

        try{

            Class.forName(dbDriver);

            java.sql.Connection con = java.sql.DriverManager.getConnection(dbUrl, dbUser, dbPasswd);

            if(!con.isClosed()){

                java.sql.PreparedStatement pstmt = con.prepareStatement(cmd);

                pstmt.executeUpdate();

                con.close();

                return "OK";

            }

        }catch(java.lang.ClassNotFoundException e){

            e.printStackTrace();

        }catch(java.sql.SQLException e){

            e.printStackTrace();

        }

        return "NO";

    }

}



/* 使用方式
class Test{
    private dbMySQL DB  = null;
    public Test(String db_url,String db_name,String db_user,String db_passwd){
        DB = new dbMySQL(db_url,db_name,db_user,db_passwd);
        DB.SQLupdate("DELETE From `MySQL_Table_Name`");

        java.sql.ResultSet SQLrs =null;
        SQLrs = DB.SQLquery("SELECT * FROM `MySQL_Table_Name`");
        if(SQLrs != null){
            while(SQLrs.next()){
                //因為是用 UTF-8 存的, 所以讀出來要轉成 Big5
                String data = new String( SQLrs.getString("欄位名字").getBytes(), "Big5");
            }
        }
    }
}
*/