www.pudn.com > shop.rar > GoodsDAO.java

package com.soft136.shop.DAO; 
 
import java.sql.Statement; 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.ArrayList; 
 
import javax.sql.rowset.CachedRowSet; 
 
import oracle.jdbc.rowset.OracleCachedRowSet; 
 
import com.soft136.shop.model.GoodsBean; 
import com.sun.rowset.CachedRowSetImpl; 
 
public class GoodsDAO { 
	public void addGoods(int goods_id, String goods_name, int type_id, 
			double goods_price, double goods_dicount, String goods_desc, 
			String supplier, int qty, int ispreferred, String pic_url) 
			throws SQLException, ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn 
					.prepareStatement("insert into goods (goods_id,goods_name,type_id,goods_price,goods_dicount,goods_desc,supplier,qty,ispreferred,pic_url)values(?,?,?,?,?,?,?,?,?,?)"); 
			ps.setInt(1, goods_id); 
			ps 
					.setString(2, new String(goods_name.getBytes("ISO8859-1"), 
							"GBK")); 
			ps.setInt(3, type_id); 
			ps.setDouble(4, goods_price); 
			ps.setDouble(5, goods_dicount); 
			ps 
					.setString(6, new String(goods_desc.getBytes("ISO8859-1"), 
							"GBK")); 
			ps.setString(7, new String(supplier.getBytes("ISO8859-1"), "GBK")); 
			ps.setInt(8, qty); 
			ps.setInt(9, ispreferred); 
			ps.setString(10, new String(pic_url.getBytes("ISO8859-1"), "GBK")); 
			int i = ps.executeUpdate(); 
			System.out.println(i); 
		} catch (Exception e) { 
			e.printStackTrace(); 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public OracleCachedRowSet getGoods(int goods_id) throws SQLException, 
			ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		ResultSet rs = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn.prepareStatement("select * from goods where goods_id=?"); 
			ps.setInt(1, goods_id); 
			rs = ps.executeQuery(); 
			OracleCachedRowSet crs = new OracleCachedRowSet(); 
			crs.populate(rs); 
			return crs; 
			// if (rs != null) { 
			// ArrayList list = new ArrayList(); 
			// while (rs.next()) { 
			// list.add(new GoodsBean(rs.getInt(1), rs.getString(2), rs 
			// .getInt(3), rs.getDouble(4), rs.getDouble(5), rs 
			// .getString(6), rs.getString(7), rs.getInt(8), rs 
			// .getInt(9), rs.getString(10))); 
			// } 
			// return list; 
			// } else { 
			// return null; 
			// } 
 
		} catch (Exception e) { 
			e.printStackTrace(); 
			System.out.println("error!"); 
			return null; 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public OracleCachedRowSet getAllGoods() throws SQLException, 
			ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		ResultSet rs = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn.prepareStatement("select * from goods"); 
			rs = ps.executeQuery(); 
			OracleCachedRowSet crs = new OracleCachedRowSet(); 
			crs.populate(rs); 
			return crs; 
		} catch (Exception e) { 
			e.printStackTrace(); 
			System.out.println("error!"); 
			return null; 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public void deleteGoods(int goods_id) throws SQLException, 
			ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn.prepareStatement("delete from goods where goods_id=?"); 
			ps.setInt(1, goods_id); 
			int i = ps.executeUpdate(); 
			System.out.println(i); 
		} catch (Exception e) { 
			e.printStackTrace(); 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public void altGoods(int goods_id, String goods_name, int type_id, 
			double goods_price, double goods_dicount, String goods_desc, 
			String supplier, int qty, int ispreferred, String pic_url) 
			throws SQLException, ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn 
					.prepareStatement("update  goods set goods_name=?,type_id=?,goods_price=?,goods_dicount=?,goods_desc=?,supplier=?,qty=?,ispreferred=?,pic_url=?  where goods_id=?"); 
 
			ps 
					.setString(1, new String(goods_name.getBytes("ISO8859-1"), 
							"GBK")); 
			ps.setInt(2, type_id); 
			ps.setDouble(3, goods_price); 
			ps.setDouble(4, goods_dicount); 
			ps 
					.setString(5, new String(goods_desc.getBytes("ISO8859-1"), 
							"GBK")); 
			ps.setString(6, new String(supplier.getBytes("ISO8859-1"), "GBK")); 
			ps.setInt(7, qty); 
			ps.setInt(8, ispreferred); 
			ps.setString(9, new String(pic_url.getBytes("ISO8859-1"), "GBK")); 
			ps.setInt(10, goods_id); 
			int i = ps.executeUpdate(); 
			System.out.println(i); 
		} catch (Exception e) { 
			e.printStackTrace(); 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public OracleCachedRowSet getcloth() throws SQLException, 
			ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		ResultSet rs = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn.prepareStatement("select * from goods where type_id=1"); 
			rs = ps.executeQuery(); 
			OracleCachedRowSet crs = new OracleCachedRowSet(); 
			crs.populate(rs); 
			return crs; 
		} catch (Exception e) { 
			e.printStackTrace(); 
			System.out.println("error!"); 
			return null; 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
 
	public OracleCachedRowSet getshoes() throws SQLException, 
			ClassNotFoundException { 
		Connection conn = null; 
		PreparedStatement ps = null; 
		ResultSet rs = null; 
		try { 
			Class.forName("oracle.jdbc.driver.OracleDriver"); 
			conn = DriverManager.getConnection( 
					"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
					"shop"); 
			ps = conn.prepareStatement("select * from goods where type_id=2"); 
			rs = ps.executeQuery(); 
			OracleCachedRowSet crs = new OracleCachedRowSet(); 
			crs.populate(rs); 
			return crs; 
		} catch (Exception e) { 
			e.printStackTrace(); 
			System.out.println("error!"); 
			return null; 
		} finally { 
			if (ps != null) { 
				ps.close(); 
			} 
			if (conn != null) { 
				conn.close(); 
			} 
		} 
	} 
	public OracleCachedRowSet getcomputer() throws SQLException, 
	ClassNotFoundException { 
Connection conn = null; 
PreparedStatement ps = null; 
ResultSet rs = null; 
try { 
	Class.forName("oracle.jdbc.driver.OracleDriver"); 
	conn = DriverManager.getConnection( 
			"jdbc:oracle:thin:@192.168.1.250:1521:coach", "shop", 
			"shop"); 
	ps = conn.prepareStatement("select * from goods where type_id=3"); 
	rs = ps.executeQuery(); 
	OracleCachedRowSet crs = new OracleCachedRowSet(); 
	crs.populate(rs); 
	return crs; 
} catch (Exception e) { 
	e.printStackTrace(); 
	System.out.println("error!"); 
	return null; 
} finally { 
	if (ps != null) { 
		ps.close(); 
	} 
	if (conn != null) { 
		conn.close(); 
	} 
} 
} 
}