Java使用C3P0数据源链接数据库

使用C3P0数据源链接数据库是Java编程中常见的一个任务，下面我们来详细讲解如何完成这个任务。

安装C3P0

首先，为了使用C3P0数据源链接数据库，我们需要在项目中添加C3P0的jar包，具体步骤如下：

1. 在 Maven 项目中，在 pom.xml 中添加以下依赖：

<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.5.5</version>
</dependency>

如果你不使用 Maven，可以自行从官网下载 jar 包并添加到项目中。

1. 将 C3P0 的配置文件添加到项目的 classpath 中。这个配置文件在 c3p0 的 jar 包中，文件名为 c3p0-config.xml。

配置C3P0

接下来，我们需要在项目的配置文件中对 C3P0 进行配置。我们主要配置以下内容：

1. 数据库连接信息：数据库类型、地址、端口、数据库名、用户名、密码等。
2. 连接池大小：最小连接数、最大连接数、增长步长等。
3. 连接有效性检查：连接超时时间、空闲时间、查询有效性等。

C3P0 的配置文件格式为 XML，以下是一个示例配置文件：

<c3p0-config xmlns="http://www.mchange.com/c3p0/config/1.0">
  <default-config>
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/testdb</property>
    <property name="user">testuser</property>
    <property name="password">testpass</property>
    <property name="initialPoolSize">5</property>
    <property name="minPoolSize">5</property>
    <property name="maxPoolSize">20</property>
    <property name="acquireIncrement">1</property>
    <property name="maxIdleTime">3600</property>
    <property name="testConnectionOnCheckin">true</property>
    <property name="testConnectionOnCheckout">true</property>
    <property name="preferredTestQuery">SELECT 1</property>
  </default-config>
</c3p0-config>

上述配置将使用 com.mysql.jdbc.Driver 驱动连接本地的 testdb 数据库，开始时使用 5 个连接，最小连接数和最大连接数都为 20，每次增加 1 个连接。连接空闲超过 1 小时将自动关闭，每次查询都会检查连接的有效性。

使用C3P0

好了，现在我们已经配置完了 C3P0，接下来就可以在代码中使用它了。以下是使用 C3P0 进行查询和更新的示例代码：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3P0Demo {
    private DataSource dataSource;

    public C3P0Demo() {
        dataSource = new ComboPooledDataSource("default-config");
    }

    public void query() throws SQLException {
        String sql = "SELECT * FROM users WHERE username=?";
        try (Connection conn = dataSource.getConnection();
             PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setString(1, "john");
            try (ResultSet rs = stmt.executeQuery()) {
                while (rs.next()) {
                    System.out.println(rs.getString("username") + " - " + rs.getString("email"));
                }
            }
        }
    }

    public void update() throws SQLException {
        String sql = "UPDATE users SET email=? WHERE username=?";
        try (Connection conn = dataSource.getConnection();
             PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setString(1, "[e-mail]");
            stmt.setString(2, "john");
            stmt.executeUpdate();
        }
    }
}

以上代码中，我们首先创建了一个 ComboPooledDataSource 对象，并以 "default-config" 作为参数传入，以使用我们在配置文件中定义的默认配置。然后我们分别实现了 query() 和 update() 方法，用于进行查询和更新。在内部我们使用了 try-with-resources 语句来确保资源会在使用后正确关闭。

现在你已经学会了如何使用 C3P0 在 Java 中连接数据库了，希望对你有所帮助！