JDBC连接数据库实例

package javacommon.base;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class JDBCTemplate {	

	private Connection conn = null;

	private Connection getConnection() {
         if(conn == null) {
        	 conn = DBManager.getConn();
         }
         return conn;
	}

	public JDBCTemplate(Connection conn) {
		this.conn = conn;
	}

	public JDBCTemplate() {
		conn = getConnection();
	}	

	public Connection getConn() {
        return conn;
    }

    public void beginTranscation() throws SQLException {
		conn.setAutoCommit(false);
	}

	public void commit() throws SQLException {
		conn.commit();
	}

	@SuppressWarnings("unchecked")
	public List<Map> query(String sql, Object[] params) throws SQLException {

		PreparedStatement pStmt = null;
		ResultSet rSet = null;
		List<Map> list = new ArrayList<Map>();

		try {
			pStmt = conn.prepareStatement(sql);
			for (int i = 0; i < params.length; i++) {
				pStmt.setObject(i + 1, params[i]);
			}
			rSet = pStmt.executeQuery();
			ResultSetMetaData rsmd = rSet.getMetaData();
			String[] names = new String[rsmd.getColumnCount()];
			for (int i = 0; i < names.length; i++) {
				names[i] = rsmd.getColumnName(i + 1);
			}
			while (rSet.next()) {
				Map row = new HashMap();
				for (int i = 0; i < names.length; i++) {
					row.put(names[i], rSet.getObject(i + 1));
				}
				list.add(row);
			}
		} catch(SQLException e) {
			e.printStackTrace();
			throw e;
		} finally {
			if (rSet != null) {
				try {
					rSet.close();
				} catch(SQLException e) {}
			}
			if (pStmt != null) {
				try {
					pStmt.close();
				} catch(SQLException e) {}
			}
		}
		return list;
	}

	public int insert(String sql, Object[] params) throws SQLException {
		return executeUpdate(sql, params);
	}

	public int executeUpdate(String sql, Object[] params) throws SQLException {
		PreparedStatement pStmt = null;
		ResultSet rSet = null;
		int result = 0;

		try {
			pStmt = conn.prepareStatement(sql);
			for (int i = 0; i < params.length; i++) {
				pStmt.setObject(i + 1, params[i]);
			}
			result = pStmt.executeUpdate();
		} catch(SQLException e) {
			e.printStackTrace();
			throw e;
		} finally {
			if (pStmt != null) {
				try {
					pStmt.close();
				} catch(SQLException e) {}
			}
		}
		return result;
	}

	public void close() {

		if (conn != null) {
			DBManager.closeConn(conn);
		}

	}
}
package javacommon.base;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * 数据库连接池管理类
 * @author SN11631
 *
 */
public class DBManager {
	private static final Log LOG = LogFactory.getLog(DBManager.class);
	private static DataSource dataSource;

