使用数据连接池进行数据库操作

一般而言，使用Java访问MySQL的方法如下。

public Connection connect() throws SQLException{
   
try{
   
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection conn=DriverManager.getConnection(url,user,password);
        stmt=conn.createPreparedStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
return conn;
    }catch(ClassNotFoundException e){
   
        System.out.println("JDBC Driver not found:"+e.getMessage());
    }catch(SQLException e){
   
        System.out.println("Database connection failed:"+e.getMessage());
    }
return null;
}

public void disconnect(Connection conn){
   
try{
   
if(conn!=null){
   
            conn.close();
        }
    }catch(Exception e){
   
        System.out.println(e.getMessage());
    }
}

public void closeStmt(PreparedStatement stmt){
   
try{
   
if(stmt!=null){
   
            stmt.close();
        }
    }catch(Exception e){
   
        System.out.println(e.getMessage());
    }
}

public void closeRS(ResultSet rs){
   
try{
   
if(rs!=null){
   
            rs.close();
        }
    }catch(Exception e){
   
        System.out.println(e.getMessage());
    }
}


//用户登录时验证数据库中是否存在该用户及其密码是否正确
public String login(Connection conn,User user)throws SQLException{
   
    String username=user.getUsername();
    String password=user.getPassword();
    PreparedStatement stmt=null;
    ResultSet rs=null;
try{
   
        String queryString="SELECT * FROM user WHERE username=? AND password=?";
        stmt=conn.preparePreparedStatement(queryString);
        stmt.setString(1,username);
        stmt.setString(2,password);
        rs=stmt.executeQuery();        
if(!rs.next()){
   
return "0";
        }else{
   
return "1";
        }
    }catch(SQLException e){
   
        Sysyem.out.println(e.getMessage());
    }finally{
   
try{
   
            closeRS(ResultSet rs);
            closeStmt(PreparedStatement stmt);
        }catch(SQLException e){
   
            Sysyem.out.println(e.getMessage());
        }
    }
return "-1";
}

Connection connect()用于建立数据库连接

void disconnect(Connection conn)用于断开数据库连接

void closeStmt(PreparedStatement stmt)用于关闭PreparedStatement

void closeRS(ResultSet rs)用于关闭ResultSet

程序使用完毕必须关闭Connection、PreparedStatement和ResultSet，否者会造成内存溢出。并且关闭顺序必须是先关闭ResultSet，接下来是PreparedStatement，最后是Connection。Java建议使用数据库连接池来对数据库操作，它的好处可以在网上查到。这里我们使用HikariCP。使用数据库连接词，必须先配置pom.xml

<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<version>5.0.1</version><!--请根据需要选择最新版本-->
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.27</version><!--请根据需要选择适合的 JDBC 驱动-->
</dependency>
<!--SLF4J API-->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.36</version>
</dependency>
<!--Logback实现-->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.11</version>
</dependency>

配置HikariCP

你可以在Java代码中或者在配置文件（如application.properties或application.yml）中进行配置。以下是两种方式的示例。

Java代码配置示例。

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

public class DataSourceConfig{
   
private HikariDataSource dataSource;
public DataSourceConfig(){
   
        HikariConfig config=new HikariConfig();
        config.setJdbcUrl("jdbc:mysql://localhost:3306/your_database");//替换为你的数据库URL
        config.setUsername("your_username");//数据库账号
        config.setPassword("your_password");//数据库密码
        config.setDriverClassName("com.mysql.cj.jdbc.Driver");//JDBC 驱动类名

//HikariCP 相关配置
        config.setMaximumPoolSize(10);//最大连接数
        config.setMinimumIdle(2);//最小空闲连接数
        config.setIdleTimeout(30000);//空闲连接最大存活时间
        config.setConnectionTimeout(30000);//连接超时时间
        dataSource=new HikariDataSource(config);
    }
public HikariDataSource getDataSource(){
   
return dataSource;
    }
}

使用HikariCP连接数据库

private HikariDataSource dataSource;
public UserService(HikariDataSource dataSource){
   
this.dataSource=dataSource;
    }
