dbfactory.java

管理药品的进出销量以及对销售状况的统计 Java+SQL医药进销存管理系统,可实现简单的操作

package org.xsp.DbFactory;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.sql.SQLException;
import java.sql.DriverManager;
import java.util.Hashtable;

public class DbFactory {
    private static Connection con = null;
    private static PreparedStatement prst = null;
    private static ResultSet rs = null;
    private static Connection getcon() {
        try {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            try {
                con = DriverManager.getConnection("jdbc:odbc:test");
            } catch (SQLException ex1) {
            }
        } catch (ClassNotFoundException ex) {
        }

        return con;
    }

    private static void setprst(ArrayList list) {
        try {
            if (list != null) {
                if (list.size() > 0) {
                    Hashtable ht = null;
                    for (int i = 0; i < list.size(); i++) {
                        ht = (Hashtable) list.get(i);
                        prst.setObject(i + 1, ht.get("s"));
                    }
                }
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage() + "11111111");
        }

    }

    public static ArrayList executeQuery(String sql, ArrayList list) {
        ArrayList resultlist = null;
        try {
            prst = getcon().prepareStatement(sql);
            if (list != null) {
                setprst(list);
            }
            rs = prst.executeQuery();
            if (rs != null) {
                resultlist = new ArrayList();
                int num = rs.getMetaData().getColumnCount();
                while (rs.next()) {
                    ArrayList rowList = new ArrayList();
                    for (int i = 1; i <= num; i++) {
                        rowList.add(rs.getObject(i));
                    }
                    resultlist.add(rowList);
                }
                System.out.println(resultlist);
            }
        } catch (SQLException ex) {
        } finally {
            clearAll();
        }

        return resultlist;
    }

    public static int executeUpdate(String sql, ArrayList list) {
        int count = 0;
        try {
            prst = getcon().prepareStatement(sql);
            if (list != null) {
                setprst(list);
            }
            count = prst.executeUpdate();
        } catch (SQLException ex) {
        } finally {
            clearAll();
        }
        return count;
    }

    private static void clearAll() {
        try {
            if (rs != null) {
                rs.close();
                rs = null;
            }
            if (prst != null) {
                prst.close();
                prst = null;
            }
            if (con != null) {
                con.close();
                con = null;
            }
        } catch (SQLException ex) {
        }
    }
}