JSP.rar_jsp_jsp 超市 库存_商品 进销存管理 系统_进销存_进销存jsp

package bean; /* * 本类为增强型数据库操作类，用于返回数据库集合Vector、数据条数、数据页数、修改数据; * 数据修改方法线程同步; * 新添根据商品名关键字返回集合; * 新添升级商品数量方法 upNumData(...);新添根据双关键字返回数据 ; */ import java.sql.*; import java.util.Vector; /** * * @author */ public class Dao_up { public static final int wrong_less = -10; public Connection con=null; public Connection con2=null; public static Statement sta=null; public static PreparedStatement pre=null; public void Connect() { try{ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); String str= "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=pos"; this.con=DriverManager.getConnection(str,"sa","123"); } catch(Exception e){ System.out.print(e.toString()); } } //获取数据库表中记录总条数 @SuppressWarnings("finally") public Integer getCount(String sql) { Statement st = null; ResultSet rs = null; Integer i = null; this.Connect(); try { st = this.con.createStatement(); rs = st.executeQuery(sql); if(rs.next()) i = rs.getInt(1); else i = 0; //return i; } catch(Exception e) { e.printStackTrace(); //return null; } finally { try{ this.con.close(); st.close(); rs.close(); return i; }catch(Exception e){ return -1; } } } //根据数据库sql语句获取记录集合并以Vector返回 @SuppressWarnings("finally") public Vector getData(String sql) { Statement st = null; ResultSet rs = null; this.Connect(); Vector v = new Vector(); try { st = this.con.createStatement(); rs = st.executeQuery(sql); ResultSetMetaData rsmd=rs.getMetaData(); int i = rsmd.getColumnCount(); while(rs.next()) { Vector vx = new Vector(); for(int m=1;m<=i;m++) { vx.add(rs.getObject(m)); } v.add(vx); } //return v; } catch(Exception e) { e.printStackTrace(); //return null; } finally { try { this.con.close(); st.close(); rs.close(); return v; } catch(Exception e) { e.printStackTrace(); return v; } } } //根据表名、列名（主键列）、分页大小、当前分页号获取数据 @SuppressWarnings("finally") public Vector getVector(String table,String columName,Integer pageSize,Integer pageNum) { Statement st = null; ResultSet rs = null; this.Connect(); Vector v = new Vector(); try { st = this.con.createStatement(); rs = st.executeQuery("select top "+pageSize+" * from "+table+" where "+columName+" not in (select top "+((pageNum-1)*pageSize)+" " +columName+" from "+table+" order by "+columName+" ASC) order by "+columName+" ASC"); ResultSetMetaData rsmd=rs.getMetaData(); int i = rsmd.getColumnCount(); while(rs.next()) { Vector vx = new Vector(); for(int m=1;m<=i;m++) { vx.add(rs.getObject(m)); } v.add(vx); } //return v; } catch(Exception e) { e.printStackTrace(); //return null; } finally { try { this.con.close(); st.close(); rs.close(); return v; } catch(Exception e) { e.printStackTrace(); return null; } } } //根据表中条数和分页大小计算分页数量 public Integer getPageCount(String sql,Integer pageSize) { Dao_up du = new Dao_up(); Integer recordCount = null; Integer pageCount = null; recordCount = du.getCount(sql); int i = recordCount%pageSize; if(i == 0) { pageCount = recordCount/pageSize; } else { pageCount = recordCount/pageSize+1; } return pageCount; } //根据表名、列名（主键列）、字符数组来删除数据这里的主键是int型，字符数组就是选择框选择的字符串 @SuppressWarnings("finally") public int delete_Integer(String table,String columName,String[] str) { int n = 0; Statement st = null; this.Connect(); String sql = "delete from "+table+" where "+columName+" ="; try { for(int ii=0;ii<str.length;ii++) { if(ii != 0) sql = sql+" or "+columName+" ="+str[ii]; else sql = sql+str[ii]; } st = this.con.createStatement(); n = st.executeUpdate(sql); //return n; } catch(Exception e) { e.printStackTrace(); //return 0; } finally { try{ this.con.close(); st.close(); //rs.close(); return n; }catch(Exception e){ return -1; } //return n; } } //更新货物数量（一般用于登记销售明细） @SuppressWarnings("finally") synchronized public int upGoodsNum(String goodsid,Integer num) { Statement st = null; int i = 0; Dao_up du = new Dao_up(); du.Connect(); try { st = du.con.createStatement(); ResultSet rs = st.executeQuery("select storenum from goodsinfo where goodsid="+goodsid); if(rs.next());else return wrong_less; Integer formernum = rs.getInt(1); Integer nownum = formernum+num; if(nownum<0) { du.con.close(); st.close(); i = wrong_less; } else i = du.upData("update goodsinfo set storenum="+nownum+" where goodsid="+goodsid); //return i; } catch(Exception e) { e.printStackTrace(); //return 0; } finally { try{ du.con.close(); st.close(); return i; }catch(Exception e){ e.printStackTrace(); return -1; } } } //更新库存数量和最后价格（一般用于入库登记） @SuppressWarnings("finally") synchronized public int upNumData(String goodsid,Integer num,String price) { Statement st = null; int i = 0; Dao_up du = new Dao_up(); du.Connect(); try { st = du.con.createStatement(); ResultSet rs = st.executeQuery("select storenum from goodsinfo where goodsid="+goodsid); if(rs.next());else {i = wrong_less; return i;} Integer formernum = rs.getInt(1); Integer nownum = formernum+num; if(nownum<0) { du.con.close(); st.close(); i = wrong_less; } else i = du.upData("update goodsinfo set storenum="+nownum+" ,lastinprice="+price+" where goodsid="+goodsid); //return i; } catch(Exception e) { e.printStackTrace(); //return 0; } finally { try{ du.con.close(); st.close(); return i; }catch(Exception e){ return -1; } } } //升级销售单号价格方法 @SuppressWarnings("finally") synchronized public int upSalesPrice(String Salesid,Double addprice) { Statement st = null; int i = 0; Dao_up du = new Dao_up(); du.Connect(); try { st = du.con.createStatement(); ResultSet rs = st.executeQuery("select SalesMoney from SalesInfo where SalesID="+Salesid); if(rs.next()); else return wrong_less; Double formerPrice = rs.getDouble(1); Double nowPrice = formerPrice + addprice; i = du.upData("update SalesInfo set SalesMoney="+nowPrice+" where SalesID="+Salesid); //return i; } catch(Exception e) { e.printStackTrace();