JDBC介绍

JDBC（Java DataBase Connectivity, Java数据库连接），是一种用于执行SQL语句的JavaAPI,为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。

JDBC访问数据库编码步骤

1：加载一个Driver驱动

2：创建数据库连接（Connection）

3：创建SQL命令发送器Statement

4：通过Statement发送SQL命令并得到结果

5：处理结果（select语句）

6：关闭数据库资源ResultSet Statement Connection

1. 准备好相应的jar包

1.进入如下网址
https://mvnrepository.com/artifact/mysql/mysql-connector-java
进入如下页面
2.选择相应的jar包
点击相应的版本(我的mysql版本是8，所以这里我用的是8.0.11)

3.点击图中标识的部分进行下载

2. 创建lib目录

3. 导入下载好的jar包

1.将jar包放入到创建好的lib目录中

2.给当前项目添加依赖(告诉当前项目/模块可以依赖jar文件中的代码)

3.如下图所示jar前面出现>表示添加依赖成功

4. 简单的CURD

1.加载驱动

// An highlighted block
Driver driver =new com.mysql.cj.jdbc.Driver();

2.注册驱动

// An highlighted block
DriverManager.registerDriver(driver);

3.获得链接 Connection
url为统一资源定位符 定位我们要连接的数据库的
1协议 jdbc:mysql
2IP 127.0.0.1/localhost
3端口号 3306
4数据库名字 mydb
5参数
协议://ip:端口/资源路径?参数名=参数值&参数名=参数值&…
jdbc:mysql://127.0.0.1:3306/mydb
user为我们数据库的账户
password为我们数据库的密码

// An highlighted block
String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
String user="root";
String password="123456";
Connection connection =DriverManager.getConnection(url, user,password );

4.获得语句对象 Statment

// An highlighted block
Statement statement = connection.createStatement();

5.执行SQL语句,返回结果
statement.executeUpdate处理插入删除更新语句

sql为我们要执行的sql语句，statement.executeUpdate处理插入删除更新语句，查询语句需要用statement.executeQuery

// An highlighted block
String sql="insert into dept values('王五',1);";
int rows = statement.executeUpdate(sql);
System.out.println("影响数据行数为:"+rows);

statement.executeQuery处理查询语句

String sql="select * from emp";
ResultSet resultSet = statement.executeQuery(sql);

执行查询语句时，得到的resultSet是数据库结果集的数据表，通常通过执行查询数据库的语句生成。我们还需对resultSet进行遍历才能得到相应的数据

String sql="select * from emp";
ResultSet resultSet = statement.executeQuery(sql);
while(resultSet.next()){int age = resultSet.getInt("age");String name = resultSet.getString("name");System.out.println("年龄为"+age+"名字为"+name);}

6.释放资源
操作完后我们要释放资源，另外释放资源要有先后顺序，后获得的先关闭,先获得的后关闭.

statement.close();
connection.close();

7.插入删除更新完整代码

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.Statement;public class TestJDBC {public static void main(String[] args) throws Exception {Driver driver =new com.mysql.cj.jdbc.Driver();DriverManager.registerDriver(driver);String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection connection =DriverManager.getConnection(url, user,password );Statement statement = connection.createStatement();String sql="insert into dept values('王五',1);";int rows = statement.executeUpdate(sql);System.out.println("影响数据行数为:"+rows);statement.close();connection.close();}
}

8.查询语句完整代码

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.Statement;public class TestJDBC {public static void main(String[] args) throws Exception {Driver driver =new com.mysql.cj.jdbc.Driver();DriverManager.registerDriver(driver);String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection connection =DriverManager.getConnection(url, user,password );Statement statement = connection.createStatement();String sql="select * from people";ResultSet resultSet = statement.executeQuery(sql);while(resultSet.next()){int age = resultSet.getInt("age");String name = resultSet.getString("name");System.out.println("年龄为"+age+"名字为"+name);}statement.close();connection.close();}
}

5. PreparedStatment完成CURD

5.1 PreparedStatment和Statement的区别

