33 JDBC实用详解

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介: info💡 概念:JDBC是java提供的一套用于操作数据库的接口API:java程序员只需要面向这套接口编程即可;

14.png

:::info

💡 概念:JDBC是java提供的一套用于操作数据库的接口API:java程序员只需要面向这套接口编程即可;

:::

java连接数据库有五种方式:①静态加载②使用反射动态加载


1 JDBC静态加载,的使用步骤


1.1 注册驱动【加载Driver类】


Driver driver = new Driver();


1.2 获取连接【得到Connection】

Properties properties = new Properties();
String url = "jdbc:mysql://127.0.0.1:3306/school";
properties.setProperty("user","root");
properties.setProperty("password","123456");
Connection connect = driver.connect(url, properties);


1.3 执行增删改查【发送SQL命令】

   

String sql = "create table test";
        Statement statement = connect.createStatement();
        statement.executeUpdate(sql);


1.4 释放资源

 

connect.close();
        statement.close();


2 反射动态加载数据库


//    方式2 动态加载[使用反射加载driver类]
//        加载driver的Class对象
        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
        Driver driver = (Driver) aClass.newInstance();
//        2得到连接
        String url = "jdbc:mysql://127.0.0.1:3306/school";
        Properties properties = new Properties();
        properties.setProperty("user", "root");
        properties.setProperty("password", "123456");
        Connection connect = driver.connect(url, properties);
//        3执行SQL
        String sql = "delete from person where id = 2";
//        创建statement对象
        Statement statement = connect.createStatement();
        int i = statement.executeUpdate(sql);
        System.out.println(i > 0 ? "成功" : "失败!");
//        4关闭资源
        connect.close();
        statement.close();


3 使用DriverManager统一管理


//        方式3 使用DriverManager注册驱动,进行统一管理
//        1 注册驱动
        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
        Driver driver = (Driver) aClass.newInstance();
        String url = "jdbc:mysql://localhost:3306/school";
        String user = "root";
        String password = "123456";
        DriverManager.registerDriver(driver);//注册driver驱动
//        2获取Connetion
        Connection connection = DriverManager.getConnection(url, user, password);
//        3 执行SQL操作
        String sql = "insert into person value (1,'韩顺平',99,88,98)";
        Statement statement = connection.createStatement();
        int i = statement.executeUpdate(sql);
        System.out.println(i>0 ? "成功":"失败");
//        3 关闭资源
        connection.close();
        statement.close();


4 推荐使用


//        方式4  使用Class.forName() 自动完成驱动,简化代码,
//        1 自动完成驱动注册
        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
//        创建url、user 、password
        String url = "jdbc:mysql://localhost:3306/school";
        String user = "root";
        String password = "123456";
//        2 创建连接
        Connection connection = DriverManager.getConnection(url, user, password);
//        3 执行SQL
        String sql = "insert into person value (2,'zsl',99,88,88)";
        Statement statement = connection.createStatement();
        int i = statement.executeUpdate(sql);
        System.out.println(i>0 ? "成功":"失败");
//        4 关闭资源
        connection.close();
        statement.close();


5 ResultSet类的使用


5.1 基本介绍


(1)表示数据库结果集的一个数据表,通常通过执行select语句生成

(2)ResultSet保持一个光标,指向当前数据行,最初光标位于第一行之前

(3)next方法将光标移到下一行,当在ResultSet对象没有下一行对象时返回false


 

//    ResultSet类的使用
        //        获取配置文件信息
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\mysql.properties"));
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String url = properties.getProperty("url");
        String driver = properties.getProperty("driver");
//       1 注册驱动
        Class<?> aClass = Class.forName(driver);
        Driver driver1 = (Driver) aClass.newInstance();
//       2 创建连接
        Connection connection = DriverManager.getConnection(url, user, password);
//        3 执行SQL语句select语句
        String sql = "select * from person ";
        Statement statement = connection.createStatement();
        ResultSet resultSet = statement.executeQuery(sql);
        while (resultSet.next()){
            int id = resultSet.getInt(1);
            String name = resultSet.getString(2);
            int Chinese = resultSet.getInt(3);
            System.out.println(id+"\t"+name+"\t"+Chinese);
        }
//        4 关闭资源
        connection.close();
        statement.close();


6 预处理PreparedStatement,与Statement相比更安全避免了SQL注入


/

/ PreparedStatement预处理使用
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\mysql.properties"));
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String url = properties.getProperty("url");
        String driver = properties.getProperty("driver");
//       1 注册驱动
        Class<?> aClass = Class.forName(driver);
        Driver driver1 = (Driver) aClass.newInstance();
//       2 创建连接
        Connection connection = DriverManager.getConnection(url, user, password);
//        3 执行SQL语句select语句
        String na = "admin";
        String pw = "123";
//        SQL语句中的?相当与站位符
        String selectSql = "select id from user where `name` =? and pwd = ?";
        String addSql =  "insert into user value('001','admin','123')";
        String createTable = "create table  user ( id varchar(10),`name` varchar(10),pwd varchar(10))";
        PreparedStatement preparedStatement = connection.prepareStatement(selectSql);
        preparedStatement.setString(1,na);
        preparedStatement.setString(2,pw);
