Java与数据库 —— JDBC标准

lastSeries 发布于2019-08-16 13:46 / 461人阅读

摘要：由来与描述没有前开发者想操作数据库，必须需要了解每个数据库对应的数据库驱动程序，由于每个数据库驱动程序的都不同，所以当需要迁移数据库时，根本不平滑，需要大量修改与重写有了后公司也知道问题之后，就提出一种约束规范，让所有数据库厂商都按照这个规

JDBC由来与描述

没有JDBC前

开发者想操作数据库，必须需要了解每个数据库对应的数据库驱动程序API，由于每个数据库驱动程序的API都不同，所以当需要迁移数据库时，根本不平滑，需要大量修改与重写

有了JDBC后

Sum公司也知道问题之后，就提出一种约束 —— JDBC规范，让所有数据库厂商都按照这个JDBC规范来开发数据库驱动程序，以便于Java程序能用统一方式操作不同的数据库，数据库迁移变成可行

JDBC描述

JDBC是一种Java web的规范，需要具体开发者（数据库厂商）来实现

JDBC常用四大API

DriverManager

作用：
1、注册驱动
Class.forName("com.jdbc.mysql.Driver");

2、获取连接
Connection conn = DriverManager.getConnection();

Connection

作用：
1、创建执行SQL语句的对象（3种）
Statement createStatement()    // 执行SQL语句
PreparedStatement prepareStatement()   // 预编译SQL并执行
CallableStatement prepareCall()    // 执行SQL存储过程

2、进行事务管理
setAutoCommit(boolean b)
commit()
rollback()

Statement

作用：
1、执行SQL语句
boolean execute(String sql)   // 执行SQL语句，执行select就返回true,否则返回false
ResultSet executeQuery(String sql)     // 执行SQL中的select语句
int executeUpdate(String sql)          // 执行SQL中的insert/update/delete语句

2、执行批量SQL语句
addBatch(String sql)    // 添加到批量处理
executeBatch()          // 执行批量处理
clearBatch()            // 清空批量处理

ResultSet

（select语句）查询结果的集合
作用：获取到查询的结果
next()           //判断是否有下一条数据
getXXX()         //根据数据类型获取查询记录的数据
getObject()      //通用获取数据方法

JDBC资源释放

释放原则：晚创建，早释放；资源稀有，不释放很快会阻塞

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb","root","root");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from user");

rs.close();
stmt.close();
conn.close();

JDBC CURD操作

增加

