Java数据源,JDBC数据源示例
Java的DataSource和JDBC DataSource编程是我们在java程序中与数据库交互的方式。我们已经知道可以使用JDBC DriverManager获取关系数据库连接。但是当我们进行实际编程时,我们想要的不仅是连接。
Java数据源
大多数时候,我们寻求松耦合来实现连接性,以便可以轻松切换数据库、事务管理和分布式系统支持的连接池。如果您在应用程序中需要这些功能之一,JDBC DataSource 是首选方法。Java 的 DataSource 接口位于 javax.sql 包中,它仅声明了两个重载方法:getConnection() 和 getConnection(String str1, String str2)。
JDBC数据源
不同的数据库供应商有责任提供不同种类的DataSource接口的实现。例如,MySQL JDBC驱动程序使用com.mysql.jdbc.jdbc2.optional.MysqlDataSource类提供DataSource接口的基本实现,而Oracle数据库驱动程序使用oracle.jdbc.pool.OracleDataSource类来实现。这些实现类通过方法来提供数据库服务器详细信息和用户凭据。这些JDBC DataSource实现类提供的其他常见功能包括:
- Caching of PreparedStatement for faster processing
- Connection timeout settings
- Logging features
- ResultSet maximum size threshold
JDBC数据源示例
让我们创建一个简单的JDBC数据源示例项目,学习如何使用MySQL和Oracle数据源基本实现类来获取数据库连接。我们的最终项目将如下图所示。
Java JDBC数据源 – 数据库设置
在我们开始示例程序之前,我们需要进行一些数据库的设置,包括表和示例数据。MySQL或Oracle数据库的安装不在本教程的范围内,所以我会直接设置表格并填充示例数据。
--Create Employee table
CREATE TABLE `Employee` (
`empId` int(10) unsigned NOT NULL,
`name` varchar(10) DEFAULT NULL,
PRIMARY KEY (`empId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- insert some sample data
INSERT INTO `Employee` (`empId`, `name`)
VALUES
(1, 'Pankaj'),
(2, 'David');
commit;
CREATE TABLE "EMPLOYEE"
(
"EMPID" NUMBER NOT NULL ENABLE,
"NAME" VARCHAR2(10 BYTE) DEFAULT NULL,
PRIMARY KEY ("EMPID")
);
Insert into EMPLOYEE (EMPID,NAME) values (10,'Pankaj');
Insert into EMPLOYEE (EMPID,NAME) values (5,'Kumar');
Insert into EMPLOYEE (EMPID,NAME) values (1,'Pankaj');
commit;
现在,我们继续进行我们的Java程序。为了使数据库配置松散耦合,我将从属性文件中读取它们。 db.properties文件:
#mysql DB properties
MYSQL_DB_DRIVER_CLASS=com.mysql.jdbc.Driver
MYSQL_DB_URL=jdbc:mysql://localhost:3306/UserDB
MYSQL_DB_USERNAME=scdev
MYSQL_DB_PASSWORD=scdev123
#Oracle DB Properties
ORACLE_DB_DRIVER_CLASS=oracle.jdbc.driver.OracleDriver
ORACLE_DB_URL=jdbc:oracle:thin:@localhost:1521:orcl
ORACLE_DB_USERNAME=hr
ORACLE_DB_PASSWORD=oracle
请确保上述配置与您的本地设置相匹配。还请确保您的项目构建路径中包含了MySQL和Oracle DB JDBC jars文件。
Java JDBC 数据源 – MySQL、Oracle 示例
让我们编写一个工厂类,用来获取MySQL或Oracle的数据源。
package com.Olivia.jdbc.datasource;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import oracle.jdbc.pool.OracleDataSource;
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
public class MyDataSourceFactory {
public static DataSource getMySQLDataSource() {
Properties props = new Properties();
FileInputStream fis = null;
MysqlDataSource mysqlDS = null;
try {
fis = new FileInputStream("db.properties");
props.load(fis);
mysqlDS = new MysqlDataSource();
mysqlDS.setURL(props.getProperty("MYSQL_DB_URL"));
mysqlDS.setUser(props.getProperty("MYSQL_DB_USERNAME"));
mysqlDS.setPassword(props.getProperty("MYSQL_DB_PASSWORD"));
} catch (IOException e) {
e.printStackTrace();
}
return mysqlDS;
}
public static DataSource getOracleDataSource(){
Properties props = new Properties();
FileInputStream fis = null;
OracleDataSource oracleDS = null;
try {
fis = new FileInputStream("db.properties");
props.load(fis);
oracleDS = new OracleDataSource();
oracleDS.setURL(props.getProperty("ORACLE_DB_URL"));
oracleDS.setUser(props.getProperty("ORACLE_DB_USERNAME"));
oracleDS.setPassword(props.getProperty("ORACLE_DB_PASSWORD"));
} catch (IOException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return oracleDS;
}
}
请注意,Oracle和MySQL的数据源实现类非常相似。让我们编写一个简单的测试程序来使用这些方法并运行一些测试。
package com.Olivia.jdbc.datasource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.sql.DataSource;
public class DataSourceTest {
public static void main(String[] args) {
testDataSource("mysql");
System.out.println("**********");
testDataSource("oracle");
}
private static void testDataSource(String dbType) {
DataSource ds = null;
if("mysql".equals(dbType)){
ds = MyDataSourceFactory.getMySQLDataSource();
}else if("oracle".equals(dbType)){
ds = MyDataSourceFactory.getOracleDataSource();
}else{
System.out.println("invalid db type");
return;
}
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try {
con = ds.getConnection();
stmt = con.createStatement();
rs = stmt.executeQuery("select empid, name from Employee");
while(rs.next()){
System.out.println("Employee ID="+rs.getInt("empid")+", Name="+rs.getString("name"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(con != null) con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
请注意,客户端类完全独立于任何特定数据库类。这有助于我们隐藏客户程序的底层实现细节,实现松耦合和抽象优势。当我们运行上述测试程序时,将获得以下输出。
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(数据库连接池)示例
如果你看上面的Java DataSource工厂类,其中有两个主要问题。
-
- 创建MySQL和Oracle DataSource的工厂类方法与它们各自的驱动程序API紧密耦合。如果未来想要移除对Oracle数据库的支持或者想要增加其他数据库的支持,就需要修改代码。
- 获取MySQL和Oracle DataSource的大部分代码是相似的,只有使用的实现类不同。
Apache Commons DBCP API通过提供Java DataSource实现作为我们程序与不同JDBC驱动程序之间的抽象层,帮助我们摆脱这些问题。 Apache DBCP库依赖于Commons Pool库,因此请确保它们都在构建路径中,如图所示。这是使用BasicDataSource的DataSource工厂类,它是DataSource的简单实现。
package com.Olivia.jdbc.datasource;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;
public class DBCPDataSourceFactory {
public static DataSource getDataSource(String dbType){
Properties props = new Properties();
FileInputStream fis = null;
BasicDataSource ds = new BasicDataSource();
try {
fis = new FileInputStream("db.properties");
props.load(fis);
}catch(IOException e){
e.printStackTrace();
return null;
}
if("mysql".equals(dbType)){
ds.setDriverClassName(props.getProperty("MYSQL_DB_DRIVER_CLASS"));
ds.setUrl(props.getProperty("MYSQL_DB_URL"));
ds.setUsername(props.getProperty("MYSQL_DB_USERNAME"));
ds.setPassword(props.getProperty("MYSQL_DB_PASSWORD"));
}else if("oracle".equals(dbType)){
ds.setDriverClassName(props.getProperty("ORACLE_DB_DRIVER_CLASS"));
ds.setUrl(props.getProperty("ORACLE_DB_URL"));
ds.setUsername(props.getProperty("ORACLE_DB_USERNAME"));
ds.setPassword(props.getProperty("ORACLE_DB_PASSWORD"));
}else{
return null;
}
return ds;
}
}
根据用户的输入,可以看到程序会创建MySQL或Oracle的数据源。如果应用程序只支持一个数据库,那么你甚至不需要这些逻辑。只需更改属性,就可以在不同的数据库服务器之间进行切换。Apache DBCP提供抽象的关键点是setDriverClassName()方法。以下是使用上述工厂方法获取不同类型连接的客户端程序。
package com.Olivia.jdbc.datasource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.sql.DataSource;
public class ApacheCommonsDBCPTest {
public static void main(String[] args) {
testDBCPDataSource("mysql");
System.out.println("**********");
testDBCPDataSource("oracle");
}
private static void testDBCPDataSource(String dbType) {
DataSource ds = DBCPDataSourceFactory.getDataSource(dbType);
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try {
con = ds.getConnection();
stmt = con.createStatement();
rs = stmt.executeQuery("select empid, name from Employee");
while(rs.next()){
System.out.println("Employee ID="+rs.getInt("empid")+", Name="+rs.getString("name"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(con != null) con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
当您运行上述程序时,输出将与之前的程序相同。如果您查看Java JDBC DataSource和上述用法,也可以使用正常的DriverManager来完成。Java DataSource的主要优点是在上下文和JNDI中使用时。通过简单的配置,我们可以创建一个由容器本身维护的数据库连接池。大多数servlet容器(如Tomcat和JBoss)都提供了自己的Java DataSource实现,我们只需要通过简单的基于XML的配置进行配置,然后使用JNDI上下文查找来获取Java DataSource并与之交互。这样可以将连接池和管理从我们的应用程序端移到服务器端,从而为我们提供更多的时间来编写应用程序的业务逻辑。在下一个教程中,我们将学习如何在Tomcat容器中配置DataSource并在Web应用程序中使用它。