Java 工具类 - JDBC通用操作基类 BaseDao

2023-12-21 10:18
文章标签 java 工具 通用 操作 jdbc 基类 basedao

本文主要是介绍Java 工具类 - JDBC通用操作基类 BaseDao，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

封装了增删改查功能
适用于MySQL、Oracle、SQLServer、DB2、Sybase、JTDS、PostgreSql、SQLite、Derby、H2、HSQLDB、ODBC 等等数据库，有需要的还可以自己增加。

package com.tgb.hz.jdbc;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;/*** 数据访问基类<br>* <strong>支持 MySQL、Oracle、SQLServer、DB2、Sybase、PostgreSql、SQLite、Derby、H2、HSQLDB、ODBC、SQLServer_JTDS、Sybase_JTDS</strong>* <br>切换数据库时，需要指定相关参数* * @author hezhao* @Time   2017年7月27日 下午4:22:23* @Description 无* @Version V 1.0*/
public class BaseDao {private final Logger logger = LoggerFactory.getLogger(BaseDao.class);private final boolean isLog = false;//是否记录SQL日志private final boolean isConfig = false;//是否需要配置文件private final boolean isDataSource = false;//是否从连接池取连接private final String datasource = "";//如果是从连接池取连接，那么给出连接名称private final DBType type = DBType.MySQL;//数据库类型// 数据库名private final String db = "dbname";private final String ip = "127.0.0.1";private String name = "root";private String pwd = "root";private String driver;private String url;private Connection conn = null;private PreparedStatement pstmt = null;protected ResultSet rs = null;{//把JDBC配置信息放在配置文件中if(isConfig){final Properties properties = new Properties();try {properties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("jdbc.properties"));} catch (final IOException e) {logger.error("加载JDBC配置信息失败...");logger.error(e.toString(),e);}driver = properties.getProperty("jdbc.driver");url = properties.getProperty("jdbc.url");name = properties.getProperty("jdbc.username");pwd = properties.getProperty("jdbc.password");}else{if(type == DBType.MySQL){driver = "com.mysql.jdbc.Driver";                                                                                  url = "jdbc:mysql://"+ip+":3306/"+db+"?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull";}else if(type == DBType.SQLServer){//1、使用sqljdbcdriver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";                                                                                  url = "jdbc:sqlserver://"+ip+":1433;DatabaseName="+db;}else if(type == DBType.SQLServer_JTDS){//2、使用jtdsdriver = "net.sourceforge.jtds.jdbc.Driver";                                                                                  url = "jdbc:jtds:sqlserver://"+ip+":1433;DatabaseName="+db;}else if(type == DBType.Oracle){driver = "oracle.jdbc.driver.OracleDriver";                                                                                  url = "jdbc:oracle:thin:@"+ip+":1521:"+db;}else if(type == DBType.DB2){driver = "com.ibm.db2.jcc.DB2Driver";                                                                                  url = "jdbc:db2://"+ip+":50000/"+db;}else if(type == DBType.Sybase){driver = "com.sybase.jdbc.SybDriver";                                                                                  url = "jdbc:sybase:Tds:"+ip+":5007/"+db;}else if(type == DBType.Sybase_JTDS){driver = "net.sourceforge.jtds.jdbc.Driver";                                                                                  url = "jdbc:jtds:sybase://"+ip+":5007/"+db;}else if(type == DBType.PostgreSql){driver = "org.postgresql.Driver";                                                                                  url = "jdbc:postgresql://"+ip+"/"+db;}else if(type == DBType.SQLite){driver = "org.sqlite.JDBC";                                                                                  url = "jdbc:sqlite:"+db;    //jdbc:sqlite:person.db}else if(type == DBType.H2){driver = "org.h2.Driver";                                                                                  url = "jdbc:h2:tcp://"+ip+"/~/"+db;}else if(type == DBType.HSQLDB){driver = "org.hsqldb.jdbcDriver";                                                                                  url = "jdbc:hsqldb:hsql://"+ip+":9001/"+db;}else if(type == DBType.Derby){driver = "org.apache.derby.jdbc.ClientDriver";                                                                                  url = "jdbc:derby://"+ip+":1527/"+db+";";}else if(type == DBType.ODBC){driver = "sun.jdbc.odbc.JdbcOdbcDriver";                                                                                  url = "jdbc:odbc:"+db;}}}private void getConnection() {if(!isDataSource){//1、通过JDBC获得链接try {Class.forName(driver);conn = DriverManager.getConnection(url, name, pwd);} catch (Exception e) {logger.error(e.toString(),e);}}else{//2、通过数据连接池获得链接try {Context ctx = new InitialContext();DataSource ds = (DataSource)ctx.lookup(datasource);this.conn = ds.getConnection();} catch (NamingException e) {logger.error(e.toString(),e);} catch (SQLException e) {logger.error(e.toString(),e);}}}/*** 关闭资源*/protected void closeAll() {try {if (this.rs != null) {rs.close();}if (this.pstmt != null) {pstmt.close();}if (this.conn != null) {conn.close();}} catch (SQLException e) {logger.error(e.toString(),e);}}/*** 增删改通用* @author hezhao* @Time   2017年7月27日 下午4:22:09* @Description 无* @Version V 1.0* @param sql* @param prams* @return*/protected int executeUpdate(String sql, Object... prams) {try {this.getConnection();this.pstmt = conn.prepareStatement(sql);if (prams != null) {for (int i = 0; i < prams.length; i++) {this.pstmt.setObject(i + 1, prams[i]);}}log(sql, prams);return this.pstmt.executeUpdate();} catch (SQLException e) {logger.error(e.toString(),e);} finally {closeAll();}return 0;}/*** 新增，返回主键* @author hezhao* @Time   2017年1月18日 下午2:23:07* @param sql* @param prams* @return*/protected int executeInsert(String sql, Object... prams) {try {this.getConnection();//传入参数：STATEMENT.RETURN_GENERATED_KEYS，指定返回生成的主键  this.pstmt = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);if (prams != null) {for (int i = 0; i < prams.length; i++) {this.pstmt.setObject(i + 1, prams[i]);}}log(sql, prams);//执行sqlint count = this.pstmt.executeUpdate();//返回的主键int autoIncKey = 0;if(count > 0){ResultSet rs = pstmt.getGeneratedKeys(); //获取结果if (rs.next()) {autoIncKey = rs.getInt(1);//取得ID} else {// throw an exception from herelogger.error("插入语句出错，没有获取到新增的ID！");}}return autoIncKey;} catch (SQLException e) {logger.error(e.toString(),e);} finally {closeAll();}return 0;}/*** 查询通用* @author hezhao* @Time   2017年7月27日 下午4:22:45* @Description 无* @Version V 1.0* @param sql* @param prams*/protected void executeQuery(String sql, Object... prams) {try {this.getConnection();this.pstmt = conn.prepareStatement(sql);if (prams != null) {for (int i = 0; i < prams.length; i++) {this.pstmt.setObject(i + 1, prams[i]);}}log(sql, prams);this.rs = this.pstmt.executeQuery();} catch (SQLException e) {logger.error(e.toString(),e);}}/*** 打印日志* @author hezhao* @Time   2017年7月27日 下午4:22:56* @Description 无* @Version V 1.0* @param sql* @param prams*/private void log(String sql, Object[] prams) {if(isLog) {System.out.println("===========" + sql);if (prams != null && prams.length > 0) {System.out.println("参数：");for (int i = 0; i < prams.length; i++) {if (i == prams.length - 1) {System.out.print(prams[i] + "\n");} else {System.out.print(prams[i] + ",");}}}}}/*** 数据库类型* @author hezhao on 2017年7月27日 上午11:26:08**/static enum DBType{MySQL,Oracle,SQLServer,  //SQLServer2005SQLServer_JTDS, //使用jtds连接SQLServerDB2,Sybase,Sybase_JTDS,    //使用jtds连接SybasePostgreSql,SQLite,Derby,H2,HSQLDB,ODBC;   //桥连接} }

这篇关于Java 工具类 - JDBC通用操作基类 BaseDao的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/519594。

相关文章

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具
阅读更多...
Spring WebFlux 与 WebClient 使用指南及最佳实践

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依
阅读更多...
Spring Boot @RestControllerAdvice全局异常处理最佳实践

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理？二、核心注解解析1. @RestControllerAdvice2
阅读更多...
Spring IoC 容器的使用详解(最新整理)

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注
阅读更多...
Spring事务传播机制最佳实践

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED（默认）2.2 SUPPORTS2
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...
Java进程异常故障定位及排查过程

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》：本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存
阅读更多...
Linux中压缩、网络传输与系统监控工具的使用完整指南

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压：数据存储与传输的优化核心1. zip/unzip：通用压缩格式的便捷操作2.
阅读更多...
Python实现对阿里云OSS对象存储的操作详解

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os
阅读更多...
java中新生代和老生代的关系说明

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》：本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2