JavaWeb如何实现mysql数据库数据的添加和删除

发布时间：2022-03-19 13:36:50 作者：小新
来源：亿速云阅读：991

JavaWeb如何实现MySQL数据库数据的添加和删除

在JavaWeb开发中，操作MySQL数据库是常见的需求。本文将介绍如何使用JavaWeb技术实现MySQL数据库数据的添加和删除操作。我们将使用JDBC（Java Database Connectivity）来连接和操作MySQL数据库。

1. 环境准备

在开始之前，确保你已经安装了以下工具和环境：

JDK（Java Development Kit）
MySQL数据库
Tomcat服务器
IDE（如Eclipse或IntelliJ IDEA）

2. 创建数据库和表

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

CREATE DATABASE testdb;

USE testdb;

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

3. 配置JDBC连接

在JavaWeb项目中，我们需要配置JDBC连接来访问MySQL数据库。通常，我们会将数据库连接信息放在一个配置文件中，例如db.properties。

# db.properties
db.driver=com.mysql.cj.jdbc.Driver
db.url=jdbc:mysql://localhost:3306/testdb?useSSL=false&serverTimezone=UTC
db.username=root
db.password=yourpassword

4. 创建JDBC工具类

为了简化数据库操作，我们可以创建一个JDBC工具类DBUtil，用于加载数据库驱动、获取连接、关闭连接等操作。

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

public class DBUtil {
    private static String driver;
    private static String url;
    private static String username;
    private static String password;

    static {
        try {
            InputStream in = DBUtil.class.getClassLoader().getResourceAsStream("db.properties");
            Properties props = new Properties();
            props.load(in);

            driver = props.getProperty("db.driver");
            url = props.getProperty("db.url");
            username = props.getProperty("db.username");
            password = props.getProperty("db.password");

            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    public static void close(Connection conn) {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

5. 实现数据添加

接下来，我们实现一个Servlet来处理用户数据的添加操作。假设我们有一个表单用于输入用户信息，表单提交后将数据插入到users表中。

import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet("/addUser")
public class AddUserServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;

    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        String name = request.getParameter("name");
        String email = request.getParameter("email");

        Connection conn = null;
        PreparedStatement pstmt = null;

        try {
            conn = DBUtil.getConnection();
            String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, name);
            pstmt.setString(2, email);
            pstmt.executeUpdate();

            response.sendRedirect("success.jsp");
        } catch (SQLException e) {
            e.printStackTrace();
            response.sendRedirect("error.jsp");
        } finally {
            DBUtil.close(conn);
        }
    }
}

6. 实现数据删除

类似地，我们可以实现一个Servlet来处理用户数据的删除操作。假设我们通过用户ID来删除用户。

import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet("/deleteUser")
public class DeleteUserServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;

    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        int id = Integer.parseInt(request.getParameter("id"));

        Connection conn = null;
        PreparedStatement pstmt = null;

        try {
            conn = DBUtil.getConnection();
            String sql = "DELETE FROM users WHERE id = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, id);
            pstmt.executeUpdate();

            response.sendRedirect("success.jsp");
        } catch (SQLException e) {
            e.printStackTrace();
            response.sendRedirect("error.jsp");
        } finally {
            DBUtil.close(conn);
        }
    }
}

7. 创建JSP页面

最后，我们需要创建一些JSP页面来展示表单和处理结果。例如，addUser.jsp用于输入用户信息，success.jsp用于显示操作成功的消息，error.jsp用于显示错误信息。

<!-- addUser.jsp -->
<form action="addUser" method="post">
    Name: <input type="text" name="name"><br>
    Email: <input type="text" name="email"><br>
    <input type="submit" value="Add User">
</form>

<!-- success.jsp -->
<h1>Operation Successful!</h1>

<!-- error.jsp -->
<h1>An Error Occurred!</h1>

8. 部署和测试

将项目部署到Tomcat服务器上，启动服务器后，访问addUser.jsp页面，输入用户信息并提交表单。如果操作成功，页面将跳转到success.jsp；如果发生错误，页面将跳转到error.jsp。

9. 总结

通过以上步骤，我们实现了JavaWeb项目中MySQL数据库数据的添加和删除操作。JDBC是Java连接数据库的标准API，虽然在实际开发中我们可能会使用ORM框架（如Hibernate或MyBatis）来简化数据库操作，但理解JDBC的基本原理仍然是非常重要的。

希望本文对你理解JavaWeb中如何操作MySQL数据库有所帮助。如果你有任何问题或建议，欢迎在评论区留言。