comment.java

一个简单实用的网上书城,可当作原型使用

/*
 * Comment.java
 *
 * Created on 2007年7月20日, 下午4:34
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package czm;
import java.sql.*;
import java.sql.Connection;

/**
 *
 * @author jfang
 */
public class Comment {
    private int commentID;
    private String bookISBN;
    private String memberID;
    private String commentTitle;
    private String comment;
    private String commentDate;
    private String memberIP;
    
    private static String strDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver";  //JDBC驱动
    private static String strDBUrl = "jdbc:odbc:bookstore";   //数据源 ，
    private Connection conn =null;             //连接
    private ResultSet rs = null;
    
    /** Creates a new instance of Comment */
    public Comment() {
        //加载JDBC-ODBC驱动
        try {
                Class.forName(strDBDriver );
                conn = DriverManager.getConnection(strDBUrl);
        }
        //捕获异常
        catch(java.lang.ClassNotFoundException cnfe){
                System.err.println("Comment():" + cnfe.getMessage());
        }catch(java.lang.Exception e){
                System.err.println("Comment():" + e.getMessage());
        }	
    }
    public Comment(String bookISBN,String memberID,String commentTitle,String comment,String commentDate,String memberIP){
        this.bookISBN = bookISBN;
        this.memberID = memberID;
        this.commentTitle = commentTitle;
        this.comment = comment;
        this.commentDate = commentDate;
        this.memberIP = memberIP;
        //加载JDBC-ODBC驱动
        try {
                Class.forName(strDBDriver );
                conn = DriverManager.getConnection(strDBUrl);
        }
        //捕获异常
        catch(java.lang.ClassNotFoundException cnfe){
                System.err.println("Comment():" + cnfe.getMessage());
        }catch(java.lang.Exception e){
                System.err.println("Comment():" + e.getMessage());
        }	
    }
    
    public void setCommentID(int commentID){
        this.commentID = commentID;
    }
    
    public int getCommentID(){
        return commentID;
    }
    
    public void setBookISBN(String bookISBN){
        this.bookISBN = bookISBN;
    }
    public String getBookISBN(){
        return bookISBN;
    }
    
    public void setMemberID(String memberID){
        this.memberID = memberID;
    }
    
    public String getMemberID(){
        return memberID;
    }
    
    public void setCommentTitle(String commentTitle){
        this.commentTitle = commentTitle;
    }
    
    public String getCommentTitle(){
        return commentTitle;
    }
    
    public void setComment(String comment){
        this.comment = comment;
    }
    
    public String getComment(){
        return comment;
    }
    
    public void setCommentDate(String commentDate){
        this.commentDate = commentDate;
    }
    
    public String getCommentDate(){
        return commentDate;
    }
    
    public void setMemberIP(String memberIP){
        this.memberIP = memberIP;
    }
    
    public String getMemberIP(){
        return memberIP;
    }
    
    private void sqlExecuteUpdate(String sql)throws Exception{
            //conn = DriverManager.getConnection(strDBUrl);
                Statement stmt = conn.createStatement();             
                stmt.executeUpdate(sql);
                stmt.close();
               // conn.close();
    }
    
    public boolean AddComment(String bookISBN,String memberID,String commentTitle,String comment,String commentDate,String memberIP){
         try{ 
           String sql = "insert into Comment(memberID,bookISBN,commentTitle,comment,commentDate,memberIP) values('"+memberID+"', '"+bookISBN+"', '"+commentTitle+"','"+comment+"','"+commentDate+"','"+memberIP+"')";
           sqlExecuteUpdate(sql);
        }catch(Exception ex){
            System.err.println(ex);
            return false;           
        }
        return true;
    }
    
    public boolean ModifyComment(int commentID,String newcomment,String commentDate){
         try{   
           String sql = "update  Comment  set comment='"+newcomment+"' and commentDate='"+commentDate+"' where commentID="+commentID;
           sqlExecuteUpdate(sql);
           return true;
        }catch(Exception ex){return false;}
    }
    
    public boolean DeleteComment(int commentID){
         try{   
           String sql = "delete from Comment where commentID="+commentID;
           sqlExecuteUpdate(sql);
           return true;
        }catch(Exception ex){return false;}
    }
    
    private ResultSet sqlExecuteQuery(String sql){
        try{
        //conn = DriverManager.getConnection(strDBUrl);
        //创建可滚动的结果集。
        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
        rs = stmt.executeQuery(sql);
        return rs;
        }catch(Exception ex){
            return null;
        }        
    }
    
   public ResultSet BrowseAllComment(){
        try{   
           String sql = "select * from Comment order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    } 
    
    public ResultSet BrowseComment(String bookISBN){
        try{   
           String sql = "select * from Comment where bookISBN='"+bookISBN+"' order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet SearchComment(int commentID){
        try{
           String sql = "select * from Comment where commentID="+commentID+" order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet SearchComment(String bookISBN){
        try{
           String sql = "select * from Comment where bookISBN='"+bookISBN+"' order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet SearchCommentBymemberID(String memberID){
        try{   
           String sql = "select * from Comment where memberID='"+memberID+"' order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet SearchCommentBycommentDate(String commentDate){
        try{
           String firstDate = "#"+commentDate+" 00:00:00#";
           String nextDate = "#"+commentDate+" 23:59:59#";
           String sql = "select * from Comment where commentDate between "+firstDate+" and "+nextDate+" order by commentDate desc";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet SearchCommentBymemberIP(String memberIP){
        try{
           String sql = "select * from Comment where memberIP='"+memberIP+"'";
           return sqlExecuteQuery(sql);
        }catch(Exception ex){return null;}
    }
    
    public ResultSet selComment(char sel,String str){
        try{
             switch(sel){
                case '1': return BrowseAllComment();
                case '2': return SearchCommentBymemberID(str);
                case '3': return SearchComment(Integer.parseInt(str));
                case '4': return SearchComment(str);
                case '5': return SearchCommentBycommentDate(str);
                case '6': return SearchCommentBymemberIP(str);
                default : return BrowseAllComment();
            }
        }catch(Exception ex){return null;}       
    }
}