连接关闭错误 - MySQL 、 JDBC 和 Hikaricp

Question

已经使用 Hikari 连接池实现了 DAO 模式充分利用了 DAO 设计模式。已创建单例 class 其中 returns 具有 public 连接的 class 的对象如果单例 class 的对象为 NULL> 从而再次创建对象获得连接调用单例class 的静态方法以获得public 连接和准备语句的查询在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;
        
    }
    
    
    }  

}

Answer 1

目前您一直在使用 .conn

返回相同的连接

从 DatabaseConnection 中删除 conn 并添加一个不同的方法，每次从 Hikari 数据源获取连接

这样 Hikari 将处理连接池

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

并单独打开连接资源，以便将其关闭：

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

Answer 2

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();
}

}

连接关闭错误 - MySQL 、 JDBC 和 Hikaricp

Connection closed error - MySQL , JDBC and Hikaricp

java

mysql

connection-pooling

jdbc

hikaricp