Java核心-Utils

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: Java核心-Utils

数据库连接池

利用池化的思想来保存数据库的连接,不必在每次使用完毕后就关闭,保证资源的重复利用。

JDBC对于连接池的接口: javax.sql.Datasource

第三方的连接池都是通过实现该接口来实现数据库连接池的,并且需要重写close方法,用来实现返回连接的功能,所以这里第三方连接池一般也需要自己实现Connection接口来创建一个自定义的连接

DBCP

配置

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/36th_rev
username=root
password=123456
#<!-- 初始化连接 -->
initialSize=10
#最大连接数量
maxActive=50
#<!-- 最大空闲连接 -->
maxIdle=20
#<!-- 最小空闲连接 -->
minIdle=5
#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useSSL=false;characterEncoding=utf8
#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true
#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=
#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

使用

步骤:在使用第三方数据库连接池的时候需要自己手写一个工具类

  • 导包
  • 加载配置文件
BasicDataSourceFactory.createDataSource(properties)
  • 提供一个获取连接的方法

C3P0

相对比DBCP来说,添加了超时自动回收的功能

配置

必须放在src目录下,且名字必须为c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <!-- 在xml文件中,有一些特殊的字符是不能写的。 & > <, 对于这三个字符,我们要写转义字符
                转义字符            
         &      &amp;
         >      &gt;
         <      &lt;
         >=     &gt;=
         <=     &lt;=
         
         -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/36th_rev?useSSL=false&amp;characterEncoding=utf8</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>
    
</c3p0-config>

使用

  • 加载配置文件
dataSource = new ComboPooledDataSource();
  • 获取连接
connection = dataSource.getConnection()

Druid

加入了数据库连接监控的功能

配置

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/36th_rev?useSSL=false&characterEncoding=utf8
username=root
password=123456
# 初始化大小,如果不配置,就使用默认值
initialSize=10

使用

  • 加载配置文件
DruidDataSourceFactory.createDataSource(properties);
  • 获取连接
connection = dataSource.getConnection();

不难发现,所有的第三方数据库连接池在获取连接的时候都是使用的JDBC接口中的getConnection方法

DBUtils

DBUtils

基本没用

// 关闭连接
public static void close(Connection conn) throws SQLException {
  if (conn != null) {
    conn.close();
  }
}
// 安静的关闭连接
public static void closeQuietly(Connection conn) {
  try {
    close(conn);
  } catch (SQLException e) { // NOPMD
    // quiet
  }
}

QueryRunner

用于执行SQL语句的对象

构造方法

// QueryRunner 有两个构造方法
// 无参构造
QueryRunner queryRunner = new QueryRunner();
// 通过数据库连接池来构造
DataSource dataSource = DruidUtils.getDataSource();
QueryRunner queryRunner = new QueryRunner(dataSource);

针对不同的构造方法,给我们提供了不同的方法来执行SQL语句

这里要注意,使用连接池构造的时候需要在我们自己写的连接池工具类中提供一个返回连接池对象的方法

API

  • update
    使用与普通的update一致,返回的是影响的行数的int值,如果使用无参构造,需要传入Connection
// 无参构造
QueryRunner queryRunner = new QueryRunner();
// 执行SQL语句
int affectedRows = queryRunner.update(DruidUtils.getConnection(),"update account set money = ? where id = ?",1000,1);
System.out.println("affectedRows:" + affectedRows);
//        // 通过数据库连接池来构造
        DataSource dataSource = DruidUtils.getDataSource();
        QueryRunner queryRunner = new QueryRunner(dataSource);
        // 执行SQL语句
        int affectedRows = queryRunner.update("update account set money = ? where id = ?",2000,1);
        System.out.println("affectedRows:" + affectedRows);
  • query
    查找语句,返回一个结果集,同样如果使用无参构造需要传入一个connection,并且需要传入一个解析结果集的 ResultSetHandler对象

ResultSetHandler

BeanHandler

将结果集封装到一个对象里面,如果有多行数据,只会封装第一行;需要传入一个对象的字节码文件

// 1. 获取QueryRunner
QueryRunner queryRunner = new QueryRunner(DruidUtils.getDataSource());
// 2. 执行SQL语句
Account account = queryRunner.query("select * from account where id > ?",new BeanHandler<>(Account.class),2); //?表示占位
System.out.println(account);

这里要注意,对象中的属性名字必须与查询出来的列名一致,如果有别名,需要和别名一致;如果查询到的列少于对象中属性的数量,那么其他没有查询的会被赋值为null,表示没有查到,所以我们在创建对象的时候需要使用包装类

BeanListHandler

