Блог

Внедрили шаблон DAO с пулом соединений Hikari, наилучшим образом используя шаблон проектирования DAO. Создали одноэлементный класс, который возвращает объект класса с общедоступным подключением, если объект одноэлементного класса равен NULL> объект снова создается, тем самым заставляя запросы на подключение вызывать статический метод одноэлементного класса для получения общедоступного подключения, а подготовленные операторы закрываются в try-with-resources . приложение работает более 12 часов после нескольких запросов запросы не выполняются «Соединение закрыто».

 public class DatabaseConnection {

//Constants 

String url = "jdbc:mysql://localhost:3306/";
String driver="com.mysql.jdbc.Driver";
String userName = "root";
String password = "#";

private static HikariDataSource dataSource;

public Connection conn;
public static DatabaseConnection db;
/**
 * A static method which uses HikariDataSource Connection Pooling library to connect with the MySQL Database. 
 * Accepts and Sets few JDBC details like User Name,Password,URL,Driver Name and many more.
 * @return This methods returns HikariDataSource 
 * @throws SQLException and CasbnException
 */

public DatabaseConnection() throws SQLException,CasbnExceptions {
    
    try {
        
        //create the object of HikariDataSource
        dataSource=new HikariDataSource();
        
        //set up the JDBC details (username,password,url,driver)
        System.out.println("Inside DatabaseConnection constructor..");
        
        dataSource.setDriverClassName(driver);
        dataSource.setJdbcUrl(url);
        dataSource.setUsername(userName);
        dataSource.setPassword(password);
        
        this.conn=dataSource.getConnection();
        
        
    }
    catch(Exception e)
    {
        e.printStackTrace();
    }

}

public static  DatabaseConnection getCon() throws CasbnExceptions, SQLException
{
    if(db==null)
    {
        System.out.println("Inside getCon() and if block...");
        db=new DatabaseConnection();
    }
    
    
    return db;
}
}


 public class DAO_Implementation implements DAOFactory {


//Declare all the SQL queries as private static and final 

//getCompany query 
private static final String getCompanyName="SELECT company_name FROM #.company_register where email=?";


@Override
public String getCompanyName(String Email) throws SQLException {

    try
    (PreparedStatement pst = DatabaseConnection.getCon().conn
            .prepareStatement(getCompanyName)){

   pst.setString(1, Email);
    ResultSet rs = pst.executeQuery();
    
    
    rs.next();
    
    Name=rs.getString(1);
    

   }
    catch(Exception e)
    {
        e.printStackTrace();
    }
    return Name;
}
@Override
public Pojos Individual_Company_detail(String CompanyName) throws SQLException{

    try
    (PreparedStatement pst = DatabaseConnection.getCon().conn
            .prepareStatement(CompanyDetail);){
    pst.setString(1, CompanyName);
  
    ResultSet rs = pst.executeQuery();

    if(rs.next()==true)
    {
    Pojos Po=new Pojos();
    
    Po.setCompanyID(rs.getInt(1));
    Po.setUserCount(rs.getInt(2));
    Po.setPlan(rs.getString(3));
    Po.setDateofSub(rs.getString(4));
    Po.setSubscriptionID(rs.getString(5));
    Po.setVaildTill(rs.getString(6));
    
    
    
    return Po;
    
    }

    else
    {
        Pojos Po=new Pojos();
        Po.setErrorMessage(CompanyName  " Has not registered to of our Plan and no Recent Transactions");
       
        
        
        return Po;
        
    }
    
    
    }  

}
  

В настоящее время вы все время возвращаете одно и то же соединение, используя .conn

удалите conn из DatabaseConnection и добавьте другой метод, который каждый раз получает соединение из источника данных Hikari

Таким образом, Hikari будет обрабатывать пул соединений

 public static Connection getConnection() {
   return dataSource.getConnection();
}
  

И откройте ресурс соединения отдельно, чтобы он был закрыт:

  try 
(Connection conn = DatabaseConnection.getConnection();
    PreparedStatement pst = conn.prepareStatement(CompanyDetail))
  

 public class DatabaseConnection {
String url = "jdbc:mysql://localhost:3306/";
//String dbName = ""
String driver="com.mysql.jdbc.Driver";
String userName = "root";
String password = "";

private static HikariDataSource dataSource;

public static DatabaseConnection db;

public DatabaseConnection() throws SQLException,CasbnExceptions {
    
    try {
        
        //create the object of HikariDataSource
        dataSource=new HikariDataSource();
        
        //set up the JDBC details (username,password,url,driver)
        System.out.println("Inside DatabaseConnection constructor..");
        
        dataSource.setDriverClassName(driver);
        dataSource.setJdbcUrl(url);
        dataSource.setUsername(userName);
        dataSource.setPassword(password);
        
    
        
        
    }
    catch(Exception e)
    {
        e.printStackTrace();
    }

}

public static Connection getConnection() throws SQLException
{
    if(db==null)
    {
        db=new DatabaseConnection();
    }
    return dataSource.getConnection();
}
  

}