【发布时间】：2017-09-26 18:39:05
【问题描述】：
我想在每个实例的实例中运行我的代码代码从我的数据库中提取数据作为结果集并停止等待另外 5 分钟提取结果集并停止。程序永远不应该结束。问题是程序在第一个实例等待 5 分钟，但再次等待它继续运行 下面是代码。结果集和数据库连接部分没问题
package postilion_error.checker;
/**
*
* @author kithinjid
*/
import java.io.IOException;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Timer;
import java.util.logging.*;
import java.util.TimerTask;
import static sun.font.FontManager.logger;
public class POSTILION_ERRORCHECKER {
static Logger log;
static Handler file_handler;
Connection conn=null;
Statement st=null;
static ResultSet rs=null;
static int i = 0;
static int counter=0;
static boolean checker=true;
private void dbconnect()
{
String username="Postilion";
String password="Password12";
String hostname="jdbc:sqlserver://172.16.112.6;databaseName=realtime";
try
{
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn=DriverManager.getConnection(hostname,username,password);
System.out.println("TIME:"+dateString("MM:dd-HH:mm:ss")+":connected to database");
}
catch(Exception e)
{
e.printStackTrace();
}
}
private ResultSet check_00(String query1)
{
dbconnect();
try
{
st=conn.createStatement();
rs=st.executeQuery(query1);
}catch(Exception e)
{
e.printStackTrace();
}
return rs ;
}
public static void scheduled()
{
Timer timer=new Timer();
timer.schedule(new TimerTask() {
@Override
public void run() {
while(checker==true)
{
log=logger.getLogger("my logger");
try {
file_handler=new FileHandler("C:\\Users\\kithinjid\\Google Drive\\interswitch\\NetBeansProjects\\POSTILION_ERROR CHECKER\\dist\\logg.txt");
SimpleFormatter formatter=new SimpleFormatter();
file_handler.setFormatter(formatter);
log.addHandler(file_handler);
} catch (IOException ex) {
log.info(dateString("HHmmss"));
Logger.getLogger(POSTILION_ERRORCHECKER.class.getName()).log(Level.SEVERE, null, ex);
} catch (SecurityException ex)
{
Logger.getLogger(POSTILION_ERRORCHECKER.class.getName()).log(Level.SEVERE, null, ex);
}
String query="SELECT TOP 100 [tran_nr]\n" +
" ,[gmt_date_time]\n" +
" ,[time_local]\n" +
" ,[date_local]\n" +
" ,[sink_node]\n" +
" ,[rsp_code_req_rsp]\n" +
" ,[rsp_code_cmp]\n" +
" ,[rsp_code_rev]\n" +
" FROM [realtime].[dbo].[tm_trans_10] where sink_node = 'GTBUSDsnk' ORDER BY tran_nr desc";
POSTILION_ERRORCHECKER pe=new POSTILION_ERRORCHECKER();
pe.dbconnect();
try
{
ResultSet result=pe.check_00(query);
while(result.next()==true)
{
//loop for counter and displaying
int response=Integer.parseInt(result.getString("rsp_code_req_rsp"));
System.out.println(response);
if (response==91)
{
counter++;
if (counter>=10)
System.out.println("TIME:"+dateString("MM:dd-HH:mm:ss")+"--error respose code:91 of count:"+ counter+" to sink node GTBUSDsnk");
}
}
}catch(Exception e)
{
e.printStackTrace();
}
// throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
}
},30000,30000);
}
public static void main(String[] args)
{
scheduled();
System.out.println("execution started");
}
private static String dateString(String formart)
{
DateFormat dateFormat = new SimpleDateFormat(formart);
java.util.Date date = new java.util.Date();
return dateFormat.format(date);
}
}
【问题讨论】：
-
无法真正阅读未格式化的代码，但最终的问题是什么或您面临什么问题？
-
@DaveNewton 我需要代码运行一次选择结果集并停止 5 分钟然后再次选择
-
简单使用Quartz调度库，无需重新发明轮子
-
我认为应该有一个java代码解决方案
-
什么是 ,30000,30000 这是无效的语法。是的，不需要库，Thread.sleep 可以完成这项工作。
标签： java sql algorithm while-loop