のjavaを持つテーブルのSQLをスキャンごとに5秒

Question

誰でもmysqlのテーブルに入力された新しいデータの存在を知るために、5秒ごとのスキャンを行うためにJavaで関数を作成する方法を、私を助けることができます。

Answer 1

。

ここにコードがあります。

java.util.TimerTask task = new java.util.TimerTask() { 
     int prevCount = 0; // you can declare it static 
     @Override 
     public void run() { 
      Connection conn = getConnection(); 
      try { 
       ResultSet rs = conn.prepareStatement("Select Count(*) from table").executeQuery(); 
       int count = rs.getInt(1); 
       System.out.println("Count diff:"+ (prevCount-count)); 
      } catch (Exception e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 
     } 
    }; 
    java.util.Timer timer = new java.util.Timer(true);// true to run timer as daemon thread 
    timer.schedule(task, 0, 5000);// Run task every 5 second 
    try { 
     Thread.sleep(60000); // Cancel task after 1 minute. 
    } catch (InterruptedException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
    timer.cancel(); 

Answer 2

大きなテーブル（特に大きなテーブル）で検索を行うのは大変です。したがって、おそらく、新しいデータを別の方法で検出することによって、テーブルの読み込み量を減らすことができます。実際のデータをフェッチする前に

たとえば、テーブルのサイズを確認することができます。これを行うには、単に "テーブルからカウント（*）を選択"操作を実行するか、ここでのようにディスク上のテーブルのサイズを計算することもできます：How to get the sizes of the tables of a mysql database?

データベーストリガーのバリアントも役立ちます。たとえば、Javaアプリケーションが表示される最後のテーブルの更新のマーカーをトリガーが更新する場合はどうなりますか？この変種はまた、あなたのテーブルのアイドルリードの実行を避けるのに役立ちます。あなたは、DBの変更をスキャンするJavaプログラムを必要としない

Answer 3

は、離れて、それがネットワークやDBにコストがかかることになる冗長から、それはすでに標準溶液として与えられている機能を実装することをお勧めではありません。あなたは何ができるか

CREATE TRIGGER `some_update_happened` BEFORE/AFTER INSERT/UPDATE/DELETE 
ON `mydb`.`mytable` 
FOR EACH ROW BEGIN 
    // your code here for db trigger calling java function 
END; 

は、DB更新トリガがthis link & this linkを参照してください使用しています。 トリガを実装した後、私はphp、javaなどで実装されたサービスを使用してトリガを捕捉する必要があると考えます。トリガの自動化を受信するイベントリスナを実装する必要があります。ちょうどdone here for PHPのように、またオークションのドキュメントにはexampleがありますが、これはOracle向けです。ここにはjava+mysqlの例があります。

私は、エラーによりステップバイステップで、エラーを行くと、あなたがそこに着くなり、あなたが初心者で理解しています。がんばろう。あなたは、Javaが提供するタイマー&タイマータスクでそれを行うことができ、唯一のJavaソリューションを必要とする場合には