메서드에 연결 풀 개체 전달

Question

연결 풀 개체를 ScheduledExecutorService 스레드로 전달해야하지만 그렇게하는 데 어려움이 있습니다. 선언 앞에 final을 추가하려고 시도했지만 다음 오류가 발생합니다 ... 최종 로컬 변수 연결을 할당 할 수 없습니다. 비어 있어야하며 복합 할당을 사용하지 않아야합니다.

어떻게이 연결 개체를 올바르게 전달할 수 있습니까?

public class AdminManager extends JFrame { 

    private JPanel contentPane; 
    private JTable tableQueue; 
    private JTable tableFilled; 

    /** 
    * Launch the application. 
    * @throws InterruptedException 
    */ 

    public static void main(String[] args) throws InterruptedException { 
     EventQueue.invokeLater(new Runnable() { 
      @Override 
      public void run() { 
       try { 
        AdminManager frame = new AdminManager(); 
        frame.setVisible(true); 
       } catch (Exception e) { 
        e.printStackTrace(); 
       } 

      } 
     }); 

     BoneCP connectionPool = null; 
     Connection connection = null; 

     try { 
      // load the database driver (make sure this is in your classpath!) 
      Class.forName("com.mysql.jdbc.Driver"); 
     } catch (Exception e) { 
      e.printStackTrace(); 
      return; 
     } 

     try { 
      // setup the connection pool 
      BoneCPConfig config = new BoneCPConfig(); 
      config.setJdbcUrl("jdbc:mysql://192.0.0.1:3306/db"); // jdbc url specific to your database, eg jdbc:mysql://127.0.0.1/yourdb 
      config.setUsername("root"); 
      config.setPassword(""); 
      connectionPool = new BoneCP(config); // setup the connection pool 

      connection = connectionPool.getConnection(); // fetch a connection 

      if (connection != null){ 
       System.out.println("Connection successful!"); 
      } 

     } catch (SQLException e) { 
      e.printStackTrace(); 
     } finally { 
      if (connection != null) { 
       try { 
        connection.close(); 
       } catch (SQLException e) { 
        e.printStackTrace(); 
       } 
      } 
     }   
ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor(); 
     exec.scheduleAtFixedRate(new Runnable(){ 
      @Override 
      public void run(){ 
       System.out.println("Working ... "); 
       String sql = "SELECT * FROM table;"; 
       Statement st; 
       try { 
        st = connection.createStatement(); 
        ResultSet rs = st.executeQuery(sql); 
       } catch (SQLException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 


      } 
     }, 2000, 1000, TimeUnit.MILLISECONDS); 

Answer 1

에서만 집행 내부에 사용되는 더미 참조를 정의 할 수 있습니다 :

문제가 이런 식으로 (코드의 나머지 부분을 볼 수 없습니다)를 해결하지 못할 경우,이 수

final Connection conn = connection; 

ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor(); 
    exec.scheduleAtFixedRate(new Runnable(){ 
     @Override 
     public void run(){ 
      System.out.println("Working ... "); 
      String sql = "SELECT * FROM table;"; 
      Statement st; 
      try { 
       st = conn.createStatement(); 
       ResultSet rs = st.executeQuery(sql); 
      } catch (SQLException e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 
     } 
    }, 2000, 1000, TimeUnit.MILLISECONDS); 

class ThreadTask implements Runnable { 
    private Connection connection; 

    public ThreadTask(Connection c) { 
      connection = c; 
    } 

    @Override 
    public void run() { 
     System.out.println("Working ... "); 
     String sql = "SELECT * FROM table;"; 
     Statement st; 
     try { 
      st = connection.createStatement(); 
      ResultSet rs = st.executeQuery(sql); 
     } catch (SQLException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 
} 

그리고 :

ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor(); 
exec.scheduleAtFixedRate(new ThreadTask(connection)); 

코드를 유지하기 위해 외부 작업 클래스를 정의