基于javaSE和MySQL的仓库管理系统

package MySql; 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.Collection; import java.util.Iterator; import java.util.List; import java.util.Vector; import javax.swing.JTable; import javax.swing.table.DefaultTableModel; public class UserDaoImpl implements UserDao { @Override public boolean login(String name, String password) { Connection conn = null; // Statement st = null; ResultSet rs = null; PreparedStatement ps = null; boolean bl = false; try { // 1. 获取连接对象 conn = JDBCUtil.getConn(); // 2. 创建statement对象 String sql = "select name,password from user where name = ? and password = ?"; // 对sql语句进行校验，把?后边的内容全部看成字符串，防止or and等的影响 ps = conn.prepareStatement(sql); // 对应的索引从1开始 ps.setString(1, name); ps.setString(2, password); rs = ps.executeQuery(); if (rs.next()) { bl = true; } } catch (Exception e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps, rs); } return bl; } @Override public boolean insert(String name, String password, String tel) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try { conn = JDBCUtil.getConn(); String sql = "insert into user values(?,?,?)"; ps = conn.prepareStatement(sql); ps.setString(1, name); ps.setString(2, password); ps.setString(3, tel); int result = ps.executeUpdate();// 查询受影响的行数 if (result > 0) { bl = true; } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps); } return bl; } @Override public void xszj(String spmc) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; String sum = null; try { conn = JDBCUtil.getConn(); String sql = "SELECT KHXM FROM xsxx WHERE SPMC = ?"; ps = conn.prepareStatement(sql); ps.setString(1, spmc); rs = ps.executeQuery(); Collection<String> list = new ArrayList<String>(); while (rs.next()) {// 如果有数据，取第一列添加如list String zz = rs.getString("KHXM"); list.add(zz); } for(Iterator<String>iter = list.iterator();iter.hasNext();) { String str = (String)iter.next(); sum += str; } System.out.println(sum); } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps ,rs); } } @Override public int Count(int id) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; int i = 0; try { conn = JDBCUtil.getConn(); String sql = "SELECT COUNT(*) as s FROM kcxx WHERE SPID = ?"; ps = conn.prepareStatement(sql); ps.setInt(1, id); rs = ps.executeQuery(); if (rs.next()) { i = rs.getInt("s"); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps, rs); } return i; } @Override public boolean insertspxx(String spmc, int spid, String spdw, String ghsid) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try { conn = JDBCUtil.getConn(); String sql = "insert into spxx values(?,?,?,?)"; ps = conn.prepareStatement(sql); ps.setString(1, spmc); ps.setInt(2, spid); ps.setString(3, spdw); ps.setString(4, ghsid); int result = ps.executeUpdate();// 查询受影响的行数 if (result > 0) { bl = true; } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps); } return bl; } @Override public boolean insertkcxx(int spid, double kcsl) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try { conn = JDBCUtil.getConn(); String sql = "insert into kcxx values(?,?)"; ps = conn.prepareStatement(sql); ps.setInt(1, spid); ps.setDouble(2, kcsl); int result = ps.executeUpdate();// 查询受影响的行数 if (result > 0) { bl = true; } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps); } return bl; } @Override public boolean insertghsxx(int ghsid, String ghsmc, String ghsdz, String ghslxfs) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try { conn = JDBCUtil.getConn(); String sql = "insert into ghsxx values(?,?,?,?)"; ps = conn.prepareStatement(sql); ps.setInt(1, ghsid); ps.setString(2, ghsmc); ps.setString(3, ghsdz); ps.setString(4, ghslxfs); int result = ps.executeUpdate();// 查询受影响的行数 if (result > 0) { bl = true; } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps); } return bl; } @Override public boolean insertdhxx(int spid, int ghsid, double dhsl, double dhjg) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try{ conn = JDBCUtil.getConn(); String sql = "insert into dhxx values(null,?,?,?,?);"; ps = conn.prepareStatement(sql); ps.setInt(1, spid); ps.setInt(2, ghsid); ps.setDouble(3, dhsl); ps.setDouble(4, dhjg); int result = ps.executeUpdate(); if(result>0){ bl = true; } }catch(SQLException e){ e.printStackTrace(); }finally{ JDBCUtil.release(conn, ps); } return bl; } @Override public double hqkcsl(int spid) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; double i = 0; try { conn = JDBCUtil.getConn(); String sql = "SELECT KCSL FROM kcxx WHERE SPID = ?;"; ps = conn.prepareStatement(sql); ps.setInt(1, spid); rs = ps.executeQuery(); if (rs.next()) { i = rs.getDouble("KCSL"); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps, rs); } return i; } @Override public boolean sumkcsl(int spid, double xzsl) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; boolean bl = false; try{ conn = JDBCUtil.getConn(); String sql = "update kcxx set KCSL = ? where SPID = ?;"; ps = conn.prepareStatement(sql); ps.setDouble(1, xzsl); ps.setInt(2, spid); int result = ps.executeUpdate(); if(result > 0){ bl = true; } }catch(SQLException e){ e.printStackTrace(); }finally{ JDBCUtil.release(conn, ps, rs); } return bl; } @Override public boolean insertxsxx(int spid, double xsjg, double xssl, String khxm, String lxfs, String shdz) { Connection conn = null; PreparedStatement ps = null; boolean bl = false; try{ conn = JDBCUtil.getConn(); String sql = "insert into xsxx values(null,?,?,?,?,?,?);"; ps = conn.prepareStatement(sql); ps.setInt(1, spid); ps.setDouble(2, xsjg); ps.setDouble(3, xssl); ps.setString(4, khxm); ps.setString(5, shdz); ps.setString(6, lxfs); int result = ps.executeUpdate(); if(result>0){ bl = true; } }catch(SQLException e){ e.printStackTrace(); }finally{ JDBCUtil.release(conn, ps); } return bl; } @Override public int selectspid(int spid) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; int i = 0; try { conn = JDBCUtil.getConn(); String sql = "SELECT COUNT(*) as s FROM spxx WHERE SPID = ?"; ps = conn.prepareStatement(sql); ps.setInt(1, spid); rs = ps.executeQuery(); if (rs.next()) { i = rs.getInt("s"); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtil.release(conn, ps, rs); } return i; } @Override public int selectghsid(int ghsid) { Connection conn = null