java - 为什么 jdbi 以函数为参数绑定(bind)失败

Question

我正在开发一个 API，它是用 Java 编写的，并使用我通过 jdbi 调用的 Oracle 数据库。我正在编写一个辅助函数，以允许我为列表中的每个项目绑定(bind)变量。但是，该列表并不相关——关键是我的函数采用查询、对象和回调函数(我计划使用 Class:getFoo)从对象中获取值。

tl;dr 如果返回的值为 null，则失败 - 但如果我直接绑定(bind) getFoo，即使为 null，它也能正常工作。为什么？

以下作品[1]:

public class Foo {
    private final String id;

    public Foo(String id) {
        this.id = id;
    }

    public String getId() {
        return this.id;
    }

    public static void main(String[] args) throws SQLException {
        // Setup DB connection
        PoolDataSource  pds = PoolDataSourceFactory.getPoolDataSource();
        pds.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
        pds.setURL("jdbc:oracle:thin:@MY_IP:MY_PORT:MY_INSTANCE_NAME");
        pds.setUser(MY_USER);
        pds.setPassword(MY_PASSWORD);
        Jdbi jdbi = Jdbi.create(pds);

        // Create object
        Foo foo = new Foo("bar");
        try {
            // Call DB
            String val = jdbi.withHandle((handle) -> {
                Query query = handle.createQuery("select :foo foo from dual");
                query.bind("foo", foo.getId());                 
                return query.mapTo(String.class).findOnly();
            });
            System.out.println("Value: " + val);            
        } catch( Exception e) {
            System.out.println(e.getMessage());
            e.printStackTrace();
        }
    }

    public static <T> SqlStatement<?> bindDataWith(SqlStatement<?> query, Foo value, String paramName, Function<Foo, ?> paramFn) {
        return query.bind(paramName, paramFn.apply(value));
    }

}

如果我替换它也有效

query.bind("foo", foo.getId());

与

Foo.bindDataWith(query, foo, "foo", Foo::getId);

但是，如果我替换

Foo foo = new Foo("bar");

与

Foo foo = new Foo(null);

(换句话说，如果 getter 返回空字符串)那么 query.bind("foo", foo.getId()); 变体仍然有效，但 Foo. bindDataWith(query, foo, "foo", Foo::getId); 失败!

我不明白为什么。在这两种情况下，它都应该在 foo 上调用 getId()，它是一个字符串(尽管为 null)。 谁能解释为什么这不起作用？

不工作的完整版本是:

public class Foo {
    private final String id;

    public Foo(String id) {
        this.id = id;
    }

    public String getId() {
        return this.id;
    }

    public static void main(String[] args) throws SQLException {
        // Setup DB connection
        PoolDataSource  pds = PoolDataSourceFactory.getPoolDataSource();
        pds.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
        pds.setURL("jdbc:oracle:thin:@MY_IP:MY_PORT:MY_INSTANCE_NAME");
        pds.setUser(MY_USER);
        pds.setPassword(MY_PASSWORD);
        Jdbi jdbi = Jdbi.create(pds);

        // Create object
        Foo foo = new Foo(null);
        try {
            // Call DB
            String val = jdbi.withHandle((handle) -> {
                Query query = handle.createQuery("select :foo foo from dual");
                Foo.bindDataWith(query, foo, "foo", Foo::getId);
                return query.mapTo(String.class).findOnly();
            });
            System.out.println("Value: " + val);            
        } catch( Exception e) {
            System.out.println(e.getMessage());
            e.printStackTrace();
        }
    }

    public static <T> SqlStatement<?> bindDataWith(SqlStatement<?> query, Foo value, String paramName, Function<Foo, ?> paramFn) {
        return query.bind(paramName, paramFn.apply(value));
    }

}

控制台输出错误是

