Java MySQL 获取最后一行

Question

所以我的程序有问题。基本上到目前为止，该程序就像一个基于 MySQL 的聊天。它将消息存储在数据库中并读取它们。我在阅读方面遇到了问题。它现在所做的是每隔 5 秒重新读取数据库中的所有消息。我试图让它只读取新消息，但效果不太好。这是我的代码：

public static void readChat()
{
    try
    {
        MySQL.sqlConnect();
        try
        {
            Statement st = con.createStatement();
            ResultSet res = st.executeQuery("SELECT * FROM  table1");
            while (res.next())
            {
                if (lastLine < res.getInt("id"))
                {
                    String message = res.getString("message");
                    Gui.out.append(message + "\n");
                    lastLine = res.getInt("id");
                }
            }
        }
        catch (SQLException s)
        {   
            System.out.println("SQL code does not execute.");
        }
        MySQL.sqlDisconnect();
    }
    catch (Exception e)
    {
        e.printStackTrace();
    }
}

我不知道如何提高效率。执行它需要太长时间。如果 id 是 23，我什至看不到消息出现，因为它需要超过 5 秒的时间。我添加了

if (lastLine < res.getInt("id"))

和

lastLine = res.getInt("id");

，努力让它只读取新消息，但它没有按预期工作。我认为它仍然是逐行执行的，只是没有在聊天中显示。一定有一个更简单的方法。

编辑：好的，所以我解决了看不到消息的问题（我忘记删除每 5 秒清除聊天的代码部分）。但是发送消息的时间还是比较长，大概3-4秒吧？

Answer 1

试试这个，你会想知道:)

ResultSet res = st.executeQuery("SELECT * FROM  table1 where id > "+lastLine);

instad

ResultSet res = st.executeQuery("SELECT * FROM  table1");

并得到结果，而不需要 if

       while (res.next())
        {
                String message = res.getString("message");
                Gui.out.append(message + "\n");
                lastLine = res.getInt("id");
        }

当然要确保 id 字段上的索引

Answer 2

您可以只读取所需的行，当前您正在读取所有行，请尝试以下操作，

public static void readChat()
{
    try
    {
        MySQL.sqlConnect();
        try
        {
            Statement st = con.Preparestatment("SELECT * FROM  table1 where id > ?");
        st.setInt(0,lastLine);
            ResultSet res = st.executeQuery();
            while (res.next())
            {
                String message = res.getString("message");
                Gui.out.append(message + "\n");
                lastLine = res.getInt("id");
            }
        }
        catch (SQLException s)
        {   
            System.out.println("SQL code does not execute.");
        }
        MySQL.sqlDisconnect();
    }
    catch (Exception e)
    {
        e.printStackTrace();
    }
}

Answer 3

您仍然迭代所有结果。如果您有某种方法来存储消息发送的时间，即创建时间列，您可以尝试通过执行

ResultSet res = st.executeQuery("SELECT * FROM  table1 WHERE id = ? AND time > ?");

第一个 ? 操作来缩短返回的结果数量。是用户的 id，第二个？是最后阅读消息的时间。这是基于 id 是某个唯一用户 ID 的假设。

Answer 4

如何维护一个列表，在将其保存到数据库时向该列表添加新消息，然后从该列表中读取新消息并在 readChat() 末尾清除它？