JDBC

JDBC基本概念

Java数据库连接,也就是使用Java语言操作数据库。

本质:

其实是官方(SUN公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库厂商去实现这套接口,提供数据库驱动jar包,我们可以使用这套接口(JDBC)变成,整整执行的代码是驱动jar包中的实现类。

JDBC快速入门

步骤:

  1. 导入驱动jar包
  2. 注册驱动
  3. 获取数据库连接对象 Connection
  4. 定义sql
  5. 获取执行sql语句的对象 Statement
  6. 执行sql,接受返回结果
  7. 处理结果
  8. 释放资源
package day21;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class Demo01 {
    public static void main(String[] args) throws Exception{
        //注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        //获取数据库连接对象
        Connection conn = DriverManager.getConnection("http://localhost/phpMyAdmin4.8.5","root1","password");
        //定义sql语句
        String sql = "select * from USER where id = 1";
        //获取执行sql的对象
        Statement stmt = conn.createStatement();
        //执行sql
        int count = stmt.executeUpdate(sql);
        //释放资源
        stmt.close();
        conn.close();
    }
}

详解各个对象:

  1. DriverManager:驱动管理对象

    1. 功能

      1. 注册驱动:告诉程序该使用哪一个数据库驱动jar
      static void registerDriver(Driver driver):注册与给定的驱动程序 DriverManager。
      写代码使用:Class.forName("com.mysql.jdbc.Driver");
      通过查看源码发现:在com.mysql.jdbc.Driver类中存在静态代码块。
      static{
      	try{
      	java.sql.DriverManager.registerDriver(new Driver());
      	} catch (SQLException E){
      		throw new RuntimeException("Can‘t register driver!");
      	}
      }
       注意:mysql5之后的驱动jar爆可以省略注册驱动的步骤
      
      2. 获取数据库连接
      	方法:static Connection getConnection(String url,String user,String password)
      	参数:
      		url:指定连接的路径
      			语法:jdbc:mysql://ip地址(域名):端口号/数据库名称
      			细节:如果连接的是本机mysql服务器,并且mysql服务默认端口是3306,则url可以简为jdbc:mysql:///数据库名称
      		user:用户名
      		password:密码
      
  2. Connection:数据库连接对象

    功能
    	获取执行sql的对象
    		Statement createStatement()
    		PreparedStatement prepareStatement(String sql)
    	管理事务
    		开启事务:void setAutoCommit(boolean autoCommit):调用该方法设置参数为false, 即开启事务
    		提交事务:commit()
    		回滚事务: rollback()
    
  3. Statement:执行sql的对象

    执行sql
    	1.boolean execute(String sql):可以执行任意的sql 了解
    	2.int executeUpdate(String sql):执行DML(insert、update、delete)语句、DDL(create、alter、drop)语句
    		返回值:影响的行数,可以通过这个影响的行数判断DML语句是否执行成功,返回值>0的则执行成功,反之则失败。
    	3.ResultSet executeQuery(String sql):执行DQL(select)语句
    

    练习1:添加一条记录

    package jdbc;
    
    /*
    添加一条记录
     */
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class ResultSet {
        public static void main(String[] args) {
            Statement stem = null;
            Connection conn = null;
            //1.注册驱动
            try {
                Class.forName("com.mysql.jdbc.Driver");
                //定义sql
                String sql = "insert into user values(2,‘xiaoming‘,‘11111‘)";
                //获取Connection对象
                conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
                //获取执行sql的对象
                stem = conn.createStatement();
                //执行sql
                int count = stem.executeUpdate(sql);
                //处理结果
                System.out.println(count);
                if (count >0){
                    System.out.println("执行成功");
                } else {
                    System.out.println("执行失败");
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
               if (stem != null){
                   try {
                       stem.close();
                   } catch (SQLException throwables) {
                       throwables.printStackTrace();
                   }
               }
                if (conn != null){
                    try {
                        conn.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
    
        }
    }
    

    练习2:修改记录

    package jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class Demo02 {
        public static void main(String[] args) {
            Connection conn = null;
            Statement stmt = null;
            //注册驱动
            try {
                Class.forName("com.mysql.jdbc.Driver");
                //获取连接对象
                conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
                //定义sql
                String sql = "UPDATE user SET passwd = ‘30000‘ WHERE id = 2";
                //获取执行sql对象
                stmt = conn.createStatement();
                //执行sql
                int count = stmt.executeUpdate(sql);
                //处理结果
                System.out.println(count);
                if (count >0){
                    System.out.println("执行成功");
                }else {
                    System.out.println("执行失败");
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (stmt != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (conn != null){
                    try {
                        conn.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
        }
    }
    

    练习3:删除一条记录

    package jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class Demo02 {
        public static void main(String[] args) {
            Connection conn = null;
            Statement stmt = null;
            //注册驱动
            try {
                Class.forName("com.mysql.jdbc.Driver");
                //获取连接对象
                conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
                //定义sql
                String sql = "delete from USER where id=1";
                //获取执行sql对象
                stmt = conn.createStatement();
                //执行sql
                int count = stmt.executeUpdate(sql);
                //处理结果
                System.out.println(count);
                if (count >0){
                    System.out.println("执行成功");
                }else {
                    System.out.println("执行失败");
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (stmt != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (conn != null){
                    try {
                        conn.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
        }
    }
    
  4. ResultSet:结果集对象,封装查询结果

    next():游标向下移动一行
    getxxx(参数):获取数据
    	xxx代表数据类型,比如获取int类型的数据,xxx就是int。
    	参数:可以接受两种类型的值
    		int:代表列的参数,从1开始。
    		String:代表列名称
    

    代码演示:

    package jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class ResultSet02 {
        public static void main(String[] args) {
            Statement stmt = null;
            Connection conn = null;
            ResultSet rs = null;
            try {
                //注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                //获取连接对象
                conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
                //定义sql
                String sql = "select * from user";
                //获取sql对象
                stmt = conn.createStatement();
                //执行sql
                rs = stmt.executeQuery(sql);
                //让游标向下移动一行
                rs.next();
                //获取数据
                int id = rs.getInt(1);
                String name = rs.getString("name");
                String passwd = rs.getString("passwd");
                rs.next();
                //获取数据
                int id1 = rs.getInt(1);
                String name1 = rs.getString("name");
                String passwd1 = rs.getString("passwd");
    
                System.out.println(id+"---"+name+"---"+passwd);
                System.out.println(id1+"---"+name1+"---"+passwd1);
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (rs != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (conn != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                } if (stmt != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
        }
    }
    
    注意:
    	使用步骤:
    		1.游标向下移动一行
    		2.判断是否有数据
    		3.获取数据
    boolean next():游标向下移动一行,判断当前行是否是最后一行末尾(是否有数据),如果是,则返回false,如果不是则返回true。
    
    代码演示:
    package jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class ResultSet02 {
        public static void main(String[] args) {
            Statement stmt = null;
            Connection conn = null;
            ResultSet rs = null;
            try {
                //注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                //获取连接对象
                conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
                //定义sql
                String sql = "select * from user";
                //获取sql对象
                stmt = conn.createStatement();
                //执行sql
                rs = stmt.executeQuery(sql);
                //使用循环遍历所有内容
                while(rs.next()){
                    int id = rs.getInt(1);
                    String name = rs.getString("name");
                    String passwd = rs.getString("passwd");
                    System.out.println(id+"---"+name+"---"+passwd);
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (rs != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (conn != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                } if (stmt != null){
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
        }
    }
    

    练习4:查询表中指定数据,将其封装成对象,装载集合,打印

    创建封装对象的类
    package jdbc;
    /*
    封装表内的数据
     */
    public class SelectDemo01 {
        private int id;
        private String name;
        private String passwd;
    
        @Override
        public String toString() {
            return "SelectDemo01{" +
                    "id=" + id +
                    ", name=‘" + name + ‘\‘‘ +
                    ", passwd=‘" + passwd + ‘\‘‘ +
                    ‘}‘;
        }
    
        public int getId() {
            return id;
        }
    
        public void setId(int id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getPasswd() {
            return passwd;
        }
    
        public void setPasswd(String passwd) {
            this.passwd = passwd;
        }
    }
    
    将表中查询的数据封装到集合中打印
    package jdbc;
    
    import java.util.Collections;
    import java.util.List;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.ArrayList;
    
    /*
    定义一个方法,查询表中的数据将其封装为对象,然后装载集合,返回
     */
    public class SelectDemo02 {
        public static void main(String[] args) {
            List<SelectDemo01> list = new SelectDemo02().findAll();
            System.out.println(list);
            System.out.println(list.size());
        }
    
        /**
         *
         * @return
         */
        public List<SelectDemo01> findAll(){
            Connection conn = null;
            Statement stmt = null;
            ResultSet rs = null;
            List<SelectDemo01> list = null;
            //注册驱动
            try {
                Class.forName("com.mysql.jdbc.Driver");
                conn = DriverManager.getConnection("jdbc:mysql:///db1", "root1", "password");
                String sql = "select * from user";
                stmt = conn.createStatement();
                rs = stmt.executeQuery(sql);
                list = new ArrayList<>();
                SelectDemo01 users = null;
                while (rs.next()) {
                    int id = rs.getInt("id");
                    String name = rs.getString("name");
                    String passwd = rs.getString("passwd");
                    //创建对象
                    users = new SelectDemo01();
                    users.setId(id);
                    users.setName(name);
                    users.setPasswd(passwd);
    
                    list.add(users);
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (rs != null) {
                    try {
                        rs.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (stmt != null) {
                    try {
                        stmt.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
                if (conn != null) {
                    try {
                        conn.close();
                    } catch (SQLException throwables) {
                        throwables.printStackTrace();
                    }
                }
            }
            return list;
        }
    }
    
  5. PreparedStatement:执行sql的对象

    1. SQL注入问题(万能密码):在拼接sql时,有一些sql的特殊关键字参与字符串的拼接,会造成安全性问题。

      1. 输入用户名随便输入,输入密码:a‘ or ‘1‘ = ‘1

        sql:select * from user where username = ‘asdaweq‘ and password = ‘a‘ or ‘1‘ = ‘1‘

    2. 解决sql注入问题:使用PreparedStatment对象来解决。

    3. 预编译sql:参数使用占位符替代,在执行sql语句的时候,将占位符替换。

    4. 步骤:

      1. 导入驱动jar包
      2. 注册驱动
      3. 获取数据库连接对象
      4. 定义sql
        • 注意:sql的参数使用?作为占位符。如:select * from user where username = ? and password = ?
      5. 获取执行的sql语句的对象
      6. 给?赋值
        • 方法: setxxx(参数1,参数2)
          • 参数1:?的位置编号,从1开始
          • 参数2:?的值
      7. 执行sql,接受返回的结果,不需要传递sql语句
      8. 处理结果
      9. 释放资源
    5. 注意:后期都会使用PreparedStatement来完成增删改查的所有操作:

      1. 可以防止sql注入
      2. 效率更高

    代码演示:

    //暂无,有坑未排
    

JDBC的工具类:JDBCUtils

目的:简化代码的书写

分析:

  1. 注册驱动也抽取

  2. 抽取一个方法获取连接对象

    1. 需求:不想传递参数(麻烦),还得保证工具类的通用性。

    2. 解决:配置文件

      ? jdbc.properties

      ? url=

      ? user=

      ? password=

      简单来说,就是在写工具类的时候,并不把连接对象写死,这样修改起来会比较麻烦,我们可以在一个文件里面写明连接对象的数据,这个在代码执行的时候,只需要修改配置文件就可以获取数据。

  3. 抽取一个方法释放资源

JDBC控制事务

事务:一个包含多个步骤的业务操作,如果这个业务操作被事务管理,则这多个步骤要么同时成功,要么同时失败。

操作:

  1. 开启事务
  2. 提交事务
  3. 回滚事务

使用Connection对象来管理事务

  • 开启事务:setAutoCommit(boolean autoCommit):调用该方法设置参数为false,即开启事务。
  • 提交事务:commit()
  • 回滚事务:rollback()

JDBC

上一篇:一个mysql表最多可以有几列? 一个mysql表最多可以创建多少个索引? 单个索引最多可以包含多少个列? 一个索引最多可以有多长?这个几个问题你都不一定知道正确答案


下一篇:【c++基础】static修饰的函数作用与意义