【Java】每2秒查询一次数据库
1.起定时器,每2秒进行一次动作
package connection;import java.util.Timer;
import java.util.TimerTask;public class ConnetionToOracle extends TimerTask {public static void main(String[] args) {Timer timer = new Timer();ConnetionToOracle t = new ConnetionToOracle();timer.schedule(t, 0, 2000);}@Overridepublic void run() {// TODO Auto-generated method stubJdbcConnection.JdbcDemo();}}
2.查询数据库
package connection;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;public class JdbcConnection {public static void JdbcDemo() {Connection con;String driver = "oracle.jdbc.OracleDriver";String url = "jdbc:oracle:thin:@。。。。";String user = "";String password = "";try {Class.forName(driver);con = DriverManager.getConnection(url,user,password);if(!con.isClosed())System.out.println("Succeeded connecting to the Database!");Statement statement = con.createStatement();String sql = "select * from t_users";ResultSet rs = statement.executeQuery(sql);System.out.println("-----------------");System.out.println("执行结果如下所示:"); System.out.println("-----------------"); System.out.println("姓名" + "\t" + "ID"); System.out.println("-----------------"); String username = null;String user_id = null;while(rs.next()){username = rs.getString("USERNAME");user_id = rs.getString("USER_ID");System.out.println(username + "\t" + user_id);}rs.close();con.close();} catch(ClassNotFoundException e) { //数据库驱动类异常处理System.out.println("数据库连接失败"); e.printStackTrace(); } catch(SQLException e) {//数据库连接失败异常处理System.out.println("数据库连接失败"); }catch (Exception e) {// TODO: handle exceptionSystem.out.println("数据库连接失败");}finally{System.out.println("数据库数据成功获取!!");}}
}
3.1中调用2中程序,完成数据库每2秒查询一次
本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!
