JavaWeb数据库连接的操作实例分析

在现代Web应用开发中，数据库连接是不可或缺的一部分。JavaWeb应用通常通过JDBC（Java Database Connectivity）技术与数据库进行交互。本文将通过一个实例，详细分析如何在JavaWeb项目中实现数据库连接，并进行基本的增删改查操作。

1. 环境准备

在开始之前，我们需要准备以下环境：

• JDK：确保已安装JDK，并配置好环境变量。
• IDE：推荐使用IntelliJ IDEA或Eclipse。
• 数据库：本文以MySQL为例，确保已安装MySQL数据库，并创建好相应的数据库和表。
• Web服务器：推荐使用Tomcat。

2. 创建数据库

首先，我们需要在MySQL中创建一个数据库和一张表。假设我们创建一个名为testdb的数据库，并在其中创建一张users表。

CREATE DATABASE testdb;

USE testdb;

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50) NOT NULL,
    password VARCHAR(50) NOT NULL,
    email VARCHAR(100)
);

3. 创建JavaWeb项目

在IDE中创建一个新的JavaWeb项目，并添加必要的依赖。如果使用Maven管理项目，可以在pom.xml中添加以下依赖：

<dependencies>
    <!-- MySQL Connector -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>
    <!-- Servlet API -->
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>javax.servlet-api</artifactId>
        <version>4.0.1</version>
        <scope>provided</scope>
    </dependency>
</dependencies>

4. 配置数据库连接

在JavaWeb项目中，通常会将数据库连接信息配置在web.xml或一个单独的配置文件中。为了简化，我们直接在代码中配置数据库连接信息。

public class DBUtil {
    private static final String URL = "jdbc:mysql://localhost:3306/testdb";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}

5. 实现增删改查操作

接下来，我们实现一个简单的UserDAO类，用于对users表进行增删改查操作。

5.1 插入数据

public class UserDAO {
    public void insertUser(User user) {
        String sql = "INSERT INTO users (username, password, email) VALUES (?, ?, ?)";
        try (Connection conn = DBUtil.getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setString(1, user.getUsername());
            pstmt.setString(2, user.getPassword());
            pstmt.setString(3, user.getEmail());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5.2 查询数据

public class UserDAO {
    public User getUserById(int id) {
        String sql = "SELECT * FROM users WHERE id = ?";
        User user = null;
        try (Connection conn = DBUtil.getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, id);
            ResultSet rs = pstmt.executeQuery();
            if (rs.next()) {
                user = new User();
                user.setId(rs.getInt("id"));
                user.setUsername(rs.getString("username"));
                user.setPassword(rs.getString("password"));
                user.setEmail(rs.getString("email"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return user;
    }
}

5.3 更新数据

public class UserDAO {
    public void updateUser(User user) {
        String sql = "UPDATE users SET username = ?, password = ?, email = ? WHERE id = ?";
        try (Connection conn = DBUtil.getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setString(1, user.getUsername());
            pstmt.setString(2, user.getPassword());
            pstmt.setString(3, user.getEmail());
            pstmt.setInt(4, user.getId());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5.4 删除数据

public class UserDAO {
    public void deleteUser(int id) {
        String sql = "DELETE FROM users WHERE id = ?";
        try (Connection conn = DBUtil.getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, id);
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

6. 创建Servlet处理请求

为了在Web应用中调用上述DAO方法，我们需要创建一个Servlet来处理HTTP请求。

@WebServlet("/user")
public class UserServlet extends HttpServlet {
    private UserDAO userDAO = new UserDAO();

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        String action = req.getParameter("action");
        if ("insert".equals(action)) {
            User user = new User();
            user.setUsername(req.getParameter("username"));
            user.setPassword(req.getParameter("password"));
            user.setEmail(req.getParameter("email"));
            userDAO.insertUser(user);
        } else if ("update".equals(action)) {
            User user = new User();
            user.setId(Integer.parseInt(req.getParameter("id")));
            user.setUsername(req.getParameter("username"));
            user.setPassword(req.getParameter("password"));
            user.setEmail(req.getParameter("email"));
            userDAO.updateUser(user);
        } else if ("delete".equals(action)) {
            int id = Integer.parseInt(req.getParameter("id"));
            userDAO.deleteUser(id);
        }
        resp.sendRedirect("index.jsp");
    }
}

7. 创建JSP页面

最后，我们创建一个简单的JSP页面来展示用户数据，并提供表单用于添加、更新和删除用户。

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>User Management</title>
</head>
<body>
    <h1>User List</h1>
    <table border="1">
        <tr>
            <th>ID</th>
            <th>Username</th>
            <th>Password</th>
            <th>Email</th>
            <th>Action</th>
        </tr>
        <c:forEach var="user" items="${userList}">
            <tr>
                <td>${user.id}</td>
                <td>${user.username}</td>
                <td>${user.password}</td>
                <td>${user.email}</td>
                <td>
                    <a href="edit.jsp?id=${user.id}">Edit</a>
                    <a href="user?action=delete&id=${user.id}">Delete</a>
                </td>
            </tr>
        </c:forEach>
    </table>
    <h2>Add User</h2>
    <form action="user" method="post">
        <input type="hidden" name="action" value="insert">
        Username: <input type="text" name="username"><br>
        Password: <input type="password" name="password"><br>
        Email: <input type="text" name="email"><br>
        <input type="submit" value="Add">
    </form>
</body>
</html>

8. 总结

通过以上步骤，我们实现了一个简单的JavaWeb应用，能够通过JDBC与MySQL数据库进行连接，并完成基本的增删改查操作。在实际开发中，我们还可以进一步优化代码结构，使用连接池技术提高性能，以及引入ORM框架简化数据库操作。

希望本文能帮助你理解JavaWeb中数据库连接的基本操作，并为你的项目开发提供参考。