JavaWeb如何连接数据库？教你快速实现表的增删查改！ |21xrx.com

JavaWeb如何连接数据库？教你快速实现表的增删查改！

2023-06-14 23:12:03 深夜i -- --

JavaWeb 连接数据库表的操作

如果你正在学习JavaWeb，那你一定不会错过连接数据库这个最基本的操作。连接数据库是Web开发中重要的一环，因为数据库是用来存储数据的，无论是网页还是桌面应用，都必须离不开它。本文将带你从头到尾完成JavaWeb连接数据库并对一张表进行增删查改操作。

在开始之前，你需要三个东西：

1. 数据库：MySQL、Oracle、SQL Server等。

2. 数据库连接工具：MySQL Workbench、Navicat等。

3. JavaWeb开发环境：Eclipse、IntelliJ IDEA等。

第一步：创建一个数据库表

在连接数据库之前，需要先创建一个表。这里以MySQL为例，使用MySQL Workbench创建一个简单的表，如下所示。


CREATE TABLE student (
id INT NOT NULL AUTO_INCREMENT,
name VARCHAR(20) NOT NULL,
age INT NOT NULL,
PRIMARY KEY (id)
);

此表名为“student”，包含“id”、“name”、“age”三个字段，其中“id”为主键。现在我们已经准备好了一个表，接下来就可以开始连接数据库了。

第二步：导入MySQL驱动

Java连接MySQL需要使用MySQL驱动程序，这里我们使用MySQL Connector/J。将下载的“mysql-connector-java-x.xx.xx.jar”文件添加到JavaWeb项目的“/WEB-INF/lib”目录下。

第三步：编写Java代码

我们将在Java中编写以下内容：连接到MySQL数据库、获取连接、关闭连接、执行SQL语句等操作。这里提供了一个类，里面包含一个方法来创建表，并实现对其进行增删查改的操作。


import java.sql.*;
public class StudentJDBC {
  private static final String url = "jdbc:mysql://localhost:3306/test";
  private static final String user = "root";
  private static final String password = "root1234";
  public static void main(String[] args) {
    createTable();
    insert("张三", 18);
    insert("李四", 19);
    insert("王五", 20);
    update(2, "李小四", 20);
    delete(3);
    selectAll();
  }
  public static void createTable() {
    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection conn = DriverManager.getConnection(url, user, password);
      Statement statement = conn.createStatement();
      String sql = "CREATE TABLE student (id INT NOT NULL AUTO_INCREMENT, name VARCHAR(20) NOT NULL, age INT NOT NULL, PRIMARY KEY (id));";
      statement.executeUpdate(sql);
      statement.close();
      conn.close();
    } catch (Exception e) {
      System.out.println("创建表失败！");
      e.printStackTrace();
    }
    System.out.println("创建表成功！");
  }
  //插入操作
  public static void insert(String name, int age) {
    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection conn = DriverManager.getConnection(url, user, password);
      Statement statement = conn.createStatement();
      String sql = "INSERT INTO student(name, age) VALUES ('" + name + "'," + age + ")";
      statement.executeUpdate(sql);
      statement.close();
      conn.close();
    } catch (Exception e) {
      System.out.println("插入数据失败！");
      e.printStackTrace();
    }
    System.out.println("插入数据成功！");
  }
  //更新操作
  public static void update(int id, String name, int age) {
    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection conn = DriverManager.getConnection(url, user, password);
      Statement statement = conn.createStatement();
      String sql = "UPDATE student SET name = '" + name + "', age = " + age + " WHERE id = " + id;
      statement.executeUpdate(sql);
      statement.close();
      conn.close();
    } catch (Exception e) {
      System.out.println("更新数据失败！");
      e.printStackTrace();
    }
    System.out.println("更新数据成功！");
  }
  //删除操作
  public static void delete(int id) {
    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection conn = DriverManager.getConnection(url, user, password);
      Statement statement = conn.createStatement();
      String sql = "DELETE FROM student WHERE id = " + id;
      statement.executeUpdate(sql);
      statement.close();
      conn.close();
    } catch (Exception e) {
      System.out.println("删除数据失败！");
      e.printStackTrace();
    }
    System.out.println("删除数据成功！");
  }
  //查询数据
  public static void selectAll() {
    try {
      Class.forName("com.mysql.jdbc.Driver");
      Connection conn = DriverManager.getConnection(url, user, password);
      Statement statement = conn.createStatement();
      String sql = "SELECT * FROM student";
      ResultSet rs = statement.executeQuery(sql);
      System.out.println("id\tname\tage");
      while (rs.next()) {
        int id = rs.getInt("id");
        String name = rs.getString("name");
        int age = rs.getInt("age");
        System.out.println(id + "\t" + name + "\t" + age);
      }
      rs.close();
      statement.close();
      conn.close();
    } catch (Exception e) {
      System.out.println("查询数据失败！");
      e.printStackTrace();
    }
    System.out.println("查询数据成功！");
  }
}

第四步：启动Tomcat服务器

在本地计算机上安装Tomcat服务器。在Eclipse中创建Web项目，然后将以上Java代码添加到项目中的Servlet，然后启动Tomcat服务器。

第五步：运行结果

在浏览器中输入“http://localhost:8080/项目名称/Servlet名称”即可运行，项目名称和Servlet名称可以在Eclipse中进行修改。运行结果如下所示。

创建表成功！插入数据成功！插入数据成功！插入数据成功！更新数据成功！删除数据成功！ id name age 1 张三 18 2 李小四 20 查询数据成功！

本文实现了JavaWeb连接数据库对一张表进行增删查改操作。

上一篇: idea打包java可执行jar包

下一篇: 学习C语言和C++ 哪个更适合就业

评论区

()

相似文章