Java 작업 데이터베이스 - 연결 풀을 사용하여 데이터베이스에 연결

전통적인 방법과 연결 풀링 방법

전통적인 방법의 단계

Java에서 JDBC를 사용하여 데이터베이스에 연결하고 데이터베이스 작업을 완료하는 일반적인 방법은 다음과 같습니다. :

1. 드라이버를 로드합니다.

2. 연결을 설정합니다.

3. SQL문을 실행합니다.

4. 연결을 해제하세요.

5. 기존 방법의 단점

데이터베이스의 모든 작업은 연결을 설정해야 하며 결과 연결 개체가 메모리에 로드되므로 많은 메모리와 시간이 소모됩니다. 짧은 시간 내에 연결을 수립해야 하는 작업이 많으면 시스템 자원을 많이 차지하게 되고, 심지어 서버 다운 현상도 발생하게 됩니다.

연결 설정에 따라 사용할 때마다 연결을 수동으로 해제해야 합니다. 연결 해제를 잊어버리거나 프로그램에서 예외로 인해 연결 해제에 실패하면 메모리 누수가 발생합니다.

또한 기존 방식으로는 연결 수를 제어할 수 없습니다. 너무 많은 사람이 연결되면 연결 개체가 무제한 생성되어 과도한 메모리 오버헤드와 서버 충돌이 발생합니다.

(추천 동영상: java 동영상 튜토리얼)

연결 풀 단계

1. 연결 풀을 생성하고 연결 속성을 구성합니다.

2. 연결 풀을 사용하여 연결을 얻으세요.

커넥션 풀의 장점

데이터베이스에 연결해야 할 때마다 연결을 설정할 필요가 없고 연결을 제공하는 연결 풀을 통해 연결을 얻습니다.

연결을 사용한 후 수동으로 연결을 해제할 필요는 없고 연결 풀에서 연결을 해제하도록 하세요.

연결 풀을 통해 연결 수를 제어할 수 있으므로 연결 풀의 연결을 여러 번 재사용할 수 있어 무제한 연결 생성 문제를 피할 수 있습니다.

연결 풀 사용

C3P0 데이터베이스 연결 풀 사용

jar 패키지 가져오기:

c3p0-0.9.5.2.jar

현재 프로젝트의 코드 루트 디렉터리 src 아래에 c3p0-config.xml이라는 새 구성 파일을 만듭니다. 내용은 다음과 같습니다.

<c3p0-config>
    <!-- 连接名称 -->
    <named-config name="mysql">
        <!-- 接数据库的驱动类名 -->
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <!-- 连接属性 -->
        <property name="jdbcUrl">jdbc:mysql://192.168.35.128:3306/demo</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <!-- 当连接池用完时等待获取新连接的时间，超时后将抛出SQLException，单位毫秒，如设为0则无限期等待。默认为0。 -->
        <property name="checkoutTimeout">5000</property>
        <!-- 当连接用尽后，一次获取的连接个数 -->
        <property name="acquireIncrement">2</property>
        <!-- 初始连接数 -->
        <property name="initialPoolSize">1</property>
        <!-- 最小连接数 -->
        <property name="minPoolSize">3</property>
        <!-- 最大连接数 -->
        <property name="maxPoolSize">5</property>
    </named-config>
</c3p0-config>

프로그램 코드:

public class TestDataPool {
    // 根据配置文件里的名称创建连接池
    public static ComboPooledDataSource cpds = new ComboPooledDataSource("mysql");
    
    /**
     * 主程序
     */
    public static void main(String[] args) {
        // 模拟多次对数据库的查询操作
        for (int i = 0; i < 6; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    select();
                }
            }, "线程" + i).start();
        }
    }
    
    /**
     * 查询程序
     */
    public static void select() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        // 获取连接并执行SQL
        try {
            conn = cpds.getConnection();
            pstmt = conn.prepareStatement("select * from student where id = 906");
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 释放资源
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

DBCP 데이터베이스 연결 풀 사용

jar 패키지 가져오기:

 commons-dbcp-1.4.jar2 commons-pool-1.5.5.jar

코드 루트 디렉터리에 "dbcp.properties"라는 새 구성 파일을 만듭니다. src" 파일명은 코드와 동일해야 합니다. 에 인용된 파일명은 일관되며 내용은 다음과 같습니다:

# 接数据库的驱动类名
driverClassName=com.mysql.jdbc.Driver
# 连接属性
url=jdbc:mysql://192.168.35.128:3306/demo
username=root
password=123456
# 初始化连接数
initialSize=10
# 最大连接数
maxActive=15

프로그램 코드:

public class TestDBCP {
    // 根据配置文件里的名称创建连接池
    private static DataSource source = null;
    static {
        Properties pros = new Properties();
        InputStream is = TestDBCP.class.getClassLoader().getResourceAsStream("dbcp.properties");
        try {
            pros.load(is);
            source = BasicDataSourceFactory.createDataSource(pros);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 主程序
     */
    public static void main(String[] args) {
        // 模拟多次对数据库的查询操作
        for (int i = 0; i < 6; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    select();
                }
            }, "线程" + i).start();
        }
    }

    /**
     * 查询程序
     */
    public static void select() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        // 获取连接并执行SQL
        try {
            conn = source.getConnection();
            pstmt = conn.prepareStatement("select * from student where id = 906");
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 释放资源
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

위 내용은 Java 작업 데이터베이스 - 연결 풀을 사용하여 데이터베이스에 연결의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!