【MySQL】_JDBC

news2024/11/24 12:06:54

目录

1. JDBC原理

2. 导入JDBC驱动包

3. 编写JDBC代码实现Insert

3.1 创建并初始化一个数据源

3.2 和数据库服务器建立连接

3.3 构造SQL语句

3.4 执行SQL语句

3.5 释放必要的资源

4. JDBC代码的优化

4.1 从控制台输入

4.2 避免SQL注入的SQL语句

5. 编写JDBC代码实现Select

1. JDBC原理

1. 各种数据库如MySQL、Oracle、SQLServer等，在开始时会提供一组编程接口（API），

API即application programming interface，即代码层次上的提供的功能，API往往是通过函数或类的形式来提供的。

2. 不同的数据库系统的API是不同的JDBC就是统一Java与数据库连接的一套规范的API：

3.Java程序员如果想要进行数据库开发，就需要在项目中导入对应数据库的驱动包，才能编写代码。

4. 驱动包是数据库厂商提供的，此处以MySQL为例，获取方式有：

（1）从MySQL官网获取（现为Oracle官网的一个子网）；

（2）github；

（3）maven中央仓库；

注：中央仓库可以理解为一个服务器，托管了各种软件程序包，maven就类似于应用商店，通过应用商店就可以访问到应用程序包并进行下载；

2. 导入JDBC驱动包

3. 编写JDBC代码实现Insert

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class JDBCInsert {
    public static void main(String[] args) throws SQLException {
        // 1. 创建并初始化一个数据源；
        DataSource dataSource = new MysqlDataSource();
        // 把dataSource对象转为MysqlDataSource类型
        // setUrl是MysqlDataSource类的方法要调用需先将对象转为MysqlDataSource类型
        ((MysqlDataSource)dataSource).setUrl
                ("jdbc:mysql://127.0.0.1:3306/JDBCProgram?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxx");

        // 2. 和数据库服务器建立连接；
        Connection connection =  dataSource.getConnection();

        // 3. 构造 SQL 语句
        String sql = "insert into student values(1, 'Mike')";
        // 使用PreparedStatement对sql语句进行预编译
        PreparedStatement statement = connection.prepareStatement(sql);

        // 4. 执行 SQL 语句
        int ret = statement.executeUpdate();
        System.out.println("ret = "+ ret);

        // 5. 释放必要的资源
        statement.close();
        connection.close();
    }
}

 运行代码，在idea控制台有：

并在MySQL中查看Student表结果：

mysql> select* from student;
+------+------+
| id   | name |
+------+------+
|    1 | Mike |
+------+------+
1 row in set (0.00 sec)

编写JDBC代码需要以下五个步骤：

3.1 创建并初始化一个数据源

（1）数据源即数据的源头，此处数据来源于数据库，即此处要描述数据库服务器在哪里；

数据库中使用DataSourse接口进行描述；

（2）在创建并初始化一个数据源，也可以无需向上转型+向下转型，直接使用MysqlDataSource：

MysqlDataSource dataSource = new MysqlDataSource();

只是在向上转型+向下转型的写法比较流行，二者均可使用；

（3）URL即唯一资源定位符，用于描述网络上某个资源所在的位置，此处设置为：

((MysqlDataSource)dataSource).setUrl
                ("jdbc:mysql://127.0.0.1:3306/JDBCProgram?characterEncoding=utf8&useSSL=false");

① jdbc是固定的，mysql为连接的哪一个库；

② 127.0.0.1为本地回环地址，表示本主机；

③ 3306为数据库服务器默认端口号，标记某一主机上的进程；

④ JDBCProgram为数据库名（自行创建）；

⑤ characterEncoding=utf8&useSSL=false分别表示字符集为utf8和不加密，SSL是一个加密协议；

（3）除设置URL之外，还需设置User和Passward才能访问数据库服务器，用户名默认为root，密码为安装数据库时的密码；

（4）经过第一步后，只是描述了数据库的位置与用户名、密码等，还没有进行连接；

3.2 和数据库服务器建立连接

（1）使用getConnection方法与数据库服务器建立连接，并用Connection类型的变量来接受返回值，注意选择第一个jdbc的Connection：

