1_基础版JDBC-DBHelper扩展(事务及大数据操作)

2023-10-28 16:58

本文主要是介绍1_基础版JDBC-DBHelper扩展(事务及大数据操作),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

			JDBC - 基础版DBHelper

/MyProperties.java/

public class MyProperties extends Properties{
private static MyProperties myproperties;
private MyProperties(){
InputStream iis = MyProperties.class.getClassLoader().getResourceAsStream(“db.properties”);
try{
super.load( iis );
}catch( IOException e ){
e.printStackTrace();
}
}

public static MyProperties getInstance(){if( myproperties == null ){myproperties = new MyProperties();}return myproperties;
}

}

/**************************************************************************/

/DBHelper.java/

public class DBHelper{

// 静态块 , 读取一次数据库驱动,
static{try{Class.forName( MyProperties.getInstance().getProperty("driver") );}catch( ClassNotFoundException e ){e.printStackTrace();}
}//获取数据库联接
public Connection getCon() throws SQLException {MyProperties mp = MyProperties.getInstance();Connection con = DriverManager.getConnection( mp.getProperty("url") , mp.getProperty ("username") , mp.getProperty("password") );return con;
}//查询
public List<Map<String , String >> findAll( String sql ,List<Object> params )throws SQLException{Connection con = getCon();PreparedStatement pstmt = con.prepareStatement( sql );setParams( pstmt , params );ResultSet rs = pstmt.executeQuery();ResultSetMetaData rsmd = rs.getMetaData(); //获取关于 ResultSet 对象中列的类型和属性信息的对象List<String> cnlist = new ArrayList<String>();for( int i = 1; i <= rsmd.getColumnCount() ; i++ ){cnlist.add( rsmd.getColumnName( i ) );}List<Map<String , String >> list = new ArrayList<Map<String ,String >>();while( rs.next() ){Map<String , String > map = new HashMap<String , String >();for( String cn :cnlist ){map.put( cn , rs.getString(cn) );}list.add( map );}closeAll(pstmt ,con ,rs );return list;
}//查询聚合函数
public double findDouble( String sql , List<Object> params ) throws SQLException{double result = 0;Connection con = getCon();PreparedStatement pstmt = con.prepareStatement( sql );setParams( pstmt ,params );ResultSet rs = pstmt.executeQuery();while( rs.next() ){rs.getDouble( 1 );}closeAll( pstmt ,con ,rs );return result;
}//封装增删改
public int doUpdate( String sql , List<Object> params ) throws SQLException{Connection con = getCon();PreparedStatement pstmt = con.prepareStatement( sql );setParams( pstmt ,params );int result = pstmt.executeUpdate();closeAll( pstmt ,con ,null );return result;
}//封装带事务的增删改
public void doUpdateTran( List<String> sqls ,List< List<Object> > listparams ){Connection con = getCon();PreparedStatement pstmt = null;con.setAutoCommit( false );  //关闭隐式事务( 一句SQL语句提交一次 )try{if( sqls != null && sqls.size() > 0 ){for( int i = 0; i < sqls.size() ; i++ ){String sql = sqls.get( i );     // 取出每一条sql语句.pstmt = con.prepareStatement( sql );setParams( pstmt , listparams( i ) );pstmt.executeUpdate();}}con.commit();}catch( Exception e ){if( con != null ){con.rollback;   // 回滚}}finally{con.setAutoCommit( true );  //恢复隐式事务closeAll( pstmt ,con ,null );}}//大数据的操作 , 批处理// 集合嵌套集合.
public void doBigDataUpdate( String sql , List<List<Object>> params ) throws SQLException{Connection con = getCon();con.setAutoCommit( false );   PreparedStatement pstmt = null;try{pstmt = con.prepareStatement( sql );for( int i = 0; i < params.size() ; i++ ){List<Object> paramsList = params.get( i );setParams( pstmt , paramsList );pstmt.addBatch();   //添加一次预定义参数if( i % 1000 == 0 ){pstmt.executeBatch(); //批量执行预定义sql ,这个返回值里面存的是每条语句执行的结果}}pstmt.executeBatch();   // 多余的余数在执行.con.commit();}catch( Exception e){e.printStackTrace();con.rollback();    // 异常 ====>>>> 回滚。}finally{con.setAutoCommit( true );closeAll( pstmt ,con ,null );}
}//设置参数 占位符
private void setParams( PreparedStatement pstmt , List<Object> params ) throws SQLException{if( params != null && params.size() > 0 ){for( int i = 1;  i <= params.size() ; i++ ){pstmt.setObject( i , params.get( i-1 ));}}
}// 释放资源
private sttaic void clossAll( PreparedStatement pstmt , Connection con , ResultSet rs ){if( pstmt != null ){pstmt.close();}if( con !=null ){con.close();}if( rs != null ){rs.close();}
}

}

这篇关于1_基础版JDBC-DBHelper扩展(事务及大数据操作)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/294624

相关文章

Python使用openpyxl读取Excel的操作详解

《Python使用openpyxl读取Excel的操作详解》本文介绍了使用Python的openpyxl库进行Excel文件的创建、读写、数据操作、工作簿与工作表管理,包括创建工作簿、加载工作簿、操作... 目录1 概述1.1 图示1.2 安装第三方库2 工作簿 workbook2.1 创建:Workboo

Ubuntu 24.04启用root图形登录的操作流程

《Ubuntu24.04启用root图形登录的操作流程》Ubuntu默认禁用root账户的图形与SSH登录,这是为了安全,但在某些场景你可能需要直接用root登录GNOME桌面,本文以Ubuntu2... 目录一、前言二、准备工作三、设置 root 密码四、启用图形界面 root 登录1. 修改 GDM 配

MyBatis-Plus通用中等、大量数据分批查询和处理方法

《MyBatis-Plus通用中等、大量数据分批查询和处理方法》文章介绍MyBatis-Plus分页查询处理,通过函数式接口与Lambda表达式实现通用逻辑,方法抽象但功能强大,建议扩展分批处理及流式... 目录函数式接口获取分页数据接口数据处理接口通用逻辑工具类使用方法简单查询自定义查询方法总结函数式接口

JSONArray在Java中的应用操作实例

《JSONArray在Java中的应用操作实例》JSONArray是org.json库用于处理JSON数组的类,可将Java对象(Map/List)转换为JSON格式,提供增删改查等操作,适用于前后端... 目录1. jsONArray定义与功能1.1 JSONArray概念阐释1.1.1 什么是JSONA

SQL中如何添加数据(常见方法及示例)

《SQL中如何添加数据(常见方法及示例)》SQL全称为StructuredQueryLanguage,是一种用于管理关系数据库的标准编程语言,下面给大家介绍SQL中如何添加数据,感兴趣的朋友一起看看吧... 目录在mysql中,有多种方法可以添加数据。以下是一些常见的方法及其示例。1. 使用INSERT I

Python使用vllm处理多模态数据的预处理技巧

《Python使用vllm处理多模态数据的预处理技巧》本文深入探讨了在Python环境下使用vLLM处理多模态数据的预处理技巧,我们将从基础概念出发,详细讲解文本、图像、音频等多模态数据的预处理方法,... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach

PostgreSQL的扩展dict_int应用案例解析

《PostgreSQL的扩展dict_int应用案例解析》dict_int扩展为PostgreSQL提供了专业的整数文本处理能力,特别适合需要精确处理数字内容的搜索场景,本文给大家介绍PostgreS... 目录PostgreSQL的扩展dict_int一、扩展概述二、核心功能三、安装与启用四、字典配置方法

MySQL 删除数据详解(最新整理)

《MySQL删除数据详解(最新整理)》:本文主要介绍MySQL删除数据的相关知识,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、前言二、mysql 中的三种删除方式1.DELETE语句✅ 基本语法: 示例:2.TRUNCATE语句✅ 基本语

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2