一个JAVA程序

jacketble

一个程序
import java.sql.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;
import java.lang.Runtime;
import java.util.*;
import java.util.regex.*;
import java.text.*;
class chat extends JPanel
  {
    public static void main(String[] args)
      {
        try
   {
            Class.forName("com.mysql.jdbc.Driver");
          }
        catch(ClassNotFoundException e)
   {
            System.out.println("找不到驱动程序");
          }
        final JFrame frame = new JFrame("数据控制系统");
        Container hu=frame.getContentPane();
        //
        final TextArea hu1=new TextArea("",20,40);
        hu1.setEditable(false);
        hu1.setText("欢迎您进入内部数据控制系统!!请选择相应命令进行操作
键入help寻求帮助");
final JTextField hu2=new JTextField(10);
hu.setLayout(new BorderLayout());
hu.add(hu1,BorderLayout.CENTER);
hu.add(hu2,BorderLayout.SOUTH);
//
        hu2.addActionListener(new ActionListener() {
   public void actionPerformed(ActionEvent e){
      String msg=hu2.getText();
      if(msg.equals("help"))
        {
          hu1.setText("help  ->  to find help
view all  ->  to view all
view visit  ->  to view visit
view ip  ->  to view ip
view user $user  ->  to view infomation of a user
Compare $user1 $user2 $dis  ->  to compare the change of $user1 and $user2,delay $dis miliseconds per one information
Allcompare amount dis or Allcompare rate dis or Allcompare all dis
listen visit  -> to listen visit change
listen data  ->  to listen data change
backup  ->  to backup database
copyright  ->  to view copyright
you can also input select Query to select information from job database
the below list is aviliable sql:
select,update,delete,drop,create,alter,optimize,lock,unlock,use,describe,repair
");
        }
      if(msg.equals("view all"))
        {
          hu1.setText("NOW,the brief information of this system:
");
          try
     {
       double[] hn=new double[20];
       int all=0;
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   String query="select count(*) as s from job";
                                   ResultSet rs=stmt.executeQuery(query);
       while(rs.next())
       hu1.append("Totally infomation: "+rs.getInt("s")+"
");
       query="select count(*) as s from job where user>0";
       rs=stmt.executeQuery(query);
       while(rs.next())
       {
       all=rs.getInt("s");
       hu1.append("User infomation: "+all+"
");
       }
       query="select avg(user) as s from job where user>0";
       rs=stmt.executeQuery(query);
       while(rs.next())
       hu1.append("User avg: "+rs.getDouble("s")+"
");
       query="select count(*) from job where to_days(antime)-to_days(now())>-30";
       rs=stmt.executeQuery(query);
       while(rs.next())
       hu1.append("the amount of laterest month:"+rs.getInt(1)+"
");
                                   query="select count(*) from job where to_days(antime)-to_days(now())>-7";
       rs=stmt.executeQuery(query);
       while(rs.next())
       hu1.append("the amount of laterest week:"+rs.getInt(1)+"
");
       query="select count(*) from job where to_days(antime)-to_days(now())=0";
       rs=stmt.executeQuery(query);
       while(rs.next())
       hu1.append("the amount of today:"+rs.getInt(1)+"
");
       hu1.append("
------list of user information/all-------
");
       query="select count(*) as s,user from job where user>0 group by user order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           int user=rs.getInt("user");
           int amount=rs.getInt("s");
           double amou=rs.getDouble("s");
           double amou1=(amou/all)*100;
           hn[user]=amou1;
           hu1.append(user+"        "+amount+"        "+amou1+"%
");
         }
                                   hu1.append("
------list of user information/laterest month-------
");
                                   query="select count(*) as s from job where to_days(antime)-to_days(now())>-30";
                                   rs=stmt.executeQuery(query);
                                   while(rs.next())
         all=rs.getInt("s");
                                   query="select count(*) as s,user from job where to_days(antime)-to_days(now())>-30 group by user order by s desc";
       rs=stmt.executeQuery(query);
       String res;
       while(rs.next())
         {
           int user=rs.getInt("user");
           int amount=rs.getInt("s");
           double amou=rs.getDouble("s");
           double amou1=(amou/all)*100;
           if(hn[user]-7";
                                   rs=stmt.executeQuery(query);
                                   while(rs.next())
         all=rs.getInt("s");
                                   query="select count(*) as s,user from job where to_days(antime)-to_days(now())>-7 group by user order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           int user=rs.getInt("user");
           int amount=rs.getInt("s");
           double amou=rs.getDouble("s");
           double amou1=(amou/all)*100;
           if(hn[user]-30";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           allm=rs.getInt("s");
           hu1.append("The amount of laterest month:"+allm+"
");
         }
                                   query="select count(*) as s from visit where to_days(time)-to_days(now())>-7";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           allw=rs.getInt("s");
           hu1.append("The amount of laterest week:"+allw+"
");
         }
       query="select count(*) as s from visit where to_days(time)-to_days(now())=0";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           alld=rs.getInt("s");
           hu1.append("The amount of today:"+alld+"
");
         }
       query="select max(time) as s from visit";
       rs=stmt.executeQuery(query);
       while(rs.next())
         hu1.append("The laterest click:"+rs.getString("s")+"
");
       hu1.append("
------the list of visit/all------
");
       query="select count(*) as s,visit from visit group by visit order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/all)*100;
           hu1.append(rs.getString("visit")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of visit/the laterest month------
");
       query="select count(*) as s,visit from visit where to_days(time)-to_days(now())>-30 group by visit order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/allm)*100;
           hu1.append(rs.getString("visit")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of visit/the laterest week------
");
       query="select count(*) as s,visit from visit where to_days(time)-to_days(now())>-7 group by visit order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/allw)*100;
           hu1.append(rs.getString("visit")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of visit/today------
");
       query="select count(*) as s,visit from visit where to_days(time)-to_days(now())=0 group by visit order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/alld)*100;
           hu1.append(rs.getString("visit")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       stmt.close();
       conn.close();
     }
                               catch(SQLException e1)
     {
       e1.printStackTrace();
     }
        }
      if(msg.equals("view ip"))
        {
                               try
     {
                                   int all,allm,allw,alld;
       all=allm=allw=alld=0;
       hu1.setText("NOW,The brief information of ip database
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   String query="select count(*) as s from visit";
                                   ResultSet rs=stmt.executeQuery(query);
       while(rs.next())
         {
           all=rs.getInt("s");
           hu1.append("The amount of visit :"+all+"
");
         }
       query="select count(*) as s from visit where to_days(time)-to_days(now())>-30";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           allm=rs.getInt("s");
           hu1.append("The amount of laterest month:"+allm+"
");
         }
                                   query="select count(*) as s from visit where to_days(time)-to_days(now())>-7";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           allw=rs.getInt("s");
           hu1.append("The amount of laterest week:"+allw+"
");
         }
       query="select count(*) as s from visit where to_days(time)-to_days(now())=0";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           alld=rs.getInt("s");
           hu1.append("The amount of today:"+alld+"
");
         }
       query="select max(time) as s from visit";
       rs=stmt.executeQuery(query);
       while(rs.next())
         hu1.append("The laterest click:"+rs.getString("s")+"
");
       hu1.append("
------the list of ip/all------
");
       query="select count(*) as s,ip from visit group by ip order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/all)*100;
           hu1.append(rs.getString("ip")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of ip/the laterest month------
");
       query="select count(*) as s,ip from visit where to_days(time)-to_days(now())>-30 group by ip order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/allm)*100;
           hu1.append(rs.getString("ip")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of ip/the laterest week------
");
       query="select count(*) as s,ip from visit where to_days(time)-to_days(now())>-7 group by ip order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/allw)*100;
           hu1.append(rs.getString("ip")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       hu1.append("
------the list of visit/today------
");
       query="select count(*) as s,ip from visit where to_days(time)-to_days(now())=0 group by ip order by s desc";
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           double v=rs.getDouble("s");
           double v1=(v/alld)*100;
           hu1.append(rs.getString("ip")+"        "+rs.getInt("s")+"        "+v1+"%
");
         }
       stmt.close();
       conn.close();
     }
                               catch(SQLException e1)
     {
       e1.printStackTrace();
     }
        }
      if(msg.equals("listen visit"))
        {
                               try
     {
       hu1.setText("Listen visit start......
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   int ori_amount=0;
                     int now_amount=0;
                     String query;
                     ResultSet rs;
                                   for(;;)
         {
           try
           {
           Thread.sleep(1000);
           query="select count(*) as s from visit";
           rs=stmt.executeQuery(query);
           while(rs.next())
      now_amount=rs.getInt("s");
           if(now_amount!=ori_amount)
      {
                                           int dis_amount=now_amount-ori_amount;
                      int now1_amount=now_amount-1;
                      query="select * from visit limit "+now1_amount+","+dis_amount;
                      rs=stmt.executeQuery(query);
                      while(rs.next())
          hu1.append(rs.getInt("id")+"        "+rs.getString("time")+"        "+rs.getString("visit")+"        "+rs.getString("ip")+"
");
        ori_amount=now_amount;
      }
           }
           catch(Exception e2)
      {
        e2.printStackTrace();
      }
         }
     }
                               catch(SQLException e1)
     {
       e1.printStackTrace();
     }
        }
      if(msg.equals("listen data"))
        {
                               try
     {
                                   hu1.setText("Listen data start......
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   int ori_amount=0;
                     int now_amount=0;
                     String query;
                     ResultSet rs;
                                   for(;;)
         {
           try
           {
           Thread.sleep(1000);
           query="select count(*) as s from job";
           rs=stmt.executeQuery(query);
           while(rs.next())
      now_amount=rs.getInt("s");
           if(now_amount!=ori_amount)
      {
                                           ori_amount=now_amount;
                      query="select count(*) as s,user from job where user>0 group by user order by user";
                      rs=stmt.executeQuery(query);
                      StringBuffer ra=new StringBuffer("");
                      int v1=now_amount-50896;
                      ra.append(v1+"        ");
                      while(rs.next())
                        {
                   int v2=rs.getInt("s");
                   ra.append(v2+"        ");
                        }
        hu1.append(ra.toString()+"
");
      }
           }
           catch(Exception e2)
      {
        e2.printStackTrace();
      }
         }
     }
                               catch(SQLException e1)
     {
       e1.printStackTrace();
     }
        }
      if(msg.startsWith("s")||msg.startsWith("use")||msg.startsWith("o")||msg.startsWith("describe")||msg.startsWith("c")||msg.startsWith("r"))
        {
                               try
     {
       int pi=-1;
       String msg_sql=hu2.getText();
       hu1.setText("the Query you input is
"+msg_sql+"
");
       hu1.append("The result from database reflection:
--->
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";//&useUnicode=true&characterEncoding=gbk";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   ResultSet rs=stmt.executeQuery(msg_sql);
                                   int cn=0;
       while(rs.next())
         {
                                       ResultSetMetaData rsmd=rs.getMetaData();
                                       cn=rsmd.getColumnCount();
                                       for(int ik=1;ik300)
      break;
           for(int is=1;is
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";//&useUnicode=true&characterEncoding=gbk";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   stmt.executeUpdate(msg_sql);
       hu1.append("run successfully");
              stmt.close();
              conn.close();
            }
          catch(SQLException e1)
     {
       String error="
"+e1;
       hu1.append("sql error happend:"+error);
     }
        }
      if(msg.startsWith("lock")||msg.startsWith("unlock"))//以下为execute部分
        {
          try
     {
                                   String msg_sql=hu2.getText();
              hu1.setText("the Query you input is
"+msg_sql+"
");
              hu1.append("The result from database reflection:
--->
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";//&useUnicode=true&characterEncoding=gbk";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
                                   stmt.execute(msg_sql);
       hu1.append("run successfully");
              stmt.close();
              conn.close();
            }
          catch(SQLException e1)
     {
       String error="
"+e1;
       hu1.append("sql error happend:"+error);
     }
        }
      if(msg.equals("backup"))//以下部分为数据库备份部分!!
        {
                               try
     {
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   String url1="jdbc:mysql://192.168.0.101:3306/";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
       String query="delete from jobbak";
       hu1.setText("execute delete:"+query+".....
");
       stmt.executeUpdate(query);
       hu1.append("execute delete:succeed!
");
       query="insert into jobbak select * from job";
       hu1.append("execute insert:"+query+".....
");
       stmt.executeUpdate(query);
       hu1.append("execute insert:succeed!
");
       query="select * from job into outfile 'f:/job.txt' fields terminated by '*&^%'";
       hu1.append("
lanback start!!
");
       hu1.append("
delete file f:/job.txt .....
");
       File china=new File("f:/job.txt");
       int ps=0;
       while(china.exists())
         {
           china.delete();
           if(++ps>10)
      break;
         }
       if(!china.exists())
         {
           hu1.append("file f:/job.txt deleted successfully!!
");
           hu1.append("execute making a file:"+query+".....
");
           stmt.execute(query);
           hu1.append("execute making a file:succeed!
");
           hu1.append("backup to 192.168.0.101 start!!
");
           Runtime rt=Runtime.getRuntime();
           //rt.exec("c:\mysql\bin\mysqlimport -u huyang -p -h 192.168.0.101 -d --fields-terminated-by="*&^%" huyang f:\job.txt");
           String cmd1="c:\mysql\bin\mysqlimport -u huyang -ppassword -h 192.168.0.101 -d --fields-terminated-by=\"*&^%\" huyang f:\job.txt";
           rt.exec(cmd1);
           hu1.append("backup to 192.168.0.101 succeed!
");
         }
       else
         {
           hu1.append("file f:/job.txt can not be deleted,lanback end!!
");
         }
       stmt.close();
       conn.close();
     }
                               catch(SQLException e1)
     {
                                   String error="
"+e1;
       hu1.append("sql error happend:
"+error);
       //e1.printStackTrace();
     }
          catch(Exception e0)
     {
       String error="
"+e0;
       hu1.append("error happend:
"+error);
     }
        }
      if(msg.startsWith("view user"))
        {
                               try
     {
       String[] ss=msg.split("
\s
");
       int user=Integer.parseInt(ss[2]);
       hu1.setText("the information of user "+user+" is :
");
                                   String url = "jdbc:mysql://localhost:3306/job?user=root&password=";
                                   Connection conn = DriverManager.getConnection(url);
                                   Statement stmt = conn.createStatement();
       String query="select count(*) as s from job where user="+user;
       ResultSet rs=stmt.executeQuery(query);
       while(rs.next())
         {
           hu1.append("The total information: "+rs.getInt("s")+"
");
         }
       query="select max(antime),min(antime) from job where user="+user;
       rs=stmt.executeQuery(query);
       while(rs.next())
         {
           hu1.append("The earlist click was at  "+rs.getString(2)+"
");
           hu1.append("The laterest click was at "+rs.getString(1)+"
");
         }
       hu1.append("
----the change of rate----
&qu

本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u/623/showart_32458.html