java - JDBC を使用した Java - 接続が多すぎますか?

Question

最終年度のプロジェクトとして、バーの在庫補充システムを書いています。MYSQL データベースから情報を取得でき、一度に 1 つの結果をスクロールできます。

選択したカテゴリに応じて結果を変更しようとしています。コンボボックスを使用してこれを達成することができましたが、カテゴリ間を移動すると次のエラーが発生します。

スレッド「メイン」com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException での例外: データソースが接続の確立を拒否しました。サーバーからのメッセージ:「接続が多すぎます」

2 つの個別のファイルのコードは次のとおりです。

の SQL クエリRetrieveStockQuery

public JComboBox getComboBox() throws SQLException {
  con = SQLConnect.getConnection();
  combo = new JComboBox();
  combo.removeAllItems();
  try {
    stat = con.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE );
    rs = stat.executeQuery("SELECT categoryName FROM Category");

    while (rs.next()) {
      combo.addItem(rs.getString("categoryName"));
      categoryName = rs.getString("categoryName"); 
    }
  }
  catch (SQLException sqle) {
    System.out.println(sqle);
    stat.close();
    con.close();
  }
  return combo;
}

//----------------------------------------------------------------

public void retrieveStock() throws SQLException { 

  con = SQLConnect.getConnection();
  stockGUI = new ViewStockGUI(); // I THINK THIS IS WHAT IS CAUSING THE ERROR   

  String viewStock = "SELECT * FROM Stock where categoryName = '" + "'" + stockGUI.selected + "'";
  System.out.println(viewStock);

  try {
    stat = con.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE );
    rs = stat.executeQuery(viewStock);

    while(rs.next()){
      stockID = rs.getInt("stockID");
      stockName = rs.getString("stockName");
      stockDescription = rs.getString("stockDescription");
      stockPrice = rs.getFloat("stockPrice");
      stockQuantity = rs.getInt("stockQuantity");
      categoryName = rs.getString("categoryName");  

      ID = Integer.toString(stockID);
      price = Float.toString(stockPrice);
      quantity = Double.toString(stockQuantity);
      stat.close();
      con.close();

      System.out.println( "Stock ID: " + stockID + " Stock Name: " + stockName + " Stock Description: " + stockDescription + " Stock Price: " + stockPrice + " Stock Quantity:" + stockQuantity + " Category: " + categoryName);
    }    
  }  
  catch (SQLException err) {
    System.out.println(err.getMessage());   
  }
}

