深入理解PreparedStatement

news2025/11/4 9:21:29

预处理

@Override
    public boolean login(String username, String userpwd) {

        Connection  con = DBUtils.getConnection();
        try {
            if(con != null)
            {
               PreparedStatement pstmt = con.prepareStatement("select username,userpwd from " +
                        " users where username=? and userpwd=?");
               pstmt.setString(1,username);
               pstmt.setString(2,userpwd);
               ResultSet rs = pstmt.executeQuery();
               if(rs.next())
               {
                   return  true;
               }
               else
               {
                   return  false;
               }
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
        return  false;
    }

分层

utils 工具类
entity/pojo 实体类/标准封装类
dao 数据库对象操作层
service 服务层
controller 业务控制层
在这里插入图片描述

JavaSE 项目

项目要求：

1、优化人事管理系统，要有完整的业务关系。
2、人事管理系统中要包含网络编程。
3、人事管理系统中要包含多线程。

连接池

数据库连接池负责分配、管理和释放数据库链接，它允许应用程序重复使用一个现有的数据库链接，而不是再重新建立一个；释放空闲时间超过最大空闲时间的数据库链接来避免因为没有释放数据库链接而引起的数据库链接遗漏。这项技术能明显提高对数据库操作的性能。

最小连接数:

是连接池一直保持的数据库链接数，所以如果应用程序对数据库链接的使用量不大，将会有大量的数据库链接资源被浪费，合理设置最小连接数，能够有效提高数据库链接性能。

最大连接数:

是连接池能申请的最大数据库连接数，如果数据库链接请求超过此数，后面的数据库链接请求将被加入到等待队列中，这会影响之后的数据库链接操作，因此合理设置最大连接数，也能够有效提高数据库链接性能。

最小连接数与最大连接数差距:

最小连接数与最大连接数相差太大，那么最先的链接请求将会获利，之后超过最小连接数量的链接请求等价于建立一个新的数据库链接，不过，这些大于最小连接数的数据库链接在使用完不会马上被释放，它将被放到连接池中等待重复使用或是空闲超时后被释放。

DBCP Apache 连接池
在这里插入图片描述

连接池配置文件内容如下:

driverClassName = com.mysql.cj.jdbc.Driver
url = jdbc:mysql://localhost:3306/wlx
username = root
password = 123456
#初始连接数
initialSize = 10
#最大链接数
maxActive = 100
#最小空闲数
minldle = 100
#最大空闲数
maxldle = 200

package com.wlx.day15.utils;

import org.apache.commons.dbcp.BasicDataSourceFactory;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

public class DBPoolUtils
{
    //链接数据库的数据源对象
    private  static DataSource  dataSource;

    //将链接存储在多线程中,一个链接一个线程
    private static  ThreadLocal<Connection>  threadLocal = new ThreadLocal<>();

    //数据库链接对象
    private  static  Connection con;


    static
    {
        try {
            Properties  source = new Properties();
            source.load(DBPoolUtils.class.getClassLoader().getResourceAsStream("db.properties"));
            //初始化数据源对象
            dataSource = BasicDataSourceFactory.createDataSource(source);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 一个链接一个线程
     * 一个线程一个事务
     * 一个事务一个业务
     * @return
     */
    public static  Connection getConnection()
    {
        try {
            //获取ThreadLocal中的数据库链接对象
            con = threadLocal.get();
            if(con == null)
            {
                con = dataSource.getConnection();
                threadLocal.set(con);
                return con;
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return con;
    }

}