（2）如果getConnection方法正常运行则连接建立成功，如果连接建立失败会直接抛异常;

3.3 构造SQL语句

基于以下数据库与数据表：

mysql> use jdbcprogram
Database changed
mysql> show tables;
+-----------------------+
| Tables_in_jdbcprogram |
+-----------------------+
| student               |
+-----------------------+
1 row in set (0.00 sec)

mysql> desc student;
+-------+-------------+------+-----+---------+-------+
| Field | Type        | Null | Key | Default | Extra |
+-------+-------------+------+-----+---------+-------+
| id    | int(11)     | YES  |     | NULL    |       |
| name  | varchar(20) | YES  |     | NULL    |       |
+-------+-------------+------+-----+---------+-------+
2 rows in set (0.00 sec)

 （1）构造的SQL语句与在MySQL中构造的规定相同；

（2）如果请求是个SQL字符串，服务器是可以处理的。服务器就需要对SQL进行解析。

客户端数目庞大时会导致服务器压力很大，故而在客户端使用PreparedStatement对SQL语句进行预编译，就可以减轻服务器的压力；

3.4 执行SQL语句

（1）注意SQL语句的insert、delete和update操作都是使用executeUpdate方法进行执行的，返回值是int类型数据，表示影响的行数；

（2）select操作使用的是executeQuery方法；

3.5 释放必要的资源

（1）数据库的客户端与服务器进行通信时，会消耗一定的系统资源，如CPU、内存、硬盘、带宽等等。为了防止服务器同时处理多个客户端造成系统资源受限，当客户端不使用服务器时，就对资源进行释放；

（2）语句与连接均需要释放，需要先释放语句再释放连接。

释放的顺序与创建的顺序是相反的。

（3）除Datsource之外，还有一种DriverManager的写法，这种写法是通过反射的方式加载驱动包中的类，进一步进行后续操作的。

但并不建议使用这种写法，反射属于java开发的特殊手段，其代码可读性非常差，编译期难以对代码的正确性进行检查，容易产生运行时异常，建议不到万不得已不要使用反射；

并且DataSource内置了数据库连接池，可以复用连接，提高连接服务器的效率；

4. JDBC代码的优化

对于上文的JDBC代码，要插入的数据是硬编码，但是让用户编码是不现实的，故而需要将数据通过其他方式供用户输入。

4.1 从控制台输入

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

public class JDBCInsert {
    public static void main(String[] args) throws SQLException {
        Scanner scanner = new Scanner(System.in);
        // 1. 创建并初始化一个数据源；
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setUrl
                ("jdbc:mysql://127.0.0.1:3306/JDBCProgram?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxx");

        // 2. 和数据库服务器建立连接；
        Connection connection =  dataSource.getConnection();

        // 3. 从控制台读取用户输入的内容
        System.out.println("请输入学生姓名：");
        String name = scanner.next();
        System.out.println("请输入学生学号：");
        int id = scanner.nextInt();

        // 4. 构造 SQL 语句
        String sql = "insert into student values(" + id + ", '"+name + "')";
        // 预编译
        PreparedStatement statement = connection.prepareStatement(sql);

        // 5. 执行 SQL 语句
        int ret = statement.executeUpdate();
        System.out.println("ret = "+ ret);

        // 6. 释放必要的资源
        statement.close();
        connection.close();
    }
}

运行代码，在控制台输入一下信息： 

在mysql中查看Student表：

mysql> select* from student;
+------+------+
| id   | name |
+------+------+
|    1 | Mike |
|    2 | Mary |
+------+------+
2 rows in set (0.00 sec)

4.2 避免SQL注入的SQL语句

在上例代码中，构造的SQL语句为：

String sql = "insert into student values(" + id + ", '"+name + "')";

如果用户输入的name形如：王五');select* from ***，导致看似一条SQL语句变为多个语句，就会出现SQL注入问题，如果再携带drop database之类的语句，可能会对系统造成更大的伤害。

针对以上问题，可以借助PreparedStatement的拼装功能实现：

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