前面我们注意到我们获取语句对象是用statement获取的(也就是获取sql语句和获取mysql的账户密码URL等属性)，但是在使用Statment获取sql语句的使用会出现sql注入攻击的问题，sql注入攻击是指是通过构建特殊的输入作为参数传入Web应用程序，而这些输入大都是SQL语法里的一些组合，通过执行SQL语句进而执行攻击者所要的操作，其主要原因是程序没有细致地过滤用户输入的数据，致使非法数据侵入系统。简单来说我们可以在不知用户密码的情况下登录账户

通过上面的语句我们可以看到无论密码正确与否都会成功登录，那么给用户带来的风险是非常大的

那么PreparedStatment和Statement的区别什么呢？

从上面的图片中我们可以看出PreparedStatement继承了Statement，其中prepareStatment对象在set***方法上,会对单引号进行转译处理,也就是说,?中的数据的单引号 ‘ 会被转义成 \’,这样就单引号就不会破坏sql语句的结构,这样就不会出现输入错误密码也能登录账户的问题

5.2PrepareStatement的优点

PreparedStatment安全性高,可以避免SQL注入
PreparedStatment简单不繁琐,不用进行字符串拼接
PreparedStatment性能高，用在执行多个相同数据库DML操作时,可以减少sql语句的编译次数

5.3具体代码实现

5.3.1向表中加入数据
在这里我们新引入了一点知识，用 Class.forName(driver);代码可以实现创建驱动和注册驱动节省代码。，其中的driver就是"com.mysql.cj.jdbc.Driver"。

