用数据库链接池的程序如何改写成用javabean的呢

用数据库链接池的程序怎么改写成用javabean的呢？
代码如下想改成 javaBean 连接的

package msdn.javabean;
import java.sql.*;
import javax.naming.*;
import javax.sql.*;

import sun.jdbc.rowset.*;

/**
* Title: 基础数据库操作类 
* Description: 
* Copyright: Copyright (c) 2006 
* Company: 
* @author hellion
* @version 1.0
*/

public class DBManager {
public static final String DATABASE = "java:comp/env/jdbc/database ";

public DBManager() {
}

/**
* 取数据库连接
* @param jndi 数据库连接JNDI
* @return 数据库连接
* @throws Exception
*/
public static Connection getConnection(String jndi) throws Exception {
Connection conn = null;
try {
Context initCtx = new InitialContext();

DataSource ds = (DataSource) initCtx.lookup(jndi);
conn = ds.getConnection();
conn.setAutoCommit(false);
}
catch (Exception e) {
e.printStackTrace();
}
return conn;
}

public static Connection getConnection() throws Exception {
return getConnection(DATABASE);
}

public static void cleanup(Connection conn, PreparedStatement ps) {
try {

if (ps != null) {
ps.close();
}
}
catch (Exception e) {
e.printStackTrace();
}
try {
if (conn != null && !conn.isClosed()) {
conn.close();
}
}
catch (Exception e) {
e.printStackTrace();
}
}

protected static void cleanup(Connection conn, PreparedStatement ps,
ResultSet rs) {

try {
if (rs != null) {
rs.close();
}
}
catch (Exception e) {
e.printStackTrace();
}
try {
if (ps != null) {
ps.close();
}
}
catch (Exception e) {}
try {
if (conn != null && !conn.isClosed()) {
conn.close();
}
}
catch (Exception e) {
e.printStackTrace();
}
}

/**
*查询默认数据库的数据
* @param sql
* @deprecated
* @return
* @throws Exception
*/
public static CachedRowSet executeQuery(String sql) {
return executeQuery(sql, DBManager.DATABASE);
}

/**
*
* @param sql
* @param databasejndi
* @deprecated
* @return
* @throws Exception
*/
public static CachedRowSet executeQuery(String sql, String databasejndi) {
CachedRowSet crs = null;
Statement st = null;
Connection conn = null;
ResultSet rs = null;
try {
crs = new CachedRowSet();
conn = DBManager.getConnection(databasejndi);
st = conn.createStatement();
rs = st.executeQuery(sql);
crs.populate(rs);
}
catch (Exception se) {
System.out.println( "SQLException in DBManager.exceuteQuery, sql is :\n " +
sql);
se.printStackTrace();

}
finally {
DBManager.cleanup(conn, null, rs);
}
return crs;
}

/**
* 通用查询默认数据库
* @param sql
* @param values
* @return CachedRowSet
*/
public static CachedRowSet executeQuery(String sql, Object[] values) {
return executeQuery(sql, values, DBManager.DATABASE);
}

/**
* 通用查询
* @param sql
* @param values
* @param dataBase
* @return
*/
public static CachedRowSet executeQuery(String sql, Object[] values,
String dataBase) {
System.out.println( "sql: "+sql);
CachedRowSet crs = null;
PreparedStatement st = null;
Connection conn = null;
ResultSet rs = null;
try {
crs = new CachedRowSet();
if (values == null || values.length < 1) {
return executeQuery(sql);
}
conn = DBManager.getConnection(dataBase);
st = conn.prepareStatement(sql);
for (int i = 0; i < values.length; i++) {
st.setObject(i + 1, values[i]);
}
rs = st.executeQuery();
crs.populate(rs);
}
catch (Exception se) {
System.out.println( "SQLException in DBManager.exceuteQuery, sql is :\n " +
sql);
se.printStackTrace();
}
finally {
DBManager.cleanup(conn, null, rs);

}
return crs;
}

/**
* 执行update,delete,insert 操作.
* @param sql
* @deprecated
* @return
* @throws Exception
*/
public static int executeUpdate(String sql) {
Statement st = null;
Connection conn = null;
int result = 0;
try {
conn = DBManager.getConnection(DBManager.DATABASE);
st = conn.createStatement();
result = st.executeUpdate(sql);
conn.commit();
}
catch (Exception se) {
try {
conn.rollback();
}
catch (Exception es) {
es.printStackTrace();
}
System.out.println( "SQLException in DBConnet.exceuteQuery, sql is :\r\n " +
sql + " \r\nerror is: " + se.getMessage());
se.printStackTrace();
}
finally {
DBManager.cleanup(conn, null, null);
}
return result;

}

/**
* 执行数据修改操作。
* @param sql
* @param values
* @return
*/
public static int executeUpdate(String sql, Object[] values) {
Connection conn = null;
PreparedStatement ps0 = null;
int rows = 0;
try {
conn = getConnection(DBManager.DATABASE);
ps0 = conn.prepareStatement(sql);
for (int i = 0; i < values.length; i++) {
ps0.setObject(i + 1, values[i]);
}
rows = ps0.executeUpdate();

conn.commit();
}
catch (Exception e) {
try {
conn.rollback();
}
catch (Exception ex) {
ex.printStackTrace();
}
e.printStackTrace();
}
finally {
cleanup(conn, ps0);
}
return rows;
}

}

server.xml 文件

<Resource name= "jdbc/database " type= "javax.sql.DataSource " username= "sa " password= "sa " driverClassName= "com.microsoft.jdbc.sqlserver.SQLServerDriver " maxIdle= "2 " maxWait= "50 " url= "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=chinamsdn " maxActive= "100 "/>

我的博客 www.liyingfei.com

[解决办法]
javabean连接的无非就是getConnection这个函数中的连接操作不再是DataSource ds = (DataSource) initCtx.lookup(jndi);
conn = ds.getConnection();
而是
Class.forName(com.microsoft.jdbc.sqlserver.SQLServerDriver ");
conn = Driver.getConnect( "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=chinamsdn ",sa ", "sa ");

之类的东西
[解决办法]
楼上正解..
[解决办法]
你的那个程序好像已经就是javabean了，
[解决办法]
public Connection getConnection() {
Connection conn = null;
try {
//加载驱动
Class.forName( "com.microsoft.jdbc.sqlserver.SQLServerDriver ");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
try {
//获得Connection对象
con = DriverManager.getConnection( "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=test ", "sa ", " ");
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
[解决办法]
这个程序是用到了连接池技术能具体结合这个例子具体写一下怎么不用连接池把数据库链接直接写在java 文件里面呢》？
===================================================
Class.forName( "com.microsoft.jdbc.sqlserver.SQLServerDriver ");
Connection conn =DriverManager.getConnection( "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=test ", "sa ", " ");

用数据库链接池的程序如何改写成用jav

热点推荐