Exception while binding named parameter 'foo' [statement:"select :foo foo from dual", rewritten:"select :foo foo from dual", parsed:"ParsedSql{sql='select ? foo from dual', parameters=ParsedParameters{positional=false, parameterNames=[foo]}}", arguments:{ positional:{}, named:{foo:NULL}, finder:[]}]
org.jdbi.v3.core.statement.UnableToCreateStatementException: Exception while binding named parameter 'foo' [statement:"select :foo foo from dual", rewritten:"select :foo foo from dual", parsed:"ParsedSql{sql='select ? foo from dual', parameters=ParsedParameters{positional=false, parameterNames=[foo]}}", arguments:{ positional:{}, named:{foo:NULL}, finder:[]}]
    at org.jdbi.v3.core.statement.ArgumentBinder.bindNamed(ArgumentBinder.java:57)
    at org.jdbi.v3.core.statement.ArgumentBinder.bind(ArgumentBinder.java:26)
    at org.jdbi.v3.core.statement.SqlStatement.internalExecute(SqlStatement.java:1378)
    at org.jdbi.v3.core.result.ResultProducers.lambda$getResultSet$2(ResultProducers.java:59)
    at org.jdbi.v3.core.result.ResultIterable.lambda$of$0(ResultIterable.java:53)
    at org.jdbi.v3.core.result.ResultIterable.findOnly(ResultIterable.java:97)
    at com.carus.api.bookings.actions.Foo.lambda$0(Foo.java:41)
    at org.jdbi.v3.core.Jdbi.withHandle(Jdbi.java:340)
    at com.carus.api.bookings.actions.Foo.main(Foo.java:37)
Caused by: java.sql.SQLException: Invalid column type: 1111
    at oracle.jdbc.driver.OracleStatement.getInternalType(OracleStatement.java:3978)
    at oracle.jdbc.driver.OraclePreparedStatement.setNullCritical(OraclePreparedStatement.java:4472)
    at oracle.jdbc.driver.OraclePreparedStatement.setNull(OraclePreparedStatement.java:4456)
    at oracle.jdbc.driver.OraclePreparedStatementWrapper.setNull(OraclePreparedStatementWrapper.java:1008)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at oracle.ucp.jdbc.proxy.StatementProxyFactory.invoke(StatementProxyFactory.java:367)
    at oracle.ucp.jdbc.proxy.PreparedStatementProxyFactory.invoke(PreparedStatementProxyFactory.java:194)
    at com.sun.proxy.$Proxy3.setNull(Unknown Source)
    at org.jdbi.v3.core.argument.NullArgument.apply(NullArgument.java:39)
    at org.jdbi.v3.core.statement.ArgumentBinder.bindNamed(ArgumentBinder.java:54)
    ... 8 more

我在 java 8 中使用 jdbi 3 和 ojdbc8 (12.2.0.1)。

[1] 为了简单起见，我在这里将所有内容都放在一个类中。事实上，我的函数是一个泛型，它采用值列表和参数名称映射来获取函数。

Answer 1

在 JDBC(Jdbi 构建于其上)中，当您绑定(bind) null 时作为参数，JDBC 需要被告知 null 是什么数据类型是。在您的示例中，我们将使用 java.sql.Types.VARCHAR String 的数据类型.

Jdbi 的SqlStatement.bind()为许多不同的数据类型重载，包括 String .当您调用这些强类型重载之一时，如果您绑定(bind) null，Jdbi 知道要指定哪种 JDBC 数据类型。 ，并为您处理。

您尝试使用 bind("foo", foo.getId())方法直接起作用，因为编译器识别了 foo.getId()返回 String ，并为您调用正确的重载。

但是，您的辅助函数需要一个 Function<Foo,?> , 所以编译器解释 paramFn.apply()返回 Object , 不是 String .

bind(String, Object)如果你传入 null，variant 无法猜测你有什么数据类型。数据库供应商通常会接受某种数据类型作为空值的一种通配符——但是他们在允许的数据类型方面有所不同。

• Postgres 接受 Types.OTHER (Jdbi 默认使用)用于未类型化的空值。
• H2 接受 Types.NULL (这实际上不是类型常量)。
• 一些实验表明 Oracle JDBC 接受 Types.NULL还有

Jdbi 提供了一个配置设置，因此您可以告诉它使用无类型空值的内容。以下代码应该可以解决您的问题:

Jdbi jdbi = Jdbi.create(...);
jdbi.getConfig(Arguments.class)
    .setUntypedNullArgument(new NullArgument(Types.NULL));