dbutil辅助类进行增删改查

2023-11-23 07:38

本文主要是介绍dbutil辅助类进行增删改查,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 Queryrunner

commnets-dbcp-1.4.jar     commnets-dbutil-1.4.jar           commnets-pool-1.4.jar

ojdbc6.jar                                      mysql数据库需要mysql-connector-java.jar

Queryrunner:增删改查,如果是自动向数据库提交数据,则必须实现有参的构造函数
步骤:

1.通过getdatasouce获得datascource

2.声明runner.query对象

QueryRunner runner=new QueryRunner(dataSource);

3.执行runner中的方法

   Object[] student=runner.query("select * from account where id>?",new ArrayHandler(),15);

    int count=runner.update("insert into account (name,id,money) values(?,?,?)",obj);

4.处理返回数据

用不到 connection 和prestatement 和prestatement ,也不用再关闭conn、关闭prestatenment、关闭statement 、关闭resutset了

使用dbcp链接池获取数据源datasource对象

import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;import javax.sql.DataSource;
import java.io.*;
import java.util.Properties;public class getdatasource {public static DataSource getdatascource()//配置DataSource信息{BasicDataSource dbcp=new BasicDataSource();dbcp.setDriverClassName("oracle.jdbc.driver.OracleDriver");dbcp.setUrl("jdbc:oracle:thin:@127.0.0.1:1521:ORCL");dbcp.setUsername("scott");dbcp.setPassword("orcl");System.out.println(dbcp);return dbcp;}public static  DataSource getdatascourcewirhDBCPbyproperites() {//通过读取文件获取datas信息DataSource dbcp=null;Properties props=new Properties();try {File file1=new File("E:\\IDEAproject\\demo\\src\\GetDataSourceFactory.properites");//获取文件InputStream inputStream=new FileInputStream(file1);//获取输入流props.load(inputStream);//props需要通过输入流读取一个.Properties文件dbcp= BasicDataSourceFactory.createDataSource(props);//只记住这句就可以,createdatasource需要一个Properties参数} catch (Exception e) {e.printStackTrace();}return dbcp;}
}

 访问数据库

