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 rocketmq配置生产者和消息者的步骤

springboot rocketmq配置生产者和消息者的步骤

《springbootrocketmq配置生产者和消息者的步骤》本文介绍了如何在SpringBoot中集成RocketMQ,包括添加依赖、配置application.yml、创建生产者和消费者,并展... 目录1. 添加依赖2. 配置application.yml3. 创建生产者4. 创建消费者5. 使用在
阅读更多...
Spring Retry 实现乐观锁重试实践记录

Spring Retry 实现乐观锁重试实践记录

《SpringRetry实现乐观锁重试实践记录》本文介绍了在秒杀商品SKU表中使用乐观锁和MybatisPlus配置乐观锁的方法,并分析了测试环境和生产环境的隔离级别对乐观锁的影响,通过简单验证,... 目录一、场景分析 二、简单验证 2.1、可重复读 2.2、读已提交 三、最佳实践 3.1、配置重试模板
阅读更多...
Spring中@Lazy注解的使用技巧与实例解析

Spring中@Lazy注解的使用技巧与实例解析

《Spring中@Lazy注解的使用技巧与实例解析》@Lazy注解在Spring框架中用于延迟Bean的初始化,优化应用启动性能,它不仅适用于@Bean和@Component,还可以用于注入点,通过将... 目录一、@Lazy注解的作用（一）延迟Bean的初始化（二）与@Autowired结合使用二、实例解
阅读更多...
SpringBoot使用Jasypt对YML文件配置内容加密的方法(数据库密码加密)

SpringBoot使用Jasypt对YML文件配置内容加密的方法(数据库密码加密)

《SpringBoot使用Jasypt对YML文件配置内容加密的方法(数据库密码加密)》本文介绍了如何在SpringBoot项目中使用Jasypt对application.yml文件中的敏感信息（如数... 目录SpringBoot使用Jasypt对YML文件配置内容进行加密（例：数据库密码加密）前言一、J
阅读更多...
Java中有什么工具可以进行代码反编译详解

Java中有什么工具可以进行代码反编译详解

《Java中有什么工具可以进行代码反编译详解》：本文主要介绍Java中有什么工具可以进行代码反编译的相关资,料,包括JD-GUI、CFR、Procyon、Fernflower、Javap、Byte... 目录1.JD-GUI2.CFR3.Procyon Decompiler4.Fernflower5.Jav
阅读更多...
Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

《SpringBoot中正确地在异步线程中使用HttpServletRequest的方法》文章讨论了在SpringBoot中如何在异步线程中正确使用HttpServletRequest的问题,... 目录前言一、问题的来源：为什么异步线程中无法访问 HttpServletRequest？1. 请求上下文与线
阅读更多...
在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

《在SpringBoot中使用异步线程时的HttpServletRequest复用问题记录》文章讨论了在SpringBoot中使用异步线程时,由于HttpServletRequest复用导致... 目录一、问题描述：异步线程操作导致请求复用时 Cookie 解析失败1. 场景背景2. 问题根源二、问题详细分
阅读更多...
Java对象和JSON字符串之间的转换方法(全网最清晰)

Java对象和JSON字符串之间的转换方法(全网最清晰)

《Java对象和JSON字符串之间的转换方法(全网最清晰)》：本文主要介绍如何在Java中使用Jackson库将对象转换为JSON字符串,并提供了一个简单的工具类示例,该工具类支持基本的转换功能,... 目录前言1. 引入 Jackson 依赖2. 创建 jsON 工具类3. 使用示例转换 Java 对象为
阅读更多...
SpringBoot快速接入OpenAI大模型的方法(JDK8)

SpringBoot快速接入OpenAI大模型的方法(JDK8)

《SpringBoot快速接入OpenAI大模型的方法(JDK8)》本文介绍了如何使用AI4J快速接入OpenAI大模型,并展示了如何实现流式与非流式的输出,以及对函数调用的使用,AI4J支持JDK8... 目录使用AI4J快速接入OpenAI大模型介绍AI4J-github快速使用创建SpringBoot
阅读更多...
使用Python创建一个能够筛选文件的PDF合并工具

使用Python创建一个能够筛选文件的PDF合并工具

《使用Python创建一个能够筛选文件的PDF合并工具》这篇文章主要为大家详细介绍了如何使用Python创建一个能够筛选文件的PDF合并工具,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下... 目录背景主要功能全部代码代码解析1. 初始化 wx.Frame 窗口2. 创建工具栏3. 创建布局和界面控件4
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2