spring+struct+hibernate的网上购物网站

package com.moon.spring.support; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import org.apache.commons.beanutils.RowSetDynaClass; import org.hibernate.Query; import org.hibernate.SQLQuery; import org.hibernate.Session; import org.hibernate.Transaction; import com.moon.data.Kind; import com.moon.data.Produces; import com.moon.data.Shop; import com.moon.spring.dao.ProducesDao; public class ProducesSupport extends AllSupport implements ProducesDao { public List getPro(int kindid){ List list = new ArrayList(); Session session = this.getSession(); Connection con = null; try{ con = session.connection(); Statement st = con.createStatement(); String sql = "SELECT * FROM produces WHERE kind_id=" + kindid; ResultSet rs = st.executeQuery(sql); RowSetDynaClass rsdc = new RowSetDynaClass(rs); list = rsdc.getRows(); }catch(Exception e){ e.printStackTrace(); }finally{ if(session != null){ session.close(); } } return list; } /* *功 能：添加商品 *参 数：商品实体类，类别编号，商店编号 *返回类型：true(成功)或false(失败) */ public boolean addProduce(Produces prod,int kid,Shop shop) { // TODO Auto-generated method stub boolean result = false; Session session = this.getSession(); Transaction tran = session.beginTransaction(); Connection con = null; try{ Kind kind = new Kind(); kind.setId(kid); // con = session.connection(); // String sql = "select max(id) from produces"; // PreparedStatement pst = con.prepareStatement(sql); // ResultSet rst = pst.executeQuery(); // if(rst.next()){ // int id = rst.getInt(1); // sql = "insert into produces values(?,?,?,?,?,?,?,?)"; // pst = con.prepareStatement(sql); // pst.setInt(1, ++ id); // pst.setInt(2, sid); // pst.setInt(3, kid); // pst.setString(4, prod.getName()); // pst.setDouble(5, prod.getPrice()); // pst.setInt(6, prod.getCount()); // pst.setString(7, prod.getIntroduce()); // pst.setString(8, prod.getImage()); // int rows = pst.executeUpdate(); // result = rows > 0 ? true : false; // } // con = session.connection(); // String sql = "select max(id) from produces"; // String sql = "insert into produces(name,price,count,image,intrduce,shop_id) values(?,?,?,?,?,?)"; // PreparedStatement pst = con.prepareStatement(sql); // ResultSet rst = pst.executeQuery(); // int id = rst.getInt(1); // pst = con.prepareStatement(sql); // pst.setInt(1, ++ id); // pst.setInt(2, sid); // pst.setInt(3, kid); // pst.setString(4, prod.getName()); // pst.setDouble(5, prod.getPrice()); // pst.setInt(6, prod.getCount()); // pst.setString(7, prod.getIntroduce()); // pst.setString(8, prod.getImage()); Produces produces = new Produces(); produces.setKind(kind); produces.setName(prod.getName()); produces.setCount(prod.getCount()); produces.setPrice(prod.getPrice()); produces.setImage(prod.getImage()); produces.setIntroduce(prod.getIntroduce()); produces.setShop(shop); session.save(produces); // pst.setString(1,prod.getName()); // pst.setDouble(2,prod.getPrice()); // pst.setInt(3,prod.getCount()); // pst.setString(4,prod.getImage()); // pst.setString(5,prod.getIntroduce()); // pst.setInt(6, sid); // // pst.executeUpdate(); result = true; // int rows = pst.executeUpdate(); // result = rows > 0 ? true : false; System.out.println("-------------------------------------OK"); tran.commit(); }catch(Exception ex){ tran.rollback(); ex.printStackTrace(); }finally{ if(session != null){ session.close(); } } return result; } /** * 查询某类商品的总个数 * @param kindId 商品的类别 * @return 要查询的商品类别的商品的个数 */ public int queryRowsByKind(int kindId){ int result = -1; Session session = this.getSession(); Connection con = null; try{ con = session.connection(); String sql = "SELECT count(1) FROM produces WHERE kind_id=" + kindId; Statement st = con.createStatement(); ResultSet rs = st.executeQuery(sql); if(rs.next()){ result = rs.getInt(1); } }catch(Exception e){ e.printStackTrace(); }finally{ if(session != null){ session.close(); } } return result; } /** * 搜索与某个名字相匹配的商品的总个数 * @param name 所需搜索商品的名字 * @return 要搜索的商品的总个数 */ public int queryRowsByName(String name){ int result = -1; Session session = this.getSession(); Connection con = null; try{ con = session.connection(); String sql = "SELECT count(1) FROM produces WHERE name like '%" + name + "%'"; //String sql = "select count(1) from produces where kind_id=" + 5; Statement st = con.createStatement(); ResultSet rs = st.executeQuery(sql); if(rs.next()){ result = rs.getInt(1); } }catch(Exception e){ e.printStackTrace(); }finally{ if(session != null){ session.close(); } } return result; } /** * 查询某类商品的总个数 * @param kindId 商品的类别，start要查询的起始行号，end要查询的结束行号 * @return 要查询的商品 */ public List queryAllByKind(int kindId,int start,int end){ List list = new ArrayList(); Session session = this.getSession(); Connection con = null; try{ String sql = "select p.id,p.shop_id,p.name,p.price,p.intrduce,p.image from (select pp.*,rownum r from produces pp where rownum<=? and pp.kind_id=?) p where r>?"; con = session.connection(); PreparedStatement pst = con.prepareStatement(sql); pst.setInt(1, end); pst.setInt(2, kindId); pst.setInt(3, start); ResultSet rs = pst.executeQuery(); RowSetDynaClass rsdc = new RowSetDynaClass(rs); list = rsdc.getRows(); }catch(Exception e){ e.printStackTrace(); }finally{ if(session != null){ session.close(); } } return list; } /** * 搜索与某名字品匹配的商品的总个数 * @param name 所需商品的名字，start要查询的起始行号，end要查询的结束行号 * @return 要查询的商品 */ public List queryAllByName(String name,int start,int end){ List list = new ArrayList(); Session session = this.getSession(); Connection con = null; try{ String sql = "select p.id,p.shop_id,p.name,p.price,p.intrduce,p.image from (select pp.*,rownum r from produces pp where rownum<=" + end + "and pp.name like '%" + name + "%') p where r>" + start; /*String sql = "select p.id,p.shop_id,p.name,p.price,p.intrduce,p.image from (select pp.*,rownum r from produces pp where rownum<=? and pp.name like '%?%') p where r>?"; System.out.println(sql + "......: " + start + "******: " + end); con = session.connection(); PreparedStatement pst = con.prepareStatement(sql); pst.setInt(1, end); pst.setString(2, name); pst.setInt(3, start);*/ con = session.connection(); Statement st = con.createStatement(); ResultSet rs = st.executeQuery(sql); RowSetDynaClass rsdc = new RowSetDynaClass(rs); list = rsdc.getRows(); }catch(Exception e){ e.printStackTrace(); }finally{ if(session != null){ session.close(); } } return list; } /* *功 能：查询一个商店的商品信息 *参 数：商店编号，查询多少条，查询页数 *返回类型：所有商品信息的集合 */ public List queryAllById(int shopId,int rows,int curr) { // TODO Auto-generated method stub List list = new ArrayList(); Session session = this.getSession(); try{ session.beginTransaction(); // Connection con = session.connection(); // String sql = "select p.id,p.name,p.price,p.count,p.intrduce,p.image from (select p_.* ,rownum r from produces P_ where rownum<=? and p_.shop_id=