package QueryRunner;import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;import javax.sql.DataSource;
import java.sql.SQLException;public class QueryRunner_test {public static void main(String[] args) throws SQLException {
//        Select_idBiggerThan15();update();}public static void Select_idBiggerThan15() throws SQLException {DataSource dataSource=GetDataSource.getdatacource();QueryRunner runner=new QueryRunner(dataSource);Object[] student=runner.query("select * from account where id>?",new ArrayHandler(),15);for(int i=0;i<student.length;++i){System.out.print(student[i]);}}public static void update() throws SQLException {DataSource dataSource=GetDataSource.getdatacource();QueryRunner runner=new QueryRunner(dataSource);Object [] obj={"name2",50,5000};int count=runner.update("insert into account (name,id,money) values(?,?,?)",obj);System.out.println("插入了"+count+"条数据");}
}

如果是查询,需要用resultsetHandler接口,有很多实现类,一个实现类对应一种不同的查询类型(对应不同的返回值类型)

1.ArrayHandler

  返回结果集中的第一行数据,并用object数组接收

Object[] student=runner.query("select * from student_info where id>?",new ArrayHandler(),1);
 System.out.print(student[1]);

2.ArrayListHandler

以list和数组形式返回结果集,list的每一行都放了一个object数组

List<Object[]>  students=runner.query("select * from student_info where id>?",new ArrayListHandler(),1);
for(Object[] student:students)
{System.out.print(student[0]);}

3.BeanHandler

以类形式返回结果集的第一行数据,注意类中的变量名要和表一致

Student student=runner.query("select * from student_info where id>?",new BeanHandler <Student> (Student.class),1);//Student.class是java的反射,不懂,这样写自动把查询结果放到student对象中
System.out.print(student.getLoc());

4.BeanListHandler

返回结果集中的多行数据用list<student>接收

List<Student> students=new ArrayList<>();
students=runner.query("select * from student_info where id>?",new BeanListHandler<Student>(Student.class),1);

5.BeanMapHandler

将结果集编号,返回map  oracle中默认的数据类型是decimal类型,java中和decimal对应的是bigdecimal类型

Map<BigDecimal,Student> students=runner.query("select * from student_info where id>?",newBeanMapHandler<BigDecimal,Student>(Student.class,"id"),1);
 Student stu=students.get( new BigDecimal(1));

6.MapHandler

以map形式返回第一行查询结果

Map<String,Object> student =runner.query("select * from student_info where id>?",new MapHandler(),1);
System.out.print(student);//

结果:{ID=2, NAME=name2, PWD=pwd2, LOC=loc2}

<String,Object>是规定放入这个map的格式,key是string,value是object

7.MapListHandler

返回结果集中的多行结果

List< Map<String,Object>> student =runner.query("select * from student_info where id>?",new MapListHandler(),1);
 System.out.print(student);

结果:[{ID=2, NAME=name2, PWD=pwd2, LOC=loc2}, {ID=5, NAME=name5, PWD=loc5, LOC=psw5}]

List里放map

8.Columnlisthander:把结果中的某一列(比如全部的id),保存在list

List< String> student =runner.query("select * from student_info where id>?",new ColumnListHandler<String>("loc"),1);
 System.out.print(student);

其中object…paramas代表可变参数:既可以写单值,也可以写数组

9.拿到符合条件的第一条数据,并把各个属性的值依次放到数组中

Object[] student=runner.query("select * from student_info where id>? And name like ?",new ArrayHandler(),new Object[]{1,"%n%"});
System.out.print(student[0]);

可能会因为jar包版本问题,当参数为数组时(上面那句)执行出错,换别版本的就可以

这篇关于dbutil辅助类进行增删改查的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/416375

相关文章

Nginx中配置使用非默认80端口进行服务的完整指南

《Nginx中配置使用非默认80端口进行服务的完整指南》在实际生产环境中,我们经常需要将Nginx配置在其他端口上运行,本文将详细介绍如何在Nginx中配置使用非默认端口进行服务,希望对大家有所帮助... 目录一、为什么需要使用非默认端口二、配置Nginx使用非默认端口的基本方法2.1 修改listen指令

Go语言连接MySQL数据库执行基本的增删改查

《Go语言连接MySQL数据库执行基本的增删改查》在后端开发中,MySQL是最常用的关系型数据库之一,本文主要为大家详细介绍了如何使用Go连接MySQL数据库并执行基本的增删改查吧... 目录Go语言连接mysql数据库准备工作安装 MySQL 驱动代码实现运行结果注意事项Go语言执行基本的增删改查准备工作

MySQL按时间维度对亿级数据表进行平滑分表

《MySQL按时间维度对亿级数据表进行平滑分表》本文将以一个真实的4亿数据表分表案例为基础,详细介绍如何在不影响线上业务的情况下,完成按时间维度分表的完整过程,感兴趣的小伙伴可以了解一下... 目录引言一、为什么我们需要分表1.1 单表数据量过大的问题1.2 分表方案选型二、分表前的准备工作2.1 数据评估

MySQL进行分片合并的实现步骤

《MySQL进行分片合并的实现步骤》分片合并是指在分布式数据库系统中,将不同分片上的查询结果进行整合,以获得完整的查询结果,下面就来具体介绍一下,感兴趣的可以了解一下... 目录环境准备项目依赖数据源配置分片上下文分片查询和合并代码实现1. 查询单条记录2. 跨分片查询和合并测试结论分片合并(Shardin

SpringBoot结合Knife4j进行API分组授权管理配置详解

《SpringBoot结合Knife4j进行API分组授权管理配置详解》在现代的微服务架构中,API文档和授权管理是不可或缺的一部分,本文将介绍如何在SpringBoot应用中集成Knife4j,并进... 目录环境准备配置 Swagger配置 Swagger OpenAPI自定义 Swagger UI 底

基于Python Playwright进行前端性能测试的脚本实现

《基于PythonPlaywright进行前端性能测试的脚本实现》在当今Web应用开发中,性能优化是提升用户体验的关键因素之一,本文将介绍如何使用Playwright构建一个自动化性能测试工具,希望... 目录引言工具概述整体架构核心实现解析1. 浏览器初始化2. 性能数据收集3. 资源分析4. 关键性能指

Nginx进行平滑升级的实战指南(不中断服务版本更新)

《Nginx进行平滑升级的实战指南(不中断服务版本更新)》Nginx的平滑升级(也称为热升级)是一种在不停止服务的情况下更新Nginx版本或添加模块的方法,这种升级方式确保了服务的高可用性,避免了因升... 目录一.下载并编译新版Nginx1.下载解压2.编译二.替换可执行文件,并平滑升级1.替换可执行文件

Python进行JSON和Excel文件转换处理指南

《Python进行JSON和Excel文件转换处理指南》在数据交换与系统集成中,JSON与Excel是两种极为常见的数据格式,本文将介绍如何使用Python实现将JSON转换为格式化的Excel文件,... 目录将 jsON 导入为格式化 Excel将 Excel 导出为结构化 JSON处理嵌套 JSON:

Olingo分析和实践之EDM 辅助序列化器详解(最佳实践)

《Olingo分析和实践之EDM辅助序列化器详解(最佳实践)》EDM辅助序列化器是ApacheOlingoOData框架中无需完整EDM模型的智能序列化工具,通过运行时类型推断实现灵活数据转换,适用... 目录概念与定义什么是 EDM 辅助序列化器?核心概念设计目标核心特点1. EDM 信息可选2. 智能类

一文解密Python进行监控进程的黑科技

《一文解密Python进行监控进程的黑科技》在计算机系统管理和应用性能优化中,监控进程的CPU、内存和IO使用率是非常重要的任务,下面我们就来讲讲如何Python写一个简单使用的监控进程的工具吧... 目录准备工作监控CPU使用率监控内存使用率监控IO使用率小工具代码整合在计算机系统管理和应用性能优化中,监