database.java

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

package com.bwm.core;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

/**
 * <p>Title: </p>
 * <p>Description: 数据库连接</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: MR</p>
 * @author BWM
 * @version 1.0
 */

public class Database {
    private static Connection con;
    private static String proxool = "org.logicalcobwebs.proxool.ProxoolDriver";
    private static String poolname = "proxool.mingri";
    public Database() {
    }

    public static Connection getConnection() {
        try {
            Class.forName(proxool);
            con = DriverManager.getConnection(poolname);
        } catch (ClassNotFoundException e) {
            System.out.println(e.getMessage());
        } catch (SQLException e) {
            System.out.println(e.getMessage());
        }
        if (con == null) {
            System.out.println("没有获取到数据库连接");
        }
        return con;
    }

    public static int getRow(String sql) {
        int i = 0;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            ps = con.prepareStatement("SELECT COUNT(*) FROM " + sql,
                                      ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_READ_ONLY);
            rs = ps.executeQuery();
            if (rs.next()) {
                i = rs.getInt(1);
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage());
            i = 0;
        } finally {
            System.out.println("SELECT COUNT(*) FROM " + sql);
            try {
                rs.close();
            } catch (SQLException e) {}
            try {
                ps.close();
            } catch (SQLException e) {}
            return i;
        }
    }
    public static boolean Delete(String sql) {
        boolean b = false;
        Connection con = null;
        PreparedStatement ps = null;
        try {
            con = Database.getConnection();
            ps = con.prepareStatement(sql);
            if (ps.executeUpdate() > 0) {
                b = true;
            } else {
                b = false;
            }
        } catch (SQLException e) {
            b = false;
            e.printStackTrace();
        } finally {
            System.out.println(ps + " Database.Delete() "+sql);
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException e) {
                ps = null;
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException e) {
                con = null;
            }
        }
        return b;
    }
}