java数据库开发之JDBC的完整封装兼容多种数据库

Java作为一种流行的编程语言，在数据库开发中也日益受到重视。它提供了一种被广泛使用的面向关系型数据库开发的API -- JDBC。JDBC提供了一种标准的接口，使得Java开发人员可以使用Java语言轻松地操作各种关系型数据库。

然而，使用标准的JDBC API进行数据库开发也有它的缺陷。首先，JDBC的API较为复杂，需要程序员编写大量的重复性代码。此外，JDBC也并不总是与所有数据库兼容。

为了解决这些问题，可以采用一种JDBC的封装来简化开发，使其更易于使用，同时保持多种数据库的兼容性。下面是一些实现JDBC完整封装的步骤，以及示例代码。

步骤1：创建数据库连接池

JDBC完整封装应该包括数据库连接池，以便在应用程序需要访问数据库时快速获取连接。下面是使用Apache Commons DBCP创建数据库连接池的示例代码：

import org.apache.commons.dbcp2.BasicDataSource;

public class DBConnectionPool {
    private static BasicDataSource dataSource;

    public static BasicDataSource getDataSource() {
        if (dataSource == null) {
            dataSource = new BasicDataSource();
            dataSource.setDriverClassName("com.mysql.jdbc.Driver");
            dataSource.setUrl("jdbc:mysql://localhost:3306/test");
            dataSource.setUsername("root");
            dataSource.setPassword("root");
        }
        return dataSource;
    }
}

步骤2：创建封装的JDBC操作类

在封装JDBC时，创建一个遵循特定接口的JDBC操作类，以封装所有与数据库相关的操作。在这个类中，应该提供所有通用的数据库操作，例如插入，查询和更新。

下面是一个封装了CRUD操作的JDBC操作类的示例：

public class JDBCOperation {
    private DataSource dataSource;
    private Connection connection;

    public JDBCOperation() {
        dataSource = DBConnectionPool.getDataSource();
    }

    public List<Map<String, Object>> query(String sql, Object[] params) {
        PreparedStatement statement = null;
        ResultSet resultSet = null;
        List<Map<String, Object>> result = new ArrayList<>();

        try {
            connection = dataSource.getConnection();
            statement = connection.prepareStatement(sql);
            if (params != null && params.length > 0) {
                for (int i = 0; i < params.length; i++) {
                    statement.setObject(i + 1, params[i]);
                }
            }
            resultSet = statement.executeQuery();
            ResultSetMetaData metaData = resultSet.getMetaData();
            int colCount = metaData.getColumnCount();
            while (resultSet.next()) {
                Map<String, Object> row = new HashMap<>();
                for (int i = 1; i <= colCount; i++) {
                    String colName = metaData.getColumnLabel(i);
                    Object colValue = resultSet.getObject(i);
                    row.put(colName, colValue);
                }
                result.add(row);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (resultSet != null) {
                    resultSet.close();
                }
                if (statement != null) {
                    statement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return result;
    }
    // insert, update and delete methods
}

示例1：使用MySQL数据库

下面是使用以上考虑的两个步骤封装了MySQL数据库的Java Web应用示例：

public class UserService {
    private JDBCOperation jdbcOperation;

    public UserService() {
        jdbcOperation = new JDBCOperation();
    }

    public boolean addUser(String username, String password) {
        String sql = "INSERT INTO user (username, password) VALUES (?, ?)";
        Object[] params = new Object[] {username, password};
        int rowsAffected = jdbcOperation.update(sql, params);
        return rowsAffected > 0;
    }

    public List<User> getUsers(int offset, int limit) {
        List<User> users = new ArrayList<>();
        String sql = "SELECT * FROM user LIMIT ?, ?";
        Object[] params = new Object[] {offset, limit};
        List<Map<String, Object>> result = jdbcOperation.query(sql, params);
        for (Map<String, Object> row : result) {
            User user = new User();
            user.setId((int) row.get("id"));
            user.setUsername((String) row.get("username"));
            user.setPassword((String) row.get("password"));
            users.add(user);
        }
        return users;
    }
}

示例2：使用Oracle数据库

如果要在上面的应用程序中使用Oracle数据库，只需在DBConnectionPool类中将数据库的URL更改为适当的值，并将驱动程序更改为适当的值，如下所示：

dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
dataSource.setUrl("jdbc:oracle:thin:@localhost:1521:ORCL");
dataSource.setUsername("username");
dataSource.setPassword("password");

当然，在创建表或其他数据库特定的操作时，您可能需要更改用户代码。