21xrx.com
2024-09-17 03:35:21 Tuesday
登录
文章检索 我的文章 写文章
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连接数据库对一张表进行增删查改操作。

  
  

评论区

{{item['qq_nickname']}}
()
回复
回复
    相似文章