public class JDBCInsert {
    public static void main(String[] args) throws SQLException {
        Scanner scanner = new Scanner(System.in);
        // 1. 创建并初始化一个数据源；
        DataSource dataSource = new MysqlDataSource();
        // 把dataSource对象转为MysqlDataSource类型
        // setUrl是MysqlDataSource类的方法要调用需先将对象转为MysqlDataSource类型
        ((MysqlDataSource)dataSource).setUrl
                ("jdbc:mysql://127.0.0.1:3306/JDBCProgram?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxx");

        // 2. 和数据库服务器建立连接；
        Connection connection =  dataSource.getConnection();

        // 3. 从控制台读取用户输入的内容
        System.out.println("请输入学生姓名：");
        String name = scanner.next();
        System.out.println("请输入学生学号：");
        int id = scanner.nextInt();

        // 4. 构造 SQL 语句
        String sql = "insert into student values(?, ?)";
        // 使用PreparedStatement对sql语句进行预编译
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1, id);
        statement.setString(2, name);
        // 打印statement需在拼接数据之后
        System.out.println(statement);
        // 5. 执行 SQL 语句
        int ret = statement.executeUpdate();
        System.out.println("ret = "+ ret);

        // 6. 释放必要的资源
        statement.close();
        connection.close();
    }
}

输入学生姓名与学号后，控制台输出结果如下：

在mysql中查看Student表：

mysql> select* from student;
+------+------+
| id   | name |
+------+------+
|    1 | Mike |
|    2 | Mary |
|    3 | John |
+------+------+
3 rows in set (0.00 sec)

注：（1）构造的SQL语句中的2个?是两个占位符，statement.setInt与statement.setString方法就可以把占位符替换为指定的值，

        statement.setInt(1, id);
        statement.setString(2, name);

分别表示将第一个占位符替换为id的值，第二个占位符替换为name的值，当用户输入给id和name赋值后，就会通过该方法自动替换；

（2）可以使用打印statement的方法查看具体拼接情况，需将该语句置于拼接数据之后；

假如代码执行出错了也可以把statement打印出来查看具体语法是否出错；

