上次说到了Manager,这次来说一下获得链接的第二种方式。javax.sql.DaraSource以及JNDI API和连接的关闭。
javax.sql.DaraSource接口最早是由JDBC2.0版本扩展包提供的,它是比较推荐的获得数据源连接的一种方式,JDBC驱动程序都会实现DataSource接口,通过DataSource实现类的实例,返回一个Connection接口的实现类的实例。
使用DataSource对象可以提高应用程序的可移植性。在应用程序中,可以通过逻辑名称来获取DataSource对象。DataSource对象用于表示能够提高数据库连接的数据源对象。如果数据库相关的关系发生了改变,则可以简单的修改DataSource对象的属性来反应这种变化,而不用修改应用程序的任何代码。
DataSource接口可以被实现,提高如下两种功能:
通过连接池提高系统性能和伸缩性。
通过XADataSource接口支持分布式事务
注意:DataSource实现类必须包含一个无参构造方法
其属性有:
databaseName:数据库名称
dataSourceName:数据源名称
description:数据源描述信息
networkProtocol:与数据库服务器交互的网络协议
password:数据库密码
portNumber:数据库监听端口
roleName:角色名称
serverName:数据库服务器名称
user:用户名
DataSource对象不建议被JDBC客户端直接访问。
JNDI是Java命名和目录接口,它为应用程序提供了一种通过网络访问远程服务的方式。
通过jndi访问抽象的资源。这样程序不至于与访问的资源耦合。比如用jndi数据库密码变了与程序无关。不需要改代码。JNDI API的命令服务把一个逻辑名称和一个具体的对象绑定,使用它,可以通过和DataSource绑定的逻辑名称直接获得DataSource对象。当DataSource的属性发生改变时,不需要需要代码。无感知的修改。
直接上代码
<dependency>
<groupId>tomcat</groupId>
<artifactId>naming-java</artifactId>
<version>5.0.28</version>
</dependency>
<dependency>
<groupId>tomcat</groupId>
<artifactId>naming-common</artifactId>
<version>5.0.28</version>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.2</version>
</dependency>
public class Test1 {
Properties jdniProp = null;
Context ctx = null;
@Before
public void before() throws Exception{
// 创建数据源工厂
DataSourceFactory dataSourceFactory = new UnpooledDataSourceFactory();
Properties properties = new Properties();
InputStream stream = Thread.currentThread().getContextClassLoader().getResourceAsStream("db1.properties");
properties.load(stream);
dataSourceFactory.setProperties(properties);
DataSource dataSource = dataSourceFactory.getDataSource();
try {
jdniProp = new Properties();
// 指定到目录服务的连接工厂
jdniProp.put(Context.INITIAL_CONTEXT_FACTORY,"org.apache.naming.java.javaURLContextFactory");
jdniProp.putIfAbsent(Context.URL_PKG_PREFIXES,"org.apache.naming");
ctx = new InitialContext(jdniProp);
// 绑定
ctx.bind("java:TestCB",dataSource);
}catch (Exception e){
System.err.println(e.getMessage());
}
}
@Test
public void test(){
try {
DataSource dataSource = (DataSource) ctx.lookup("java:TestCB");
Connection connection = dataSource.getConnection();
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("select * from blog");
while (resultSet.next()){
String bid = resultSet.getString("bid");
System.out.println(bid);
}
}catch (Exception e){
}
}
}
UnpooledDataSourceFactory是指没有实现连接池。
创建了一个 java.naming.InitalContext实例,调用该实例的bind创建命令服务,可以通过lookup()查找服务,它是一个上下文对象。我们也可以用Tomcat来配置JNDI数据源。
用完Connection之后,需要显示的对其关闭,除了close以外,还提供了一个isClose方法,判断连接是否关闭,isValid方法判断连接是否有效。
码字不易,请给个赞把,谢谢!
下一章 讲一个Statement.