[大数据]DataSource接口和一些扩展

序言

上次说到了Manager，这次来说一下获得链接的第二种方式。javax.sql.DaraSource以及JNDI API和连接的关闭。

javax.sql.DaraSource

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 API增强应用的可移植性

what?

JNDI是Java命名和目录接口，它为应用程序提供了一种通过网络访问远程服务的方式。

why?

通过jndi访问抽象的资源。这样程序不至于与访问的资源耦合。比如用jndi数据库密码变了与程序无关。不需要改代码。JNDI API的命令服务把一个逻辑名称和一个具体的对象绑定，使用它，可以通过和DataSource绑定的逻辑名称直接获得DataSource对象。当DataSource的属性发生改变时，不需要需要代码。无感知的修改。

how?

直接上代码

    <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.