[关闭]
@caos 2014-09-02T13:58:10.000000Z 字数 6152 阅读 2153

JDBC DataSource

编程

简介

DataSource是JDBC规范的一部分， 它被视为一个通用的数据库连接工厂。通过使用DataSource， Container或Framework可以将连接池以及事务管理的细节从应用代码中分离出来。 作为一个开发人员，在开发和测试产品的过程中，你可能需要知道连接数据库的细节。 但在产品实施时，你不需要知道这些细节。通常数据库管理员会帮你设置好数据源。

也就是说，DataSource接口能够将应用程序和数据库解耦，从而使应用程序能够方便的从多种不同的数据库中切换，当然，这也离不开各数据库提供商对JDBC结构标准实现的努力。
JDBC
JDBC DataSource 接口由 javax.sql包中，而且接口中声明了两个需要实现的方法：

使用指南

数据库 Oracle MySQL
接口 oracle.jdbc.pool.OracleDataSource com.mysql.jdbc.jdbc2.optional.MysqlDataSource

创建一个简单的JDBC项目引入Jar包
此处输入图片的描述

创建数据库表结构

在Oracle和MySQL中创建表并初始化数据

MySQLSetup.sql

  1. --Create Employee table
  2. CREATE TABLE `Employee` (
  3.   `empId` int(10) unsigned NOT NULL,
  4.   `name` varchar(10) DEFAULT NULL,
  5.   PRIMARY KEY (`empId`)
  6. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  8. -- insert some sample data
  9. INSERT INTO `Employee` (`empId`, `name`)
  10. VALUES
  11.     (1, 'Pankaj'),
  12.     (2, 'David');
  14. commit;

OracleSetup.sql

  1. CREATE TABLE "EMPLOYEE"
  2.   (
  3.     "EMPID"   NUMBER NOT NULL ENABLE,
  4.     "NAME"    VARCHAR2(10 BYTE) DEFAULT NULL,
  5.     PRIMARY KEY ("EMPID")
  6.   );
  8. Insert into EMPLOYEE (EMPID,NAME) values (10,'Pankaj');
  9. Insert into EMPLOYEE (EMPID,NAME) values (5,'Kumar');
  10. Insert into EMPLOYEE (EMPID,NAME) values (1,'Pankaj');
  11. commit;

数据库连接配置

db.properties

  1. #mysql DB properties
  2. MYSQL_DB_DRIVER_CLASS=com.mysql.jdbc.Driver
  3. MYSQL_DB_URL=jdbc:mysql://localhost:3306/UserDB
  4. MYSQL_DB_USERNAME=pankaj
  5. MYSQL_DB_PASSWORD=pankaj123
  7. #Oracle DB Properties
  8. ORACLE_DB_DRIVER_CLASS=oracle.jdbc.driver.OracleDriver
  9. ORACLE_DB_URL=jdbc:oracle:thin:@localhost:1521:orcl
  10. ORACLE_DB_USERNAME=hr
  11. ORACLE_DB_PASSWORD=oracle

示例代码

MyDataSourceFactory.java

  1. package com.journaldev.jdbc.datasource;
  3. import java.io.FileInputStream;
  4. import java.io.IOException;
  5. import java.sql.SQLException;
  6. import java.util.Properties;
  8. import javax.sql.DataSource;
  10. import oracle.jdbc.pool.OracleDataSource;
  12. import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
  14. public class MyDataSourceFactory {
  16.     public static DataSource getMySQLDataSource() {
  17.         Properties props = new Properties();
  18.         FileInputStream fis = null;
  19.         MysqlDataSource mysqlDS = null;
  20.         try {
  21.             fis = new FileInputStream("db.properties");
  22.             props.load(fis);
  23.             mysqlDS = new MysqlDataSource();
  24.             mysqlDS.setURL(props.getProperty("MYSQL_DB_URL"));
  25.             mysqlDS.setUser(props.getProperty("MYSQL_DB_USERNAME"));
  26.             mysqlDS.setPassword(props.getProperty("MYSQL_DB_PASSWORD"));
  27.         } catch (IOException e) {
  28.             e.printStackTrace();
  29.         }
  30.         return mysqlDS;
  31.     }
  33.     public static DataSource getOracleDataSource(){
  34.         Properties props = new Properties();
  35.         FileInputStream fis = null;
  36.         OracleDataSource oracleDS = null;
  37.         try {
  38.             fis = new FileInputStream("db.properties");
  39.             props.load(fis);
  40.             oracleDS = new OracleDataSource();
  41.             oracleDS.setURL(props.getProperty("ORACLE_DB_URL"));
  42.             oracleDS.setUser(props.getProperty("ORACLE_DB_USERNAME"));
  43.             oracleDS.setPassword(props.getProperty("ORACLE_DB_PASSWORD"));
  44.         } catch (IOException e) {
  45.             e.printStackTrace();
  46.         } catch (SQLException e) {
  47.             e.printStackTrace();
  48.         }
  49.         return oracleDS;
  50.     }
  52. }

测试代码
DataSourceTest.java

  1. package com.journaldev.jdbc.datasource;
  3. import java.sql.Connection;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  8. import javax.sql.DataSource;
  10. public class DataSourceTest {
  12.     public static void main(String[] args) {
  14.         testDataSource("mysql");
  15.         System.out.println("**********");
  16.         testDataSource("oracle");
  18.     }
  20.     private static void testDataSource(String dbType) {
  21.         DataSource ds = null;
  22.         if("mysql".equals(dbType)){
  23.             ds = MyDataSourceFactory.getMySQLDataSource();
  24.         }else if("oracle".equals(dbType)){
  25.             ds = MyDataSourceFactory.getOracleDataSource();
  26.         }else{
  27.             System.out.println("invalid db type");
  28.             return;
  29.         }
  31.         Connection con = null;
  32.         Statement stmt = null;
  33.         ResultSet rs = null;
  34.         try {
  35.             con = ds.getConnection();
  36.             stmt = con.createStatement();
  37.             rs = stmt.executeQuery("select empid, name from Employee");
  38.             while(rs.next()){
  39.                 System.out.println("Employee ID="+rs.getInt("empid")+", Name="+rs.getString("name"));
  40.             }
  41.         } catch (SQLException e) {
  42.             e.printStackTrace();
  43.         }finally{
  44.                 try {
  45.                     if(rs != null) rs.close();
  46.                     if(stmt != null) stmt.close();
  47.                     if(con != null) con.close();
  48.                 } catch (SQLException e) {
  49.                     e.printStackTrace();
  50.                 }
  51.         }
  52.     }
  54. }

测试结果

Employee ID=1, Name=Pankaj
Employee ID=2, Name=David
**********
Employee ID=10, Name=Pankaj
Employee ID=5, Name=Kumar
Employee ID=1, Name=Pankaj

Apache Commons DBCP 示例

上图中项目结构中我们看到了DBCP的Jar包，使用DBCP能够更好的解耦应用程序与数据库的关联，下面给出使用DBCP的做法：

示例代码
DBCPDataSourceFactory.java

  1. package com.journaldev.jdbc.datasource;
  3. import java.io.FileInputStream;
  4. import java.io.IOException;
  5. import java.util.Properties;
  7. import javax.sql.DataSource;
  9. import org.apache.commons.dbcp.BasicDataSource;
  11. public class DBCPDataSourceFactory {
  13.     public static DataSource getDataSource(String dbType){
  14.         Properties props = new Properties();
  15.         FileInputStream fis = null;
  16.         BasicDataSource ds = new BasicDataSource();
  18.         try {
  19.             fis = new FileInputStream("db.properties");
  20.             props.load(fis);
  21.         }catch(IOException e){
  22.             e.printStackTrace();
  23.             return null;
  24.         }
  25.         if("mysql".equals(dbType)){
  26.             ds.setDriverClassName(props.getProperty("MYSQL_DB_DRIVER_CLASS"));
  27.             ds.setUrl(props.getProperty("MYSQL_DB_URL"));
  28.             ds.setUsername(props.getProperty("MYSQL_DB_USERNAME"));
  29.             ds.setPassword(props.getProperty("MYSQL_DB_PASSWORD"));
  30.         }else if("oracle".equals(dbType)){
  31.             ds.setDriverClassName(props.getProperty("ORACLE_DB_DRIVER_CLASS"));
  32.             ds.setUrl(props.getProperty("ORACLE_DB_URL"));
  33.             ds.setUsername(props.getProperty("ORACLE_DB_USERNAME"));
  34.             ds.setPassword(props.getProperty("ORACLE_DB_PASSWORD"));
  35.         }else{
  36.             return null;
  37.         }
  39.         return ds;
  40.     }
  41. }

测试代码
ApacheCommonsDBCPTest.java

  1. package com.journaldev.jdbc.datasource;
  3. import java.sql.Connection;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  8. import javax.sql.DataSource;
  10. public class ApacheCommonsDBCPTest {
  12.     public static void main(String[] args) {
  13.         testDBCPDataSource("mysql");
  14.         System.out.println("**********");
  15.         testDBCPDataSource("oracle");
  16.     }
  18.     private static void testDBCPDataSource(String dbType) {
  19.         DataSource ds = DBCPDataSourceFactory.getDataSource(dbType);
  21.         Connection con = null;
  22.         Statement stmt = null;
  23.         ResultSet rs = null;
  24.         try {
  25.             con = ds.getConnection();
  26.             stmt = con.createStatement();
  27.             rs = stmt.executeQuery("select empid, name from Employee");
  28.             while(rs.next()){
  29.                 System.out.println("Employee ID="+rs.getInt("empid")+", Name="+rs.getString("name"));
  30.             }
  31.         } catch (SQLException e) {
  32.             e.printStackTrace();
  33.         }finally{
  34.                 try {
  35.                     if(rs != null) rs.close();
  36.                     if(stmt != null) stmt.close();
  37.                     if(con != null) con.close();
  38.                 } catch (SQLException e) {
  39.                     e.printStackTrace();
  40.                 }
  41.         }
  42.     }
  44. }

测试结果与第一次相同

总结

DataSource的获取方式，也可以使用主流容器（Tomcat/JBoss）中提供的JNDI(Java Naming and Directory Interface,Java命名和目录接口)，这些都是为了满足应用程序能够更灵活的使用数据库连接而产生的，本文大部分内容摘录自JDBC DataSource Example – Oracle, MySQL and Apache DBCP Tutorial英文好的童鞋可以阅读原版。

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注