私ViewStockGUIのクラス

  public class ViewStockGUI extends JPanel {

    private static final long serialVersionUID = 1L;
    final JFrame viewFrame;
    ViewStockQuery stockQuery;
    ViewStockQuery stockName;
    JComboBox comboGUI;
    String selected;
    JComboBox combo;

    public ViewStockGUI() throws SQLException {

      final ViewStockQuery stock = new ViewStockQuery();

      comboGUI = stock.getComboBox();
      stock.retrieveStock();
      viewFrame = new JFrame("View Stock");

      JPanel p = new JPanel();
      p.setBorder (new TitledBorder(new LineBorder(Color.black, 1, true)));
      p.setPreferredSize(new Dimension(500,400));

      JPanel p2 = new JPanel();
      p2.setBorder (new TitledBorder(new LineBorder(Color.black, 1, true)));
      p2.setPreferredSize(new Dimension(500, 50));

      JPanel p3 = new JPanel();
      JPanel p4 = new JPanel();
      JPanel p5 = new JPanel();
      JPanel p6 = new JPanel();

      Box box = Box.createVerticalBox();        
      Box box2 = Box.createHorizontalBox();
      Box box3 = Box.createHorizontalBox();
      Box box4 = Box.createHorizontalBox();

      final JTextField textfieldStockName;
      final JTextField textfieldStockID;
      final JTextField textfieldStockDescription;
      final JTextField textfieldStockPrice;
      final JTextField textfieldStockQuantity;
      final JTextField textfieldStockCategory;

      final JLabel stockName = new JLabel("Name:");
      JLabel stockID = new JLabel("ID:");
      JLabel stockDescription = new JLabel("Description:");
      JLabel stockPrice = new JLabel("Price:");
      JLabel stockQuantity = new JLabel("Quantity:");
      JLabel categoryName = new JLabel("Category:");

      box.add(Box.createVerticalGlue());
      box.add(stockName);
      box.add(textfieldStockName = new JTextField(""));
      textfieldStockName.setText(stock.getStockName());
      textfieldStockName.setEditable(false);

      box.add(stockID);
      box.add(textfieldStockID = new JTextField(""));
      textfieldStockID.setText(stock.getStockID());
      textfieldStockID.setEditable(false);

      box.add(stockDescription);
      box.add(textfieldStockDescription = new JTextField(""));
      textfieldStockDescription.setText(stock.getStockDescription());
      textfieldStockDescription.setEditable(false);

      box.add(stockPrice);
      box.add(textfieldStockPrice = new JTextField(""));
      textfieldStockPrice.setText(stock.getStockPrice());
      textfieldStockPrice.setEditable(false);

      box.add(stockQuantity);
      box.add(textfieldStockQuantity = new JTextField(""));
      textfieldStockQuantity.setText(stock.getStockQuantity());
      textfieldStockQuantity.setEditable(false);

      box.add(categoryName);
      box.add(textfieldStockCategory = new JTextField(""));
      textfieldStockCategory.setText(stock.getStockCategory());
      textfieldStockCategory.setEditable(false);
      box.add(Box.createVerticalGlue());

      JButton next = new JButton("Next");
      next.addActionListener(new ActionListener() {
        public void actionPerformed(ActionEvent e) {
          stock.doNext();
          textfieldStockName.setText(stock.getStockName());
          textfieldStockID.setText(stock.getStockID());
          textfieldStockDescription.setText(stock.getStockDescription());
          textfieldStockPrice.setText(stock.getStockPrice());
          textfieldStockQuantity.setText(stock.getStockQuantity());
          textfieldStockCategory.setText(stock.getStockCategory());
        }
      }); 

      JButton previous = new JButton("Previous");
      previous.addActionListener(new ActionListener() {
        public void actionPerformed(ActionEvent e) {
          stock.doPrevious();
          textfieldStockName.setText(stock.getStockName());
          textfieldStockID.setText(stock.getStockID());
          textfieldStockDescription.setText(stock.getStockDescription());
          textfieldStockPrice.setText(stock.getStockPrice());
          textfieldStockQuantity.setText(stock.getStockQuantity());
          textfieldStockCategory.setText(stock.getStockCategory());
        }
      }); 

      final Counter counter = new Counter();
      final JLabel text = new JLabel(counter.getValue1());

      JButton plus = new JButton("+");
      plus.addActionListener(new ActionListener() {
        public void actionPerformed(ActionEvent e) {
          counter.increment();
          text.setText(counter.getValue1());
        }
      }); 

    JButton minus = new JButton("-");
    minus.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {
        counter.decrease();
        text.setText(counter.getValue1());
      }  
    });

    JButton update = new JButton("Update");
    update.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {
        try {
          stock.updateStock(counter.getValue1());
        } 
        catch (SQLException e1) {
          e1.printStackTrace();
        }
        finally { // doesn't update yet; will work on this later
          textfieldStockQuantity.setText(stock.getStockQuantity());
        }
      }
    }); 

    comboGUI.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {
        try {
          combo = (JComboBox) e.getSource();
          selected = (String)combo.getSelectedItem();
          textfieldStockName.setText(stock.getStockName());
          textfieldStockID.setText(stock.getStockID());
          textfieldStockDescription.setText(stock.getStockDescription());
          textfieldStockPrice.setText(stock.getStockPrice());
          textfieldStockQuantity.setText(stock.getStockQuantity());
          textfieldStockCategory.setText(stock.getStockCategory());
          stockQuery.con.close();
        }
        catch (SQLException e1) {
          e1.printStackTrace();
        }
      }
    }); 


    box.add(comboGUI);      
    box2.add(previous);
    box2.add(next);
    box3.add(minus);
    box3.add(text);
    box3.add(plus);
    box4.add(update);

    p.add(box2);
    p.add(box);
    p.add(box3);
    p.add(box4);

    this.add(p, BorderLayout.SOUTH);
  }
}