5. 编写JDBC代码实现Select

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class JDBCSelect {
    public static void main(String[] args) throws SQLException {
        // 1. 创建并初始化数据源
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setUrl
                ("jdbc:mysql://127.0.0.1:3306/JDBCProgram?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("97805");
        // 2. 建立连接
        Connection connection = dataSource.getConnection();
        // 3. 构造SQL语句
        String sql = "select* from Student";
        PreparedStatement statement = connection.prepareStatement(sql);
        // 4. 执行SQL语句
        ResultSet resultSet = statement.executeQuery();
        // 5. 遍历结果集合
        while(resultSet.next()){
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");
            System.out.println("id = " + id +", name = " + name);
        }
        // 6. 释放资源
        resultSet.close();
        statement.close();
        connection.close();
    }
}

控制台输出结果为：

 

注：（1）执行SQL的语句为：

ResultSet resultSet = statement.executeQuery();

对比SQL实现Insert的executeUpdate方法返回的是一个int类型数据，实现Select的executeQuery方法返回的是一个ResultSet类型对象。

该对象可以视为是一张表，初始时光标指向表首行，可以使用getXXX方法获取当前光标指向的行的数据。每调用一次next，就使光标下移一行，当光标遍历完整张表，再调用next时，就会返回false；

（2）getXXX方法用于取出这一行指定列的值，使用的方法要与列的类型匹配；

参数可以是第几列的下标，也可以是列名，更推荐使用列名；

        while(resultSet.next()){
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");
            System.out.println("id = " + id +", name = " + name);
        }

（3）实现Select的程序在释放资源时，相较于Insert，需要多释放一个resultSet，可以将查询结果的临时表视为一个resultSet；

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1230023.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【SpringBoot3+Vue3】四【基础篇】-前端（vue基础）

【SpringBoot3+Vue3】四【基础篇】-前端（vue基础）

目录 一、项目前置知识 二、使用vscode创建 三、vue介绍 四、局部使用vue 1、快速入门 1.1 需求 1.2 准备工作 1.3 操作 1.3.1 创建html 1.3.2 创建初始html代码 1.3.3 参照官网import vue 1.3.4 创建vue应用实例 1.3.5 准备div 1.3.6 准备用户数据 1.3.7 通过…
阅读更多...
Matlab论文插图绘制模板第127期—进阶气泡矩阵/热图

Matlab论文插图绘制模板第127期—进阶气泡矩阵/热图

​在之前的文章中，分享了Matlab散点图矩阵的绘制模板： 也分享过气泡矩阵图的绘制模板： 考虑到规范性和便捷性，再来分享一下进阶版的气泡矩阵/热图。 先来看一下成品效果： 特别提示：本期内容『数据代码』已…
阅读更多...
PlayCover“模拟器”作弊解决方案

PlayCover“模拟器”作弊解决方案

当下的游戏市场，移动游戏已占据了主导地位，但移动端游戏碍于屏幕大小影响操作、性能限制导致卡顿等因素，开始逐步支持多端互通。但仍有一些游戏存在移动端与 PC 端不互通、不支持 PC 端或没有 Mac 版本，导致 Mac 设备体验游戏不方…
阅读更多...
通信原理板块——纠错编码的基本原理和性能

通信原理板块——纠错编码的基本原理和性能

微信公众号上线，搜索公众号小灰灰的FPGA,关注可获取相关源码，定期更新有关FPGA的项目以及开源项目源码，包括但不限于各类检测芯片驱动、低速接口驱动、高速接口驱动、数据信号处理、图像处理以及AXI总线等 1、分组码 将信息码分组&#xff0…
阅读更多...
CleanMyMac X2024免费测试版好不好用？值不值得下载

CleanMyMac X2024免费测试版好不好用？值不值得下载

如果你是一位Mac用户，你可能会遇到一些问题，比如Mac运行缓慢、磁盘空间不足、应用程序难以管理等。这些问题会影响你的Mac的性能和体验，让你感到沮丧和无奈。那么，有没有一款软件可以帮助你解决这些问题呢？答案是肯定的…
阅读更多...
109.firefly-extboot的生成脚本

109.firefly-extboot的生成脚本

内核版本： 4.4.194 在firefly的sdk 2.5.1c及以后的版本都是extboot.img（对应表中的extboot） 但是之前的并不是，而且一个boot.img，（对应表中rkboot） rkboot的生成方法可以参考解决linux5.15编…
阅读更多...
二、什么是寄存器

二、什么是寄存器

目录 一、STM32芯片架构简图及系统框图 1.1 STM32芯片架构简图 1.1.1 FLASH是什么，用来做什么 1.1.2 SRAM是什么，用来做什么 1.1.3 片上外设是什么，用来做什么 1.2 系统框图 1.2.1 驱动单元 1.2.2 被动单元 二、什么是寄存器 2.1 存…
阅读更多...
Cannot find proj.db

Cannot find proj.db

原因 编译GDAL完成后，我打了个包(包括.so)移动到了另外同环境的机器上。 应用gdal ogr2ogr时候提示找不到proj.db 解决办法： 把proj的share拷贝到另外环境上。 #gdal新建othershare，proj的share复制过去 mkdir -p /usr/local/gdal-3.6.2…
阅读更多...
通达信的ebk文件

通达信的ebk文件

我们在通达信软件中 调出 “自定义板块设置” 这个菜单，点击“导出”，会提示你存储 “自选股.EBK”，其实就是对自定义板块里的目录进行备份的一种方式， 当我们打开 这个文件，你会发现其实就是存储了 股票代码&#xff…
阅读更多...
python 自动化福音，30行代码手撸ddt模块

python 自动化福音，30行代码手撸ddt模块

用 python 做过自动化的小伙伴，大多数都应该使用过 ddt 这个模块，不可否认 ddt 这个模块确实挺好用，可以自动根据用例数据，来生成测试用例，能够很方便的将测试数据和测试用例执行的逻辑进行分离。 接下来就带大家一起…
阅读更多...
微服务：何为RPC框架

微服务：何为RPC框架

前言 最近在看有关分布式和微服务的知识，首先第一个碰到的就是RPC框架，常见的RPC框架其实有很多，比较常见的比如：阿里的Dubbo、ApacheThrift、谷歌的gRPC、腾讯的tRPC等等。RPC作为远程调用协议在微服务架构中可以说是比较常见了&…
阅读更多...
基于GATK流程化进行SNP calling

基于GATK流程化进行SNP calling

在进行变异检测时，以群体基因组重测序数据为例，涉及到的个体基本都是上百个，而其中大多数流程均是重复的步骤。 本文将基于GATK进行SNP calling的流程写入循环，便于批量分析。 1 涉及变量 1.工作目录work_dir/ 2.参考基因组ref…
阅读更多...
每天一点python——day74

每天一点python——day74

#每天一点Python——74 #函数调用的参数传递：位置与关键字函数参数传递指的是函数调用时候的传递 一般有两种： 位置实参传递 关键字实参传递#位置实参传递 #我们昨天定义了一个函数 def jiafa(a,b):#我们定义了两个参数，a和b，他们…
阅读更多...
用公式告诉你 现货黄金投资者要不要换策略？

用公式告诉你 现货黄金投资者要不要换策略？

看过笔者相关文章的朋友都知道，其实笔者是相当不鼓励投资者更改策略的。但这并不意味着，策略不能改或者换。之所以反对更改策略，是因为很多人对自己的策略还没上手，没了解清楚就急着换策略，这是没必要的。通过下面这个…
阅读更多...
1688商品详情原数据（2023年11月最新版）

1688商品详情原数据（2023年11月最新版）

返回数据&#xff1a; 请求链接 {"item": {"desc_wdescContent": {"itemProperties": [],"offerId": "705844836943","wdescContent": {"content": "<div id\"offer-template-0\"&g…
阅读更多...
【实用干货】如何用LightningChart创建WPF 2D热图？（一）

【实用干货】如何用LightningChart创建WPF 2D热图？（一）

LightningChart.NET完全由GPU加速&#xff0c;并且性能经过优化&#xff0c;可用于实时显示海量数据-超过10亿个数据点。 LightningChart包括广泛的2D&#xff0c;高级3D&#xff0c;Polar&#xff0c;Smith&#xff0c;3D饼/甜甜圈&#xff0c;地理地图和GIS图表以及适用于科学…
阅读更多...
如何看待阿里云发布的全球首个容器计算服务 ACS？

如何看待阿里云发布的全球首个容器计算服务 ACS？

如何看待阿里云发布的全球首个容器计算服务 ACS&#xff1f; 本文目录&#xff1a; 前言 一、什么是ACS 二、ACS 的核心特性 三、ACS 的关键技术 四、本期话题讨论 4.1、你如何看待容器计算服务 ACS 的发布&#xff1f; 4.2、你认为 ACS 的产品设计能降低企业使用 K8s的…
阅读更多...
Springboot+vue的机动车号牌管理系统（有报告）。Javaee项目，springboot vue前后端分离项目

Springboot+vue的机动车号牌管理系统（有报告）。Javaee项目，springboot vue前后端分离项目

演示视频: Springbootvue的机动车号牌管理系统&#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot vue前后端分离项目 项目介绍&#xff1a; 本文设计了一个基于Springbootvue的前后端分离的机动车号牌管理系统&#xff0c;采用M&#xff08;model&#xff09…
阅读更多...
【如何让你的建筑设计更高效】推荐7个3DMAX建筑设计的实用插件

【如何让你的建筑设计更高效】推荐7个3DMAX建筑设计的实用插件

3DMAX是创建具有复杂对象和照片级真实感材质的大型三维项目的绝佳工具。它有用于粒子模拟和参数化建模的内置工具&#xff0c;只要有足够的时间和练习&#xff0c;你就可以创建任何东西。然而&#xff0c;总有改进的余地。许多第三方开发人员已经发布了自己的扩展&#xff0c;也…
阅读更多...
ChatGPT API 学习

ChatGPT API 学习

参考&#xff1a;从零开始的 ChatGPT API 使用指南&#xff0c;只需三步&#xff01; - 知乎 (zhihu.com) ChatGPT API 是一种由 OpenAI 提供的 API&#xff0c;它可以用最简单的方式把 ChatGPT 的聊天能力接入到各种应用程序或服务中。 自然语言语音识别(Natural Language S…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023