| |
封装数据库操作，目的就是为了隐藏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());
}
}
|
|
