当前位置： 首页 > news >正文

Java学习--JDBC

news 来源：原创 2024/5/19 0:00:35

JDBC概念

JDBC概念

就是使用Java语言操作关系型数据库的一套API 全称：( Java DataBase Connectivity ) Java 数据库连接

我们开发的同一套Java代码是无法操作不同的关系型数据库，因为每一个关系型数据库的底层实现细节都不一样。如果这样，问题就很大了，在公司中可以在开发阶段使用的是MySQL数据库，而上线时公司最终选用oracle数据库，我们就需要对代码进行大批量修改，这显然并不是我们想看到的。我们要做到的是同一套Java代码操作不同的关系型数据库，而此时sun公司就指定了一套标准接口（JDBC），JDBC中定义了所有操作关系型数据库的规则。众所周知接口是无法直接使用的，我们需要使用接口的实现类，而这套实现类（称之为：驱动）就由各自的数据库厂商给出。

JDBC本质

各个数据库厂商去实现这些套接口，提供数据库驱动jar包
我们可以使用这些套接口(JDBC)编程，真正执行的代码是驱动jar包中的实现类

JDBC的好处

各数据库厂商使用相同的接口，Java代码不需要针对不同数据库分别开发
可随时替换底层数据库，访问数据库的Java代码基本不变

步骤及具体操作

java操作数据库的流程

1.编写java代码
2.java代码将SQL发送到MySQL服务端
3.MySQL服务端接收到SQL语句并执行该SQL语句
4.将SQL语句执行的结果返回给java代码

编写代码步骤

创建工程，导入驱动jar包

将mysql的驱动包放在模块下的lib目录（随意命名）下，并将该jar包添加为库文件

在添加为库文件的时候，有三个选项

Global Library ： 全局有效

Project Library : 项目有效

Module Library ： 模块有效

这里可以选择模块有效

 

接下来就是在src中创建类

注册驱动

Class.forName("com.mysql.jdbc.Driver");

获得连接

Connection conn = DriverManager.getConnection(url, username, password);
java代码需要发送给MySQL服务端，就需要先建立连接

定义SQL语句

String sql =  “update…” ;

获取执行SQL对象

执行SQL语句需要SQL执行对象，而这个执行对象就是Statement对象
Statement stmt = conn.createStatement();

执行SQL

stmt.executeUpdate(sql);  

处理返回结果
释放资源

先开的后关，后开的先关

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

public class JDBCDemo {
    public static void main(String[] args) throws Exception {
        //1.注册驱动
//        Class.forName("com.mysql.jdbc.Driver");

        //2.获取连接
        String url="jdbc:mysql://127.0.0.1:3306/bookmal?useSSL=false&useServerPrepStmts=true&serverTimezone=UTC";
        String username="root";
        String password="123456";
        Connection conn = DriverManager.getConnection(url, username, password);

        //3.定义sql语句
        String sql="UPDATE `user` SET `password`=222 WHERE id = 2";

        //4.获取执行sql的对象
        Statement stmt = conn.createStatement();

        //5.执行sql
        int count = stmt.executeUpdate(sql);//受影响的行数

        //6.处理的结果
        System.out.println(count);
        //7.释放资源
        stmt.close();
        conn.close();

    }
}

JDBC API

DriverManager(驱动管理类)

注册驱动

registerDriver用于注册驱动，但是我们在写注册驱动的时候写的是Class.forName("com.mysql.jdbc.Driver");   这是因为该类中的静态代码块中已经执行了DriverManager对象的registerDriver()方法的注册，所以我们只需要加载Driver类，该静态代码块就会执行。而Class.forName("com.mysql.jdbc.Driver")；就可以加载Driver类

在MySql5之后的驱动包，可以省略注册驱动的步骤

获取数据库连接

getConnection(String url,String user,String password)

url:

jdbc:mysql://ip地址(域名):端口号/数据库名称?参数键值对1&参数键值对2…

Mysql8.0以上版本的数据库连接有所不同

com.mysql.jdbc.Driver需要改为com.mysql.cj.jdbc.Driver
MySQL8.0以上版本不要SSL连接的，需要显示关闭
allowPublicKeyRetrieval允许客户端从服务器获取公钥
最后还需要设置时区
 

user：用户名
password：密码

Connection

获取执行SQL的对象

普通执行SQL对象  Statement createStatement()
预编译SQL的执行SQL对象：防止SQL注入  prepareStatement prepareStatement(sql)
执行存储过程的对象   CallableStatement prepareCall(sql)

管理事务

开启事物：BEGIN或者START TRANSACTION
提交事物：COMMIT
回滚事物：ROLLBACK