将结果转换为一个集合,存放的都是结果对象,可存储多行值

// 获取QueryRunner
QueryRunner queryRunner = new QueryRunner(DruidUtils.getDataSource());
// 执行SQL
List<Account> list = queryRunner.query("select * from account where id in (?,?,?)",new BeanListHandler<>(Account.class),1,2,3);
System.out.println(list);

ColumnListHandler

将单列的值封装到list中

//创建QueryRunner对象
QueryRunner queryRunner = new QueryRunner(DruidUtils.getDataSource());
//执行SQL语句
List<String> nameList = queryRunner.query("select name from account where id > ?",new ColumnListHandler<String>(),1);
System.out.println(nameList);

ScalarHandler

返回查询到的单个的值,一般配合聚合函数来使用

//创建QueryRunner对象
QueryRunner queryRunner = new QueryRunner(DruidUtils.getDataSource());
Long count = queryRunner.query("select count(*) from account where money >5000",new ScalarHandler<Long>());

注意在使用的时候不用传入字节码文件对象,但需要指定泛型,只有使用对象封装的时候才需要传入字节码文件对象,因为内部需要使用反射来创建对象封装值

MapListHandler

将结果封装到一个MapList中,本质上是一个List里面存储了很多Map,可以存放多行结果,可以存放不同列结果,优势在于不需要创建一个对象来接收

key值是列名,value值是这一列对应的数据

QueryRunner queryRunner = new QueryRunner(DruidUtils.getDataSource);
List<Map<String,Object>>mapList = queryRunner.query("select id,name,role from account",new MapListHandler());
for(Map<String,Object> map : mapList){
    System.out.println(map);
}

Junit

规范

  1. Junit的测试方法应该单独写到一个测试类中
  2. Junit的测试类应该是 XxxTest 这种格式
  3. Junit的测试方法应该是 testXxx() 这种格式
  4. Junit里面有@Test注解,那么@Test注解修饰的方法
  • 必须是public
  • 返回值必须是void
  • 不能传参
  1. Junit里面有@AfterClass、@BeforeClass注解修饰的方法必须是静态的

使用场景

  • @Test
    一般用来测试我们写的代码
  • @BeforeClass
    在类被加载的时候执行,可以去做一些成员变量初始化的工作
  • @AfterClass
    在类被销毁的时候执行,可以做一些善后工作
  • @Before
    在测试方法执行之前执行,可以给测试方法里面的变量去赋值
  • @After
    在测试方法之后执行,可以做一些测试方法的执行之后执行的重复的工作(connection.commit(); )
相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
4月前
|
数据可视化 数据挖掘 开发者
import有什么用,python中怎么使用import
import有什么用,python中怎么使用import
54 1
Py之utils:utils库的简介、安装、使用方法之详细攻略
Py之utils:utils库的简介、安装、使用方法之详细攻略
Py之utils:utils库的简介、安装、使用方法之详细攻略
|
4月前
|
Java
【Java开发指南 | 第三十一篇】Java 包(package)
【Java开发指南 | 第三十一篇】Java 包(package)
41 1
|
4月前
|
搜索推荐 Java 测试技术
小白学Java
【2月更文挑战第9天】
57 5
|
Java 编译器 数据安全/隐私保护
【JavaSE专栏22】一文吃透Java的包机制
【JavaSE专栏22】一文吃透Java的包机制
124 0
【JavaSE专栏22】一文吃透Java的包机制
|
设计模式 Java 编译器
【Java 基础】Java SPI 二 之 Java APT原理及APT实战 - 一步步教你写ButterKnife
Java APT 是 Java 技术设计的一个 APT 架构, APT(Annotation Processing Tool)即注解处理器,它是一种处理注解的工具,也是javac中的一个工具,用于在编译阶段未生成class之前对源码中的注解进行扫描和处理。 APT可以用来在编译时扫描和处理注解, 它可以用来获取到注解和被注解对象的相关信息,在拿到这些信息后我们可以根据需求来自动的生成一些代码,省去了手动编写。 在Android中有如ButterKnife、Dagger、EventBus等第三方框架,都采用了APT。
|
Java 编译器 C++
java入门概念个人理解之package与import浅析
java入门概念个人理解之package与import浅析
java202303java学习笔记第三十八天常用工具包hutool之2
java202303java学习笔记第三十八天常用工具包hutool之2
44 0
java202303java学习笔记第三十八天常用工具包hutool之1
java202303java学习笔记第三十八天常用工具包hutool之1
46 0
java202303java学习笔记第二十六天-深克隆4gson包
java202303java学习笔记第二十六天-深克隆4gson包
36 0