db_operate_mysql_impl.java

一套网上书店系统采用JAVABEAN+SERVLET+JSP

package ghy_db;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

public class DB_operate_mysql_impl implements DB_operate_interface {

	public ArrayList query(String sql) throws Throwable {
		ArrayList resultSet_list = new ArrayList();
		try {
			Statement stmt = Conn_Manager.getConnection().createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
				String[] row = new String[rs.getMetaData().getColumnCount()];
				for (int i = 0; i < row.length; i++) {
					row[i] = rs.getString(i + 1);
				}
				resultSet_list.add(row);
			}
			rs.close();
			stmt.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			throw e;
		}
		return resultSet_list;
	}

	public void update(String sql, ArrayList values_list) throws Throwable {
		try {
			PreparedStatement ps = Conn_Manager.getConnection()
					.prepareStatement(sql);

			for (int i = 0; i < values_list.size(); i++) {
				ps.setObject(i + 1, values_list.get(i));
			}

			ps.executeUpdate();
			ps.close();

		} catch (SQLException e) {
			e.printStackTrace();
			throw e;
		}
	}

}