mainframe.java

查询分析器java

            //设置默认的文件管理器
            chooser.setFileFilter(fliter);
            int rs = chooser.showSaveDialog(this);


            if(rs == JFileChooser.APPROVE_OPTION)
            {
                try
                {
                    //BufferedReader br=new BufferedReader(new StringReader(txtoutare.getText()));
                    BufferedReader br=new BufferedReader(new StringReader(txtoutare.getText()));
                    BufferedWriter bw = new BufferedWriter(new FileWriter(chooser.getSelectedFile().getAbsolutePath()));

                    String line = null;

                    while((line=br.readLine())!=null)
                    {
                        bw.write(line);
                        bw.newLine();
                    }
                    bw.flush();
                    bw.close();

                    JOptionPane.showMessageDialog(null,"输出结果保存成功！","提示",JOptionPane.INFORMATION_MESSAGE);
                } catch (Exception ex)
                {
                    System.out.print(ex.getMessage());
                }
            }
        }
        //打开文件
        if(e.getSource()==open)
        {
            JFileChooser chooser = new JFileChooser(".");
            FileFliter fliter=new FileFliter();
            chooser.addChoosableFileFilter(fliter);
            //设置默认的文件管理器
            chooser.setFileFilter(fliter);
            chooser.showOpenDialog(null);
            BufferedReader brr=null;
            String line;
            String str="";
            try
            {
                brr=new BufferedReader(new FileReader(chooser.getSelectedFile().getAbsolutePath()));
                line=brr.readLine();
                str=line;
                while((line=brr.readLine())!=null)
                {
                    str+="\n";
                    str+=line;
                }
                brr.close();
                txtinare.setText(str);
            } catch (Exception ex)
            {
                System.out.println(ex.getMessage());
            }
       }
       if(e.getSource()==all)
       {
           txtinare.selectAll();
       }
       if(e.getSource()==clear)
       {
           txtinare.setText("");
       }
       if(e.getSource()==cut)
       {
           txtinare.cut();
       }
       if(e.getSource()==copy)
       {
           txtinare.copy();
       }
       if(e.getSource()==parse)
       {
           txtinare.paste();
       }
       if(e.getSource()==execute||e.getSource()==btnexecute)
       {
           if (!txtinare.getText().equals(""))
           {
               String sub = txtinare.getText().substring(0, 6);
               System.out.println(sub);
               //查询数据
               if (sub.toLowerCase().compareTo("select") == 0) {
                   System.out.println("aaa");
                   String result = "\n";
                   try {
                       ResultSet rs = conn.stmt.executeQuery(txtinare.getText());
                       ResultSetMetaData rsmd = rs.getMetaData();
                       for (int i = 1; i <= rsmd.getColumnCount(); i++) {
                           result += rsmd.getColumnName(i) + "\t";
                       }
                       result += "\n";
                       int m = result.length();
                       for (int i = 0; i < m+m/2; i++) {
                           result += "—";
                       }
                       result += "\n";
                       while (rs.next()) {
                           for (int i = 1; i <= rsmd.getColumnCount(); i++) {
                               result += rs.getString(i) + "\t";
                           }
                           result += "\n";
                       }
                       txtoutare.append(result);
                   } catch (Exception ex) {
                       txtoutare.append("\n" + ex.getMessage());
                   }
               }
               //创建
               else if(txtinare.getText().substring(0, 6).toLowerCase().compareTo("create") == 0)
               {
                   Create create=new Create(txtinare.getText(),conn);
                   String result=create.createMethod();
                   txtoutare.append(result);
               }
                 //System.out.println(txtinare.getText().substring(0, 4));
                 //查询表结构
              else if(txtinare.getText().substring(0, 4).toLowerCase().compareTo("desc") == 0)
               {
                   int length=txtinare.getText().length();
                   String result = "\n";
                   try {
                       ResultSet rs = conn.stmt.executeQuery("select * from "+txtinare.getText().substring(5,length).toLowerCase());
                       System.out.println(txtinare.getText().substring(0, 4));
                       ResultSetMetaData rsmd = rs.getMetaData();
                       result+="列名"+"\t"+"数据类型"+"\n";
                       result+="--------------------------------------------------------"+"\n";
                       for (int i = 1; i <= rsmd.getColumnCount(); i++) {
                           result += rsmd.getColumnName(i) + "\t"+rsmd.getColumnTypeName(i)+"\n";
                       }
                       result += "\n";
                       txtoutare.append(result);
                   } catch (Exception ex) {
                       txtoutare.append("\n" + ex.getMessage());
                   }

               }
               //删除
               else if(txtinare.getText().substring(0, 4).toLowerCase().compareTo("drop") == 0)
               {
                   System.out.println(txtinare.getText().substring(0, 4));
                   Drop drop=new Drop(txtinare.getText(),conn);
                   String result=drop.dropMethod();
                   txtoutare.append(result);
               }
               //授权
               else if(txtinare.getText().substring(0, 5).toLowerCase().compareTo("grant") == 0)
               {
                   try
                   {
                       conn.stmt.executeUpdate(txtinare.getText());
                       txtoutare.append("\n" + "授权成功");
                   }
                   catch(Exception ex)
                   {
                       txtoutare.append("\n" + ex.getMessage());
                   }
               }
               //撤销
               else if(txtinare.getText().substring(0, 6).toLowerCase().compareTo("revoke") == 0)
               {
                   try
                   {
                       conn.stmt.executeUpdate(txtinare.getText());
                       txtoutare.append("\n" + "撤销成功");
                   }
                   catch(Exception ex)
                   {
                       txtoutare.append("\n" + ex.getMessage());
                   }
               }
               else if(txtinare.getText().substring(0, 4).toLowerCase().compareTo("show") == 0)
               {
                   txtoutare.append("\n当前用户"+"'"+log.getUsername()+"'");
               }
               else if(txtinare.getText().substring(0, 5).toLowerCase().compareTo("alter") == 0)
               {
                   try
                   {
                       conn.stmt.executeUpdate(txtinare.getText());
                       txtoutare.append("\n" + "已修改");
                   }
                   catch(Exception ex)
                   {
                       txtoutare.append("\n" + ex.getMessage());
                   }
               }
               else
               {
                   try
                  {
                      conn.stmt.executeUpdate(txtinare.getText());
                      int row=conn.stmt.getUpdateCount();
                      txtoutare.append("\n" + row+"行受到影响");
                  }
                  catch(Exception ex)
                  {
                      txtoutare.append("\n" + ex.getMessage());
                  }

               }
           }
       }
    }
   /* public static void main(String[] args)
    {
        MainFrame mainframe = new MainFrame();
    }*/
}