浅谈实际开发中数据源在JDBC中的应用
2024-07-21 02:15:05
供稿：网友
菜鸟学堂：
数据源在jdbc中的应用众所周知，jdbc（java数据库连接）是java2企业版的重要组成部分。它是基于sql层的api。通过把sql语句嵌入jdbc接口的方法中，用户可以通过java程序执行几乎所有的数据库操作。
jdbc只提供了接口，具体的类的实现要求数据库的设计者完成。通过生成这些接口的实例，即使对于不同的数据库，java程序也可以正确地执行sql调用。所以对于程序员来说，不必把注意力放在如何向数据库发送sql指令，因为程序员需要了解和用到的只是jdbc的接口，只有在极少数情况下会用到面向特定数据库的类，例如程序员希望使用oracle的扩展api。
在jdbc程序中，首先需要做的是实现与数据库的连接。在示例程序中，我们使用的是oracle8i的jdbc包。连接数据库通常需要实现以下几个步骤：
1、注册数据库驱动程序（driver）
可以通过调用java.sql.drivermanager类的registerdriver方法显式注册驱动程序，也可以通过加载数据库驱动程序类隐式注册驱动程序。例如我们希望向虚拟机注册oracle8i jdbc驱动程序显式注册：
drivermanager.registerdriver
(neworacle.jdbc.driver.oracledriver());
隐式注册：
class.forname(“oracle.jdbc.driver.oracledriver”);
关于虚拟机如何自动注册通过类加载器（classloader）加载的数据库驱动程序超过了本文讨论的范围，在此不做详细讨论。
2、建立连接
调用java.sql.drivermanager类的getconnection（）方法可以建立与数据库的连接。getconnection（）方法返回一个connection对象。需要注意的是，getconnection（）方法会自动从数据库驱动程序注册表中选择一个最合适的驱动程序。
3、建立连接后
允许自动更新（autocommit）。调用java.sql.connection接口的serautocommit（）方法可以设定当程序向数据库发出一条sql指令后，数据库是否立即更新。下面是一个具体的实例。
在该实例中，作为getconnection（）方法参数的url使用的是net8 keyword-value pair格式。当然也可以使用普通格式。数据库安装在名为chicago的服务器上，使用的协议是tcp协议，使用的端口是1521，数据库的sid是chidb，使用的数据库驱动程序是oracle jdbc thin驱动程序。
import java.sql.*;
// 初始化常数private static string url=
“jdbc:oracle:thin:@(description
=(address=(host=chicago)” +
“(protocol=tcp)(port=1521))
(connect_data=(sid=chidb)))”;
// 也可以设定url为“jdbc:oracle:thin:@ chicago:1521:chidb”
private static string username
= “guest”;private static string
password = “guest”;
try
{
// 注册数据库
class.forname(“oracle.jdbc.driver.oracledriver”);
// 建立连接
connection conn =
drivermanager.getconnection(url,
username, password);
//允许自动更新conn.setautocommit(true);
}
catch(classnotfoundexception e )
{
e.printstacktrace();
}catch(sqlexception e)
{
e.printstacktrace();
}
从实际应用的角度出发，我们可以看出采取这种方式连接到数据库存在几个问题。第一是安全性问题，由于程序代码中包含用户名和密码，其他人如果能得到bytecode，可以通过反编译工具获得用户名和密码。
第二是代码的可移植性问题。如果希望连接的数据库名称或用户名有所更改，程序员需要修改源程序，然后把修改过的程序发送给用户。也就是说，软件无法脱离数据库独立存在。这样不仅会大大提高软件的成本，也不利于软件本身的发展。
还可能出现这样的情况：在某些情况下，提供数据的机构不希望数据库的用户名和密码让编写程序的程序员知道知道。这样就提出了一个问题，如何使java和数据库之间建立连接时隐藏一些敏感的信息。
数据源（data source）及jndi数据源是在jdbc 2.0中引入的一个概念。在jdbc 2.0扩展包中定义了javax.sql.datasource接口来描述这个概念。如果用户希望建立一个数据库连接，通过查询在jndi服务中的数据源，可以从数据源中获取相应的数据库连接。
这样用户就只需要提供一个逻辑名称（logic name），而不是数据库登录的具体细节。在这里有必要简单介绍一下jndi。jndi的全称是java naming and directory interface， 可以理解为java名称和目录服务接口。
jndi向应用程序提供了一个查询和使用远程服务的机制。这些服务可以是任何企业服务。对于jdbc应用程序来说，jndi提供的是数据库连接服务。当然jndi也可以向数据库提供其他服务，但是这超出了本文范围，在此不做论述。
其实jndi并不难理解。简单来说，名称服务提供了一个把文件，打印机，服务器等实体映射到一个逻辑名称的机制。例如在操作系统中的名称服务就把打印机映射到一个i/o端口。而目录服务可以理解为名称服务的一个扩展，它允许在服务中的各项拥有自己的属性。
又以打印机为例，打印机可以是彩色打印机，支持双面打印，支持网络打印，支持高速打印等。所有这些打印机的属性都可以储存在目录服务中，和相应的打印机联系起来。一些常见的目录服务有nis，nis+，ldap和novell的nds等。
jndi使应用程序通过使用逻辑名称获取对象和对象提供的服务，从而使程序员可以避免使用与提供对象的机构有关联的代码。例如在下面的例子中使用了在jndi中的数据源，程序员就不需要提供oracle8i驱动程序的名称，这样代码的移植能力就更强。
下面详细介绍一下数据源和javax.sql.datasource接口。在数据源中存储了所有建立数据库连接的信息。就象通过指定文件名你可以在文件系统中找到文件一样，通过提供正确的数据源名称，你可以找到相应的数据库连接。
javax.sql.datasource接口定义了如何实现数据源。在该接口中定义了九个属性。同时，oracledatasource还实现了java.io.serializable和javax.naming.referenceable接口。独立使用数据源实际应用中，你可以把oracledatasource注册到jndi，也可以单独使用。
下面先给出一个单独使用oracledatasource的例子：
// 初始化数据源实例oracledatasource ods
= new oracledatasource();
ods.setdrivertype("thin");
ods.setservername("chicago");
ods.setnetworkprotocol("tcp");
ods.setdatabasename("chidb");
ods.setportnumber(1521);
ods.setuser("guest");
ods.setpassword("guest");
// 从数据源中获取数据库连接connection
conn = ods.getconnection();
// 通过数据库连接进行数据操作
使用oracledatasource时有几点需要注意：如果使用的时服务器端内部驱动程序（server-side internal driver），drivertype属性会被设置为kprb，其它所有属性失效。 如果使用thin或oci驱动程序： url中可以包括用户登录名和用户登录密码。例如：
jdbc:oracle:thin:guest/[email protected]:1521:chidb;
如果设定了url属性，tnsentry, drivertype, portnumber, networkprotocol, servername，和databasename属性将失效。在没有设定url属性的情况下，如果设定了tnsentry属性，portnumber, networkprotocol, servername，和databasename属性将失效。
如果使用oci驱动程序，并且networkprotocol属性被设定为ipc，除user和password外的所有其他属性将失效。通过jndi使用数据源在本节首先给出了一个实际程序，然后通过程序来讲解如何通过jndi查询数据源。
import java.sql.*;
import javax.sql.*;
import oracle.jdbc.driver.*;
import oracle.jdbc.pool.oracledatasource;
import javax.naming.*;
import javax.naming.spi.*;
import java.util.hashtable;
public class datasourcejndi
{
public static void main
(string args [])throws sqlexception
{
// 初始化名称服务环境context ctx = null;
try{hashtable env = new hashtable (5);
env.put (context.initial_context_factory,
"com.sun.jndi.fscontext.reffscontextfactory");
env.put (context.provider_url, "file:jndi");
ctx = new initialcontext(env);
}
catch (namingexception ne)
{
ne.printstacktrace();
}bind(ctx, "jdbc/chidb");
lookup(ctx, "jdbc/chidb");
}
static void bind
(context ctx, string ln)throws namingexception,
sqlexception
{
// 创建一个oracledatasource
实例oracledatasource ods
= new oracledatasource();
ods.setdrivertype("thin");
ods.setservername("chicago");
ods.setnetworkprotocol("tcp");
ods.setdatabasename("chidb");
ods.setportnumber(1521);
ods.setuser("guest");
ods.setpassword("guest");
// 把oracledatasource实例注册到jndi中
system.out.println
("doing a bind with the logical name : " + ln);
ctx.bind (ln,ods);
system.out.println
("successfully bound");
}
static void lookup
(context ctx, string ln)throws
namingexception， sqlexception
{
// 从jndi中查询oracledatasource
实例system.out.println
("doing a lookup with the logical name
: " + ln);
oracledatasource ods
= (oracledatasource)
ctx.lookup (ln);
system.out.println ("successful lookup");
// 从查询到的oracledatasource
实例中获取数据库连接
connection conn = ods.getconnection();
// 进行数据库操作getusername(conn);
// 关闭连接conn.close();
conn = null;
}
static void getusername
(connection conn)throws sqlexception
{
// 生成一个statement实例statement
stmt = conn.createstatement ();
// 从addressbook表中选中姓名列resultset
rset = stmt.executequery
("select name from addressbook");
// 列出addressbook表所有人的姓名while
(rset.next ())system.out.println
("name is " + rset.getstring (1));
// 关闭rseultset实例rset.close();
rset = null;
// 关闭statement实例stmt.close();
stmt = null;
}
}
程序首先生成了一个context实例。javax.naming.context接口定义了名称服务环境（naming context）及该环境支持的操作。名称服务环境实际上是由名称和对象间的相互映射组成。程序中初始化名称服务环境的环境工厂（context factory）是com.sun.jndi.fscontext.reffscontextfactory（该类在fscontext.jar中可以找到，由于fscontext.jar中包含的不是标准的api，用户需要从www.javasoft.com中的jndi专区下载一个名为fscontext1_2beta3.zip的压缩文件,在该文件中可以找到fscontext.jar）。
环境工厂的作用是生成名称服务环境的实例，javax.naming.spi.initialcontextfactory接口定义了环境工厂应该如何初始化名称服务环境。在初始化名称服务环境时还需要定义环境的url。
程序中使用的是"file:jndi"，也就是把环境保存在本地硬盘的jndi目录下。初始化了名称服务环境后，就可以把数据源实例注册到名称服务环境中。注册时调用javax.naming.context.bind()方法，参数为注册名称和注册对象。
注册成功后，在jndi目录下会生成一个.binding文件，该文件记录了当前名称服务环境拥有的名称及对象。当需要在名称服务环境中查询一个对象时，需要调用javax.naming.context.lookup（）方法，并把查询到的对象显式转化为数据源对象。
然后通过该数据源对象进行数据库操作。在这个例子中，程序和名称服务环境都是在同一台计算机上运行。在实际的应用中，程序可以通过rmi或corba向名称服务环境注册或查询对象。
例如在一个服务器-客户机结构中,客户机上的应用程序只需要知道数据源对象在服务器名称服务环境中的逻辑名称,就可以通过rmi向服务器查询数据源,然后通过建立与数据库的连接.这样就可以解决本文最开始提出的问题。