public static void testAdd(){Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="insert into people values(?,?)";preparedStatement = connection.prepareStatement(sql)//设置参数preparedStatement.setString(1,"王五");preparedStatement.setString(2,"1" );//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}

PreparedStatement不是直接使用一条sql完成操作，而是用？来代替要传入的值，然后在通过set###方法进行设置,这里要注意我们可以根据我们要传入的参数类型进行设置set###方法，比如传入Int值用setInt，String用setString，其它的一样,当然你也可以使用setObject设置，可以通用
5.3.2修改表中的数据

 public static void testUpdate(){Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="update people set age =?  where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"2");preparedStatement.setString(2,"王五" );//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}

5.3.3删除表中的数据

 Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="delete from people where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"王五");//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}

5.3.4查询表中的数据

public static void testQuery(){Connection connection = null;PreparedStatement preparedStatement=null;ResultSet resultSet=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="select * from people where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"张三");//执行CURDresultSet = preparedStatement.executeQuery();// 这里不需要再传入SQL语句while(resultSet.next()){int age = resultSet.getInt("age");String name = resultSet.getString("name");System.out.println("姓名为"+name+""+"年龄为"+age);}}catch (Exception e){e.printStackTrace();}finally {if(null != resultSet){try {resultSet.close();} catch (SQLException e) {e.printStackTrace();}}if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}// 遍历集合}

5.3.5全部完整代码

import java.sql.*;public class abc{private static String driver ="com.mysql.cj.jdbc.Driver";private static String url="jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true";private static String user="root";private static String password="123456";public static void main(String[] args) {//testAdd();//testUpdate();//testDelete();testQuery();}public static void testAdd(){Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="insert into people values(?,?)";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"王五");preparedStatement.setString(2,"1" );//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}public static void testUpdate(){Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="update people set age =?  where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"2");preparedStatement.setString(2,"王五" );//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}public static void testDelete(){Connection connection = null;PreparedStatement preparedStatement=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="delete from people where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"王五");//执行CURDint rows =preparedStatement.executeUpdate();// 这里不需要再传入SQL语句System.out.println(rows);}catch (Exception e){e.printStackTrace();}finally {if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}public static void testQuery(){Connection connection = null;PreparedStatement preparedStatement=null;ResultSet resultSet=null;try{Class.forName(driver);connection = DriverManager.getConnection(url, user,password);String sql="select * from people where name =?";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setString(1,"张三");//执行CURDresultSet = preparedStatement.executeQuery();// 这里不需要再传入SQL语句while(resultSet.next()){int age = resultSet.getInt("age");String name = resultSet.getString("name");System.out.println("姓名为"+name+""+"年龄为"+age);}}catch (Exception e){e.printStackTrace();}finally {if(null != resultSet){try {resultSet.close();} catch (SQLException e) {e.printStackTrace();}}if(null != preparedStatement){try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if(null != connection){try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}}

6.DAO模式

DAO (DataAccessobjects 数据存取对象)是指位于业务逻辑和持久化数据之间实现对持久化数据的访问。通俗来讲，就是将数据库操作都封装起来。简单来说就是创建一个接口里边有实现方法，在创建一个表的实现类，类中有表中的具体属性
从以上 DAO 模式使用可以看出，DAO 模式的优势就在于它实现了两次隔离。

1、隔离了数据访问代码和业务逻辑代码。业务逻辑代码直接调用DAO方法即可，完全感觉不到数据库表的存在。分工明确，数据访问层代码变化不影响业务逻辑代码,这符合单一职能原则，降低了藕合性，提高了可复用性。
2、隔离了不同数据库实现。采用面向接口编程，如果底层数据库变化，如由 MySQL 变成 Oracle 只要增加 DAO 接口的新实现类即可，原有 MySQ 实现不用修改。这符合 “开-闭” 原则。该原则降低了代码的藕合性，提高了代码扩展性和系统的可移植性。

DAO 模式需要由以下几部分组成。

1、DAO接口： 把对数据库的所有操作定义成抽象方法，可以提供多种实现。
2、DAO 实现类： 针对不同数据库给出DAO接口定义方法的具体实现。
3、实体类：用于存放与传输对象数据，类中的属性和表中的属性相同。
4、数据库连接和关闭工具类： 避免了数据库连接和关闭代码的重复使用，方便修改。
实体类：

import java.io.Serializable;public class People implements Serializable {private String name;private Integer age;public People(String name, Integer age) {this.name = name;this.age = age;}public People() {}public String getName() {return name;}public void setName(String name) {this.name = name;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}@Overridepublic String toString() {return "People{" +"name='" + name + '\'' +", age=" + age +'}';}
}

DAO接口：

public interface PeopleDao {int addpeople(People people);
}

DAO实现类：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class PeopleDaoImpl implements PeopleDao {private static String driver = "com.mysql.cj.jdbc.Driver";private static String url = "jdbc:mysql://127.0.0.1:3306/mydb?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true";private static String user = "root";private static String password = "123456";public int addpeople (People people){Connection connection = null;PreparedStatement preparedStatement = null;int rows = 0;try {Class.forName(driver);connection = DriverManager.getConnection(url, user, password);String sql = "insert into emp values(?,?)";preparedStatement = connection.prepareStatement(sql);//这里已经传入SQL语句//设置参数preparedStatement.setObject(1, people.getName());preparedStatement.setObject(2, people.getAge());//执行CURDrows = preparedStatement.executeUpdate();// 这里不需要再传入SQL语句} catch (Exception e) {e.printStackTrace();} finally {if (null != preparedStatement) {try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if (null != connection) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}return rows;}
}

创建主方法调用即可

 People people = new People("王五", 1);PeopleDaoImpl peopleDao= new PeopleDaoImpl();peopleDao.addpeople(people);

以上就是文章的全部内容，本文所有的代码均是在作者电脑是哪个运行之后才放上去的可直接复制使用，随着作者以后技术的精进会继续完善文章，改文章可能也会有错误的地方，希望大家能给我留言我会及时做出修改，欢迎大家的批评指正。

转载文章请注明出处。

JDBC连接数据库详细讲解及代码演示相关推荐

1. 【OS系列-2】- 进程详细讲解（代码示例）

   进程 进程详细讲解(代码示例) 进程 示例代码 创建进程的具体过程? 执行 fork()的时候系统做了什么? 进程间通信 管道 消息队列 共享内存 信号量 套接字 进程间同步 信号量 文件锁 无锁 C ...

2. lamport面包店算法详细讲解及代码实现

   lamport面包店算法详细讲解及代码实现 1 算法详解 1.1 一个较为直观的解释 1.2 Lamport算法的时间戳原理 1.3 Lamport算法的5个原则 1.4 一个小栗子 2 算法实现 3 ...

3. linux下的fgetc（）与fputc（）函数详细介绍及代码演示

   linux下的标准I/O的fgetc()与fputc()函数详细介绍及代码演示 文章目录 前言 一.fgetc()用法介绍 二.fputc()用法介绍 代码演示 总结 前言 在C语言中,读写文件比较灵 ...

4. 深度学习：NiN（Network In Network）详细讲解与代码实现

   深度学习:NiN(Network In Network)详细讲解与代码实现 网络核心思想 1*1卷积 NiN块的作用 全局池化(Global Average Pooling) 基于NiN的服装分类(P ...

5. Java对象，Map，List，Set数组等相互转换大全（详细讲解,附代码，讲解案例）

   Java对象,Map,List,Set数组等相互转换大全(详细讲解,附代码,讲解案例) Java对象 转 JSON字符串 JAVA对象转MAP Map转java对象 List转map List和Map ...

6. JDBC连接数据库详细步骤

   一.先创建一个项目 二.打开数据库并启动连接 (我是在IDEA中写的,提前导包) 三.不会导包就在Maven中导,在pom.xml中的dependencise放,版本号看自己要高版本还是低版本.放进去 ...

7. HMM详细讲解与代码的实现

   #写在前面 老习惯,正文之前瞎扯一通.HMM学了很久,最初是在<统计学自然语言处理>里面就学到了相关内容,并且知道HMM CRF一直都是NLP比较底层比较基础且较为有效的算法模型(虽然感觉 ...

8. Python的简单代码：两天肝出画函数图像（散点图）的程序（不用matplotlib）（含白菜也能看懂的超超超详细讲解和源代码哦）

   [ 原创作者:小康2021 ](12.08已更新) 该程序(玩具)基本上支持任何普通函数和 math 模块中的函数,具体操作说明见下面的效果图.博主能力有限(所以初学者百分之百也能看懂我的代码),爆肝 ...

9. 数学建模学习（29）：matlab求解微分方程组详细讲解，代码+案例讲解，学不会找我！

   文章目录 前言 求解微分方程组 求解矩阵微分方程组 总结 前言 上一篇我已经详细讲过求微分方程,这一篇是对上一篇的补充,也就是变得稍微复杂一点,就是要求方程组了,如果你学会了上一篇,那么求解方程组其实 ...

最新文章

1. linux db2 修改日志路径,db2中更改日志文件大小及其个数
2. 网站标题如何设计才更有利于网站优化呢？
3. 保监会：《保险公司信息系统安全管理指引（试行）》
4. Linux IPC POSIX 消息队列
5. 自学机器学习、深度学习、人工智能的学习资源集合
6. bzoj 2330: [SCOI2011]糖果
7. 2019年房贷利率会下调吗？
8. 面试被问mysql扩展性设计相关的点，你知道该如何回答吗
9. C++构造函数的各种用法全面解析（C++初学面向对象编程）
10. 容易被PHP程序员忽视的几个要点
11. 单例模式中的饿汉模式
12. 一道看似简单的sql需求却难倒各路高手 - 你也来挑战下吗？
13. 用cookie实现查看浏览记录
14. 青岛大学计算机分专业吗,青岛大学热门专业有哪些？附青岛大学最低分专业名单...
15. 2022年版中国共享单车市场现状调研及投资前景预测报告
16. 灰度图像增强和图像去噪
17. linux前一个的输出作为后一个参数,将Linux命令的结果作为下一个命令的参数
18. 大数据时代下，医疗行业如何实现数据安全保障？
19. 杨致远：雅虎的华裔酋长(附图)
20. php 图片mete_data,进入多摄时代后，摄像头成了手机的「第二张脸」

热门文章

1. 华为eNSP: OSPF+RIP实验
2. 英语自我介绍思维导图
3. day09 书城项目第三阶段
4. 隐私计算头条周刊（2.13-2.19）
5. 机QQ：跌倒在Cosplay微信的舞台上
6. 炫界 (392) -(持法延迟)_Apex英雄支持NVIDIA Reflex 华硕显卡低延迟利器
7. 【Java代码实现飞机大战小游戏】简单理解
8. php是脚本吗,php是脚本吗-PHP问题
9. springboot集成groovy脚本环境
10. 【MEF：深度感知增强（细节增强：色彩映增强）】