package com.shop.util;import java.sql.*;//SqlHelper类 //定义了数据库连接函数，关闭查询结果集，关闭Statement对象，关闭数据库连接//这样的做法是执行上述4个操作时可以直接调用函数（面向对象的思想），可以好好理解一下public class SqlHelper {    public static Connection getConnection() {        Connection conn = null;        String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";// 驱动        String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=Shopping";// SqlServer链接地址        String username = "sa";// 用户名        String password = "sa";// 密码        try {            Class.forName(driver);// 加载驱动类            conn = DriverManager.getConnection(url, username, password);        } catch (ClassNotFoundException e) {            System.out.println("找不到驱动程序类 ，加载驱动失败！");            e.printStackTrace();        } catch (SQLException e) {            System.out.println("数据库连接失败！");            e.printStackTrace();        }        // System.out.println("连接成功");        return conn;    }    //关闭连接    public static void closeConn(Connection conn){        if(conn!=null){            try {                conn.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }    }    //关闭执行对象    public static void closeStatement(Statement stmt){        if(stmt!=null){            try {                stmt.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }    }    //关闭结果集    public static void closeResultSet(ResultSet rs){        if(rs!=null){            try {                rs.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }    }}SqlHelper

package com.shop.dao;import java.sql.*;import java.util.ArrayList;import java.util.List;import com.shop.po.Goods;import com.shop.util.SqlHelper;/** * GoodsDao接口实现类 *  * @author HP-Developer *  */public class GoodsDaoImpl implements GoodsDao {    public int insertGoods(Goods goods) {        Connection conn = null;        //PreparedStatement和Statement的区别在于        //PreparedStatement接口继承Statement，         //PreparedStatement 实例包含已编译的 SQL 语句，所以其执行速度要快于 Statement 对象。        //作为 Statement 的子类，PreparedStatement 继承了 Statement 的所有功能。        //三种方法 execute、 executeQuery 和 executeUpdate 已被更改以使之不再需要参数        //PreparedStatement性能更优，建议使用，但是比较复杂一点                //Statement 是 Java 执行数据库操作的一个重要方法，用于在已经建立数据库连接的基础上，向数据库发送要执行的SQL语句        //使用 Statement 对象执行语句        Statement stmt = null;        int result = 0;        String name=goods.getName();        String kind=goods.getKind();        double price=goods.getPrice();        int stock=goods.getStock();        String des=goods.getDescription();        String sql = "insert into Goods values(‘"+name+"‘,‘"+kind+"‘,‘"+price+"‘,‘"+stock+"‘,‘"+des+"‘)";        // 访问数据库        try {            // 1获得连接            conn = SqlHelper.getConnection();            // 2执行对象            stmt = conn.createStatement();            // 3执行            result = stmt.executeUpdate(sql);        } catch (Exception e) {            //捕捉错误            e.printStackTrace();        } finally {            //关闭操作对象            SqlHelper.closeStatement(stmt);            //关闭连接            SqlHelper.closeConn(conn);        }        //返回受影响的行数        return result;        //try catch finally是一种语句结构        //就我个人的理解，在try中执行操作，catch捕捉错误，finally进行收尾    }    //删除和更新与插入类似 ，我就不加注释了    public int deleteGoods(int id) {        Connection conn = null;        Statement stmt = null;        int result = 0;        String sql = "delete from Goods where gID=‘"+id+"‘";        try {            conn = SqlHelper.getConnection();            stmt = conn.createStatement();            result = stmt.executeUpdate(sql);        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();        } finally {            SqlHelper.closeStatement(stmt);            SqlHelper.closeConn(conn);        }        return result;    }    public int updateGoods(int id, Goods goods) {        // TODO Auto-generated method stub        Connection conn = null;        Statement stmt = null;        int result = 0;        String name=goods.getName();        String kind=goods.getKind();        double price=goods.getPrice();        int stock=goods.getStock();        String des=goods.getDescription();        String sql = "update Goods set gName=‘"+name+"‘,gKind=‘"+kind+"‘,gPrice=‘"+price+"‘,gNum=‘"+stock+"‘,gDes=‘"+des+"‘ where gID=‘"+id+"‘";        try {            conn = SqlHelper.getConnection();            stmt = conn.createStatement();            result = stmt.executeUpdate(sql);        } catch (SQLException e) {            e.printStackTrace();        } finally {            SqlHelper.closeStatement(stmt);            SqlHelper.closeConn(conn);        }        return result;    }    //查询全部商品    //因为是多个对象，采用返回List的方式，返回Goods对象的集合    public List<Goods> findAll() {        Connection conn=null;        Statement stmt=null;        //创建对象集合        List gdList = new ArrayList();        ResultSet rs=null;        String sql="select * from Goods";        try{            conn=SqlHelper.getConnection();            stmt=conn.createStatement();            rs=stmt.executeQuery(sql);            while(rs.next()){                //创建单个对象                Goods gd = new Goods();                gd.setId(rs.getInt("gID"));                gd.setName(rs.getString("gName"));                gd.setKind(rs.getString("gKind"));                gd.setPrice(rs.getDouble("gPrice"));                gd.setStock(rs.getInt("gNum"));                gd.setDescription(rs.getString("gDes"));                //将此对象存入集合中，昨天闫老师带我们学习了ArrayList，add方法大家应该不陌生                gdList.add(gd);            }        }        catch(SQLException e){            e.printStackTrace();        }        finally{            SqlHelper.closeResultSet(rs);//关闭结果集            SqlHelper.closeStatement(stmt);//关闭Statement对象            SqlHelper.closeConn(conn);//关闭连接            //注意关闭的顺序不能        }        return gdList;    }    public Goods findById(int id) {        Connection conn=null;        Statement stmt=null;        //在判断商品存在后再new对象，这样规范        Goods gd = null;        ResultSet rs=null;//定义数据集ResultSet 接受stmt.executeQuery(sql)的返回值        String sql="select * from Goods where gID=‘"+id+"‘";        try{            conn=SqlHelper.getConnection();            stmt=conn.createStatement();            //gd=(Goods)stmt.executeQuery(sql);stmt.executeQuery(sql)的返回值是一个结果集ResultSet            //因为返回的记录是一条，之前想用强制转换的方法实现返回一个商品(Goods)对象，但是不可行，这条代码错误，下面给出正确的操作            rs=stmt.executeQuery(sql);            if(rs.next()){                gd=new Goods();                gd.setId(rs.getInt("gID"));                gd.setName(rs.getString("gName"));                gd.setKind(rs.getString("gKind"));                gd.setPrice(rs.getDouble("gPrice"));                gd.setStock(rs.getInt("gNum"));                gd.setDescription(rs.getString("gDes"));            }            else{                //这样返回一个空商品对象，节省了即使对象为空还赋值的多余操作                return gd;            }        }        catch(SQLException e){            e.printStackTrace();        }        finally{            SqlHelper.closeResultSet(rs);//关闭结果集            SqlHelper.closeStatement(stmt);//关闭            SqlHelper.closeConn(conn);//关闭数据库连接        }        return gd;    }}GoodsDaoImpl