Statement

Statement对象的作用就是用来执行SQL语句。而针对不同类型的SQL语句使用的方法也不一样。

ResultSet

执行了DQL语句就会返回该对象   ResultSet  executeQuery(sql)：执行DQL 语句，返回 ResultSet 对象

boolean  next()
将光标从当前位置向前移动一行
判断当前行是否为有效行

方法返回值说明：
true  ： 有效航，当前行有数据
false ： 无效行，当前行没有数据

xxx  getXxx(参数)：获取数据
xxx : 数据类型；如： int getInt(参数) ；String getString(参数)
参数：
         int类型的参数：列的编号，从1开始
         String类型的参数： 列的名称

PreparedStatement
    预编译SQL语句并执行：预防SQL注入问题
    SQL注入
        SQL注入是通过操作输入来修改事先定义好的SQL语句，用以达到执行代码对服务器进行攻击的方法。

比如下面这个代码：

import java.sql.*;
import java.util.Scanner;

public class JDBCDemo02 {
    public static void main(String[] args) throws SQLException {
        Scanner sc= new Scanner(System.in);
        System.out.println("请输入用户名：");
        String userName = sc.next();
        System.out.println("请输入密码：");
        String pwd = sc.next();
        //1.注册驱动
//        Class.forName("com.mysql.jdbc.Driver");

        //2.获取连接
        String url="jdbc:mysql://127.0.0.1:3306/bookmal";
        String username="root";
        String password="123456";
        Connection connection = DriverManager.getConnection(url, username, password);

        // 3、获取发送SQL对象
        Statement statement = connection.createStatement();

        // 4、执行SQL语句
        String sql = "select * from user where userName='" + userName
                + "' and password = '" + pwd + "'";
        ResultSet resultSet = statement.executeQuery(sql);

        // 5、处理结果:只要resultSet.next()结果为true，说明查询到了你的用户名和密码，否则，没有查询到你的用户名和密码，从而说明你的用户名或者密码错误
        if (resultSet.next()) {
            System.out.println("用户名和密码正确，登录成功");
        } else {
            System.out.println("用户名或密码错误，登录失败");
        }

        // 6、释放资源:与关闭流的方式一样，先开的后关，后开的先关
        resultSet.close();
        statement.close();
        connection.close();
        sc.close();
    }
}

 

输入结果正确时是可以登陆的

但是如果恶意的修改， 

即使密码不正确也可以登录成功，因为这里面的字符串时拼接起来并且传到数据库中的，所以在数据库中就相当于是 select * from user where username = 'sjdljfld' and password = ''or '1' = '1'

所以可以使用PreparedStatement替换Statement,它将特殊字符进行了转义。在每个 ’ 的前面都加上了/，这样的话安全性更高

使用工具类简化代码

使用DBUtil提高代码的重用性

