optproduct.java

实现了基本的增删改查和分页功能很简单的但是挺不错的适合初学者

package org.demo.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.demo.bean.ProductBean;
import org.demo.dbutil.DBConn;
import org.demo.util.Page;

public class OptProduct extends Page {
	public List showAll(int pageSize, int currentPage) {
		List list = new ArrayList();
		DBConn dbconn = new DBConn();
		String strSQL = "select * from products order by pid";
		ResultSet rs = dbconn.execQuery(strSQL);
		int i = 0;
		try {
			rs.absolute((currentPage - 1) * pageSize + 1);
			while (i < pageSize || rs.isAfterLast()) {
				ProductBean obj = new ProductBean();
				obj.setPid(rs.getInt(1));
				obj.setPname(rs.getString(2));
				obj.setPprice(rs.getString(3));
				obj.setPtype(rs.getString(4));
				obj.setPcount(rs.getString(5));
				obj.setPback(rs.getString(6));
				list.add(obj);
				rs.next();
				i++;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			//e.printStackTrace();
		}

		return list;
	}
   public void addPro(ProductBean obj){
	   DBConn dbconn = new DBConn();
		String pname = obj.getPname();
		float pprice = Float.parseFloat(obj.getPprice());
		String ptype = obj.getPtype();
		int pcount = Integer.parseInt(obj.getPcount());
		String pback = obj.getPback();
		String strSQL = "insert into products values('" + pname + "'," + pprice
				+ ",'" + ptype + "'," + pcount + ",'" + pback + "')";
		dbconn.execOther(strSQL);
   }
   public void delPro(int pid){
	   DBConn dbconn=new DBConn();
	   String strSQL="delete from products where pid="+pid+"";
	   dbconn.execOther(strSQL);
   }
   public ProductBean loadPro(int pid){
	    DBConn dbconn=new DBConn();
	    String strSQL="select * from products where pid="+pid+"";
	    ResultSet rs=dbconn.execQuery(strSQL);
	    try {
			while(rs.next()){
				ProductBean obj=new ProductBean();
				obj.setPid(rs.getInt(1));
				obj.setPname(rs.getString(2));
				obj.setPprice(rs.getString(3));
				obj.setPtype(rs.getString(4));
				obj.setPcount(rs.getString(5));
				obj.setPback(rs.getString(6));
				return obj;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		return null;
   }
   public void updatePro(ProductBean obj){
	   DBConn dbconn=new DBConn();
	    int pid=obj.getPid();
	    String pname = obj.getPname();
		float pprice = Float.parseFloat(obj.getPprice());
		String ptype = obj.getPtype();
		int pcount = Integer.parseInt(obj.getPcount());
		String pback = obj.getPback();
		String strSQL="update products set pname='"+pname+"',pprice="+pprice+",ptype='"+ptype+"',pcount="+pcount+",pback='"+pback+"' where pid="+pid+"";
		dbconn.execOther(strSQL);
   }
}