	static {
		Properties properties = PropertiesHandler.readPropertiesFile("/opt/hr/hr-info-sync.properites");
		try {
			BasicDataSource basicDataSource = new BasicDataSource();
			if (null != properties
					.getProperty("dataSource.accessToUnderlyingConnectionAllowed")) {
				basicDataSource
						.setAccessToUnderlyingConnectionAllowed(Boolean.valueOf(properties
								.getProperty("dataSource.accessToUnderlyingConnectionAllowed")));
			}
			// if (null !=
			// properties.getProperty("dataSource.connectionInitSqls"))
			// {basicDataSource.setConnectionInitSqls(properties.getProperty("dataSource.connectionInitSqls"));}
			if (null != properties
					.getProperty("dataSource.connectionProperties")) {
				basicDataSource.setConnectionProperties(properties
						.getProperty("dataSource.connectionProperties"));
			}
			if (null != properties.getProperty("dataSource.defaultAutoCommit")) {
				basicDataSource.setDefaultAutoCommit(Boolean.valueOf(properties
						.getProperty("dataSource.defaultAutoCommit")));
			}
			if (null != properties.getProperty("dataSource.defaultCatalog")) {
				basicDataSource.setDefaultCatalog(properties
						.getProperty("dataSource.defaultCatalog"));
			}
			if (null != properties.getProperty("dataSource.defaultReadOnly")) {
				basicDataSource.setDefaultReadOnly(Boolean.valueOf(properties
						.getProperty("dataSource.defaultReadOnly")));
			}
			if (null != properties
					.getProperty("dataSource.defaultTransactionIsolation")) {
				basicDataSource
						.setDefaultTransactionIsolation(Integer.valueOf(properties
								.getProperty("dataSource.defaultTransactionIsolation")));
			}
			// if (null !=
			// properties.getProperty("dataSource.driverClassLoader"))
			// {basicDataSource.setDriverClassLoader(properties.getProperty("dataSource.driverClassLoader"));}
			if (null != properties.getProperty("dataSource.driverClassName")) {
				basicDataSource.setDriverClassName(properties
						.getProperty("dataSource.driverClassName"));
			}
			if (null != properties.getProperty("dataSource.initialSize")) {
				basicDataSource.setInitialSize(Integer.valueOf(properties
						.getProperty("dataSource.initialSize")));
			}
			if (null != properties.getProperty("dataSource.logAbandoned")) {
				basicDataSource.setLogAbandoned(Boolean.valueOf(properties
						.getProperty("dataSource.logAbandoned")));
			}
			if (null != properties.getProperty("dataSource.loginTimeout")) {
				basicDataSource.setLoginTimeout(Integer.valueOf(properties
						.getProperty("dataSource.loginTimeout")));
			}
			// if (null != properties.getProperty("dataSource.logWriter"))
			// {basicDataSource.setLogWriter(properties.getProperty("dataSource.logWriter"));}
			if (null != properties.getProperty("dataSource.maxActive")) {
				basicDataSource.setMaxActive(Integer.valueOf(properties
						.getProperty("dataSource.maxActive")));
			}
			if (null != properties.getProperty("dataSource.maxIdle")) {
				basicDataSource.setMaxIdle(Integer.valueOf(properties
						.getProperty("dataSource.maxIdle")));
			}
			if (null != properties
					.getProperty("dataSource.maxOpenPreparedStatements")) {
				basicDataSource
						.setMaxOpenPreparedStatements(Integer.valueOf(properties
								.getProperty("dataSource.maxOpenPreparedStatements")));
			}
			if (null != properties.getProperty("dataSource.maxWait")) {
				basicDataSource.setMaxWait(Long.valueOf(properties
						.getProperty("dataSource.maxWait")));
			}
			if (null != properties
					.getProperty("dataSource.minEvictableIdleTimeMillis")) {
				basicDataSource
						.setMinEvictableIdleTimeMillis(Long.valueOf(properties
								.getProperty("dataSource.minEvictableIdleTimeMillis")));
			}
			if (null != properties.getProperty("dataSource.minIdle")) {
				basicDataSource.setMinIdle(Integer.valueOf(properties
						.getProperty("dataSource.minIdle")));
			}
			if (null != properties
					.getProperty("dataSource.numTestsPerEvictionRun")) {
				basicDataSource
						.setNumTestsPerEvictionRun(Integer.valueOf(properties
								.getProperty("dataSource.numTestsPerEvictionRun")));
			}
			if (null != properties.getProperty("dataSource.password")) {
				basicDataSource.setPassword(properties
						.getProperty("dataSource.password"));
			}
			if (null != properties
					.getProperty("dataSource.poolPreparedStatements")) {
				basicDataSource
						.setPoolPreparedStatements(Boolean.valueOf(properties
								.getProperty("dataSource.poolPreparedStatements")));
			}
			if (null != properties.getProperty("dataSource.removeAbandoned")) {
				basicDataSource.setRemoveAbandoned(Boolean.valueOf(properties
						.getProperty("dataSource.removeAbandoned")));
			}
			if (null != properties
					.getProperty("dataSource.removeAbandonedTimeout")) {
				basicDataSource
						.setRemoveAbandonedTimeout(Integer.valueOf(properties
								.getProperty("dataSource.removeAbandonedTimeout")));
			}
			if (null != properties.getProperty("dataSource.testOnBorrow")) {
				basicDataSource.setTestOnBorrow(Boolean.valueOf(properties
						.getProperty("dataSource.testOnBorrow")));
			}
			if (null != properties.getProperty("dataSource.testOnReturn")) {
				basicDataSource.setTestOnReturn(Boolean.valueOf(properties
						.getProperty("dataSource.testOnReturn")));
			}
			if (null != properties.getProperty("dataSource.testWhileIdle")) {
				basicDataSource.setTestWhileIdle(Boolean.valueOf(properties
						.getProperty("dataSource.testWhileIdle")));
			}
			if (null != properties
					.getProperty("dataSource.timeBetweenEvictionRunsMillis")) {
				basicDataSource
						.setTimeBetweenEvictionRunsMillis(Long.valueOf(properties
								.getProperty("dataSource.timeBetweenEvictionRunsMillis")));
			}
			if (null != properties.getProperty("dataSource.url")) {
				basicDataSource
						.setUrl(properties.getProperty("dataSource.url"));
			}
			if (null != properties.getProperty("dataSource.username")) {
				basicDataSource.setUsername(properties
						.getProperty("dataSource.username"));
			}
			if (null != properties.getProperty("dataSource.validationQuery")) {
				basicDataSource.setValidationQuery(properties
						.getProperty("dataSource.validationQuery"));
			}
			if (null != properties
					.getProperty("dataSource.validationQueryTimeout")) {
				basicDataSource
						.setValidationQueryTimeout(Integer.valueOf(properties
								.getProperty("dataSource.validationQueryTimeout")));
			}

			dataSource = basicDataSource;

			Connection conn = getConn();
			DatabaseMetaData mdm = conn.getMetaData();
			LOG.info("Connected to " + mdm.getDatabaseProductName() + " "
			+ mdm.getDatabaseProductVersion());
			if (conn != null) {
				conn.close();
			}
		} catch (Exception e) {
			LOG.error("初始化连接池失败:" + e);
		}
	}

