//package com.muyu.breakdown.DTO;
//
//
//import com.muyu.breakdown.domain.Messages;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import java.sql.*;
//import java.util.*;
//
///**
// * @ Tool：IntelliJ IDEA
// * @ Author：CHX
// * @ Date：2024-09-18-15:00
// * @ Version：1.0
// * @ Description：数据库连接层
// * @author Lenovo
// */
//@Component
//public class MessageDTO {
//    private static final String DB_URL = "jdbc:mysql://106.54.193.225:3306/one";
//    private static final String USER = "root";
//    private static final String PASSWORD = "bawei2112A";
//
//    // 2. 建立数据库连接
//    Connection connection;
//    // 构造函数，初始化数据库连接
//    // 保存消息到数据库
//    public void saveMessage(Messages message) {
//        String sql = "INSERT INTO sys_messages (sender_id, receiver_id, content) VALUES (?, ?, ?)";
//        try {
//            Class.forName("com.mysql.cj.jdbc.Driver");
//        } catch (ClassNotFoundException e) {
//            throw new RuntimeException(e);
//        }
//        try {
//            connection = DriverManager.getConnection(DB_URL, USER, PASSWORD);
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//        try (PreparedStatement preparedStatement = connection.prepareStatement(sql)) {
//            preparedStatement.setInt(1, message.getSenderId());
//            preparedStatement.setInt(2, message.getReceiverId());
//            preparedStatement.setString(3, message.getContent());
//            // 执行添加操作
//            preparedStatement.executeUpdate();
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//        try {
//            connection.close();
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//    }
//
//    // 获取所有消息
//    public List<Messages> getAllMessages(int receiverId){
//        String sql = "SELECT * FROM sys_messages WHERE receiver_id = ?";
//        try {
//            Class.forName("com.mysql.cj.jdbc.Driver");
//        } catch (ClassNotFoundException e) {
//            throw new RuntimeException(e);
//        }
//        List<Messages> messages = new ArrayList<>();
//        try {
//            connection = DriverManager.getConnection(DB_URL, USER, PASSWORD);
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//        try (PreparedStatement preparedStatement = connection.prepareStatement(sql)) {
//            preparedStatement.setInt(1, receiverId);
//            // 执行查询操作
//            ResultSet rs = preparedStatement.executeQuery();
//            while (rs.next()) {
//                Messages message = new Messages(rs.getInt("sender_id"), receiverId, rs.getString("content"));
//
//                // 添加到消息列表
//                messages.add(message);
//            }
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//        try {
//            connection.close();
//        } catch (SQLException e) {
//            throw new RuntimeException(e);
//        }
//        // 返回消息列表
//        return messages;
//    }
//
//}
