JDBC的使用以及预处理的重要性

作者: 葡小萄家的猫 | 来源:发表于2017-07-25 21:52 被阅读0次

JDBC的使用以及预处理的重要性
6.JDBC学习笔记
基本
6-基于Spring的框架-JDBC——6-2 基本实现思路
Java自学-JDBC 预编译PreparedStatement
JDBC面试问题与解答
Java web之JDBC
揭秘MyBatis为什么在阿里等大厂这么流行
springboot中 log4jdbc+logback的使用
JDBC的简单使用

JDBC 入门

1.创建JDBC与数据库的链接
    0）导入
        import java.sql.Connection;
        import java.sql.DriverManager;
        import java.sql.ResultSet;
        import java.sql.SQLException;
        import java.sql.Statement;

    public class JDBCDemo1 {

        @Test
        // JDBC入门程序
        public void demo1(){
            /**
             * 1.注册驱动
             * 2.获得连接
             * 3.执行sql
             * 4.释放资源
             */
            Connection conn = null;
            Statement stmt = null;
            ResultSet rs = null;
            try{
                // 1.注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                // DriverManager.registerDriver(new Driver());
                // 2.获得连接
                conn = DriverManager.getConnection("jdbc:mysql:///day03", "root", "123");
                // 3.执行SQL语句
                // 3.1创建执行sql语句的对象:
                stmt = conn.createStatement();
                // 3.2执行sql语句
                rs = stmt.executeQuery("select * from user");
                // 3.3遍历结果集
                while(rs.next()){
                    System.out.println(rs.getInt("id")+"   "+rs.getString("username")+"   "+rs.getString("password")+"   "+rs.getString("nickname")+"   "+rs.getDouble("salary"));
                }
            }catch(Exception e){
                e.printStackTrace();
            }finally{
                // 4.释放资源
                if(rs != null){
                    try {
                        rs.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                    rs = null;
                }
                if(stmt != null){
                    try {
                        stmt.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                    stmt = null;
                }
                if(conn != null){
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                    conn = null;
                }
            }
        }
}

02 使用Statement连接并作增删改查操作

/**
 * 完成JDBC的CRUD的操作
 * @author jt
 *
 */
public class JDBCDemo2 {
    @Test
    // 查询一条记录
    public void demo4(){
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try{
            // 注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 获得连接
            conn = DriverManager.getConnection("jdbc:mysql:///day03", "root", "123");
            // 创建执行SQL对象
            stmt = conn.createStatement();
            String sql = "select * from user where id = 2";
            rs = stmt.executeQuery(sql);
            // 不用遍历结果集
            if(rs.next()){
                System.out.println(rs.getInt("id")+"   "+rs.getString("username")+"   "+rs.getString("password")+"   "+rs.getString("nickname")+"  "+rs.getDouble("salary"));
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            // 4.释放资源
            if(rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                rs = null;
            }
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                conn = null;
            }   
        }
    }
    
    @Test
    // 删除操作
    public void demo3(){
        Connection conn = null;
        Statement stmt = null;
        try{
            // 1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2.获得连接
            conn = DriverManager.getConnection("jdbc:mysql:///day03", "root", "123");
            // 3.创建执行SQL对象:
            stmt = conn.createStatement();
            String sql = "delete from user where id = 3";
            int num = stmt.executeUpdate(sql);
            if(num > 0){
                System.out.println("删除成功!");
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            // 4.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                conn = null;
            }
        }
    }
    
    @Test
    // 修改操作
    public void demo2(){
        Connection conn = null;
        Statement stmt = null;
        try{
            // 1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2.获得连接
            conn = DriverManager.getConnection("jdbc:mysql:///day03", "root", "123");
            // 3.执行SQL
            stmt = conn.createStatement();
            String sql = "update user set username='qwe',password='zxc',nickname='王yy',salary=4800 where id = 6";
            int num = stmt.executeUpdate(sql);
            if(num > 0){
                System.out.println("修改成功！");
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            // 4.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                conn = null;
            }
        }
    }

    @Test
    // 保存操作
    public void demo1(){
        Connection conn = null;
        Statement stmt = null;
        try{
            // 1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2.获得连接
            conn = DriverManager.getConnection("jdbc:mysql:///day03", "root", "123");
            // 3.创建执行SQL对象，执行SQL
            stmt = conn.createStatement();
            String sql = "insert into user values (null,'fff','abc','刘xx',3800)";
            int num = stmt.executeUpdate(sql);
            if(num > 0){
                System.out.println("保存成功!");
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            // 4.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                stmt = null;
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                conn = null;
            }
        }
    }
}

03预处理SQL语句（常用以上了解）PreparedStatement 关键类

/**

解决了SQL注入漏洞的登录

@author jt

*/
public class UserDao2 {

     public boolean login(String username,String password){
       boolean flag = false;
 
       Connection conn = null;
       PreparedStatement pstmt = null;
       ResultSet rs = null;
       try{
         // 获得连接:
           conn = JDBCUtils.getConnection();
         // 编写SQL:
           String sql = "select * from user where username = ? and password = ?";
         // 预处理sql:
           pstmt = conn.prepareStatement(sql);
         // 设置参数
           pstmt.setString(1, username);
           pstmt.setString(2, password);
         // 执行sql:
           rs = pstmt.executeQuery();
           if(rs.next()){
              flag = true;
             }
     }catch(Exception e){
             e.printStackTrace();
         }finally{
             JDBCUtils.release(rs, pstmt, conn);
          }
       
         return flag;
       }
}

04PreparedStatement的CRUD的操作（关键）

    /**
     * PreparedStatement的CRUD的操作
     * @author jt
     *
     */
    public class JDBCDemo1 {
          @Test
          // 查询一条
          public void demo4(){
                Connection conn = null;
                PreparedStatement pstmt = null;
                ResultSet rs = null;
                User user  = new User();
      try{
        // 获得连接:
        conn = JDBCUtils.getConnection();
        // 编写sql:
        String sql = "select * from user where id = ?";
        // 预编译sql
        pstmt = conn.prepareStatement(sql);
        // 设置参数
        pstmt.setInt(1, 2);
        // 执行sql:
        rs = pstmt.executeQuery();
        if(rs.next()){
            user.setId(rs.getInt("id"));
            user.setUsername(rs.getString("username"));
            user.setPassword(rs.getString("password"));
            user.setNickname(rs.getString("nickname"));
            user.setSalary(rs.getDouble("salary"));;
        }
    }catch(Exception e){
        e.printStackTrace();
    }finally{
        JDBCUtils.release(rs, pstmt, conn);
    }
    
    System.out.println(user);
}

@Test
// 删除操作
public void demo3(){
    Connection conn = null;
    PreparedStatement pstmt = null;
    try{
        // 获得连接:
        conn = JDBCUtils.getConnection();
        // 编写SQL:
        String sql = "delete from user where id=?";
        // 预编译SQL:
        pstmt = conn.prepareStatement(sql);
        // 设置参数:
        pstmt.setInt(1, 7);
        // 执行SQL:
        int num = pstmt.executeUpdate();
        if(num > 0){
            System.out.println("删除成功!");
        }
    }catch(Exception e){
        e.printStackTrace();
    }finally{
        JDBCUtils.release( pstmt, conn);
    }
}

@Test
// 修改操作
public void demo2(){
    Connection conn = null;
    PreparedStatement pstmt = null;
    try{
        // 获得连接:
        conn = JDBCUtils.getConnection();
        // 编写SQL:
        String sql = "update user set username =?,password=?,nickname=?,salary=? where id=?";
        // 预编译SQL:
        pstmt = conn.prepareStatement(sql);
        // 设置参数:
        pstmt.setString(1, "abc");
        pstmt.setString(2, "yui");
        pstmt.setString(3, "王老八");
        pstmt.setDouble(4, 6600);
        pstmt.setInt(5, 7);
        // 执行SQL:
        int num = pstmt.executeUpdate();
        if(num > 0){
            System.out.println("修改成功!");
        }
    }catch(Exception e){
        e.printStackTrace();
    }finally{
        JDBCUtils.release( pstmt, conn);
    }
}

@Test
// 保存操作
public void demo1(){
    Connection conn = null;
    PreparedStatement pstmt = null;
    try{
        // 获得连接:
        conn = JDBCUtils.getConnection();
        // 编写SQL:
        String sql = "insert into user values (null,?,?,?,?)";
        // 预编译SQL:
        pstmt = conn.prepareStatement(sql);
        // 设置参数:
        pstmt.setString(1, "hhh");
        pstmt.setString(2, "123456");
        pstmt.setString(3, "王老五");
        pstmt.setDouble(4, 9000);
        // 执行SQL:
        int num = pstmt.executeUpdate();
        if(num > 0){
            System.out.println("保存成功!");
        }
    }catch(Exception e){
        e.printStackTrace();
    }finally{
        JDBCUtils.release(pstmt, conn);
    }
}

}

JDBC的使用以及预处理的重要性
JDBC 入门 02 使用Statement连接并作增删改查操作 03预处理SQL语句（常用以上了解）Prepa...
6.JDBC学习笔记
本文内容 1.什么是JDBC以及为什么要使用JDBC 2.JDBC核心API的讲解 3.使用JDBC核心API进行...
基本
概述 1.什么是JDBC以及为什么要使用JDBC 2.JDBC核心API的讲解 3.使用JDBC核心API进行CR...
6-基于Spring的框架-JDBC——6-2 基本实现思路
概要过度我们前面介绍了 JDBC 的基本使用方法，以及 Spring JDBC 使用方法。我们大概猜测了一下，...
Java自学-JDBC 预编译PreparedStatement
在JDBC中使用预编译PreparedStatement 以及它的优点步骤 1 : 使用PreparedStat...
JDBC面试问题与解答
什么是JDBC API以及何时使用它？ Java数据库连接API允许我们使用关系数据库.JDBC API接口和类是...
Java web之JDBC
一、JDBC的创建流程二、JDBC的封装三、用户操作和预处理块四、手动控制事务五、basedao实现更新（增删改）...
揭秘MyBatis为什么在阿里等大厂这么流行
一、什么是Mybatis？我们在使用传统JDBC时，我们往往需要写很多JDBC代码，需要自己写SQL语句以及自己...
springboot中 log4jdbc+logback的使用
1.什么是log4jdbc以及log4jdbc的特性使用使用java进行数据库操作时最痛苦的莫过于拼接SQL语句。...
JDBC的简单使用
JDBC 什么是JDBC 使用java代码发送sql语句的技术，就是jdbc技术。使用jdbc的前提需要登录数...