欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

浅谈对jdbc和jtds的一些认识

程序员文章站 2024-03-14 19:37:16
...
最近做项目用SQLSERVER2000的数据库,使用JTDS开源的驱动,跟大家谈谈个人对JDBC的一些理解。
一个DateSource可以获取多个Connection,一个Connection可以打开多个Statement,一个Statement可以打开多个ResultSet。如果我直接

conn.close();仔细翻看jtds源代码。在底层是这样实现的。
Connection------------------------close方法

synchronized public void close() throws SQLException {
if (!closed) {
try {
//
// Close any open statements
//
ArrayList tmpList;

synchronized (statements) {
tmpList = new ArrayList(statements);
statements.clear();
}

for (int i = 0; i < tmpList.size(); i++) {
WeakReference wr = (WeakReference)tmpList.get(i);

if (wr != null) {
Statement stmt = (Statement) wr.get();
if (stmt != null) {
try {
stmt.close();
} catch (SQLException ex) {
// Ignore
}
}
}
}

try {
// Tell the server the session is ending
baseTds.closeConnection();
// Close network connection
baseTds.close();
// Close cached TdsCore
if (cachedTds != null) {
cachedTds.close();
cachedTds = null;
}
} catch (SQLException ex) {
// Ignore
}

socket.close();
} catch (IOException e) {
// Ignore
} finally {
closed = true;
}
}
}


statement------------------------close方法

public void close() throws SQLException {
if (!closed) {
SQLException closeEx = null;
try {
closeAllResultSets();
} catch (SQLException ex) {
if (!"HYT00".equals(ex.getSQLState())
&& !"HY008".equals(ex.getSQLState())) {
// Only throw exceptions not caused by cancels or timeouts
closeEx = ex;
}
} finally {
SQLException releaseEx = null;
try {
if (!connection.isClosed()) {
connection.releaseTds(tds);
}
// Check for server side errors
tds.getMessages().checkErrors();
} catch (SQLException ex) {
// Remember any exception thrown
releaseEx = ex;
// Queue up any result set close exceptions
if (closeEx != null) {
releaseEx.setNextException(closeEx);
}
} finally {
// Clean up everything
closed = true;
tds = null;
connection.removeStatement(this);
connection = null;

// Re-throw any caught exception
if (releaseEx != null) {
throw releaseEx;
}
}
}
// Throw any exception caught during result set close
if (closeEx != null) {
throw closeEx;
}
}
}

看起来是如果关闭Connection,那么在此Connection上打开的所有Statement会关闭,如果关闭Statement那么在此Statement上打开的所有的

ResultSet也会关闭。如果没有特殊需要,直接关闭Connection即可。

那么在什么情况下需要先关闭ResultSet,然后关闭Statement。然后关闭Connection呢?

仔细翻看Jtds的文档。找到了以下内容:
JDBC Concurrency : CONCUR_UPDATABLE+1
SQL Server Concurrency: Pessimistic concurrency, updatable
Row Locks: Yes
Description : Row integrity isensured by locking rows


意思就是当
Statement st=Connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_UPDATABLE+1);
ResultSet rs=st.executeQuery("SELECT * FROM TABLE2 where id=1");
rs.updateString(1,"test");
rs.updateRow() ;

该结果集就会锁定当前行,其他ResultSet不得访问。
这个时候ResultSet应当尽可能早的close()。以便释放资源。

web服务器会为每次请求创建一个线程。也就是说一次request打开一次连接即可!在一次连接上创建多个Statement。
写一个监听器,每次销毁request的时候释放数据库连接。
http://supttkl.iteye.com/admin/blogs/181419

JTDS虽然实现了数据源,但是没有实现实现连接池。所以还要借助中间件的连接池,如dbcp。。。

ConnectionJDBC2没有实现Savepoint保存点。ConnectionJDBC3实现了保存点.
那么什么时候使用保存点事务呢?
个人理解:
a向b借钱,b当时没有钱,然后到银行取出钱后委托给c,又c将钱转交给a
等c将钱转交给a的时候,发生了意外。那么钱应该在c手中,事务应该回滚到c,而不应该回滚到b。因为钱已经在c手中。
Connection conn=getConnetion();
conn.setAutoCommit(false);//启动事务
//b取钱
PreparedStatement pst=conn.prepareStatement("select * from money where bid=1");
ResultSet rs=pst.exeQuery();
int money=rs.getInt("money");
Savepoint savepoint=conn.setSavepoint("pointc");
//b将钱转交给c
PreparedStatement pst2=conn.prepareStatement("update table set money + ?");
pst2.setInt(1, money);
pst2.execute();
//c将钱转交给a的时候,出现了异常,如a不在家。
try{
PreparedStatement pstc=conn.prepareStatement("update table set money - ?");
pstc.setInt(money);
pstc.execute();
PreparedStatement psta=conn.prepareStatement("update table set money + ?");
psta.setInt(money);
psta.execute();
}catch(SQLException e){
//回滚到c
conn.rollback(savepoint)

}