热门标签 | HotTags
当前位置:  开发笔记 > 数据库 > 正文

DBCP数据库连接池的使用

packagetk.dong.connectionPool;importjava.io.IOException;importjava.io.InputStream;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.util.Properties;importjav

package tk.dong.connectionPool;import java.io.IOException;import java.io.InputStream;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.Properties;import jav

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
package tk.dong.connectionPool;
 
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
 
import javax.sql.DataSource;
 
import org.apache.commons.dbcp.BasicDataSourceFactory;
 
public class Pool_dbcp {
    // 首先要导入包commons-pool.jar和commons-dbcp-1.4.jar
 
    // 声明数据源
    private static DataSource dataSource;
    private static PreparedStatement pstmt;
    private static ResultSet rs;
 
    static {
        // 将配置文件以输入流的形式读入
        InputStream inputStream = Pool_dbcp.class.getClassLoader()
                .getResourceAsStream("dbcp.properties");
 
        // 创建属性操作的对象
        Properties properties = new Properties();
 
        try {
            // 将配置文件读入
            properties.load(inputStream);
            // 创建基础的数据源处理工厂类的对象
            BasicDataSourceFactory basicDataSourceFactory = new BasicDataSourceFactory();
            // 通过基础的数据处理工厂创建出数据源
            dataSource = basicDataSourceFactory.createDataSource(properties);
 
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
 
    // 创建返回连接对象的方法
    public static Connection getConn() {
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
 
    public static void release(ResultSet rs, PreparedStatement pstmt) {
        // 释放结果集
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        // 释放准备语句
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
 
    // 更新数据的操作增,删,改要用到的封装方法
    public static boolean upDate(String sql, Object[] obj) {
        boolean flag = false;
 
        try {
            // 准备语句的创建,带有sql命令的对象
            pstmt = getConn().prepareStatement(sql);
 
            for (int i = 1; i <= obj.length; i++) {
                pstmt.setObject(i, obj[i - 1]);
            }
            int i = pstmt.executeUpdate();
            if (i > 0) {
                flag = true;
            }
 
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            release(rs, pstmt);
        }
        return flag;
    }
 
    // 进行批量删除处理
    public static boolean updateBatchDel(String sql, Object[] ids) {
        boolean flag = false;
        Connection cOnn= getConn();
        PreparedStatement pstmt = null;
        ResultSet rs = null;
 
        try {
            conn.setAutoCommit(false);
            pstmt = conn.prepareStatement(sql);
            for (int i = 0; i <ids.length; i++)="" {="" pstmt.setobject(1,="" ids[i]);="" system.out.println(sql="" +="" "---------------"="" pstmt.addbatch();="" }="" int[]="" num="pstmt.executeBatch();" 批量执行="" for="" (int="" i="0;" <num.length;="" if="" (num[i]="=" 0)="" try="" conn.rollback();="" 进行事务回滚="" return="" flag;="" catch="" (sqlexception="" ex)="" ex.printstacktrace();="" conn.commit();="" 提交事务="" flag="true;" e)="" e.printstacktrace();="" finally="" release(rs,="" pstmt);="" 根据传入的表的名称,和每页数据得到传入表的所有的页数="" tablename:::::操作的数据表名称="" pagesize::::::每页显示的信息条数="" public="" static="" integer="" getcountpage(string="" tablename,="" pagesize)="" countpage="0;" string="" sql="select count(*) as c from " tablename;="" connection="" conn="Pool_dbcp.getConn();" preparedstatement="" pstmt="null;" resultset="" rs="null;" (rs.next())="" int="" countrecord="rs.getInt("c");" %="" pagesize="=" 0="" ?="" :="" 1;="" todo="" auto-generated="" block="" pool_dbcp.release(rs,="" countpage;="" <="" pre=""><br>                             <br>
        <script type="text/javascript">
            var cpro_id = "u6885494";
 
        </script>
        <script type="text/javascript" src="//cpro.baidustatic.com/cpro/ui/cm.js"></script>
    </ids.length;>
推荐阅读
  • 在当前众多持久层框架中,MyBatis(前身为iBatis)凭借其轻量级、易用性和对SQL的直接支持,成为许多开发者的首选。本文将详细探讨MyBatis的核心概念、设计理念及其优势。 ... [详细]
  • 本文探讨了如何优化和正确配置Kafka Streams应用程序以确保准确的状态存储查询。通过调整配置参数和代码逻辑,可以有效解决数据不一致的问题。 ... [详细]
  • 网络运维工程师负责确保企业IT基础设施的稳定运行,保障业务连续性和数据安全。他们需要具备多种技能,包括搭建和维护网络环境、监控系统性能、处理突发事件等。本文将探讨网络运维工程师的职业前景及其平均薪酬水平。 ... [详细]
  • PHP 5.5.0rc1 发布:深入解析 Zend OPcache
    2013年5月9日,PHP官方发布了PHP 5.5.0rc1和PHP 5.4.15正式版,这两个版本均支持64位环境。本文将详细介绍Zend OPcache的功能及其在Windows环境下的配置与测试。 ... [详细]
  • 本文详细介绍了 Java 中 org.apache.xmlbeans.SchemaType 类的 getBaseEnumType() 方法,提供了多个代码示例,并解释了其在不同场景下的使用方法。 ... [详细]
  • 本文介绍如何在Java项目中使用Log4j库进行日志记录。我们将详细说明Log4j库的引入、配置及简单应用,帮助开发者快速上手。 ... [详细]
  • 本文详细介绍了如何在ECharts中使用线性渐变色,通过echarts.graphic.LinearGradient方法实现。文章不仅提供了完整的代码示例,还解释了各个参数的具体含义及其应用场景。 ... [详细]
  • 本文详细介绍了如何解决MyBatis中常见的BindingException错误,提供了多种排查和修复方法,确保Mapper接口与XML文件的正确配置。 ... [详细]
  • 解决JAX-WS动态客户端工厂弃用问题并迁移到XFire
    在处理Java项目中的JAR包冲突时,我们遇到了JaxWsDynamicClientFactory被弃用的问题,并成功将其迁移到org.codehaus.xfire.client。本文详细介绍了这一过程及解决方案。 ... [详细]
  • 本文详细介绍了Linux系统中init进程的作用及其启动过程,解释了运行级别的概念,并提供了调整服务启动顺序的具体步骤和实例。通过了解这些内容,用户可以更好地管理系统的启动流程和服务配置。 ... [详细]
  • 深入解析 Apache Shiro 安全框架架构
    本文详细介绍了 Apache Shiro,一个强大且灵活的开源安全框架。Shiro 专注于简化身份验证、授权、会话管理和加密等复杂的安全操作,使开发者能够更轻松地保护应用程序。其核心目标是提供易于使用和理解的API,同时确保高度的安全性和灵活性。 ... [详细]
  • 探讨了小型企业在构建安全网络和软件时所面临的挑战和机遇。本文介绍了如何通过合理的方法和工具,确保小型企业能够有效提升其软件的安全性,从而保护客户数据并增强市场竞争力。 ... [详细]
  • 本文详细介绍了如何准备和安装 Eclipse 开发环境及其相关插件,包括 JDK、Tomcat、Struts 等组件的安装步骤及配置方法。 ... [详细]
  • HBase运维工具全解析
    本文深入探讨了HBase常用的运维工具,详细介绍了每种工具的功能、使用场景及操作示例。对于HBase的开发人员和运维工程师来说,这些工具是日常管理和故障排查的重要手段。 ... [详细]
  • 在本周的白板演练中,Apache Flink 的 PMC 成员及数据工匠首席技术官 Stephan Ewen 深入探讨了如何利用保存点功能进行流处理中的数据重新处理、错误修复、系统升级和 A/B 测试。本文将详细解释保存点的工作原理及其应用场景。 ... [详细]
author-avatar
手机用户2602927805
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有