java jdbc sqlhelper

package com.shop.util;

import java.sql.*;

//SqlHelper类 
//定义了数据库连接函数，关闭查询结果集，关闭Statement对象，关闭数据库连接
//这样的做法是执行上述4个操作时可以直接调用函数（面向对象的思想），可以好好理解一下
public class SqlHelper {
    public static Connection getConnection() {
        Connection conn = null;

　　　　　　String driver = "com.mysql.jdbc.Driver";// 驱动
　　　　　　String url = "jdbc:mysql://127.0.0.1:3306/banksystem";// 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

商品dao方法的实现。

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

代码转载于：http://www.cnblogs.com/wangkaipeng/p/4725548.html。

不做讲解，仅用于使用。