dbforum.java

一个完整的门户网站,基于JSP环境下开发的,使用SQL数据库.

package com.bwm.database;

import java.sql.*;
import java.util.*;
import com.jspsmart.upload.Request;
import com.bwm.model.Forum;
import com.bwm.core.*;

/**
 * <p>Title: mingrisoft</p>
 * <p>Description: 明日科技门户网站</p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: MR</p>
 * @author BWM
 * @version 1.0
 */

public class Dbforum extends Forum {
    public Dbforum() {
    }
    public Dbforum(String sql) {
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(FinalConstants.SELECT_FROUM + sql,
                                      ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_READ_ONLY);
            rs = ps.executeQuery();
            if (rs.next()) {
                f.setFid(rs.getInt("fid"));
                f.setFsid(rs.getInt("fsid"));
                f.setState(rs.getInt("state"));
                f.setTitle(ParamUtils.getSqlString(rs.getString("title")));
                f.setUid(ParamUtils.getSqlString(rs.getString("uid")));
                f.setIid(ParamUtils.getSqlString(rs.getString("iid")));
                f.setFtime(ParamUtils.getSqlString(rs.getString("ftime")));
                f.setContent(ParamUtils.getSqlString(rs.getString("content")));
                f.setRenum(rs.getInt("renum"));
                f.setHitnum(rs.getInt("hitnum"));
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage());
            e.printStackTrace();
        } finally {
            System.out.println(ps + " Dbfroum(String sql) " + f.getFid());
            try {
                if (ps != null) {
                    ps.close();
                    ps = null;
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                    con = null;
                }
            } catch (SQLException e) {
                con = null;
            }
        }
    }

    public Dbforum(Request request,String iid) {
        f.setFsid(ParamUtils.getIntParameter(request, "fsid"));
        f.setState(ParamUtils.getIntParameter(request, "state"));
        f.setTitle(ParamUtils.getRequestString(request, "title"));
        f.setUid(ParamUtils.getRequestString(request, "uid"));
        f.setIid(ParamUtils.getSqlString(iid));
        f.setContent(ParamUtils.getRequestString(request, "content"));
        f.setRenum(ParamUtils.getIntParameter(request, "renum"));
        f.setHitnum(ParamUtils.getIntParameter(request, "hitnum"));
    }

    public boolean Insert() {
        boolean b = false;
        Connection con = null;
        PreparedStatement ps = null;
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(FinalConstants.INSERT_FROUM);
            ps.setInt(1, f.getFsid());
            ps.setInt(2, f.getState());
            ps.setString(3,f.getTitle());
            ps.setString(4,f.getUid());
            ps.setString(5,f.getIid());
            ps.setString(6,f.getContent());
            ps.setInt(7,f.getRenum());
            ps.setInt(8,f.getHitnum());
            if (ps.executeUpdate() > 0) {
                b = true;
            } else {
                b = false;
            }
        } catch (SQLException e) {
            b = false;
            System.out.println(e.getMessage());
            e.printStackTrace();
        } finally {
            System.out.println(ps + " Dbforum.Insert()");
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException e) {
                con = null;
            }
        }
        return b;
    }

    public Collection Select(String sql) {
        Collection coll = new ArrayList();
        Connection con = null;
        ResultSet rs = null;
        PreparedStatement ps = null;
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(FinalConstants.SELECT_FROUM + sql);
            rs = ps.executeQuery();
            while (rs.next()) {
                Forum link = new Forum();
                link.setFid(rs.getInt("fid"));
                link.setFsid(rs.getInt("fsid"));
                link.setState(rs.getInt("state"));
                link.setTitle(ParamUtils.getSqlString(rs.getString("title")));
                link.setUid(ParamUtils.getSqlString(rs.getString("uid")));
                link.setIid(ParamUtils.getSqlString(rs.getString("iid")));
                link.setFtime(ParamUtils.getSqlString(rs.getString("ftime")));
                link.setContent(ParamUtils.getSqlString(rs.getString("content")));
                link.setRenum(rs.getInt("renum"));
                link.setHitnum(rs.getInt("hitnum"));
                coll.add(link);
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        } finally {
            System.out.println(ps + " Dbforum.Select(String sql) "+FinalConstants.SELECT_FROUM + sql);
            try {
                if (ps != null) {
                    ps.close();
                    ps = null;
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                    con = null;
                }
            } catch (SQLException e) {
                con = null;
            }
        }
        return coll;
    }

    //页数+SQL条件
    public Collection Select(int page, String sql) {
        Collection coll = new ArrayList();
        Connection con = null;
        ResultSet rs = null;
        PreparedStatement ps = null;
        int tip = FinalConstants.STEP * (page - 1);
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(FinalConstants.SELECT_FROUM + sql);
            rs = ps.executeQuery();
            if (tip <= 0) {
                rs.beforeFirst();
            } else {
                if (!rs.absolute(tip)) {
                    rs.beforeFirst();
                }
            }
            for (int i = 1; rs.next() && i <= FinalConstants.STEP; i++) {
                Forum link = new Forum();
                link.setFid(rs.getInt("fid"));
                link.setFsid(rs.getInt("fsid"));
                link.setState(rs.getInt("state"));
                link.setTitle(ParamUtils.getSqlString(rs.getString("title")));
                link.setUid(ParamUtils.getSqlString(rs.getString("uid")));
                link.setIid(ParamUtils.getSqlString(rs.getString("iid")));
                link.setFtime(ParamUtils.getSqlString(rs.getString("ftime")));
                link.setContent(ParamUtils.getSqlString(rs.getString("content")));
                link.setRenum(rs.getInt("renum"));
                link.setHitnum(rs.getInt("hitnum"));
                coll.add(link);
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        } finally {
            System.out.println(ps + " Dbforum.Select(int page,String sql) ");
            try {
                if (ps != null) {
                    ps.close();
                    ps = null;
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                    con = null;
                }
            } catch (SQLException e) {
                con = null;
            }
        }
        return coll;
    }

    private boolean Update() {
        boolean b = false;
        Connection con = null;
        PreparedStatement ps = null;
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(FinalConstants.UPDATE_FROUM);
            ps.setInt(1, f.getFsid());
            ps.setInt(2, f.getState());
            ps.setString(3,f.getTitle());
            ps.setString(4,f.getContent());
            ps.setInt(5,f.getRenum());
            ps.setInt(6,f.getHitnum());
            ps.setInt(7,f.getFid());
            if (ps.executeUpdate() > 0) {
                b = true;
            } else {
                b = false;
            }
        } catch (SQLException e) {
            b = false;
            e.printStackTrace();
        } finally {
            System.out.println(ps + " Dbfroum.Update() ");
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException e) {
                con = null;
            }
        }
        return b;
    }
    private Forum f=new Forum();
    public int getFid() {
        return f.getFid();
    }
    public void setFid(int fid) {
        f.setFid(fid);
    }
    public int getFsid() {
        return f.getFsid();
    }
    public void setFsid(int fsid) {
        f.setFsid(fsid);
        this.Update();
    }
    public String getTitle() {
        return f.getTitle();
    }
    public void setTitle(String title) {
        f.setTitle(title);
        this.Update();
    }
    public String getUid() {
        return f.getUid();
    }
    public void setUid(String uid) {
        f.setUid(uid);
    }
    public String getFtime() {
        return f.getFtime();
    }
    public void setFtime(String ftime) {
        f.setFtime(ftime);
    }
    public String getContent() {
        return f.getContent();
    }
    public void setContent(String content) {
        f.setContent(content);
        this.Update();
    }
    public int getRenum() {
        return f.getRenum();
    }
    public void setRenum(int renum) {
        f.setRenum(renum);
        this.Update();
    }
    public int getHitnum() {
        return f.getHitnum();
    }
    public void setHitnum(int hitnum) {
        f.setHitnum(hitnum);
        this.Update();
    }
    public int getState() {
        return f.getState();
    }
    public void setState(int state) {
        f.setState(state);
        this.Update();
    }
    public String getIid() {
        return f.getIid();
    }
    public void setIid(String iid) {
        f.setIid(iid);
    }
}