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

人气：1902 2007-11-20

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("<p>rst is ok!" + rst.next());
                while(rst.next()){
                       out.println("<p>book_code:" + rst.getstring(1));
                  }
                        cn.close();
                }else{
                        out.println("rst fail!");
                }
        }
        else
                out.println("fail!");
           }catch(exception ne){ out.println(ne);
         }

3.2 statement pool

普通预编译代码：

string strsql=”select name from items where id=?”;

preparedstatement ps=conn.preparestatement(strsql);

ps.setstring(1, “2”);

resultset rs=ps.executequery();

但是preparedstatement 是与特定的connection关联的，一旦connection关闭，则相关的preparedstatement 也会关闭。

为了创建preparedstatement 缓冲池，可以在invoke方法中通过sql语句判断池中还有没有可用实例。

4. 持久层设计与o/r mapping 技术

1） hernate：适合对新产品的开发，进行封闭化的设计

hibernate 2003年被jboss接管，通过把java pojo对象映射到数据库的table中，采用了xml/javareflection技术等。3.0提供了对存储过程和手写sql的支持，本身提供了hql语言。

开发所需要的文件：

hibernate配置文件： hibernate.cfg.xml 或 hibernate.properties

hibernate 映射文件： a.hbm.xml

pojo类源文件： a.java　　

导出表与表之间的关系：

a. 从java对象到hbm文件：xdoclet

b. 从hbm文件到java对象：hibernate extension

c. 从数据库到hbm文件：middlegen

d. 从hbm文件到数据库：schemaexport

2）iatis ：适合对遗留系统的改造和对既有数据库的复用，有很强的灵活性 3） apache ojb：优势在于对标准的全面支持 4）ejb：适合集群服务器，其性能也不象某些人所诟病的那么差劲 5） jdo (java data object)

设置一个properties对象，从而获取一个jdo的persistencemanagerfactory（相当于jdbc连接池中的datasource），进而获得一个persistencemanager对象（相当于jdbc中的connection对象），之后，你可以用这个persistencemanager对象来增加、更新、删除、查询对象。

jdoql是jdo的查询语言；它有点象sql，但却是依照java的语法的。

5. 基于开源框架的struts+spring+hibernate实现方案