日期:2014-05-17  浏览次数:20851 次

使用dbcp连接池Insert成功但是查询无记录

package com.hero.Dao;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;
/**
 * @author Hero
 *
 * dbcp 实用类,提供了dbcp连接,不允许继承;
 * 
 * 该类需要有个地方来初始化 DS ,通过调用initDS 方法来完成,可以在通过调用带参数的构造函数完成调用,
 * 可以在其它类中调用,也可以在本类中加一个static{}来完成;
 */
public final class MySqlDbPool {
/** 数据源,static */
private static DataSource DS;
/** 从数据源获得一个连接 */
public Connection getConn() {
Connection con = null;
if (DS!= null) {
try {
con = DS.getConnection();
} catch (Exception e) {
e.printStackTrace(System.err);
}

try {
con.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
return con;
}
return con;
}
/** 默认的构造函数 */
public MySqlDbPool() {
}
/** 构造函数,初始化了 DS ,指定 数据库 */
public MySqlDbPool(String connectURI) {
initDS(connectURI);
}
/** 构造函数,初始化了 DS ,指定 所有参数 */
public MySqlDbPool(String connectURI, String username, String pswd, String driverClass, int initialSize,
int maxActive, int maxIdle, int maxWait) {
initDS(connectURI, username, pswd, driverClass, initialSize, maxActive, maxIdle, maxWait);
}
/**
 * 创建数据源,除了数据库外,都使用硬编码默认参数;
 * 
 * @param connectURI 数据库
 * @return
 */
public static void initDS(String connectURI) {
initDS(connectURI, "root", "sa", "com.mysql.jdbc.Driver", 10, 100, 30, 10000);
}
/** 
 * 指定所有参数连接数据源
 * 
 * @param connectURI 数据库
 * @param username 用户名
 * @param pswd 密码
 * @param driverClass 数据库连接驱动名
 * @param initialSize 初始连接池连接个数
 * @param maxActive 最大激活连接数
 * @param maxIdle 最大闲置连接数
 * @param maxWait 获得连接的最大等待毫秒数
 * @return
 */
public static void initDS(String connectURI, String username, String pswd, String driverClass, int initialSize,
int maxActive, int maxIdle, int maxWait) {
BasicDataSource ds = new BasicDataSource();
ds.setDriverClassName(driverClass);
ds.setUsername(username);
ds.setPassword(pswd);
ds.setUrl(connectURI);
ds.setInitialSize(initialSize); // 初始的连接数;
ds.setMaxActive(maxActive);
ds.setMaxIdle(maxIdle);
ds.setMaxWait(maxWait);
DS = ds;
}
/** 获得数据源连接状态 */
public static Map<String, Integer> getDa