Servlet – CRUD 操作示例

在Web应用程序中，CRUD（创建，读取，更新，删除）是常见的数据操作，用于管理和操作数据库中的记录。本文将介绍如何使用Java Servlet来实现基本的CRUD操作示例。

准备工作

在开始之前，首先确保你已经正确设置了Java开发环境，包括Java SDK、Eclipse（或其他Java开发工具）和Tomcat（或其他Java Web服务器）。同时，你需要熟悉Java Servlet和基本的数据库操作知识。

创建数据库表

首先，创建一个数据库表来存储我们的示例数据。假设我们要创建一个名为"users"的表，包含以下字段：

• id: 用户ID，主键
• name: 用户名
• email: 用户邮箱

具体的数据库创建语句如下：

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

请根据自己的数据库类型和需求进行相应的调整。

创建Servlet

接下来，创建一个名为"UserServlet"的Servlet类，用于处理用户的CRUD操作。

@WebServlet("/users/*")
public class UserServlet extends HttpServlet {

    private UserDao userDao;

    @Override
    public void init() throws ServletException {
        userDao = new UserDao(); // 初始化UserDao实例
    }

    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String pathInfo = request.getPathInfo();
        if (pathInfo == null || pathInfo.equals("/")) {
            createUser(request, response);
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String pathInfo = request.getPathInfo();
        if (pathInfo == null || pathInfo.equals("/")) {
            listUsers(request, response);
        } else {
            getUser(request, response, pathInfo);
        }
    }

    @Override
    protected void doPut(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String pathInfo = request.getPathInfo();
        if (pathInfo != null && !pathInfo.equals("/")) {
            updateUser(request, response, pathInfo);
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }

    @Override
    protected void doDelete(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String pathInfo = request.getPathInfo();
        if (pathInfo != null && !pathInfo.equals("/")) {
            deleteUser(request, response, pathInfo);
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }

    private void createUser(HttpServletRequest request, HttpServletResponse response) throws IOException {
        String name = request.getParameter("name");
        String email = request.getParameter("email");
        // 创建新用户记录
        User user = userDao.create(new User(name, email));
        // 返回用户ID
        response.getWriter().print(user.getId());
    }

    private void listUsers(HttpServletRequest request, HttpServletResponse response) throws IOException {
        // 获取所有用户记录
        List<User> users = userDao.getAll();
        // 将用户记录转换为JSON格式并返回
        response.setContentType("application/json");
        response.getWriter().print(new Gson().toJson(users));
    }

    private void getUser(HttpServletRequest request, HttpServletResponse response, String pathInfo) throws IOException {
        // 解析路径中的用户ID
        String userId = pathInfo.substring(1);
        // 获取指定用户记录
        User user = userDao.get(Integer.parseInt(userId));
        if (user != null) {
            // 将用户记录转换为JSON格式并返回
            response.setContentType("application/json");
            response.getWriter().print(new Gson().toJson(user));
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }

    private void updateUser(HttpServletRequest request, HttpServletResponse response, String pathInfo) throws IOException {
        // 解析路径中的用户ID
        String userId = pathInfo.substring(1);
        // 获取更新后的用户信息
        String name = request.getParameter("name");
        String email = request.getParameter("email");
        // 更新指定用户记录
        User user = userDao.update(Integer.parseInt(userId), new User(name, email));
        if (user != null) {
            response.getWriter().print("Update successful!");
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }

    private void deleteUser(HttpServletRequest request, HttpServletResponse response, String pathInfo) throws IOException {
        // 解析路径中的用户ID
        String userId = pathInfo.substring(1);
        // 删除指定用户记录
        boolean result = userDao.delete(Integer.parseInt(userId));
        if (result) {
            response.getWriter().print("Delete successful!");
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }
}

创建DAO类

为了与数据库进行交互，我们需要创建一个数据访问对象（DAO）类来执行相应的数据库操作。在这个例子中，我们创建了一个名为"UserDao"的DAO类。

public class UserDao {

    private Connection connection;

    public UserDao() {
        // 初始化数据库连接
        // ...
    }

    public User create(User user) {
        // 创建新用户记录
        // ...
        return user;
    }

    public List<User> getAll() {
        // 获取所有用户记录
        // ...
        return users;
    }

    public User get(int id) {
        // 获取指定用户记录
        // ...
        return user;
    }

    public User update(int id, User user) {
        // 更新指定用户记录
        // ...
        return user;
    }

    public boolean delete(int id) {
        // 删除指定用户记录
        // ...
        return true or false;
    }
}

请根据自己使用的数据库类型和JDBC驱动进行相应的调整。

配置Web.xml

最后，在Web应用程序的web.xml文件中配置Servlet，并指定相应的URL映射。具体的配置示例如下：

<web-app>
    <servlet>
        <servlet-name>UserServlet</servlet-name>
        <servlet-class>com.example.UserServlet</servlet-class>
    </servlet>
    <servlet-mapping>
        <servlet-name>UserServlet</servlet-name>
        <url-pattern>/users/*</url-pattern>
    </servlet-mapping>
</web-app>

运行示例

完成上述步骤后，重新启动Web服务器，并访问http://localhost:8080/your-web-app/users即可查看所有用户记录。你可以使用工具（如Postman）测试各种CRUD操作，例如：

• 创建用户（POST请求）: http://localhost:8080/your-web-app/users, 参数为name和email。
• 获取所有用户（GET请求）: http://localhost:8080/your-web-app/users.
• 获取指定用户（GET请求）: http://localhost:8080/your-web-app/users/{userId}, 其中{userId}为用户ID。
• 更新指定用户（PUT请求）: http://localhost:8080/your-web-app/users/{userId}, 其中{userId}为用户ID，参数为name和email。
• 删除指定用户（DELETE请求）: http://localhost:8080/your-web-app/users/{userId}, 其中{userId}为用户ID。

以上就是一个使用Java Servlet实现CRUD操作的示例。你可以根据实际的需求进行修改和扩展。