服务热线:13616026886

技术文档 欢迎使用技术文档,我们为你提供从新手到专业开发者的所有资源,你也可以通过它日益精进

位置:首页 > 技术文档 > JAVA > 新手入门 > 基础入门 > 查看文档

java语言操作数据库方式与设计模式应用

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

扫描关注微信公众号