热门标签 | 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的核心概念、设计理念及其优势。 ... [详细]
  • Windows服务与数据库交互问题解析
    本文探讨了在Windows 10(64位)环境下开发的Windows服务,旨在定期向本地MS SQL Server (v.11)插入记录。尽管服务已成功安装并运行,但记录并未正确插入。我们将详细分析可能的原因及解决方案。 ... [详细]
  • 本文探讨了Hive中内部表和外部表的区别及其在HDFS上的路径映射,详细解释了两者的创建、加载及删除操作,并提供了查看表详细信息的方法。通过对比这两种表类型,帮助读者理解如何更好地管理和保护数据。 ... [详细]
  • 本文详细介绍了如何在Linux系统上安装和配置Smokeping,以实现对网络链路质量的实时监控。通过详细的步骤和必要的依赖包安装,确保用户能够顺利完成部署并优化其网络性能监控。 ... [详细]
  • 本文详细介绍了 Dockerfile 的编写方法及其在网络配置中的应用,涵盖基础指令、镜像构建与发布流程,并深入探讨了 Docker 的默认网络、容器互联及自定义网络的实现。 ... [详细]
  • 在哈佛大学商学院举行的Cyberposium大会上,专家们深入探讨了开源软件的崛起及其对企业市场的影响。会议指出,开源软件不仅为企业提供了新的增长机会,还促进了软件质量的提升和创新。 ... [详细]
  • 作为一名新手,您可能会在初次尝试使用Eclipse进行Struts开发时遇到一些挑战。本文将为您提供详细的指导和解决方案,帮助您克服常见的配置和操作难题。 ... [详细]
  • 如何在PHPCMS V9中实现多站点功能并配置独立域名与动态URL
    本文介绍如何在PHPCMS V9中创建和管理多个站点,包括配置独立域名、设置动态URL,并确保各子站能够正常运行。我们将详细讲解从新建站点到最终配置路由的每一步骤。 ... [详细]
  • 本文详细分析了Hive在启动过程中遇到的权限拒绝错误,并提供了多种解决方案,包括调整文件权限、用户组设置以及环境变量配置等。 ... [详细]
  • 本文详细介绍了Java中org.w3c.dom.Text类的splitText()方法,通过多个代码示例展示了其实际应用。该方法用于将文本节点在指定位置拆分为两个节点,并保持在文档树中。 ... [详细]
  • 本文探讨了如何优化和正确配置Kafka Streams应用程序以确保准确的状态存储查询。通过调整配置参数和代码逻辑,可以有效解决数据不一致的问题。 ... [详细]
  • 本文详细介绍了 Apache Jena 库中的 Txn.executeWrite 方法,通过多个实际代码示例展示了其在不同场景下的应用,帮助开发者更好地理解和使用该方法。 ... [详细]
  • 网络运维工程师负责确保企业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() 方法,提供了多个代码示例,并解释了其在不同场景下的使用方法。 ... [详细]
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社区 版权所有