JDBC 如何取出数据库里的数据~菜鸟求救!!!
发布网友
发布时间：2022-04-09 08:07
共2个回答
懂视网
时间：2022-04-09 12:28
先读取所有编号形成List，后遍历这个List，先查出id再查详细数据。这样的数据csv文件中大约8万多条
一条条的来肯定慢，如果不按照编号，直接一次查出，数据是9万多条。速度都很慢！！！
后来想提高下，至少要有个明显的提升呀。写文件这块基本排除了，剩下的疑问就是ResultSet是否拿到了所有结果呢？
根据网上查到的资料和实际调试，得出答案：ResultSet默认一次取10条数据，怪不得要慢，如果一次全部读入内存再写入文件就一定很快了。
怎样一次读取所有数据呢？
sql改为读取全部
1 String sql="select req.LR_APPLYID,CURR_PERIODS,REPAY_DAY, " + 2 "(NEEDREPAY_PRINCIPAL+NEEDREPAY_INTEREST+NEEDREPAY_ADMIFEE+nvl(RISK_AMOUNT,0)+nvl(SERVICEFEE,0)+nvl(PARKINGFEE,0))NEEDREPAY_TOTAL, " + 3 "PERIOD_REPAY_AMOUNT " + 4 "from( " + 5 " select lr_id,LR_APPLYID from t_loan_request t " + 6 " where t.LR_REQUESTSTATUS =‘2‘ and t.creater=‘PostLoanOuterAction‘ " + 7 " order by lr_id desc)req " + 8 "left join t_repay_plan rp " + 9 "on req.lr_id=rp.lr_id " + 10 "order by req.lr_id,CURR_PERIODS";
设置PreparedStatement：
1 pre = con.prepareStatement(sql); 2 pre.setFetchSize(100000); 3 result = pre.executeQuery(); 4 //result.setFetchSize(100000);
主要是PreparedStatement的 setFetchSize 方法，
后来发现ResultSet也有个setFetchSize 方法，也是可行的，只是这个时候resultset中已经有了10条记录直到循环10次后，再次使用result.next()才去取100000，fetchSize才起作用
这样设置后速度飞快！！！
jdbc--取大量数据
标签：
热心网友
时间：2022-04-09 09:36
注意：你需要在项目中引入“ojdbc6.jar”才可以在java中访问Oracle。
修改后的Java程序：
import java.awt.FlowLayout;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
class Main extends JFrame implements ActionListener {
TextField tf;
TextArea ta;
JButton btn;
public Main(){
super();
tf = new TextField(10);
ta = new TextArea(10,15);
btn = new JButton("确定");
this.setLayout(new FlowLayout());
this.add(tf);
this.add(btn);
this.add(ta);
btn.addActionListener(this);
this.setSize(200, 200);
this.setVisible(true);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
public static void main(String[] args) {
new Main();
}
@Override
public void actionPerformed(ActionEvent e) {
if(tf.getText().equals("")) {
JOptionPane.showMessageDialog(null, "请输入问题！","Warning", 0);
return;
}
else {
String str = Connect.getDeptName(tf.getText());
ta.setText(str);
}
}
}
class Connect{
public static String getDeptName(String deptNo1){
ResultSet rs = null;
Statement stmt = null;
Connection conn = null;
PreparedStatement ps = null;
String deptName = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","scott","tiger");
stmt = conn.createStatement();
ps = conn.prepareStatement("select DNAME from dept where deptno = ?");
ps.setString(1,deptNo1);
rs = ps.executeQuery();
if(rs.next()){
deptName = rs.getString(1);
}
}
catch(ClassNotFoundException e){
e.printStackTrace();
}
catch(SQLException e){
e.printStackTrace();
}
finally{
try{
if(rs!=null){
rs.close();
rs = null;
}
if(ps!=null){
ps.close();
ps = null;
}
if(conn!=null){
conn.close();
conn = null;
}
}
catch(SQLException e){
e.printStackTrace();
}
}
return deptName;//返回对应的DANME;
}
}
运行测试：