Connection conn = null;
Statement stmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 获取执行SQL语句对象
    stmt = conn.createStatement();
    // 编写SQL
    String sql = "insert into user values ("xiaomin","女人",12)";
    // 执行SQL语句
    int i = stmt.executeUpdate(sql);
    if(i > 0){
        System.out.println("插入成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(stmt != null){
        try{
            stmt .close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            stmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

更新

Connection conn = null;
Statement stmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 获取执行SQL语句对象
    stmt = conn.createStatement();
    // 编写SQL
    String sql = "update user set name = "wt"";
    // 执行SQL语句
    int i = stmt.executeUpdate(sql);
    if(i > 0){
        System.out.println("更新成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(stmt != null){
        try{
            stmt .close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            stmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

删除

Connection conn = null;
Statement stmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 获取执行SQL语句对象
    stmt = conn.createStatement();
    // 编写SQL
    String sql = "delete from user where id = 3";
    // 执行SQL语句
    int i = stmt.executeUpdate(sql);
    if(i > 0){
        System.out.println("删除成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(stmt != null){
        try{
            stmt .close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            stmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

查询

Connection conn = null;
Statement stmt = null;
ResultSet rs = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 获取执行SQL语句对象
    stmt = conn.createStatement();
    // 编写SQL
    String sql = "select * from user";
    // 执行SQL语句
    rs = stmt.executeQuery(sql);
    if(rs.next()){
        System.out.print(rs.getString("name"));
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(rs != null){
        try{
            rs .close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            rs = null;
        }
    }
    if(stmt != null){
        try{
            stmt .close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            stmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

JDBC SQL注入解决方案

开发时，使用 PreparedStatement对象 取代 Statement对象 来执行SQL，有效避免SQL注入

增加

Connection conn = null;
PreparedStatement pstmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 编写SQL
    String sql = "insert into user values (?,?,?)";
    // 获取执行SQL语句对象
    pstmt = conn.preparedStatement(sql);
    // 设置参数
    pstmt.setString(1, "qqq");
    pstmt.setString(2, "bbb");
    pstmt.setString(3, "ccc");
    // 执行SQL语句
    int i = pstmt.executeUpdate();
    if(i > 0){
        System.out.println("插入成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(pstmt != null){
        try{
            pstmt.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            pstmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

更新

Connection conn = null;
PreparedStatement pstmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 编写SQL
    String sql = "update user set name = ?, age = ?, pwd = ? where id = ?";
    // 获取执行SQL语句对象
    pstmt = conn.preparedStatement(sql);
    // 设置参数
    pstmt.setString(1, "wt");
    pstmt.setString(2, 15);
    pstmt.setString(3, "basdcx");
    pstmt.setString(4, 10);
    // 执行SQL语句
    int i = pstmt.executeUpdate();
    if(i > 0){
        System.out.println("更新成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(pstmt != null){
        try{
            pstmt.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            pstmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

删除

Connection conn = null;
PreparedStatement pstmt = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 编写SQL
    String sql = "delete from user where id = ?";
    // 获取执行SQL语句对象
    pstmt = conn.preparedStatement(sql);
    // 设置参数
    pstmt.setString(1, 16);
    // 执行SQL语句
    int i = pstmt.executeUpdate();
    if(i > 0){
        System.out.println("删除成功！");
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
    if(pstmt != null){
        try{
            pstmt.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            pstmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

查询

Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;

try{
    // 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 获得连接
    conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/myDB","root","root");
    // 编写SQL
    String sql = "select * from user where sex = ？";
    // 获取执行SQL语句对象
    pstmt = conn.preparedStatement(sql);
    // 设置参数
    pstmt.setString(1, "男");
    // 执行SQL语句
    rs = pstmt.executeQuery();
    while(rs.next()){
        System.out.println(rs.getString("name"));
    }
}catch(Exception e){
    e.printStackTrace();
}finally{
     if(rs != null){
        try{
            rs.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            rs = null;
        }
    }
    if(pstmt != null){
        try{
            pstmt.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            pstmt = null;
        }
    }
    if(conn != null){
        try{
            conn.close();
        }catch(SQLException e){
            e.printStackTrace();
        }finally{
            conn = null;
        }
    }
}

连接池（数据源）JDBC优化技术

数据库连接频繁创建与消耗，在资源使用上是一种浪费

常用连接池

C3P0、HikariCP、Druid、Tomcat、Dbcp

用法（以C3P0为例）

ComboPooledDataSource dataSource = new ComboPooledDataSource();   // 只需一个对象
// 获取连接
Connection conn = dataSource.getConnection();

云内存存储UMem Redis 云数据库MySQL jdbc连接java数据库 jdbc连接数据库java代码 java jdbc连接mysql数据库 java jdbc

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/72313.html

【Java学习】JDBC数据类型

摘要：通过这个驱动程序，我们就能够两个数据类型的相互转化了。和和方法可以将特定的类型转换为特定的数据类型。和可以将几乎任何数据类型映射到数据类型。时间与日期类型类映射到类型，和类分别映射到和数据类型。概述我们知道Java的数据类型和数据库中的类型并不是一一对应的，我们在使用JDBC在与数据库进行交互的时候，比如我们向数据库中插入一条数据，或者从数据库中查询一个数据，为什么我们能够正常的读...

Vixb 2019-08-19 10:42 评论0 收藏0
Java知识点总结（JDBC-概要）

摘要：知识点总结概要知识点总结简介为开发者使用数据库提供了统一的编程接口，它由一组类和接口组成主要在包中。跟踪可用的驱动程序，并在数据库和相应的驱动程序之间建立连接。接口与特定数据库的连接会话，在连接上下文中执行语句并返回结果。 Java知识点总结（JDBC-概要） @(Java知识点总结)[Java, JDBC] 简介 JDBC（Java Database Connection）为Java...

animabear 2019-08-16 12:38 评论0 收藏0
JDBC干货篇一

摘要：干货篇一基础的全称是，即数据库连接，它是一种可以执行语句的。将光标移动到上一行，如果超过结果集的范围则返回。列索引从开始，意味着行中的第一列是，第二列是，以此类推。 JDBC干货篇一 JDBC基础 JDBC的全称是Java Database Connectivity，即Java数据库连接，它是一种可以执行SQL语句的Java API。程序可通过JDBC API连接到关系数据库，并使用...

hiyang 2019-08-16 10:31 评论0 收藏0
从懵逼到再入门——JavaEE完整体系架构

摘要：软件开发体系架构两层架构传统的客户服务器系统仅只简单地基于两层体系来构建，即客户端前台和企业信息系统后台，没有任何中间件，业务逻辑层与表示层或数据层混在一起。 showImg(https://segmentfault.com/img/remote/1460000007090113); 理想的建筑师应该既是文学家又是数字家，他还应通晓历史，热衷于哲学研究，精通音乐，懂得医药知识，具有法学...

ZweiZhao 2019-08-14 15:55 评论0 收藏0