誰かが助けてくれれば幸いです。

score 7 · Accepted Answer

開いている接続が多すぎると、この例外が発生します。
これは構成可能ですが、あなたの場合、問題はコードにあります。

あなたが投稿したコードは（少なくとも）奇妙です。
を取得しない限り接続を閉じないかSQLException、結果セットの処理中に接続を閉じます!

いずれにせよ、終了したらすぐに接続や結果セットなどを閉じるようにコードをリファクタリングする必要があります。
例：

try { 

     stat = con.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE ); 
     rs = stat.executeQuery("SELECT categoryName FROM Category"); 

  while (rs.next()) { 
      combo.addItem(rs.getString("categoryName")); 
      categoryName = rs.getString("categoryName");  


  } 
} catch (SQLException sqle) { 
  System.out.println(sqle);   
} 
finally{
 if(stat != null) stat.close(); 
 if(con != null)  con.close(); 
}

close を a に入れることfinallyで、正しいフローまたは例外で接続が確実に閉じられます (try-catchわかりやすくするために省略しています)。

したがって、このようにコードを変更して接続を閉じます。

パフォーマンスを向上させるには、接続プーリングを検討する必要があります

score 1 · Accepted Answer

あなたのコードに問題があると思います。あなたのコードは非常に奇妙ですが、これが私が思っていることです：

あなたのViewStockQueryクラスには、retrieveStock()メソッドがあります。このメソッドは、GUI クラスのインスタンスを作成しますViewStockGUI。これが悪い習慣であることは別として、この行のメソッドでViewStockGUI呼び出したのコンストラクターで、ここで問題が発生します。retrieveStock()

stockGUI = new ViewStockGUI();

retrieveStock()次に、次の行で再度呼び出します。

final ViewStockQuery stock = new ViewStockQuery();

comboGUI = stock.getComboBox();
stock.retrieveStock();

ViewStockGUI()これは、コンストラクターがretrieveStock()接続を作成するメソッドを呼び出し、ViewStockGUI()コンストラクターを再度呼び出してretrieveStock()、接続を閉じていないメソッドを再度呼び出し、別の接続を開こうとするため、再帰的な問題につながります。あなたが絵を手に入れることを願っています。

それを解決する方法は、コードをクリーンアップすることです。でコンストラクターを呼び出さないでくださいretrieveStock()。選択したカテゴリをクエリに渡す別の方法を見つけてください。

編集：

あなたViewStockQueryのように書いてください：

private String mSelected;

public ViewStockQuery(String selectedCategory) {
    mSelected = selectedCategory;
}

...

public void retrieveStock() throws SQLException { 

    con = SQLConnect.getConnection();


    String viewStock = "SELECT * FROM Stock where categoryName = '" + "'" + mSelected + "'";
    System.out.println(viewStock);


     try {
...

次にViewStockGUI、カテゴリが選択されたとき、つまりを作成ViewStockQueryして選択した文字列を渡すように your を記述します。

編集：

前に言ったように、最終的にコードを変更しなければならないことがたくさんあります。しかし、この号の目的のために、あなたができることはあなたので、次ViewStockGUIのことです:

String selected = (String)combo.getSelectedItem();
final ViewStockQuery stock = new ViewStockQuery(selected);

最初の行は、選択したカテゴリをコンボボックスから収集し、2 行目は、選択したカテゴリのインスタンスを作成ViewStockQueryしてコンストラクタに渡します。これにより、上記の for コンストラクターで見られるように、mSelected が初期化されますViewStockQuery。

score 0 · Accepted Answer

(JPA ではなく) JDBC を使用する場合は、Spring のJdbcTemplateまたは Java SE 7 の自動リソース管理 (ARM) を使用することをお勧めします (ARM で JDBC をまだ試していませんが、動作するはずです。 )

基本的に、try-catch 句の finally ブロックで Closeable を閉じる必要があります。

java - JDBC を使用した Java - 接続が多すぎますか?

3 に答える 3

Related

Reference