	/**
	  * 获取链接,用完后记得关闭
	  * @see {@link DBManager#closeConn(Connection)}
	  * @return
	  */
	public static final Connection getConn() {
		Connection conn = null;
		try {
			conn = dataSource.getConnection();
		} catch (SQLException e) {
			LOG.error("获取数据库连接失败:" + e);
		}
		return conn;
	}

	/**
	 * 关闭连接
	 * 
	 * @param conn
	 *            需要关闭的连接
	 */
	public static void closeConn(Connection conn) {
		try {
			if (conn != null && !conn.isClosed()) {
				conn.setAutoCommit(true);
				conn.close();
			}
		} catch (SQLException e) {
			LOG.error("关闭数据库连接失败:" + e);
		}
	}
}
package javacommon.base;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * Properties处理
 * @author SN11631
 *
 */
public class PropertiesHandler {

	/**
	 * 读取资源文件
	 * @param filename 文件名
	 * @return Properties
	 */
	public static Properties readPropertiesFile(String filename)  
	{  
	    Properties properties = new Properties();  
	    try  
	    {  
	        InputStream inputStream = new FileInputStream(filename);  
	        properties.load(inputStream);  
	        inputStream.close(); //关闭流  
	    }  
	    catch (IOException e)  
	    {
	        e.printStackTrace();  
	    }
	    
	    return properties;
	}
}
时间: 2024-10-10 21:22:53

JDBC连接数据库实例的相关文章

Java实现JDBC连接数据库实例

1 import java.sql.Connection; 2 import java.sql.DriverManager; 3 import java.sql.ResultSet; 4 import java.sql.SQLException; 5 import java.sql.Statement; 6 7 public class JDBCTest { 8 9 private static final String URL="jdbc:mysql://127.0.0.1:3306/stud

【转】Java开发中JDBC连接数据库代码和步骤总结

(转自:http://www.cnblogs.com/hongten/archive/2011/03/29/1998311.html) JDBC连接数据库 创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("co

完整java开发中JDBC连接数据库代码和步骤

完整java开发中JDBC连接数据库代码和步骤 JDBC连接数据库 •创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机), 这通过java.lang.Class类的静态方法forName(String  className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(Class

Java开发中JDBC连接数据库代码和步骤

JDBC连接数据库:创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String  className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver"); }catch(ClassNotFoundException e){ Syste

JDBC - 开发实例 - MVC模式

JDBC - 开发实例 - MVC模式  1. 在web.xml中配置连接数据库的信息 web.xml: <context-param> <param-name>server</param-name> //主机名 <param-value>localhost</param-value> </context-param> <context-param> <param-name>db</param-name&

Java中JDBC连接数据库(MySQL)

 JDBC连接数据库步骤. 一个简单详细的查询数据的例子. 封装连接数据库,释放数据库连接方法. 实现查询,插入,删除,更新等十一个处理数据库信息的功能.(包括事务处理,批量更新等) 把十一个功能都放在一起. 安装下载的数据库驱动程序jar包,不同的数据库需要不同的驱动程序(这本该是第一步,但是由于属于安装类,所以我们放在最后) 一.JDBC连接数据库(编辑)步骤(主要有六个步骤).  1.注册驱动: Class.forName("com.mysql.jdbc.Driver");显示的

JDBC系列:(1)通过JDBC连接数据库

1.什么是JDBC 2.JDBC连接数据库的三种方式 2.1.第一种实现方式 2.2.第二种实现方式 2.3.第三种实现方式 3.com.mysql.jdbc.Driver的内部实现 1.什么是JDBC 使用java代码(程序)发送sql语句的技术 使用jdbc发送sql前提需要知道:数据库的IP地址.端口.数据名.用户名和密码. JDBC的URL=协议名+子协议名+数据源名. a 协议名总是"jdbc". b 子协议名由JDBC驱动程序的编写者决定. c 数据源名也可能包含用户与口令

JDBC 连接数据库代码及步骤

完整java开发中JDBC连接数据库代码和步骤 JDBC连接数据库 ?创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机), 这通过java.lang.Class类的静态方法forName(String  className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(Class

使用JDBC连接数据库详解

JDBC连接数据库详细流程 ?创建一个以JDBC连接数据库的程序,包含7个步骤:    1.加载JDBC驱动程序:       在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),       这通过java.lang.Class类的静态方法forName(String  className)实现.       例如:       try{       //加载MySql的驱动类       Class.forName("com.mysql.jdbc.Driver&qu