21xrx.com
2025-06-30 23:03:41 Monday
登录
文章检索 我的文章 写文章
JavaWeb如何连接数据库?教你快速实现表的增删查改!
2023-06-14 23:12:03 深夜i     22     0
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连接数据库对一张表进行增删查改操作。

  
  

评论区

    相似文章