db_ssi.java~15~

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

package com.bwm.compose;

import java.sql.*;
import java.util.*;
import com.bwm.core.*;
import com.jspsmart.upload.Request;
/**
 * <p>Title: mingrisoft</p>
 * <p>Description: 明日科技门户网站</p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: MR</p>
 * @author BWM
 * @version 1.0
 */

public class Db_ssi extends Ssort_soft_ico{
    private String dsql="";
    public Db_ssi() {
    }
    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(sql);
            rs = ps.executeQuery();
            while (rs.next()) {
                Db_ssi link = new Db_ssi();
                link.setSfid(rs.getInt("sfid"));
                link.setName(ParamUtils.getSqlString(rs.getString("name")));
                link.setEdition(ParamUtils.getSqlString(rs.getString("edition")));
                link.setPrice(rs.getFloat("price"));
                link.setUptime(ParamUtils.getSqlString(rs.getString("uptime")));
                link.setUid(ParamUtils.getSqlString(rs.getString("uid")));
                link.setIid(ParamUtils.getSqlString(rs.getString("iid")));
                link.setSid(rs.getInt("sid"));
                link.setEnvironment(ParamUtils.getSqlString(rs.getString("environment")));
                link.setFilesize(rs.getInt("filesize"));
                link.setCommend(rs.getInt("commend"));
                link.setLoadnum(rs.getInt("loadnum"));
                link.setRegular(rs.getInt("regular"));
                link.setIntroduce(ParamUtils.getSqlString(rs.getString("introduce")));
                link.setPath(ParamUtils.getSqlString(rs.getString("path")));
                link.setResume(ParamUtils.getSqlString(rs.getString("resume")));
                coll.add(link);
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        } finally {
            System.out.println(ps + " Dbsoft.Select(String sql) "+FinalConstants.SELECT_SOFT + 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_SOFT + 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++) {
                Db_ssi link = new Db_ssi();
                link.setSfid(rs.getInt("sfid"));
                link.setName(ParamUtils.getSqlString(rs.getString("name")));
                link.setEdition(ParamUtils.getSqlString(rs.getString("edition")));
                link.setPrice(rs.getFloat("price"));
                link.setUptime(ParamUtils.getSqlString(rs.getString("uptime")));
                link.setUid(ParamUtils.getSqlString(rs.getString("uid")));
                link.setIid(ParamUtils.getSqlString(rs.getString("iid")));
                link.setSid(rs.getInt("sid"));
                link.setEnvironment(ParamUtils.getSqlString(rs.getString("environment")));
                link.setFilesize(rs.getInt("filesize"));
                link.setCommend(rs.getInt("commend"));
                link.setLoadnum(rs.getInt("loadnum"));
                link.setRegular(rs.getInt("regular"));
                link.setIntroduce(ParamUtils.getSqlString(rs.getString("introduce")));
                link.setPath(ParamUtils.getSqlString(rs.getString("path")));
                link.setResume(ParamUtils.getSqlString(rs.getString("resume")));
                coll.add(link);
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        } finally {
            System.out.println(ps + " Dbsoft.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;
    }
}