comment.java

来自「一个用java编写的功能强大的OA系统」· Java 代码 · 共 147 行

package cn.js.fan.module.cms;

import org.apache.log4j.Logger;
import cn.js.fan.db.Conn;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import cn.js.fan.web.Global;

public class Comment implements java.io.Serializable {
    String content,ip,nick,link;
    int id, doc_id;
    String add_date;

    String connname = "";
    transient Logger logger = Logger.getLogger(Comment.class.getName());

    private static final String INSERT =
            "INSERT into cms_comment (nick, link, content, ip, doc_id, add_date) VALUES (?,?,?,?,?,NOW())";
    private static final String LOAD =
            "SELECT id,nick,content,link,ip,add_date,doc_id from cms_comment WHERE id=?";
    private static final String DEL =
            "delete FROM cms_comment WHERE id=?";

    public Comment() {
        connname = Global.defaultDB;
        if (connname.equals(""))
            logger.info("Directory:默认数据库名为空！");
    }

    public Comment(int id) {
        this.id = id;
        connname = Global.defaultDB;
        if (connname.equals(""))
            logger.info("Directory:默认数据库名为空！");
        load(id);
    }

    public void renew() {
        logger = Logger.getLogger(Comment.class.getName());
    }

    public boolean insert(int doc_id, String nick, String link, String content, String ip) {
        Conn conn = new Conn(connname);
        boolean re = false;
        try {
            PreparedStatement pstmt = conn.prepareStatement(INSERT);
            pstmt.setString(1, nick);
            pstmt.setString(2, link);
            pstmt.setString(3, content);
            pstmt.setString(4, ip);
            pstmt.setInt(5, doc_id);
            re = conn.executePreUpdate()==1?true:false;
        }
        catch (SQLException e) {
            logger.error(e.getMessage());
        }
        finally {
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
        return re;
    }

    public String getContent() {
        return content;
    }

    public String getIp() {
        return ip;
    }

    public String getAddDate() {
        return add_date;
    }

    public int getId() {
        return id;
    }

    public String getNick() {
        return nick;
    }

    public String getLink() {
        return link;
    }

    public int getDocId() {
        return doc_id;
    }

    public void load(int id) {
        Conn conn = new Conn(connname);
        ResultSet rs = null;
        try {
            PreparedStatement pstmt = conn.prepareStatement(LOAD);
            pstmt.setInt(1, id);
            rs = conn.executePreQuery();
            if (rs!=null) {
                if (rs.next()) {
                    id = rs.getInt(1);
                    nick = rs.getString(2);
                    content = rs.getString(3);
                    link = rs.getString(4);
                    ip = rs.getString(5);
                    add_date = rs.getString(6).substring(0,16);
                    doc_id = rs.getInt(7);
                }
            }
        }
        catch (SQLException e) {
            logger.error(e.getMessage());
        }
        finally {
            if (rs!=null) {
                try { rs.close(); } catch (Exception e) {}
                rs = null;
            }
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
    }

    public boolean del(int id) {
        Conn conn = new Conn(connname);
        boolean re = true;
        try {
            PreparedStatement pstmt = conn.prepareStatement(DEL);
            pstmt.setInt(1, id);
            re = conn.executePreUpdate()==1?true:false;
        }
        catch (SQLException e) {
            re = false;
            logger.error(e.getMessage());
        }
        finally {
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
        return re;
    }
}