急求 使用代理出现类型转换异常!!!
悬赏：5 发布时间：2008-07-22 提问人：wasdju (初级程序员)
非常抱歉，由于问题还没有解决而点了关闭问题，在此道歉，用mysql连接没有出现问题，而用sqlserver就出现下述问题。
具体代码如下,异常出现在getConnection方法中Connection conn2 = (Connection)Proxy.newProxyInstance(conn.getClass().getClassLoader(),conn.getClass().getInterfaces(),this);
异常内容:Exception in thread "main" java.lang.ClassCastException: $Proxy0
at com.think.Handler.bind(Handler.java:24)
at com.think.TestProxy.main(TestProxy.java:9)
代码:
package tutorial.DBUtil;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
public class _Connection implements InvocationHandler {
private final String CLOSE_METHOD_NAME = "close";
private Connection conn = null;
private boolean inUse = false; //数据库的忙状态
private long lastAccessTime = System.currentTimeMillis();//用户最后一次访问该连接方法的时间
_Connection(Connection conn,boolean inUse)
{
this.conn = conn;
this.inUse = inUse;
}
/**
* Returns the conn.
* @return Connection
*/
public Connection getConnection()
{
//返回数据库连接conn的接管类，以便截住close方法
Connection conn2 = (Connection)Proxy.newProxyInstance(
conn.getClass().getClassLoader(),
conn.getClass().getInterfaces(),this);
return conn2;
}
/**
* @see java.lang.reflect.InvocationHandler#invoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object)
*/
public Object invoke(Object proxy,Method m,Object[] args)
{
Object obj = null;
if(CLOSE_METHOD_NAME.equals(m.getName()))
{
setInUse(false);
}else{
try {
m.invoke(conn, args);
////设置最后一次访问时间，以便及时清除超时的连接
lastAccessTime = System.currentTimeMillis();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return obj;
}
/**
* 该方法真正的关闭了数据库的连接
* @throws SQLException
*/
public void close() throws SQLException
{
//由于类属性conn是没有被接管的连接，因此一旦调用close方法后就直接关闭连接
conn.close();
}
/**
* Returns the inUse.
* @return boolean
*/
public boolean isInUse() {
return inUse;
}
/**
* Returns the lastAccessTime.
* @return long
*/
public long getLastAccessTime() {
return lastAccessTime;
}
/**
* Sets the inUse.
* @param inUse The inUse to set
*/
public void setInUse(boolean inUse) {
this.inUse = inUse;
}
}
问题补充：
public static void main(String[] args) throws Exception {
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
String url = "jdbc:microsoft:sqlserver://localhost:1433;databasename=Test";
Connection conn = DriverManager.getConnection(url, "sa", "123456");
// Connection con = getConnection();
_Connection _con = new _Connection(conn,true);
Connection cs = _con.getConnection();
PreparedStatement ps = cs.prepareStatement("select * from testuser");
ResultSet rs = ps.executeQuery();
while (rs.next()) {
System.out.print(rs.getString(1) + "\n");
System.out.print(rs.getString(2) + "\n");
}
cs.close();
}
其他的除了 obj = m.invoke(conn,args);修改外都一样。既然楼下测试没有问题，我想是否是我的环境中少些东西。当我不用代理时候，一切连接正常。当调用Connection cs = _con.getConnection();就会报异常，Debug 时候在Thread.dispatchUncaughtExcetpion(Throwable) line:not available 页中显示Source not found.
问题补充：
根据楼下的要求 我贴出了main方法，问题还是存在
问题补充：
针对你提的两个可能,我晚上回去测试下,希望在此期间你能给出更多可能,谢谢
问题补充：
导入的 java.sql.Connection是JDBC3.0的。就会出现ClassCastException，而且不会打印出更详细的错误信息。
SqlServer2005支持JDBC3.0,那你的意思是只能用2005的版本?
问题补充：
找了下,好象没有提供的啊,能否给提供下?再次谢谢你的关注!
问题补充：
象这样说 我只能用sqlserver2005的版本了?
问题补充：
不错啊 我晚上找个2005的驱动包 调试下,要是行的通的话就结帖,非常感激你的帮助!
具体代码如下,异常出现在getConnection方法中Connection conn2 = (Connection)Proxy.newProxyInstance(conn.getClass().getClassLoader(),conn.getClass().getInterfaces(),this);
异常内容:Exception in thread "main" java.lang.ClassCastException: $Proxy0
at com.think.Handler.bind(Handler.java:24)
at com.think.TestProxy.main(TestProxy.java:9)
代码:
package tutorial.DBUtil;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
public class _Connection implements InvocationHandler {
private final String CLOSE_METHOD_NAME = "close";
private Connection conn = null;
private boolean inUse = false; //数据库的忙状态
private long lastAccessTime = System.currentTimeMillis();//用户最后一次访问该连接方法的时间
_Connection(Connection conn,boolean inUse)
{
this.conn = conn;
this.inUse = inUse;
}
/**
* Returns the conn.
* @return Connection
*/
public Connection getConnection()
{
//返回数据库连接conn的接管类，以便截住close方法
Connection conn2 = (Connection)Proxy.newProxyInstance(
conn.getClass().getClassLoader(),
conn.getClass().getInterfaces(),this);
return conn2;
}
/**
* @see java.lang.reflect.InvocationHandler#invoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object)
*/
public Object invoke(Object proxy,Method m,Object[] args)
{
Object obj = null;
if(CLOSE_METHOD_NAME.equals(m.getName()))
{
setInUse(false);
}else{
try {
m.invoke(conn, args);
////设置最后一次访问时间，以便及时清除超时的连接
lastAccessTime = System.currentTimeMillis();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return obj;
}
/**
* 该方法真正的关闭了数据库的连接
* @throws SQLException
*/
public void close() throws SQLException
{
//由于类属性conn是没有被接管的连接，因此一旦调用close方法后就直接关闭连接
conn.close();
}
/**
* Returns the inUse.
* @return boolean
*/
public boolean isInUse() {
return inUse;
}
/**
* Returns the lastAccessTime.
* @return long
*/
public long getLastAccessTime() {
return lastAccessTime;
}
/**
* Sets the inUse.
* @param inUse The inUse to set
*/
public void setInUse(boolean inUse) {
this.inUse = inUse;
}
}
问题补充：
public static void main(String[] args) throws Exception {
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
String url = "jdbc:microsoft:sqlserver://localhost:1433;databasename=Test";
Connection conn = DriverManager.getConnection(url, "sa", "123456");
// Connection con = getConnection();
_Connection _con = new _Connection(conn,true);
Connection cs = _con.getConnection();
PreparedStatement ps = cs.prepareStatement("select * from testuser");
ResultSet rs = ps.executeQuery();
while (rs.next()) {
System.out.print(rs.getString(1) + "\n");
System.out.print(rs.getString(2) + "\n");
}
cs.close();
}
其他的除了 obj = m.invoke(conn,args);修改外都一样。既然楼下测试没有问题，我想是否是我的环境中少些东西。当我不用代理时候，一切连接正常。当调用Connection cs = _con.getConnection();就会报异常，Debug 时候在Thread.dispatchUncaughtExcetpion(Throwable) line:not available 页中显示Source not found.
问题补充：
根据楼下的要求 我贴出了main方法，问题还是存在
问题补充：
针对你提的两个可能,我晚上回去测试下,希望在此期间你能给出更多可能,谢谢
问题补充：
导入的 java.sql.Connection是JDBC3.0的。就会出现ClassCastException，而且不会打印出更详细的错误信息。
SqlServer2005支持JDBC3.0,那你的意思是只能用2005的版本?
问题补充：
找了下,好象没有提供的啊,能否给提供下?再次谢谢你的关注!
问题补充：
象这样说 我只能用sqlserver2005的版本了?
问题补充：
不错啊 我晚上找个2005的驱动包 调试下,要是行的通的话就结帖,非常感激你的帮助!
采纳的答案
2008-07-23 lggege (架构师)
我觉得问题还是在这里:
他们的区别在于SQLServerConnection多实现了一个接口, 所以, 使用Mysql驱动没问题, 使用SQL驱动有问题, 看分析, 你应该只需要代理Connection.class就好了
你再试试看.
Connection conn2 = (Connection)Proxy.newProxyInstance( conn.getClass().getClassLoader(), conn.getClass().getInterfaces(), // 这个是这个类实现的所有接口 this); return conn2; }
public classs com.microsoft.sqlserver.jdbc.SQLServerConnection implements java.sql.Connection, java.io.Serializable public calss com.mysql.jdbc.Connection extends com.mysql.jdbc.ConnectionProperties implements java.sql.Connection
他们的区别在于SQLServerConnection多实现了一个接口, 所以, 使用Mysql驱动没问题, 使用SQL驱动有问题, 看分析, 你应该只需要代理Connection.class就好了
Connection conn2 = (Connection) Proxy.newProxyInstance(conn.getClass().getClassLoader(), new Class[] { Connection.class }, this);
你再试试看.
提问者对于答案的评价：
问题终于得以解决，并不需要Jdbc3.0的支持，而是按照上述代码，应该是只实现Connection接口就行，感谢你的回答，把所有的分都给你了，谢谢！
其他回答
更可能的原因是sqlserver的驱动版本不够高，比如说不支持JDBC3.0，你import语句：
导入的 java.sql.Connection是JDBC3.0的。就会出现ClassCastException，而且不会打印出更详细的错误信息。
import java.sql.Connection;
导入的 java.sql.Connection是JDBC3.0的。就会出现ClassCastException，而且不会打印出更详细的错误信息。
llade (资深程序员) 2008-07-23
接口是3.0的那当然要用支持3.0的版本啦。
llade (资深程序员) 2008-07-23
java.sql.Connection 3.0多了几个方法，而你的sql驱动只实现了2.0的。那就会少几个方法的。这也是导致出错的原因所在。
llade (资深程序员) 2008-07-23
引用
SqlServer2005支持JDBC3.0
那么就使用2005的JDBC驱动嘛。
llade (资深程序员) 2008-07-23
sqlserver 可以用2000的，JDBC用2005版本的。应该可以行得通。
llade (资深程序员) 2008-07-23
我用Oracle10g的JDBC驱动来访问Oracle9i的数据库，没啥问题，还解决了一个BUG（Oracle9i的某个版本的驱动对SQL分页程序支持有个BUG）。
llade (资深程序员) 2008-07-23