public class DBUtils {
    /**
     *重用性方案  获取连接，释放资源
     */
    static {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    //1.获取连接
    public static Connection getConnection() {
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/bookmal", "root", "123456");
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }

    public static void closeAll(Connection connection, Statement statement, ResultSet resultSet) {
        try {
            if (resultSet != null) {
                resultSet.close();
            }
            if (statement != null) {
                statement.close();
            }
            if (connection != null) {
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;

public class JDBCDemo01 {
    public static void main(String[] args) throws SQLException {
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入用户名：");
        String userName = sc.nextLine();
        System.out.println("请输入密码：");
        String pwd = sc.nextLine();
        //2.获得连接
        Connection connection = DBUtils.getConnection();
        // 3、获取发送SQL对象
        String sql = "select * from user where userName = ? and password=?;";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        // 4、绑定参数，有多少个?绑定多少个参数值
        preparedStatement.setString(1, userName);
        preparedStatement.setString(2, pwd);
        // 5、执行SQL语句，并处理结果
        ResultSet resultSet = preparedStatement.executeQuery();
        if (resultSet.next()) {
            System.out.println("用户名和密码正确，登录成功");
        } else {
            System.out.println("用户名或密码错误，登录失败");
        }

        // 6、释放资源:与关闭流的方式一样，先开的后关，后开的先关
        DBUtils.closeAll(connection, preparedStatement, resultSet);
        sc.close();
    }
}

数据库连接池

数据库连接池简介
    数据库连接池是个容器，负责分配、管理数据库连接(Connection)
    它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个；
    释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏
    好处
        资源重用
        提升系统响应速度
        避免数据库连接遗漏

常见的数据库连接池有 DBCP、C3P0、Druid。

  • Druid连接池是阿里巴巴开源的数据库连接池项目

  • 功能强大，性能优秀，是Java语言最好的数据库连接池之一

Druid的使用

  • 导入jar包 druid-1.1.12.jar

  • 定义配置文件

  • 加载配置文件

  • 获取数据库连接池对象

  • 获取连接

  • 在获取了连接之后就可以为所欲为了

配置文件的编写

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/bookmal?useSSL=false&serverTimeZone=UTC
username=root
password=123456
#初始化连接数量
initialSize=5
#最大连接数
maxActive=10
#最大等待时间
maxWait-3000

public class DruidDemo {

    public static void main(String[] args) throws Exception {
        //1.导入jar包
        //2.定义配置文件
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);

        //5. 获取数据库连接 Connection
        Connection connection = dataSource.getConnection();
        System.out.println(connection); //获取到了连接后就可以继续做其他操作了

        //System.out.println(System.getProperty("user.dir"));
    }
}

相关文章：

  • C++中GDAL批量创建多个栅格图像文件并批量写入数据
  • 基于maven的spring项目实现登录注册（SSM）
  • 【C++】动态内存管理
  • 波士顿动力再惊艳！机器人大秀男团舞，举手投足人味满满，多次转卖后展示新标签...
  • Python 代码托管到码云平台，原来这么简单
  • 【MATLAB教程案例26】图像特征点提取算法matlab仿真与分析——sift,surf,kaze,corner,BRISK等
  • 前端深拷贝与浅拷贝（附实现方法）
  • C#工业生产线MES系统，源代码分享
  • 2022软考高项十大领域知识整理（四）-人力资源管理、干系人管理、采购管理
  • 企业级低代码平台Jeecgboot3.4.2及3.4.3版本新功能介绍
  • SQL SERVER Sequence Number 序列号
  • 【Web实战-Tomcat-Servlet-Thymeleaf -JDBC-MySQL】浏览器页面显示数据库数据（水果库存系统）
  • 【超好懂的比赛题解】2022CCPC四川省赛 个人题解
  • Pytest如何执行txt格式的文本测试
  • 目标检测算法——YOLOv5 结合Swin Transformer V2
  • CSS3 变换
  • java8-模拟hadoop
  • node学习系列之简单文件上传
  • Puppeteer：浏览器控制器
  • 大数据与云计算学习：数据分析（二）
  • 分布式任务队列Celery
  • 分类模型——Logistics Regression
  • 技术：超级实用的电脑小技巧
  • 前端之React实战：创建跨平台的项目架构
  • 如何编写一个可升级的智能合约
  • 移动端 h5开发相关内容总结(三)
  • 中文输入法与React文本输入框的问题与解决方案
  • 3月7日云栖精选夜读 | RSA 2019安全大会：企业资产管理成行业新风向标，云上安全占绝对优势 ...
  • 翻译 | The Principles of OOD 面向对象设计原则
  • ​​​​​​​​​​​​​​Γ函数
  • ​什么是bug？bug的源头在哪里？
  • #我与Java虚拟机的故事#连载19：等我技术变强了，我会去看你的 ​
  • #在 README.md 中生成项目目录结构
  • $.ajax中的eval及dataType
  • （52）只出现一次的数字III
  • （ZT)北大教授朱青生给学生的一封信：大学，更是一个科学的保证
  • （附源码）ssm高校运动会管理系统 毕业设计 020419
  • （三维重建学习）已有位姿放入colmap和3D Gaussian Splatting训练
  • （十二）devops持续集成开发——jenkins的全局工具配置之sonar qube环境安装及配置
  • （四）七种元启发算法（DBO、LO、SWO、COA、LSO、KOA、GRO）求解无人机路径规划MATLAB
  • （转）GCC在C语言中内嵌汇编 asm __volatile__
  • （转）创业家杂志：UCWEB天使第一步
  • (转)大型网站架构演变和知识体系
  • .equals()到底是什么意思？
  • .form文件_一篇文章学会文件上传
  • .NET Core WebAPI中封装Swagger配置
  • .NET Standard 支持的 .NET Framework 和 .NET Core
  • :如何用SQL脚本保存存储过程返回的结果集
  • [ 英语 ] 马斯克抱水槽“入主”推特总部中那句 Let that sink in 到底是什么梗？
  • [1159]adb判断手机屏幕状态并点亮屏幕
  • [3300万人的聊天室] 作为产品的上游公司该如何？
  • [BUUCTF NewStarCTF 2023 公开赛道] week4 crypto/pwn
  • [C++打怪升级]--学习总目录
  • [Fri 26 Jun 2015 ~ Thu 2 Jul 2015] Deep Learning in arxiv
  • [GN] Vue3.2 快速上手 ---- 核心语法2