Java实现数据库连接的最详细教程分享
作者：无声编码器 发布时间：2024-01-28 01:34:15
标签：Java,数据库,连接
JDBC，Java Database Connectivity，即 Java 数据库连接。实际上 JDBC 是 Java 中的一套和数据库进行交互的API。
因为 Java 程序员需要连接多种数据库，为了避免每一个数据库都学习一套新的API，SUN公司提出一个JDBC接口，各个数据库厂商根据接口写实现类（驱动），这样 Java 程序员只需要掌握 JDBC 接口中的一套方法，就可以访问任何数据库。
使用 JDBC 可以创建一个 Maven 工程，使用 Maven 工具便捷的下载 MySQL 驱动相关 Jar 包。使用实例如下：
1.创建 Maven 工程
使用 IntelliJ IDEA 新建工程，选择 Maven 工程：
设置项目名称：
2.添加 MySQL 驱动依赖 Jar 包
在 Maven 工程的 pom.xml 文件中加入 MySQL 驱动依赖，并下载 Jar 包：
3.创建一个测试使用的 MySQL 数据库
// 创建名为 test_base 的数据库
CREATE DATABASE test_base;
// 使用 test_base 数据库
USE test_base;
// 创建名为 websites 的表
CREATE TABLE `websites` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` char(20) NOT NULL DEFAULT '' COMMENT '站点名称',
`url` varchar(255) NOT NULL DEFAULT '',
`alexa` int(11) NOT NULL DEFAULT '0' COMMENT 'Alexa 排名',
`country` char(10) NOT NULL DEFAULT '' COMMENT '国家',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;
// 在 websites 中插入数据
INSERT INTO `websites` VALUES ('1', 'Google', 'https://www.google.cm/', '1', 'USA'),
('2', '淘宝', 'https://www.taobao.com/', '13', 'CN'),
('3', '菜鸟教程', 'http://www.runoob.com', '5892', ''),
('4', '微博', 'http://weibo.com/', '20', 'CN'),
('5', 'Facebook', 'https://www.facebook.com/', '3', 'USA'),
('6', 'JueJin', 'https://www.juejin.cn/', '2213', 'CN');
4.创建 Java 文件，编写 JDBC 相关代码
import java.sql.*;
/**
* @Author：WG
* @Package：PACKAGE_NAME
* @Project：JDBCTest
* @name：MySQLDemo
* @Date：2023/5/17 21:35
* @Filename：MySQLDemo
*/
public class MySQLDemo {
// MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/test_base?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
// MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
//static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
//static final String DB_URL = "jdbc:mysql://localhost:3306/test_base?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
// 数据库的用户名与密码，需要根据自己的设置
static final String USER = "root";
static final String PASS = "root";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try{
// 注册 JDBC 驱动
Class.forName(JDBC_DRIVER);
System.out.println("连接数据库...");
// 获取连接对象
conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println(" 实例化Statement对象...");
// 创建 Sql 执行对象
stmt = conn.createStatement();
// Sql 查询语句
String sql = "SELECT id, name, url FROM websites";
// 执行 Sql
ResultSet rs = stmt.executeQuery(sql);
// 展开结果集数据库，next()会判断有无下条数据，有的话返回 true
while(rs.next()){
// 通过字段检索
int id = rs.getInt("id");
String name = rs.getString("name");
String url = rs.getString("url");
// 输出数据
System.out.print("ID: " + id);
System.out.print(", 站点名称: " + name);
System.out.print(", 站点 URL: " + url);
System.out.print("\n");
}
// 完成后关闭
rs.close();
stmt.close();
conn.close();
}catch(SQLException se){
// 处理 JDBC 错误
se.printStackTrace();
}catch(Exception e){
// 处理 Class.forName 错误
e.printStackTrace();
}finally{
try{
// 关闭资源
if(stmt!=null) stmt.close();
}catch(SQLException se2){
// 什么都不做
}
try{
if(conn!=null) conn.close();
}catch(SQLException se){
se.printStackTrace();
}
}
System.out.println("Goodbye!");
}
}
// 程序运行结果如下：
// 连接数据库...
// 实例化Statement对象...
// ID: 1, 站点名称: Google, 站点 URL: https://www.google.cm/
// ID: 2, 站点名称: 淘宝, 站点 URL: https://www.taobao.com/
// ID: 3, 站点名称: 菜鸟教程, 站点 URL: http://www.runoob.com
// ID: 4, 站点名称: 微博, 站点 URL: http://weibo.com/
// ID: 5, 站点名称: Facebook, 站点 URL: https://www.facebook.com/
// ID: 6, 站点名称: JueJin, 站点 URL: https://www.juejin.cn/
// Goodbye!
DBCP - 数据库连接池
数据库连接池可以预先设置一定数量的初始连接，如果有业务需要使用连接，则从连接池中直接获取，如果连接池中连接用光，这些连接请求将被加入到等待队列中，等待连接归还后再获取连接。
数据库连接池避免了每一次业务都需要和数据库服务器建立一次连接，业务处理完成后再断开连接，因为频繁的开关连接非常的浪费资源，甚至造成服务器崩溃。
DBCP 使用实例：
1.使用数据库连接池需要在 Maven 工程的 pom.xml 文件中加入依赖，并下载 Jar 包：
<!-- dependencies标签主要用于管理项目中需要引入的其他依赖 -->
<dependencies>
<!--mysql驱动-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.39</version>
</dependency>
<!--数据库连接池-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-dbcp2</artifactId>
<version>2.1.1</version>
</dependency>
</dependencies>
2.创建 Java 文件，编写 JDBC 相关代码：
import org.apache.commons.dbcp2.BasicDataSource;
import java.sql.*;
/**
* @Author：WG
* @Package：PACKAGE_NAME
* @Project：JDBCTest
* @name：DBCPDemo
* @Date：2023/5/18 15:09
* @Filename：DBCPDemo
*/
public class DBCPDemo {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
// 获取连接池
BasicDataSource dataSource = JdbcUtils.getDataSource();
try {
// 在连接池中获取连接
conn = dataSource.getConnection();
// 创建 Sql 执行对象
stmt = conn.createStatement();
// Sql 查询语句
String sql = "SELECT id, name, url FROM websites";
// 执行 Sql
ResultSet rs = stmt.executeQuery(sql);
// 展开结果集数据库，next()会判断有无下条数据，有的话返回 true
while(rs.next()){
// 通过字段检索
int id = rs.getInt("id");
String name = rs.getString("name");
String url = rs.getString("url");
// 输出数据
System.out.print("ID: " + id);
System.out.print(", 站点名称: " + name);
System.out.print(", 站点 URL: " + url);
System.out.print("\n");
}
// 完成后关闭
rs.close();
stmt.close();
conn.close();
} catch (SQLException se) {
// 获取连接错误
se.printStackTrace();
}finally{
try{
// 关闭资源
if(stmt!=null) stmt.close();
}catch(SQLException se2){
// 什么都不做
}
try{
if(conn!=null) conn.close();
}catch(SQLException se){
se.printStackTrace();
}
}
System.out.println("Goodbye!");
}
}
class JdbcUtils {
// 创建连接池
private static BasicDataSource dataSource = new BasicDataSource();
static {
//必须要的配置
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/test_base?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC");
dataSource.setUsername("root");
dataSource.setPassword("root");
//可选配置
dataSource.setMaxTotal(10);//连接池最大连接数
dataSource.setMaxIdle(5);//连接池最大空闲数
dataSource.setMinIdle(3);//连接池最小空闲数
dataSource.setInitialSize(10);//初始化连接池时的连接数
}
// 获取连接池
public static BasicDataSource getDataSource() {
return dataSource;
}
}
// 程序运行结果如下：
// ID: 1, 站点名称: Google, 站点 URL: https://www.google.cm/
// ID: 2, 站点名称: 淘宝, 站点 URL: https://www.taobao.com/
// ID: 3, 站点名称: 菜鸟教程, 站点 URL: http://www.runoob.com
// ID: 4, 站点名称: 微博, 站点 URL: http://weibo.com/
// ID: 5, 站点名称: Facebook, 站点 URL: https://www.facebook.com/
// ID: 6, 站点名称: JueJin, 站点 URL: https://www.juejin.cn/
// Goodbye!
使用数据库连接池也同样连接到了 MySQL 数据库，并打印了查询数据，这里并没有看出使用数据库连接池有什么优势，但如果使用 JDBC（非数据库连接池方式） 与 DBCP （数据库连接池方式）同时进行20000次数据库连接查询，消耗时间大概如下：
JDBC 耗时 40898毫秒
DBCP 耗时 3726毫秒
来源：https://juejin.cn/post/7234836453652430906
0
投稿猜你喜欢
- a1="sp2=20;sp1=34;" a2="sp3=2;sp2=3;sp1=4;" 两组字符串数
下面先给大家介绍下python获取酷狗音乐top500的下载地址 MP3格式，具体代码如下所示：# -*- coding: utf-8 -*- 有时会在存储过程中处理一些XML格式的数据，所以会用到sp_xml_preparedocument，他可以将XML数据进行读取，然后使用 M
- 导入同级模块导入sys，一定要将当前包所在路径添加进来。import syssys.path.append(r"directory
- 魔法方法凡是在类内部定义，以“__开头__结尾”的方法都称之为魔法方法，又称“类的内置方法”， 这些方法会在某些条件成立时触发。经常用到的双
- 概述在绝大部分的开发语言中与实际开发过程中，Dictionary扮演着举足轻重的角色。从我们的数据模型到服务器返回的参数到数据库的应用等等，
- 窗口函数形如：表达式 OVER (PARTITION BY 分组字段 ORDER BY 排序字段)有两个能力：当表达式为 rank() de
- 在python中进行两个整数相除的时候，在默认情况下都是只能够得到整数的值解决方法：1. 修改被除数的值为带小数点的形式即可得到浮点值2.在
- 本文实例讲述了php中$_GET与$_POST过滤sql注入的方法，分享给大家供大家参考。具体分析如下：此函数只能过滤一些敏感的sql命令了
- 今天想围绕“产品交互设计”说说一些我们的想法，一说到产品设计，我想在坐的各位脑海里肯定联想到了很多表单设计、导航设计、界面布局等等，但是今天
- 刚在虚拟机里面安装了pycharm，配置（setting）完后，新建一个py文件，键入"hello world"，竟然没
- 在类unix中，是\n (0x0A)。以为没有什么大的问题，没想到，这次开发一个小程序，却让我对这个问题大为头痛。 首先发现这个问题是这样的
- 本文实例为大家分享了python实现飞机大战的具体代码，供大家参考，具体内容如下初学Python，写了一个简单的Python小游戏。师出bi
- 本文研究的主要是python实现Adapter模式的相关内容，具体实现代码如下。Adapter模式有两种实现方式一种是类方式。#理解 #就是
- 元组：# 元组，一种不可变的序列，在创建之后不能做任何的修改# 1.不可变# 2.用（）创建元组类型，数据项用逗号来分割# 3.可以是任何的
- PIL中设计的几个基本概念1.通道（bands）：即使图像的波段数，RGB图像，灰度图像以RGB图像为例：>>>from
- 本文实例为大家分享了python实现坦克大战的具体代码，供大家参考，具体内容如下本游戏制作代码量较大具体代码与图片声源可以在我的GitHub
- 用selenium做自动化，有时候会遇到需要模拟鼠标操作才能进行的情况，比如单击、双击、点击鼠标右键、拖拽等等。而selenium给我们提供
- Oracle数据库开发应用中经常对数据库管理员有这样的需求，对比两个不同实例间某模式下对象的差异或者对比两个不同实例某模式下表定义的差异性，
- 片头语：因为工作需要，在CentOS上搭建环境MySQL+Python+MySQLdb，个人比较习惯使用Windows系统的操作习惯，对纯字
