JDBC（一）

桃扇骨 2024-04-17 18:07 47阅读 0赞

## 1.概念 ##

> JDBC：Java Data Base Connectivity Java 连接数据库  
> JDBC，其实就是Java定义的一套和数据库建立连接的规范(接口)，那么各家数据库厂商，想要Java去操作各家的数据库，必须实现这套接口，我们把数据库厂商写的这套实现类，称之为数据库驱动。  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjU4NDU0NQ_size_16_color_FFFFFF_t_70]

#### 2、建立步骤 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjU4NDU0NQ_size_16_color_FFFFFF_t_70 1]

案例1
    public class JDBCDemo {
        public static void main(String[] args) throws ClassNotFoundException, SQLException {
            //第一步 手动导入数据库的驱动jar包，记得依赖一下
            //第二步 通过反射加载驱动
            //""内为Driver的全路径
            Class.forName("com.mysql.jdbc.Driver");
            //第三步建立连接
            //url  统一资源定位符url="jdbc:mysql://localhost:3306/mydb";  协议：//ip:端口/具体资源路经
            String url="jdbc:mysql://localhost:3306/mydb";
            String username="root";
            String password="123456";
            Connection connection = DriverManager.getConnection(url, username, password);
            //第四步获取操作对象
            Statement statement = connection.createStatement();
            //第六步编写SQL语句
            String sql="insert into users values(1999,'张五')";
            //第七步执行SQL语句
            statement.executeUpdate(sql);
           //第八步释放资源
            connection.close();
            statement.close();
        }
    }
    案例2
    public class JDBCDemo {
    public static void main(String[] args) throws Exception {
        //1.导入数据库厂商的驱动jar包  右键---->add as lib
        //2.加载驱动
        Class.forName("com.mysql.jdbc.Driver"); //驱动在5.0 以上 这句话也可以省略不写
        //3.建立连接
        //URL:统一资源定位符
         //协议：//ip:端口/具体的资源路径
        //"https://home.firefoxchina.cn/"
        // 主协议:子协议://ip:端口/资源
        //"jdbc:mysql://localhost:3306/mydb"
        //如果是本地连接，可以省略 localhost:3306 不用写
        Connection conn = DriverManager.getConnection("jdbc:mysql:///mydb","root","123456");        //4.获取操作对象
        Statement statement = conn.createStatement();
        //5.编写SQL
        String sql="insert into users values('李四',’123')";
        //返回值i 代表你影响的行数
        int i = statement.executeUpdate(sql);//执行DML语句
        if(i>0){
            System.out.println(i);
            System.out.println("插入成功");
        }else{
            System.out.println("插入失败");
        }
        //释放资源
        conn.close();
        statement.close();
    }

## 3.JDBC查询表中所有数据 ##

public class MyDemo2 {
        public static void main(String[] args) throws Exception {
            //加载驱动
            Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
            //建立连接
            //DriverManager 驱动管理类 管理一组JDBC驱动的基本服务
           //Connection 与特定的数据库建立连接（回话）
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf-8","root","123456");
            //获取操作对象 创建一个Statement对象来将SQL语句发送到数据库
            // Statement 用于执行静态 SQL 语句并返回它所生成结果的对象。
            Statement statement = connection.createStatement();
            //statement.execute() 执行任何的sql语句
            //statement.executeUpdate().执行DML语句
           // statement.executeQuery()  执行DQL语句
            String sql="select*from bank";
    
            //ResultSet结果集对象 执行查询语句后 查询到的结果集对象封装在结果集对象中
            //表示数据库结果集的数据表，通常通过执行查询数据库的语句生成。
            //ResultSet对象具有指向其当前数据行的光标。最初光标在第一行之前
            //next 方法将光标移到下一行
           //因为该方法在 ResultSet 对象没有下一行时返回 false，所以可以在 //while
              //循环中使用它来迭代结果集。
    
            ResultSet resultSet = statement.executeQuery(sql);
              //取出结果集对象 放入集合中
            ArrayList<Bank> banks = new ArrayList<>();
            while (resultSet.next()){
                int money = resultSet.getInt("money");
                String username = resultSet.getString("usename");
             //也可以使用列号
             //    int money = resultSet.getInt(1);
                //            String username = resultSet.getString(2);
                //
                Bank bank = new Bank(money, username);
                banks.add(bank);
    
            }
            System.out.println(banks);
            connection.close();
           statement.close();
        }
    }

## 4.预编译对象操作 ##

##### 登录案例 #####

public class loginDemo {
        public static void main(String[] args) throws Exception {
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入用户名");
            String name = scanner.nextLine().trim();
            System.out.println("请输入密码");
            String passwrod = scanner.nextLine();
    
            Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
    
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf-8","root","123456");
            Statement statement = connection.createStatement();
            String sql="select*from user where name='"+name+"' and password='"+passwrod+"'";
            ResultSet resultSet = statement.executeQuery(sql);
            boolean next = resultSet.next();
            if (next){
                System.out.println("登录成功");
            }else {
                System.out.println("登录失败");
            }
        }
    }
    但是这样写有问题不能防止SQL注入
    比如这样写也可以登上
    
       public class loginDemo {
        public static void main(String[] args) throws Exception {
    //        Scanner scanner = new Scanner(System.in);
    //        System.out.println("请输入用户名");
    //        String name = scanner.nextLine().trim();
    //        System.out.println("请输入密码");
    //        String passwrod = scanner.nextLine();
            String name="1' or '1'='1";
            String passwrod="1' or '1'='1";
        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
    
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf-8","root","123456");
        Statement statement = connection.createStatement();
        String sql="select*from user where name='"+name+"' and password='"+passwrod+"'";
        ResultSet resultSet = statement.executeQuery(sql);
        boolean next = resultSet.next();
        if (next){
            System.out.println("登录成功");
        }else {
            System.out.println("登录失败");
        }
    }
    }

### 防止SQL注入的写法 ###

> 我们通过createStatement() 获取出的这个操作对象，去执行SQL语句，那么这个sql语句，有时会拼串，不能防止sql注入  
> 为了预防sql注入，我们可以使用另外一个操作对象 connection.prepareStatement()

### 5.JDBC工具类 ###

Java提供的一个工具类，可以读取 src目录下的文件 
         jdbcProperties.properties
    className=com.mysql.jdbc.Driver
    url=jdbc:mysql:///test
    username=root
    password=123456

#### 读取配置文件的方法 ####

1   ResourceBundle 这个类，读取的配置文件，有两点要求，
           1.配置文件要在src 下
            2.配置文件的后缀名，必须为 .properties
            . 文件的后缀名，你在读取的时候，不要写      jdbcProperties 
      ResourceBundle bundle = ResourceBundle.getBundle("jdbcProperties");
            //键找值
            String className = bundle.getString("className");
            String url = bundle.getString("url");
            String username = bundle.getString("username");
            String password = bundle.getString("password");
     2.
            InputStream in = MyTest.class.getClassLoader().getResourceAsStream("jdbcProperties.properties");
            Properties properties = new Properties();
            properties.load(in);
             BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(in));
        String[] split = bufferedReader.readLine().split("=");
        System.out.println(split[0]);
        System.out.println(split[1]);

