java - 需要修改 java 时间戳以从数据库中获取最新记录

标签 java mysql jdbc timestamp

我编写了一个网络服务,负责向用户界面显示数据库中最新插入或更新的记录。

这是我的查询

String selectSQL = "SELECT id , VendorName , Item , updated_at , created_at  from Orders where updated_at > ? OR created_at > ?";

这是我的表结构

mysql> select * from Orders;
+-------+--------------+----------+---------------------+---------------------+
| id    | VendorName   | Item     | updated_at          | created_at          |
+-------+--------------+----------+---------------------+---------------------+
| 12345 | PoppyCounter | Chocltae | 2014-05-08 18:49:42 | 2014-05-08 18:49:42 |
+-------+--------------+----------+---------------------+---------------------+
1 row in set (0.00 sec)

我正在检查当前时间戳,如下所示

java.sql.Timestamp date = new java.sql.Timestamp(new java.util.Date().getTime());

如何让日期少于 1 分钟??

package com.serviceees;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;

import com.google.gson.Gson;

import dto.Orders;

@Path("/updates")
public class DBPollerService {
    @GET
    @Produces("application/json")
    public String getUpdates() {
        System.out.println("getUpdates called");
        String clientResponse = "Error";
        ArrayList<Orders> newOrdersList = new ArrayList<Orders>();  
        Gson gson = new Gson();
        try {

            try {
                Class.forName("com.mysql.jdbc.Driver");
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
            System.out.println("connection");
            Connection connection = null;
            PreparedStatement preparedStatement = null;
            String selectSQL = "SELECT id , VendorName , Item , updated_at , created_at  from Orders where updated_at > ? OR created_at > ?";
            try {
                connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "", "");
                while (true) {
                    System.out.println("Into while true");
                    try {

                        java.sql.Timestamp date = new java.sql.Timestamp(new java.util.Date().getTime());
                        preparedStatement = connection.prepareStatement(selectSQL);
                        preparedStatement.setTimestamp(1, date);
                        preparedStatement.setTimestamp(2, date);
                        ResultSet rs = preparedStatement.executeQuery();
                        while (rs.next()) {
                            Orders order = new Orders();
                            order.setId(rs.getInt(1));
                            order.setVendorName(rs.getString(2));
                            order.setItem(rs.getString(3));
                            newOrdersList.add(order);
                        }

                        Thread.sleep(3000);
                        clientResponse =    "jsonCallback(["+gson.toJson(newOrdersList)+"])";
                        return clientResponse;
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }

            } catch (SQLException e) {
                System.out.println("Connection Failed! Check output console");
                e.printStackTrace();

            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        clientResponse =    gson.toJson(newOrdersList); 
        System.out.println("clientResponse"+clientResponse);
        return clientResponse;
    }

}

提前致谢。

最佳答案

虽然这在技术上不是您问题的答案,但您可以或者修改您的 SQL 语句以简单地返回最新的行。在 MSSQL 语法中,它看起来像这样:

SELECT TOP 1 * 
FROM Orders
INNER JOIN (
    SELECT id, updated_at AS modified from Orders
    UNION
    SELECT id, created_at from Orders 
) AS whatever ON whatever.id = Orders.id
ORDER BY whatever.modified DESC

这将始终返回最后修改(如创建或更新)的行,并且不带任何参数。

关于java - 需要修改 java 时间戳以从数据库中获取最新记录,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23544602/

相关文章:

java - 用于更新特定用户属性的准备语句 - JDBC

oracle - 我可以在 Oracle 11gR2 数据库上使用 OJDBC7 吗?

java - 处理动态表/列名时如何防止SQL注入(inject)?

java - 如何使用 `adb` 仅为一个用户安装开发应用程序?

java - 在方法中传递 boolean 参数,但方法 boolean 变量仍然未使用

php - 尝试在 mac os mavericks 上使用 mysql、php 和 apache 连接到本地主机

mysql - 这是删除重复 MySQL 行的好解决方案吗?

java - 测试自定义插件 portlet : BeanLocatorException and Transaction roll-back for services testing

java - java中如何对数组进行排序?

php - 如何用准备好的语句更新两个表?