1. 在业务层使用jdbc直接操作数据库-最简单,最直接的操作
1)数据库url,username,password写死在代码中
class.forname("oracle.jdbc.driver.oracledriver").newinstance();
string url="jdbc:oracle:thin:@localhost:1521:orcl";
string user="scott";
string password="tiger";
connection conn= drivermanager.getconnection(url,user,password);
statement stmt=conn.createstatement(
resultset.type_scroll_sensitive,resultset.concur_updatable);
string sql="select * from test";
resultset rs=stmt.executequery(sql);
2)采用facade和command模式,使用dbutil类封装jdbc操作;
数据库url,username,password可以放在配置文件中(如xml,properties,ini等)。
这种方法在小程序中应用较多。
2.dao(data accessor object)模式-松耦合的开始
dao = data + accessor + domain object
例如user类-domain object (javabean)
userdao类-accessor ,提供的方法getuser(int id),save(user user)内包含了jdbc操作
在业务逻辑中使用这两个类来完成数据操作。
使用factory模式可以方便不同数据库连接之间的移植。
3.数据库资源管理模式
3.1 数据库连接池技术
资源重用,避免频繁创建,释放连接引起大大量性能开销;
更快的系统响应速度;
通过实现jdbc的部分资源对象接口( connection, statement, resultset ),可以使用decorator设计模式分别产生三种逻辑资源对象: pooledconnection, pooledstatement和 pooledresultset。
一个最简单地数据库连接池实现:
public class connectionpool {
private static vector pools;
private final int pool_maxsize = 25;
/**
* 获取数据库连接
* 如果当前池中有可用连接,则将池中最后一个返回;若没有,则创建一个新的返回
*/
public synchronized connection getconnection() {
connection conn = null;
if (pools == null) {
pools = new vector();
}
if (pools.isempty()) {
conn = createconnection();
} else {
int last_idx = pools.size() - 1;
conn = (connection) pools.get(last_idx);
pools.remove(last_idx);
}
return conn;
}
/**
* 将使用完毕的数据库连接放回池中
* 若池中连接已经超过阈值,则关闭该连接;否则放回池中下次再使用
*/
public synchronized void releaseconnection(connection conn) {
if (pools.size() >= pool_maxsize)
try {
conn.close();
} catch (sqlexception e) {
// todo自动生成 catch 块
e.printstacktrace();
} else
pools.add(conn);
}
public static connection createconnection() {
connection conn = null;
try {
class.forname("oracle.jdbc.driver.oracledriver").newinstance();
string url = "jdbc:oracle:thin:@localhost:1521:orcl";
string user = "scott";
string password = "tiger";
conn = drivermanager.getconnection(url, user, password);
} catch (instantiationexception e) {
// todo自动生成 catch 块
e.printstacktrace();
} catch (illegalaccessexception e) {
// todo自动生成 catch 块
e.printstacktrace();
} catch (classnotfoundexception e) {
// todo自动生成 catch 块
e.printstacktrace();
} catch (sqlexception e) {
// todo自动生成 catch 块
e.printstacktrace();
}
return conn;
}
}
注意:利用getconnection()方法得到的connection,程序员很习惯地调用conn.close()方法关闭了数据库连接,那么上述的数据库连接机制便形同虚设。在调用conn.close()方法方法时如何调用releaseconnection()方法?这是关键。这里,我们使用proxy模式和java反射机制。
public synchronized connection getconnection() {
connection conn = null;
if (pools == null) {
pools = new vector();
}
if (pools.isempty()) {
conn = createconnection();
} else {
int last_idx = pools.size() - 1;
conn = (connection) pools.get(last_idx);
pools.remove(last_idx);
}
connectionhandler handler=new connectionhandler(this);
return handler.bind(con);
}
public class connectionhandler implements invocationhandler {
private connection conn;
private connectionpool pool;
public connectionhandler(connectionpool pool){
this.pool=pool;
}
/**
* 将动态代理绑定到指定connection
* @param conn
* @return
*/
public connection bind(connection conn){
this.conn=conn;
connection proxyconn=(connection)proxy.newproxyinstance(
conn.getclass().getclassloader(), conn.getclass().getinterfaces(),this);
return proxyconn;
}
/* (非 javadoc)
* @see java.lang.reflect.invocationhandler#invoke(java.lang.object, java.lang.reflect.method, java.lang.object[])
*/
public object invoke(object proxy, method method, object[] args) throws throwable {
// todo自动生成方法存根
object obj=null;
if("close".equals(method.getname())){
this.pool.releaseconnection(this.conn);
}
else{
obj=method.invoke(this.conn, args);
}
return obj;
}
}
在实际项目中,并不需要你来从头开始来设计数据库连接池机制,现在成熟的开源项目,如c3p0,dbcp,proxool等提供了良好的实现。一般推荐使用apache dbcp,基本使用实例:
datasource ds = null;
try{
context initctx = new initialcontext();
context envctx = (context) initctx.lookup("java:comp/env");
ds = (datasource)envctx.lookup("jdbc/myoracle");
if(ds!=null){
out.println("connection is ok!");
connection cn=ds.getconnection();
if(cn!=null){
out.println("cn is ok!");
statement stmt = cn.createstatement();
resultset rst = stmt.executequery("select * from book");
out.println("
rst is ok!" + rst.next());
while(rst.next()){
out.println("
book_code:" + rst.getstrin
闽公网安备 35060202000074号