### 封装的工具 ###

public class JDBCUtils {
    
    //ctrl+alt+F 快速抽取成员变量
    private static String url;
    private static String username;
    private static String password;
    
    private JDBCUtils() {
    }
    
    static {
        try {
            //注册启动
            Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
            url = "jdbc:mysql:///mydb";
            username = "root";
            password = "123456";
    
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    //获取连接对象的方法
    public static Connection getConnection() throws Exception {
    
        Connection connection = DriverManager.getConnection(url, username, password);
    
    
        return connection;
    }
    
    //释放资源的方法
    public static void colse(Connection conn, Statement statement, ResultSet resultSet) throws SQLException {
        if (conn != null) {
            conn.close();
        }
        if (statement != null) {
            statement.close();
        }
        if (resultSet != null) {
            resultSet.close();
    
        }
    }
    
    public static void colse(Connection conn, Statement statement) throws SQLException {
        if (conn != null) {
            conn.close();
        }
        if (statement != null) {
            statement.close();
        }
    
    }

### 6.JDBC批处理 ###

> 插入大量数据时，建议使用批处理来做 statement.addBatch();//添加批处理，先将数据缓存起来  
> statement.executeBatch();//执行批处理 statement.clearBatch();//清空缓存

案例

public class MyTest2 {
        public static void main(String[] args) throws Exception {
            ArrayList<Bank> list = new ArrayList<>();
            for (int i = 0; i < 1000; i++) {
                Bank bank = new Bank(i + 1000, "李四");
                list.add(bank);
            }
            Connection connection = JDBCUtils.getConnection();
            String sql = "insert into bank values (?,?)";
            PreparedStatement statement = null;
            statement = connection.prepareStatement(sql);
            for (Bank bank : list) {
                statement.setInt(2, bank.getMoney());
                statement.setString(1, bank.getUsename());
                statement.addBatch(); //添加批处理
            }
            statement.executeBatch();//执行批处理
            statement.clearBatch();//清空批处理
            JDBCUtils.colse(connection, statement);
        }
    }

#### 7.JDBC 调用存储过程和自定义函数 ####

CallableStatement

调用存储过程 {call <procedure-name>[(<arg1>,<arg2>, ...)]}
     		Connection conn = JDBCUtils.getConnection();
            String sql="{call testPro(?,?)}"; //输入或输出参数用?占位
            CallableStatement prepareCall = conn.prepareCall(sql);
            //给输入参数设置值
            prepareCall.setInt(1,7369);
            //如果有输出参数我们需要注册输出参数
            prepareCall.registerOutParameter(2, Types.INTEGER);
            boolean b = prepareCall.execute();
            //获取输出结果
            int r = prepareCall.getInt(2);
            System.out.println(r);
            //释放资源
            JDBCUtils.close(conn,prepareCall);         
     调用自定义函数 {?=call<procedure -name >[( < arg1 >,<arg2 >, ...)]}
     		String sql="{?=call testFun(?)}";
            CallableStatement callableStatement = conn.prepareCall(sql);
            //设置输入参数
            callableStatement.setInt(2,7902);
            //注册返回值
            callableStatement.registerOutParameter(1, Types.INTEGER);
            callableStatement.execute();
            //获取返回的结果
            int r = callableStatement.getInt(1);
            System.out.println("结果是："+r);
            //释放资源
            JDBCUtils.close(conn,callableStatement);

## 建立存储过程 ##

DELIMITER $$
    
    USE `test`$$
    
    DROP PROCEDURE IF EXISTS `Myprocedure`$$
    
    CREATE DEFINER=`root`@`localhost` PROCEDURE `Myprocedure`(IN num INT,OUT r INT)
    BEGIN
        DELETE FROM bank WHERE id=num;
        SELECT COUNT(*)FROM bank INTO r;
        END$$
    
    DELIMITER ;
      // 数据库这样调用
        CALL Myprocedure(2,@rr);
        SELECT @rr;
     // Java调用存储过程
    public class Mytext {
        public static void main(String[] args) throws Exception {
            Connection connection = JDBCUtils.getConnection();
            //sql语句
           String sql="{call Myprocedure(?,?)}";
           //得到prepareCall 执行sql语句
            CallableStatement callableStatement = connection.prepareCall(sql);
            //给sql语句赋值
            callableStatement.setInt(1,7);
            //输出参数 ：我们需要注册 输出参数
            callableStatement.registerOutParameter(2, Types.INTEGER);
            //执行调用的存储过程
            callableStatement.execute();
            //获取结果
            int r = callableStatement.getInt(2);
            System.out.println(r);
            //释放资源
            JDBCUtils.colse(connection,callableStatement);
        }
    }
    
    创建自定义函数
    DELIMITER $$
    CREATE
      FUNCTION `test`.`Functiong1`(num INT)
        RETURNS INT
        
        BEGIN
    --删除一个人，在统计一下好友多少人 把这个人返回
    --定义变量
    DECLARE i INT DEFAULT 0;
    DELETE FROM bank WHERE id=num;
    SELECT COUNT(*)FROM bank INTO i;
    RETURN i;
        END$$
    
    DELIMITER ;
    数据库的调用方法
    SELECT Functiong1(8)

;

### 8. ###

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjU4NDU0NQ_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/f8ab8db8aa3f4e638c49f9ab1879802b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjU4NDU0NQ_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/8cd58b2123224a55bacf8c7406b5d354.png