21xrx.com
2025-04-09 10:06:14 Wednesday
文章检索 我的文章 写文章
我最近学习了如何使用Java语言来实现MySQL数据库的增删改查操作
2023-06-11 07:04:20 深夜i     9     0

我最近学习了如何使用Java语言来实现MySQL数据库的增删改查操作。在这个过程中,我成功地编写了一些示例代码,让我更好地理解了这些概念。下面是我学习过程中的关键词和例子,以及相应的代码:

1. 连接MySQL数据库

要连接MySQL数据库,我使用了Java中的JDBC(Java Database Connectivity)接口。我首先需要下载并安装MySQL Connector/J,这是MySQL官方提供的JDBC驱动程序。然后我编写了以下代码:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class MySQLConnection {
  private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
  private static final String USERNAME = "root";
  private static final String PASSWORD = "password";
  public Connection getConnection() {
    Connection connection = null;
    try {
      connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
      System.out.println("Connected to the MySQL database successfully.");
    } catch (SQLException e) {
      System.out.println("Error connecting to the MySQL database.");
      e.printStackTrace();
    }
    return connection;
  }
}

这段代码创建了一个名为`MySQLConnection`的类,其中定义了连接MySQL所需要的URL、用户名和密码。然后,在`getConnection()`方法中,我们使用DriverManager类从MySQL数据库获取连接。如果连接成功,将会输出一条成功连接的消息。如果连接失败,则会输出错误信息并打印出根本原因。在主方法中,我们只需要创建一个`MySQLConnection`对象,并调用它的`getConnection()`方法即可连接到MySQL数据库。

2. 增加数据

一旦我们成功地连接到了MySQL数据库,就可以开始执行增加数据的操作了。以下是我的示例代码:

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class InsertData {
  public static void main(String[] args) {
    Scanner scanner = new Scanner(System.in);
    Connection connection = new MySQLConnection().getConnection();
    String sql = "INSERT INTO students (id, name, age) VALUES (?, ?, ?)";
    try {
      PreparedStatement statement = connection.prepareStatement(sql);
      System.out.print("Enter Student ID: ");
      statement.setInt(1, scanner.nextInt());
      System.out.print("Enter Student Name: ");
      statement.setString(2, scanner.next());
      System.out.print("Enter Student Age: ");
      statement.setInt(3, scanner.nextInt());
      
      int rowsInserted = statement.executeUpdate();
      if (rowsInserted > 0) {
        System.out.println("A new student was added successfully!");
      } else {
        System.out.println("Something went wrong. Please try again.");
      }
    } catch (SQLException e) {
      System.out.println("Error inserting data into the students table.");
      e.printStackTrace();
    }
  }
}

这段代码通过JDBC API向一个名为`students`的表中插入数据。在主方法中,我们使用`Scanner`类从控制台获取用户输入的学生ID、姓名和年龄,然后使用这些数据填充一个`PreparedStatement`对象,并使用`executeUpdate()`方法将其添加到数据库中。如果成功插入数据,将会输出一条成功的消息。否则,将会输出错误信息并打印出根本原因。

3. 更新数据

一旦我们成功地向MySQL数据库添加了数据,就可以开始执行更新数据的操作了。以下是我的示例代码:

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class UpdateData {
  public static void main(String[] args) {
    Scanner scanner = new Scanner(System.in);
    Connection connection = new MySQLConnection().getConnection();
    String sql = "UPDATE students SET age=? WHERE id=?";
    try {
      PreparedStatement statement = connection.prepareStatement(sql);
      System.out.print("Enter Student ID: ");
      statement.setInt(2, scanner.nextInt());
      System.out.print("Enter Updated Age: ");
      statement.setInt(1, scanner.nextInt());
      
      int rowsUpdated = statement.executeUpdate();
      if (rowsUpdated > 0) {
        System.out.println("Data updated successfully!");
      } else {
        System.out.println("Something went wrong. Please try again.");
      }
    } catch (SQLException e) {
      System.out.println("Error updating data in the students table.");
      e.printStackTrace();
    }
  }
}

这段代码使用JDBC API更新一个名为`students`的表中的数据。在主方法中,我们使用`Scanner`类从控制台获取要更新的学生ID和新的年龄。然后,我们使用`PreparedStatement`对象来执行更新操作。如果成功更新数据,将会输出一条成功的消息。否则,将会输出错误信息并打印出根本原因。

4. 删除数据

一旦我们成功地向MySQL数据库添加了数据并更新了它,就可以开始执行删除数据的操作了。以下是我的示例代码:

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class DeleteData {
  public static void main(String[] args) {
    Scanner scanner = new Scanner(System.in);
    Connection connection = new MySQLConnection().getConnection();
    String sql = "DELETE FROM students WHERE id=?";
    try {
      PreparedStatement statement = connection.prepareStatement(sql);
      System.out.print("Enter Student ID: ");
      statement.setInt(1, scanner.nextInt());
      
      int rowsDeleted = statement.executeUpdate();
      if (rowsDeleted > 0) {
        System.out.println("Data deleted successfully!");
      } else {
        System.out.println("Something went wrong. Please try again.");
      }
    } catch (SQLException e) {
      System.out.println("Error deleting data from the students table.");
      e.printStackTrace();
    }
  }
}

这段代码使用JDBC API从一个名为`students`的表中删除数据。在主方法中,我们使用`Scanner`类从控制台获取要删除的学生ID。然后,我们使用`PreparedStatement`对象来执行删除操作。如果成功删除数据,将会输出一条成功的消息。否则,将会输出错误信息并打印出根本原因。

综上所述,我学习了如何使用Java语言通过JDBC接口来实现MySQL数据库的增删改查操作,并展示了具体的代码实现。通过这个过程,我更好地理解了这些概念,并掌握了如何使用Java编程语言来操作数据库。

  
  

评论区

请求出错了