Mysql存储java对象实例详解

MySQL是一种流行的关系型数据库，而Java是一种流行的编程语言。如果你正在使用Java编写应用程序，那么你可能需要在MySQL中存储Java对象实例。本文将详细介绍如何将Java对象存储到MySQL中的方法。

环境和实例准备

环境

• 操作系统：Windows 10
• Java版本：1.8
• MySQL版本：8.0

实例

我们将使用一个简单的Java类作为例子，该类保存人员的基本信息，包括姓名和年龄。

public class Person {
    private String name;
    private int age;

    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }

    public String getName() {
        return name;
    }

    public int getAge() {
        return age;
    }

    @Override
    public String toString() {
        return "Person{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

将Java对象存储到MySQL中

步骤1. 准备MySQL表

创建一个新表来保存Person对象。我们将使用以下命令：

CREATE TABLE `person` (
  `id` int NOT NULL AUTO_INCREMENT,
  `person_data` blob NOT NULL,
  PRIMARY KEY (`id`)
);

该命令将创建一个名为person的新表，其中包含两个列：id和person_data。person_data列是一个BLOB类型的列，用于存储Java对象的二进制数据。

步骤2. 实现序列化接口

Java对象需要实现Serializable接口才能被序列化。修改Person类，使其实现Serializable接口。

public class Person implements Serializable {
    // ...
}

步骤3. 将Java对象写入MySQL

在Java代码中，我们需要将Person对象转换为字节数组，并将其存储到MySQL数据库中。代码如下：

public static void writePersonToDatabase(Person person) throws SQLException, IOException {
    try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD)) {
        String sql = "INSERT INTO `person` (`person_data`) VALUES (?)";
        try (PreparedStatement stmt = conn.prepareStatement(sql)) {
            try (ByteArrayOutputStream out = new ByteArrayOutputStream();
                 ObjectOutputStream objOut = new ObjectOutputStream(out)) {
                objOut.writeObject(person);
                byte[] bytes = out.toByteArray();
                ByteArrayInputStream in = new ByteArrayInputStream(bytes);
                stmt.setBinaryStream(1, in, bytes.length);
                stmt.executeUpdate();
            }
        }
    }
}

该方法将Person对象序列化为字节数组，并将字节数组存储到MySQL数据库中。使用了Java的try-with-resources结构，确保资源能够被正确关闭。

步骤4. 从MySQL读取Java对象

我们可以使用以下代码从MySQL数据库中读取保存的Person对象：

public static Person readPersonFromDatabase(int id) throws SQLException, IOException, ClassNotFoundException {
    try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD)) {
        String sql = "SELECT `person_data` FROM `person` WHERE `id` = ?";
        try (PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setInt(1, id);
            try (ResultSet rs = stmt.executeQuery()) {
                while (rs.next()) {
                    byte[] bytes = rs.getBytes("person_data");
                    ByteArrayInputStream in = new ByteArrayInputStream(bytes);
                    try (ObjectInputStream objIn = new ObjectInputStream(in)) {
                        return (Person) objIn.readObject();
                    }
                }
            }
        }
    }
    return null;
}

该方法从MySQL数据库中读取二进制数据，反序列化为Person对象，并返回Person对象。同样使用了try-with-resources结构，确保资源能够被正确关闭。

示例

示例1：将Person对象写入MySQL并读取回来

Person person = new Person("John", 30);
writePersonToDatabase(person);
Person readPerson = readPersonFromDatabase(1);
System.out.println(readPerson);

该代码将创建一个Person对象person，然后将其写入MySQL数据库。接着，从MySQL数据库中读取person对象的二进制数据，并将其反序列化为Person对象readPerson。最后，输出readPerson对象的内容。

示例2：在MySQL中保存一个Java集合

List<Person> personList = new ArrayList<>();
personList.add(new Person("John", 30));
personList.add(new Person("Mike", 40));
personList.add(new Person("Amy", 25));

try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD)) {
    String sql = "INSERT INTO `person` (`person_data`) VALUES (?)";
    try (PreparedStatement stmt = conn.prepareStatement(sql)) {
        try (ByteArrayOutputStream out = new ByteArrayOutputStream();
             ObjectOutputStream objOut = new ObjectOutputStream(out)) {
            objOut.writeObject(personList);
            byte[] bytes = out.toByteArray();
            ByteArrayInputStream in = new ByteArrayInputStream(bytes);
            stmt.setBinaryStream(1, in, bytes.length);
            stmt.executeUpdate();
        }
    }
}

该代码将创建一个Person对象的集合personList，并将其序列化为字节数组。然后将字节数组存储到MySQL数据库中。注意这里的person_data列仍然是BLOB类型。

总结

本文介绍了如何将Java对象存储到MySQL数据库中。我们介绍了序列化和反序列化Java对象，以及如何将Java对象转换为字节数组，并存储到MySQL数据库中。同时提供了两个实例，方便读者理解实现细节。