服务热线:13616026886

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

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

java基础:将数据库操作封装到javabean

封装数据库操作,目的就是为了隐藏java.sql包内的类,在编码中去掉核心的数据库操作代码。以杜绝直接数据库操作容易带来的资源未释放问题。同时也减少了数据库操作的编码量。

但是很多网友在封装时,却喜欢返回结果集(resultset对象),那么这个封装就没有意义了。
1. 又是直接操作核心数据库类,跟封装前几乎没什么变化。
2. 结果集总是依赖于它使用的连接(connection)对象。因此当连接对象在方法内被关闭后,你返回的resultset就没有用了。

如果真的要获得查询数据库的结果集,就把结果集对象内的所有数据,转储到以map为元素的list对象内。
当然,这种方式,不能适应大数据量的查询,不过如果真的碰到大数据量的查询,那用什么封装都不好,还是得直接数据库操作. :)))

下面是简单的数据库操作javabean的代码

dbwrapper.java
import java.sql.*;
import java.util.*;
public class dbwrapper
{
    // 定义连接池对象为静态变量,将一直存在,直到工作目录关闭。
    private static datasource ds = null;
    // 1.用连接池的方式获得连接
    // 如果不是做多数据库程序,推荐使用此方法
    // 相关内容:在tomcat管理界面配置连接池
    public static connection openconnection() throws exception
    {
        // 只需要初始化1次
        if ( ds == null )
        {
            context initcontext = new initialcontext();
            context envcontext = (context) initcontext.lookup("java:/comp/env");
            datasource ds = (datasource) envcontext.lookup("jdbc/mydatasource");
        }
        return ds.getconnection();
    }
   
    // 2.用jdbc驱动获得连接
    // 相关内容:jsp数据库连接大全
    public static connection openconnection(
        string driver,
        string url,
        string username,
        string password)
            throws exception
    {
        class.forname(driver).newinstance();
        return drivermanager.getconnection(url, username, password);
    }
   
    public static void closeconnection(connection conn) throws exception
    {
        if ( conn != null )
        {
            conn.close();
        }
    }
    public static int executeupdate(string sql) throws exception
    {
       int count = 0;
       
        connection conn = null;
        statement  stmt = null;
       
        try
        {
            conn = openconnection();
            stmt = conn.createstatement();
       
            count = stmt.executeupdate(sql);
        }
        catch ( exception e )
        {
            throw e;
        }
        finally
        {
            closeconnection(conn);
        }
       
        return count;
    }
   
    public static list executequery(string sql) throws exception
    {
        list list = new arraylist();
       
        connection conn = null;
        statement  stmt = null;
        resultset  rs   = null;
       
        try
        {
            conn = openconnection();
            stmt = conn.createstatement();
            rs   = stmt.executequery(sql);
           
            resultsetmetadata rsmd = rs.getmetadata();
       
            while ( rs.next() )
            {
                map map = new hashmap();
               
                for ( int i = 1; i < = rsmd.getcolumncount(); i++ )
                {
                    map.put(rsmd.getcolumnname(i), rs.getobject(i));
                }
               
                list.add(map);
            }        }
        catch ( exception e )
        {
            e.printstacktrace();
        }
        finally
        {
            if ( rs != null ) rs.close();
            closeconnection(conn);
        }
       
        return list;    }
}
 


使用示例:
// 1.对于insert, update, delete语句int count = dbwrapper.executeupdate(sql);
// 2.对于selete语句
java.util.list list = dbwrapper.executequery(sql);
// 方法一:按名字取值,注意大小写是严格区分的
for ( int i = 0; i < list.size(); i++ )
{
    java.util.map map = (java.util.map)list.get(i);
    out.println(mag.get("column_name").tostring());
}
// 方法二:遍历取值
for ( int i = 0; i < list.size(); i++ )
{
    java.util.map map = (java.util.map)list.get(i);
    for (java.util.iterator it = map.keyset().iterator(); it.hasnext();)
    {
        string column_name = it.next().tostring());        // 取值时注意null判断
        out.println(column_name + " = " + map.get(column_name)  == null ? "" :        map.get(column_name).tostring());
    }
}