我的Java脚本由2 Java类:RMS
,queryRMS
在RMS
I类调用该方法的queryRMS
类
RMS Java类(我省略了开始执行部分,下面只是方法)
for (int i = 1; i <= itemCount; i++) {
GlobalVariables.numberRow = i;
JavaDatapool.settings();
String item = queryRPM.connectDB_Multi(configFile,"SELECT ITEM FROM ORDSKU WHERE ORDER_NO = '" + orderNo + "' ORDER BY ITEM ASC",i);
JavaDatapool.writeXLS("item",item,GlobalVariables.sheetXLS);
sleep(1);
}
Run Code Online (Sandbox Code Playgroud)
queryRMS JAVA类
public static String connectDB_Multi(String configFile, String query, int i) throws FileNotFoundException, IOException, SQLException, ClassNotFoundException{
Properties p = new Properties();
p.load(new FileInputStream(configFile));
String serverName = (p.getProperty("RMS_DBServerName"));
String portNumber = (p.getProperty("RMS_PortNumber"));
String sid = (p.getProperty("RMS_SID"));
String url = "jdbc:oracle:thin:@//" + serverName + ":" + portNumber + "/" + sid;
String username = (p.getProperty("RMS_Username"));
String password = (p.getProperty("RMS_Password"));
// jdbc:oracle:thin:@//localhost:1521/orcl
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection connection = DriverManager.getConnection(url,username,password);
String setr = null;
try {
Statement stmt = connection.createStatement();
try {ResultSet rset = stmt.executeQuery(query);
try {
while(rset.absolute(i))
setr = rset.getString(1);
return setr;
}
finally {
try { rset.close();
}
catch (Exception ignore) {}
}
}
finally {
try { stmt.close();
}
catch (Exception ignore) {}
}
}
finally {
try { connection.close();
}
catch (Exception ignore) {}
}
}
Run Code Online (Sandbox Code Playgroud)
所以它的作用是调用connectDB_multi
类,然后返回String,下一部分将其保存在Excel工作表中.
循环应该一次返回所有行,然后将其保存在Excel工作表中.
在第二次循环中,查询出现故障,尽管查询应该返回包含2行的1列.
原始包含的部分while(rset.next())
代替while(rset.absolute(i))
但是接下来每次只返回第一行.所以当从数据库中只检索到一列和一行时,脚本才有效.
你的逻辑看起来有点搞砸了.
看看你发布的第一个循环.你有效地执行:
SELECT ITEM FROM ORDSKU WHERE ORDER_NO = '" + orderNo + "' ORDER BY ITEM ASC
itemCount
次数.每次执行它时,您都试图访问第n行,n是循环计数器.你觉得那里有问题吗?你怎么知道查询会返回itemCount行数?因为如果没有,它将失败,因为您尝试访问不存在的行.
我怀疑你想做的事情是这样的
Statement stmt = connection.createStatement();
ResultSet rset = stmt.executeQuery(query);
while(rset.next()) {
JavaDatapool.writeXLS("item",rset.getString(1),GlobalVariables.sheetXLS);
}
Run Code Online (Sandbox Code Playgroud)
您还应该认真考虑使用某种形式的连接池,以避免不得不一直重新打开新连接,因为这是一个非常耗时的操作.
归档时间: |
|
查看次数: |
167 次 |
最近记录: |