21xrx.com
2024-12-23 02:03:43 Monday
登录
文章检索 我的文章 写文章
我最近学习了如何使用Java语言来实现MySQL数据库的增删改查操作
2023-06-11 07:04:20 深夜i     --     --

我最近学习了如何使用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编程语言来操作数据库。

  
  

评论区

{{item['qq_nickname']}}
()
回复
回复