我尝试用一个大表(大约一万条记录)中的记录填充JdbcRowSet。我尝试了两个变体(参见下面的代码):
第一个变体会导致内存泄漏,直到堆满为止。第二个变体没有内存泄漏。有人能解释一下为什么第一个会在重用连接对象时导致内存泄漏吗?
谢谢
%1的代码。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import javax.sql.rowset.JdbcRowSet;
import com.sun.rowset.JdbcRowSetImpl;
public class JdbcRowSetMemoryLeak {
/**
* @param args
*/
public static void main(String[] args) {
String username = "user";
String password = "password";
Connection connection = null;
try {
Class.forName("com.mysql.jdbc.Driver");
connection = DriverManager.getConnection("jdbc:mysql://localhost/db_ams?user=" + username + "&password=" + password);
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
JdbcRowSet jdbcRS = null;
for (int i=0;i<150;i++){
System.out.println(i);
try {
jdbcRS = new JdbcRowSetImpl(connection); // <-- Memory is leaking
jdbcRS.setCommand("Select * from sample_t;");
jdbcRS.execute();
// jdbcRS.close(); <-- Returns a null pointer Exception
jdbcRS = null;
} catch (SQLException e) {
e.printStackTrace();
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
%2的代码。
import java.sql.DriverManager;
import java.sql.SQLException;
import javax.sql.rowset.JdbcRowSet;
import com.sun.rowset.JdbcRowSetImpl;
public class JdbcRowSetMemoryGood {
/**
* @param args
*/
public static void main(String[] args) {
String username = "user";
String password = "password";
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
JdbcRowSet jdbcRS = null;
for (int i=0;i<150;i++){
System.out.println(i);
try {
jdbcRS = new JdbcRowSetImpl(DriverManager.getConnection("jdbc:mysql://localhost/db_ams?user=" + username + "&password=" + password));
jdbcRS.setCommand("Select * from sample_t;");
jdbcRS.execute();
jdbcRS.close();
jdbcRS = null;
} catch (SQLException e) {
e.printStackTrace();
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
您的问题“为什么在重用连接对象时第一个会导致内存泄漏?”的答案
是的,您正在重用connection对象,但您在每次迭代中都创建一个新的jdbcrowset
对象,而您没有关闭它,这会导致内存泄漏。jdbcrs=null;
不会关闭资源。
您的问题“为什么我不能在第一个snippset中关闭ResultSet而在第二个snippset中关闭?”的答案
在第一个代码段中,当您使用close方法关闭jdbcrs
对象jdbcrs
时,jdbcrs.close();
也关闭了连接。因此,第二次迭代将抛出一个NullPointerException,因为在jdbcrs=new JdbcRowSetImpl(connection);
处,connection
已经关闭。
第二个代码段工作良好,因为您在getConnection
方法的每次迭代中都创建一个新连接。
最好的方法是使用cachedrowset
在每次迭代后自动关闭资源:
package databases;
import java.sql.SQLException;
import javax.sql.rowset.*;
public class CachedRowSet_Usage {
public static void main(String[] args) {
String username = "username";
String password = "password";
String url = "jdbc:mysql://localhost:3306/your_database_name";
try{
CachedRowSet rs = RowSetProvider.newFactory().createCachedRowSet();
//JdbcRowSet rs = RowSetProvider.newFactory().createJdbcRowSet();
rs.setUrl(url);
rs.setUsername(username);
rs.setPassword(password);
for(int i=0;i<150;i++){
System.out.println(i);
rs.setCommand("Select * from your_table");
rs.execute();
//rs.close(); <-- no use, rs closes automatically
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}