//        int i = preparedStatement.executeUpdate();
//        System.out.println(i>0? "成功":"失败");
        ResultSet resultSet = preparedStatement.executeQuery();
        System.out.println(resultSet);
            while (resultSet.next()){
                String id = resultSet.getString(1);
                System.out.println(id);
            }
//        4 关闭资源
        connection.close();
      preparedStatement.close();


7 JDBC事务处理


(1)在JDBC程序中当Connection对象创建时,默认情况下自动提交事务,没执行成功一次sql语句,自动提交不能回退

(2)在JDBC程序中为了让多个语句成为一个整体,需要用到事务

(3)调用Connection的setAutoCommit(false)可以取消自动提交事务

(4)所有SQL语句执行后,调用commit() 方法提交事务

(5)在其中的某个操作失败或者出现异常时,调用rollback()方法回退事务;


8 JDBC的SQL语句批处理


基本介绍:

(1):当需要成批的删除或者添加数据时,可以采用java的批量更新机制;

(2):JDBC的批量处理包含以下方法:

①:addBatch();添加需要批处理的SQL语句或参数;

②:executeBatch();执行批处理语句

③:JDBC连接mysql时,如果需要批处理,在 url中添加参数 :

?rewriteBatchedStatements=true

④:批处理往往和PreparedStatement一起搭配使用


public void batch(){
        Connection conection = JDBCUtils.getConection();
        String sql = "insert into admain value(?,?,?)";
        PreparedStatement preparedStatement = null;
        try {
            preparedStatement = conection.prepareStatement(sql);
            System.out.println("开始执行!");
            long starr = System.currentTimeMillis();
            for (int i = 0; i <= 1000; i++) {
                preparedStatement.setInt(1,i);
                preparedStatement.setString(2,"小明"+i);
                preparedStatement.setString(3,"123"+i);
//                将SQL语句加入批处理中
                preparedStatement.addBatch();
//                当有111条语句时批量执行
                if (i%100==0){//执行语句满111
//                    批量执行
                    preparedStatement.executeBatch();
//                    清空
                    preparedStatement.clearBatch();
                }
            }
            long end = System.currentTimeMillis();
            System.out.println("批量处理执行时间:"+(end-starr));
        } catch (SQLException e) {
            e.printStackTrace();
        }
        JDBCUtils.getClose(preparedStatement,conection,null);
    }
相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
3月前
|
SQL Java 关系型数据库
JDBC详解
Java Database Connectivity(JDBC)是Java语言中用于访问关系型数据库的标准接口,定义了一组API,使Java程序能以统一方式连接、访问和操作不同关系型数据库,简化数据库操作,提高Java应用程序的可移植性和可维护性。使用JDBC进行数据库操作主要包括创建数据源对象、建立连接、构造和执行SQL语句及释放资源等步骤。此外,还可以使用Set系列方法设置值,并使用get系列方法获取查询结果。
74 2
JDBC详解
|
3月前
|
SQL Java 关系型数据库
|
7月前
|
Java 关系型数据库 MySQL
JDBC是真的啰里啰嗦啊-但是很重要!(上)
JDBC是真的啰里啰嗦啊-但是很重要!
42 1
|
SQL Oracle 数据可视化
|
7月前
|
存储 Java 数据库连接
JDBC简单总结
JDBC简单总结
|
缓存 druid Java
JDBC2.0
JDBC2.0在1.0版本java.sql.*上增加了一个扩展包javax.sql.*包,这个包里面包含两个接口: 1.DataSource,数据源。 2.ConnectionPoolDataSource,数据池。 DataSource的源码可以看到,这个接口的作用就是拿来获取connection连接的。 各个数据库厂商只负责实现connection, 至于获取connection,在JDBC1.0里面是由DriverManager来负责的。 JDBC2.0版本之所新增DataSource,原因很简单——数据库连接池。1.0版本时每用一次connection都需要重新new,而da
132 0
JDBC2.0
|
SQL 人工智能 数据可视化
JDBC的“那些事“之应当注意的问题(上)
JDBC的“那些事“之应当注意的问题(上)
|
SQL 存储 关系型数据库
JDBC的“那些事“之应当注意的问题(中)
JDBC的“那些事“之应当注意的问题(中)
|
Java 关系型数据库 MySQL
JDBC1.0
JDBC是JAVA十三大规范之一,由JAVA定义顶级接口API,各个数据库厂商去实现。常用的四大接口——Driver,DriverManager,Connection,Statement。 这里先给出结论: 所谓的JAVA制定标准,就是指JAVA给出接口,厂家各自去实现。 比如Driver,Connection,Statement等都是有接口,有实现。 通过向DriverManager注册不同Driver来确定Connection,Statement的类型
67 0
|
SQL Java 关系型数据库
JDBC介绍
JDBC介绍
115 0