public boolean deleteUser(String username){
   
String sql="DELETE FROM user WHERE username=?";
try(Connection connection=dataSource.getConnection();
            PreparedStatement ps=connection.preparePreparedStatement(sql)){
   
            ps.setString(1,username);
            int affectedRows=ps.executeUpdate();
return affectedRows==1;
        }catch(SQLException e){
   
            logger.error(e.getMessage());
return false;
        }
    }

public String login(Connection conn,User user)throws SQLException{
   
String queryString="SELECT * FROM user WHERE username=? AND password=?";
try{
   
Connection connection=dataSource.getConnection();
try{
   
PreparedStatement ps=connection.preparePreparedStatement(queryString);
            stmt=conn.preparePreparedStatement(queryString);
            stmt.setString(1,username);
            stmt.setString(2,password);
            rs=stmt.executeQuery();
if(!rs.next()){
   
return "0";
            }else{
   
return "1";
            }
        }
    }catch(SQLException e){
   
Sysyem.out.println(e.getMessage());
    }finally{
   
try{
   
closeRS(ResultSet rs);
closeStmt(PreparedStatement stmt);
        }catch(SQLException e){
   
Sysyem.out.println(e.getMessage());
        }
    }
return "-1";
}

关闭HikariCP

在应用程序关闭时，确保关闭Hikari连接池以释放资源。

dataSource.close();

可以将关闭连接池封装方法

//关闭连接池
public void closePool(HikariDataSource dataSource){
   
if(dataSource!=null){
   
        dataSource.close();
    }
}

接下来我们看看如何在程序中使用数据库连接池

private void validatePass(User user,String info,String username)throws SQLException,IOException{
   
    UserRepository mysql=new UserRepository();
    HikariDataSource dataSource=mysql.dataSource;
try{
   
if(mysql.login(user).equals("0")){
   
            …
        }else{
   
            …
        }
    }catch(Exception e){
   
        …;
    }finally{
   
        mysql.closePool(dataSource);
    }
}

数据库的配置与操作放在UserRepository类中，通过

HikariDataSource dataSource=mysql.dataSource;

获取dataSource,接下来调用对数据库的操作，比如这里mysql.login(user)，最后记得一定要在finally块中把dataSource关掉。

我们如果在程序中忘记关闭ResultSet、PreparedStatement、connection、HikariDataSource就会带来内存溢出。但是如果我们使用try-with-resources结构就可以在程序完毕，自动关闭这些对象。

// 登录
    public String login(User user) throws SQLException {
   
        String username = user.getUsername();
        String password = user.getPassword();
        String queryString = "SELECT COUNT(*) as sum FROM user WHERE username=? AND password=?";        
        try (Connection conn = dataSource.getConnection();
            PreparedStatement stmt = conn.preparePreparedStatement(queryString)) {
   
                stmt.setString(1, username);
                stmt.setString(2, password);
                try (ResultSet rs = stmt.executeQuery()) {
   
                    if (rs.next()) {
   
                        int result = rs.getInt("sum");
                        if (result == 0) {
   
                            logger.error("登录失败");
                            return "0";
                        } else {
   
                            logger.info("登录成功");
                            return "1";
                        }
                    }
                }
            } catch (SQLException e) {
   
                logger.error("login(User user) 发生数据库错误: " + e.getMessage());
            }
        return "-1";
    }

这里

try (Connection conn = dataSource.getConnection();
            PreparedStatement stmt = conn.preparePreparedStatement(queryString)) {
   
                stmt.setString(1, username);
                stmt.setString(2, password);
                try (ResultSet rs = stmt.executeQuery()) {
   

                }//这里自动关闭ResultSet rs
}//这里自动关闭PreparedStatement和Connection。

调用的时候

UserRepository mysql = new UserRepository();
try(HikariDataSource dataSource = mysql.dataSource) {
   
            …
        } catch (Exception e) {
   
            …
        }//这里自动关闭HikariDataSource dataSource

顾翔凡言：人工智能未来的发展瓶颈在于对知识的更新。唯一不变的是变化，知识发生了变化，人工智能软件能否及时跟进变化，可能阻碍人工智能的使用。