30_数据库_第30天java_jdbc_（DBUtils）_讲义
程序员文章站
2024-01-05 20:43:46
今日内容介绍 1、DBUtils 2、连接池 01DButils工具类的介绍个三个核心类 A: DButils工具类的介绍个三个核心类 a: 概述 DBUtils是java编程中的数据库操作实用工具，小巧简单实用。 DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。 DBUti ......
今日内容介绍
1、dbutils
2、连接池
01dbutils工具类的介绍个三个核心类
* a: dbutils工具类的介绍个三个核心类
* a: 概述
* dbutils是java编程中的数据库操作实用工具，小巧简单实用。
* dbutils封装了对jdbc的操作，简化了jdbc操作，可以少写代码。
* dbutils就是jdbc的简化开发工具包。需要项目导入commons-dbutils-1.6.jar
* 才能够正常使用dbutils工具。
* b: dbutils三个核心功能介绍
* queryrunner中提供对sql语句操作的api.
* update(connection conn, string sql, object... params) ，用来完成
* 表数据的增加、删除、更新操作
* query(connection conn, string sql, resultsethandler<t> rsh,
* object... params) ，用来完成表数据的查询操作
* resultsethandler接口，用于定义select操作后，怎样封装结果集.
* dbutils类，它就是一个工具类,定义了关闭资源与事务处理的方法
02事务的简单介绍()
* a: 事务的简单介绍
03queryrunner类的update方法介绍
* a：queryrunner类的update方法介绍
* a: 方法介绍
* update(connection conn, string sql, object... params) ，用来完成表数据的增加、删除、更新操作
* 使用queryrunner类,实现对数据表的insert delete update
* 调用queryrunner类的方法 update (connection con,string sql,object...param)
* object...param 可变参数,object类型,sql语句会出现?占位符
* 数据库连接对象,自定义的工具类传递
04queryrunner类实现insert添加数据
* a: queryrunner类实现insert添加数据
* a: 案例代码
public class queryrunnerdemo {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args)throws sqlexception {
insert();
}
/*
* 定义方法,使用queryrunner类的方法update向数据表中,添加数据
*/
public static void insert()throws sqlexception{
//创建queryrunner类对象
queryrunner qr = new queryrunner();
string sql = "insert into sort (sname,sprice,sdesc)values(?,?,?)";
//将三个?占位符的实际参数,写在数组中
object[] params = {"体育用品",289.32,"购买体育用品"};
//调用queryrunner类的方法update执行sql语句
int row = qr.update(con, sql, params);
system.out.println(row);
dbutils.closequietly(con);
}
}
05queryrunner类实现update修改数据
* a: queryrunner类实现update修改数据
* a: 案例代码
public class queryrunnerdemo {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args)throws sqlexception {
update();
}
/*
* 定义方法,使用queryrunner类的方法update将数据表的数据修改
*/
public static void update()throws sqlexception{
//创建queryrunner类对象
queryrunner qr = new queryrunner();
//写修改数据的sql语句
string sql = "update sort set sname=?,sprice=?,sdesc=? where sid=?";
//定义object数组,存储?中的参数
object[] params = {"花卉",100.88,"情人节玫瑰花",4};
//调用queryrunner方法update
int row = qr.update(con, sql, params);
system.out.println(row);
dbutils.closequietly(con);
}
}
06queryrunner类实现delete删除数据
* a: queryrunner类实现delete删除数据
* a: 案例代码
public class queryrunnerdemo {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args)throws sqlexception {
delete();
}
/*
* 定义方法,使用queryrunner类的方法delete将数据表的数据删除
*/
public static void delete()throws sqlexception{
//创建queryrunner类对象
queryrunner qr = new queryrunner();
//写删除的sql语句
string sql = "delete from sort where sid=?";
//调用queryrunner方法update
int row = qr.update(con, sql, 8);
system.out.println(row);
/*
* 判断insert,update,delete执行是否成功
* 对返回值row判断
* if(row>0) 执行成功
*/
dbutils.closequietly(con);
}
}
07javabean类
* a: javabean类
* a: 概念
* javabean就是一个类，在开发中常用封装数据。具有如下特性
1. 需要实现接口：java.io.serializable ，通常实现接口这步骤省略了，不会影响程序。
2. 提供私有字段：private 类型 字段名;
3. 提供getter/setter方法：
4. 提供无参构造
08dbutils工具类结果集处理的方式
* a: dbutils工具类结果集处理的方式
* a: queryrunner实现查询操作
* query(connection conn, string sql, resultsethandler<t> rsh,
* object... params) ，用来完成表数据的查询操作
* b: resultsethandler结果集处理类
* arrayhandler 将结果集中的第一条记录封装到一个object[]数组中，数
* 组中的每一个元素就是这条记录中的每一个字段的值
* arraylisthandler 将结果集中的每一条记录都封装到一个object[]数组中，将这些数组在封装到list集合中。
* beanhandler 将结果集中第一条记录封装到一个指定的javabean中。
* beanlisthandler 将结果集中每一条记录封装到指定的javabean中，将这些javabean在封装到list集合中
* columnlisthandler 将结果集中指定的列的字段值，封装到一个list集合中
* scalarhandler 它是用于单数据。例如select count(*) from 表操作。
* maphandler 将结果集第一行封装到map集合中,key 列名, value 该列数据
* maplisthandler 将结果集第一行封装到map集合中,key 列名, value 该列数据,map集合存储到list集合
09queryrunner类的方法query
* a: queryrunner类的方法query
* a: queryrunner数据查询操作
* 调用queryrunner类方法query(connection con,string sql,resultsethandler r, object..params)
* resultsethandler r 结果集的处理方式,传递resultsethandler接口实现类
* object..params sql语句中的?占位符
* 注意: query方法返回值,返回的是t 泛型, 具体返回值类型,跟随结果集处理方式变化
* b: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
}
10结果集处理arrayhandler
* a: 结果集处理arrayhandler
* 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
arrayhandler();
}
/*
* 结果集第一种处理方法, arrayhandler
* 将结果集的第一行存储到对象数组中 object[]
*/
public static void arrayhandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort";
//调用方法query执行查询,传递连接对象,sql语句,结果集处理方式的实现类
//返回对象数组
object[] result = qr.query(con, sql, new arrayhandler());
for(object obj : result){
system.out.print(obj);
}
}
}
11结果集处理arraylisthandler
* a: 结果集处理arraylisthandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
arraylisthandler();
}
/*
* 结果集第二种处理方法,arraylisthandler
* 将结果集的每一行,封装到对象数组中, 出现很多对象数组
* 对象数组存储到list集合
*/
public static void arraylisthandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort";
//调用query方法,结果集处理的参数上,传递实现类arraylisthandler
//方法返回值 每行是一个对象数组,存储到list
list<object[]> result= qr.query(con, sql, new arraylisthandler());
//集合的遍历
for( object[] objs : result){
//遍历对象数组
for(object obj : objs){
system.out.print(obj+" ");
}
system.out.println();
}
}
}
12结果集处理beanhandler
* a: 结果集处理beanhandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
beanhandler();
}
/*
* 结果集第三种处理方法,beanhandler
* 将结果集的第一行数据,封装成javabean对象
* 注意: 被封装成数据到javabean对象, sort类必须有空参数构造
*/
public static void beanhandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort ";
//调用方法,传递结果集实现类beanhandler
//beanhandler(class<t> type)
sort s = qr.query(con, sql, new beanhandler<sort>(sort.class));
system.out.println(s);
}
}
13结果集处理beanlisthandler
* a: 结果集处理beanlisthandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
beanlisthander();
}
/*
* 结果集第四种处理方法, beanlisthandler
* 结果集每一行数据,封装javabean对象
* 多个javabean对象,存储到list集合
*/
public static void beanlisthander()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort ";
//调用方法query,传递结果集处理实现类beanlisthandler
list<sort> list = qr.query(con, sql, new beanlisthandler<sort>(sort.class));
for(sort s : list){
system.out.println(s);
}
}
}
14结果集处理columnlisthandler
* a: 结果集处理columnlisthandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
columnlisthandler();
}
/*
* 结果集第五种处理方法,columnlisthandler
* 结果集,指定列的数据,存储到list集合
* list<object> 每个列数据类型不同
*/
public static void columnlisthandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort ";
//调用方法 query,传递结果集实现类columnlisthandler
//实现类构造方法中,使用字符串的列名
list<object> list = qr.query(con, sql, new columnlisthandler<object>("sname"));
for(object obj : list){
system.out.println(obj);
}
}
}
15结果集处理scalarhandler
* a: 结果集处理scalarhandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
scalarhandler();
}
/*
* 结果集第六种处理方法,scalarhandler
* 对于查询后,只有1个结果
*/
public static void scalarhandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select count(*) from sort";
//调用方法query,传递结果集处理实现类scalarhandler
long count = qr.query(con, sql, new scalarhandler<long>());
system.out.println(count);
}
}
16结果集处理maphandler
* a: 结果集处理maphandler
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
maphandler();
}
/*
* 结果集第七种处理方法,maphandler
* 将结果集第一行数据,封装到map集合中
* map<键,值> 键:列名 值:这列的数据
*/
public static void maphandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort";
//调用方法query,传递结果集实现类maphandler
//返回值: map集合,map接口实现类, 泛型
map<string,object> map = qr.query(con, sql, new maphandler());
//遍历map集合
for(string key : map.keyset()){
system.out.println(key+".."+map.get(key));
}
}
}
17结果集处理maplisthandler
* a: 结果集处理maplisthandlerr
* a: 案例代码
public class queryrunnerdemo1 {
private static connection con = jdbcutilsconfig.getconnection();
public static void main(string[] args) throws sqlexception{
maplisthandler();
}
/*
* 结果集第八种处理方法,maplisthandler
* 将结果集每一行存储到map集合,键:列名,值:数据
* map集合过多,存储到list集合
*/
public static void maplisthandler()throws sqlexception{
queryrunner qr = new queryrunner();
string sql = "select * from sort";
//调用方法query,传递结果集实现类maplisthandler
//返回值list集合, 存储的是map集合
list<map<string,object>> list = qr.query(con, sql, new maplisthandler());
//遍历集合list
for( map<string,object> map : list ){
for(string key : map.keyset()){
system.out.print(key+"..."+map.get(key));
}
system.out.println();
}
}
}
18连接池介绍
* a: 连接池介绍
* a: 连接池介绍
* 实际上就是存放连接的池子(容器)
* 在开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程
* 为了解决此类性能问题，通常情况我们采用连接池技术，来共享连接connection。
* 这样我们就不需要每次都创建连接、释放连接了，这些操作都交给了连接池
19连接池概念规范和datasource接口
* a: 连接池概念规范和datasource接口
* a: 连接池概念规范
* 用池来管理connection，这样可以重复使用connection。
* 不用自己来创建connection，而是通过池来获取connection对象
* 使用完connection后，调用connection的close()方法也不会真的关闭connection，而是把connection“归还”给池
* 连接池技术可以完成connection对象的再次利用
* b: datasource接口
* java为数据库连接池提供了公共的接口：javax.sql.datasource
* 各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池
* 常见的连接池：dbcp、c3p0
20dbcp连接池介绍
* a: dbcp连接池介绍
* a: dbcp连接池介绍
* dbcp也是一个开源的连接池，是apache common成员之一，在企业开发中也比较常见，tomcat内置的连接池
* tomcat服务器简单介绍
21导入jar包
* a: 导入jar包
* a: jar包介绍
* mysql-connector-java-5.1.37-bin.jar：数据库驱动
* commons-dbutils-1.6.jar：提供queryrunner类方便进行增删改查操作
* commons-dbcp-1.4.jar：
* commons-pool-1.5.6.jar：提供高效的数据库连接池技术
* b: 导入jar包
* 在项目根路径下建立文件夹lib
* 拷贝以上jar包，选定拷贝的jar包/右键/build path/add to build path
22basicdatasource类的使用
* a: basicdatasource类的使用
* a: 案例代码
/*
* 连接池jar包中,定义好一个类 basicdatasource
* 实现类数据源的规范接口 javax.sql.datasource
*/
public class datasorucedemo {
public static void main(string[] args) {
//创建datasource接口的实现类对象
//实现类, org.apache.commons.dbcp
basicdatasource datasource = new basicdatasource();
//连接数据库的4个最基本信息,通过对象方法setxxx设置进来
datasource.setdriverclassname("com.mysql.jdbc.driver");
datasource.seturl("jdbc:mysql://localhost:3306/mybase");
datasource.setusername("root");
datasource.setpassword("123");
try{
//调用对象方法getconnection获取数据库的连接
connection con = datasource.getconnection();
system.out.println(con);
}catch(sqlexception ex){
// system.out.println(ex);
ex.printstacktrace();
throw new runtimeexception("数据库连接失败");
}
}
}
23basicdatasource类的常见配置
* a: basicdatasource类的常见配置
* a: 常见配置
分类 属性 描述
必须项
driverclassname 数据库驱动名称
url 数据库的地址
username 用户名
password 密码
基本项（扩展）
maxactive 最大连接数量
minidle 最小空闲连接
maxidle 最大空闲连接
initialsize 初始化连接
24实现数据库连接池工具类
* a: 实现数据库连接池工具类
* a: 案例代码
/*
* 使用dbcp实现数据库的连接池
* 连接池配置,自定义类,
* 最基本四项完整
* 对于数据库连接池其他配置,自定义
*/
import javax.sql.datasource;
import org.apache.commons.dbcp.basicdatasource;
public class jdbcutils{
//创建出basicdatasource类对象
private static basicdatasource datasource = new basicdatasource();
//静态代码块,对象basicdatasource对象中的配置,自定义
static{
//数据库连接信息,必须的
datasource.setdriverclassname("com.mysql.jdbc.driver");
datasource.seturl("jdbc:mysql://localhost:3306/day33_user");
datasource.setusername("root");
datasource.setpassword("123");
//对象连接池中的连接数量配置,可选的
datasource.setinitialsize(10);//初始化的连接数
datasource.setmaxactive(8);//最大连接数量
datasource.setmaxidle(5);//最大空闲数
datasource.setminidle(1);//最小空闲
}
//定义静态方法,返回basicdatasource类的对象
public static datasource getdatasource(){
return datasource;
}
}
25工具类的测试
* a: 工具类的测试
* a: 案例代码
/*
* 测试写好的工具类,
* 提供的是一个datasource接口的数据源
* queryrunner类构造方法,接收datasource接口的实现类
* 后面,调用方法update,query,无需传递他们connection连接对象
*/
import java.sql.sqlexception;
import java.util.list;
import org.apache.commons.dbutils.queryrunner;
import org.apache.commons.dbutils.handlers.arraylisthandler;
import cn.itcast.jdbcutils.jdbcutils;
public class queryrunnerdemo{
public static void main(string[] args) {
select();
}
//定义2个方法,实现数据表的添加,数据表查询
//queryrunner类对象,写在类成员位置
private static queryrunner qr = new queryrunner(jdbcutils.getdatasource());
//数据表查询
public static void select(){
string sql = "select * from sort";
try{
list<object[]> list = qr.query(sql, new arraylisthandler());
for(object[] objs : list){
for(object obj : objs){
system.out.print(obj+"\t");
}
system.out.println();
}
}catch(sqlexception ex){
throw new runtimeexception("数据查询失败");
}
}
//数据表添加数据
public static void insert(){
string sql = "insert into sort (sname,sprice,sdesc)values(?,?,?)";
object[] params = {"水果",100.12,"刚刚上市的核桃"};
try{
int row = qr.update(sql, params);
system.out.println(row);
}catch(sqlexception ex){
throw new runtimeexception("数据添加失败");
}
}
}