Hello, when using a DB2 LUW database, this change introduced a blocking issue. getObject("column", LocalDateTime.class) generates a NPE when the column value is null.

Because of this, tasks cannot be started, the TaskExecution object cannot be created. Before this change the TaskExecution object did a null check in the constructor on the data fields.

see:
a0fda4b#diff-e9a20e8dde96fa5498b9dc316343e3ab29058094f5dd59a25cc2b4cbb7d80b86L103

Below a small test class to demonstrate the problem:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.time.LocalDateTime;


public class DB2Test {

    public static void main(String[] args) {
        // Replace with your actual database connection details
        String dbUrl = "jdbc:db2://server.name:50012/DB";
        String dbUsername = "user";
        String dbPassword = "pass";

        var tableName = "TEST";

        String drop = "DROP TABLE IF EXISTS " + tableName;
        String create = "CREATE TABLE " + tableName + "  ( ID BIGINT, YOUR_TIMESTAMP_COLUMN TIMESTAMP(9) )";
        String insert1 = "INSERT INTO " + tableName + "( ID, YOUR_TIMESTAMP_COLUMN) VALUES ( 0,  current_timestamp )";
        String insert2 = "INSERT INTO " + tableName + "( ID ) VALUES ( 1 )";

        String query = "SELECT YOUR_TIMESTAMP_COLUMN FROM " + tableName;


        try (Connection connection = DriverManager.getConnection(dbUrl, dbUsername, dbPassword);
        ) {
            PreparedStatement dropStatement = connection.prepareStatement(drop);
            PreparedStatement createStatement = connection.prepareStatement(create);
            PreparedStatement insertStatement1 = connection.prepareStatement(insert1);
            PreparedStatement insertStatement2 = connection.prepareStatement(insert2);
            PreparedStatement queryStatement = connection.prepareStatement(query);


            dropStatement.executeUpdate();
            createStatement.executeUpdate();
            insertStatement1.executeUpdate();
            insertStatement2.executeUpdate();

            var resultSet = queryStatement.executeQuery();


            while (resultSet.next()) {

                System.out.println("------ ROW " + resultSet.getRow() + " -------");
                //via
                try {
                    LocalDateTime localDateTime = resultSet.getObject("YOUR_TIMESTAMP_COLUMN", LocalDateTime.class);
                    System.out.println("Successful retrieved LocalDateTime : " + localDateTime);
                } catch (Exception e) {
                    System.out.println("Unable to retrieve YOUR_TIMESTAMP_COLUMN via getObject(YOUR_TIMESTAMP_COLUMN, LocalDateTime.class)");
                    System.out.println("Error message: " + e.getMessage());
                }


                try {
                    var yourTimestampColumn = resultSet.getTimestamp("YOUR_TIMESTAMP_COLUMN");

                    java.util.Date dateFromTimestamp = (yourTimestampColumn != null) ? (java.util.Date) yourTimestampColumn.clone() : null;

                    System.out.println("Successful retrieved Date from Timestamp : " + dateFromTimestamp);
                } catch (Exception e) {
                    System.out.println("Unable to retrieve YOUR_TIMESTAMP_COLUMN via getTimestamp(YOUR_TIMESTAMP_COLUMN)");
                    System.out.println("Error message: " + e.getMessage());

                }

            }

        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("Error executing query: " + e.getMessage());
        }
    }
}

Output :

------ RECORD -------1
Successful retrieved LocalDateTime : 2023-12-22T08:16:50.674910
Successful retrieved Date from Timestamp : 2023-12-22 08:16:50.67491
------ RECORD -------2
Unable to retrieve YOUR_TIMESTAMP_COLUMN via getObject(YOUR_TIMESTAMP_COLUMN, LocalDateTime.class)
Error message: Cannot invoke "java.sql.Timestamp.toLocalDateTime()" because "" is null
Successful retrieved Date from Timestamp : null

Support Java 8 Dates in Task Execution #868

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions